shkong/go-cqhttp
1
0
Fork 0
mirror of https://github.com/Mrs4s/go-cqhttp.git synced 2025-05-04 19:17:37 +08:00
Code Issues Projects Releases Wiki Activity

server: add a error log

Browse Source
This commit is contained in:
wdvxdr 2023-02-04 13:01:16 +08:00
parent d96f840d7f
commit bbef330069
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
server/websocket.go
View File

@ -467,14 +467,16 @@ func (s *webSocketServer) listenAPI(c *wsConn) {
func (c *wsConn) handleRequest(_ *coolq.CQBot, payload []byte) {
defer func() {
if err := recover(); err != nil {
log.Printf("处置WS命令时发生无法恢复的异常：%v\n%s", err, debug.Stack())
log.Errorf("处置WS命令时发生无法恢复的异常：%v\n%s", err, debug.Stack())
_ = c.Close()
}
}()
j := gjson.Parse(utils.B2S(payload))
t := strings.TrimSuffix(j.Get("action").Str, "_async")
log.Debugf("WS接收到API调用: %v 参数: %v", t, j.Get("params").Raw)
ret := c.apiCaller.Call(t, j.Get("params"))
params := j.Get("params")
log.Debugf("WS接收到API调用: %v 参数: %v", t, params.Raw)
ret := c.apiCaller.Call(t, params)
if j.Get("echo").Exists() {
ret["echo"] = j.Get("echo").Value()
}
@ -482,7 +484,11 @@ func (c *wsConn) handleRequest(_ *coolq.CQBot, payload []byte) {
c.mu.Lock()
defer c.mu.Unlock()
_ = c.conn.SetWriteDeadline(time.Now().Add(time.Second * 15))
writer, _ := c.conn.NextWriter(websocket.TextMessage)
writer, err := c.conn.NextWriter(websocket.TextMessage)
if err != nil {
log.Errorf("无法响应API调用(连接已断开?): %v", err)
return
}
_ = json.NewEncoder(writer).Encode(ret)
_ = writer.Close()
}