Function scenarioBoundary

apps/api/e2e/session-e2e.ts:115–142

()

}

async function scenarioBoundary() {
  scenario('boundary split → first session closes, second opens');
  const ip = `10.${(runId >> 16) & 255}.2.${runId & 255 || 1}`;

  const a = await screenView(ip, '/x');
  console.log(`   …waiting ${IDLE_WAIT_MS}ms so the next event crosses the boundary`);
  await sleep(IDLE_WAIT_MS);
  const b = await screenView(ip, '/y');

  check(
    'second event opened a NEW session id',
    a.sessionId !== b.sessionId && !!b.sessionId,
    `${a.sessionId} vs ${b.sessionId}`
  );

  const startsA = await pollUntil(async () =>
    (await countByName([a.sessionId], 'session_start')) > 0 ? true : null
  );
  check('clickhouse: session_start for first session', !!startsA);
  const startsB = await pollUntil(async () =>
    (await countByName([b.sessionId], 'session_start')) > 0 ? true : null
  );
  check('clickhouse: session_start for second session', !!startsB);
  const endsA = await pollUntil(async () =>
    (await countByName([a.sessionId], 'session_end')) > 0 ? true : null
  );
  check('clickhouse: first session got a session_end', !!endsA);
}

async function scenarioNonScreenViewFirst() {
  scenario('session opened by a non-screen_view event');