Merge remote-tracking branch 'origin/dev' into dev

This commit is contained in:
Mike Cao 2022-11-08 22:59:01 -08:00
commit 1bce4f2174
2 changed files with 6 additions and 2 deletions

View File

@ -39,7 +39,7 @@ async function relationalQuery(data) {
}
async function clickhouseQuery(data) {
const { websiteId, sessionId, url, eventName, eventData } = data;
const { websiteId, id: sessionId, url, eventName, eventData, country, ...args } = data;
const { getDateFormat, sendMessage } = kafka;
const website = await cache.fetchWebsite(websiteId);
@ -52,6 +52,8 @@ async function clickhouseQuery(data) {
event_data: eventData ? JSON.stringify(eventData) : null,
rev_id: website?.revId || 0,
created_at: getDateFormat(new Date()),
country: country ? country : null,
...args,
};
await sendMessage(params, 'event');

View File

@ -26,7 +26,7 @@ async function relationalQuery(data) {
}
async function clickhouseQuery(data) {
const { websiteId, sessionId, url, referrer } = data;
const { websiteId, id: sessionId, url, referrer, country, ...args } = data;
const website = await cache.fetchWebsite(websiteId);
const { getDateFormat, sendMessage } = kafka;
@ -37,6 +37,8 @@ async function clickhouseQuery(data) {
referrer: referrer?.substring(0, URL_LENGTH),
rev_id: website?.revId || 0,
created_at: getDateFormat(new Date()),
country: country ? country : null,
...args,
};
await sendMessage(msg, 'event');