Start of Chrome-side plumbing for ServiceWorker fetch

content/browser/service_worker/service_worker_browsertest.cc

 // Copyright 2014 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 "base/bind.h"
 #include "base/callback.h"
 #include "base/command_line.h"
 #include "base/run_loop.h"
 #include "content/browser/service_worker/embedded_worker_instance.h"
 #include "content/browser/service_worker/embedded_worker_registry.h"
@@ skipping 213 matching lines @@
     AssociateRendererProcessToWorker(version_->embedded_worker());
   }
 
   void StartOnIOThread(const base::Closure& done,
                        ServiceWorkerStatusCode* result) {
     ASSERT_TRUE(BrowserThread::CurrentlyOn(BrowserThread::IO));
     version_->StartWorker(CreateReceiver(BrowserThread::UI, done, result));
   }
 
   void InstallOnIOThread(const base::Closure& done,
                         ServiceWorkerStatusCode* result) {

[nhiroki, 2014/02/14 09:03:21]

indent-nit.

[falken, 2014/02/19 05:32:19]

Done.

     ASSERT_TRUE(BrowserThread::CurrentlyOn(BrowserThread::IO));
     version_->DispatchInstallEvent(
         -1, CreateReceiver(BrowserThread::UI, done, result));
   }
 
+  void FetchOnIOThread(const base::Closure& done,
+                        ServiceWorkerStatusCode* result) {

[nhiroki, 2014/02/14 09:03:21]

ditto.

[falken, 2014/02/19 05:32:19]

Done.

+    ASSERT_TRUE(BrowserThread::CurrentlyOn(BrowserThread::IO));
+    ServiceWorkerFetchRequest request(
+        embedded_test_server()->GetURL("/service_worker/empty.html"),
+        "GET",
+        std::map<std::string, std::string>());
+    // TODO(falken): Actually receive and test the ServiceWorkerFetchResponse.
+    version_->DispatchFetchEvent(
+        request, CreateReceiver(BrowserThread::UI, done, result));
+  }
+
+
   void StopOnIOThread(const base::Closure& done,
                       ServiceWorkerStatusCode* result) {
     ASSERT_TRUE(version_);
     version_->StopWorker(CreateReceiver(BrowserThread::UI, done, result));
   }
 
  protected:
   int64 next_registration_id_;
   scoped_refptr<ServiceWorkerRegistration> registration_;
   scoped_refptr<ServiceWorkerVersion> version_;
@@ skipping 68 matching lines @@
   InstallTestHelper("/service_worker/worker_install_fulfilled.js");
 }
 
 IN_PROC_BROWSER_TEST_F(ServiceWorkerVersionBrowserTest,
                        InstallWithWaitUntil_Rejected) {
   // TODO(kinuko): This should also report back an error, but we
   // don't have plumbing for it yet.
   InstallTestHelper("/service_worker/worker_install_rejected.js");
 }
 
+IN_PROC_BROWSER_TEST_F(ServiceWorkerVersionBrowserTest, Fetch) {
+  RunOnIOThread(base::Bind(&self::SetUpRegistrationOnIOThread, this,
+                           "/service_worker/worker.js"));
+
+  ServiceWorkerStatusCode status = SERVICE_WORKER_ERROR_FAILED;
+  base::RunLoop fetch_run_loop;
+  BrowserThread::PostTask(BrowserThread::IO, FROM_HERE,
+                          base::Bind(&self::FetchOnIOThread, this,
+                                     fetch_run_loop.QuitClosure(),
+                                     &status));
+  fetch_run_loop.Run();
+  ASSERT_EQ(SERVICE_WORKER_OK, status);
+}
+
 }  // namespace content