ApplicationCacheResourceLoader.cpp [plain text]
#include "config.h"
#include "ApplicationCacheResourceLoader.h"
#include "CachedResourceLoader.h"
namespace WebCore {
RefPtr<ApplicationCacheResourceLoader> ApplicationCacheResourceLoader::create(unsigned type, CachedResourceLoader& loader, ResourceRequest&& request, CompletionHandler<void(ResourceOrError&&)>&& callback)
{
ResourceLoaderOptions options;
options.storedCredentialsPolicy = StoredCredentialsPolicy::Use;
options.credentials = FetchOptions::Credentials::Include;
options.applicationCacheMode = ApplicationCacheMode::Bypass;
options.certificateInfoPolicy = CertificateInfoPolicy::IncludeCertificateInfo;
CachedResourceRequest cachedResourceRequest { WTFMove(request), options };
auto resource = loader.requestRawResource(WTFMove(cachedResourceRequest));
if (!resource.has_value()) {
callback(makeUnexpected(Error::CannotCreateResource));
return nullptr;
}
return adoptRef(*new ApplicationCacheResourceLoader { type, WTFMove(resource.value()), WTFMove(callback) });
}
ApplicationCacheResourceLoader::ApplicationCacheResourceLoader(unsigned type, CachedResourceHandle<CachedRawResource>&& resource, CompletionHandler<void(ResourceOrError&&)>&& callback)
: m_type(type)
, m_resource(WTFMove(resource))
, m_callback(WTFMove(callback))
{
m_resource->addClient(*this);
}
ApplicationCacheResourceLoader::~ApplicationCacheResourceLoader()
{
if (auto callback = WTFMove(m_callback))
callback(makeUnexpected(Error::Abort));
if (m_resource)
m_resource->removeClient(*this);
}
void ApplicationCacheResourceLoader::cancel(Error error)
{
auto protectedThis = makeRef(*this);
if (auto callback = WTFMove(m_callback))
callback(makeUnexpected(error));
if (m_resource) {
m_resource->removeClient(*this);
m_resource = nullptr;
}
}
void ApplicationCacheResourceLoader::responseReceived(CachedResource& resource, const ResourceResponse& response, CompletionHandler<void()>&& completionHandler)
{
ASSERT_UNUSED(resource, &resource == m_resource);
CompletionHandlerCallingScope completionHandlerCaller(WTFMove(completionHandler));
if (response.httpStatusCode() == 404 || response.httpStatusCode() == 410) {
cancel(Error::NotFound);
return;
}
if (response.httpStatusCode() == 304) {
notifyFinished(*m_resource);
return;
}
if (response.httpStatusCode() / 100 != 2) {
cancel(Error::NotOK);
return;
}
m_applicationCacheResource = ApplicationCacheResource::create(m_resource->url(), response, m_type);
}
void ApplicationCacheResourceLoader::dataReceived(CachedResource&, const char* data, int length)
{
m_applicationCacheResource->data().append(data, length);
}
void ApplicationCacheResourceLoader::redirectReceived(CachedResource&, ResourceRequest&& newRequest, const ResourceResponse&, CompletionHandler<void(ResourceRequest&&)>&& callback)
{
m_hasRedirection = true;
bool isRedirectionDisallowed = (m_type & ApplicationCacheResource::Type::Manifest) || (m_type & ApplicationCacheResource::Explicit) || (m_type & ApplicationCacheResource::Fallback);
if (isRedirectionDisallowed) {
cancel(Error::RedirectForbidden);
callback({ });
return;
}
callback(WTFMove(newRequest));
}
void ApplicationCacheResourceLoader::notifyFinished(CachedResource& resource)
{
auto protectedThis = makeRef(*this);
ASSERT_UNUSED(resource, &resource == m_resource);
if (m_resource->errorOccurred()) {
cancel(Error::NetworkError);
return;
}
if (auto callback = WTFMove(m_callback))
callback(WTFMove(m_applicationCacheResource));
CachedResourceHandle<CachedRawResource> resourceHandle;
std::swap(resourceHandle, m_resource);
if (resourceHandle)
resourceHandle->removeClient(*this);
}
}