Method sendMessage

server/handlers/websocket.go:437–477

sendMessage sends a message to the WebSocket client

(wsConn *WebSocketConnection, msgType string, payload map[string]any)

// sendMessage sends a message to the WebSocket client
func (h *WebSocketHandler) sendMessage(wsConn *WebSocketConnection, msgType string, payload map[string]any) {
	// 检查 context 是否已取消
	if wsConn.ctx.Err() != nil {
		return
	}

	msg := WebSocketMessage{
		Type:    msgType,
		Payload: payload,
	}

	data, err := json.Marshal(msg)
	if err != nil {
		logging.Error(wsConn.ctx, "websocket.marshal.error", map[string]any{
			"error": err.Error(),
		})
		return
	}

	// 使用 defer recover 防止发送到已关闭的 channel 导致 panic
	defer func() {
		if r := recover(); r != nil {
			logging.Warn(wsConn.ctx, "websocket.send.recovered", map[string]any{
				"connection_id": wsConn.ID,
				"message_type":  msgType,
				"panic":         r,
			})
		}
	}()

	select {
	case wsConn.Send <- data:
	case <-wsConn.ctx.Done():
	default:
		// Channel full, skip message
		logging.Warn(wsConn.ctx, "websocket.send.dropped", map[string]any{
			"connection_id": wsConn.ID,
			"message_type":  msgType,
		})
	}
}

// sendError sends an error message to the WebSocket client
func (h *WebSocketHandler) sendError(wsConn *WebSocketConnection, code, message string) {