Method drainTerminalAttention

src/node/services/taskService.ts:4508–4665

* Drain pending terminal notifications for one owner workspace: defer (leave pending) when the * owner is busy/queued/preparing, otherwise send one coalesced synthetic wake-up and mark the * drained notifications delivered. Stale (deleted-workspace) notifications are marked superseded.

(ownerWorkspaceId: string)

   * drained notifications delivered. Stale (deleted-workspace) notifications are marked superseded.
   */
  private async drainTerminalAttention(ownerWorkspaceId: string): Promise<void> {
    const pending = await this.terminalAttentionStore.listPending(ownerWorkspaceId);
    if (pending.length === 0) {
      return;
    }

    const cfg = this.config.loadConfigOrDefault();
    const entry = findWorkspaceEntry(cfg, ownerWorkspaceId);
    if (entry == null) {
      // Owner workspace no longer exists: the terminal artifacts remain retrievable elsewhere.
      for (const notification of pending) {
        await this.terminalAttentionStore.markSuperseded(ownerWorkspaceId, notification.id);
      }
      return;
    }

    // Defer-until-idle: never inject ahead of an active stream or a queued/preparing user turn.
    const ownerHasPendingQueuedPreparingOrRetry =
      this.workspaceService.hasPendingQueuedOrPreparingTurn(ownerWorkspaceId);
    const ownerHasBusyQueuedOrRetry =
      this.workspaceService.isBusyForMessage(ownerWorkspaceId) ||
      this.workspaceService.hasQueuedMessages(ownerWorkspaceId) ||
      ownerHasPendingQueuedPreparingOrRetry;
    if (
      this.aiService.isStreaming(ownerWorkspaceId) ||
      ownerHasPendingQueuedPreparingOrRetry ||
      this.interruptedParentWorkspaceIds.has(ownerWorkspaceId)
    ) {
      if (ownerHasBusyQueuedOrRetry && !this.interruptedParentWorkspaceIds.has(ownerWorkspaceId)) {
        this.scheduleTerminalAttentionDrainAfterIdle(ownerWorkspaceId);
      }
      return;
    }

    const taskIndex = this.buildAgentTaskIndex(cfg);
    if (await this.hasBlockingActiveWorkForTerminalDrain(ownerWorkspaceId, taskIndex)) {
      return;
    }

    const injectedNotifications = pending.filter((n) => n.outputDelivery === "already_injected");
    const injectedTaskIds = injectedNotifications.map((n) => n.sourceId);
    const awaitHandleIds = pending
      .filter((n) => n.outputDelivery === "requires_task_await")
      .map((n) => n.sourceId);
    const workflowNotifications = pending.filter(
      (n) => n.outputDelivery === "workflow_result_context"
    );
    const anyInjectedFailure = injectedNotifications.some(
      (n) => n.terminalOutcome === "failed" || n.terminalOutcome === "error"
    );

    const promptSections: string[] = [];
    if (injectedTaskIds.length > 0) {
      promptSections.push(
        anyInjectedFailure
          ? FAILED_BACKGROUND_SUBAGENT_HANDOFF_PROMPT
          : COMPLETED_BACKGROUND_SUBAGENT_HANDOFF_PROMPT
      );