| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "content/browser/service_worker/embedded_worker_test_helper.h" | 5 #include "content/browser/service_worker/embedded_worker_test_helper.h" |
| 6 | 6 |
| 7 #include <map> | 7 #include <map> |
| 8 #include <string> | 8 #include <string> |
| 9 #include <utility> | 9 #include <utility> |
| 10 | 10 |
| (...skipping 171 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 182 void DispatchSyncEvent( | 182 void DispatchSyncEvent( |
| 183 const std::string& tag, | 183 const std::string& tag, |
| 184 blink::mojom::BackgroundSyncEventLastChance last_chance, | 184 blink::mojom::BackgroundSyncEventLastChance last_chance, |
| 185 const DispatchSyncEventCallback& callback) override { | 185 const DispatchSyncEventCallback& callback) override { |
| 186 NOTIMPLEMENTED(); | 186 NOTIMPLEMENTED(); |
| 187 } | 187 } |
| 188 | 188 |
| 189 void DispatchPaymentRequestEvent( | 189 void DispatchPaymentRequestEvent( |
| 190 payments::mojom::PaymentAppRequestDataPtr data, | 190 payments::mojom::PaymentAppRequestDataPtr data, |
| 191 const DispatchPaymentRequestEventCallback& callback) override { | 191 const DispatchPaymentRequestEventCallback& callback) override { |
| 192 NOTIMPLEMENTED(); | 192 if (!helper_) |
| 193 return; |
| 194 helper_->OnPaymentRequestEventStub(std::move(data), callback); |
| 193 } | 195 } |
| 194 | 196 |
| 195 void DispatchExtendableMessageEvent( | 197 void DispatchExtendableMessageEvent( |
| 196 mojom::ExtendableMessageEventPtr event, | 198 mojom::ExtendableMessageEventPtr event, |
| 197 const DispatchExtendableMessageEventCallback& callback) override { | 199 const DispatchExtendableMessageEventCallback& callback) override { |
| 198 if (!helper_) | 200 if (!helper_) |
| 199 return; | 201 return; |
| 200 helper_->OnExtendableMessageEventStub(std::move(event), callback); | 202 helper_->OnExtendableMessageEventStub(std::move(event), callback); |
| 201 } | 203 } |
| 202 | 204 |
| (...skipping 190 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 393 } | 395 } |
| 394 | 396 |
| 395 void EmbeddedWorkerTestHelper::OnPushEvent(int embedded_worker_id, | 397 void EmbeddedWorkerTestHelper::OnPushEvent(int embedded_worker_id, |
| 396 int request_id, | 398 int request_id, |
| 397 const PushEventPayload& payload) { | 399 const PushEventPayload& payload) { |
| 398 SimulateSend(new ServiceWorkerHostMsg_PushEventFinished( | 400 SimulateSend(new ServiceWorkerHostMsg_PushEventFinished( |
| 399 embedded_worker_id, request_id, | 401 embedded_worker_id, request_id, |
| 400 blink::WebServiceWorkerEventResultCompleted, base::Time::Now())); | 402 blink::WebServiceWorkerEventResultCompleted, base::Time::Now())); |
| 401 } | 403 } |
| 402 | 404 |
| 405 void EmbeddedWorkerTestHelper::OnPaymentRequestEvent( |
| 406 payments::mojom::PaymentAppRequestDataPtr data, |
| 407 const mojom::ServiceWorkerEventDispatcher:: |
| 408 DispatchPaymentRequestEventCallback& callback) { |
| 409 callback.Run(SERVICE_WORKER_OK, base::Time::Now()); |
| 410 } |
| 411 |
| 403 void EmbeddedWorkerTestHelper::SimulateWorkerReadyForInspection( | 412 void EmbeddedWorkerTestHelper::SimulateWorkerReadyForInspection( |
| 404 int embedded_worker_id) { | 413 int embedded_worker_id) { |
| 405 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); | 414 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); |
| 406 ASSERT_TRUE(worker != NULL); | 415 ASSERT_TRUE(worker != NULL); |
| 407 registry()->OnWorkerReadyForInspection(worker->process_id(), | 416 registry()->OnWorkerReadyForInspection(worker->process_id(), |
| 408 embedded_worker_id); | 417 embedded_worker_id); |
| 409 } | 418 } |
| 410 | 419 |
| 411 void EmbeddedWorkerTestHelper::SimulateWorkerScriptCached( | 420 void EmbeddedWorkerTestHelper::SimulateWorkerScriptCached( |
| 412 int embedded_worker_id) { | 421 int embedded_worker_id) { |
| (...skipping 136 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 549 } | 558 } |
| 550 | 559 |
| 551 void EmbeddedWorkerTestHelper::OnPushEventStub( | 560 void EmbeddedWorkerTestHelper::OnPushEventStub( |
| 552 int request_id, | 561 int request_id, |
| 553 const PushEventPayload& payload) { | 562 const PushEventPayload& payload) { |
| 554 base::ThreadTaskRunnerHandle::Get()->PostTask( | 563 base::ThreadTaskRunnerHandle::Get()->PostTask( |
| 555 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnPushEvent, AsWeakPtr(), | 564 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnPushEvent, AsWeakPtr(), |
| 556 current_embedded_worker_id_, request_id, payload)); | 565 current_embedded_worker_id_, request_id, payload)); |
| 557 } | 566 } |
| 558 | 567 |
| 568 void EmbeddedWorkerTestHelper::OnPaymentRequestEventStub( |
| 569 payments::mojom::PaymentAppRequestDataPtr data, |
| 570 const mojom::ServiceWorkerEventDispatcher:: |
| 571 DispatchPaymentRequestEventCallback& callback) { |
| 572 base::ThreadTaskRunnerHandle::Get()->PostTask( |
| 573 FROM_HERE, |
| 574 base::Bind(&EmbeddedWorkerTestHelper::OnPaymentRequestEvent, AsWeakPtr(), |
| 575 base::Passed(std::move(data)), callback)); |
| 576 } |
| 577 |
| 559 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() { | 578 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() { |
| 560 DCHECK(context()); | 579 DCHECK(context()); |
| 561 return context()->embedded_worker_registry(); | 580 return context()->embedded_worker_registry(); |
| 562 } | 581 } |
| 563 | 582 |
| 564 MessagePortMessageFilter* | 583 MessagePortMessageFilter* |
| 565 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { | 584 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { |
| 566 scoped_refptr<MessagePortMessageFilter> filter( | 585 scoped_refptr<MessagePortMessageFilter> filter( |
| 567 new MockMessagePortMessageFilter); | 586 new MockMessagePortMessageFilter); |
| 568 message_port_message_filters_.push_back(filter); | 587 message_port_message_filters_.push_back(filter); |
| (...skipping 16 matching lines...) Expand all Loading... |
| 585 service_manager::InterfaceProviderSpec()); | 604 service_manager::InterfaceProviderSpec()); |
| 586 | 605 |
| 587 std::unique_ptr<service_manager::InterfaceProvider> remote_interfaces( | 606 std::unique_ptr<service_manager::InterfaceProvider> remote_interfaces( |
| 588 new service_manager::InterfaceProvider); | 607 new service_manager::InterfaceProvider); |
| 589 remote_interfaces->Bind(std::move(interfaces)); | 608 remote_interfaces->Bind(std::move(interfaces)); |
| 590 rph->SetRemoteInterfaces(std::move(remote_interfaces)); | 609 rph->SetRemoteInterfaces(std::move(remote_interfaces)); |
| 591 return registry; | 610 return registry; |
| 592 } | 611 } |
| 593 | 612 |
| 594 } // namespace content | 613 } // namespace content |
| OLD | NEW |