********** Content tests with blob hacking.

webkit/fileapi/syncable/canned_syncable_file_system.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "webkit/fileapi/syncable/canned_syncable_file_system.h"
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/file_util.h"
 #include "base/message_loop_proxy.h"
 #include "base/run_loop.h"
 #include "base/single_thread_task_runner.h"
 #include "base/task_runner_util.h"
 #include "testing/gtest/include/gtest/gtest.h"
+#include "webkit/blob/blob_storage_context.h"
 #include "webkit/blob/mock_blob_url_request_context.h"
 #include "webkit/fileapi/external_mount_points.h"
 #include "webkit/fileapi/file_system_context.h"
 #include "webkit/fileapi/file_system_operation_context.h"
 #include "webkit/fileapi/file_system_task_runners.h"
 #include "webkit/fileapi/local_file_system_operation.h"
 #include "webkit/fileapi/mock_file_system_options.h"
 #include "webkit/fileapi/sandbox_mount_point_provider.h"
 #include "webkit/fileapi/syncable/local_file_change_tracker.h"
 #include "webkit/fileapi/syncable/local_file_sync_context.h"
@@ skipping 92 matching lines @@
   DCHECK(platform_path_out);
   *file_info_out = file_info;
   *platform_path_out = platform_path;
   callback.Run(result);
 }
 
 class WriteHelper {
  public:
   WriteHelper() : bytes_written_(0) {}
   WriteHelper(MockBlobURLRequestContext* request_context,
-              const GURL& blob_url,
+              const std::string& blob_id,
               const std::string& blob_data)
       : bytes_written_(0),
         request_context_(request_context),
-        blob_data_(new ScopedTextBlob(*request_context, blob_url, blob_data)) {}
+        blob_data_(new ScopedTextBlob(*request_context, blob_id, blob_data)) {}
 
   ~WriteHelper() {
     if (request_context_)
       MessageLoop::current()->DeleteSoon(FROM_HERE, request_context_.release());
   }
 
   void DidWrite(const base::Callback<void(int64 result)>& completion_callback,
                 PlatformFileError error, int64 bytes, bool complete) {
     if (error == base::PLATFORM_FILE_OK) {
       bytes_written_ += bytes;
       if (!complete)
         return;
     }
     completion_callback.Run(error == base::PLATFORM_FILE_OK
                             ? bytes_written_ : static_cast<int64>(error));
   }
 
+  ScopedTextBlob* scoped_text_blob() const { return blob_data_.get(); }
+
  private:
   int64 bytes_written_;
   scoped_ptr<MockBlobURLRequestContext> request_context_;
   scoped_ptr<ScopedTextBlob> blob_data_;
 
   DISALLOW_COPY_AND_ASSIGN(WriteHelper);
 };
 
 void DidGetUsageAndQuota(const quota::StatusCallback& callback,
                          int64* usage_out, int64* quota_out,
@@ skipping 223 matching lines @@
     base::FilePath* platform_path) {
   return RunOnThread<PlatformFileError>(
       io_task_runner_,
       FROM_HERE,
       base::Bind(&CannedSyncableFileSystem::DoGetMetadata,
                  base::Unretained(this), url, info, platform_path));
 }
 
 int64 CannedSyncableFileSystem::Write(
     net::URLRequestContext* url_request_context,
-    const FileSystemURL& url, const GURL& blob_url) {
+    const FileSystemURL& url, scoped_ptr<webkit_blob::BlobDataHandle> blob_data_handle) {
   return RunOnThread<int64>(
       io_task_runner_,
       FROM_HERE,
       base::Bind(&CannedSyncableFileSystem::DoWrite,
-                 base::Unretained(this), url_request_context, url, blob_url));
+                 base::Unretained(this), url_request_context, url, base::Passed(&blob_data_handle)));
 }
 
 int64 CannedSyncableFileSystem::WriteString(
     const FileSystemURL& url, const std::string& data) {
   return RunOnThread<int64>(
       io_task_runner_,
       FROM_HERE,
       base::Bind(&CannedSyncableFileSystem::DoWriteString,
                  base::Unretained(this), url, data));
 }
@@ skipping 138 matching lines @@
     base::PlatformFileInfo* info,
     base::FilePath* platform_path,
     const StatusCallback& callback) {
   EXPECT_TRUE(is_filesystem_opened_);
   NewOperation()->GetMetadata(
       url, base::Bind(&OnGetMetadata, info, platform_path, callback));
 }
 
 void CannedSyncableFileSystem::DoWrite(
     net::URLRequestContext* url_request_context,
-    const FileSystemURL& url, const GURL& blob_url,
+    const FileSystemURL& url,
+    scoped_ptr<webkit_blob::BlobDataHandle> blob_data_handle,
     const WriteCallback& callback) {
   EXPECT_TRUE(is_filesystem_opened_);
   WriteHelper* helper = new WriteHelper;
-  NewOperation()->Write(url_request_context, url, blob_url, 0,
+  NewOperation()->Write(url_request_context, url, blob_data_handle.Pass(), 0,
                         base::Bind(&WriteHelper::DidWrite,
                                    base::Owned(helper), callback));
 }
 
 void CannedSyncableFileSystem::DoWriteString(
     const FileSystemURL& url,
     const std::string& data,
     const WriteCallback& callback) {
   MockBlobURLRequestContext* url_request_context(
       new MockBlobURLRequestContext(file_system_context_));
-  const GURL blob_url(std::string("blob:") + data);
-  WriteHelper* helper = new WriteHelper(url_request_context, blob_url, data);
-  NewOperation()->Write(url_request_context, url, blob_url, 0,
+  const std::string blob_id(std::string("blob:") + data);
+  WriteHelper* helper = new WriteHelper(url_request_context, blob_id, data);
+  NewOperation()->Write(url_request_context, url,
+                        helper->scoped_text_blob()->GetBlobDataHandle(), 0,
                         base::Bind(&WriteHelper::DidWrite,
                                    base::Owned(helper), callback));
 }
 
 void CannedSyncableFileSystem::DoGetUsageAndQuota(
     int64* usage,
     int64* quota,
     const quota::StatusCallback& callback) {
   quota_manager_->GetUsageAndQuota(
       origin_, storage_type(),
@@ skipping 13 matching lines @@
   sync_status_ = status;
   MessageLoop::current()->Quit();
 }
 
 void CannedSyncableFileSystem::InitializeSyncStatusObserver() {
   ASSERT_TRUE(io_task_runner_->RunsTasksOnCurrentThread());
   file_system_context_->sync_context()->sync_status()->AddObserver(this);
 }
 
 }  // namespace sync_file_system