Function reconcileChatStreamMarkers

apps/sim/lib/copilot/chat/stream-liveness.ts:34–97

(
  candidates: ChatStreamMarkerCandidate[],
  options: ReconcileChatStreamMarkersOptions = {}
)

 * incorrectly hide a live stream owned by another pod.
 */
export async function reconcileChatStreamMarkers(
  candidates: ChatStreamMarkerCandidate[],
  options: ReconcileChatStreamMarkersOptions = {}
): Promise<Map<string, ReconciledChatStreamMarker>> {
  const results = new Map<string, ReconciledChatStreamMarker>()

  for (const candidate of candidates) {
    if (candidate.streamId === null) {
      results.set(candidate.chatId, {
        chatId: candidate.chatId,
        streamId: null,
        status: 'inactive',
      })
      continue
    }
    results.set(candidate.chatId, {
      chatId: candidate.chatId,
      streamId: candidate.streamId,
      status: 'unknown',
    })
  }

  const candidatesWithMarkers = candidates.filter((candidate) => candidate.streamId !== null)
  if (candidatesWithMarkers.length === 0) {
    return results
  }

  const { status, ownersByChatId } = await getChatStreamLockOwners(
    candidatesWithMarkers.map((candidate) => candidate.chatId)
  )

  for (const candidate of candidatesWithMarkers) {
    const owner = ownersByChatId.get(candidate.chatId)
    if (owner && (status === 'verified' || owner === candidate.streamId)) {
      results.set(candidate.chatId, {
        chatId: candidate.chatId,
        streamId: owner,
        status: 'active',
      })
      continue
    }

    if (status === 'verified') {
      results.set(candidate.chatId, {
        chatId: candidate.chatId,
        streamId: null,
        status: 'inactive',
      })
      continue
    }

    results.set(candidate.chatId, {
      chatId: candidate.chatId,
      streamId: candidate.streamId,
      status: 'unknown',
    })
  }