Function setTurnState

lib/logger.js:183–210

(phase, { sessionId = state.currentSessionId, reason = '', force = false } = {})

}

function setTurnState(phase, { sessionId = state.currentSessionId, reason = '', force = false } = {}) {
  const normalizedPhase = phase === 'running' ? 'running' : 'idle';
  const normalizedSessionId = sessionId || null;
  const changed = force ||
    state.turnState.phase !== normalizedPhase ||
    state.turnState.sessionId !== normalizedSessionId;

  if (!changed) return false;

  state.turnState = {
    phase: normalizedPhase,
    sessionId: normalizedSessionId,
    version: ++state.turnStateVersion,
    updatedAt: Date.now(),
    reason,
  };

  const modeReason = reason || `turn_state:${normalizedPhase}`;
  if (normalizedPhase !== 'running' && state.turnApprovalFloorMode) {
    clearTurnApprovalFloorMode(modeReason);
  } else {
    recomputeEffectiveApprovalMode(modeReason);
  }

  log(`Turn state -> phase=${state.turnState.phase} session=${state.turnState.sessionId ?? 'null'} version=${state.turnState.version}${reason ? ` reason=${reason}` : ''}`);
  broadcast(getTurnStatePayload());
  return true;
}

function emitInterrupt(source) {
  const interruptEvent = {