56 lines
1.2 KiB
JavaScript
56 lines
1.2 KiB
JavaScript
import { CLICKHOUSE, RELATIONAL } from 'lib/constants';
|
|
import {
|
|
getDateFormatClickhouse,
|
|
prisma,
|
|
rawQueryClickhouse,
|
|
runAnalyticsQuery,
|
|
runQuery,
|
|
} from 'lib/db';
|
|
import { getSessionByUuid } from 'queries';
|
|
|
|
export async function createSession(...args) {
|
|
return runAnalyticsQuery({
|
|
[RELATIONAL]: () => relationalQuery(...args),
|
|
[CLICKHOUSE]: () => clickhouseQuery(...args),
|
|
});
|
|
}
|
|
|
|
async function relationalQuery(website_id, data) {
|
|
return runQuery(
|
|
prisma.session.create({
|
|
data: {
|
|
website_id,
|
|
...data,
|
|
},
|
|
select: {
|
|
session_id: true,
|
|
},
|
|
}),
|
|
);
|
|
}
|
|
|
|
async function clickhouseQuery(
|
|
website_id,
|
|
{ session_uuid, hostname, browser, os, screen, language, country, device },
|
|
) {
|
|
const params = [
|
|
session_uuid,
|
|
website_id,
|
|
hostname,
|
|
browser,
|
|
os,
|
|
device,
|
|
screen,
|
|
language,
|
|
country ? country : null,
|
|
];
|
|
|
|
await rawQueryClickhouse(
|
|
`insert into umami_dev.session (created_at, session_uuid, website_id, hostname, browser, os, device, screen, language, country)
|
|
values (${getDateFormatClickhouse(new Date())}, $1, $2, $3, $4, $5, $6, $7, $8, $9);`,
|
|
params,
|
|
);
|
|
|
|
return getSessionByUuid(session_uuid);
|
|
}
|