Support dispatching ServiceWorker FetchEvent and receiving response

content/renderer/service_worker/embedded_worker_context_client.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/renderer/service_worker/embedded_worker_context_client.h"
 
 #include "base/lazy_instance.h"
 #include "base/message_loop/message_loop_proxy.h"
 #include "base/pickle.h"
 #include "base/threading/thread_local.h"
 #include "content/child/thread_safe_sender.h"
 #include "content/child/worker_task_runner.h"
 #include "content/child/worker_thread_task_runner.h"
 #include "content/common/service_worker/embedded_worker_messages.h"
+#include "content/common/service_worker/service_worker_types.h"
 #include "content/renderer/render_thread_impl.h"
 #include "content/renderer/service_worker/embedded_worker_dispatcher.h"
 #include "content/renderer/service_worker/service_worker_script_context.h"
 #include "ipc/ipc_message_macros.h"
+#include "third_party/WebKit/public/platform/WebServiceWorkerResponse.h"
 #include "third_party/WebKit/public/platform/WebString.h"
 
 namespace content {
 
 namespace {
 
 // For now client must be a per-thread instance.
 // TODO(kinuko): This needs to be refactored when we start using thread pool
 // or having multiple clients per one thread.
 base::LazyInstance<base::ThreadLocalPointer<EmbeddedWorkerContextClient> >::
@@ skipping 89 matching lines @@
                  embedded_worker_id_));
 }
 
 void EmbeddedWorkerContextClient::didHandleInstallEvent(int request_id) {
   DCHECK(script_context_);
   script_context_->DidHandleInstallEvent(request_id);
 }
 
 void EmbeddedWorkerContextClient::didHandleFetchEvent(int request_id) {
   DCHECK(script_context_);
-  NOTIMPLEMENTED();
+  script_context_->DidHandleFetchEvent(
+      request_id,
+      SERVICE_WORKER_FETCH_EVENT_RESULT_FALLBACK,
+      ServiceWorkerResponse());
+}
+
+void EmbeddedWorkerContextClient::didHandleFetchEvent(
+    int request_id,
+    const blink::WebServiceWorkerResponse& web_response) {
+  DCHECK(script_context_);
+  ServiceWorkerResponse response(web_response.statusCode(),
+                                 web_response.statusText().utf8(),
+                                 web_response.method().utf8(),
+                                 std::map<std::string, std::string>());
+  script_context_->DidHandleFetchEvent(
+      request_id, SERVICE_WORKER_FETCH_EVENT_RESULT_RESPONSE, response);
 }
 
 void EmbeddedWorkerContextClient::OnSendMessageToWorker(
     int thread_id,
     int embedded_worker_id,
     int request_id,
     const IPC::Message& message) {
   if (!script_context_)
     return;
   DCHECK_EQ(embedded_worker_id_, embedded_worker_id);
   script_context_->OnMessageReceived(request_id, message);
 }
 
 void EmbeddedWorkerContextClient::SendWorkerStarted() {
   DCHECK(worker_task_runner_->RunsTasksOnCurrentThread());
   sender_->Send(new EmbeddedWorkerHostMsg_WorkerStarted(
       WorkerTaskRunner::Instance()->CurrentWorkerId(),
       embedded_worker_id_));
 }
 
 }  // namespace content