file_system_backend_delegate.cc revision 5d1f7b1de12d16ceb2c938c56701a3e8bfa558f7 
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
21using content::BrowserThread;
22
23namespace drive {
24
25FileSystemBackendDelegate::FileSystemBackendDelegate()
26    : async_file_util_(new internal::AsyncFileUtil) {
27}
28
29FileSystemBackendDelegate::~FileSystemBackendDelegate() {
30}
31
32fileapi::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
39scoped_ptr<webkit_blob::FileStreamReader>
40FileSystemBackendDelegate::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
59scoped_ptr<fileapi::FileStreamWriter>
60FileSystemBackendDelegate::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
79