Function getResumedTurnState

src/features/threads/utils/threadRpc.ts:337–388

(
  thread: Record<string, unknown>,
)

}

export function getResumedTurnState(
  thread: Record<string, unknown>,
): ResumedTurnState {
  const explicitState = getExplicitActiveTurnState(thread);
  if (explicitState.explicit) {
    return {
      activeTurnId: explicitState.activeTurnId,
      activeTurnStartedAtMs: explicitState.activeTurnStartedAtMs,
      confidentNoActiveTurn: !explicitState.activeTurnId,
    };
  }

  const turns = Array.isArray(thread.turns)
    ? (thread.turns as Array<Record<string, unknown>>)
    : [];
  let sawTerminalStatus = false;
  let sawUnknownStatus = false;
  for (let index = turns.length - 1; index >= 0; index -= 1) {
    const turn = turns[index];
    if (!turn || typeof turn !== "object") {
      sawUnknownStatus = true;
      continue;
    }
    const status = classifyTurnStatus(
      normalizeTurnStatus(
        turn.status ?? turn.turnStatus ?? turn.turn_status,
      ),
    );
    if (status === "active") {
      const turnId = asString(turn.id ?? turn.turnId ?? turn.turn_id).trim();
      if (turnId) {
        return {
          activeTurnId: turnId,
          activeTurnStartedAtMs: turnStartedAtMs(turn),
          confidentNoActiveTurn: false,
        };
      }
      sawUnknownStatus = true;
      continue;
    }
    if (status === "terminal") {
      sawTerminalStatus = true;
      continue;
    }
    sawUnknownStatus = true;
  }
  return {
    activeTurnId: null,
    activeTurnStartedAtMs: null,
    confidentNoActiveTurn: sawTerminalStatus && !sawUnknownStatus,
  };
}

export function getResumedActiveTurnId(thread: Record<string, unknown>): string | null {
  return getResumedTurnState(thread).activeTurnId;