NetworkDataTaskReplay.h [plain text]
#pragma once
#if ENABLE(NETWORK_CAPTURE)
#include "NetworkCaptureResource.h"
#include "NetworkDataTask.h"
#include <WebCore/ResourceRequest.h>
namespace WebCore {
class ResourceError;
class ResourceResponse;
}
namespace WebKit {
class NetworkDataTaskClient;
class NetworkLoadParameters;
class NetworkSession;
}
namespace WebKit {
namespace NetworkCapture {
struct RequestSentEvent;
struct ResponseReceivedEvent;
struct RedirectReceivedEvent;
struct RedirectSentEvent;
struct DataReceivedEvent;
struct FinishedEvent;
class NetworkDataTaskReplay : public NetworkDataTask {
public:
static Ref<NetworkDataTaskReplay> create(NetworkSession& session, NetworkDataTaskClient& client, const NetworkLoadParameters& parameters, Resource* resource)
{
return adoptRef(*new NetworkDataTaskReplay(session, client, parameters, resource));
}
void replayRequestSent(const RequestSentEvent&);
void replayResponseReceived(const ResponseReceivedEvent&);
void replayRedirectReceived(const RedirectReceivedEvent&);
void replayRedirectSent(const RedirectSentEvent&);
void replayDataReceived(const DataReceivedEvent&);
void replayFinished(const FinishedEvent&);
private:
NetworkDataTaskReplay(NetworkSession&, NetworkDataTaskClient&, const NetworkLoadParameters&, Resource*);
~NetworkDataTaskReplay() override;
void resume() override;
void suspend() override;
void cancel() override;
void complete();
void invalidateAndCancel() override;
State state() const override { return m_state; }
void enqueueEventHandler();
enum class Error {
NoError = 0,
NotFoundError = 1,
MethodNotAllowed = 5
};
void didReceiveResponse(WebCore::ResourceResponse&&);
void didFinish();
void didFinish(Error);
void didFinish(const WebCore::ResourceError&);
State m_state { State::Suspended };
WebCore::ResourceRequest m_currentRequest;
Resource* m_resource;
Resource::EventStream m_eventStream;
};
} }
#endif // ENABLE(NETWORK_CAPTURE)