chat service update

- readme update - room map key fixed Author: [email protected]
thanhpp · Jan 21, 2022 · dbb027c · dbb027c
1 parent f11f541
commit dbb027c
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/README.md b/README.md
@@ -79,8 +79,8 @@
 - [ ] delete_conversation
 
 - TODO (data whatever)
-  - [ ] Tạo connection || ws://localhost:12000/ws ||
-  - [ ] Join room
+  - [x] Tạo connection || ws://localhost:12000/ws ||
+  - [x] Join room
     - ```go
       type WsMessage struct {
         MsgID      string `json:"message_id"` // null
@@ -91,7 +91,7 @@
         Content    string `json:"content"`    // null
       }
       ```
-  - [ ] send message
+  - [x] send message
     - ```go
       type WsMessage struct {
         MsgID      string `json:"message_id"` // null

diff --git a/internal/auco/app/wsmap.go b/internal/auco/app/wsmap.go
@@ -22,6 +22,7 @@ func newWsRoomMap() *wsRoomMap {
 
 func (rm *wsRoomMap) add(room *WsRoom) {
 	rm.rw.Lock()
+	logger.Debugf("WsRoomMap: added room %s", room.key())
 	rm.m[room.key()] = room
 	rm.rw.Unlock()
 }
@@ -36,6 +37,9 @@ func (rm *wsRoomMap) delete(room *WsRoom) {
 
 func (rm *wsRoomMap) findByUserIDs(userA, userB string) (*WsRoom, bool) {
 	rm.rw.RLock()
+	if userA > userB {
+		userA, userB = userB, userA
+	}
 	room, ok := rm.m[userA+"-"+userB]
 	rm.rw.RUnlock()
 	return room, ok