Add one more check

nkonev · Jan 14, 2024 · 28a2dc9 · 28a2dc9
1 parent a1b8d90
commit 28a2dc9
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/video/services/invitation_service.go b/video/services/invitation_service.go
@@ -41,7 +41,7 @@ func (srv *ChatInvitationService) SendInvitationsWithStatuses(ctx context.Contex
 
 	// this is sending call invitations to all the ivitees
 	for _, chatInviteName := range inviteNames {
-		status, err := srv.redisService.GetUserCallStatus(ctx, chatInviteName.UserId)
+		status, innerChatId, _, _, err := srv.redisService.GetUserCallState(ctx, chatInviteName.UserId)
 		if err != nil {
 			GetLogEntry(ctx).Errorf("Error during getting callStatus of %v: %v", chatInviteName.UserId, err)
 			continue
@@ -52,6 +52,11 @@ func (srv *ChatInvitationService) SendInvitationsWithStatuses(ctx context.Contex
 			continue
 		}
 
+		if innerChatId != chatId {
+			GetLogEntry(ctx).Warnf("Call status for user %v contain another chatId %v, the correct chatId should be %v", chatInviteName.UserId, innerChatId, chatId)
+			continue
+		}
+
 		invitation := dto.VideoCallInvitation{
 			ChatId:   chatId,
 			ChatName: chatInviteName.Name,