common

type Agent struct {
	Name        string `json:"name" yaml:"name"`
	Identifier  string `json:"identifier" yaml:"identifier" gorm:"primary_key"`
	Description string `json:"description" yaml:"description"`
}

type AgentConfig struct {
	Basic struct {
		Server  string `yaml:"server"`
		Port    int    `yaml:"port"`
		AgentId string `yaml:"agentId"`
	}
	Log   LogConfig
	Miscs struct {
		HttpTimeout int `yaml:"httpTimeout"`
	}
}

type AgentManager interface {
	List() ([]Agent, error)
	Add(node Agent) (*Agent, error)
	Update(node Agent) (*Agent, error)
	DeleteById(identifier string) error
}

type AgentMemoryManager struct {
	Cache map[string]*Agent
}

type BasicCommand struct {
	Identifier string
	Sequence   int
	CType      CmdType
}

type BasicResponse struct {
	ResponseType ResponseType
	Identifier   string
	Sequence     int
	Code         ResponseCode
	Description  string
}

type CmdType int

type Command interface {
	GetSequence() int
	Json() []byte
	Validate() *BasicResponse
}

type HttpCommand struct {
	BasicCommand
	HttpRequest
}

type HttpRequest struct {
	Schema   string
	Method   string
	Host     string
	Port     int
	BasePath string
	Path     string
	Headers  http.Header
	Body     []byte
}

type HttpResponse struct {
	BasicResponse
	http.Header
	HttpResponseCode int
	HttpResponseText string
	Body             []byte
}

type LogConfig struct {
	Debug      bool   `yaml:"debug"`
	ConsoleLog bool   `yaml:"consoleLog"`
	LogPath    string `yaml:"logPath"`
}

type MWMemoryCache struct {
	Cache map[string]Middlewares
}

type Middleware struct {
	Name string `json:"name" yaml:"name"`
	Path string `json:"path" yaml:"path"`
	Port int    `json:"port" yaml:"port"`
}

type MiddlewareManager interface {
	List(nodeid string) (Middlewares, error)
	Add(nodeid string, middleware Middleware) (*Middleware, error)
	Update(nodeid string, middleware Middleware) (*Middleware, error)
	DeleteByName(nodeid string, name string) error
	GetByName(nodeid string, name string) error
}

type Middlewares []Middleware

type PackageHeader struct {
	// major_version: Version << 24
	// minor_version: Version << 16
	// fix_version: Version << 8
	// Version => {major_version} | {minor_version} | {fix_version}
	Version uint32

	// the package type
	// message package: 0x01
	// stream package: 0x02
	// user-defined package: 0x04
	PackageType PackageType

	// flags
	Flags uint8

	// payload length
	// the size of package payload
	PayloadLen uint32
}

type PackageType uint8

type QConnectionManager map[string]*QuicConnection

type QuicConnection struct {
	Session quic.Session
	Stream  quic.Stream

	Cancel context.CancelFunc
	// contains filtered or unexported fields
}

type Reader struct {
	Reader io.Reader
}

type Response interface {
	GetSequence() int
	GetResponseCode() ResponseCode
	GetDescription() string
	Json() []byte
	Validate() error
}

type ResponseCode int

type ResponseType int

type ServerConfig struct {
	Basic struct {
		BindAddr string `yaml:"bindAddr"`
		BindPort int    `yaml:"bindPort"`
	}
	Log  LogConfig
	Rest struct {
		RestBindAddr string `yaml:"restBindAddr"`
		RestBindPort int    `yaml:"restBindPort"`
		EnableRest   bool   `yaml:"enableRest"`
	}
}

type Writer struct {
	Writer io.Writer
}