NetworkDataTaskSoup.h [plain text]
#pragma once
#include "NetworkDataTask.h"
#include <WebCore/FrameIdentifier.h>
#include <WebCore/NetworkLoadMetrics.h>
#include <WebCore/PageIdentifier.h>
#include <WebCore/ProtectionSpace.h>
#include <WebCore/ResourceResponse.h>
#include <wtf/RunLoop.h>
#include <wtf/glib/GRefPtr.h>
namespace WebKit {
class NetworkDataTaskSoup final : public NetworkDataTask {
public:
static Ref<NetworkDataTask> create(NetworkSession& session, NetworkDataTaskClient& client, const WebCore::ResourceRequest& request, WebCore::FrameIdentifier frameID, WebCore::PageIdentifier pageID, WebCore::StoredCredentialsPolicy storedCredentialsPolicy, WebCore::ContentSniffingPolicy shouldContentSniff, WebCore::ContentEncodingSniffingPolicy shouldContentEncodingSniff, bool shouldClearReferrerOnHTTPSToHTTPRedirect, bool dataTaskIsForMainFrameNavigation)
{
return adoptRef(*new NetworkDataTaskSoup(session, client, request, frameID, pageID, storedCredentialsPolicy, shouldContentSniff, shouldContentEncodingSniff, shouldClearReferrerOnHTTPSToHTTPRedirect, dataTaskIsForMainFrameNavigation));
}
~NetworkDataTaskSoup();
private:
NetworkDataTaskSoup(NetworkSession&, NetworkDataTaskClient&, const WebCore::ResourceRequest&, WebCore::FrameIdentifier, WebCore::PageIdentifier, WebCore::StoredCredentialsPolicy, WebCore::ContentSniffingPolicy, WebCore::ContentEncodingSniffingPolicy, bool shouldClearReferrerOnHTTPSToHTTPRedirect, bool dataTaskIsForMainFrameNavigation);
void cancel() override;
void resume() override;
void invalidateAndCancel() override;
NetworkDataTask::State state() const override;
void setPendingDownloadLocation(const String&, SandboxExtension::Handle&&, bool ) override;
String suggestedFilename() const override;
void timeoutFired();
void startTimeout();
void stopTimeout();
enum class WasBlockingCookies { No, Yes };
void createRequest(WebCore::ResourceRequest&&, WasBlockingCookies);
void clearRequest();
static void sendRequestCallback(SoupRequest*, GAsyncResult*, NetworkDataTaskSoup*);
void didSendRequest(GRefPtr<GInputStream>&&);
void dispatchDidReceiveResponse();
void dispatchDidCompleteWithError(const WebCore::ResourceError&);
static gboolean tlsConnectionAcceptCertificateCallback(GTlsConnection*, GTlsCertificate*, GTlsCertificateFlags, NetworkDataTaskSoup*);
bool tlsConnectionAcceptCertificate(GTlsCertificate*, GTlsCertificateFlags);
bool persistentCredentialStorageEnabled() const;
void applyAuthenticationToRequest(WebCore::ResourceRequest&);
static void authenticateCallback(SoupSession*, SoupMessage*, SoupAuth*, gboolean retrying, NetworkDataTaskSoup*);
void authenticate(WebCore::AuthenticationChallenge&&);
void continueAuthenticate(WebCore::AuthenticationChallenge&&);
static void skipInputStreamForRedirectionCallback(GInputStream*, GAsyncResult*, NetworkDataTaskSoup*);
void skipInputStreamForRedirection();
void didFinishSkipInputStreamForRedirection();
bool shouldStartHTTPRedirection();
void continueHTTPRedirection();
static void readCallback(GInputStream*, GAsyncResult*, NetworkDataTaskSoup*);
void read();
void didRead(gssize bytesRead);
void didFinishRead();
static void requestNextPartCallback(SoupMultipartInputStream*, GAsyncResult*, NetworkDataTaskSoup*);
void requestNextPart();
void didRequestNextPart(GRefPtr<GInputStream>&&);
void didFinishRequestNextPart();
static void gotHeadersCallback(SoupMessage*, NetworkDataTaskSoup*);
void didGetHeaders();
static void wroteBodyDataCallback(SoupMessage*, SoupBuffer*, NetworkDataTaskSoup*);
void didWriteBodyData(uint64_t bytesSent);
void download();
static void writeDownloadCallback(GOutputStream*, GAsyncResult*, NetworkDataTaskSoup*);
void writeDownload();
void didWriteDownload(gsize bytesWritten);
void didFailDownload(const WebCore::ResourceError&);
void didFinishDownload();
void cleanDownloadFiles();
void didFail(const WebCore::ResourceError&);
static void networkEventCallback(SoupMessage*, GSocketClientEvent, GIOStream*, NetworkDataTaskSoup*);
void networkEvent(GSocketClientEvent, GIOStream*);
#if SOUP_CHECK_VERSION(2, 49, 91)
static void startingCallback(SoupMessage*, NetworkDataTaskSoup*);
#else
static void requestStartedCallback(SoupSession*, SoupMessage*, SoupSocket*, NetworkDataTaskSoup*);
#endif
#if SOUP_CHECK_VERSION(2, 67, 1)
bool shouldAllowHSTSPolicySetting() const;
bool shouldAllowHSTSProtocolUpgrade() const;
void protocolUpgradedViaHSTS(SoupMessage*);
static void hstsEnforced(SoupHSTSEnforcer*, SoupMessage*, NetworkDataTaskSoup*);
#endif
void didStartRequest();
static void restartedCallback(SoupMessage*, NetworkDataTaskSoup*);
void didRestart();
WebCore::FrameIdentifier m_frameID;
WebCore::PageIdentifier m_pageID;
State m_state { State::Suspended };
WebCore::ContentSniffingPolicy m_shouldContentSniff;
GRefPtr<SoupRequest> m_soupRequest;
GRefPtr<SoupMessage> m_soupMessage;
GRefPtr<GInputStream> m_inputStream;
GRefPtr<SoupMultipartInputStream> m_multipartInputStream;
GRefPtr<GCancellable> m_cancellable;
GRefPtr<GAsyncResult> m_pendingResult;
WebCore::ProtectionSpace m_protectionSpaceForPersistentStorage;
WebCore::Credential m_credentialForPersistentStorage;
WebCore::ResourceRequest m_currentRequest;
WebCore::ResourceResponse m_response;
Vector<char> m_readBuffer;
unsigned m_redirectCount { 0 };
uint64_t m_bodyDataTotalBytesSent { 0 };
GRefPtr<GFile> m_downloadDestinationFile;
GRefPtr<GFile> m_downloadIntermediateFile;
GRefPtr<GOutputStream> m_downloadOutputStream;
bool m_allowOverwriteDownload { false };
WebCore::NetworkLoadMetrics m_networkLoadMetrics;
MonotonicTime m_startTime;
bool m_isBlockingCookies { false };
RunLoop::Timer<NetworkDataTaskSoup> m_timeoutSource;
};
}