m/umami
1
0
Fork 0
mirror of https://github.com/kremalicious/umami.git synced 2025-02-01 12:29:35 +01:00
Code Issues Packages Projects Releases Wiki Activity

Changed kafka method signature.

Browse Source
This commit is contained in:
Mike Cao 2024-07-05 02:29:12 -07:00
parent 26462cffbc
commit 72b3b6158a
4 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/lib/kafka.ts
View File

@ -61,8 +61,8 @@ function getDateFormat(date: Date, format?: string): string {
} }
async function sendMessage( async function sendMessage(
message: { [key: string]: string | number },
topic: string, topic: string,
message: { [key: string]: string | number },
): Promise<RecordMetadata[]> { ): Promise<RecordMetadata[]> {
await connect(); await connect();
@ -77,7 +77,7 @@ async function sendMessage(
}); });
} }
async function sendMessages(messages: { [key: string]: string | number }[], topic: string) { async function sendMessages(topic: string, messages: { [key: string]: string | number }[]) {
await connect(); await connect();
await producer.send({ await producer.send({

2
src/queries/analytics/eventData/saveEventData.ts
View File

@ -82,7 +82,7 @@ async function clickhouseQuery(data: {
}); });
if (kafka.enabled) { if (kafka.enabled) {
await sendMessages(messages, 'event_data'); await sendMessages('event_data', messages);
} else { } else {
await insert('event_data', messages); await insert('event_data', messages);
} }

2
src/queries/analytics/events/saveEvent.ts
View File

@ -167,7 +167,7 @@ async function clickhouseQuery(data: {
}; };
if (kafka.enabled) { if (kafka.enabled) {
await sendMessage(message, 'event'); await sendMessage('event', message);
} else { } else {
await insert('website_event', [message]); await insert('website_event', [message]);
} }

4
src/queries/analytics/sessions/saveSessionData.ts
View File

@ -101,9 +101,9 @@ async function clickhouseQuery(data: {
}); });
if (kafka.enabled) { if (kafka.enabled) {
await sendMessages(messages, 'session_data'); await sendMessages('session_data', messages);
} else { } else {
await insert('event_data', messages); await insert('session_data', messages);
} }
return data; return data;