common

type ConnOptions struct {
	ReadBuffer  *int // readBuffer sets the size of the operating system's receive buffer associated with the connection. [default]: 1024*1024/系统默认
	WriteBuffer *int // writeBuffer sets the size of the operating system's transmit buffer associated with the connection. [default]: 1024*1024/系统默认
}

type Connect struct {
	IHandler IHandler
	IRemote  IRemote
}

type DefaultRemote struct {
	SendChan         chan any // 发送管道
	CancelFunc       context.CancelFunc
	Object           any              // 保存 应用层数据
	DisconnectReason DisconnectReason // 断开原因
	HeaderStrategy   xpacket.IHeaderStrategy
	PacketLimit      IPacketLimit
}

type Disconnect struct {
	IHandler IHandler
	IRemote  IRemote
}

type DisconnectReason int

type IHandler interface {
	OnConnect(remote IRemote) error                                         // 处理-链接成功-对方链接过来
	OnCheckPacketLength(length uint32) error                                // 处理-检查长度是否合法(包头中) [recv 协程中]
	OnCheckPacketLimit(remote IRemote) error                                // 处理-限流 [recv 协程中]
	OnUnmarshalPacket(remote IRemote, data []byte) (xpacket.IPacket, error) // 处理-数据包-反序列化 [recv 协程中] // data:数据 [NOTE] 如果保存该参数 则 需要copy
	OnPacket(remote IRemote, packet xpacket.IPacket) error                  // 处理-数据包
	OnDisconnect(remote IRemote) error                                      // 处理-断开链接
}

type IPacketLimit interface {
	IsOverload(cnt uint32, nowTime time.Time) bool // 是否超载, cnt 为当前包数量, nowTime 为当前时间
}

type IRemote interface {
	ISend
	IPacketLimit
	IsConnect() bool
	Start(connOptions *ConnOptions, iout xcontrol.IOut, handler IHandler)
	Stop()
	GetIP() string
	GetDisconnectReason() DisconnectReason
	SetDisconnectReason(reason DisconnectReason)
}

type ISend interface {
	Send(packet xpacket.IPacket) error
}

type KCPOptions struct {
	SndWindowSize *int           // 窗口大小-发送 [default:512]
	RcvWindowSize *int           // 窗口大小-接收 [default:512]
	Nodelay       *int           // 无延迟 0:关闭 1:打开 [default:1]
	Interval      *int           // 间隔 [default:20ms]
	Resend        *int           // 重传模式 [default:2]
	Nc            *int           // 关闭Nagle算法 0:打开 1:关闭 [default:1]
	AckNodelay    *bool          // 关闭延迟确认 [default:true]
	Mtu           *int           // 最大传输单元 [default:1350]
	BlockCrypt    kcp.BlockCrypt //加密,解密 [default:nil]
	Fec           *bool          // 是否开启FEC [default:false]
	DataShards    *int           // Fec: true 数据分片数 [default: 10] Fec: false 数据分片数 [default: 0]
	ParityShards  *int           // Fec: true 奇偶校验分片数 [default: 3] Fec: false 奇偶校验分片数 [default: 0]
}

type PackLimitDefault struct {
	MaxCntPerSec uint32    // 最大包数量-每秒
	Cnt          uint32    // 包数量
	Time         time.Time // 时间
}

type Packet struct {
	IHandler IHandler
	IRemote  IRemote
	IPacket  xpacket.IPacket
}

type PacketLimitOptions struct {
	NewPacketLimitFunc func(maxCntPerSec uint32) IPacketLimit // 创建包限制器
	MaxCntPerSec       uint32                                 // 最大包数量-每秒
}

type Status struct {
	Inactive       bool               // 非活跃状态
	InactiveStart  int64              // 非活跃开始时间戳
	InactiveData   []byte             // 非活跃期间缓存的数据
	DeathTimestamp int64              // 死亡时间戳
	DeathCallback  xcontrol.ICallBack // 死亡时回调函数
}