Function getChatStreamLockOwners

apps/sim/lib/copilot/request/session/abort.ts:139–173

(
  chatIds: string[]
)

 * in a multi-pod deployment.
 */
export async function getChatStreamLockOwners(
  chatIds: string[]
): Promise<ChatStreamLockOwnersResult> {
  const localOwnersByChatId = new Map<string, string>()
  if (chatIds.length === 0) {
    return { status: 'verified', ownersByChatId: localOwnersByChatId }
  }

  for (const chatId of chatIds) {
    const entry = pendingChatStreams.get(chatId)
    if (entry?.streamId) localOwnersByChatId.set(chatId, entry.streamId)
  }

  const redis = getRedisClient()
  if (!redis) {
    return { status: 'unknown', ownersByChatId: localOwnersByChatId }
  }

  try {
    const keys = chatIds.map(getChatStreamLockKey)
    const values = await redis.mget(keys)
    const redisOwnersByChatId = new Map<string, string>()
    for (let i = 0; i < chatIds.length; i++) {
      const owner = values[i]
      if (owner) redisOwnersByChatId.set(chatIds[i], owner)
    }
    return { status: 'verified', ownersByChatId: redisOwnersByChatId }
  } catch (error) {
    logger.warn('Failed to load chat stream lock owners (batch)', {
      count: chatIds.length,
      error: toError(error).message,
    })
    return { status: 'unknown', ownersByChatId: localOwnersByChatId }
  }
}

export async function releasePendingChatStream(chatId: string, streamId: string): Promise<void> {
  try {