WebSoupRequestManagerProxy.cpp [plain text]
#include "config.h"
#include "WebSoupRequestManagerProxy.h"
#include "APIData.h"
#include "WebContext.h"
#include "WebSoupRequestManagerMessages.h"
#include "WebSoupRequestManagerProxyMessages.h"
namespace WebKit {
const char* WebSoupRequestManagerProxy::supplementName()
{
return "WebSoupRequestManagerProxy";
}
PassRefPtr<WebSoupRequestManagerProxy> WebSoupRequestManagerProxy::create(WebContext* context)
{
return adoptRef(new WebSoupRequestManagerProxy(context));
}
WebSoupRequestManagerProxy::WebSoupRequestManagerProxy(WebContext* context)
: WebContextSupplement(context)
, m_loadFailed(false)
{
WebContextSupplement::context()->addMessageReceiver(Messages::WebSoupRequestManagerProxy::messageReceiverName(), *this);
}
WebSoupRequestManagerProxy::~WebSoupRequestManagerProxy()
{
}
void WebSoupRequestManagerProxy::initializeClient(const WKSoupRequestManagerClientBase* client)
{
m_client.initialize(client);
}
void WebSoupRequestManagerProxy::contextDestroyed()
{
}
void WebSoupRequestManagerProxy::processDidClose(WebProcessProxy*)
{
}
void WebSoupRequestManagerProxy::refWebContextSupplement()
{
API::Object::ref();
}
void WebSoupRequestManagerProxy::derefWebContextSupplement()
{
API::Object::deref();
}
void WebSoupRequestManagerProxy::registerURIScheme(const String& scheme)
{
if (!context())
return;
context()->sendToAllProcessesRelaunchingThemIfNecessary(Messages::WebSoupRequestManager::RegisterURIScheme(scheme));
ASSERT(!m_registeredURISchemes.contains(scheme));
m_registeredURISchemes.append(scheme);
}
void WebSoupRequestManagerProxy::didHandleURIRequest(const API::Data* requestData, uint64_t contentLength, const String& mimeType, uint64_t requestID)
{
if (!context())
return;
context()->sendToAllProcesses(Messages::WebSoupRequestManager::DidHandleURIRequest(requestData->dataReference(), contentLength, mimeType, requestID));
}
void WebSoupRequestManagerProxy::didReceiveURIRequestData(const API::Data* requestData, uint64_t requestID)
{
if (!context())
return;
if (m_loadFailed)
return;
context()->sendToAllProcesses(Messages::WebSoupRequestManager::DidReceiveURIRequestData(requestData->dataReference(), requestID));
}
void WebSoupRequestManagerProxy::didReceiveURIRequest(const String& uriString, WebPageProxy* initiaingPage, uint64_t requestID)
{
if (!m_client.didReceiveURIRequest(this, API::URL::create(uriString).get(), initiaingPage, requestID))
didHandleURIRequest(API::Data::create(0, 0).get(), 0, String(), requestID);
}
void WebSoupRequestManagerProxy::didFailToLoadURIRequest(uint64_t requestID)
{
m_loadFailed = true;
m_client.didFailToLoadURIRequest(this, requestID);
}
void WebSoupRequestManagerProxy::didFailURIRequest(const WebCore::ResourceError& error, uint64_t requestID)
{
if (!context())
return;
m_loadFailed = true;
context()->sendToAllProcesses(Messages::WebSoupRequestManager::DidFailURIRequest(error, requestID));
}
}