gosrv

type BootHandler func() (err error)

type Client interface {
	UpdateHandler(subscribers ...UpdateSubscriber)
	On(method, channel string, handler UpdateHandler)
	SendRequest(method, channel string, data any) (resp Response, err error)
	Start(errChan ...chan error)
	Stop() error
}

type ClientBootHandler func(client NetIO) (err error)

type ClientConn interface {
	NetConn
	ClientUpdater

	ReadRequest() (req *Request, err error)
	WriteResponse(data *Response) (n int, err error)
	WriteError(data *Data) (n int, err error)
}

type ClientOptions struct {
	ServerHost  string `binding:"required"`
	ServerPort  string `binding:"required"`
	Info        *Info  `binding:"required"`
	CertOptions *cert.Options
}

type ClientReadyHandler func(client ClientUpdater) (err error)

type ClientUpdater interface {
	WriteUpdate(data Update) (n int, err error)
}

type Context interface {
	ParseContent(v any) (err error)
	Update(v any, codes ...int) (n int, err error)
	UpdateAll(v any, codes ...int)
	Output(v any, code ...int) (data Output)
	Success(v any) (data Output)
	Error(v any, code ...int) (data Output)
}

type Data interface {
	// SetContent(v any) (err error)
	ParseContent(v any) (err error)
}

type DataWithCode interface {
	Data

	GetError() (err error)
}

type Info struct {
	Name        string `json:"name"`
	Alias       string `json:"alias"`
	Description string `json:"description"`
}

type KCallback[K any] func(i K) string

type KCollection[K any, T any] interface {
	Has(i K) bool
	GetAll(i K) (values []T)
	Get(i K) (value T, ok bool)
	Add(i K, value T)
	AddOne(i K, value T) (ok bool)
}

type MCollection[T any] interface {
	Has(method, channel string) bool
	GetAll(method, channel string) (values []T)
	Get(method, channel string) (value T, ok bool)
	Add(method, channel string, value T)
	AddOne(method, channel string, value T) (ok bool)
}

type NetConn interface {
	NetIO

	ReadInfo() (*Info, error)
	WriteInfo(info *Info) (n int, err error)

	Close() error
}

type NetIO interface {
	NetReader
	NetWriter
}

type NetReader interface {
	Read(b []byte) (n int, err error)
	ReadByte() (b byte, err error)
	ReadBytes(delim byte) (b []byte, err error)
	ReadLine(delim byte) (line []byte, isPrefix bool, err error)
	ReadRune() (r rune, size int, err error)
	ReadSlice(delim byte) (line []byte, err error)
	ReadString(delim byte) (s string, err error)
}

type NetWriter interface {
	Write(b []byte) (n int, err error)
	WriteLine(b []byte) (n int, err error)
	WriteString(s string) (n int, err error)
	WriteStringLine(s string) (n int, err error)
}

type Options interface {
	// contains filtered or unexported methods
}

type Output interface {
	GetCode() int
	GetContent() any
}

type ReadyHandler func() (err error)

type Request interface {
	Data
}

type RequestHandler func(ctx Context) Output

type RequestHandlerCollection interface {
	On(method, channel string, handler RequestHandler) (err error)
}

type RequestHandlerSubscriber func(collection RequestHandlerCollection)

type Response interface {
	DataWithCode

	GetRequest() Request
}

type ResponseHandler func(data *pResponse)

type Server interface {
	Listen(errChan ...chan error)
	OnBoot(handlers ...BootHandler)
	OnReady(handlers ...ReadyHandler)
	OnClientBoot(handlers ...ClientBootHandler)
	OnClientReady(handlers ...ClientReadyHandler)
	RequestHandlers(subscribers ...RequestHandlerSubscriber)
	Stop() error
}

type ServerConn interface {
	NetConn
}

type ServerOptions struct {
	Host        string `binding:"required"`
	Port        string `binding:"required"`
	Info        *Info  `binding:"required"`
	CertOptions *cert.Options
}

type Update interface {
	DataWithCode
}

type UpdateHandler func(data Update)

type UpdateSubscriber func(collection MCollection[UpdateHandler])