m/umami
1
0
Fork 0
mirror of https://github.com/kremalicious/umami.git synced 2024-06-30 13:41:50 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'dev' of https://github.com/mikecao/umami into dev

Browse Source
This commit is contained in:
Mike Cao 2022-07-13 08:21:36 -07:00
commit 9b3105cefd
52 changed files with 612 additions and 502 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
lang/da-DK.json
View File

@ -4,9 +4,9 @@
"label.add-website": "Tilføj hjemmeside",
"label.administrator": "Administrator",
"label.all": "Alle",
"label.all-events": "All events",
"label.all-time": "All time",
"label.all-websites": "Alle websites",
"label.all-events": "Alle hændelser",
"label.all-time": "Altid",
"label.all-websites": "Alle hjemmesider",
"label.back": "Tilbage",
"label.cancel": "Afvis",
"label.change-password": "Skift adgangskode",
@ -28,30 +28,30 @@
"label.enable-share-url": "Aktivér delings-URL",
"label.invalid": "Ugyldig",
"label.invalid-domain": "Ugyldigt domæne",
"label.language": "Language",
"label.language": "Sprog",
"label.last-days": "Sidste {x} dage",
"label.last-hours": "Sidste {x} timer",
"label.logged-in-as": "Loggede ind som {username}",
"label.logged-in-as": "Logget ind som {username}",
"label.login": "Log ind",
"label.logout": "Log ud",
"label.more": "Mere",
"label.name": "Navn",
"label.new-password": "Ny adgangskode",
"label.owner": "Owner",
"label.owner": "Ejer",
"label.password": "Adgangskode",
"label.passwords-dont-match": "Adgangskoder matcher ikke",
"label.passwords-dont-match": "Adgangskoderne matcher ikke",
"label.profile": "Profil",
"label.realtime": "Realtid",
"label.realtime-logs": "Realtid logs",
"label.refresh": "Opdater",
"label.required": "Påkrævet",
"label.reset": "Reset",
"label.reset-website": "Reset statistics",
"label.reset": "Nulstil",
"label.reset-website": "Nulstil statistikker",
"label.save": "Gem",
"label.settings": "Indstillinger",
"label.share-url": "Del URL",
"label.single-day": "Enkelt dag",
"label.theme": "Theme",
"label.theme": "Tema",
"label.this-month": "Denne måned",
"label.this-week": "Denne uge",
"label.this-year": "Dette år",
@ -64,7 +64,7 @@
"label.websites": "Hjemmesider",
"message.active-users": "{x} nuværende {x, plural, one {bruger} other {brugere}}",
"message.confirm-delete": "Er du sikker på at du vil slette {target}?",
"message.confirm-reset": "Are your sure you want to reset {target}'s statistics?",
"message.confirm-reset": "Er du sikker på at du ville nulstille {target}'s statistikker?",
"message.copied": "Kopieret!",
"message.delete-warning": "Alle tilknyttede data slettes også.",
"message.failure": "Noget gik galt.",
@ -75,14 +75,14 @@
"message.log.visitor": "Besøgende fra {country} bruger {browser} på {os} {device}",
"message.new-version-available": "Ny udgave af Umami {version} er tilgængelig!",
"message.no-data-available": "Ingen data tilgængelig.",
"message.no-websites-configured": "Du har ikke konfigureret nogen websteder.",
"message.no-websites-configured": "Du har ikke konfigureret nogen hjemmesider.",
"message.page-not-found": "Side ikke fundet.",
"message.powered-by": "Drevet af {name}",
"message.reset-warning": "All statistics for this website will be deleted, but your tracking code will remain intact.",
"message.reset-warning": "Alle statistikker for denne hjemmeside ville blive slettet, men sporingskode ville forblive intakt.",
"message.save-success": "Gemt!",
"message.share-url": "Dette er den offentligt delings-URL til {target}.",
"message.toggle-charts": "Toggle charts",
"message.track-stats": "For at spore statistik for {target} skal du placere følgende kode i {head} sektionen på dit websted.",
"message.share-url": "Dette er den offentlige delings-URL til {target}.",
"message.toggle-charts": "Ændre graf",
"message.track-stats": "For at spore statistik for {target} skal du placere følgende kode i {head} sektionen på din hjemmeside.",
"message.type-delete": "Skriv {delete} i boksen nedenfor, for at bekræfte.",
"message.type-reset": "Skriv {reset} i boksen nedenfor, for at bekræfte.",
"metrics.actions": "Handlinger",
@ -99,7 +99,7 @@
"metrics.filter.combined": "Kombineret",
"metrics.filter.domain-only": "Kun domæne",
"metrics.filter.raw": "Rå",
"metrics.languages": "Languages",
"metrics.languages": "Sprog",
"metrics.operating-systems": "Operativsystemer",
"metrics.page-views": "Sidevisninger",
"metrics.pages": "Sider",

