Function queryEventsCore

packages/db/src/services/event.service.ts:1311–1415

(
  input: QueryEventsInput
)

}

export async function queryEventsCore(
  input: QueryEventsInput
): Promise<IClickhouseEvent[]> {
  const builder = clix(ch)
    .select<IClickhouseEvent>([])
    .from(TABLE_NAMES.events)
    .where('project_id', '=', input.projectId);

  if (input.sessionId) {
    builder.where('session_id', '=', input.sessionId);
  }

  if (input.profileId) {
    builder.where('profile_id', '=', input.profileId);
  }

  if (input.profileIds?.length) {
    builder.where('profile_id', 'IN', input.profileIds);
  }

  if (input.eventNames?.length) {
    builder.where('name', 'IN', input.eventNames);
  }

  if (input.path) {
    builder.where('path', '=', input.path);
  }

  if (input.referrer) {
    builder.where('referrer', '=', input.referrer);
  }

  if (input.referrerName) {
    builder.where('referrer_name', '=', input.referrerName);
  }

  if (input.referrerType) {
    builder.where('referrer_type', '=', input.referrerType);
  }

  if (input.device) {
    builder.where('device', '=', input.device);
  }

  if (input.country) {
    builder.where('country', '=', input.country);
  }

  if (input.city) {
    builder.where('city', '=', input.city);
  }

  if (input.os) {
    builder.where('os', '=', input.os);
  }

  if (input.browser) {
    builder.where('browser', '=', input.browser);