ServiceWorkerProcessProxy.cpp [plain text]
#include "config.h"
#include "ServiceWorkerProcessProxy.h"
#if ENABLE(SERVICE_WORKER)
#include "AuthenticationChallengeProxy.h"
#include "WebCredential.h"
#include "WebPageGroup.h"
#include "WebPreferencesStore.h"
#include "WebProcessMessages.h"
#include "WebProcessPool.h"
#include "WebSWContextManagerConnectionMessages.h"
#include <WebCore/NotImplemented.h>
#include <WebCore/RegistrationDatabase.h>
namespace WebKit {
using namespace WebCore;
Ref<ServiceWorkerProcessProxy> ServiceWorkerProcessProxy::create(WebProcessPool& pool, const SecurityOriginData& securityOrigin, WebsiteDataStore& store)
{
auto proxy = adoptRef(*new ServiceWorkerProcessProxy { pool, securityOrigin, store });
proxy->connect();
return proxy;
}
ServiceWorkerProcessProxy::ServiceWorkerProcessProxy(WebProcessPool& pool, const SecurityOriginData& securityOrigin, WebsiteDataStore& store)
: WebProcessProxy { pool, store, IsInPrewarmedPool::No }
, m_securityOrigin(securityOrigin)
, m_serviceWorkerPageID(generatePageID())
{
}
ServiceWorkerProcessProxy::~ServiceWorkerProcessProxy()
{
}
bool ServiceWorkerProcessProxy::hasRegisteredServiceWorkers(const String& serviceWorkerDirectory)
{
String registrationFile = WebCore::serviceWorkerRegistrationDatabaseFilename(serviceWorkerDirectory);
return WebCore::FileSystem::fileExists(registrationFile);
}
void ServiceWorkerProcessProxy::getLaunchOptions(ProcessLauncher::LaunchOptions& launchOptions)
{
WebProcessProxy::getLaunchOptions(launchOptions);
launchOptions.extraInitializationData.add("service-worker-process"_s, "1"_s);
launchOptions.extraInitializationData.add("security-origin"_s, securityOrigin().toString());
}
void ServiceWorkerProcessProxy::start(const WebPreferencesStore& store, std::optional<PAL::SessionID> initialSessionID)
{
send(Messages::WebProcess::EstablishWorkerContextConnectionToStorageProcess { processPool().defaultPageGroup().pageGroupID(), m_serviceWorkerPageID, store, initialSessionID.value_or(PAL::SessionID::defaultSessionID()) }, 0);
}
void ServiceWorkerProcessProxy::setUserAgent(const String& userAgent)
{
send(Messages::WebSWContextManagerConnection::SetUserAgent { userAgent }, 0);
}
void ServiceWorkerProcessProxy::updatePreferencesStore(const WebPreferencesStore& store)
{
send(Messages::WebSWContextManagerConnection::UpdatePreferencesStore { store }, 0);
}
void ServiceWorkerProcessProxy::didReceiveAuthenticationChallenge(uint64_t pageID, uint64_t frameID, Ref<AuthenticationChallengeProxy>&& challenge)
{
UNUSED_PARAM(pageID);
UNUSED_PARAM(frameID);
auto& protectionSpace = challenge->core().protectionSpace();
if (protectionSpace.authenticationScheme() == WebCore::ProtectionSpaceAuthenticationSchemeServerTrustEvaluationRequested && processPool().allowsAnySSLCertificateForServiceWorker()) {
auto credential = WebCore::Credential("accept server trust"_s, emptyString(), WebCore::CredentialPersistenceNone);
challenge->useCredential(WebCredential::create(credential).ptr());
return;
}
notImplemented();
challenge->performDefaultHandling();
}
void ServiceWorkerProcessProxy::didFinishLaunching(ProcessLauncher* launcher, IPC::Connection::Identifier connectionIdentifier)
{
WebProcessProxy::didFinishLaunching(launcher, connectionIdentifier);
setProcessSuppressionEnabled(false);
}
}
#endif // ENABLE(SERVICE_WORKER)