Class EventService

packages/db/src/services/event.service.ts:839–1181

}

class EventService {
  constructor(private client: typeof ch) {}

  query<T>({
    projectId,
    profileId,
    where,
    select,
    limit,
    filters,
  }: {
    projectId: string;
    profileId?: string;
    where?: {
      profile?: (query: Query<T>) => void;
      event?: (query: Query<T>) => void;
      session?: (query: Query<T>) => void;
    };
    select: {
      profile?: Partial<SelectHelper<IServiceProfile>>;
      event: Partial<SelectHelper<IServiceEvent>>;
    };
    limit?: number;
    orderBy?: keyof IClickhouseEvent;
    filters?: IChartEventFilter[];
  }) {
    // Extract profile filters if any
    const profileFilters =
      filters
        ?.filter((f) => f.name.startsWith('profile.'))
        .map((f) => f.name.replace('profile.', '')) ?? [];

    const events = clix(this.client)
      .select<
        Partial<IClickhouseEvent> & {
          // profile
          profileId: string;
          profile_firstName: string;
          profile_lastName: string;
          profile_avatar: string;
          profile_isExternal: boolean;
          profile_createdAt: string;
        }
      >([
        select.event.id && 'e.id as id',
        select.event.deviceId && 'e.device_id as device_id',
        select.event.name && 'e.name as name',
        select.event.path && 'e.path as path',
        select.event.country && 'e.country as country',
        select.event.city && 'e.city as city',
        select.event.os && 'e.os as os',
        select.event.browser && 'e.browser as browser',
        select.event.createdAt && 'e.created_at as created_at',
        select.event.projectId && 'e.project_id as project_id',
        'e.session_id as session_id',
        'e.profile_id as profile_id',
      ])
      .from('events e')