Function getPendingChatStreamId

apps/sim/lib/copilot/request/session/abort.ts:109–129

(chatId: string)

}

export async function getPendingChatStreamId(chatId: string): Promise<string | null> {
  const localEntry = pendingChatStreams.get(chatId)
  if (localEntry?.streamId) {
    return localEntry.streamId
  }

  const redis = getRedisClient()
  if (!redis) {
    return null
  }

  try {
    return (await redis.get(getChatStreamLockKey(chatId))) || null
  } catch (error) {
    logger.warn('Failed to load chat stream lock owner', {
      chatId,
      error: toError(error).message,
    })
    return null
  }
}

/**
 * Loads canonical stream lock owners for chat IDs.