117 lines
4.0 KiB
TypeScript
117 lines
4.0 KiB
TypeScript
import clickhouse from '@/lib/clickhouse';
|
|
import { EVENT_TYPE } from '@/lib/constants';
|
|
import { CLICKHOUSE, PRISMA, runQuery } from '@/lib/db';
|
|
import prisma from '@/lib/prisma';
|
|
|
|
const FUNCTION_NAME = 'getWebsiteSession';
|
|
|
|
export async function getWebsiteSession(...args: [websiteId: string, sessionId: string]) {
|
|
return runQuery({
|
|
[PRISMA]: () => relationalQuery(...args),
|
|
[CLICKHOUSE]: () => clickhouseQuery(...args),
|
|
});
|
|
}
|
|
|
|
async function relationalQuery(websiteId: string, sessionId: string) {
|
|
const { rawQuery, getTimestampDiffSQL } = prisma;
|
|
|
|
return rawQuery(
|
|
`
|
|
select id,
|
|
distinct_id as "distinctId",
|
|
website_id as "websiteId",
|
|
browser,
|
|
os,
|
|
device,
|
|
screen,
|
|
language,
|
|
country,
|
|
region,
|
|
city,
|
|
min(min_time) as "firstAt",
|
|
max(max_time) as "lastAt",
|
|
count(distinct visit_id) as visits,
|
|
sum(views) as views,
|
|
sum(events) as events,
|
|
sum(${getTimestampDiffSQL('min_time', 'max_time')}) as "totaltime"
|
|
from (select
|
|
session.session_id as id,
|
|
session.distinct_id,
|
|
website_event.visit_id,
|
|
session.website_id,
|
|
session.browser,
|
|
session.os,
|
|
session.device,
|
|
session.screen,
|
|
session.language,
|
|
session.country,
|
|
session.region,
|
|
session.city,
|
|
min(website_event.created_at) as min_time,
|
|
max(website_event.created_at) as max_time,
|
|
sum(case when website_event.event_type = 1 then 1 else 0 end) as views,
|
|
sum(case when website_event.event_type = 2 then 1 else 0 end) as events
|
|
from session
|
|
join website_event on website_event.session_id = session.session_id
|
|
where session.website_id = {{websiteId::uuid}}
|
|
and session.session_id = {{sessionId::uuid}}
|
|
and website_event.event_type != ${EVENT_TYPE.performance}
|
|
group by session.session_id, session.distinct_id, visit_id, session.website_id, session.browser, session.os, session.device, session.screen, session.language, session.country, session.region, session.city) t
|
|
group by id, distinct_id, website_id, browser, os, device, screen, language, country, region, city;
|
|
`,
|
|
{ websiteId, sessionId },
|
|
FUNCTION_NAME,
|
|
).then(result => result?.[0]);
|
|
}
|
|
|
|
async function clickhouseQuery(websiteId: string, sessionId: string) {
|
|
const { rawQuery, getDateStringSQL } = clickhouse;
|
|
|
|
return rawQuery(
|
|
`
|
|
select id,
|
|
any(websiteId) as websiteId,
|
|
argMax(distinctId, max_time) as distinctId,
|
|
argMax(browser, max_time) as browser,
|
|
argMax(os, max_time) as os,
|
|
argMax(device, max_time) as device,
|
|
argMax(screen, max_time) as screen,
|
|
argMax(language, max_time) as language,
|
|
argMax(country, max_time) as country,
|
|
argMax(region, max_time) as region,
|
|
argMax(city, max_time) as city,
|
|
${getDateStringSQL('min(min_time)')} as firstAt,
|
|
${getDateStringSQL('max(max_time)')} as lastAt,
|
|
uniq(visit_id) visits,
|
|
sum(views) as views,
|
|
sum(events) as events,
|
|
sum(max_time-min_time) as totaltime
|
|
from (select
|
|
session_id as id,
|
|
distinct_id as distinctId,
|
|
visit_id,
|
|
website_id as websiteId,
|
|
browser,
|
|
os,
|
|
device,
|
|
screen,
|
|
language,
|
|
country,
|
|
region,
|
|
city,
|
|
min(min_time) as min_time,
|
|
max(max_time) as max_time,
|
|
sum(views) as views,
|
|
length(groupArrayArray(event_name)) as events
|
|
from website_event_stats_hourly
|
|
where website_id = {websiteId:UUID}
|
|
and session_id = {sessionId:UUID}
|
|
and event_type != ${EVENT_TYPE.performance}
|
|
group by session_id, distinct_id, visit_id, website_id, browser, os, device, screen, language, country, region, city) t
|
|
group by id;
|
|
`,
|
|
{ websiteId, sessionId },
|
|
FUNCTION_NAME,
|
|
).then(result => result?.[0]);
|
|
}
|