Function startTailing

lib/transcript.js:314–393

()

}

function startTailing() {
  state.tailRemainder = Buffer.alloc(0);
  state.tailTimer = setInterval(() => {
    if (maybeAttachPendingSwitchTarget('tail_pending_target')) return;
    if (!state.transcriptPath) return;
    try {
      const stat = fs.statSync(state.transcriptPath);
      if (stat.size <= state.transcriptOffset) {
        if (state.tailCatchingUp) {
          state.tailCatchingUp = false;
          log('Tail catch-up complete, live mode');
        }
        return;
      }

      const fd = fs.openSync(state.transcriptPath, 'r');
      const buf = Buffer.alloc(stat.size - state.transcriptOffset);
      fs.readSync(fd, buf, 0, buf.length, state.transcriptOffset);
      fs.closeSync(fd);
      state.transcriptOffset = stat.size;

      const data = state.tailRemainder.length > 0 ? Buffer.concat([state.tailRemainder, buf]) : buf;
      let start = 0;
      for (let i = 0; i < data.length; i++) {
        if (data[i] !== 0x0A) continue;
        const line = data.slice(start, i).toString('utf8').trim();
        start = i + 1;
        if (!line) continue;
        try {
          const event = JSON.parse(line);
          if (event.type === 'user' || (event.message && event.message.role === 'user')) {
            const content = event.message && event.message.content;
            const slashCommand = extractSlashCommand(content);
            const isInterruptedUserEvent = isUserInterruptEvent(content);
            const isPassiveUserEvent = isNonAiUserEvent(event, content);
            const ignoreInitialClear = (
              slashCommand === '/clear' &&
              state.pendingInitialClearTranscript &&
              state.pendingInitialClearTranscript.sessionId === state.currentSessionId
            );
            if (!state.tailCatchingUp && isInterruptedUserEvent) {
              setTurnState('idle', { sessionId: state.currentSessionId, reason: 'transcript_user_interrupt' });
            }
            if (!state.tailCatchingUp && !slashCommand && !isPassiveUserEvent) {
              setTurnState('running', { sessionId: state.currentSessionId, reason: 'transcript_user_event' });
            }
            if (slashCommand === '/clear') {
              if (ignoreInitialClear) {
                state.pendingInitialClearTranscript = null;
                log(`Ignored bootstrap /clear transcript event for session ${state.currentSessionId}`);
              } else {
                markExpectingSwitch();
              }
            } else if (
              state.pendingInitialClearTranscript &&
              state.pendingInitialClearTranscript.sessionId === state.currentSessionId &&
              !isPassiveUserEvent &&
              !event.isMeta &&