Skip to content

Commit

Permalink
chat_dialer
Browse files Browse the repository at this point in the history
  • Loading branch information
nkonev committed Sep 10, 2024
1 parent 0d67d97 commit 6da722b
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions video/tasks/chat_dialer.go
Original file line number Diff line number Diff line change
Expand Up @@ -113,8 +113,8 @@ func (srv *ChatDialerService) processBatch(ctx context.Context, tx *db.Tx, batch

sent := map[int64]bool{}
for _, state := range callees {
// cleanNotNeededAnymoreDialRedisData - should be before status == services.CallStatusNotFound exit
srv.cleanNotNeededAnymoreDialRedisData(ctx, tx, chatId, state)
// cleanNotNeededAnymoreDialData - should be before status == services.CallStatusNotFound exit
srv.cleanNotNeededAnymoreDialData(ctx, tx, chatId, state)

if _, ok := sent[state.UserId]; !ok {
// send the new status (= invitation) immediately to users (callees)
Expand All @@ -127,7 +127,7 @@ func (srv *ChatDialerService) processBatch(ctx context.Context, tx *db.Tx, batch
}
}

func (srv *ChatDialerService) cleanNotNeededAnymoreDialRedisData(
func (srv *ChatDialerService) cleanNotNeededAnymoreDialData(
ctx context.Context,
tx *db.Tx,
chatId int64,
Expand Down
2 changes: 1 addition & 1 deletion video/tasks/synchronize_with_livekit.go
Original file line number Diff line number Diff line change
Expand Up @@ -127,7 +127,7 @@ func (srv *SynchronizeWithLivekitService) cleanOrphans(ctx context.Context, user
}
}

} // else branch not needed, because they removed from chat_dialer task's cleanNotNeededAnymoreDialRedisData()
} // else branch not needed, because they removed from chat_dialer task's cleanNotNeededAnymoreDialData()
}
}

Expand Down

0 comments on commit 6da722b

Please sign in to comment.