From 440db17000067fcedae580ee527b19cbd73ee1a8 Mon Sep 17 00:00:00 2001
From: Mike Cao <moocao@gmail.com>
Date: Sat, 3 Aug 2024 22:02:41 -0700
Subject: [PATCH] Added created date to session data save.

---
 src/pages/api/send.ts                             | 4 +---
 src/queries/analytics/sessions/saveSessionData.ts | 5 ++---
 2 files changed, 3 insertions(+), 6 deletions(-)

diff --git a/src/pages/api/send.ts b/src/pages/api/send.ts
index 31318420..23640de9 100644
--- a/src/pages/api/send.ts
+++ b/src/pages/api/send.ts
@@ -144,9 +144,7 @@ export default async (req: NextApiRequestCollect, res: NextApiResponse) => {
         ...session,
         sessionId: session.id,
       });
-    }
-
-    if (type === COLLECTION_TYPE.identify) {
+    } else if (type === COLLECTION_TYPE.identify) {
       if (!data) {
         return badRequest(res, 'Data required.');
       }
diff --git a/src/queries/analytics/sessions/saveSessionData.ts b/src/queries/analytics/sessions/saveSessionData.ts
index 1f5c1494..51f5c47d 100644
--- a/src/queries/analytics/sessions/saveSessionData.ts
+++ b/src/queries/analytics/sessions/saveSessionData.ts
@@ -11,7 +11,6 @@ export async function saveSessionData(data: {
   websiteId: string;
   sessionId: string;
   sessionData: DynamicData;
-  createdAt?: string;
 }) {
   return runQuery({
     [PRISMA]: () => relationalQuery(data),
@@ -78,12 +77,12 @@ async function clickhouseQuery(data: {
   websiteId: string;
   sessionId: string;
   sessionData: DynamicData;
-  createdAt?: string;
 }) {
-  const { websiteId, sessionId, sessionData, createdAt } = data;
+  const { websiteId, sessionId, sessionData } = data;
 
   const { insert } = clickhouse;
   const { getDateFormat, sendMessages } = kafka;
+  const createdAt = getDateFormat(new Date());
 
   const jsonKeys = flattenJSON(sessionData);