test: websocket

aarch64/pjibot_guide/common/config/c_websocket.go

@@ -86,14 +86,15 @@ func sendRequestAndAwaitResponse(ws *websocket.Conn) ([]byte, error) {
 	requestJSON, err := json.Marshal(request)
 	if err != nil {
 		c_log.GlobalLogger.Error("保持websocket连接活跃，解析requestJSON - 失败。", err)
+		return nil, err
 	}
 
 	err = ws.WriteMessage(websocket.TextMessage, requestJSON)
 	if err != nil {
 		c_log.GlobalLogger.Error("保持websocket连接活跃，发送心跳请求 - 失败。", err)
-		return nil, fmt.Errorf("发送心跳请求 - 失败。")
+		return nil, err
 	}
-	c_log.GlobalLogger.Info("保持websocket连接活跃，发送心跳请求 - 成功。", err)
+	c_log.GlobalLogger.Info("保持websocket连接活跃，发送心跳请求 - 成功。")
 
 	// 使用channel等待响应
 	responseChan := make(chan []byte)
@@ -101,7 +102,7 @@ func sendRequestAndAwaitResponse(ws *websocket.Conn) ([]byte, error) {
 
 	select {
 	case response := <-responseChan:
-		c_log.GlobalLogger.Error("保持websocket连接活跃，等待心跳响应 - 成功。", err)
+		c_log.GlobalLogger.Error("保持websocket连接活跃，等待心跳响应 - 成功。")
 		return response, nil
 	case <-time.After(30 * time.Second): // 设置超时时间
 		return nil, fmt.Errorf("保持websocket连接活跃，等待心跳响应 - 超时。")
@@ -113,7 +114,7 @@ func handleMessages(ws *websocket.Conn, responseChan chan<- []byte) {
 		time.Sleep(100 * time.Millisecond)
 		_, message, err := ws.ReadMessage()
 		if err != nil {
-			c_log.GlobalLogger.Error("保持websocket连接活跃，读取websocket消息失败", err)
+			c_log.GlobalLogger.Error("保持websocket连接活跃，读取websocket消息 - 失败 ", err)
 			return
 		}