Function scenarioNonScreenViewFirst

apps/api/e2e/session-e2e.ts:144–191

()

}

async function scenarioNonScreenViewFirst() {
  scenario('session opened by a non-screen_view event');
  const ip = `10.${(runId >> 16) & 255}.5.${runId & 255 || 1}`;

  // First (and only) event is a custom event with no __path.
  const { deviceId, sessionId } = await track(
    { type: 'track', payload: { name: 'purchase', properties: { __ip: ip } } },
    ip
  );
  check('track returned a sessionId for a non-screen_view first event', !!sessionId);

  const starts = await pollUntil(async () =>
    (await countByName([sessionId], 'session_start')) > 0 ? true : null
  );
  check('clickhouse: session_start emitted for a custom-event session', !!starts);

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

  const ends = await pollUntil(async () =>
    (await countByName([sessionId], 'session_end')) > 0 ? true : null
  );
  check('clickhouse: session_end emitted (closes normally)', !!ends);

  const row = await pollUntil(async () => {
    const rows = await chQuery<{
      screen_view_count: number;
      event_count: number;
      is_bounce: boolean;
    }>(
      `SELECT screen_view_count, event_count, is_bounce FROM sessions FINAL WHERE project_id = '${PROJECT_ID}' AND id = '${sessionId}' LIMIT 1`
    );
    return rows[0] ?? null;
  });
  check('clickhouse: screen_view_count is 0', Number(row?.screen_view_count) === 0, `${row?.screen_view_count}`);
  check('clickhouse: event_count is 1', Number(row?.event_count) === 1, `${row?.event_count}`);
  check(
    'clickhouse: is_bounce is true (no pageviews)',
    row?.is_bounce === true || Number(row?.is_bounce) === 1,
    `is_bounce=${row?.is_bounce}`
  );

  const cleaned = await pollUntil(async () =>
    (await redis.get(sessionKey(deviceId))) === null ? true : null
  );
  check('redis: session cleaned up after close', !!cleaned);
}

async function scenarioReplay() {
  scenario('replay chunk files under the echoed session id');