watson/umami
1
0
Fork 0
mirror of https://github.com/umami-software/umami.git synced 2026-02-09 15:17:23 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

Render view for user journey report.

Browse source
This commit is contained in:
Mike Cao 2024-06-01 11:45:06 -07:00
parent 06c62a199c
commit 8a722ff013
4 changed files with 187 additions and 35 deletions
Download patch file Download diff file Expand all files Collapse all files

39
src/queries/analytics/reports/getJourney.ts
View file

@ -2,6 +2,15 @@ import clickhouse from 'lib/clickhouse';
import { CLICKHOUSE, PRISMA, runQuery } from 'lib/db';
import prisma from 'lib/prisma';
interface JourneyResult {
e1: string;
e2: string;
e3: string;
e4: string;
e5: string;
count: string;
}
export async function getJourney(
...args: [
websiteId: string,
@ -23,16 +32,7 @@ async function relationalQuery(
startDate: Date;
endDate: Date;
},
): Promise<
{
e1: string;
e2: string;
e3: string;
e4: string;
e5: string;
count: string;
}[]
> {
): Promise<JourneyResult[]> {
const { startDate, endDate } = filters;
const { rawQuery } = prisma;
@ -79,7 +79,7 @@ async function relationalQuery(
startDate,
endDate,
},
);
).then(parseResult);
}
async function clickhouseQuery(
@ -88,16 +88,7 @@ async function clickhouseQuery(
startDate: Date;
endDate: Date;
},
): Promise<
{
e1: string;
e2: string;
e3: string;
e4: string;
e5: string;
count: string;
}[]
> {
): Promise<JourneyResult[]> {
const { startDate, endDate } = filters;
const { rawQuery } = clickhouse;
@ -144,5 +135,9 @@ async function clickhouseQuery(
startDate,
endDate,
},
);
).then(parseResult);
}
function parseResult(data: any) {
return data.map(({ e1, e2, e3, e4, e5, count }) => ({ items: [e1, e2, e3, e4, e5], count }));
}