feat: join room send room people num

2024-08-30 22:46:55 +08:00 · 2024-08-30 22:46:55 +08:00 · bf3c3d174b
parent 279ff2bc2d
commit bf3c3d174b
1 changed files with 7 additions and 0 deletions
--- a/server/handlers/websocket.go
+++ b/server/handlers/websocket.go
@ -66,6 +66,13 @@ func NewWSMessageHandler(u *op.User, r *op.Room, l *logrus.Entry) func(c *websoc
 			client.Close()
 			l.Info("ws: disconnected")
 		}()
+		if err := client.Send(&pb.ElementMessage{
+			Type:          pb.ElementMessageType_PEOPLE_CHANGED,
+			PeopleChanged: r.PeopleNum(),
+		}); err != nil {
+			l.Errorf("ws: send people changed error: %v", err)
+			return err
+		}
 		go handleReaderMessage(client, l)
 		return handleWriterMessage(client, l)
 	}