src/app/api/send/route.ts

@@ -146,7 +146,6 @@ export async function POST(request: Request) {
         region,
         city,
         distinctId: id,
-        createdAt,
       });
     }
 

src/queries/sql/sessions/createSession.ts

@@ -1,16 +1,10 @@
 import { Prisma } from '@/generated/prisma/client';
 import prisma from '@/lib/prisma';
 
-const FUNCTION_NAME = 'createSession';
-
 export async function createSession(data: Prisma.SessionCreateInput) {
-  const { rawQuery } = prisma;
+  const {
-
+    id,
-  await rawQuery(
+    websiteId,
-    `
-    insert into session (
-      session_id,
-      website_id,
     browser,
     os,
     device,
@@ -19,26 +13,29 @@ export async function createSession(data: Prisma.SessionCreateInput) {
     country,
     region,
     city,
-      distinct_id,
+    distinctId,
-      created_at
+  } = data;
-    )
+
-    values (
+  try {
-      {{id}},
+    return await prisma.client.session.create({
-      {{websiteId}},
+      data: {
-      {{browser}},
+        id,
-      {{os}},
+        websiteId,
-      {{device}},
+        browser,
-      {{screen}},
+        os,
-      {{language}},
+        device,
-      {{country}},
+        screen,
-      {{region}},
+        language,
-      {{city}},
+        country,
-      {{distinctId}},
+        region,
-      {{createdAt}}
+        city,
-    )
+        distinctId,
-    on conflict (session_id) do nothing
+      },
-    `,
+    });
-    data,
+  } catch (e: any) {
-    FUNCTION_NAME,
+    if (e.message.toLowerCase().includes('unique constraint')) {
-  );
+      return null;
+    }
+    throw e;
+  }
 }