Function fetchHistoricalSessionEvents

src/cli/remoteIO.ts:81–127

(
  eventsUrl: string,
  headers: Record<string, string>,
)

}

export async function fetchHistoricalSessionEvents(
  eventsUrl: string,
  headers: Record<string, string>,
): Promise<ReplayableHistoricalSessionEvent[]> {
  const replayable: ReplayableHistoricalSessionEvent[] = []
  let cursor: string | null = null
  const maxPages = 50

  for (let page = 0; page < maxPages; page++) {
    const response = await axios.get<HistoricalSessionEventsResponse>(
      eventsUrl,
      {
        headers,
        params: cursor ? { after_id: cursor } : undefined,
        timeout: 20_000,
        validateStatus: status => status < 500,
      },
    )

    if (response.status === 404) {
      return []
    }
    if (response.status !== 200) {
      throw new Error(
        `Failed to fetch historical session events: ${response.status}`,
      )
    }

    const body = response.data
    if (!body || !Array.isArray(body.data)) {
      throw new Error('Invalid historical session events response')
    }

    for (const event of body.data) {
      if (isReplayableHistoricalSessionEvent(event)) {
        replayable.push(event)
      }
    }

    cursor = body.last_id ?? null
    if (!body.has_more || !cursor) {
      break
    }
  }

  return replayable
}

/**
 * Bidirectional streaming for SDK mode with session tracking