Function fakeIO

test/bot-stream-pump.test.ts:6–19

A fake transport that records every send/edit, with a hand-driven clock.

(maxLen = 50, minIntervalMs = 1000)

/** A fake transport that records every send/edit, with a hand-driven clock. */
function fakeIO(maxLen = 50, minIntervalMs = 1000) {
  const log: Array<{ op: 'send' | 'edit'; id: string; text: string }> = [];
  let clock = 0;
  let n = 0;
  const messages = new Map<string, string>();
  const io: PumpIO = {
    maxLen,
    minIntervalMs,
    now: () => clock,
    send: async (text) => { const id = `m${++n}`; messages.set(id, text); log.push({ op: 'send', id, text }); return { id } as MessageRef; },
    edit: async (ref, text) => { messages.set(ref.id, text); log.push({ op: 'edit', id: ref.id, text }); },
  };
  return { io, log, messages, tick: (ms: number) => { clock += ms; }, sends: () => log.filter(l => l.op === 'send').length, edits: () => log.filter(l => l.op === 'edit').length };
}

describe('StreamPump', () => {
  it('throttles: many rapid pushes inside one window cause at most the first send', async () => {