From 72b3b6158ab3999767de351e30122ac56f2dd4cf Mon Sep 17 00:00:00 2001
From: Mike Cao <moocao@gmail.com>
Date: Fri, 5 Jul 2024 02:29:12 -0700
Subject: [PATCH] Changed kafka method signature.

---
 src/lib/kafka.ts                                  | 4 ++--
 src/queries/analytics/eventData/saveEventData.ts  | 2 +-
 src/queries/analytics/events/saveEvent.ts         | 2 +-
 src/queries/analytics/sessions/saveSessionData.ts | 4 ++--
 4 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/lib/kafka.ts b/src/lib/kafka.ts
index da38baa4..76692afb 100644
--- a/src/lib/kafka.ts
+++ b/src/lib/kafka.ts
@@ -61,8 +61,8 @@ function getDateFormat(date: Date, format?: string): string {
 }
 
 async function sendMessage(
-  message: { [key: string]: string | number },
   topic: string,
+  message: { [key: string]: string | number },
 ): Promise<RecordMetadata[]> {
   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 producer.send({
diff --git a/src/queries/analytics/eventData/saveEventData.ts b/src/queries/analytics/eventData/saveEventData.ts
index 222e8b73..9c7218e9 100644
--- a/src/queries/analytics/eventData/saveEventData.ts
+++ b/src/queries/analytics/eventData/saveEventData.ts
@@ -82,7 +82,7 @@ async function clickhouseQuery(data: {
   });
 
   if (kafka.enabled) {
-    await sendMessages(messages, 'event_data');
+    await sendMessages('event_data', messages);
   } else {
     await insert('event_data', messages);
   }
diff --git a/src/queries/analytics/events/saveEvent.ts b/src/queries/analytics/events/saveEvent.ts
index 9a5787a3..cd41b7a3 100644
--- a/src/queries/analytics/events/saveEvent.ts
+++ b/src/queries/analytics/events/saveEvent.ts
@@ -167,7 +167,7 @@ async function clickhouseQuery(data: {
   };
 
   if (kafka.enabled) {
-    await sendMessage(message, 'event');
+    await sendMessage('event', message);
   } else {
     await insert('website_event', [message]);
   }
diff --git a/src/queries/analytics/sessions/saveSessionData.ts b/src/queries/analytics/sessions/saveSessionData.ts
index 6ab5d6ae..1f5c1494 100644
--- a/src/queries/analytics/sessions/saveSessionData.ts
+++ b/src/queries/analytics/sessions/saveSessionData.ts
@@ -101,9 +101,9 @@ async function clickhouseQuery(data: {
   });
 
   if (kafka.enabled) {
-    await sendMessages(messages, 'session_data');
+    await sendMessages('session_data', messages);
   } else {
-    await insert('event_data', messages);
+    await insert('session_data', messages);
   }
 
   return data;