File tree Expand file tree Collapse file tree 1 file changed +15
-0
lines changed Expand file tree Collapse file tree 1 file changed +15
-0
lines changed Original file line number Diff line number Diff line change @@ -2,6 +2,7 @@ package main
2
2
3
3
import (
4
4
verify "collab/verify"
5
+ "context"
5
6
"encoding/json"
6
7
"io"
7
8
"log"
@@ -266,6 +267,20 @@ func handleMessages(
266
267
RoomID : client .roomID ,
267
268
Content : []byte ("The session has been closed by a user." ),
268
269
}
270
+ targetId := msgData ["userId" ].(string )
271
+ data , err := persistMappings .Conn .HGetAll (context .Background (), targetId ).Result ()
272
+ if err != nil {
273
+ log .Printf ("Error retrieving data for userID %s: %v" , targetId , err )
274
+ } else {
275
+ _ , err1 := persistMappings .Conn .Del (context .Background (), targetId ).Result ()
276
+ if err1 != nil {
277
+ log .Printf ("Error deleting data for userID %s: %v" , targetId , err1 );
278
+ }
279
+ _ , err2 := persistMappings .Conn .Del (context .Background (), data ["otherUser" ]).Result ()
280
+ if err2 != nil {
281
+ log .Printf ("Error deleting data for other user %s: %v" , data ["otherUser" ], err2 );
282
+ }
283
+ }
269
284
hub .broadcast <- closeMessage
270
285
}
271
286
You can’t perform that action at this time.
0 commit comments