traffic

type BodyRef struct {
	Path      string `json:"path,omitempty"`
	Size      int64  `json:"size"`
	SHA256    string `json:"sha256,omitempty"`
	Complete  bool   `json:"complete"`
	Truncated bool   `json:"truncated,omitempty"`
}

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

type CaptureConfig struct {
	Mode         CaptureMode `protobuf:"varint,1,opt,name=mode,proto3,enum=aop.traffic.CaptureMode" json:"mode,omitempty"`
	DecryptHttps bool        `protobuf:"varint,2,opt,name=decrypt_https,json=decryptHttps,proto3" json:"decrypt_https,omitempty"` // intercept CONNECT to MITM-decrypt HTTPS
	Filter       *FlowFilter `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`                                  // record only matching flows
	Stream       bool        `protobuf:"varint,4,opt,name=stream,proto3" json:"stream,omitempty"`                                 // push Flow messages as they are captured
	// contains filtered or unexported fields
}

type CaptureMode int32

type CaptureState struct {
	Mode      CaptureMode `protobuf:"varint,1,opt,name=mode,proto3,enum=aop.traffic.CaptureMode" json:"mode,omitempty"`
	Capturing bool        `protobuf:"varint,2,opt,name=capturing,proto3" json:"capturing,omitempty"`
	// contains filtered or unexported fields
}

type Configure struct {
	Routing *RoutingConfig `protobuf:"bytes,1,opt,name=routing,proto3" json:"routing,omitempty"`
	Capture *CaptureConfig `protobuf:"bytes,2,opt,name=capture,proto3" json:"capture,omitempty"`
	// contains filtered or unexported fields
}

type Exchange struct {
	ID       string
	Request  Request
	Response *Response
	Error    string
	Complete bool
}

type Flow struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ToolId    string                 `protobuf:"bytes,2,opt,name=tool_id,json=toolId,proto3" json:"tool_id,omitempty"`
	Error     string                 `protobuf:"bytes,12,opt,name=error,proto3" json:"error,omitempty"`
	Complete  bool                   `protobuf:"varint,13,opt,name=complete,proto3" json:"complete,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Request   *HttpRequest           `protobuf:"bytes,15,opt,name=request,proto3" json:"request,omitempty"`
	Response  *HttpResponse          `protobuf:"bytes,16,opt,name=response,proto3" json:"response,omitempty"` // absent when no response was received
	// contains filtered or unexported fields
}

type FlowFilter struct {
	Host   string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`     // host substring
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // status class or code, e.g. "2xx", "404", "5xx"
	Type   string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`     // Content-Type substring
	Last   uint32 `protobuf:"varint,4,opt,name=last,proto3" json:"last,omitempty"`    // return only the last N flows (Query)
	// contains filtered or unexported fields
}

type Header struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type HttpRequest struct {
	Method   string    `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Url      string    `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Protocol string    `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Headers  []*Header `protobuf:"bytes,4,rep,name=headers,proto3" json:"headers,omitempty"`
	Body     []byte    `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type HttpResponse struct {
	StatusCode   int32     `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	ReasonPhrase string    `protobuf:"bytes,2,opt,name=reason_phrase,json=reasonPhrase,proto3" json:"reason_phrase,omitempty"`
	Headers      []*Header `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
	Body         []byte    `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type Pair struct {
	Name  string
	Value string
}

type ProtocolMessage struct {

	// Types that are valid to be assigned to Message:
	//
	//	*ProtocolMessage_Configure
	//	*ProtocolMessage_Query
	//	*ProtocolMessage_State
	//	*ProtocolMessage_Flow
	Message isProtocolMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type ProtocolMessage_Configure struct {
	Configure *Configure `protobuf:"bytes,10,opt,name=configure,proto3,oneof"`
}

type ProtocolMessage_Flow struct {
	Flow *Flow `protobuf:"bytes,13,opt,name=flow,proto3,oneof"`
}

type ProtocolMessage_Query struct {
	Query *Query `protobuf:"bytes,11,opt,name=query,proto3,oneof"`
}

type ProtocolMessage_State struct {
	State *State `protobuf:"bytes,12,opt,name=state,proto3,oneof"`
}

type Query struct {
	State  bool        `protobuf:"varint,1,opt,name=state,proto3" json:"state,omitempty"`  // request current State
	Flows  bool        `protobuf:"varint,2,opt,name=flows,proto3" json:"flows,omitempty"`  // request recorded flows (batched Flow replies)
	Filter *FlowFilter `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"` // filter for flows = true
	// contains filtered or unexported fields
}

type Request struct {
	Method   string
	URL      string
	Protocol string
	Headers  []Pair
	Body     []byte
	BodyRef  *BodyRef `json:"-"`
}

type Response struct {
	StatusCode   int
	ReasonPhrase string
	Headers      []Pair
	Body         []byte
	BodyRef      *BodyRef `json:"-"`
}

type RoutingConfig struct {
	Mode     RoutingMode `protobuf:"varint,1,opt,name=mode,proto3,enum=aop.traffic.RoutingMode" json:"mode,omitempty"`
	Url      string      `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`           // proxy URL (PROXY) or subscription URL (SUBSCRIBE/AUTO)
	Selector string      `protobuf:"bytes,3,opt,name=selector,proto3" json:"selector,omitempty"` // node name or 1-based index (SWITCH)
	Type     string      `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`         // protocol filter, e.g. "trojan,vless" (AUTO)
	Name     string      `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`         // node name keyword (AUTO)
	Country  string      `protobuf:"bytes,6,opt,name=country,proto3" json:"country,omitempty"`   // ISO 3166-1 alpha-2 filter, e.g. "HK,JP" (AUTO)
	Strategy string      `protobuf:"bytes,7,opt,name=strategy,proto3" json:"strategy,omitempty"` // adaptive|url-test|round-robin|random (AUTO)
	// contains filtered or unexported fields
}

type RoutingMode int32

type RoutingState struct {
	ActiveNode string `protobuf:"bytes,1,opt,name=active_node,json=activeNode,proto3" json:"active_node,omitempty"`
	EgressUrl  string `protobuf:"bytes,2,opt,name=egress_url,json=egressUrl,proto3" json:"egress_url,omitempty"`
	Auto       bool   `protobuf:"varint,3,opt,name=auto,proto3" json:"auto,omitempty"`
	// contains filtered or unexported fields
}

type State struct {
	Routing *RoutingState `protobuf:"bytes,1,opt,name=routing,proto3" json:"routing,omitempty"`
	Capture *CaptureState `protobuf:"bytes,2,opt,name=capture,proto3" json:"capture,omitempty"`
	Error   string        `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type WebSocketExchange struct {
	ID        string
	URL       string
	Protocol  string
	Headers   []Pair
	Messages  []WebSocketMessage
	StartTime time.Time
	EndTime   time.Time
	Complete  bool
	Error     string
}

type WebSocketMessage struct {
	Direction string
	Type      string
	Body      []byte
	Timestamp time.Time
}