ServiceWorkerThreadProxy.h [plain text]
#pragma once
#if ENABLE(SERVICE_WORKER)
#include "CacheStorageConnection.h"
#include "Document.h"
#include "FetchIdentifier.h"
#include "Page.h"
#include "SecurityOrigin.h"
#include "ServiceWorkerDebuggable.h"
#include "ServiceWorkerIdentifier.h"
#include "ServiceWorkerInspectorProxy.h"
#include "ServiceWorkerThread.h"
#include "WorkerDebuggerProxy.h"
#include "WorkerLoaderProxy.h"
#include <wtf/HashMap.h>
namespace WebCore {
class CacheStorageProvider;
class FetchLoader;
class FetchLoaderClient;
class PageConfiguration;
class ServiceWorkerInspectorProxy;
struct ServiceWorkerContextData;
class ServiceWorkerThreadProxy final : public ThreadSafeRefCounted<ServiceWorkerThreadProxy>, public WorkerLoaderProxy, public WorkerDebuggerProxy {
public:
template<typename... Args> static Ref<ServiceWorkerThreadProxy> create(Args&&... args)
{
return adoptRef(*new ServiceWorkerThreadProxy(std::forward<Args>(args)...));
}
~ServiceWorkerThreadProxy();
ServiceWorkerIdentifier identifier() const { return m_serviceWorkerThread->identifier(); }
ServiceWorkerThread& thread() { return m_serviceWorkerThread.get(); }
ServiceWorkerInspectorProxy& inspectorProxy() { return m_inspectorProxy; }
bool isTerminatingOrTerminated() const { return m_isTerminatingOrTerminated; }
void setAsTerminatingOrTerminated() { m_isTerminatingOrTerminated = true; }
WEBCORE_EXPORT std::unique_ptr<FetchLoader> createBlobLoader(FetchLoaderClient&, const URL&);
const URL& scriptURL() const { return m_document->url(); }
WEBCORE_TESTSUPPORT_EXPORT void notifyNetworkStateChange(bool isOnline);
WEBCORE_EXPORT void startFetch(SWServerConnectionIdentifier, FetchIdentifier, Ref<ServiceWorkerFetch::Client>&&, Optional<ServiceWorkerClientIdentifier>&&, ResourceRequest&&, String&& referrer, FetchOptions&&);
WEBCORE_EXPORT void cancelFetch(SWServerConnectionIdentifier, FetchIdentifier);
WEBCORE_EXPORT void removeFetch(SWServerConnectionIdentifier, FetchIdentifier);
private:
WEBCORE_EXPORT ServiceWorkerThreadProxy(PageConfiguration&&, const ServiceWorkerContextData&, PAL::SessionID, String&& userAgent, CacheStorageProvider&, SecurityOrigin::StorageBlockingPolicy);
WEBCORE_EXPORT static void networkStateChanged(bool isOnLine);
bool postTaskForModeToWorkerGlobalScope(ScriptExecutionContext::Task&&, const String& mode) final;
void postTaskToLoader(ScriptExecutionContext::Task&&) final;
Ref<CacheStorageConnection> createCacheStorageConnection() final;
void postMessageToDebugger(const String&) final;
void setResourceCachingDisabled(bool) final;
UniqueRef<Page> m_page;
Ref<Document> m_document;
Ref<ServiceWorkerThread> m_serviceWorkerThread;
CacheStorageProvider& m_cacheStorageProvider;
RefPtr<CacheStorageConnection> m_cacheStorageConnection;
PAL::SessionID m_sessionID;
bool m_isTerminatingOrTerminated { false };
ServiceWorkerInspectorProxy m_inspectorProxy;
#if ENABLE(REMOTE_INSPECTOR)
std::unique_ptr<ServiceWorkerDebuggable> m_remoteDebuggable;
#endif
HashMap<std::pair<SWServerConnectionIdentifier, FetchIdentifier>, Ref<ServiceWorkerFetch::Client>> m_ongoingFetchTasks;
};
}
#endif // ENABLE(SERVICE_WORKER)