ServiceWorkerClientFetch.h [plain text]
#pragma once
#if ENABLE(SERVICE_WORKER)
#include "DataReference.h"
#include "FormDataReference.h"
#include "MessageReceiver.h"
#include "MessageSender.h"
#include <WebCore/FetchIdentifier.h>
#include <WebCore/ResourceError.h>
#include <WebCore/ResourceLoader.h>
#include <wtf/CompletionHandler.h>
namespace WebKit {
class WebSWClientConnection;
class WebServiceWorkerProvider;
class ServiceWorkerClientFetch final : public RefCounted<ServiceWorkerClientFetch>, public IPC::MessageReceiver {
public:
enum class Result { Succeeded, Cancelled, Unhandled };
using Callback = WTF::CompletionHandler<void(Result)>;
static Ref<ServiceWorkerClientFetch> create(WebServiceWorkerProvider&, Ref<WebCore::ResourceLoader>&&, WebCore::FetchIdentifier, Ref<WebSWClientConnection>&&, bool shouldClearReferrerOnHTTPSToHTTPRedirect, Callback&&);
~ServiceWorkerClientFetch();
void start();
void didReceiveMessage(IPC::Connection&, IPC::Decoder&) final;
void cancel();
bool isOngoing() const { return !!m_callback; }
private:
ServiceWorkerClientFetch(WebServiceWorkerProvider&, Ref<WebCore::ResourceLoader>&&, WebCore::FetchIdentifier, Ref<WebSWClientConnection>&&, bool shouldClearReferrerOnHTTPSToHTTPRedirect, Callback&&);
std::optional<WebCore::ResourceError> validateResponse(const WebCore::ResourceResponse&);
void didReceiveResponse(WebCore::ResourceResponse&&);
void didReceiveData(const IPC::DataReference&, int64_t encodedDataLength);
void didReceiveFormData(const IPC::FormDataReference&);
void didFinish();
void didFail(WebCore::ResourceError&&);
void didNotHandle();
void continueLoadingAfterCheckingResponse();
WebServiceWorkerProvider& m_serviceWorkerProvider;
RefPtr<WebCore::ResourceLoader> m_loader;
WebCore::FetchIdentifier m_identifier;
Ref<WebSWClientConnection> m_connection;
Callback m_callback;
enum class RedirectionStatus { None, Receiving, Following, Received };
RedirectionStatus m_redirectionStatus { RedirectionStatus::None };
bool m_shouldClearReferrerOnHTTPSToHTTPRedirect { true };
RefPtr<WebCore::SharedBuffer> m_buffer;
int64_t m_encodedDataLength { 0 };
bool m_isCheckingResponse { false };
bool m_didFinish { false };
bool m_didFail { false };
WebCore::ResourceError m_error;
WebCore::ServiceWorkerRegistrationIdentifier m_serviceWorkerRegistrationIdentifier;
};
}
#endif // ENABLE(SERVICE_WORKER)