Function sendReplay

lib/ws-server.js:53–77

(ws, lastSeq = null)

const { restartClaude } = require('./pty-manager');

function sendReplay(ws, lastSeq = null) {
  const normalizedLastSeq = Number.isInteger(lastSeq) && lastSeq >= 0 ? lastSeq : null;
  const replayFrom = normalizedLastSeq == null ? 0 : normalizedLastSeq;
  const records = replayFrom > 0
    ? state.eventBuffer.filter(record => record.seq > replayFrom)
    : state.eventBuffer;

  log(`Replay start -> ${wsLabel(ws)} from=${replayFrom} count=${records.length} currentSession=${state.currentSessionId ?? 'null'}`);

  for (const record of records) {
    ws.send(JSON.stringify({
      type: 'log_event',
      seq: record.seq,
      event: record.event,
    }));
  }

  sendWs(ws, {
    type: 'replay_done',
    sessionId: state.currentSessionId,
    lastSeq: latestEventSeq(),
    resumed: normalizedLastSeq != null,
  }, 'sendReplay');
  sendTurnState(ws, 'sendReplay');
}

function sendInitialMessages(ws) {
  sendWs(ws, {