optimize the code for change chat session

This commit is contained in:
RockYang
2023-04-19 21:45:37 +08:00
parent 673cdada5a
commit efc1ea5d8b
2 changed files with 585 additions and 588 deletions

View File

@@ -61,18 +61,18 @@ func (s *Server) ChatHandle(c *gin.Context) {
return return
} }
logger.Info("Receive a message: ", string(message)) logger.Info("Receive a message: ", string(message))
replyMessage(client, "当前 TOKEN 无效,请使用合法的 TOKEN 登录!", false) //replyMessage(client, "当前 TOKEN 无效,请使用合法的 TOKEN 登录!", false)
//replyMessage(client, "![](images/wx.png)", true) //replyMessage(client, "![](images/wx.png)", true)
//ctx, cancel := context.WithCancel(context.Background()) ctx, cancel := context.WithCancel(context.Background())
//s.ReqCancelFunc[sessionId] = cancel s.ReqCancelFunc[sessionId] = cancel
//// 回复消息 // 回复消息
//err = s.sendMessage(ctx, session, chatRole, string(message), client, false) err = s.sendMessage(ctx, session, chatRole, string(message), client, false)
//if err != nil { if err != nil {
// logger.Error(err) logger.Error(err)
//} else { } else {
// replyChunkMessage(client, types.WsMessage{Type: types.WsEnd, IsHelloMsg: false}) replyChunkMessage(client, types.WsMessage{Type: types.WsEnd, IsHelloMsg: false})
// logger.Info("回答完毕: " + string(message)) logger.Info("回答完毕: " + string(message))
//} }
} }
}() }()

File diff suppressed because it is too large Load Diff