Function attachTranscript

lib/transcript.js:222–258

(target, startOffset = 0)

//  Transcript Attachment & Tailing
// ============================================================
function attachTranscript(target, startOffset = 0) {
  state.transcriptPath = target.full;
  state.currentSessionId = path.basename(state.transcriptPath, '.jsonl');
  setTurnState('idle', { sessionId: state.currentSessionId, reason: 'transcript_attached' });
  state.pendingInitialClearTranscript = target.ignoreInitialClearCommand
    ? { sessionId: state.currentSessionId }
    : null;
  if (state.pendingSwitchTarget && state.pendingSwitchTarget.sessionId === state.currentSessionId) {
    state.pendingSwitchTarget = null;
  }
  state.transcriptOffset = Math.max(0, startOffset);
  state.tailRemainder = Buffer.alloc(0);
  state.eventBuffer = [];
  state.eventSeq = 0;

  if (state.expectingSwitch) {
    state.expectingSwitch = false;
    if (state.expectingSwitchTimer) { clearTimeout(state.expectingSwitchTimer); state.expectingSwitchTimer = null; }
  }
  if (state.switchWatcherDelayTimer) { clearTimeout(state.switchWatcherDelayTimer); state.switchWatcherDelayTimer = null; }

  try {
    const stat = fs.statSync(state.transcriptPath);
    state.tailCatchingUp = stat.size > state.transcriptOffset;
  } catch {
    state.tailCatchingUp = false;
  }

  log(`Transcript attached: ${state.currentSessionId} (offset=${state.transcriptOffset} catchUp=${state.tailCatchingUp})`);
  broadcast({
    type: 'transcript_ready',
    transcript: state.transcriptPath,
    sessionId: state.currentSessionId,
    lastSeq: 0,
  });
  startTailing();
}

function markExpectingSwitch() {
  state.expectingSwitch = true;