Function startSwitchWatcher

lib/transcript.js:282–312

()

}

function startSwitchWatcher() {
  if (state.switchWatcher) { clearInterval(state.switchWatcher); state.switchWatcher = null; }
  const slug = getProjectSlug(state.CWD);
  const projectDir = path.join(PROJECTS_DIR, slug);

  state.switchWatcher = setInterval(() => {
    if (!state.transcriptPath || !state.expectingSwitch || !fs.existsSync(projectDir)) return;
    try {
      const currentBasename = path.basename(state.transcriptPath);
      const candidates = fs.readdirSync(projectDir)
        .filter(f => f.endsWith('.jsonl') && f !== currentBasename)
        .map(f => {
          const full = path.join(projectDir, f);
          const stat = fs.statSync(full);
          return { name: f, full, mtime: stat.mtimeMs, size: stat.size };
        })
        .filter(t => t.mtime > fs.statSync(state.transcriptPath).mtimeMs)
        .sort((a, b) => b.mtime - a.mtime);

      const newer = candidates.find(t => fileLooksLikeTranscript(t.full));
      if (newer) {
        log(`Session switch detected → ${path.basename(newer.full, '.jsonl')}`);
        state.expectingSwitch = false;
        if (state.expectingSwitchTimer) { clearTimeout(state.expectingSwitchTimer); state.expectingSwitchTimer = null; }
        if (state.tailTimer) { clearInterval(state.tailTimer); state.tailTimer = null; }
        if (state.switchWatcher) { clearInterval(state.switchWatcher); state.switchWatcher = null; }
        attachTranscript(newer, 0);
      }
    } catch {}
  }, 500);
}

function startTailing() {
  state.tailRemainder = Buffer.alloc(0);