1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150
|
// Copyright 2015 The Chromium Authors
// 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 <memory>
#include <string>
#include <unordered_map>
#include <vector>
#include "base/functional/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/common/service_worker/embedded_worker_status.h"
namespace blink {
class StorageKey;
} // namespace blink
namespace content {
class ServiceWorkerContextWrapper;
// 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:
using WorkerRegistrationUpdatedCallback = base::RepeatingCallback<void(
const std::vector<ServiceWorkerRegistrationInfo>&)>;
using WorkerVersionUpdatedCallback = base::RepeatingCallback<void(
const std::vector<ServiceWorkerVersionInfo>&)>;
using WorkerErrorReportedCallback = base::RepeatingCallback<void(
int64_t /* registration_id */,
int64_t /* version_id */,
const ServiceWorkerContextObserver::ErrorInfo&)>;
ServiceWorkerContextWatcher(
scoped_refptr<ServiceWorkerContextWrapper> context,
WorkerRegistrationUpdatedCallback registration_callback,
WorkerVersionUpdatedCallback version_callback,
WorkerErrorReportedCallback error_callback);
void Start();
void Stop();
private:
friend class base::RefCountedThreadSafe<ServiceWorkerContextWatcher>;
friend class ServiceWorkerContextWatcherTest;
~ServiceWorkerContextWatcher() override;
void OnStoredRegistrations(
blink::ServiceWorkerStatusCode status,
const std::vector<ServiceWorkerRegistrationInfo>& stored_registrations);
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& scope,
const blink::StorageKey& key,
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<ServiceWorkerContextObserver::ErrorInfo> error_info);
// ServiceWorkerContextCoreObserver implements
void OnNewLiveRegistration(int64_t registration_id,
const GURL& scope,
const blink::StorageKey& key) override;
void OnNewLiveVersion(const ServiceWorkerVersionInfo& version_info) override;
void OnStarting(int64_t version_id) override;
void OnStarted(int64_t version_id,
const GURL& scope,
int process_id,
const GURL& script_url,
const blink::ServiceWorkerToken& token,
const blink::StorageKey& key) override;
void OnStopping(int64_t version_id) override;
void OnStopped(int64_t version_id) override;
void OnVersionStateChanged(int64_t version_id,
const GURL& scope,
const blink::StorageKey& key,
ServiceWorkerVersion::Status status) override;
void OnVersionRouterRulesChanged(int64_t version_id,
const std::string& router_rules) override;
void OnVersionDevToolsRoutingIdChanged(int64_t version_id,
int process_id,
int devtools_agent_route_id) override;
void OnMainScriptResponseSet(int64_t version_id,
base::Time script_response_time,
base::Time script_last_modified) override;
void OnErrorReported(
int64_t version_id,
const GURL& scope,
const blink::StorageKey& key,
const ServiceWorkerContextObserver::ErrorInfo& info) override;
void OnReportConsoleMessage(int64_t version_id,
const GURL& scope,
const blink::StorageKey& key,
const ConsoleMessage& message) override;
void OnControlleeAdded(int64_t version_id,
const std::string& uuid,
const ServiceWorkerClientInfo& info) override;
void OnControlleeRemoved(int64_t version_id,
const std::string& uuid) override;
void OnRegistrationCompleted(int64_t registration_id,
const GURL& scope,
const blink::StorageKey& key) override;
void OnRegistrationDeleted(int64_t registration_id,
const GURL& scope,
const blink::StorageKey& key) override;
void OnRunningStateChanged(int64_t version_id,
blink::EmbeddedWorkerStatus running_status);
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 UI thread only.
bool is_stopped_ = false;
};
} // namespace content
#endif // CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_CONTEXT_WATCHER_H_
|