diff --git a/src/lib/clickhouse.ts b/src/lib/clickhouse.ts index 5e6e7133c..bc99f8f2a 100644 --- a/src/lib/clickhouse.ts +++ b/src/lib/clickhouse.ts @@ -181,7 +181,6 @@ async function pagedRawQuery( query: string, queryParams: Record, filters: QueryFilters, - name?: string, ) { const { page = 1, pageSize, orderBy, sortDescending = false, search } = filters; const size = +pageSize || DEFAULT_PAGE_SIZE; @@ -199,7 +198,7 @@ async function pagedRawQuery( res => res[0].num, ); - const data = await rawQuery(`${query}${statements}`, queryParams, name); + const data = await rawQuery(`${query}${statements}`, queryParams); return { data, count, page: +page, pageSize: size, orderBy, search }; } diff --git a/src/lib/prisma.ts b/src/lib/prisma.ts index 346f118e9..c3092512b 100644 --- a/src/lib/prisma.ts +++ b/src/lib/prisma.ts @@ -219,7 +219,6 @@ async function pagedRawQuery( query: string, filters: QueryFilters, queryParams: Record, - name?: string, ) { const { page = 1, pageSize, orderBy, sortDescending = false } = filters; const size = +pageSize || DEFAULT_PAGE_SIZE; @@ -237,7 +236,7 @@ async function pagedRawQuery( res => res[0].num, ); - const data = await rawQuery(`${query}${statements}`, queryParams, name); + const data = await rawQuery(`${query}${statements}`, queryParams); return { data, count, page: +page, pageSize: size, orderBy }; } diff --git a/src/queries/sql/events/getEventData.ts b/src/queries/sql/events/getEventData.ts index f8ba2eef3..1167f0140 100644 --- a/src/queries/sql/events/getEventData.ts +++ b/src/queries/sql/events/getEventData.ts @@ -3,8 +3,6 @@ import prisma from '@/lib/prisma'; import clickhouse from '@/lib/clickhouse'; import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; -const FUNCTION_NAME = 'getEventData'; - export async function getEventData(...args: [eventId: string]): Promise { return runQuery({ [PRISMA]: () => relationalQuery(...args), @@ -32,7 +30,6 @@ async function relationalQuery(eventId: string) { where event_id = {{eventId::uuid}} `, { eventId }, - FUNCTION_NAME, ); } @@ -56,6 +53,5 @@ async function clickhouseQuery(eventId: string): Promise { where event_id = {eventId:UUID} `, { eventId }, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/events/getEventDataEvents.ts b/src/queries/sql/events/getEventDataEvents.ts index f7bea46c1..ac9f26d6e 100644 --- a/src/queries/sql/events/getEventDataEvents.ts +++ b/src/queries/sql/events/getEventDataEvents.ts @@ -3,8 +3,6 @@ import clickhouse from '@/lib/clickhouse'; import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getEventDataEvents'; - export interface WebsiteEventData { eventName?: string; propertyName: string; @@ -46,7 +44,6 @@ async function relationalQuery(websiteId: string, filters: QueryFilters) { order by 1 asc, 2 asc, 3 asc, 5 desc `, queryParams, - FUNCTION_NAME, ); } @@ -62,10 +59,11 @@ async function relationalQuery(websiteId: string, filters: QueryFilters) { on website_event.event_id = event_data.website_event_id where event_data.website_id = {{websiteId::uuid}} and event_data.created_at between {{startDate}} and {{endDate}} + group by website_event.event_name, event_data.data_key, event_data.data_type + order by 1 asc, 2 asc limit 500 `, queryParams, - FUNCTION_NAME, ); } @@ -95,7 +93,6 @@ async function clickhouseQuery( limit 500 `, queryParams, - FUNCTION_NAME, ); } @@ -114,6 +111,5 @@ async function clickhouseQuery( limit 500 `, queryParams, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/events/getEventDataFields.ts b/src/queries/sql/events/getEventDataFields.ts index d62af2d40..1b76f0a06 100644 --- a/src/queries/sql/events/getEventDataFields.ts +++ b/src/queries/sql/events/getEventDataFields.ts @@ -3,8 +3,6 @@ import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import prisma from '@/lib/prisma'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getEventDataFields'; - export async function getEventDataFields(...args: [websiteId: string, filters: QueryFilters]) { return runQuery({ [PRISMA]: () => relationalQuery(...args), @@ -44,7 +42,6 @@ async function relationalQuery(websiteId: string, filters: QueryFilters) { limit 100 `, queryParams, - FUNCTION_NAME, ); } @@ -74,6 +71,5 @@ async function clickhouseQuery( limit 100 `, queryParams, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/events/getEventDataProperties.ts b/src/queries/sql/events/getEventDataProperties.ts index 60b46bcce..7eccf594c 100644 --- a/src/queries/sql/events/getEventDataProperties.ts +++ b/src/queries/sql/events/getEventDataProperties.ts @@ -3,8 +3,6 @@ import clickhouse from '@/lib/clickhouse'; import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getEventDataProperties'; - export async function getEventDataProperties( ...args: [websiteId: string, filters: QueryFilters & { propertyName?: string }] ) { @@ -46,7 +44,6 @@ async function relationalQuery( limit 500 `, queryParams, - FUNCTION_NAME, ); } @@ -78,6 +75,5 @@ async function clickhouseQuery( limit 500 `, queryParams, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/events/getEventDataStats.ts b/src/queries/sql/events/getEventDataStats.ts index 606a49ea5..ea42be7c0 100644 --- a/src/queries/sql/events/getEventDataStats.ts +++ b/src/queries/sql/events/getEventDataStats.ts @@ -3,8 +3,6 @@ import clickhouse from '@/lib/clickhouse'; import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getEventDataStats'; - export async function getEventDataStats( ...args: [websiteId: string, filters: QueryFilters] ): Promise<{ @@ -49,7 +47,6 @@ async function relationalQuery(websiteId: string, filters: QueryFilters) { ) as t `, queryParams, - FUNCTION_NAME, ); } @@ -80,6 +77,5 @@ async function clickhouseQuery( ) as t `, queryParams, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/events/getEventDataUsage.ts b/src/queries/sql/events/getEventDataUsage.ts index c72f5b3e6..7417a17e3 100644 --- a/src/queries/sql/events/getEventDataUsage.ts +++ b/src/queries/sql/events/getEventDataUsage.ts @@ -2,8 +2,6 @@ import clickhouse from '@/lib/clickhouse'; import { CLICKHOUSE, PRISMA, runQuery, notImplemented } from '@/lib/db'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getEventDataUsage'; - export function getEventDataUsage(...args: [websiteIds: string[], filters: QueryFilters]) { return runQuery({ [PRISMA]: notImplemented, @@ -33,6 +31,5 @@ function clickhouseQuery( startDate, endDate, }, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/events/getEventDataValues.ts b/src/queries/sql/events/getEventDataValues.ts index bdfe7482e..a8f4b4a1e 100644 --- a/src/queries/sql/events/getEventDataValues.ts +++ b/src/queries/sql/events/getEventDataValues.ts @@ -3,8 +3,6 @@ import clickhouse from '@/lib/clickhouse'; import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getEventDataValues'; - interface WebsiteEventData { value: string; total: number; @@ -57,7 +55,6 @@ async function relationalQuery( limit 100 `, queryParams, - FUNCTION_NAME, ); } @@ -87,6 +84,5 @@ async function clickhouseQuery( limit 100 `, queryParams, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/events/getEventExpandedMetrics.ts b/src/queries/sql/events/getEventExpandedMetrics.ts index c36a829a9..6be99b409 100644 --- a/src/queries/sql/events/getEventExpandedMetrics.ts +++ b/src/queries/sql/events/getEventExpandedMetrics.ts @@ -4,8 +4,6 @@ import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import prisma from '@/lib/prisma'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getEventExpandedMetrics'; - export interface EventExpandedMetricParameters { type: string; limit?: string; @@ -63,7 +61,6 @@ async function relationalQuery( offset ${offset} `, queryParams, - FUNCTION_NAME, ); } @@ -112,6 +109,5 @@ async function clickhouseQuery( offset ${offset} `, { ...queryParams, ...parameters }, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/events/getEventStats.ts b/src/queries/sql/events/getEventStats.ts index baa6f700d..54afaaf50 100644 --- a/src/queries/sql/events/getEventStats.ts +++ b/src/queries/sql/events/getEventStats.ts @@ -4,8 +4,6 @@ import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import prisma from '@/lib/prisma'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getEventStats'; - interface WebsiteEventMetric { x: string; t: string; @@ -46,7 +44,6 @@ async function relationalQuery(websiteId: string, filters: QueryFilters) { order by 2 `, queryParams, - FUNCTION_NAME, ); } @@ -97,5 +94,5 @@ async function clickhouseQuery( `; } - return rawQuery(sql, queryParams, FUNCTION_NAME); + return rawQuery(sql, queryParams); } diff --git a/src/queries/sql/events/getEventUsage.ts b/src/queries/sql/events/getEventUsage.ts index 0bd0a5f3a..45f1a4a89 100644 --- a/src/queries/sql/events/getEventUsage.ts +++ b/src/queries/sql/events/getEventUsage.ts @@ -2,8 +2,6 @@ import clickhouse from '@/lib/clickhouse'; import { CLICKHOUSE, PRISMA, runQuery, notImplemented } from '@/lib/db'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getEventUsage'; - export function getEventUsage(...args: [websiteIds: string[], filters: QueryFilters]) { return runQuery({ [PRISMA]: notImplemented, @@ -33,6 +31,5 @@ function clickhouseQuery( startDate, endDate, }, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/events/getWebsiteEvents.ts b/src/queries/sql/events/getWebsiteEvents.ts index 371c45f66..b81ca9701 100644 --- a/src/queries/sql/events/getWebsiteEvents.ts +++ b/src/queries/sql/events/getWebsiteEvents.ts @@ -3,8 +3,6 @@ import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import prisma from '@/lib/prisma'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getWebsiteEvents'; - export function getWebsiteEvents(...args: [websiteId: string, filters: QueryFilters]) { return runQuery({ [PRISMA]: () => relationalQuery(...args), @@ -58,7 +56,6 @@ async function relationalQuery(websiteId: string, filters: QueryFilters) { `, queryParams, filters, - FUNCTION_NAME, ); } @@ -107,6 +104,5 @@ async function clickhouseQuery(websiteId: string, filters: QueryFilters) { `, queryParams, filters, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/getWebsiteStats.ts b/src/queries/sql/getWebsiteStats.ts index 391d22be2..9551cd8f7 100644 --- a/src/queries/sql/getWebsiteStats.ts +++ b/src/queries/sql/getWebsiteStats.ts @@ -4,8 +4,6 @@ import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import prisma from '@/lib/prisma'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getWebsiteStats'; - export interface WebsiteStatsData { pageviews: number; visitors: number; @@ -59,7 +57,6 @@ async function relationalQuery( ) as t `, queryParams, - FUNCTION_NAME, ).then(result => result?.[0]); } @@ -124,5 +121,5 @@ async function clickhouseQuery( `; } - return rawQuery(sql, queryParams, FUNCTION_NAME).then(result => result?.[0]); + return rawQuery(sql, queryParams).then(result => result?.[0]); } diff --git a/src/queries/sql/getWeeklyTraffic.ts b/src/queries/sql/getWeeklyTraffic.ts index 2ea370670..217f6fa7a 100644 --- a/src/queries/sql/getWeeklyTraffic.ts +++ b/src/queries/sql/getWeeklyTraffic.ts @@ -4,8 +4,6 @@ import { runQuery, PRISMA, CLICKHOUSE } from '@/lib/db'; import { QueryFilters } from '@/lib/types'; import { EVENT_COLUMNS } from '@/lib/constants'; -const FUNCTION_NAME = 'getWeeklyTraffic'; - export async function getWeeklyTraffic(...args: [websiteId: string, filters: QueryFilters]) { return runQuery({ [PRISMA]: () => relationalQuery(...args), @@ -36,7 +34,6 @@ async function relationalQuery(websiteId: string, filters: QueryFilters) { order by 2 `, queryParams, - FUNCTION_NAME, ).then(formatResults); } @@ -75,7 +72,7 @@ async function clickhouseQuery(websiteId: string, filters: QueryFilters) { `; } - return rawQuery(sql, queryParams, FUNCTION_NAME).then(formatResults); + return rawQuery(sql, queryParams).then(formatResults); } function formatResults(data: any) { diff --git a/src/queries/sql/pageviews/getPageviewStats.ts b/src/queries/sql/pageviews/getPageviewStats.ts index 7dd9ac93e..1e7f9d61b 100644 --- a/src/queries/sql/pageviews/getPageviewStats.ts +++ b/src/queries/sql/pageviews/getPageviewStats.ts @@ -4,8 +4,6 @@ import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import prisma from '@/lib/prisma'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getPageviewStats'; - export async function getPageviewStats(...args: [websiteId: string, filters: QueryFilters]) { return runQuery({ [PRISMA]: () => relationalQuery(...args), @@ -37,7 +35,6 @@ async function relationalQuery(websiteId: string, filters: QueryFilters) { order by 1 `, queryParams, - FUNCTION_NAME, ); } @@ -94,5 +91,5 @@ async function clickhouseQuery( `; } - return rawQuery(sql, queryParams, FUNCTION_NAME); + return rawQuery(sql, queryParams); } diff --git a/src/queries/sql/sessions/getSessionActivity.ts b/src/queries/sql/sessions/getSessionActivity.ts index 06b8a1372..ca0f18ee8 100644 --- a/src/queries/sql/sessions/getSessionActivity.ts +++ b/src/queries/sql/sessions/getSessionActivity.ts @@ -3,8 +3,6 @@ import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import prisma from '@/lib/prisma'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getSessionActivity'; - export async function getSessionActivity( ...args: [websiteId: string, sessionId: string, filters: QueryFilters] ) { @@ -15,31 +13,17 @@ export async function getSessionActivity( } async function relationalQuery(websiteId: string, sessionId: string, filters: QueryFilters) { - const { rawQuery } = prisma; const { startDate, endDate } = filters; - return rawQuery( - ` - select - created_at as createdAt, - url_path as urlPath, - url_query as urlQuery, - referrer_domain as referrerDomain, - event_id as eventId, - event_type as eventType, - event_name as eventName, - visit_id as visitId, - event_id IN (SELECT event_id FROM event_data) AS hasData - from website_event e - where e.website_id = {websiteId:UUID} - and e.session_id = {sessionId:UUID} - and e.created_at between {startDate:DateTime64} and {endDate:DateTime64} - order by e.created_at desc - limit 500 - `, - { websiteId, sessionId, startDate, endDate }, - FUNCTION_NAME, - ); + return prisma.client.websiteEvent.findMany({ + where: { + sessionId, + websiteId, + createdAt: { gte: startDate, lte: endDate }, + }, + take: 500, + orderBy: { createdAt: 'desc' }, + }); } async function clickhouseQuery(websiteId: string, sessionId: string, filters: QueryFilters) { @@ -66,6 +50,5 @@ async function clickhouseQuery(websiteId: string, sessionId: string, filters: Qu limit 500 `, { websiteId, sessionId, startDate, endDate }, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/sessions/getSessionData.ts b/src/queries/sql/sessions/getSessionData.ts index 09679fc82..a3f1e113b 100644 --- a/src/queries/sql/sessions/getSessionData.ts +++ b/src/queries/sql/sessions/getSessionData.ts @@ -2,8 +2,6 @@ import prisma from '@/lib/prisma'; import clickhouse from '@/lib/clickhouse'; import { runQuery, PRISMA, CLICKHOUSE } from '@/lib/db'; -const FUNCTION_NAME = 'getSessionData'; - export async function getSessionData(...args: [websiteId: string, sessionId: string]) { return runQuery({ [PRISMA]: () => relationalQuery(...args), @@ -31,7 +29,6 @@ async function relationalQuery(websiteId: string, sessionId: string) { order by data_key asc `, { websiteId, sessionId }, - FUNCTION_NAME, ); } @@ -55,6 +52,5 @@ async function clickhouseQuery(websiteId: string, sessionId: string) { order by data_key asc `, { websiteId, sessionId }, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/sessions/getSessionDataProperties.ts b/src/queries/sql/sessions/getSessionDataProperties.ts index 134cf7205..d72a04804 100644 --- a/src/queries/sql/sessions/getSessionDataProperties.ts +++ b/src/queries/sql/sessions/getSessionDataProperties.ts @@ -3,8 +3,6 @@ import clickhouse from '@/lib/clickhouse'; import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getSessionDataProperties'; - export async function getSessionDataProperties( ...args: [websiteId: string, filters: QueryFilters & { propertyName?: string }] ) { @@ -44,7 +42,6 @@ async function relationalQuery( limit 500 `, queryParams, - FUNCTION_NAME, ); } @@ -78,6 +75,5 @@ async function clickhouseQuery( limit 500 `, queryParams, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/sessions/getSessionDataValues.ts b/src/queries/sql/sessions/getSessionDataValues.ts index 8da126690..9ff3cb45e 100644 --- a/src/queries/sql/sessions/getSessionDataValues.ts +++ b/src/queries/sql/sessions/getSessionDataValues.ts @@ -3,8 +3,6 @@ import clickhouse from '@/lib/clickhouse'; import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getSessionDataValues'; - export async function getSessionDataValues( ...args: [websiteId: string, filters: QueryFilters & { propertyName?: string }] ) { @@ -47,7 +45,6 @@ async function relationalQuery( limit 100 `, queryParams, - FUNCTION_NAME, ); } @@ -78,6 +75,5 @@ async function clickhouseQuery( limit 100 `, queryParams, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/sessions/getSessionExpandedMetrics.ts b/src/queries/sql/sessions/getSessionExpandedMetrics.ts index 3adfd3464..b4ba5b671 100644 --- a/src/queries/sql/sessions/getSessionExpandedMetrics.ts +++ b/src/queries/sql/sessions/getSessionExpandedMetrics.ts @@ -4,8 +4,6 @@ import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import prisma from '@/lib/prisma'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getSessionExpandedMetrics'; - export interface SessionExpandedMetricsParameters { type: string; limit?: number | string; @@ -73,7 +71,6 @@ async function relationalQuery( offset ${offset} `, { ...queryParams, ...parameters }, - FUNCTION_NAME, ); } @@ -131,6 +128,5 @@ async function clickhouseQuery( offset ${offset} `, { ...queryParams, ...parameters }, - FUNCTION_NAME, ); } diff --git a/src/queries/sql/sessions/getSessionStats.ts b/src/queries/sql/sessions/getSessionStats.ts index 07582d395..b1c9891eb 100644 --- a/src/queries/sql/sessions/getSessionStats.ts +++ b/src/queries/sql/sessions/getSessionStats.ts @@ -4,8 +4,6 @@ import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import prisma from '@/lib/prisma'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getSessionStats'; - export async function getSessionStats(...args: [websiteId: string, filters: QueryFilters]) { return runQuery({ [PRISMA]: () => relationalQuery(...args), @@ -37,7 +35,6 @@ async function relationalQuery(websiteId: string, filters: QueryFilters) { order by 1 `, queryParams, - FUNCTION_NAME, ); } @@ -94,5 +91,5 @@ async function clickhouseQuery( `; } - return rawQuery(sql, queryParams, FUNCTION_NAME); + return rawQuery(sql, queryParams); } diff --git a/src/queries/sql/sessions/getWebsiteSession.ts b/src/queries/sql/sessions/getWebsiteSession.ts index 36c48c204..8c549ca30 100644 --- a/src/queries/sql/sessions/getWebsiteSession.ts +++ b/src/queries/sql/sessions/getWebsiteSession.ts @@ -2,8 +2,6 @@ import prisma from '@/lib/prisma'; import clickhouse from '@/lib/clickhouse'; import { runQuery, PRISMA, CLICKHOUSE } from '@/lib/db'; -const FUNCTION_NAME = 'getWebsiteSession'; - export async function getWebsiteSession(...args: [websiteId: string, sessionId: string]) { return runQuery({ [PRISMA]: () => relationalQuery(...args), @@ -58,7 +56,6 @@ async function relationalQuery(websiteId: string, sessionId: string) { group by id, distinct_id, website_id, browser, os, device, screen, language, country, region, city; `, { websiteId, sessionId }, - FUNCTION_NAME, ).then(result => result?.[0]); } @@ -108,6 +105,5 @@ async function clickhouseQuery(websiteId: string, sessionId: string) { group by id, websiteId, distinctId, browser, os, device, screen, language, country, region, city; `, { websiteId, sessionId }, - FUNCTION_NAME, ).then(result => result?.[0]); } diff --git a/src/queries/sql/sessions/getWebsiteSessionStats.ts b/src/queries/sql/sessions/getWebsiteSessionStats.ts index be90d4cd2..804a483b5 100644 --- a/src/queries/sql/sessions/getWebsiteSessionStats.ts +++ b/src/queries/sql/sessions/getWebsiteSessionStats.ts @@ -4,8 +4,6 @@ import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db'; import prisma from '@/lib/prisma'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getWebsiteSessionStats'; - export interface WebsiteSessionStatsData { pageviews: number; visitors: number; @@ -49,7 +47,6 @@ async function relationalQuery( ${filterQuery} `, queryParams, - FUNCTION_NAME, ); } @@ -92,5 +89,5 @@ async function clickhouseQuery( `; } - return rawQuery(sql, queryParams, FUNCTION_NAME); + return rawQuery(sql, queryParams); } diff --git a/src/queries/sql/sessions/getWebsiteSessions.ts b/src/queries/sql/sessions/getWebsiteSessions.ts index 44b52d8e9..2e93a9665 100644 --- a/src/queries/sql/sessions/getWebsiteSessions.ts +++ b/src/queries/sql/sessions/getWebsiteSessions.ts @@ -4,8 +4,6 @@ import { EVENT_COLUMNS } from '@/lib/constants'; import prisma from '@/lib/prisma'; import { QueryFilters } from '@/lib/types'; -const FUNCTION_NAME = 'getWebsiteSessions'; - export async function getWebsiteSessions(...args: [websiteId: string, filters: QueryFilters]) { return runQuery({ [PRISMA]: () => relationalQuery(...args), @@ -71,7 +69,6 @@ async function relationalQuery(websiteId: string, filters: QueryFilters) { `, queryParams, filters, - FUNCTION_NAME, ); } @@ -150,5 +147,5 @@ async function clickhouseQuery(websiteId: string, filters: QueryFilters) { `; } - return pagedRawQuery(sql, queryParams, filters, FUNCTION_NAME); + return pagedRawQuery(sql, queryParams, filters); }