Function poll

src/tasks/RemoteAgentTask/RemoteAgentTask.tsx:748–1066

()

  let cachedReviewContent: string | null = null;

  const poll = async (): Promise<void> => {
    if (!isRunning) return;

    try {
      const appState = context.getAppState();
      const task = appState.tasks?.[taskId] as RemoteAgentTaskState | undefined;
      if (!task || task.status !== 'running') {
        // Task was killed externally (TaskStopTool) or already terminal.
        // Session left alive so the claude.ai URL stays valid — the run_hunt.sh
        // post_stage() calls land as assistant events there, and the user may
        // want to revisit them after closing the terminal. TTL reaps it.
        return;
      }

      const response = await pollRemoteSessionEvents(task.sessionId, lastEventId);
      lastEventId = response.lastEventId;
      const logGrew = response.newEvents.length > 0;
      if (logGrew) {
        accumulatedLog = [...accumulatedLog, ...response.newEvents];
        const deltaText = response.newEvents
          .map(msg => {
            if (msg.type === 'assistant') {
              const content = (msg as SDKAssistantMessage).message?.content;
              if (!content || typeof content === 'string') return '';
              return (content as Array<{ type: string; text?: string }>)
                .filter(block => block.type === 'text')
                .map(block => ('text' in block ? block.text : ''))
                .join('\n');
            }
            return jsonStringify(msg);
          })
          .join('\n');
        if (deltaText) {
          appendTaskOutput(taskId, deltaText + '\n');
        }
      }

      if (response.sessionStatus === 'archived') {
        updateTaskState<RemoteAgentTaskState>(taskId, context.setAppState, t =>
          t.status === 'running' ? { ...t, status: 'completed', endTime: Date.now() } : t,
        );
        const richContent = tryExtractRichContent(task, accumulatedLog);
        if (richContent) {
          enqueueRichRemoteNotification(
            taskId,
            task.title,
            'completed',
            richContent,
            context.setAppState,
            task.toolUseId,
          );
        } else {
          enqueueRemoteNotification(taskId, task.title, 'completed', context.setAppState, task.toolUseId);
        }
        void evictTaskOutput(taskId);
        void removeRemoteAgentMetadata(taskId);
        runCompletionHook(taskId, task);
        return;