NetscapePlugInStreamLoader.cpp [plain text]
#include "config.h"
#include "NetscapePlugInStreamLoader.h"
#include "DocumentLoader.h"
#include "FrameLoader.h"
#include "FrameLoaderClient.h"
#include <wtf/CompletionHandler.h>
#include <wtf/Ref.h>
#if ENABLE(CONTENT_EXTENSIONS)
#include "ResourceLoadInfo.h"
#endif
namespace WebCore {
NetscapePlugInStreamLoader::NetscapePlugInStreamLoader(Frame& frame, NetscapePlugInStreamLoaderClient& client)
: ResourceLoader(frame, ResourceLoaderOptions(SendCallbacks, SniffContent, DoNotBufferData, StoredCredentialsPolicy::Use, ClientCredentialPolicy::MayAskClientForCredentials, FetchOptions::Credentials::Include, SkipSecurityCheck, FetchOptions::Mode::NoCors, DoNotIncludeCertificateInfo, ContentSecurityPolicyImposition::DoPolicyCheck, DefersLoadingPolicy::AllowDefersLoading, CachingPolicy::AllowCaching))
, m_client(&client)
{
#if ENABLE(CONTENT_EXTENSIONS)
m_resourceType = ResourceType::PlugInStream;
#endif
}
NetscapePlugInStreamLoader::~NetscapePlugInStreamLoader() = default;
void NetscapePlugInStreamLoader::create(Frame& frame, NetscapePlugInStreamLoaderClient& client, ResourceRequest&& request, CompletionHandler<void(RefPtr<NetscapePlugInStreamLoader>&&)>&& completionHandler)
{
auto loader(adoptRef(*new NetscapePlugInStreamLoader(frame, client)));
loader->init(WTFMove(request), [loader = loader.copyRef(), completionHandler = WTFMove(completionHandler)] (bool initialized) mutable {
if (!initialized)
return completionHandler(nullptr);
completionHandler(WTFMove(loader));
});
}
bool NetscapePlugInStreamLoader::isDone() const
{
return !m_client;
}
void NetscapePlugInStreamLoader::releaseResources()
{
m_client = nullptr;
ResourceLoader::releaseResources();
}
void NetscapePlugInStreamLoader::init(ResourceRequest&& request, CompletionHandler<void(bool)>&& completionHandler)
{
ResourceLoader::init(WTFMove(request), [this, protectedThis = makeRef(*this), completionHandler = WTFMove(completionHandler)] (bool success) mutable {
if (!success)
return completionHandler(false);
ASSERT(!reachedTerminalState());
m_documentLoader->addPlugInStreamLoader(*this);
m_isInitialized = true;
completionHandler(true);
});
}
void NetscapePlugInStreamLoader::willSendRequest(ResourceRequest&& request, const ResourceResponse& redirectResponse, CompletionHandler<void(ResourceRequest&&)>&& callback)
{
m_client->willSendRequest(this, WTFMove(request), redirectResponse, [protectedThis = makeRef(*this), redirectResponse, callback = WTFMove(callback)] (ResourceRequest&& request) mutable {
if (!request.isNull())
protectedThis->willSendRequestInternal(WTFMove(request), redirectResponse, WTFMove(callback));
else
callback({ });
});
}
void NetscapePlugInStreamLoader::didReceiveResponse(const ResourceResponse& response)
{
Ref<NetscapePlugInStreamLoader> protectedThis(*this);
m_client->didReceiveResponse(this, response);
if (!m_client)
return;
ResourceLoader::didReceiveResponse(response);
if (!m_client)
return;
if (!response.isHTTP())
return;
if (m_client->wantsAllStreams())
return;
if (response.httpStatusCode() && (response.httpStatusCode() < 100 || response.httpStatusCode() >= 400))
cancel(frameLoader()->client().fileDoesNotExistError(response));
}
void NetscapePlugInStreamLoader::didReceiveData(const char* data, unsigned length, long long encodedDataLength, DataPayloadType dataPayloadType)
{
didReceiveDataOrBuffer(data, length, nullptr, encodedDataLength, dataPayloadType);
}
void NetscapePlugInStreamLoader::didReceiveBuffer(Ref<SharedBuffer>&& buffer, long long encodedDataLength, DataPayloadType dataPayloadType)
{
didReceiveDataOrBuffer(nullptr, 0, WTFMove(buffer), encodedDataLength, dataPayloadType);
}
void NetscapePlugInStreamLoader::didReceiveDataOrBuffer(const char* data, int length, RefPtr<SharedBuffer>&& buffer, long long encodedDataLength, DataPayloadType dataPayloadType)
{
Ref<NetscapePlugInStreamLoader> protectedThis(*this);
m_client->didReceiveData(this, buffer ? buffer->data() : data, buffer ? buffer->size() : length);
ResourceLoader::didReceiveDataOrBuffer(data, length, WTFMove(buffer), encodedDataLength, dataPayloadType);
}
void NetscapePlugInStreamLoader::didFinishLoading(const NetworkLoadMetrics& networkLoadMetrics)
{
Ref<NetscapePlugInStreamLoader> protectedThis(*this);
notifyDone();
m_client->didFinishLoading(this);
ResourceLoader::didFinishLoading(networkLoadMetrics);
}
void NetscapePlugInStreamLoader::didFail(const ResourceError& error)
{
Ref<NetscapePlugInStreamLoader> protectedThis(*this);
notifyDone();
m_client->didFail(this, error);
ResourceLoader::didFail(error);
}
void NetscapePlugInStreamLoader::willCancel(const ResourceError& error)
{
m_client->didFail(this, error);
}
void NetscapePlugInStreamLoader::didCancel(const ResourceError&)
{
notifyDone();
}
void NetscapePlugInStreamLoader::notifyDone()
{
if (!m_isInitialized)
return;
m_documentLoader->removePlugInStreamLoader(*this);
}
}