Function getWebsitePageviewMetrics

src/server/model/website/index.ts:577–667

(
  websiteId: string,
  column: string,
  filters: WebsiteQueryFilters
)

}

export async function getWebsitePageviewMetrics(
  websiteId: string,
  column: string,
  filters: WebsiteQueryFilters
): Promise<{ x: string; y: number }[]> {
  const eventType =
    column === 'eventName' ? EVENT_TYPE.customEvent : EVENT_TYPE.pageView;
  const { filterQuery, joinSession, params } = await parseWebsiteFilters(
    websiteId,
    {
      ...filters,
    },
    { joinSession: SESSION_COLUMNS.includes(column) }
  );

  let excludeDomain = Prisma.empty;
  if (column === 'referrerDomain') {
    excludeDomain = Prisma.sql`and ("WebsiteEvent"."referrerDomain" != ${params.websiteDomain} or "WebsiteEvent"."referrerDomain" is null)`;
  }

  // ClickHouse fast path: only on WebsiteEvent without session join
  if (env.clickhouse.enable && clickhouseHealthManager.isClickHouseHealthy()) {
    try {
      const chFilter = unwrapSQL(filterQuery)
        .replace(/\"WebsiteEvent\"\./g, '')
        .replace(/\"WebsiteSession\"\./g, '')
        .replace(/\"/g, '')
        .replace(/::[a-zA-Z]+/g, '');

      const chExclude =
        column === 'referrerDomain'
          ? `and (referrerDomain != {websiteDomain:String} or referrerDomain is null)`
          : '';

      const chJoin =
        joinSession === Prisma.empty
          ? ''
          : 'INNER JOIN WebsiteSession ON WebsiteEvent.sessionId = WebsiteSession.id';

      const chQuery = `
        select ${column} as x, count(*) as y
        from WebsiteEvent
        ${chJoin}
        where websiteId = {websiteId:String}
          and createdAt between toDateTime({start:String}, 'UTC') and toDateTime({end:String}, 'UTC')
          and eventType = {eventType:UInt64}
          ${chExclude}
          ${chFilter}
        group by ${column}
        order by y desc
        limit 100
      `;

      const result = await clickhouse.query({
        query: chQuery,
        query_params: {
          websiteId,
          websiteDomain: params.websiteDomain,