From 396acf3bbbe00a192cb0ea0a9ccf91b1d8d2850b Mon Sep 17 00:00:00 2001 From: Fuwn <50817549+Fuwn@users.noreply.github.com> Date: Sat, 24 Jan 2026 13:09:50 +0000 Subject: Initial commit Created from https://vercel.com/new --- src/queries/sql/events/getEventDataUsage.ts | 38 +++++++++++++++++++++++++++++ 1 file changed, 38 insertions(+) create mode 100644 src/queries/sql/events/getEventDataUsage.ts (limited to 'src/queries/sql/events/getEventDataUsage.ts') diff --git a/src/queries/sql/events/getEventDataUsage.ts b/src/queries/sql/events/getEventDataUsage.ts new file mode 100644 index 0000000..50613a7 --- /dev/null +++ b/src/queries/sql/events/getEventDataUsage.ts @@ -0,0 +1,38 @@ +import clickhouse from '@/lib/clickhouse'; +import { CLICKHOUSE, notImplemented, PRISMA, runQuery } from '@/lib/db'; +import type { QueryFilters } from '@/lib/types'; + +const FUNCTION_NAME = 'getEventDataUsage'; + +export function getEventDataUsage(...args: [websiteIds: string[], filters: QueryFilters]) { + return runQuery({ + [PRISMA]: notImplemented, + [CLICKHOUSE]: () => clickhouseQuery(...args), + }); +} + +function clickhouseQuery( + websiteIds: string[], + filters: QueryFilters, +): Promise<{ websiteId: string; count: number }[]> { + const { rawQuery } = clickhouse; + const { startDate, endDate } = filters; + + return rawQuery( + ` + select + website_id as websiteId, + count(*) as count + from event_data + where created_at between {startDate:DateTime64} and {endDate:DateTime64} + and website_id in {websiteIds:Array(UUID)} + group by website_id + `, + { + websiteIds, + startDate, + endDate, + }, + FUNCTION_NAME, + ); +} -- cgit v1.2.3