core

type EmptyReq struct {
}

type EmptyResp struct {
}

type EndpointCollector interface {
	SetEndpointNode(key string, et EndpointMaker)
	GetEndpointNode(key string) EndpointMaker
	GetEndpointNodesMapper() map[string]EndpointMaker
	Middlewares() []gokitendpoint.Middleware
	RegisterMiddlewares(mws ...gokitendpoint.Middleware)
}

type EndpointMaker interface {
	Name() string
	Request() interface{}
	Response() interface{}
	Middlewares() []gokitendpoint.Middleware
	Endpoint(mws ...gokitendpoint.Middleware) gokitendpoint.Endpoint
	RegisterMiddlewares(mws ...gokitendpoint.Middleware)
	GenerateHttpTransport() HttpTransportI
	GenerateNatsMicroTransport() NatsMicroTransportI
}

type EndpointNode[REQ, RESP any] struct {
	EndpointName string
	ServiceFunc  func(context.Context, REQ) (RESP, error)
	// contains filtered or unexported fields
}

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

type ErrDetail struct {
	Detail string `json:"detail"` // 错误详细信息
}

type GenericCommonResponse[T any] struct {
	Code int    `json:"code" default:"200"` // 业务Code
	Msg  string `json:"msg"`                // 消息
	Data T      `json:"data"`               // 数据
}

type GenericModelList[T any] struct {
	List []T `json:"list"`
}

type GenericResponse[T any] struct {
	Code int    `json:"code" default:"0"`
	Msg  string `json:"msg"`
	Data T      `json:"data"`
}

type HttpTransport[REQ, RESP any] struct {
	EndpointName string
}

type HttpTransportI interface {
	MakeDecodeRequestFunc() coder.DecodeHttpRequestFunc
	MakeEncodeRequestFunc() coder.EncodeHttpRequestFunc
	MakeDecodeResponseFunc() coder.DecodeHttpResponseFunc
	MakeEncodeResponseFunc() coder.EncodeHttpResponseFunc
}

type IdPathReq struct {
	Id string `json:"id" form:"id" uri:"id"` // ID
}

type IdReq struct {
	Id string `json:"id" form:"id" uri:"id"` // ID
}

type IdsReq struct {
	Ids []string `json:"ids"` // ID 列表
}

type MapReq map[string]interface{}

type NatsMicroTransport[REQ, RESP any] struct {
	EndpointName string
}

type NatsMicroTransportI interface {
	MakeDecodeRequestFunc() coder.DecodeNatsMicroRequestFunc
	MakeEncodeRequestFunc() coder.EncodeNatsMicroRequestFunc
	MakeDecodeResponseFunc() coder.DecodeNatsMicroResponseFunc
	MakeEncodeResponseFunc() coder.EncodeNatsMicroResponseFunc
}

type NatsTransport[REQ, RESP any] struct {
	EndpointName string
}

type NatsTransportI interface {
	MakeDecodeRequestFunc() natstransport.DecodeRequestFunc
	MakeEncodeRequestFunc() natstransport.EncodeRequestFunc
	MakeDecodeResponseFunc() natstransport.DecodeResponseFunc
	MakeEncodeResponseFunc() natstransport.EncodeResponseFunc
}

type PageReq struct {
	Page     int64 `json:"page" form:"page"`         // 页码
	PageSize int64 `json:"pageSize" form:"pageSize"` // 页长
}

type PageResp struct {
	Total    int64 `json:"total"`    // 记录总数
	Page     int64 `json:"page"`     // 页码
	PageSize int64 `json:"pageSize"` // 页长
}

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

type PublisherOption func(*Publisher)

type RequestFunc[T any] func(ctx context.Context, req any) (resp GenericResponse[T], err error)

type Response struct {
	Code int         `json:"code" default:"0"`
	Msg  string      `json:"msg"`
	Data interface{} `json:"data"`
}

type SearchReq struct {
	Search string `json:"search" form:"search"` // 搜索字符串
}