Method drainBashMonitorWakes

src/node/services/workspaceService.ts:1728–1904

(ownerWorkspaceId: string)

  }

  private async drainBashMonitorWakes(ownerWorkspaceId: string): Promise<void> {
    const pending = (await this.bashMonitorWakeStore.listPending(ownerWorkspaceId)).filter(
      (record) =>
        !this.cancelingBashMonitorWakeKeys.has(this.bashMonitorWakeKey(ownerWorkspaceId, record.id))
    );
    if (pending.length === 0) return;

    const cfg = this.config.loadConfigOrDefault();
    const entry = findWorkspaceEntry(cfg, ownerWorkspaceId);
    if (entry == null) {
      for (const record of pending) {
        await this.bashMonitorWakeStore.markSuperseded(ownerWorkspaceId, record.id);
      }
      return;
    }

    const ownerHasPendingQueuedPreparingOrRetry =
      this.hasPendingQueuedOrPreparingTurn(ownerWorkspaceId);
    const ownerHasSessionBackedBusyState = this.isBusyForMessage(ownerWorkspaceId);
    const ownerHasAiServiceStream = this.aiService.isStreaming(ownerWorkspaceId);
    if (
      ownerHasPendingQueuedPreparingOrRetry ||
      (ownerHasSessionBackedBusyState && !ownerHasAiServiceStream)
    ) {
      this.scheduleBashMonitorWakeDrainAfterIdle(ownerWorkspaceId);
      return;
    }

    if (ownerHasAiServiceStream && !ownerHasSessionBackedBusyState) {
      return;
    }

    const sendOptions = this.getWorkflowContinuationSendOptions(ownerWorkspaceId);
    if (sendOptions == null) {
      log.debug("Bash monitor wake has no send options; leaving pending", { ownerWorkspaceId });
      return;
    }

    const prompt = buildBashMonitorWakePrompt(pending);
    const retryAfterIdleIfBusy = (reason: string): void => {
      if (
        this.isBusyForMessage(ownerWorkspaceId) ||
        this.hasPendingQueuedOrPreparingTurn(ownerWorkspaceId)
      ) {
        this.scheduleBashMonitorWakeDrainAfterIdle(ownerWorkspaceId);
        return;
      }
      log.debug("Bash monitor wake left pending without immediate retry", {
        ownerWorkspaceId,
        reason,
      });
    };
    const markDeliveredAfterAccepted = async (
      records: readonly BashMonitorWakeRecord[]
    ): Promise<void> => {
      let hasUndeliveredMergedMatches = false;
      for (const record of records) {
        const delivered = await this.bashMonitorWakeStore.markDeliveredSnapshot(