Method runForWorkspace

src/node/services/agentStatusService.ts:225–442

(
    workspaceId: string,
    observedRecency: number | null = null,
    streaming = false
  )

  }

  private async runForWorkspace(
    workspaceId: string,
    observedRecency: number | null = null,
    streaming = false
  ): Promise<void> {
    try {
      const transcript = await this.buildTrailingTranscript(workspaceId);
      // Two hashes, two purposes:
      //
      //   transcriptHash — keyed only on transcript bytes. Used by the
      //     history-catch-up guard (`isRecentRecencyAheadOfHistory` +
      //     `lastSeenInputHash`) to detect "transcript unchanged since the
      //     last look." Folding `streaming` into this comparison would make
      //     the common idle→streaming transition look like a transcript
      //     change and bypass the wait-for-history guard, letting the
      //     service persist a stale pre-pivot status and consume the
      //     recency signal.
      //
      //   dedupHash — keyed on transcript + streaming. Used by the
      //     "settled, skip regeneration" branch (`state.lastInputHash`)
      //     because `streaming` now changes the prompt's tense guidance
      //     and therefore the generated status; identical transcript bytes
      //     with different streaming values must dedup independently.
      const transcriptHash = computeTranscriptHash(transcript);
      const dedupHash = computeDedupHash(transcriptHash, streaming);
      // dispatch() set lastRanAt to the tick start time before kicking us
      // off, so the scheduler won't reconsider this workspace until the next
      // interval boundary unless a newer user-recency timestamp indicates the
      // chat pivoted again.
      const state = this.ensureState(workspaceId);

      const markRecencyObserved = () => {
        if (observedRecency !== null) {
          state.lastObservedRecency = observedRecency;
        }
      };
      // Settle this transcript: consume observed recency AND advance the dedup
      // hash so the next tick won't regenerate against the same input. Used by
      // the three branches that produce a definitive outcome for this transcript
      // (post-provider failure, placeholder rejection, successful persist).
      // Pre-provider failures and the empty/dedup-hit branches use bare
      // `markRecencyObserved()` because they should still retry on the same
      // transcript when conditions change.
      const settleOnTranscript = () => {
        markRecencyObserved();
        state.lastInputHash = dedupHash;
        resetProviderFailureTracking(state);
      };

      if (
        isRecentRecencyAheadOfHistory(
          state,
          transcriptHash,
          observedRecency,
          this.clock(),
          AGENT_STATUS_TICK_INTERVAL_MS
        )
      ) {