service

type IRobot interface {
	GetRobotByUserId(ctx context.Context, userId int) (*model.Robot, error)
}

type IServerConsume interface {
	// 触发回调事件
	Call(ctx context.Context, event string, data []byte)
}

type IServerEvent interface {
	Call(ctx context.Context, client socket.IClient, event string, data []byte)
	// 连接成功回调事件
	OnOpen(client socket.IClient)
	// 消息回调事件
	OnMessage(client socket.IClient, message []byte)
	// 连接关闭回调事件
	OnClose(client socket.IClient, code int, text string)
}

type IServerSubscribe interface {
	// 初始化连接
	Conn(w http.ResponseWriter, r *http.Request) error
	NewClient(uid int, conn socket.IConn) error
	// Start 启动服务
	Start(ctx context.Context, eg *errgroup.Group)
	// 注册健康上报
	SetupHealthSubscribe(ctx context.Context) error
	// 注册消息订阅
	SetupMessageSubscribe(ctx context.Context) error
}

type ISession interface {
	// 获取会话中UserId
	GetUid(ctx context.Context) int
}

type ITalkMessage interface {
	// 文本消息
	SendText(ctx context.Context, uid int, req *model.TextMessageReq) error
	// 代码消息
	SendCode(ctx context.Context, uid int, req *model.CodeMessageReq) error
}

type ITalkRecords interface {
	GetTalkRecord(ctx context.Context, recordId int) (*model.TalkRecordsItem, error)
	HandleTalkRecords(ctx context.Context, items []*model.TalkRecordsItem) ([]*model.TalkRecordsItem, error)
}