Function scenarioSingleSession

apps/api/e2e/session-e2e.ts:43–113

()

} from './lib';

async function scenarioSingleSession() {
  scenario('single session → reaper close → cleanup');
  const ip = `10.${(runId >> 16) & 255}.1.${runId & 255 || 1}`;

  const first = await screenView(ip, '/a');
  await screenView(ip, '/b');
  await screenView(ip, '/c');
  const { deviceId, sessionId } = first;
  check('track returned a sessionId', !!sessionId, `got '${sessionId}'`);

  const blob = await pollUntil(async () => {
    const b = await getBlob(deviceId);
    return b?.id === sessionId ? b : null;
  });
  check('redis: session blob exists with matching id', !!blob);
  check(
    'redis: device in wallclock index',
    (await redis.zscore(wallclockKey, deviceId)) !== null
  );
  check(
    'redis: project in active set',
    (await redis.sismember('session:projects', PROJECT_ID)) === 1
  );

  const starts = await pollUntil(async () => {
    const c = await countByName([sessionId], 'session_start');
    return c > 0 ? c : null;
  });
  check('clickhouse: exactly one session_start', starts === 1, `got ${starts}`);
  const views = await pollUntil(async () => {
    const c = await countByName([sessionId], 'screen_view');
    return c >= 3 ? c : null;
  });
  check('clickhouse: 3 screen_views ingested', !!views, `got ${views}`);

  console.log(`   …waiting ${IDLE_WAIT_MS}ms for idle window, then reaping`);
  await sleep(IDLE_WAIT_MS);
  await triggerReaper();

  const ends = await pollUntil(async () => {
    const c = await countByName([sessionId], 'session_end');
    return c > 0 ? c : null;
  });
  check('clickhouse: exactly one session_end', ends === 1, `got ${ends}`);

  const sessionRow = await pollUntil(async () => {
    const rows = await chQuery<{ is_bounce: boolean }>(
      `SELECT is_bounce FROM sessions FINAL WHERE project_id = '${PROJECT_ID}' AND id = '${sessionId}' LIMIT 1`
    );
    return rows[0] ?? null;
  });
  check('clickhouse: sessions row present (collapsed)', !!sessionRow);
  check(
    'clickhouse: session not a bounce (3 screen_views)',
    sessionRow?.is_bounce === false || Number(sessionRow?.is_bounce) === 0,
    `is_bounce=${sessionRow?.is_bounce}`
  );