From 9865914436388683d2621ca25b0f8ff6755f4063 Mon Sep 17 00:00:00 2001 From: hyung-hwan Date: Tue, 18 Mar 2025 23:45:00 +0900 Subject: [PATCH] fired CONN_UPDATED from receive_from_stream --- server.go | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/server.go b/server.go index 90eea18..901602c 100644 --- a/server.go +++ b/server.go @@ -889,6 +889,19 @@ func (cts *ServerConn) receive_from_stream(wg *sync.WaitGroup) { cts.S.cts_map_by_token[x.Conn.Token] = cts cts.S.cts_mtx.Unlock() cts.S.log.Write(cts.Sid, LOG_INFO, "client(%d) %s - token set to '%s'", cts.Id, cts.RemoteAddr, x.Conn.Token) + + cts.S.bulletin.Enqueue( + &ServerEvent{ + Kind: SERVER_EVENT_CONN_UPDATED, + Data: &ServerEventConnAdded{ + Conn: cts.Id, + ServerAddr: cts.LocalAddr.String(), + ClientAddr: cts.RemoteAddr.String(), + ClientToken: cts.ClientToken.Get(), + CreatedMilli: cts.Created.UnixMilli(), + }, + }, + ) } } }