ziface

type Chain interface {
	Request() Request
	Proceed(Request) Response
}

type HandleStep int

type HeartBeatMsgFunc func(IConnection) []byte

type HeartBeatOption struct {
	MakeMsg          HeartBeatMsgFunc //用户自定义的心跳检测消息处理方法
	OnRemoteNotAlive OnRemoteNotAlive //用户自定义的远程连接不存活时的处理方法
	HeadBeatMsgID    uint32           //用户自定义的心跳检测消息ID
	Router           IRouter          //用户自定义的心跳检测消息业务处理路由
}

type IClient interface {
	Start()
	Stop()
	AddRouter(msgID uint32, router IRouter)
	Conn() IConnection
	SetOnConnStart(func(IConnection))                         //设置该Client的连接创建时Hook函数
	SetOnConnStop(func(IConnection))                          //设置该Client的连接断开时的Hook函数
	GetOnConnStart() func(IConnection)                        //获取该Client的连接创建时Hook函数
	GetOnConnStop() func(IConnection)                         //设置该Client的连接断开时的Hook函数
	GetPacket() IDataPack                                     //获取Client绑定的数据协议封包方式
	SetPacket(IDataPack)                                      //设置Client绑定的数据协议封包方式
	GetMsgHandler() IMsgHandle                                //获取Client绑定的消息处理模块
	StartHeartBeat(time.Duration)                             //启动心跳检测
	StartHeartBeatWithOption(time.Duration, *HeartBeatOption) //启动心跳检测(自定义回调)
	GetLengthField() *LengthField
	SetDecoder(IDecoder)
}

type IConnManager interface {
	Add(conn IConnection)                   //添加链接
	Remove(conn IConnection)                //删除连接
	Get(connID uint64) (IConnection, error) //利用ConnID获取链接
	Len() int                               //获取当前连接
	ClearConn()                             //删除并停止所有链接
	GetAllConnID() []uint64                 //获取所有连接ID
}

type IConnection interface {
	Start()                   //启动连接，让当前连接开始工作
	Stop()                    //停止连接，结束当前连接状态
	Context() context.Context //返回ctx，用于用户自定义的go程获取连接退出状态

	GetConnection() net.Conn //从当前连接获取原始的socket TCPConn
	GetConnID() uint64       //获取当前连接ID
	RemoteAddr() net.Addr    //获取链接远程地址信息
	LocalAddr() net.Addr     //获取链接本地地址信息

	Send(data []byte) error
	SendToQueue(data []byte) error
	SendMsg(msgID uint32, data []byte) error     //直接将Message数据发送数据给远程的TCP客户端(无缓冲)
	SendBuffMsg(msgID uint32, data []byte) error //直接将Message数据发送给远程的TCP客户端(有缓冲)

	SetProperty(key string, value interface{})   //设置链接属性
	GetProperty(key string) (interface{}, error) //获取链接属性
	RemoveProperty(key string)                   //移除链接属性
	IsAlive() bool                               //判断当前连接是否存活
}

type IDataPack interface {
	GetHeadLen() uint32                //获取包头长度方法
	Pack(msg IMessage) ([]byte, error) //封包方法
	Unpack([]byte) (IMessage, error)   //拆包方法
}

type IDecoder interface {
	Interceptor
	GetLengthField() *LengthField
}

type ILengthField interface {
	Decode(buff []byte) [][]byte
}

type ILogger interface {
	//没有context的日志接口
	InfoF(format string, v ...interface{})
	ErrorF(format string, v ...interface{})
	DebugF(format string, v ...interface{})

	//携带context的日志接口
	InfoFX(ctx context.Context, format string, v ...interface{})
	ErrorFX(ctx context.Context, format string, v ...interface{})
	DebugFX(ctx context.Context, format string, v ...interface{})
}

type IMessage interface {
	GetDataLen() uint32 //获取消息数据段长度
	GetMsgID() uint32   //获取消息ID
	GetData() []byte    //获取消息内容
	GetRawData() []byte //获取原始数据

	SetMsgID(uint32)   //设计消息ID
	SetData([]byte)    //设计消息内容
	SetDataLen(uint32) //设置消息数据段长度
}

