fix: just for safety

mynaparrot · Feb 20, 2025 · 17ba8f4 · 17ba8f4
1 parent 2be4cec
commit 17ba8f4
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/pkg/controllers/nats.go b/pkg/controllers/nats.go
@@ -163,9 +163,11 @@ func (c *NatsController) subscribeToSystemWorker(stream jetstream.Stream) {
 			req := new(plugnmeet.NatsMsgClientToServer)
 			if err := proto.Unmarshal(data, req); err == nil {
 				p := strings.Split(sub, ".")
-				roomId := p[1]
-				userId := p[2]
-				c.natsModel.HandleFromClientToServerReq(roomId, userId, req)
+				if len(p) == 3 {
+					roomId := p[1]
+					userId := p[2]
+					c.natsModel.HandleFromClientToServerReq(roomId, userId, req)
+				}
 			}
 		}(msg.Subject(), msg.Data())
 	}, jetstream.ConsumeErrHandler(func(consumeCtx jetstream.ConsumeContext, err error) {