From 0b2df543431423999b38716658220223dbc2c95b Mon Sep 17 00:00:00 2001 From: Joachim Bauch Date: Tue, 1 Jun 2021 09:52:19 +0200 Subject: [PATCH] Send hello response through session. --- hub.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/hub.go b/hub.go index 78ed3f1..dbeaa7a 100644 --- a/hub.go +++ b/hub.go @@ -740,7 +740,7 @@ func (h *Hub) processRegister(client *Client, message *ClientMessage, backend *B h.setDecodedSessionId(privateSessionId, privateSessionName, sessionIdData) h.setDecodedSessionId(publicSessionId, publicSessionName, sessionIdData) - h.sendHelloResponse(client, message, session) + h.sendHelloResponse(session, message) } func (h *Hub) processUnregister(client *Client) *ClientSession { @@ -816,7 +816,7 @@ func (h *Hub) processMessage(client *Client, data []byte) { } } -func (h *Hub) sendHelloResponse(client *Client, message *ClientMessage, session *ClientSession) bool { +func (h *Hub) sendHelloResponse(session *ClientSession, message *ClientMessage) bool { response := &ServerMessage{ Id: message.Id, Type: "hello", @@ -828,7 +828,7 @@ func (h *Hub) sendHelloResponse(client *Client, message *ClientMessage, session Server: h.GetServerInfo(session), }, } - return client.SendMessage(response) + return session.SendMessage(response) } func (h *Hub) processHello(client *Client, message *ClientMessage) { @@ -875,7 +875,7 @@ func (h *Hub) processHello(client *Client, message *ClientMessage) { log.Printf("Resume session from %s in %s (%s) %s (private=%s)", client.RemoteAddr(), client.Country(), client.UserAgent(), session.PublicId(), session.PrivateId()) - h.sendHelloResponse(client, message, clientSession) + h.sendHelloResponse(clientSession, message) clientSession.NotifySessionResumed(client) return }