Turn-budget alert cannot be matched to its Re-read row #101

cat > /tmp/repro-bell.mts <<'EOF'
import { mkdtempSync, writeFileSync } from 'node:fs';
import { tmpdir } from 'node:os';
import { join } from 'node:path';
const R = process.cwd(); // запускать из корня репозитория
const load = (p: string) => import(`${R}/${p}`);
let t = Date.parse('2026-10-01T07:00:00Z'), n = 0;
const at = (ms = 20_000) => new Date((t += ms)).toISOString();
const base = (x = {}) => ({ uuid: `u${++n}`, parentUuid: null, sessionId: 's', cwd: '/p', isSidechain: false, ...x });
const user = (content: unknown, x = {}, gap?: number) => ({ ...base(x), type: 'user', timestamp: at(gap), message: { role: 'user', content } });
const ai = (block: object, ctx: number, out: number, ids: { rid?: string; mid: string }, x = {}, gap?: number) => ({ ...base(x), type: 'assistant', timestamp: at(gap), ...(ids.rid ? { requestId: ids.rid } : {}), message: { id: ids.mid, role: 'assistant', model: 'claude-x', content: [block], usage: { input_tokens: 0, cache_read_input_tokens: ctx, cache_creation_input_tokens: 0, output_tokens: out } } });
const text = (s: string) => ({ type: 'text', text: s });
const write = (lines: object[]) => { const f = join(mkdtempSync(join(tmpdir(), 'repro-')), 's.jsonl'); writeFileSync(f, lines.map((l) => JSON.stringify(l)).join('\n') + '\n'); return f; };
// бюджет хода 10M, каждый запрос перечитывает 4M; время — UTC
const BUDGET = 10_000_000;
const jsonl = await load('src/main/utils/jsonl.ts');
const { ChunkBuilder } = await load('src/main/services/analysis/ChunkBuilder.ts');
const { transformChunksToConversation } = await load('src/renderer/utils/groupTransformer.ts');
const { processSessionContextWithPhases } = await load('src/renderer/utils/contextTracker.ts');
const { TurnBudgetDetector } = await load('src/main/utils/loopDetection.ts');
const hhmm = (d: string | Date) => new Date(d).toISOString().slice(11, 16);
const at2 = (iso: string) => ({ timestamp: iso });
const row = (kind: string, i: number, iso: string, x: object = {}) => {
  const m = kind === 'ai' ? ai(text(`r${i}`), 4_000_000, 10, { rid: `q${i}`, mid: `m${i}` }) : kind === 'relay'
    ? user('<teammate-message teammate_id="b">status?</teammate-message>', { isMeta: false })
    : kind === 'compact' ? user('This session is being continued...', { isCompactSummary: true }) : user('go');
  return { ...m, ...x, ...at2(iso) };
};
const scenarios = {
  'компакт внутри хода': [['user', '07:00'], ['ai', '07:01'], ['ai', '07:02'], ['compact', '07:30'], ['ai', '07:31'], ['ai', '07:32'], ['ai', '07:33']],
  'релей после пересечения': [['user', '08:00'], ['ai', '08:01'], ['ai', '08:02'], ['ai', '08:03'], ['relay', '08:10'], ['ai', '08:11']],
};
let bad = 0;
for (const [name, steps] of Object.entries(scenarios)) {
  const f = write(steps.map(([k, hm], i) => row(k, i, `2026-10-01T${hm}:00Z`)));
  const msgs = await jsonl.parseJsonlFile(f);
  const det = new TurnBudgetDetector();
  const bell = msgs.map((m: object) => det.feed('f', [m], BUDGET)).find(Boolean);
  const conv = transformChunksToConversation(new ChunkBuilder().buildChunks(msgs, []), [], false);
  const raw = processSessionContextWithPhases(conv.items, '/p', {}, new Map(), new Map()).phaseInfo.rereadAll;
  const same = raw.some((r: { turnIndex: number; turnStartTs: string }) => r.turnIndex + 1 === bell.turnNumber && hhmm(r.turnStartTs) === hhmm(bell.turnStartTs));
  bad += same ? 0 : 1;
  const rows = raw
    .map((r: { turnIndex: number; phaseNumber: number; turnStartTs: string; estimatedTokens: number }) => `Turn ${r.turnIndex + 1} · ph${r.phaseNumber} · ${hhmm(r.turnStartTs)} · ${r.estimatedTokens / 1e6}M`);
  console.log(`\n== ${name}\nколокол: turn ${bell.turnNumber} (${hhmm(bell.turnStartTs)}) · ${bell.spent / 1e6}M at crossing\nпанель Re-read:\n  ${rows.join('\n  ')}\nстрока панели с тем же номером и временем: ${same ? 'есть' : 'НЕТ'}`);
}
console.log(bad ? `\nВОСПРОИЗВЕДЕНО: в ${bad} из 2 сценариев уведомление нельзя сопоставить со строкой панели` : '\nOK');
EOF
pnpm exec tsx /tmp/repro-bell.mts