enable batching in video

nkonev · Sep 12, 2024 · e57927f · e57927f
1 parent 5b7a019
commit e57927f
Showing 1 changed file with 14 additions and 8 deletions.
diff --git a/video/tasks/chat_dialer.go b/video/tasks/chat_dialer.go
@@ -116,17 +116,23 @@ func (srv *ChatDialerService) processBatch(ctx context.Context, tx *db.Tx, chatI
 		GetLogEntry(ctx).Error(err, "Failed during getting chat invite names")
 	}
 
-	for _, st := range batchUserStates {
+	// we can do it, because
+	// 1. batchUserStates is not empty
+	// 2. st.OwnerAvatar <-> ownerId, st.ChatTetATet <-> chatId from the args of this function
+	st := batchUserStates[0]
+	realOwnerId := ownerId
+	if realOwnerId == db.NoUser {
+		realOwnerId = st.UserId
+	}
+
+	m := map[int64]string{}
+	for _, state := range batchUserStates {
 		// cleanNotNeededAnymoreDialData - should be before status == services.CallStatusNotFound exit
-		srv.cleanNotNeededAnymoreDialData(ctx, tx, chatId, st)
+		srv.cleanNotNeededAnymoreDialData(ctx, tx, chatId, state)
 
-		m := map[int64]string{st.UserId: st.Status}
-		realOwnerId := ownerId
-		if realOwnerId == db.NoUser {
-			realOwnerId = st.UserId
-		}
-		srv.stateChangedEventService.SendDialEvents(ctx, chatId, m, realOwnerId, utils.NullToEmpty(st.OwnerAvatar), st.ChatTetATet, inviteNames)
+		m[state.UserId] = state.Status
 	}
+	srv.stateChangedEventService.SendDialEvents(ctx, chatId, m, realOwnerId, utils.NullToEmpty(st.OwnerAvatar), st.ChatTetATet, inviteNames)
 }
 
 func (srv *ChatDialerService) cleanNotNeededAnymoreDialData(