Method getStreamLastTimestamp

src/node/services/agentSession.ts:650–681

(streamInfo: {
    startTime?: number;
    parts: Array<{ timestamp?: number; workflowRun?: { timestamp?: number } }>;
    toolCompletionTimestamps: Map<string, number>;
  })

  }

  private getStreamLastTimestamp(streamInfo: {
    startTime?: number;
    parts: Array<{ timestamp?: number; workflowRun?: { timestamp?: number } }>;
    toolCompletionTimestamps: Map<string, number>;
  }): number {
    // Use a nonzero floor so live-mode replay never sends afterTimestamp=0 when a
    // stream has started but no parts/completions are recorded yet.
    let streamLastTimestamp = streamInfo.startTime ?? 1;
    for (let index = streamInfo.parts.length - 1; index >= 0; index -= 1) {
      const timestamp = streamInfo.parts[index]?.timestamp;
      if (timestamp === undefined) {
        continue;
      }
      streamLastTimestamp = timestamp;
      break;
    }

    for (const part of streamInfo.parts) {
      const workflowRunTimestamp = part.workflowRun?.timestamp;
      if (workflowRunTimestamp !== undefined && workflowRunTimestamp > streamLastTimestamp) {
        streamLastTimestamp = workflowRunTimestamp;
      }
    }

    for (const completionTimestamp of streamInfo.toolCompletionTimestamps.values()) {
      if (completionTimestamp > streamLastTimestamp) {
        streamLastTimestamp = completionTimestamp;
      }
    }

    return streamLastTimestamp;
  }

  private getCurrentStreamLifecycleSnapshot(): StreamLifecycleSnapshot {
    if (this.turnPhase === TurnPhase.PREPARING) {