#include "http2/adapter/recording_http2_visitor.h" #include "absl/strings/str_format.h" #include "http2/adapter/http2_protocol.h" #include "http2/adapter/http2_util.h" namespace http2 { namespace adapter { namespace test { int64_t RecordingHttp2Visitor::OnReadyToSend(absl::string_view serialized) { events_.push_back(absl::StrFormat("OnReadyToSend %d", serialized.size())); return serialized.size(); } void RecordingHttp2Visitor::OnConnectionError(ConnectionError error) { events_.push_back( absl::StrFormat("OnConnectionError %s", ConnectionErrorToString(error))); } bool RecordingHttp2Visitor::OnFrameHeader(Http2StreamId stream_id, size_t length, uint8_t type, uint8_t flags) { events_.push_back(absl::StrFormat("OnFrameHeader %d %d %d %d", stream_id, length, type, flags)); return true; } void RecordingHttp2Visitor::OnSettingsStart() { events_.push_back("OnSettingsStart"); } void RecordingHttp2Visitor::OnSetting(Http2Setting setting) { events_.push_back(absl::StrFormat( "OnSetting %s %d", Http2SettingsIdToString(setting.id), setting.value)); } void RecordingHttp2Visitor::OnSettingsEnd() { events_.push_back("OnSettingsEnd"); } void RecordingHttp2Visitor::OnSettingsAck() { events_.push_back("OnSettingsAck"); } bool RecordingHttp2Visitor::OnBeginHeadersForStream(Http2StreamId stream_id) { events_.push_back(absl::StrFormat("OnBeginHeadersForStream %d", stream_id)); return true; } Http2VisitorInterface::OnHeaderResult RecordingHttp2Visitor::OnHeaderForStream( Http2StreamId stream_id, absl::string_view name, absl::string_view value) { events_.push_back( absl::StrFormat("OnHeaderForStream %d %s %s", stream_id, name, value)); return HEADER_OK; } bool RecordingHttp2Visitor::OnEndHeadersForStream(Http2StreamId stream_id) { events_.push_back(absl::StrFormat("OnEndHeadersForStream %d", stream_id)); return true; } bool RecordingHttp2Visitor::OnBeginDataForStream(Http2StreamId stream_id, size_t payload_length) { events_.push_back( absl::StrFormat("OnBeginDataForStream %d %d", stream_id, payload_length)); return true; } bool RecordingHttp2Visitor::OnDataForStream(Http2StreamId stream_id, absl::string_view data) { events_.push_back(absl::StrFormat("OnDataForStream %d %s", stream_id, data)); return true; } void RecordingHttp2Visitor::OnEndStream(Http2StreamId stream_id) { events_.push_back(absl::StrFormat("OnEndStream %d", stream_id)); } void RecordingHttp2Visitor::OnRstStream(Http2StreamId stream_id, Http2ErrorCode error_code) { events_.push_back(absl::StrFormat("OnRstStream %d %s", stream_id, Http2ErrorCodeToString(error_code))); } void RecordingHttp2Visitor::OnCloseStream(Http2StreamId stream_id, Http2ErrorCode error_code) { events_.push_back(absl::StrFormat("OnCloseStream %d %s", stream_id, Http2ErrorCodeToString(error_code))); } void RecordingHttp2Visitor::OnPriorityForStream(Http2StreamId stream_id, Http2StreamId parent_stream_id, int weight, bool exclusive) { events_.push_back(absl::StrFormat("OnPriorityForStream %d %d %d %d", stream_id, parent_stream_id, weight, exclusive)); } void RecordingHttp2Visitor::OnPing(Http2PingId ping_id, bool is_ack) { events_.push_back(absl::StrFormat("OnPing %d %d", ping_id, is_ack)); } void RecordingHttp2Visitor::OnPushPromiseForStream( Http2StreamId stream_id, Http2StreamId promised_stream_id) { events_.push_back(absl::StrFormat("OnPushPromiseForStream %d %d", stream_id, promised_stream_id)); } bool RecordingHttp2Visitor::OnGoAway(Http2StreamId last_accepted_stream_id, Http2ErrorCode error_code, absl::string_view opaque_data) { events_.push_back( absl::StrFormat("OnGoAway %d %s %s", last_accepted_stream_id, Http2ErrorCodeToString(error_code), opaque_data)); return true; } void RecordingHttp2Visitor::OnWindowUpdate(Http2StreamId stream_id, int window_increment) { events_.push_back( absl::StrFormat("OnWindowUpdate %d %d", stream_id, window_increment)); } int RecordingHttp2Visitor::OnBeforeFrameSent(uint8_t frame_type, Http2StreamId stream_id, size_t length, uint8_t flags) { events_.push_back(absl::StrFormat("OnBeforeFrameSent %d %d %d %d", frame_type, stream_id, length, flags)); return 0; } int RecordingHttp2Visitor::OnFrameSent(uint8_t frame_type, Http2StreamId stream_id, size_t length, uint8_t flags, uint32_t error_code) { events_.push_back(absl::StrFormat("OnFrameSent %d %d %d %d %d", frame_type, stream_id, length, flags, error_code)); return 0; } bool RecordingHttp2Visitor::OnInvalidFrame(Http2StreamId stream_id, InvalidFrameError error) { events_.push_back(absl::StrFormat("OnInvalidFrame %d %s", stream_id, InvalidFrameErrorToString(error))); return true; } void RecordingHttp2Visitor::OnBeginMetadataForStream(Http2StreamId stream_id, size_t payload_length) { events_.push_back(absl::StrFormat("OnBeginMetadataForStream %d %d", stream_id, payload_length)); } bool RecordingHttp2Visitor::OnMetadataForStream(Http2StreamId stream_id, absl::string_view metadata) { events_.push_back( absl::StrFormat("OnMetadataForStream %d %s", stream_id, metadata)); return true; } bool RecordingHttp2Visitor::OnMetadataEndForStream(Http2StreamId stream_id) { events_.push_back(absl::StrFormat("OnMetadataEndForStream %d", stream_id)); return true; } void RecordingHttp2Visitor::OnErrorDebug(absl::string_view message) { events_.push_back(absl::StrFormat("OnErrorDebug %s", message)); } } // namespace test } // namespace adapter } // namespace http2