Support filesystem files from BlobURLRequestJob

chrome/browser/extensions/api/downloads/downloads_api_unittest.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 <algorithm>
 
 #include "base/file_util.h"
 #include "base/json/json_reader.h"
 #include "base/json/json_writer.h"
 #include "base/message_loop.h"
@@ skipping 604 matching lines @@
   }
 
  private:
   DownloadManager::DownloadVector* items_;
   DISALLOW_COPY_AND_ASSIGN(ScopedItemVectorCanceller);
 };
 
 class TestProtocolHandler : public net::URLRequestJobFactory::ProtocolHandler {
  public:
   explicit TestProtocolHandler(
-      webkit_blob::BlobStorageController* blob_storage_controller)
-      : blob_storage_controller_(blob_storage_controller) {}
+      webkit_blob::BlobStorageController* blob_storage_controller,
+      fileapi::FileSystemContext* file_system_context)
+      : blob_storage_controller_(blob_storage_controller),
+        file_system_context_(file_system_context) {}
 
   virtual ~TestProtocolHandler() {}
 
   virtual net::URLRequestJob* MaybeCreateJob(
       net::URLRequest* request,
       net::NetworkDelegate* network_delegate) const OVERRIDE {
     return new webkit_blob::BlobURLRequestJob(
         request,
         network_delegate,
         blob_storage_controller_->GetBlobDataFromUrl(request->url()),
+        file_system_context_,
         base::MessageLoopProxy::current());
   }
 
  private:
   webkit_blob::BlobStorageController* const blob_storage_controller_;
+  fileapi::FileSystemContext* const file_system_context_;
 
   DISALLOW_COPY_AND_ASSIGN(TestProtocolHandler);
 };
 
 class TestURLRequestContext : public net::URLRequestContext {
  public:
-  TestURLRequestContext()
+  explicit TestURLRequestContext(
+      fileapi::FileSystemContext* file_system_context)
       : blob_storage_controller_(new webkit_blob::BlobStorageController) {
     // Job factory owns the protocol handler.
     job_factory_.SetProtocolHandler(
-        "blob", new TestProtocolHandler(blob_storage_controller_.get()));
+        "blob", new TestProtocolHandler(blob_storage_controller_.get(),
+                                        file_system_context));
     set_job_factory(&job_factory_);
   }
 
   virtual ~TestURLRequestContext() {}
 
   webkit_blob::BlobStorageController* blob_storage_controller() const {
     return blob_storage_controller_.get();
   }
 
  private:
@@ skipping 69 matching lines @@
     CHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
     operation()->CreateFile(fileapi::FileSystemURL(GURL(root_ + filename_)),
         kExclusive, base::Bind(
             &HTML5FileWriter::CreateFileCallback, base::Unretained(this)));
   }
 
   void CreateFileCallback(base::PlatformFileError result) {
     CHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
     CHECK_EQ(base::PLATFORM_FILE_OK, result);
     blob_data_->AppendData(payload_);
-    url_request_context_.reset(new TestURLRequestContext());
+    url_request_context_.reset(new TestURLRequestContext(fs_));
     url_request_context_->blob_storage_controller()->AddFinishedBlob(
         blob_url(), blob_data_);
     operation()->Write(
         url_request_context_.get(),
         fileapi::FileSystemURL(GURL(root_ + filename_)),
         blob_url(),
         0,  // offset
         base::Bind(&HTML5FileWriter::WriteCallback, base::Unretained(this)));
   }
 
@@ skipping 1323 matching lines @@
                           "  \"state\": {"
                           "    \"previous\": \"in_progress\","
                           "    \"current\": \"complete\"}}]",
                           result_id,
                           GetFilename("on_record.txt.crdownload").c_str(),
                           GetFilename("on_record.txt").c_str())));
   std::string disk_data;
   EXPECT_TRUE(file_util::ReadFileToString(item->GetFullPath(), &disk_data));
   EXPECT_STREQ(kPayloadData, disk_data.c_str());
 }