src/chrome/browser/chromeos/drive/fileapi/file_system_backend_delegate.cc

   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 "content/public/browser/browser_thread.h"
  16 #include "webkit/browser/blob/file_stream_reader.h"
  17 #include "webkit/browser/fileapi/async_file_util.h"
  18 #include "webkit/browser/fileapi/file_system_context.h"
  19 #include "webkit/browser/fileapi/file_system_url.h"
  20
  21 using content::BrowserThread;
  22
  23 namespace drive {
  24
  25 FileSystemBackendDelegate::FileSystemBackendDelegate()
  26     : async_file_util_(new internal::AsyncFileUtil) {
  27 }
  28
  29 FileSystemBackendDelegate::~FileSystemBackendDelegate() {
  30 }
  31
  32 fileapi::AsyncFileUtil* FileSystemBackendDelegate::GetAsyncFileUtil(
  33     fileapi::FileSystemType type) {
  34   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
  35   DCHECK_EQ(fileapi::kFileSystemTypeDrive, type);
  36   return async_file_util_.get();
  37 }
  38
  39 scoped_ptr<webkit_blob::FileStreamReader>
  40 FileSystemBackendDelegate::CreateFileStreamReader(
  41     const fileapi::FileSystemURL& url,
  42     int64 offset,
  43     const base::Time& expected_modification_time,
  44     fileapi::FileSystemContext* context) {
  45   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
  46   DCHECK_EQ(fileapi::kFileSystemTypeDrive, url.type());
  47
  48   base::FilePath file_path = util::ExtractDrivePathFromFileSystemUrl(url);
  49   if (file_path.empty())
  50     return scoped_ptr<webkit_blob::FileStreamReader>();
  51
  52   return scoped_ptr<webkit_blob::FileStreamReader>(
  53       new internal::WebkitFileStreamReaderImpl(
  54           base::Bind(&fileapi_internal::GetFileSystemFromUrl, url),
  55           context->default_file_task_runner(),
  56           file_path, offset, expected_modification_time));
  57 }
  58
  59 scoped_ptr<fileapi::FileStreamWriter>
  60 FileSystemBackendDelegate::CreateFileStreamWriter(
  61     const fileapi::FileSystemURL& url,
  62     int64 offset,
  63     fileapi::FileSystemContext* context) {
  64   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
  65   DCHECK_EQ(fileapi::kFileSystemTypeDrive, url.type());
  66
  67   base::FilePath file_path = util::ExtractDrivePathFromFileSystemUrl(url);
  68   // Hosted documents don't support stream writer.
  69   if (file_path.empty() || util::HasGDocFileExtension(file_path))
  70     return scoped_ptr<fileapi::FileStreamWriter>();
  71
  72   return scoped_ptr<fileapi::FileStreamWriter>(
  73       new internal::WebkitFileStreamWriterImpl(
  74           base::Bind(&fileapi_internal::GetFileSystemFromUrl, url),
  75           context->default_file_task_runner(),file_path, offset));
  76 }
  77
  78 }  // namespace drive