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