Function pollRemoteSessionEvents

src/utils/teleport.tsx:733–823

(sessionId: string, afterId: string | null = null, opts?: {
  skipMetadata?: boolean;
})

 * per-call GET /v1/sessions/{id} when branch/status aren't needed.
 */
export async function pollRemoteSessionEvents(sessionId: string, afterId: string | null = null, opts?: {
  skipMetadata?: boolean;
}): Promise<PollRemoteSessionResponse> {
  let accessToken: string
  let orgUUID: string
  try {
    const capability = await resolveManagedRemoteCapability()
    accessToken = capability.accessToken
    orgUUID = capability.orgUUID
  } catch (error) {
    const err = toError(error)
    if (err.message === MANAGED_REMOTE_AUTH_REQUIRED_MESSAGE) {
      throw new Error('No access token for polling')
    }
    if (err.message === 'Unable to get organization UUID') {
      throw new Error('No org UUID for polling')
    }
    throw err
  }
  const headers = {
    ...getOAuthHeaders(accessToken),
    'anthropic-beta': 'ccr-byoc-2025-07-29',
    'x-organization-uuid': orgUUID
  };
  const eventsUrl = buildNoumenaPlatformUrl(`/v1/sessions/${sessionId}/events`);
  type EventsResponse = {
    data: unknown[];
    has_more: boolean;
    first_id: string | null;
    last_id: string | null;
  };

  // Cap is a safety valve against stuck cursors; steady-state is 0–1 pages.
  const MAX_EVENT_PAGES = 50;
  const sdkMessages: SDKMessage[] = [];
  let cursor = afterId;
  for (let page = 0; page < MAX_EVENT_PAGES; page++) {
    const eventsResponse = await axios.get(eventsUrl, {
      headers,
      params: cursor ? {
        after_id: cursor
      } : undefined,
      timeout: 30000
    });
    if (eventsResponse.status !== 200) {
      throw new Error(`Failed to fetch session events: ${eventsResponse.statusText}`);
    }
    const eventsData: EventsResponse = eventsResponse.data;
    if (!eventsData?.data || !Array.isArray(eventsData.data)) {
      throw new Error('Invalid events response');
    }
    for (const event of eventsData.data) {
      if (event && typeof event === 'object' && 'type' in event) {
        if (event.type === 'env_manager_log' || event.type === 'control_response') {
          continue;
        }
        if ('session_id' in event) {
          sdkMessages.push(event as SDKMessage);