Add type to metrics.

pull/1740/head
Brian Cao 2023-01-12 21:48:21 -08:00
parent 7c7bb654d9
commit 8de369df96
2 changed files with 10 additions and 8 deletions

View File

@ -144,8 +144,8 @@ export default async (
startDate,
endDate,
column,
table,
filters,
type,
});
return ok(res, data);

View File

@ -12,8 +12,8 @@ export async function getPageviewMetrics(
startDate: Date;
endDate: Date;
column: Prisma.WebsiteEventScalarFieldEnum | Prisma.SessionScalarFieldEnum;
table: string;
filters: object;
type: string;
},
]
) {
@ -30,16 +30,17 @@ async function relationalQuery(
endDate: Date;
column: Prisma.WebsiteEventScalarFieldEnum | Prisma.SessionScalarFieldEnum;
filters: object;
type: string;
},
) {
const { startDate, endDate, column, filters = {} } = data;
const { startDate, endDate, column, filters = {}, type } = data;
const { rawQuery, parseFilters, toUuid } = prisma;
const params: any = {
const params: any = [
websiteId,
startDate,
endDate,
type: EVENT_TYPE.pageView,
};
type === 'event' ? EVENT_TYPE.customEvent : EVENT_TYPE.pageView,
];
const { filterQuery, joinSession } = parseFilters(filters, params);
return rawQuery(
@ -63,15 +64,16 @@ async function clickhouseQuery(
endDate: Date;
column: Prisma.WebsiteEventScalarFieldEnum | Prisma.SessionScalarFieldEnum;
filters: object;
type: string;
},
) {
const { startDate, endDate, column, filters = {} } = data;
const { startDate, endDate, column, filters = {}, type } = data;
const { rawQuery, parseFilters, getBetweenDates } = clickhouse;
const website = await cache.fetchWebsite(websiteId);
const params = {
websiteId,
revId: website?.revId || 0,
eventType: EVENT_TYPE.pageView,
eventType: type === 'event' ? EVENT_TYPE.customEvent : EVENT_TYPE.pageView,
};
const { filterQuery } = parseFilters(filters, params);