From ed8d36cdad2fcd66dcb636b9f621de8004a53ddf Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?M=2E=20Mert=20Y=C4=B1ld=C4=B1ran?= Date: Thu, 11 Nov 2021 11:10:42 +0300 Subject: [PATCH] Send the message into this WebSocket connection instead of all (#449) --- agent/pkg/api/socket_routes.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/agent/pkg/api/socket_routes.go b/agent/pkg/api/socket_routes.go index dff86157f..6344c66a8 100644 --- a/agent/pkg/api/socket_routes.go +++ b/agent/pkg/api/socket_routes.go @@ -92,7 +92,7 @@ func websocketHandler(w http.ResponseWriter, r *http.Request, eventHandlers Even eventHandlers.WebSocketConnect(socketId, isTapper) startTimeBytes, _ := models.CreateWebsocketStartTimeMessage(startTime) - BroadcastToBrowserClients(startTimeBytes) + SendToSocket(socketId, startTimeBytes) for { _, msg, err := ws.ReadMessage() @@ -110,7 +110,7 @@ func websocketHandler(w http.ResponseWriter, r *http.Request, eventHandlers Even AutoClose: 5000, Text: fmt.Sprintf("Syntax error: %s", err.Error()), }) - BroadcastToBrowserClients(toastBytes) + SendToSocket(socketId, toastBytes) break } @@ -131,7 +131,7 @@ func websocketHandler(w http.ResponseWriter, r *http.Request, eventHandlers Even base["id"] = uint(dataMap["id"].(float64)) baseEntryBytes, _ := models.CreateBaseEntryWebSocketMessage(base) - BroadcastToBrowserClients(baseEntryBytes) + SendToSocket(socketId, baseEntryBytes) } } @@ -150,7 +150,7 @@ func websocketHandler(w http.ResponseWriter, r *http.Request, eventHandlers Even } metadataBytes, _ := models.CreateWebsocketQueryMetadataMessage(metadata) - BroadcastToBrowserClients(metadataBytes) + SendToSocket(socketId, metadataBytes) } }