type IMsgHandle interface {
	DoMsgHandler(request IRequest) //马上以非阻塞方式处理消息
	//为消息添加具体的处理逻辑, msgID，支持整型，字符串
	AddRouter(msgID uint32, router IRouter)
	StartWorkerPool()                    //启动worker工作池
	SendMsgToTaskQueue(request IRequest) //将消息交给TaskQueue,由worker进行处理

	Decode(request IRequest)                //
	AddInterceptor(interceptor Interceptor) //注册责任链任务入口，每个拦截器处理完后，数据都会传递至下一个拦截器，使得消息可以层层处理层层传递，顺序取决于注册顺序
}

type IRequest interface {
	GetConnection() IConnection //获取请求连接信息
	GetData() []byte            //获取请求消息的数据
	GetMsgID() uint32           //获取请求的消息ID

	GetMessage() IMessage //获取请求消息的原始数据 add by uuxia 2023-03-10

	GetResponse() Response //获取解析完后序列化数据
	SetResponse(Response)  //设置解析完后序列化数据

	BindRouter(router IRouter) //绑定这次请求由哪个路由处理
	Call()                     //转进到下一个处理器开始执行 但是调用此方法的函数会根据先后顺序逆序执行
	Abort()                    //终止处理函数的运行 但调用此方法的函数会执行完毕
	//慎用，会导致循环调用
	Goto(HandleStep) //指定接下来的Handle去执行哪个Handler函数
}

type IRouter interface {
	PreHandle(request IRequest)  //在处理conn业务之前的钩子方法
	Handle(request IRequest)     //处理conn业务的方法
	PostHandle(request IRequest) //处理conn业务之后的钩子方法
}

type IServer interface {
	Start()                                                   //启动服务器方法
	Stop()                                                    //停止服务器方法
	Serve()                                                   //开启业务服务方法
	AddRouter(msgID uint32, router IRouter)                   //路由功能：给当前服务注册一个路由业务方法，供客户端链接处理使用
	GetConnMgr() IConnManager                                 //得到链接管理
	SetOnConnStart(func(IConnection))                         //设置该Server的连接创建时Hook函数
	SetOnConnStop(func(IConnection))                          //设置该Server的连接断开时的Hook函数
	GetOnConnStart() func(IConnection)                        //得到该Server的连接创建时Hook函数
	GetOnConnStop() func(IConnection)                         //得到该Server的连接断开时的Hook函数
	GetPacket() IDataPack                                     //获取Server绑定的数据协议封包方式
	GetMsgHandler() IMsgHandle                                //获取Server绑定的消息处理模块
	SetPacket(IDataPack)                                      //设置Server绑定的数据协议封包方式
	StartHeartBeat(time.Duration)                             //启动心跳检测
	StartHeartBeatWithOption(time.Duration, *HeartBeatOption) //启动心跳检测(自定义回调)
	GetLengthField() *LengthField
	SetDecoder(IDecoder)
}

type Inotify interface {
	//是否有这个id
	HasIdConn(id uint64) bool
	//存储的map长度
	ConnNums() int
	//添加链接
	SetNotifyID(Id uint64, conn IConnection)
	//得到某个链接
	GetNotifyByID(Id uint64) (IConnection, error)
	//删除某个链接
	DelNotifyByID(Id uint64)
	//通知某个id的方法
	NotifyToConnByID(Id uint64, MsgId uint32, data []byte) error
	//通知所有人
	NotifyAll(MsgId uint32, data []byte) error
	//通过缓冲队列通知某个id的方法
	NotifyBuffToConnByID(Id uint64, MsgId uint32, data []byte) error
	//缓冲队列通知所有人
	NotifyBuffAll(MsgId uint32, data []byte) error
}

type Interceptor interface {
	Intercept(Chain) Response
}

type InterceptorBuilder interface {
	AddInterceptor(interceptor Interceptor)
	Execute(request Request) Response
}

type LengthField struct {
	//大小端排序
	//大端模式：是指数据的高字节保存在内存的低地址中，而数据的低字节保存在内存的高地址中，地址由小向大增加，而数据从高位往低位放；
	//小端模式：是指数据的高字节保存在内存的高地址中，而数据的低字节保存在内存的低地址中，高地址部分权值高，低地址部分权值低，和我们的日常逻辑方法一致。
	//不了解的自行查阅一下资料
	Order               binary.ByteOrder
	MaxFrameLength      int64 //最大帧长度
	LengthFieldOffset   int   //长度字段偏移量
	LengthFieldLength   int   //长度域字段的字节数
	LengthAdjustment    int   //长度调整
	InitialBytesToStrip int   //需要跳过的字节数
}

type OnRemoteNotAlive func(IConnection)

type Request interface {
}

type Response interface {
}