Function parseTelemetryFilters

src/server/utils/prisma.ts:103–135

(
  telemetryId: string,
  filters: BaseQueryFilters = {},
  options: QueryOptions = {}
)

}

export async function parseTelemetryFilters(
  telemetryId: string,
  filters: BaseQueryFilters = {},
  options: QueryOptions = {}
) {
  const telemetry = await loadTelemetry(telemetryId);

  if (!telemetry) {
    throw new Error('Not found telemetry');
  }

  return {
    joinSession:
      options?.joinSession ||
      Object.entries(filters).find(
        ([key, value]) =>
          typeof value !== 'undefined' && SESSION_COLUMNS.includes(key)
      )
        ? Prisma.sql([
            `inner join "TelemetrySession" on "TelemetryEvent"."sessionId" = "TelemetrySession"."id"`,
          ])
        : Prisma.empty,
    filterQuery: getTelemetryFilterQuery(filters, options),
    params: {
      ...normalizeFilters(filters),
      telemetryId,
      startDate: dayjs(filters.startDate).toISOString(),
      endDate: filters.endDate
        ? dayjs(filters.endDate).toISOString()
        : undefined,
    },
  };
}

function normalizeFilters(filters: Record<string, any> = {}) {
  return Object.keys(filters).reduce(