| // Copyright 2015 The Chromium Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #ifndef CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_CONTEXT_WATCHER_H_ |
| #define CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_CONTEXT_WATCHER_H_ |
| |
| #include <stdint.h> |
| |
| #include <unordered_map> |
| #include <vector> |
| |
| #include "base/callback.h" |
| #include "content/browser/service_worker/service_worker_context_core_observer.h" |
| #include "content/browser/service_worker/service_worker_info.h" |
| #include "content/common/content_export.h" |
| #include "third_party/blink/public/mojom/service_worker/service_worker_provider_type.mojom.h" |
| |
| namespace content { |
| |
| class ServiceWorkerContextWrapper; |
| enum class EmbeddedWorkerStatus; |
| |
| // Used to monitor the status change of the ServiceWorker registrations and |
| // versions in the ServiceWorkerContext from UI thread. |
| class CONTENT_EXPORT ServiceWorkerContextWatcher |
| : public ServiceWorkerContextCoreObserver, |
| public base::RefCountedThreadSafe<ServiceWorkerContextWatcher> { |
| public: |
| typedef base::Callback<void( |
| const std::vector<ServiceWorkerRegistrationInfo>&)> |
| WorkerRegistrationUpdatedCallback; |
| typedef base::Callback<void(const std::vector<ServiceWorkerVersionInfo>&)> |
| WorkerVersionUpdatedCallback; |
| typedef base::Callback<void(int64_t /* registration_id */, |
| int64_t /* version_id */, |
| const ErrorInfo&)> WorkerErrorReportedCallback; |
| |
| ServiceWorkerContextWatcher( |
| scoped_refptr<ServiceWorkerContextWrapper> context, |
| const WorkerRegistrationUpdatedCallback& registration_callback, |
| const WorkerVersionUpdatedCallback& version_callback, |
| const WorkerErrorReportedCallback& error_callback); |
| void Start(); |
| void Stop(); |
| |
| private: |
| friend class base::RefCountedThreadSafe<ServiceWorkerContextWatcher>; |
| friend class ServiceWorkerContextWatcherTest; |
| |
| ~ServiceWorkerContextWatcher() override; |
| |
| void GetStoredRegistrationsOnIOThread(); |
| void OnStoredRegistrationsOnIOThread( |
| ServiceWorkerStatusCode status, |
| const std::vector<ServiceWorkerRegistrationInfo>& stored_registrations); |
| void StopOnIOThread(); |
| |
| void StoreRegistrationInfo( |
| const ServiceWorkerRegistrationInfo& registration, |
| std::unordered_map<int64_t, |
| std::unique_ptr<ServiceWorkerRegistrationInfo>>* |
| info_map); |
| void StoreVersionInfo(const ServiceWorkerVersionInfo& version); |
| |
| void SendRegistrationInfo( |
| int64_t registration_id, |
| const GURL& pattern, |
| ServiceWorkerRegistrationInfo::DeleteFlag delete_flag); |
| void SendVersionInfo(const ServiceWorkerVersionInfo& version); |
| |
| void RunWorkerRegistrationUpdatedCallback( |
| std::unique_ptr<std::vector<ServiceWorkerRegistrationInfo>> |
| registrations); |
| void RunWorkerVersionUpdatedCallback( |
| std::unique_ptr<std::vector<ServiceWorkerVersionInfo>> versions); |
| void RunWorkerErrorReportedCallback(int64_t registration_id, |
| int64_t version_id, |
| std::unique_ptr<ErrorInfo> error_info); |
| |
| // ServiceWorkerContextCoreObserver implements |
| void OnNewLiveRegistration(int64_t registration_id, |
| const GURL& pattern) override; |
| void OnNewLiveVersion(const ServiceWorkerVersionInfo& version_info) override; |
| void OnRunningStateChanged( |
| int64_t version_id, |
| content::EmbeddedWorkerStatus running_status) override; |
| void OnVersionStateChanged( |
| int64_t version_id, |
| content::ServiceWorkerVersion::Status status) override; |
| void OnVersionDevToolsRoutingIdChanged(int64_t version_id, |
| int process_id, |
| int devtools_agent_route_id) override; |
| void OnMainScriptHttpResponseInfoSet( |
| int64_t version_id, |
| base::Time script_response_time, |
| base::Time script_last_modified) override; |
| void OnErrorReported(int64_t version_id, |
| int process_id, |
| int thread_id, |
| const ErrorInfo& info) override; |
| void OnReportConsoleMessage(int64_t version_id, |
| int process_id, |
| int thread_id, |
| const ConsoleMessage& message) override; |
| void OnControlleeAdded( |
| int64_t version_id, |
| const std::string& uuid, |
| int process_id, |
| int route_id, |
| const base::Callback<WebContents*(void)>& web_contents_getter, |
| blink::mojom::ServiceWorkerProviderType type) override; |
| void OnControlleeRemoved(int64_t version_id, |
| const std::string& uuid) override; |
| void OnRegistrationCompleted(int64_t registration_id, |
| const GURL& pattern) override; |
| void OnRegistrationDeleted(int64_t registration_id, |
| const GURL& pattern) override; |
| |
| std::unordered_map<int64_t, std::unique_ptr<ServiceWorkerVersionInfo>> |
| version_info_map_; |
| scoped_refptr<ServiceWorkerContextWrapper> context_; |
| WorkerRegistrationUpdatedCallback registration_callback_; |
| WorkerVersionUpdatedCallback version_callback_; |
| WorkerErrorReportedCallback error_callback_; |
| // Should be used on UI thread only. |
| bool stop_called_ = false; |
| // Should be used on IO thread only. |
| bool is_stopped_ = false; |
| }; |
| |
| } // namespace content |
| |
| #endif // CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_CONTEXT_WATCHER_H_ |