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 |