| 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 139 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 150 | 150 |
| 151 ~MockServiceWorkerEventDispatcher() override {} | 151 ~MockServiceWorkerEventDispatcher() override {} |
| 152 | 152 |
| 153 void DispatchActivateEvent( | 153 void DispatchActivateEvent( |
| 154 const DispatchActivateEventCallback& callback) override { | 154 const DispatchActivateEventCallback& callback) override { |
| 155 if (!helper_) | 155 if (!helper_) |
| 156 return; | 156 return; |
| 157 helper_->OnActivateEventStub(callback); | 157 helper_->OnActivateEventStub(callback); |
| 158 } | 158 } |
| 159 | 159 |
| 160 void DispatchBackgroundFetchAbortEvent( |
| 161 const std::string& tag, |
| 162 const DispatchBackgroundFetchAbortEventCallback& callback) override { |
| 163 if (!helper_) |
| 164 return; |
| 165 helper_->OnBackgroundFetchAbortEventStub(tag, callback); |
| 166 } |
| 167 |
| 168 void DispatchBackgroundFetchClickEvent( |
| 169 const std::string& tag, |
| 170 mojom::BackgroundFetchState state, |
| 171 const DispatchBackgroundFetchClickEventCallback& callback) override { |
| 172 if (!helper_) |
| 173 return; |
| 174 helper_->OnBackgroundFetchClickEventStub(tag, state, callback); |
| 175 } |
| 176 |
| 160 void DispatchFetchEvent(int fetch_event_id, | 177 void DispatchFetchEvent(int fetch_event_id, |
| 161 const ServiceWorkerFetchRequest& request, | 178 const ServiceWorkerFetchRequest& request, |
| 162 mojom::FetchEventPreloadHandlePtr preload_handle, | 179 mojom::FetchEventPreloadHandlePtr preload_handle, |
| 163 const DispatchFetchEventCallback& callback) override { | 180 const DispatchFetchEventCallback& callback) override { |
| 164 if (!helper_) | 181 if (!helper_) |
| 165 return; | 182 return; |
| 166 helper_->OnFetchEventStub(thread_id_, fetch_event_id, request, | 183 helper_->OnFetchEventStub(thread_id_, fetch_event_id, request, |
| 167 std::move(preload_handle), callback); | 184 std::move(preload_handle), callback); |
| 168 } | 185 } |
| 169 | 186 |
| (...skipping 201 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 371 return handled; | 388 return handled; |
| 372 } | 389 } |
| 373 | 390 |
| 374 void EmbeddedWorkerTestHelper::OnActivateEvent( | 391 void EmbeddedWorkerTestHelper::OnActivateEvent( |
| 375 const mojom::ServiceWorkerEventDispatcher::DispatchActivateEventCallback& | 392 const mojom::ServiceWorkerEventDispatcher::DispatchActivateEventCallback& |
| 376 callback) { | 393 callback) { |
| 377 dispatched_events()->push_back(Event::Activate); | 394 dispatched_events()->push_back(Event::Activate); |
| 378 callback.Run(SERVICE_WORKER_OK, base::Time::Now()); | 395 callback.Run(SERVICE_WORKER_OK, base::Time::Now()); |
| 379 } | 396 } |
| 380 | 397 |
| 398 void EmbeddedWorkerTestHelper::OnBackgroundFetchAbortEvent( |
| 399 const std::string& tag, |
| 400 const mojom::ServiceWorkerEventDispatcher:: |
| 401 DispatchBackgroundFetchAbortEventCallback& callback) { |
| 402 callback.Run(SERVICE_WORKER_OK, base::Time::Now()); |
| 403 } |
| 404 |
| 405 void EmbeddedWorkerTestHelper::OnBackgroundFetchClickEvent( |
| 406 const std::string& tag, |
| 407 mojom::BackgroundFetchState state, |
| 408 const mojom::ServiceWorkerEventDispatcher:: |
| 409 DispatchBackgroundFetchClickEventCallback& callback) { |
| 410 callback.Run(SERVICE_WORKER_OK, base::Time::Now()); |
| 411 } |
| 412 |
| 381 void EmbeddedWorkerTestHelper::OnExtendableMessageEvent( | 413 void EmbeddedWorkerTestHelper::OnExtendableMessageEvent( |
| 382 mojom::ExtendableMessageEventPtr event, | 414 mojom::ExtendableMessageEventPtr event, |
| 383 const mojom::ServiceWorkerEventDispatcher:: | 415 const mojom::ServiceWorkerEventDispatcher:: |
| 384 DispatchExtendableMessageEventCallback& callback) { | 416 DispatchExtendableMessageEventCallback& callback) { |
| 385 callback.Run(SERVICE_WORKER_OK, base::Time::Now()); | 417 callback.Run(SERVICE_WORKER_OK, base::Time::Now()); |
| 386 } | 418 } |
| 387 | 419 |
| 388 void EmbeddedWorkerTestHelper::OnInstallEvent(int embedded_worker_id, | 420 void EmbeddedWorkerTestHelper::OnInstallEvent(int embedded_worker_id, |
| 389 int request_id) { | 421 int request_id) { |
| 390 // The installing worker may have been doomed and terminated. | 422 // The installing worker may have been doomed and terminated. |
| (...skipping 175 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 566 } | 598 } |
| 567 | 599 |
| 568 void EmbeddedWorkerTestHelper::OnActivateEventStub( | 600 void EmbeddedWorkerTestHelper::OnActivateEventStub( |
| 569 const mojom::ServiceWorkerEventDispatcher::DispatchActivateEventCallback& | 601 const mojom::ServiceWorkerEventDispatcher::DispatchActivateEventCallback& |
| 570 callback) { | 602 callback) { |
| 571 base::ThreadTaskRunnerHandle::Get()->PostTask( | 603 base::ThreadTaskRunnerHandle::Get()->PostTask( |
| 572 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnActivateEvent, | 604 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnActivateEvent, |
| 573 AsWeakPtr(), callback)); | 605 AsWeakPtr(), callback)); |
| 574 } | 606 } |
| 575 | 607 |
| 608 void EmbeddedWorkerTestHelper::OnBackgroundFetchAbortEventStub( |
| 609 const std::string& tag, |
| 610 const mojom::ServiceWorkerEventDispatcher:: |
| 611 DispatchBackgroundFetchAbortEventCallback& callback) { |
| 612 base::ThreadTaskRunnerHandle::Get()->PostTask( |
| 613 FROM_HERE, |
| 614 base::Bind(&EmbeddedWorkerTestHelper::OnBackgroundFetchAbortEvent, |
| 615 AsWeakPtr(), tag, callback)); |
| 616 } |
| 617 |
| 618 void EmbeddedWorkerTestHelper::OnBackgroundFetchClickEventStub( |
| 619 const std::string& tag, |
| 620 mojom::BackgroundFetchState state, |
| 621 const mojom::ServiceWorkerEventDispatcher:: |
| 622 DispatchBackgroundFetchClickEventCallback& callback) { |
| 623 base::ThreadTaskRunnerHandle::Get()->PostTask( |
| 624 FROM_HERE, |
| 625 base::Bind(&EmbeddedWorkerTestHelper::OnBackgroundFetchClickEvent, |
| 626 AsWeakPtr(), tag, state, callback)); |
| 627 } |
| 628 |
| 576 void EmbeddedWorkerTestHelper::OnExtendableMessageEventStub( | 629 void EmbeddedWorkerTestHelper::OnExtendableMessageEventStub( |
| 577 mojom::ExtendableMessageEventPtr event, | 630 mojom::ExtendableMessageEventPtr event, |
| 578 const mojom::ServiceWorkerEventDispatcher:: | 631 const mojom::ServiceWorkerEventDispatcher:: |
| 579 DispatchExtendableMessageEventCallback& callback) { | 632 DispatchExtendableMessageEventCallback& callback) { |
| 580 base::ThreadTaskRunnerHandle::Get()->PostTask( | 633 base::ThreadTaskRunnerHandle::Get()->PostTask( |
| 581 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnExtendableMessageEvent, | 634 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnExtendableMessageEvent, |
| 582 AsWeakPtr(), base::Passed(&event), callback)); | 635 AsWeakPtr(), base::Passed(&event), callback)); |
| 583 } | 636 } |
| 584 | 637 |
| 585 void EmbeddedWorkerTestHelper::OnInstallEventStub(int request_id) { | 638 void EmbeddedWorkerTestHelper::OnInstallEventStub(int request_id) { |
| (...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 664 service_manager::InterfaceProviderSpec()); | 717 service_manager::InterfaceProviderSpec()); |
| 665 | 718 |
| 666 std::unique_ptr<service_manager::InterfaceProvider> remote_interfaces( | 719 std::unique_ptr<service_manager::InterfaceProvider> remote_interfaces( |
| 667 new service_manager::InterfaceProvider); | 720 new service_manager::InterfaceProvider); |
| 668 remote_interfaces->Bind(std::move(interfaces)); | 721 remote_interfaces->Bind(std::move(interfaces)); |
| 669 rph->SetRemoteInterfaces(std::move(remote_interfaces)); | 722 rph->SetRemoteInterfaces(std::move(remote_interfaces)); |
| 670 return registry; | 723 return registry; |
| 671 } | 724 } |
| 672 | 725 |
| 673 } // namespace content | 726 } // namespace content |
| OLD | NEW |