Chromium Blob hacking

chrome/browser/sync_file_system/local/canned_syncable_file_system.cc

 // Copyright 2013 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 "chrome/browser/sync_file_system/local/canned_syncable_file_system.h"
 
 #include <algorithm>
 #include <iterator>
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/file_util.h"
+#include "base/guid.h"
 #include "base/message_loop/message_loop_proxy.h"
 #include "base/run_loop.h"
 #include "base/single_thread_task_runner.h"
 #include "base/task_runner_util.h"
 #include "chrome/browser/sync_file_system/local/local_file_change_tracker.h"
 #include "chrome/browser/sync_file_system/local/local_file_sync_context.h"
 #include "chrome/browser/sync_file_system/local/sync_file_system_backend.h"
 #include "chrome/browser/sync_file_system/syncable_file_system_util.h"
 #include "testing/gtest/include/gtest/gtest.h"
 #include "webkit/browser/blob/mock_blob_url_request_context.h"
@@ skipping 117 matching lines @@
   std::copy(entries.begin(), entries.end(), std::back_inserter(*entries_out));
 
   if (!has_more)
     callback.Run(error);
 }
 
 class WriteHelper {
  public:
   WriteHelper() : bytes_written_(0) {}
   WriteHelper(MockBlobURLRequestContext* request_context,
-              const GURL& blob_url,
               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,
+                                      base::GenerateGUID(),
+                                      blob_data)) {
+  }
 
   ~WriteHelper() {
     if (request_context_) {
       base::MessageLoop::current()->DeleteSoon(FROM_HERE,
                                                request_context_.release());
     }
   }
 
+  ScopedTextBlob* scoped_text_blob() const { return blob_data_.get(); }
+
   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));
   }
@@ skipping 268 matching lines @@
       io_task_runner_.get(),
       FROM_HERE,
       base::Bind(&CannedSyncableFileSystem::DoReadDirectory,
           base::Unretained(this),
           url,
           entries));
 }
 
 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_.get(),
                             FROM_HERE,
                             base::Bind(&CannedSyncableFileSystem::DoWrite,
                                        base::Unretained(this),
                                        url_request_context,
                                        url,
-                                       blob_url));
+                                       base::Passed(&blob_data_handle)));
 }
 
 int64 CannedSyncableFileSystem::WriteString(
     const FileSystemURL& url, const std::string& data) {
   return RunOnThread<int64>(io_task_runner_.get(),
                             FROM_HERE,
                             base::Bind(&CannedSyncableFileSystem::DoWriteString,
                                        base::Unretained(this),
                                        url,
                                        data));
@@ skipping 150 matching lines @@
     const FileSystemURL& url,
     FileEntryList* entries,
     const StatusCallback& callback) {
   EXPECT_TRUE(is_filesystem_opened_);
   operation_runner()->ReadDirectory(
       url, base::Bind(&OnReadDirectory, entries, 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;
-  operation_runner()->Write(url_request_context, url, blob_url, 0,
+  operation_runner()->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_.get()));
-  const GURL blob_url(std::string("blob:") + data);
-  WriteHelper* helper = new WriteHelper(url_request_context, blob_url, data);
-  operation_runner()->Write(url_request_context, url, blob_url, 0,
+  WriteHelper* helper = new WriteHelper(url_request_context, data);
+  operation_runner()->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;
   base::MessageLoop::current()->Quit();
 }
 
 void CannedSyncableFileSystem::InitializeSyncStatusObserver() {
   ASSERT_TRUE(io_task_runner_->RunsTasksOnCurrentThread());
   backend()->sync_context()->sync_status()->AddObserver(this);
 }
 
 }  // namespace sync_file_system