http2

type ConnSet struct {
	// contains filtered or unexported fields
}

type Dir uint8

type DirectConn struct {
	SrcAddr psnet.Addr
	DstAddr psnet.Addr
}

type FrameBase struct {
	DirectConn DirectConn
	// input or output ?
	InputFlag bool

	StreamID uint32
	Type     uint8
	Flags    uint8
	Length   uint32
	Payload  []byte
}

type FrameContinuation struct {
	EndHeader           bool
	HeaderBlockFragment []byte
	// contains filtered or unexported fields
}

type FrameData struct {
	EndStream bool
	Padded    bool
	// Frame Payload
	PadLength uint8
	Data      []byte
	// contains filtered or unexported fields
}

type FrameHeader struct {
	EndStream bool
	EndHeader bool
	Padded    bool
	// I don't care
	Priority bool
	// Frame Payload
	PadLength           uint8
	HeaderBlockFragment []byte
	// contains filtered or unexported fields
}

type FrameSetting struct {
	Ack bool
	// contains filtered or unexported fields
}

type GRPCMessage struct {
	// ------ complete gRPC Message------
	// https://github.com/grpc/grpc-go/blob/master/Documentation/encoding.md
	//	gRPC lets you use encoders other than Protobuf.
	//  gRPC is compatible with JSON, Thrift, Avro, Flatbuffers, Cap’n Proto, and even raw bytes!
	/*
				+--------------------+
				|  payloadFormat(8)  |
				+--------------------+------------------------------------------+
				|                          length(32)                           |
				+---------------------------------------------------------------+
				|                        encodedMessage(*)                  ... |
				+---------------------------------------------------------------+
			   payloadFormat: compressed or not?
		       encodedMessage: Protobuf,JSON,Thrift,etc.
	*/
	PayloadFormat  payloadFormat
	Length         uint32
	EncodedMessage []byte
}

type HTTPItem struct {
	EndHeader atomic.Bool
	EndStream atomic.Bool

	Headers *sync.Map                 `json:"headers"`
	DataBuf *util.GoroutineSafeBuffer `json:"-"`
}

type Http2Conn struct {
	DirectConn DirectConn

	Streams [StreamArraySize]*Stream
	// ###### for input ######
	Input *MessageParser
	// ###### for output ######
	Output *MessageParser

	Processor          *Processor
	RecordResponse     bool
	MaxHeaderStringLen uint32
}

type MessageParser struct {
	TCPBuffer           *TCPBuffer
	MaxDynamicTableSize uint32
	HeaderDecoder       *hpack.Decoder
}

type MethodInputOutput struct {
	InType  proto.Message
	OutType proto.Message
}

type NetPkg struct {
	SrcIP string
	DstIP string

	Ethernet  *layers.Ethernet
	IPv4      *layers.IPv4
	IPv6      *layers.IPv6
	TCP       *layers.TCP
	Direction Dir
}

type PBFinder interface {
	// svcAndMethod looks like"/helloworld.Greeter/SayHello"
	Get(svcAndMethod string) (*MethodInputOutput, error)
	GetDescriptorSource() grpcurl.DescriptorSource
}

type PBFinderDelegate struct {
	// contains filtered or unexported fields
}

type Processor struct {
	ConnStates      map[DirectConn]*TCPConnectionState
	ConnRepository  map[DirectConn]*Http2Conn
	InputChan       chan *NetPkg
	OutputChan      chan *protocol.Message
	Finder          PBFinder
	RecordResponse  bool
	TCPStateMachine *fsm.StateMachine
}

type Stream struct {
	StreamID       uint32
	RecordResponse bool
	Request        *HTTPItem
	Response       *HTTPItem
	// contains filtered or unexported fields
}

type TCPBuffer struct {
	List *skiplist.SkipList
	// contains filtered or unexported fields
}

type TCPConnectionState struct {
	State  string
	States []string
	// contains filtered or unexported fields
}

type TCPEventProcessor struct{}