ServiceWorker: Use mojo's data pipe for respondWith(stream)

content/browser/service_worker/embedded_worker_test_helper.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 "content/browser/service_worker/embedded_worker_test_helper.h"
 
 #include <map>
 #include <memory>
 #include <string>
 #include <utility>
@@ skipping 178 matching lines @@
 
   void DispatchBackgroundFetchedEvent(
       const std::string& tag,
       const std::vector<BackgroundFetchSettledFetch>& fetches,
       const DispatchBackgroundFetchedEventCallback& callback) override {
     if (!helper_)
       return;
     helper_->OnBackgroundFetchedEventStub(tag, fetches, callback);
   }
 
-  void DispatchFetchEvent(int fetch_event_id,
-                          const ServiceWorkerFetchRequest& request,
-                          mojom::FetchEventPreloadHandlePtr preload_handle,
-                          const DispatchFetchEventCallback& callback) override {
+  void DispatchFetchEvent(
+      int fetch_event_id,
+      const ServiceWorkerFetchRequest& request,
+      mojom::FetchEventPreloadHandlePtr preload_handle,
+      mojom::ServiceWorkerFetchResponseCallbackPtr response_callback,
+      const DispatchFetchEventCallback& callback) override {
     if (!helper_)
       return;
     helper_->OnFetchEventStub(thread_id_, fetch_event_id, request,
-                              std::move(preload_handle), callback);
+                              std::move(preload_handle),
+                              std::move(response_callback), callback);
   }
 
   void DispatchNotificationClickEvent(
       const std::string& notification_id,
       const PlatformNotificationData& notification_data,
       int action_index,
       const base::Optional<base::string16>& reply,
       const DispatchNotificationClickEventCallback& callback) override {
     if (!helper_)
       return;
@@ skipping 248 matching lines @@
                                               int request_id) {
   // The installing worker may have been doomed and terminated.
   if (!registry()->GetWorker(embedded_worker_id))
     return;
   SimulateSend(new ServiceWorkerHostMsg_InstallEventFinished(
       embedded_worker_id, request_id,
       blink::WebServiceWorkerEventResultCompleted, true, base::Time::Now()));
 }
 
 void EmbeddedWorkerTestHelper::OnFetchEvent(
-    int embedded_worker_id,
-    int fetch_event_id,
-    const ServiceWorkerFetchRequest& request,
-    mojom::FetchEventPreloadHandlePtr preload_handle,
-    const FetchCallback& callback) {
-  SimulateSend(new ServiceWorkerHostMsg_FetchEventResponse(
-      embedded_worker_id, fetch_event_id,
-      SERVICE_WORKER_FETCH_EVENT_RESULT_RESPONSE,
+    int /* embedded_worker_id */,
+    int /* fetch_event_id */,
+    const ServiceWorkerFetchRequest& /* request */,
+    mojom::FetchEventPreloadHandlePtr /* preload_handle */,
+    mojom::ServiceWorkerFetchResponseCallbackPtr response_callback,
+    const FetchCallback& finish_callback) {
+  response_callback->OnResponse(
       ServiceWorkerResponse(
           base::MakeUnique<std::vector<GURL>>(), 200, "OK",
           blink::WebServiceWorkerResponseTypeDefault,
-          base::MakeUnique<ServiceWorkerHeaderMap>(), std::string(), 0, GURL(),
+          base::MakeUnique<ServiceWorkerHeaderMap>(), std::string(), 0,
           blink::WebServiceWorkerResponseErrorUnknown, base::Time(),
           false /* is_in_cache_storage */,
           std::string() /* cache_storage_cache_name */,
           base::MakeUnique<
               ServiceWorkerHeaderList>() /* cors_exposed_header_names */),
-      base::Time::Now()));
-  callback.Run(SERVICE_WORKER_OK, base::Time::Now());
+      base::Time::Now());
+  finish_callback.Run(SERVICE_WORKER_OK, base::Time::Now());
 }
 
 void EmbeddedWorkerTestHelper::OnPushEvent(
     const PushEventPayload& payload,
     const mojom::ServiceWorkerEventDispatcher::DispatchPushEventCallback&
         callback) {
   callback.Run(SERVICE_WORKER_OK, base::Time::Now());
 }
 
 void EmbeddedWorkerTestHelper::OnNotificationClickEvent(
@@ skipping 204 matching lines @@
       FROM_HERE,
       base::Bind(&EmbeddedWorkerTestHelper::OnInstallEvent, AsWeakPtr(),
                  current_embedded_worker_id_, request_id));
 }
 
 void EmbeddedWorkerTestHelper::OnFetchEventStub(
     int thread_id,
     int fetch_event_id,
     const ServiceWorkerFetchRequest& request,
     mojom::FetchEventPreloadHandlePtr preload_handle,
-    const FetchCallback& callback) {
+    mojom::ServiceWorkerFetchResponseCallbackPtr response_callback,
+    const FetchCallback& finish_callback) {
   base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE,
       base::Bind(&EmbeddedWorkerTestHelper::OnFetchEvent, AsWeakPtr(),
                  thread_id_embedded_worker_id_map_[thread_id], fetch_event_id,
-                 request, base::Passed(&preload_handle), callback));
+                 request, base::Passed(&preload_handle),
+                 base::Passed(&response_callback), finish_callback));
 }
 
 void EmbeddedWorkerTestHelper::OnNotificationClickEventStub(
     const std::string& notification_id,
     const PlatformNotificationData& notification_data,
     int action_index,
     const base::Optional<base::string16>& reply,
     const mojom::ServiceWorkerEventDispatcher::
         DispatchNotificationClickEventCallback& callback) {
   base::ThreadTaskRunnerHandle::Get()->PostTask(
@@ skipping 33 matching lines @@
                  base::Passed(std::move(app_request)),
                  base::Passed(std::move(response_callback)), callback));
 }
 
 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() {
   DCHECK(context());
   return context()->embedded_worker_registry();
 }
 
 }  // namespace content