Index: content/browser/service_worker/embedded_worker_test_helper.cc |
diff --git a/content/browser/service_worker/embedded_worker_test_helper.cc b/content/browser/service_worker/embedded_worker_test_helper.cc |
index 8103b7451172c61d84b9638a3bdd7c1092eae4ab..a62e371df763d8afa76b385511120a829f906cd9 100644 |
--- a/content/browser/service_worker/embedded_worker_test_helper.cc |
+++ b/content/browser/service_worker/embedded_worker_test_helper.cc |
@@ -24,6 +24,7 @@ |
#include "content/common/background_fetch/background_fetch_types.h" |
#include "content/common/service_worker/embedded_worker_messages.h" |
#include "content/common/service_worker/embedded_worker_start_params.h" |
+#include "content/common/service_worker/service_worker_event_dispatcher.mojom.h" |
#include "content/common/service_worker/service_worker_messages.h" |
#include "content/common/service_worker/service_worker_utils.h" |
#include "content/public/common/push_event_payload.h" |
@@ -151,6 +152,14 @@ class EmbeddedWorkerTestHelper::MockServiceWorkerEventDispatcher |
~MockServiceWorkerEventDispatcher() override {} |
+ void DispatchInstallEvent( |
+ mojom::InstallEventMethodAssociatedPtrInfo client, |
+ const DispatchInstallEventCallback& callback) override { |
+ if (!helper_) |
+ return; |
+ helper_->OnInstallEventStub(callback); |
+ } |
+ |
void DispatchActivateEvent( |
const DispatchActivateEventCallback& callback) override { |
if (!helper_) |
@@ -402,11 +411,6 @@ bool EmbeddedWorkerTestHelper::OnMessageToWorker(int thread_id, |
int embedded_worker_id, |
const IPC::Message& message) { |
bool handled = true; |
- current_embedded_worker_id_ = embedded_worker_id; |
- IPC_BEGIN_MESSAGE_MAP(EmbeddedWorkerTestHelper, message) |
- IPC_MESSAGE_HANDLER(ServiceWorkerMsg_InstallEvent, OnInstallEventStub) |
- IPC_MESSAGE_UNHANDLED(handled = false) |
- IPC_END_MESSAGE_MAP() |
// Record all messages directed to inner script context. |
inner_sink_.OnMessageReceived(message); |
return handled; |
@@ -457,14 +461,12 @@ void EmbeddedWorkerTestHelper::OnExtendableMessageEvent( |
callback.Run(SERVICE_WORKER_OK, base::Time::Now()); |
} |
-void EmbeddedWorkerTestHelper::OnInstallEvent(int embedded_worker_id, |
- 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::OnInstallEvent( |
+ const mojom::ServiceWorkerEventDispatcher::DispatchInstallEventCallback& |
+ callback) { |
+ dispatched_events()->push_back(Event::Install); |
+ callback.Run(SERVICE_WORKER_OK, true /* has_fetch_handler */, |
+ base::Time::Now()); |
} |
void EmbeddedWorkerTestHelper::OnFetchEvent( |
@@ -699,11 +701,12 @@ void EmbeddedWorkerTestHelper::OnExtendableMessageEventStub( |
AsWeakPtr(), base::Passed(&event), callback)); |
} |
-void EmbeddedWorkerTestHelper::OnInstallEventStub(int request_id) { |
+void EmbeddedWorkerTestHelper::OnInstallEventStub( |
+ const mojom::ServiceWorkerEventDispatcher::DispatchInstallEventCallback& |
+ callback) { |
base::ThreadTaskRunnerHandle::Get()->PostTask( |
- FROM_HERE, |
- base::Bind(&EmbeddedWorkerTestHelper::OnInstallEvent, AsWeakPtr(), |
- current_embedded_worker_id_, request_id)); |
+ FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnInstallEvent, |
+ AsWeakPtr(), callback)); |
} |
void EmbeddedWorkerTestHelper::OnFetchEventStub( |