Function getTelemetrySessionMetrics

src/server/model/telemetry.ts:265–297

(
  telemetryId: string,
  column: string,
  filters: BaseQueryFilters
)

}

export async function getTelemetrySessionMetrics(
  telemetryId: string,
  column: string,
  filters: BaseQueryFilters
): Promise<{ x: string; y: number }[]> {
  const { filterQuery, joinSession, params } = await parseTelemetryFilters(
    telemetryId,
    {
      ...filters,
    },
    {
      joinSession: SESSION_COLUMNS.includes(column),
    }
  );
  const includeCountry = column === 'city' || column === 'subdivision1';

  return prisma.$queryRaw`select
      ${Prisma.sql([`"${column}"`])} x,
      count(distinct "TelemetryEvent"."sessionId") y
      ${includeCountry ? Prisma.sql([', country']) : Prisma.empty}
    from "TelemetryEvent"
    ${joinSession}
    where "TelemetryEvent"."telemetryId" = ${telemetryId}
      and "TelemetryEvent"."createdAt"
      between ${params.startDate}::timestamptz and ${
        params.endDate
      }::timestamptz
      ${filterQuery}
    group by 1
    ${includeCountry ? Prisma.sql([', 3']) : Prisma.empty}
    order by 2 desc
    limit 100`;
}

export async function getTelemetryPageviewMetrics(
  telemetryId: string,