file_system_backend_delegate.cc revision 03b57e008b61dfcb1fbad3aea950ae0e001748b0 
1// Copyright 2014 The Chromium Authors. All rights reserved.
2// Use of this source code is governed by a BSD-style license that can be
3// found in the LICENSE file.
4
5#include "chrome/browser/chromeos/drive/fileapi/file_system_backend_delegate.h"
6
7#include "base/bind.h"
8#include "base/files/file_path.h"
9#include "base/memory/scoped_ptr.h"
10#include "chrome/browser/chromeos/drive/file_system_util.h"
11#include "chrome/browser/chromeos/drive/fileapi/async_file_util.h"
12#include "chrome/browser/chromeos/drive/fileapi/fileapi_worker.h"
13#include "chrome/browser/chromeos/drive/fileapi/webkit_file_stream_reader_impl.h"
14#include "chrome/browser/chromeos/drive/fileapi/webkit_file_stream_writer_impl.h"
15#include "chrome/browser/drive/drive_api_util.h"
16#include "content/public/browser/browser_thread.h"
17#include "webkit/browser/blob/file_stream_reader.h"
18#include "webkit/browser/fileapi/async_file_util.h"
19#include "webkit/browser/fileapi/file_system_context.h"
20#include "webkit/browser/fileapi/file_system_url.h"
21
22using content::BrowserThread;
23
24namespace drive {
25
26FileSystemBackendDelegate::FileSystemBackendDelegate()
27    : async_file_util_(new internal::AsyncFileUtil) {
28}
29
30FileSystemBackendDelegate::~FileSystemBackendDelegate() {
31}
32
33storage::AsyncFileUtil* FileSystemBackendDelegate::GetAsyncFileUtil(
34    storage::FileSystemType type) {
35  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
36  DCHECK_EQ(storage::kFileSystemTypeDrive, type);
37  return async_file_util_.get();
38}
39
40scoped_ptr<storage::FileStreamReader>
41FileSystemBackendDelegate::CreateFileStreamReader(
42    const storage::FileSystemURL& url,
43    int64 offset,
44    const base::Time& expected_modification_time,
45    storage::FileSystemContext* context) {
46  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
47  DCHECK_EQ(storage::kFileSystemTypeDrive, url.type());
48
49  base::FilePath file_path = util::ExtractDrivePathFromFileSystemUrl(url);
50  if (file_path.empty())
51    return scoped_ptr<storage::FileStreamReader>();
52
53  return scoped_ptr<storage::FileStreamReader>(
54      new internal::WebkitFileStreamReaderImpl(
55          base::Bind(&fileapi_internal::GetFileSystemFromUrl, url),
56          context->default_file_task_runner(),
57          file_path,
58          offset,
59          expected_modification_time));
60}
61
62scoped_ptr<storage::FileStreamWriter>
63FileSystemBackendDelegate::CreateFileStreamWriter(
64    const storage::FileSystemURL& url,
65    int64 offset,
66    storage::FileSystemContext* context) {
67  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
68  DCHECK_EQ(storage::kFileSystemTypeDrive, url.type());
69
70  base::FilePath file_path = util::ExtractDrivePathFromFileSystemUrl(url);
71  // Hosted documents don't support stream writer.
72  if (file_path.empty() || util::HasHostedDocumentExtension(file_path))
73    return scoped_ptr<storage::FileStreamWriter>();
74
75  return scoped_ptr<storage::FileStreamWriter>(
76      new internal::WebkitFileStreamWriterImpl(
77          base::Bind(&fileapi_internal::GetFileSystemFromUrl, url),
78          context->default_file_task_runner(),
79          file_path,
80          offset));
81}
82
83}  // namespace drive
84