umami/lib/queries.js

495 lines
9.6 KiB
JavaScript
Raw Normal View History

2020-08-12 05:05:40 +02:00
import moment from 'moment-timezone';
2020-08-12 07:24:41 +02:00
import prisma, { runQuery } from 'lib/db';
2020-08-18 09:51:32 +02:00
import { subMinutes } from 'date-fns';
import { MYSQL, POSTGRESQL, MYSQL_DATE_FORMATS, POSTGRESQL_DATE_FORMATS } from 'lib/constants';
2020-08-12 05:05:40 +02:00
export function getDatabase() {
const type =
2020-08-30 09:02:03 +02:00
process.env.DATABASE_TYPE ||
(process.env.DATABASE_URL && process.env.DATABASE_URL.split(':')[0]);
if (type === 'postgres') {
return 'postgresql';
}
return type;
2020-08-12 05:05:40 +02:00
}
export function getDateQuery(db, field, unit, timezone) {
if (db === POSTGRESQL) {
if (timezone) {
return `to_char(date_trunc('${unit}', ${field} at time zone '${timezone}'), '${POSTGRESQL_DATE_FORMATS[unit]}')`;
}
return `to_char(date_trunc('${unit}', ${field}), '${POSTGRESQL_DATE_FORMATS[unit]}')`;
}
if (db === MYSQL) {
if (timezone) {
const tz = moment.tz(timezone).format('Z');
return `DATE_FORMAT(convert_tz(${field},'+00:00','${tz}'), '${MYSQL_DATE_FORMATS[unit]}')`;
}
return `DATE_FORMAT(${field}, '${MYSQL_DATE_FORMATS[unit]}')`;
}
}
2020-08-12 07:24:41 +02:00
export async function getWebsiteById(website_id) {
return runQuery(
prisma.website.findOne({
where: {
website_id,
},
}),
);
}
export async function getWebsiteByUuid(website_uuid) {
return runQuery(
prisma.website.findOne({
where: {
website_uuid,
},
}),
);
}
2020-08-15 10:17:15 +02:00
export async function getWebsiteByShareId(share_id) {
return runQuery(
prisma.website.findOne({
where: {
share_id,
},
}),
);
}
2020-08-12 07:24:41 +02:00
export async function getUserWebsites(user_id) {
return runQuery(
prisma.website.findMany({
where: {
user_id,
},
orderBy: {
name: 'asc',
},
}),
);
}
export async function createWebsite(user_id, data) {
return runQuery(
prisma.website.create({
data: {
account: {
connect: {
user_id,
},
},
...data,
},
}),
);
}
export async function updateWebsite(website_id, data) {
return runQuery(
prisma.website.update({
where: {
website_id,
},
data,
}),
);
}
export async function deleteWebsite(website_id) {
return runQuery(
/* Prisma bug, does not cascade on non-nullable foreign keys
prisma.website.delete({
where: {
website_id,
},
}),
*/
prisma.$queryRaw`delete from website where website_id=${website_id}`,
);
}
export async function createSession(website_id, data) {
return runQuery(
prisma.session.create({
data: {
website: {
connect: {
website_id,
},
},
...data,
},
select: {
session_id: true,
},
}),
);
}
export async function getSessionById(session_id) {
return runQuery(
prisma.session.findOne({
where: {
session_id,
},
}),
);
}
export async function getSessionByUuid(session_uuid) {
return runQuery(
prisma.session.findOne({
where: {
session_uuid,
},
}),
);
}
export async function savePageView(website_id, session_id, url, referrer) {
return runQuery(
prisma.pageview.create({
data: {
website: {
connect: {
website_id,
},
},
session: {
connect: {
session_id,
},
},
url,
referrer,
},
}),
);
}
export async function saveEvent(website_id, session_id, url, event_type, event_value) {
return runQuery(
prisma.event.create({
data: {
website: {
connect: {
website_id,
},
},
session: {
connect: {
session_id,
},
},
url,
event_type,
event_value,
},
}),
);
}
export async function getAccounts() {
return runQuery(prisma.account.findMany());
}
export async function getAccountById(user_id) {
return runQuery(
prisma.account.findOne({
where: {
user_id,
},
}),
);
}
export async function getAccountByUsername(username) {
return runQuery(
prisma.account.findOne({
where: {
username,
},
}),
);
}
export async function updateAccount(user_id, data) {
return runQuery(
prisma.account.update({
where: {
user_id,
},
data,
}),
);
}
export async function deleteAccount(user_id) {
return runQuery(
/* Prisma bug, does not cascade on non-nullable foreign keys
prisma.account.delete({
where: {
user_id,
},
}),
*/
prisma.$queryRaw`delete from account where user_id=${user_id}`,
);
}
export async function createAccount(data) {
return runQuery(
prisma.account.create({
data,
}),
);
}
export function getMetrics(website_id, start_at, end_at) {
2020-08-12 05:05:40 +02:00
const db = getDatabase();
if (db === POSTGRESQL) {
2020-09-03 00:14:33 +02:00
return runQuery(
prisma.$queryRaw(
`
2020-08-12 05:05:40 +02:00
select sum(t.c) as "pageviews",
count(distinct t.session_id) as "uniques",
2020-08-24 19:52:47 +02:00
sum(case when t.c = 1 then 1 else 0 end) as "bounces",
2020-08-12 05:05:40 +02:00
sum(t.time) as "totaltime"
from (
select session_id,
${getDateQuery(db, 'created_at', 'hour')},
2020-08-12 05:05:40 +02:00
count(*) c,
floor(extract(epoch from max(created_at) - min(created_at))) as "time"
from pageview
where website_id=$1
and created_at between $2 and $3
group by 1, 2
) t
`,
2020-09-03 00:14:33 +02:00
website_id,
start_at,
end_at,
),
2020-08-12 05:05:40 +02:00
);
}
if (db === MYSQL) {
2020-09-03 00:14:33 +02:00
return runQuery(
prisma.$queryRaw(
`
2020-08-12 05:05:40 +02:00
select sum(t.c) as "pageviews",
count(distinct t.session_id) as "uniques",
2020-08-24 19:52:47 +02:00
sum(case when t.c = 1 then 1 else 0 end) as "bounces",
2020-08-12 05:05:40 +02:00
sum(t.time) as "totaltime"
from (
select session_id,
${getDateQuery(db, 'created_at', 'hour')},
2020-08-12 05:05:40 +02:00
count(*) c,
floor(unix_timestamp(max(created_at)) - unix_timestamp(min(created_at))) as "time"
from pageview
where website_id=?
and created_at between ? and ?
group by 1, 2
) t
`,
2020-09-03 00:14:33 +02:00
website_id,
start_at,
end_at,
),
2020-08-12 05:05:40 +02:00
);
}
2020-09-01 06:11:53 +02:00
return Promise.reject(new Error('Unknown database.'));
2020-08-12 05:05:40 +02:00
}
2020-08-12 07:24:41 +02:00
export function getPageviews(
website_id,
start_at,
end_at,
timezone = 'utc',
unit = 'day',
count = '*',
) {
2020-08-12 05:05:40 +02:00
const db = getDatabase();
if (db === POSTGRESQL) {
2020-09-03 00:14:33 +02:00
return runQuery(
prisma.$queryRaw(
`
select ${getDateQuery(db, 'created_at', unit, timezone)} t,
count(${count}) y
2020-08-12 05:05:40 +02:00
from pageview
where website_id=$1
and created_at between $2 and $3
group by 1
order by 1
`,
2020-09-03 00:14:33 +02:00
website_id,
start_at,
end_at,
),
2020-08-12 05:05:40 +02:00
);
}
if (db === MYSQL) {
2020-09-03 00:14:33 +02:00
return runQuery(
prisma.$queryRaw(
`
select ${getDateQuery(db, 'created_at', unit, timezone)} t,
count(${count}) y
2020-08-12 05:05:40 +02:00
from pageview
where website_id=?
and created_at between ? and ?
group by 1
order by 1
`,
2020-09-03 00:14:33 +02:00
website_id,
start_at,
end_at,
),
2020-08-12 05:05:40 +02:00
);
}
2020-09-01 06:11:53 +02:00
return Promise.reject(new Error('Unknown database.'));
2020-08-12 05:05:40 +02:00
}
export function getRankings(website_id, start_at, end_at, type, table, domain) {
2020-08-12 05:05:40 +02:00
const db = getDatabase();
const filter = domain ? `and ${type} not like '%${domain}%'` : '';
2020-08-12 05:05:40 +02:00
if (db === POSTGRESQL) {
2020-09-03 00:14:33 +02:00
return runQuery(
prisma.$queryRaw(
`
2020-08-12 05:05:40 +02:00
select distinct ${type} x, count(*) y
from ${table}
where website_id=$1
and created_at between $2 and $3
${filter}
2020-08-12 05:05:40 +02:00
group by 1
order by 2 desc
`,
2020-09-03 00:14:33 +02:00
website_id,
start_at,
end_at,
),
2020-08-12 05:05:40 +02:00
);
}
if (db === MYSQL) {
2020-09-03 00:14:33 +02:00
return runQuery(
prisma.$queryRaw(
`
2020-08-12 05:05:40 +02:00
select distinct ${type} x, count(*) y
from ${table}
where website_id=?
and created_at between ? and ?
${filter}
2020-08-12 05:05:40 +02:00
group by 1
order by 2 desc
`,
2020-09-03 00:14:33 +02:00
website_id,
start_at,
end_at,
),
2020-08-12 05:05:40 +02:00
);
}
2020-09-01 06:11:53 +02:00
return Promise.reject(new Error('Unknown database.'));
2020-08-12 05:05:40 +02:00
}
2020-08-18 09:51:32 +02:00
export function getActiveVisitors(website_id) {
2020-08-19 03:33:59 +02:00
const db = getDatabase();
const date = subMinutes(new Date(), 5);
if (db === POSTGRESQL) {
2020-09-03 00:14:33 +02:00
return runQuery(
prisma.$queryRaw(
`
2020-08-18 09:51:32 +02:00
select count(distinct session_id) x
from pageview
where website_id=$1
and created_at >= $2
`,
2020-09-03 00:14:33 +02:00
website_id,
date,
),
2020-08-19 03:33:59 +02:00
);
}
if (db === MYSQL) {
2020-09-03 00:14:33 +02:00
return runQuery(
prisma.$queryRaw(
`
2020-08-19 03:33:59 +02:00
select count(distinct session_id) x
from pageview
where website_id=?
and created_at >= ?
`,
2020-09-03 00:14:33 +02:00
website_id,
date,
),
2020-08-19 03:33:59 +02:00
);
}
2020-09-01 06:11:53 +02:00
return Promise.reject(new Error('Unknown database.'));
2020-08-18 09:51:32 +02:00
}
2020-08-25 08:49:14 +02:00
2020-08-27 12:42:24 +02:00
export function getEvents(website_id, start_at, end_at, timezone = 'utc', unit = 'day') {
const db = getDatabase();
if (db === POSTGRESQL) {
2020-09-03 00:14:33 +02:00
return runQuery(
prisma.$queryRaw(
`
2020-08-27 12:42:24 +02:00
select
event_value x,
${getDateQuery(db, 'created_at', unit, timezone)} t,
2020-08-27 12:42:24 +02:00
count(*) y
from event
where website_id=$1
and created_at between $2 and $3
group by 1, 2
order by 2
`,
2020-09-03 00:14:33 +02:00
website_id,
start_at,
end_at,
),
2020-08-27 12:42:24 +02:00
);
}
if (db === MYSQL) {
2020-09-03 00:14:33 +02:00
return runQuery(
prisma.$queryRaw(
`
2020-08-27 12:42:24 +02:00
select
event_value x,
${getDateQuery(db, 'created_at', unit, timezone)} t,
2020-08-27 12:42:24 +02:00
count(*) y
from event
where website_id=?
and created_at between ? and ?
group by 1, 2
order by 2
`,
2020-09-03 00:14:33 +02:00
website_id,
start_at,
end_at,
),
2020-08-27 12:42:24 +02:00
);
}
2020-09-01 06:11:53 +02:00
return Promise.reject(new Error('Unknown database.'));
2020-08-27 12:42:24 +02:00
}