Function main

scripts/seed-events.mjs:526–594

()

// ---------------------------------------------------------------------------

async function main() {
  console.log(`\nSeeding ${SESSION_COUNT} sessions over ${TIMELINE_MINUTES} minutes`);
  console.log(`API: ${TRACK_URL}`);
  console.log(`Client ID: ${CLIENT_ID}\n`);

  let totalEvents = 0;
  let errors = 0;

  const sessionTasks = Array.from({ length: SESSION_COUNT }, (_, i) => async () => {
    const session = buildSession(i);
    const scheduledEvents = scheduleSession(session, i, SESSION_COUNT);
    const { identity, group, ua, ip } = session;

    // 1. Identify
    try {
      await sendEvent({ type: 'identify', payload: identity }, ua, ip);
    } catch (e) {
      errors++;
      console.error(`  [ERROR] identify session ${i}:`, e.message);
    }

    // 2. Group (if applicable)
    if (group) {
      try {
        await sendEvent({ type: 'group', payload: { ...group, profileId: identity.profileId } }, ua, ip);
      } catch (e) {
        errors++;
        console.error(`  [ERROR] group session ${i}:`, e.message);
      }
    }

    // 3. Track events in order
    for (const ev of scheduledEvents) {
      const trackPayload = {
        name: ev.name,
        profileId: identity.profileId,
        properties: {
          ...ev.props,
          __timestamp: new Date(ev.timestamp).toISOString(),
          ...(group ? { __group: group.id } : {}),
        },
        groups: group ? [group.id] : [],
      };

      if (ev.revenue) {
        trackPayload.properties.__revenue = ev.props.revenue;
      }

      try {
        await sendEvent({ type: 'track', payload: trackPayload }, ua, ip);
        totalEvents++;
      } catch (e) {
        errors++;
        console.error(`  [ERROR] track ${ev.name} session ${i}:`, e.message);
      }
    }

    if ((i + 1) % 50 === 0 || i + 1 === SESSION_COUNT) {