2
lib/auth.js
View File

@ -1,6 +1,6 @@
import { parseSecureToken, parseToken } from './crypto';
import { SHARE_TOKEN_HEADER } from './constants';
import { getWebsiteById } from './queries';
import { getWebsiteById } from 'queries';
export async function getAuthToken(req) {
try {

467
lib/queries.js
View File

@ -1,13 +1,6 @@
import moment from 'moment-timezone';
import { MYSQL, MYSQL_DATE_FORMATS, POSTGRESQL, POSTGRESQL_DATE_FORMATS } from 'lib/constants';
import prisma from 'lib/db';
import { subMinutes } from 'date-fns';
import {
MYSQL,
POSTGRESQL,
MYSQL_DATE_FORMATS,
POSTGRESQL_DATE_FORMATS,
URL_LENGTH,
} from 'lib/constants';
import moment from 'moment-timezone';
export function getDatabase() {
const type =
@ -160,459 +153,3 @@ export async function rawQuery(query, params = []) {
return runQuery(prisma.$queryRawUnsafe.apply(prisma, [sql, ...params]));
}
export async function getWebsiteById(website_id) {
return runQuery(
prisma.website.findUnique({
where: {
website_id,
},
}),
);
}
export async function getWebsiteByUuid(website_uuid) {
return runQuery(
prisma.website.findUnique({
where: {
website_uuid,
},
}),
);
}
export async function getWebsiteByShareId(share_id) {
return runQuery(
prisma.website.findUnique({
where: {
share_id,
},
}),
);
}
export async function getUserWebsites(user_id) {
return runQuery(
prisma.website.findMany({
where: {
user_id,
},
orderBy: {
name: 'asc',
},
}),
);
}
export async function getAllWebsites() {
let data = await runQuery(
prisma.website.findMany({
orderBy: [
{
user_id: 'asc',
},
{
name: 'asc',
},
],
include: {
account: {
select: {
username: true,
},
},
},
}),
);
return data.map(i => ({ ...i, account: i.account.username }));
}
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 resetWebsite(website_id) {
return runQuery(prisma.$queryRaw`delete from session where website_id=${website_id}`);
}
export async function deleteWebsite(website_id) {
return runQuery(
prisma.website.delete({
where: {
website_id,
},
}),
);
}
export async function createSession(website_id, data) {
return runQuery(
prisma.session.create({
data: {
website_id,
...data,
},
select: {
session_id: true,
},
}),
);
}
export async function getSessionByUuid(session_uuid) {
return runQuery(
prisma.session.findUnique({
where: {
session_uuid,
},
}),
);
}
export async function savePageView(website_id, session_id, url, referrer) {
return runQuery(
prisma.pageview.create({
data: {
website_id,
session_id,
url: url?.substr(0, URL_LENGTH),
referrer: referrer?.substr(0, URL_LENGTH),
},
}),
);
}
export async function saveEvent(website_id, session_id, url, event_type, event_value) {
return runQuery(
prisma.event.create({
data: {
website_id,
session_id,
url: url?.substr(0, URL_LENGTH),
event_type: event_type?.substr(0, 50),
event_value: event_value?.substr(0, 50),
},
}),
);
}
export async function getAccounts() {
return runQuery(
prisma.account.findMany({
orderBy: [
{ is_admin: 'desc' },
{
username: 'asc',
},
],
select: {
user_id: true,
username: true,
is_admin: true,
created_at: true,
updated_at: true,
},
}),
);
}
export async function getAccountById(user_id) {
return runQuery(
prisma.account.findUnique({
where: {
user_id,
},
}),
);
}
export async function getAccountByUsername(username) {
return runQuery(
prisma.account.findUnique({
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.account.delete({
where: {
user_id,
},
}),
);
}
export async function createAccount(data) {
return runQuery(
prisma.account.create({
data,
}),
);
}
export async function getSessions(websites, start_at) {
return runQuery(
prisma.session.findMany({
where: {
website: {
website_id: {
in: websites,
},
},
created_at: {
gte: start_at,
},
},
}),
);
}
export async function getPageviews(websites, start_at) {
return runQuery(
prisma.pageview.findMany({
where: {
website: {
website_id: {
in: websites,
},
},
created_at: {
gte: start_at,
},
},
}),
);
}
export async function getEvents(websites, start_at) {
return runQuery(
prisma.event.findMany({
where: {
website: {
website_id: {
in: websites,
},
},
created_at: {
gte: start_at,
},
},
}),
);
}
export function getWebsiteStats(website_id, start_at, end_at, filters = {}) {
const params = [website_id, start_at, end_at];
const { pageviewQuery, sessionQuery, joinSession } = parseFilters('pageview', filters, params);
return rawQuery(
`
select sum(t.c) as "pageviews",
count(distinct t.session_id) as "uniques",
sum(case when t.c = 1 then 1 else 0 end) as "bounces",
sum(t.time) as "totaltime"
from (
select pageview.session_id,
${getDateQuery('pageview.created_at', 'hour', false, 'date')},
count(*) c,
${getTimestampInterval('pageview.created_at')} as "time"
from pageview
${joinSession}
where pageview.website_id=$1
and pageview.created_at between $2 and $3
${pageviewQuery}
${sessionQuery}
group by 1, 2
) t
`,
params,
);
}
export function getPageviewStats(
website_id,
start_at,
end_at,
timezone = 'utc',
unit = 'day',
count = '*',
filters = {},
) {
const params = [website_id, start_at, end_at];
const { pageviewQuery, sessionQuery, joinSession } = parseFilters('pageview', filters, params);
return rawQuery(
`
select
${getDateStringQuery('g.t', unit)} as t,
g.y as y
from
(select ${getDateQuery('pageview.created_at', unit, timezone)} t,
count(${count}) y
from pageview
${joinSession}
where pageview.website_id=$1
and pageview.created_at between $2 and $3
${pageviewQuery}
${sessionQuery}
group by 1) g
order by 1
`,
params,
);
}
export function getSessionMetrics(website_id, start_at, end_at, field, filters = {}) {
const params = [website_id, start_at, end_at];
const { pageviewQuery, sessionQuery, joinSession } = parseFilters('pageview', filters, params);
return rawQuery(
`
select ${field} x, count(*) y
from session as x
where x.session_id in (
select pageview.session_id
from pageview
${joinSession}
where pageview.website_id=$1
and pageview.created_at between $2 and $3
${pageviewQuery}
${sessionQuery}
)
group by 1
order by 2 desc
`,
params,
);
}
export function getPageviewMetrics(website_id, start_at, end_at, field, table, filters = {}) {
const params = [website_id, start_at, end_at];
const { pageviewQuery, sessionQuery, eventQuery, joinSession } = parseFilters(
table,
filters,
params,
);
return rawQuery(
`
select ${field} x, count(*) y
from ${table}
${joinSession}
where ${table}.website_id=$1
and ${table}.created_at between $2 and $3
${pageviewQuery}
${joinSession && sessionQuery}
${eventQuery}
group by 1
order by 2 desc
`,
params,
);
}
export function getActiveVisitors(website_id) {
const date = subMinutes(new Date(), 5);
const params = [website_id, date];
return rawQuery(
`
select count(distinct session_id) x
from pageview
where website_id=$1
and created_at >= $2
`,
params,
);
}
export function getEventMetrics(
website_id,
start_at,
end_at,
timezone = 'utc',
unit = 'day',
filters = {},
) {
const params = [website_id, start_at, end_at];
return rawQuery(
`
select
event_value x,
${getDateStringQuery(getDateQuery('created_at', unit, timezone), unit)} t,
count(*) y
from event
where website_id=$1
and created_at between $2 and $3
${getFilterQuery('event', filters, params)}
group by 1, 2
order by 2
`,
params,
);
}
export async function getRealtimeData(websites, time) {
const [pageviews, sessions, events] = await Promise.all([
getPageviews(websites, time),
getSessions(websites, time),
getEvents(websites, time),
]);
return {
pageviews: pageviews.map(({ view_id, ...props }) => ({
__id: `p${view_id}`,
view_id,
...props,
})),
sessions: sessions.map(({ session_id, ...props }) => ({
__id: `s${session_id}`,
session_id,
...props,
})),
events: events.map(({ event_id, ...props }) => ({
__id: `e${event_id}`,
event_id,
...props,
})),
timestamp: Date.now(),
};
}

2
lib/session.js
View File

@ -1,4 +1,4 @@
import { getWebsiteByUuid, getSessionByUuid, createSession } from 'lib/queries';
import { getWebsiteByUuid, getSessionByUuid, createSession } from 'queries';
import { getJsonBody, getClientInfo } from 'lib/request';
import { uuid, isValidUuid, parseToken } from 'lib/crypto';

2
pages/api/account/[id].js
View File

@ -1,4 +1,4 @@
import { getAccountById, deleteAccount } from 'lib/queries';
import { getAccountById, deleteAccount } from 'queries';
import { useAuth } from 'lib/middleware';
import { methodNotAllowed, ok, unauthorized } from 'lib/response';

2
pages/api/account/index.js
View File

@ -1,4 +1,4 @@
import { getAccountById, getAccountByUsername, updateAccount, createAccount } from 'lib/queries';
import { getAccountById, getAccountByUsername, updateAccount, createAccount } from 'queries';
import { useAuth } from 'lib/middleware';
import { hashPassword } from 'lib/crypto';
import { ok, unauthorized, methodNotAllowed, badRequest } from 'lib/response';

2
pages/api/account/password.js
View File

@ -1,4 +1,4 @@
import { getAccountById, updateAccount } from 'lib/queries';
import { getAccountById, updateAccount } from 'queries';
import { useAuth } from 'lib/middleware';
import { badRequest, methodNotAllowed, ok, unauthorized } from 'lib/response';
import { checkPassword, hashPassword } from 'lib/crypto';

2
pages/api/accounts/index.js
View File

@ -1,4 +1,4 @@
import { getAccounts } from 'lib/queries';
import { getAccounts } from 'queries';
import { useAuth } from 'lib/middleware';
import { ok, unauthorized, methodNotAllowed } from 'lib/response';

2
pages/api/auth/login.js
View File

@ -1,5 +1,5 @@
import { checkPassword, createSecureToken } from 'lib/crypto';
import { getAccountByUsername } from 'lib/queries';
import { getAccountByUsername } from 'queries/admin/account/getAccountByUsername';
import { ok, unauthorized, badRequest } from 'lib/response';
export default async (req, res) => {

2
pages/api/collect.js
View File

@ -1,7 +1,7 @@
const { Resolver } = require('dns').promises;
import isbot from 'isbot';
import ipaddr from 'ipaddr.js';
import { savePageView, saveEvent } from 'lib/queries';
import { savePageView, saveEvent } from 'queries';
import { useCors, useSession } from 'lib/middleware';
import { getJsonBody, getIpAddress } from 'lib/request';
import { ok, send, badRequest, forbidden } from 'lib/response';

2
pages/api/realtime/init.js
View File

@ -1,7 +1,7 @@
import { subMinutes } from 'date-fns';
import { useAuth } from 'lib/middleware';
import { ok, methodNotAllowed } from 'lib/response';
import { getUserWebsites, getRealtimeData } from 'lib/queries';
import { getUserWebsites, getRealtimeData } from 'queries';
import { createToken } from 'lib/crypto';
export default async (req, res) => {

2
pages/api/realtime/update.js
View File

@ -1,6 +1,6 @@
import { useAuth } from 'lib/middleware';
import { ok, methodNotAllowed, badRequest } from 'lib/response';
import { getRealtimeData } from 'lib/queries';
import { getRealtimeData } from 'queries';
import { parseToken } from 'lib/crypto';
import { SHARE_TOKEN_HEADER } from 'lib/constants';

2
pages/api/share/[id].js
View File

@ -1,4 +1,4 @@
import { getWebsiteByShareId } from 'lib/queries';
import { getWebsiteByShareId } from 'queries';
import { ok, notFound, methodNotAllowed } from 'lib/response';
import { createToken } from 'lib/crypto';

2
pages/api/website/[id]/active.js
View File

@ -1,7 +1,7 @@
import { getActiveVisitors } from 'lib/queries';
import { methodNotAllowed, ok, unauthorized } from 'lib/response';
import { allowQuery } from 'lib/auth';
import { useCors } from 'lib/middleware';
import { getActiveVisitors } from 'queries';
export default async (req, res) => {
if (req.method === 'GET') {

2
pages/api/website/[id]/events.js
View File

@ -1,5 +1,5 @@
import moment from 'moment-timezone';
import { getEventMetrics } from 'lib/queries';
import { getEventMetrics } from 'queries';
import { ok, badRequest, methodNotAllowed, unauthorized } from 'lib/response';
import { allowQuery } from 'lib/auth';
import { useCors } from 'lib/middleware';

2
pages/api/website/[id]/index.js
View File

@ -1,4 +1,4 @@
import { deleteWebsite, getWebsiteById } from 'lib/queries';
import { deleteWebsite, getWebsiteById } from 'queries';
import { methodNotAllowed, ok, unauthorized } from 'lib/response';
import { allowQuery } from 'lib/auth';
import { useCors } from 'lib/middleware';

2
pages/api/website/[id]/metrics.js
View File

@ -1,4 +1,4 @@
import { getPageviewMetrics, getSessionMetrics, getWebsiteById } from 'lib/queries';
import { getPageviewMetrics, getSessionMetrics, getWebsiteById } from 'queries';
import { ok, methodNotAllowed, unauthorized, badRequest } from 'lib/response';
import { allowQuery } from 'lib/auth';
import { useCors } from 'lib/middleware';

2
pages/api/website/[id]/pageviews.js
View File

@ -1,5 +1,5 @@
import moment from 'moment-timezone';
import { getPageviewStats } from 'lib/queries';
import { getPageviewStats } from 'queries';
import { ok, badRequest, methodNotAllowed, unauthorized } from 'lib/response';
import { allowQuery } from 'lib/auth';
import { useCors } from 'lib/middleware';

2
pages/api/website/[id]/reset.js
View File

@ -1,4 +1,4 @@
import { resetWebsite } from 'lib/queries';
import { resetWebsite } from 'queries';
import { methodNotAllowed, ok, unauthorized } from 'lib/response';
import { allowQuery } from 'lib/auth';

2
pages/api/website/[id]/stats.js
View File

@ -1,4 +1,4 @@
import { getWebsiteStats } from 'lib/queries';
import { getWebsiteStats } from 'queries';
import { methodNotAllowed, ok, unauthorized } from 'lib/response';
import { allowQuery } from 'lib/auth';
import { useCors } from 'lib/middleware';

2
pages/api/website/index.js
View File

@ -1,4 +1,4 @@
import { updateWebsite, createWebsite, getWebsiteById } from 'lib/queries';
import { updateWebsite, createWebsite, getWebsiteById } from 'queries';
import { useAuth } from 'lib/middleware';
import { uuid, getRandomChars } from 'lib/crypto';
import { ok, unauthorized, methodNotAllowed } from 'lib/response';

2
pages/api/websites/index.js
View File

@ -1,4 +1,4 @@
import { getAllWebsites, getUserWebsites } from 'lib/queries';
import { getAllWebsites, getUserWebsites } from 'queries';
import { useAuth } from 'lib/middleware';
import { ok, methodNotAllowed, unauthorized } from 'lib/response';

10
queries/admin/account/createAccount.js Normal file
View File

@ -0,0 +1,10 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function createAccount(data) {
return runQuery(
prisma.account.create({
data,
}),
);
}

12
queries/admin/account/deleteAccount.js Normal file
View File

@ -0,0 +1,12 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function deleteAccount(user_id) {
return runQuery(
prisma.account.delete({
where: {
user_id,
},
}),
);
}

12
queries/admin/account/getAccountById.js Normal file
View File

@ -0,0 +1,12 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function getAccountById(user_id) {
return runQuery(
prisma.account.findUnique({
where: {
user_id,
},
}),
);
}

12
queries/admin/account/getAccountByUsername.js Normal file
View File

@ -0,0 +1,12 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function getAccountByUsername(username) {
return runQuery(
prisma.account.findUnique({
where: {
username,
},
}),
);
}

22
queries/admin/account/getAccounts.js Normal file
View File

@ -0,0 +1,22 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function getAccounts() {
return runQuery(
prisma.account.findMany({
orderBy: [
{ is_admin: 'desc' },
{
username: 'asc',
},
],
select: {
user_id: true,
username: true,
is_admin: true,
created_at: true,
updated_at: true,
},
}),
);
}

13
queries/admin/account/updateAccount.js Normal file
View File

@ -0,0 +1,13 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function updateAccount(user_id, data) {
return runQuery(
prisma.account.update({
where: {
user_id,
},
data,
}),
);
}

17
queries/admin/website/createWebsite.js Normal file
View File

@ -0,0 +1,17 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function createWebsite(user_id, data) {
return runQuery(
prisma.website.create({
data: {
account: {
connect: {
user_id,
},
},
...data,
},
}),
);
}

12
queries/admin/website/deleteWebsite.js Normal file
View File

@ -0,0 +1,12 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function deleteWebsite(website_id) {
return runQuery(
prisma.website.delete({
where: {
website_id,
},
}),
);
}

25
queries/admin/website/getAllWebsites.js Normal file
View File

@ -0,0 +1,25 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function getAllWebsites() {
let data = await runQuery(
prisma.website.findMany({
orderBy: [
{
user_id: 'asc',
},
{
name: 'asc',
},
],
include: {
account: {
select: {
username: true,
},
},
},
}),
);
return data.map(i => ({ ...i, account: i.account.username }));
}

15
queries/admin/website/getUserWebsites.js Normal file
View File

@ -0,0 +1,15 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function getUserWebsites(user_id) {
return runQuery(
prisma.website.findMany({
where: {
user_id,
},
orderBy: {
name: 'asc',
},
}),
);
}

12
queries/admin/website/getWebsiteById.js Normal file
View File

@ -0,0 +1,12 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function getWebsiteById(website_id) {
return runQuery(
prisma.website.findUnique({
where: {
website_id,
},
}),
);
}

12
queries/admin/website/getWebsiteByShareId.js Normal file
View File

@ -0,0 +1,12 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function getWebsiteByShareId(share_id) {
return runQuery(
prisma.website.findUnique({
where: {
share_id,
},
}),
);
}

12
queries/admin/website/getWebsiteByUuid.js Normal file
View File

@ -0,0 +1,12 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function getWebsiteByUuid(website_uuid) {
return runQuery(
prisma.website.findUnique({
where: {
website_uuid,
},
}),
);
}

6
queries/admin/website/resetWebsite.js Normal file
View File

@ -0,0 +1,6 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function resetWebsite(website_id) {
return runQuery(prisma.$queryRaw`delete from session where website_id=${website_id}`);
}

13
queries/admin/website/updateWebsite.js Normal file
View File

@ -0,0 +1,13 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function updateWebsite(website_id, data) {
return runQuery(
prisma.website.update({
where: {
website_id,
},
data,
}),
);
}

28
queries/analytics/event/getEventMetrics.js Normal file
View File

@ -0,0 +1,28 @@
import { getDateQuery, getDateStringQuery, getFilterQuery, rawQuery } from 'lib/queries';
export function getEventMetrics(
website_id,
start_at,
end_at,
timezone = 'utc',
unit = 'day',
filters = {},
) {
const params = [website_id, start_at, end_at];
return rawQuery(
`
select
event_value x,
${getDateStringQuery(getDateQuery('created_at', unit, timezone), unit)} t,
count(*) y
from event
where website_id=$1
and created_at between $2 and $3
${getFilterQuery('event', filters, params)}
group by 1, 2
order by 2
`,
params,
);
}

19
queries/analytics/event/getEvents.js Normal file
View File

@ -0,0 +1,19 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function getEvents(websites, start_at) {
return runQuery(
prisma.event.findMany({
where: {
website: {
website_id: {
in: websites,
},
},
created_at: {
gte: start_at,
},
},
}),
);
}

17
queries/analytics/event/saveEvent.js Normal file
View File

@ -0,0 +1,17 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
import { URL_LENGTH } from 'lib/constants';
export async function saveEvent(website_id, session_id, url, event_type, event_value) {
return runQuery(
prisma.event.create({
data: {
website_id,
session_id,
url: url?.substr(0, URL_LENGTH),
event_type: event_type?.substr(0, 50),
event_value: event_value?.substr(0, 50),
},
}),
);
}

26
queries/analytics/pageview/getPageviewMetrics.js Normal file
View File

@ -0,0 +1,26 @@
import { parseFilters, rawQuery } from 'lib/queries';
export function getPageviewMetrics(website_id, start_at, end_at, field, table, filters = {}) {
const params = [website_id, start_at, end_at];
const { pageviewQuery, sessionQuery, eventQuery, joinSession } = parseFilters(
table,
filters,
params,
);
return rawQuery(
`
select ${field} x, count(*) y
from ${table}
${joinSession}
where ${table}.website_id=$1
and ${table}.created_at between $2 and $3
${pageviewQuery}
${joinSession && sessionQuery}
${eventQuery}
group by 1
order by 2 desc
`,
params,
);
}

34
queries/analytics/pageview/getPageviewStats.js Normal file
View File

@ -0,0 +1,34 @@
import { parseFilters, rawQuery, getDateQuery, getDateStringQuery } from 'lib/queries';
export function getPageviewStats(
website_id,
start_at,
end_at,
timezone = 'utc',
unit = 'day',
count = '*',
filters = {},
) {
const params = [website_id, start_at, end_at];
const { pageviewQuery, sessionQuery, joinSession } = parseFilters('pageview', filters, params);
return rawQuery(
`
select
${getDateStringQuery('g.t', unit)} as t,
g.y as y
from
(select ${getDateQuery('pageview.created_at', unit, timezone)} t,
count(${count}) y
from pageview
${joinSession}
where pageview.website_id=$1
and pageview.created_at between $2 and $3
${pageviewQuery}
${sessionQuery}
group by 1) g
order by 1
`,
params,
);
}

19
queries/analytics/pageview/getPageviews.js Normal file
View File

@ -0,0 +1,19 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function getPageviews(websites, start_at) {
return runQuery(
prisma.pageview.findMany({
where: {
website: {
website_id: {
in: websites,
},
},
created_at: {
gte: start_at,
},
},
}),
);
}

16
queries/analytics/pageview/savePageView.js Normal file
View File

@ -0,0 +1,16 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
import { URL_LENGTH } from 'lib/constants';
export async function savePageView(website_id, session_id, url, referrer) {
return runQuery(
prisma.pageview.create({
data: {
website_id,
session_id,
url: url?.substr(0, URL_LENGTH),
referrer: referrer?.substr(0, URL_LENGTH),
},
}),
);
}

16
queries/analytics/session/createSession.js Normal file
View File

@ -0,0 +1,16 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function createSession(website_id, data) {
return runQuery(
prisma.session.create({
data: {
website_id,
...data,
},
select: {
session_id: true,
},
}),
);
}

12
queries/analytics/session/getSessionByUuid.js Normal file
View File

@ -0,0 +1,12 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function getSessionByUuid(session_uuid) {
return runQuery(
prisma.session.findUnique({
where: {
session_uuid,
},
}),
);
}

25
queries/analytics/session/getSessionMetrics.js Normal file
View File

@ -0,0 +1,25 @@
import { parseFilters, rawQuery } from 'lib/queries';
export function getSessionMetrics(website_id, start_at, end_at, field, filters = {}) {
const params = [website_id, start_at, end_at];
const { pageviewQuery, sessionQuery, joinSession } = parseFilters('pageview', filters, params);
return rawQuery(
`
select ${field} x, count(*) y
from session as x
where x.session_id in (
select pageview.session_id
from pageview
${joinSession}
where pageview.website_id=$1
and pageview.created_at between $2 and $3
${pageviewQuery}
${sessionQuery}
)
group by 1
order by 2 desc
`,
params,
);
}

19
queries/analytics/session/getSessions.js Normal file
View File

@ -0,0 +1,19 @@
import { runQuery } from 'lib/queries';
import prisma from 'lib/db';
export async function getSessions(websites, start_at) {
return runQuery(
prisma.session.findMany({
where: {
website: {
website_id: {
in: websites,
},
},
created_at: {
gte: start_at,
},
},
}),
);
}

17
queries/analytics/stats/getActiveVisitors.js Normal file
View File

@ -0,0 +1,17 @@
import { rawQuery } from 'lib/queries';
import { subMinutes } from 'date-fns';
export function getActiveVisitors(website_id) {
const date = subMinutes(new Date(), 5);
const params = [website_id, date];
return rawQuery(
`
select count(distinct session_id) x
from pageview
where website_id=$1
and created_at >= $2
`,
params,
);
}

30
queries/analytics/stats/getRealtimeData.js Normal file
View File

@ -0,0 +1,30 @@
import { getPageviews } from '../pageview/getPageviews';
import { getSessions } from '../session/getSessions';
import { getEvents } from '../event/getEvents';
export async function getRealtimeData(websites, time) {
const [pageviews, sessions, events] = await Promise.all([
getPageviews(websites, time),
getSessions(websites, time),
getEvents(websites, time),
]);
return {
pageviews: pageviews.map(({ view_id, ...props }) => ({
__id: `p${view_id}`,
view_id,
...props,
})),
sessions: sessions.map(({ session_id, ...props }) => ({
__id: `s${session_id}`,
session_id,
...props,
})),
events: events.map(({ event_id, ...props }) => ({
__id: `e${event_id}`,
event_id,
...props,
})),
timestamp: Date.now(),
};
}

29
queries/analytics/stats/getWebsiteStats.js Normal file
View File

@ -0,0 +1,29 @@
import { parseFilters, rawQuery, getDateQuery, getTimestampInterval } from 'lib/queries';
export function getWebsiteStats(website_id, start_at, end_at, filters = {}) {
const params = [website_id, start_at, end_at];
const { pageviewQuery, sessionQuery, joinSession } = parseFilters('pageview', filters, params);
return rawQuery(
`
select sum(t.c) as "pageviews",
count(distinct t.session_id) as "uniques",
sum(case when t.c = 1 then 1 else 0 end) as "bounces",
sum(t.time) as "totaltime"
from (
select pageview.session_id,
${getDateQuery('pageview.created_at', 'hour')},
count(*) c,
${getTimestampInterval('pageview.created_at')} as "time"
from pageview
${joinSession}
where pageview.website_id=$1
and pageview.created_at between $2 and $3
${pageviewQuery}
${sessionQuery}
group by 1, 2
) t
`,
params,
);
}

61
queries/index.js Normal file
View File

@ -0,0 +1,61 @@
import { createAccount } from './admin/account/createAccount';
import { deleteAccount } from './admin/account/deleteAccount';
import { getAccountById } from './admin/account/getAccountById';
import { getAccountByUsername } from './admin/account/getAccountByUsername';
import { getAccounts } from './admin/account/getAccounts';
import { updateAccount } from './admin/account/updateAccount';
import { createWebsite } from './admin/website/createWebsite';
import { deleteWebsite } from './admin/website/deleteWebsite';
import { getAllWebsites } from './admin/website/getAllWebsites';
import { getUserWebsites } from './admin/website/getUserWebsites';
import { getWebsiteById } from './admin/website/getWebsiteById';
import { getWebsiteByShareId } from './admin/website/getWebsiteByShareId';
import { getWebsiteByUuid } from './admin/website/getWebsiteByUuid';
import { resetWebsite } from './admin/website/resetWebsite';
import { updateWebsite } from './admin/website/updateWebsite';
import { getEventMetrics } from './analytics/event/getEventMetrics';
import { getEvents } from './analytics/event/getEvents';
import { saveEvent } from './analytics/event/saveEvent';
import { getPageviewMetrics } from './analytics/pageview/getPageviewMetrics';
import { getPageviews } from './analytics/pageview/getPageviews';
import { getPageviewStats } from './analytics/pageview/getPageviewStats';
import { savePageView } from './analytics/pageview/savePageView';
import { createSession } from './analytics/session/createSession';
import { getSessionByUuid } from './analytics/session/getSessionByUuid';
import { getSessionMetrics } from './analytics/session/getSessionMetrics';
import { getSessions } from './analytics/session/getSessions';
import { getActiveVisitors } from './analytics/stats/getActiveVisitors';
import { getRealtimeData } from './analytics/stats/getRealtimeData';
import { getWebsiteStats } from './analytics/stats/getWebsiteStats';
export {
createWebsite,
deleteWebsite,
getAllWebsites,
getUserWebsites,
getWebsiteById,
getWebsiteByShareId,
getWebsiteByUuid,
resetWebsite,
updateWebsite,
createAccount,
deleteAccount,
getAccountById,
getAccountByUsername,
getAccounts,
updateAccount,
getEventMetrics,
getEvents,
saveEvent,
getPageviewMetrics,
getPageviews,
getPageviewStats,
savePageView,
createSession,
getSessionByUuid,
getSessionMetrics,
getSessions,
getActiveVisitors,
getRealtimeData,
getWebsiteStats,
};