Function emit

apps/api/e2e/session-stress.ts:99–137

()

}

async function emit(): Promise<Session[]> {
  scenario(`emit ${SESSIONS} sessions × ${EVENTS_PER_SESSION} events (concurrency ${CONCURRENCY})`);
  const sessions: Session[] = [];
  let done = 0;
  let errors = 0;
  const started = Date.now();

  await runPool(
    Array.from({ length: SESSIONS }, (_, i) => i),
    CONCURRENCY,
    async (i) => {
      const ip = ipForSession(i);
      try {
        const first = await sendSessionEvent(ip, i, 0); // entry is a screen_view
        for (let e = 1; e < EVENTS_PER_SESSION; e++) {
          await sendSessionEvent(ip, i, e);
        }
        sessions.push({ sessionId: first.sessionId, deviceId: first.deviceId });
      } catch (error) {
        errors++;
        if (errors <= 3) console.warn(`   session ${i} failed: ${(error as Error).message}`);
      }
      done++;
      if (done % 100 === 0 || done === SESSIONS) {
        console.log(`   …emitted ${done}/${SESSIONS}`);
      }
    }
  );

  const uniq = new Set(sessions.map((s) => s.sessionId)).size;
  check('all sessions sent without HTTP errors', errors === 0, `${errors} errors`);
  check(
    'each session got a distinct session id',
    uniq === SESSIONS,
    `${uniq} unique / ${sessions.length} ok / ${SESSIONS} sent`
  );
  console.log(`   emit took ${((Date.now() - started) / 1000).toFixed(1)}s`);
  return sessions;
}

async function settle(sessions: Session[]) {
  scenario('settle: all sessions opened in ClickHouse');