| 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 <memory> | 8 #include <memory> |
| 9 #include <string> | 9 #include <string> |
| 10 #include <utility> | 10 #include <utility> |
| (...skipping 222 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 233 } | 233 } |
| 234 | 234 |
| 235 void DispatchSyncEvent( | 235 void DispatchSyncEvent( |
| 236 const std::string& tag, | 236 const std::string& tag, |
| 237 blink::mojom::BackgroundSyncEventLastChance last_chance, | 237 blink::mojom::BackgroundSyncEventLastChance last_chance, |
| 238 const DispatchSyncEventCallback& callback) override { | 238 const DispatchSyncEventCallback& callback) override { |
| 239 NOTIMPLEMENTED(); | 239 NOTIMPLEMENTED(); |
| 240 } | 240 } |
| 241 | 241 |
| 242 void DispatchPaymentRequestEvent( | 242 void DispatchPaymentRequestEvent( |
| 243 int payment_request_id, |
| 243 payments::mojom::PaymentAppRequestPtr app_request, | 244 payments::mojom::PaymentAppRequestPtr app_request, |
| 245 payments::mojom::PaymentAppResponseCallbackPtr response_callback, |
| 244 const DispatchPaymentRequestEventCallback& callback) override { | 246 const DispatchPaymentRequestEventCallback& callback) override { |
| 245 if (!helper_) | 247 if (!helper_) |
| 246 return; | 248 return; |
| 247 helper_->OnPaymentRequestEventStub(std::move(app_request), callback); | 249 helper_->OnPaymentRequestEventStub(std::move(app_request), |
| 250 std::move(response_callback), callback); |
| 248 } | 251 } |
| 249 | 252 |
| 250 void DispatchExtendableMessageEvent( | 253 void DispatchExtendableMessageEvent( |
| 251 mojom::ExtendableMessageEventPtr event, | 254 mojom::ExtendableMessageEventPtr event, |
| 252 const DispatchExtendableMessageEventCallback& callback) override { | 255 const DispatchExtendableMessageEventCallback& callback) override { |
| 253 if (!helper_) | 256 if (!helper_) |
| 254 return; | 257 return; |
| 255 helper_->OnExtendableMessageEventStub(std::move(event), callback); | 258 helper_->OnExtendableMessageEventStub(std::move(event), callback); |
| 256 } | 259 } |
| 257 | 260 |
| (...skipping 248 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 506 void EmbeddedWorkerTestHelper::OnNotificationCloseEvent( | 509 void EmbeddedWorkerTestHelper::OnNotificationCloseEvent( |
| 507 const std::string& notification_id, | 510 const std::string& notification_id, |
| 508 const PlatformNotificationData& notification_data, | 511 const PlatformNotificationData& notification_data, |
| 509 const mojom::ServiceWorkerEventDispatcher:: | 512 const mojom::ServiceWorkerEventDispatcher:: |
| 510 DispatchNotificationCloseEventCallback& callback) { | 513 DispatchNotificationCloseEventCallback& callback) { |
| 511 callback.Run(SERVICE_WORKER_OK, base::Time::Now()); | 514 callback.Run(SERVICE_WORKER_OK, base::Time::Now()); |
| 512 } | 515 } |
| 513 | 516 |
| 514 void EmbeddedWorkerTestHelper::OnPaymentRequestEvent( | 517 void EmbeddedWorkerTestHelper::OnPaymentRequestEvent( |
| 515 payments::mojom::PaymentAppRequestPtr app_request, | 518 payments::mojom::PaymentAppRequestPtr app_request, |
| 519 payments::mojom::PaymentAppResponseCallbackPtr response_callback, |
| 516 const mojom::ServiceWorkerEventDispatcher:: | 520 const mojom::ServiceWorkerEventDispatcher:: |
| 517 DispatchPaymentRequestEventCallback& callback) { | 521 DispatchPaymentRequestEventCallback& callback) { |
| 522 response_callback->OnPaymentAppResponse( |
| 523 payments::mojom::PaymentAppResponse::New(), base::Time::Now()); |
| 518 callback.Run(SERVICE_WORKER_OK, base::Time::Now()); | 524 callback.Run(SERVICE_WORKER_OK, base::Time::Now()); |
| 519 } | 525 } |
| 520 | 526 |
| 521 void EmbeddedWorkerTestHelper::SimulateWorkerReadyForInspection( | 527 void EmbeddedWorkerTestHelper::SimulateWorkerReadyForInspection( |
| 522 int embedded_worker_id) { | 528 int embedded_worker_id) { |
| 523 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); | 529 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); |
| 524 ASSERT_TRUE(worker); | 530 ASSERT_TRUE(worker); |
| 525 registry()->OnWorkerReadyForInspection(worker->process_id(), | 531 registry()->OnWorkerReadyForInspection(worker->process_id(), |
| 526 embedded_worker_id); | 532 embedded_worker_id); |
| 527 } | 533 } |
| (...skipping 213 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 741 const PushEventPayload& payload, | 747 const PushEventPayload& payload, |
| 742 const mojom::ServiceWorkerEventDispatcher::DispatchPushEventCallback& | 748 const mojom::ServiceWorkerEventDispatcher::DispatchPushEventCallback& |
| 743 callback) { | 749 callback) { |
| 744 base::ThreadTaskRunnerHandle::Get()->PostTask( | 750 base::ThreadTaskRunnerHandle::Get()->PostTask( |
| 745 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnPushEvent, AsWeakPtr(), | 751 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnPushEvent, AsWeakPtr(), |
| 746 payload, callback)); | 752 payload, callback)); |
| 747 } | 753 } |
| 748 | 754 |
| 749 void EmbeddedWorkerTestHelper::OnPaymentRequestEventStub( | 755 void EmbeddedWorkerTestHelper::OnPaymentRequestEventStub( |
| 750 payments::mojom::PaymentAppRequestPtr app_request, | 756 payments::mojom::PaymentAppRequestPtr app_request, |
| 757 payments::mojom::PaymentAppResponseCallbackPtr response_callback, |
| 751 const mojom::ServiceWorkerEventDispatcher:: | 758 const mojom::ServiceWorkerEventDispatcher:: |
| 752 DispatchPaymentRequestEventCallback& callback) { | 759 DispatchPaymentRequestEventCallback& callback) { |
| 753 base::ThreadTaskRunnerHandle::Get()->PostTask( | 760 base::ThreadTaskRunnerHandle::Get()->PostTask( |
| 754 FROM_HERE, | 761 FROM_HERE, |
| 755 base::Bind(&EmbeddedWorkerTestHelper::OnPaymentRequestEvent, AsWeakPtr(), | 762 base::Bind(&EmbeddedWorkerTestHelper::OnPaymentRequestEvent, AsWeakPtr(), |
| 756 base::Passed(std::move(app_request)), callback)); | 763 base::Passed(std::move(app_request)), |
| 764 base::Passed(std::move(response_callback)), callback)); |
| 757 } | 765 } |
| 758 | 766 |
| 759 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() { | 767 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() { |
| 760 DCHECK(context()); | 768 DCHECK(context()); |
| 761 return context()->embedded_worker_registry(); | 769 return context()->embedded_worker_registry(); |
| 762 } | 770 } |
| 763 | 771 |
| 764 std::unique_ptr<service_manager::InterfaceRegistry> | 772 std::unique_ptr<service_manager::InterfaceRegistry> |
| 765 EmbeddedWorkerTestHelper::CreateInterfaceRegistry(MockRenderProcessHost* rph) { | 773 EmbeddedWorkerTestHelper::CreateInterfaceRegistry(MockRenderProcessHost* rph) { |
| 766 auto registry = | 774 auto registry = |
| 767 base::MakeUnique<service_manager::InterfaceRegistry>(std::string()); | 775 base::MakeUnique<service_manager::InterfaceRegistry>(std::string()); |
| 768 registry->AddInterface( | 776 registry->AddInterface( |
| 769 base::Bind(&MockEmbeddedWorkerInstanceClient::Bind, AsWeakPtr())); | 777 base::Bind(&MockEmbeddedWorkerInstanceClient::Bind, AsWeakPtr())); |
| 770 | 778 |
| 771 service_manager::mojom::InterfaceProviderPtr interfaces; | 779 service_manager::mojom::InterfaceProviderPtr interfaces; |
| 772 registry->Bind(mojo::MakeRequest(&interfaces), service_manager::Identity(), | 780 registry->Bind(mojo::MakeRequest(&interfaces), service_manager::Identity(), |
| 773 service_manager::InterfaceProviderSpec(), | 781 service_manager::InterfaceProviderSpec(), |
| 774 service_manager::Identity(), | 782 service_manager::Identity(), |
| 775 service_manager::InterfaceProviderSpec()); | 783 service_manager::InterfaceProviderSpec()); |
| 776 | 784 |
| 777 std::unique_ptr<service_manager::InterfaceProvider> remote_interfaces( | 785 std::unique_ptr<service_manager::InterfaceProvider> remote_interfaces( |
| 778 new service_manager::InterfaceProvider); | 786 new service_manager::InterfaceProvider); |
| 779 remote_interfaces->Bind(std::move(interfaces)); | 787 remote_interfaces->Bind(std::move(interfaces)); |
| 780 rph->SetRemoteInterfaces(std::move(remote_interfaces)); | 788 rph->SetRemoteInterfaces(std::move(remote_interfaces)); |
| 781 return registry; | 789 return registry; |
| 782 } | 790 } |
| 783 | 791 |
| 784 } // namespace content | 792 } // namespace content |
| OLD | NEW |