diff --git a/src/lib/clickhouse.ts b/src/lib/clickhouse.ts index ae44c9147..bf9d72677 100644 --- a/src/lib/clickhouse.ts +++ b/src/lib/clickhouse.ts @@ -1,7 +1,7 @@ -import { CLICKHOUSE } from '@/lib/db'; import { type ClickHouseClient, createClient } from '@clickhouse/client'; import { formatInTimeZone } from 'date-fns-tz'; import debug from 'debug'; +import { CLICKHOUSE } from '@/lib/db'; import { DATA_TYPE, DEFAULT_PAGE_SIZE, FILTER_COLUMNS, OPERATORS } from './constants'; import { filtersObjectToArray } from './params'; import type { Operator, PropertyFilter, QueryFilters, QueryOptions } from './types'; @@ -79,7 +79,13 @@ function getSearchSQL(column: string, param: string = 'search'): string { return `and positionCaseInsensitive(${column}, {${param}:String}) > 0`; } -function mapFilter(column: string, operator: Operator, name: string, type: string = 'String', paramName?: string) { +function mapFilter( + column: string, + operator: Operator, + name: string, + type: string = 'String', + paramName?: string, +) { const param = paramName ?? name; const value = `{${param}:${type}}`; @@ -388,7 +394,15 @@ async function pagedRawQuery( const count = await rawQuery(countQuery, queryParams).then(res => res[0].num); const data = await rawQuery(`${query}${statements}`, queryParams, name); - return { data, count, page: +page, pageSize: size, orderBy, search, isCapped: !!maxResults && +count >= +maxResults }; + return { + data, + count, + page: +page, + pageSize: size, + orderBy, + search, + isCapped: !!maxResults && +count >= +maxResults, + }; } async function rawQuery( diff --git a/src/lib/prisma.ts b/src/lib/prisma.ts index 7f400d05b..6cdb33cfd 100644 --- a/src/lib/prisma.ts +++ b/src/lib/prisma.ts @@ -1,8 +1,14 @@ -import { PrismaClient } from '@/generated/prisma/client'; import { PrismaPg } from '@prisma/adapter-pg'; import { readReplicas } from '@prisma/extension-read-replicas'; import debug from 'debug'; -import { DATA_TYPE, DEFAULT_PAGE_SIZE, FILTER_COLUMNS, OPERATORS, SESSION_COLUMNS } from './constants'; +import { PrismaClient } from '@/generated/prisma/client'; +import { + DATA_TYPE, + DEFAULT_PAGE_SIZE, + FILTER_COLUMNS, + OPERATORS, + SESSION_COLUMNS, +} from './constants'; import { filtersObjectToArray } from './params'; import type { Operator, PropertyFilter, QueryFilters, QueryOptions } from './types'; @@ -68,7 +74,11 @@ function getDateSQL(field: string, unit: string, timezone?: string): string { return `to_char(date_trunc('${unit}', ${field}), '${DATE_FORMATS_UTC[unit]}')`; } -function getDateStringSQL(field: string, unit: keyof typeof DATE_STRING_FORMATS = 'utc', timezone?: string): string { +function getDateStringSQL( + field: string, + unit: keyof typeof DATE_STRING_FORMATS = 'utc', + timezone?: string, +): string { if (timezone && !isUtcTimezone(timezone)) { return `to_char(${field} at time zone '${timezone}', '${DATE_STRING_FORMATS[unit]}')`; } @@ -478,7 +488,14 @@ async function pagedRawQuery( const count = await rawQuery(countQuery, queryParams).then(res => Number(res[0].num)); const data = await rawQuery(`${query}${statements}`, queryParams, name); - return { data, count, page: +page, pageSize: size, orderBy, isCapped: !!maxResults && +count >= +maxResults }; + return { + data, + count, + page: +page, + pageSize: size, + orderBy, + isCapped: !!maxResults && +count >= +maxResults, + }; } function getSearchParameters(query: string, filters: Record[]) {