Function scenarioIdentify

apps/api/e2e/session-e2e.ts:223–249

()

}

async function scenarioIdentify() {
  scenario('identified visit → profile index + profile_id on events');
  const ip = `10.${(runId >> 16) & 255}.4.${runId & 255 || 1}`;
  const profileId = `e2e-user-${runId}`;

  const { deviceId, sessionId } = await screenView(ip, '/account');
  await track(
    {
      type: 'track',
      payload: { name: 'signed_in', profileId, properties: { __ip: ip } },
    },
    ip
  );

  const ptr = await pollUntil(async () =>
    (await redis.get(profileKey(profileId))) === deviceId ? true : null
  );
  check('redis: profile→device pointer written', !!ptr);

  const profiled = await pollUntil(async () => {
    const rows = await chQuery<{ c: string }>(
      `SELECT count() AS c FROM events WHERE project_id = '${PROJECT_ID}' AND session_id = '${sessionId}' AND profile_id = '${profileId}'`
    );
    return Number(rows[0]?.c ?? 0) > 0 ? true : null;
  });
  check('clickhouse: event carries the identified profile_id', !!profiled);
}

async function main() {
  console.log(