Start of Chrome-side plumbing for ServiceWorker fetch

content/browser/service_worker/service_worker_version.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 "content/browser/service_worker/service_worker_version.h"
 
 #include "base/stl_util.h"
 #include "content/browser/service_worker/embedded_worker_instance.h"
 #include "content/browser/service_worker/embedded_worker_registry.h"
 #include "content/browser/service_worker/service_worker_context_core.h"
@@ skipping 56 matching lines @@
 
   if (message.type() != ServiceWorkerHostMsg_InstallEventFinished::ID) {
     NOTREACHED() << "Got unexpected response for InstallEvent: "
                  << message.type();
     callback.Run(SERVICE_WORKER_ERROR_FAILED);
     return;
   }
   callback.Run(SERVICE_WORKER_OK);
 }
 
+void HandleFetchResponse(const ServiceWorkerVersion::FetchCallback& callback,
+                         ServiceWorkerStatusCode status,
+                         const IPC::Message& message) {
+  Tuple1<ServiceWorkerFetchResponse> response;
+  if (message.type() != ServiceWorkerHostMsg_FetchEventFinished::ID) {
+    NOTREACHED() << "Got unexpected response for FetchEvent: "
+                 << message.type();
+    callback.Run(SERVICE_WORKER_ERROR_FAILED, response.a);
+    return;
+  }
+  ServiceWorkerHostMsg_FetchEventFinished::Read(&message, &response);
+  callback.Run(status, response.a);
+}
+
 }  // namespace
 
 ServiceWorkerVersion::ServiceWorkerVersion(
     ServiceWorkerRegistration* registration,
     EmbeddedWorkerRegistry* worker_registry,
     int64 version_id)
     : version_id_(version_id),
       is_shutdown_(false),
       registration_(registration),
       weak_factory_(this) {
@@ skipping 100 matching lines @@
 }
 
 void ServiceWorkerVersion::DispatchInstallEvent(
     int active_version_embedded_worker_id,
     const StatusCallback& callback) {
   SendMessageAndRegisterCallback(
       ServiceWorkerMsg_InstallEvent(active_version_embedded_worker_id),
       base::Bind(&HandleInstallFinished, callback));
 }
 
-bool ServiceWorkerVersion::DispatchFetchEvent(
-    const ServiceWorkerFetchRequest& request) {
-  if (status() != RUNNING)
-    return false;
-  return embedded_worker_->SendMessage(
-      kInvalidRequestId, ServiceWorkerMsg_FetchEvent(request))
-          == SERVICE_WORKER_OK;
+void ServiceWorkerVersion::DispatchFetchEvent(
+    const ServiceWorkerFetchRequest& request,
+    const FetchCallback& callback) {
+  SendMessageAndRegisterCallback(
+      ServiceWorkerMsg_FetchEvent(request),
+      base::Bind(&HandleFetchResponse, callback));
 }
 
 void ServiceWorkerVersion::AddProcessToWorker(int process_id) {
   DCHECK(!is_shutdown_);
   embedded_worker_->AddProcessReference(process_id);
 }
 
 void ServiceWorkerVersion::RemoveProcessToWorker(int process_id) {
   embedded_worker_->ReleaseProcessReference(process_id);
 }
@@ skipping 31 matching lines @@
   if (callback) {
     callback->Run(SERVICE_WORKER_OK, message);
     message_callbacks_.Remove(request_id);
     return;
   }
   NOTREACHED() << "Got unexpected message: " << request_id
                << " " << message.type();
 }
 
 }  // namespace content