analytics.ts

import { generateUUID } from '../ids';
import { retryFetch } from './retry';

const generateEventId = (now: Date) => {
  const randomStr = (Math.random() + 1).toString(36).substring(8);
  const timePart = (now.getTime() / 1000).toFixed(0);
  return `${timePart}${randomStr}`;
};

export type AnalyticsEvent = {
  event_name: string;
  event_timestamp: Date;
  user_id: string;
};

export enum AnalyticsEventName {
  ConfirmAddingWorkspace = 'confirm adding workspace',
  // Plus
  ChangeBillingCycle = 'change billing cycle',
  CancelSubscription = 'cancel subscription',
  ReceivePayment = 'receive payment',
  ClaimSubscription = 'claim subscription',
}

export async function sendAnalyticsEvent<T extends AnalyticsEvent>(
  events: T[],
): Promise<void> {
  const now = new Date();
  const [visit_id, session_id] = await Promise.all([
    generateUUID(),
    generateUUID(),
  ]);
  const transformed = events.map((event) => ({
    event_id: generateEventId(now),
    visit_id,
    session_id,
    ...event,
  }));
  await retryFetch(
    `${process.env.ANALYTICS_URL}/e`,
    {
      method: 'POST',
      body: JSON.stringify({ events: transformed }),
      headers: {
        'content-type': 'application/json',
      },
    },
    { retries: 3 },
  );
}

export type ExperimentAllocationEvent = {
  event_timestamp: Date;
  user_id: string;
  experiment_id: string;
  variation_id: string;
};

export async function sendExperimentAllocationEvent<
  T extends ExperimentAllocationEvent,
>(event: T): Promise<void> {
  await retryFetch(
    `${process.env.ANALYTICS_URL}/e/x`,
    {
      method: 'POST',
      body: JSON.stringify(event),
      headers: {
        'content-type': 'application/json',
      },
    },
    { retries: 3 },
  );
}

export enum TargetType {
  Plus = 'plus',
  Credits = 'credits',
  Recruiter = 'recruiter',
}