From 26e968f7c9bf429fd1db1320ff050713f3eea840 Mon Sep 17 00:00:00 2001 From: mountain Date: Fri, 1 Sep 2023 11:29:51 +0900 Subject: [PATCH] =?UTF-8?q?wshandler=EC=97=90=EC=84=9C=20=EC=A7=81?= =?UTF-8?q?=EC=A0=91=20state=EB=A5=BC=20=EC=93=B0=EB=8A=94=20=EC=BD=94?= =?UTF-8?q?=EB=93=9C=20=EC=A0=9C=EA=B1=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- wshandler/wshandler.go | 12 ------------ 1 file changed, 12 deletions(-) diff --git a/wshandler/wshandler.go b/wshandler/wshandler.go index 1897fe5..950da01 100644 --- a/wshandler/wshandler.go +++ b/wshandler/wshandler.go @@ -258,15 +258,6 @@ func (ws *WebsocketHandler) RegisterHandlers(serveMux *http.ServeMux, prefix str return nil } -func (ws *WebsocketHandler) GetState(accid primitive.ObjectID) string { - state, _ := ws.redisSync.Get(context.Background(), accid.Hex()).Result() - return state -} - -func (ws *WebsocketHandler) SetState(accid primitive.ObjectID, state string) { - ws.redisSync.SetArgs(context.Background(), accid.Hex(), state, redis.SetArgs{Mode: "XX"}).Result() -} - func (ws *WebsocketHandler) SendUpstreamMessage(msg *UpstreamMessage) { ws.localDeliveryChan <- msg } @@ -547,7 +538,6 @@ func upgrade_core(ws *WebsocketHandler, conn *websocket.Conn, accid primitive.Ob ws.connWaitGroup.Add(1) go func(c *wsconn, accid primitive.ObjectID, deliveryChan chan<- any) { - ws.redisSync.Set(context.Background(), accid.Hex(), "online", 0) for { messageType, r, err := c.NextReader() if err != nil { @@ -571,8 +561,6 @@ func upgrade_core(ws *WebsocketHandler, conn *websocket.Conn, accid primitive.Ob f() } } - - ws.redisSync.Del(context.Background(), accid.Hex()) ws.connWaitGroup.Done() c.Conn = nil