add timestamp column to prisma realtime queries

COMPFEST · Jun 20, 2024 · 2969435 · 2969435
1 parent 8a4fe95
commit 2969435
Show file tree

Hide file tree

Showing 2 changed files with 38 additions and 20 deletions.
diff --git a/src/queries/analytics/events/getEvents.ts b/src/queries/analytics/events/getEvents.ts
@@ -13,17 +13,26 @@ export function getEvents(...args: [websiteId: string, filters: QueryFilters]) {
 function relationalQuery(websiteId: string, filters: QueryFilters) {
   const { startDate } = filters;
 
-  return prisma.client.websiteEvent.findMany({
-    where: {
-      websiteId,
-      createdAt: {
-        gte: startDate,
+  return prisma.client.websiteEvent
+    .findMany({
+      where: {
+        websiteId,
+        createdAt: {
+          gte: startDate,
+        },
       },
-    },
-    orderBy: {
-      createdAt: 'desc',
-    },
-  });
+      orderBy: {
+        createdAt: 'desc',
+      },
+    })
+    .then(a => {
+      return Object.values(a).map(a => {
+        return {
+          ...a,
+          timestamp: new Date(a.createdAt).getTime() / 1000,
+        };
+      });
+    });
 }
 
 function clickhouseQuery(websiteId: string, filters: QueryFilters) {

diff --git a/src/queries/analytics/sessions/getSessions.ts b/src/queries/analytics/sessions/getSessions.ts
@@ -13,17 +13,26 @@ export async function getSessions(...args: [websiteId: string, filters: QueryFil
 async function relationalQuery(websiteId: string, filters: QueryFilters) {
   const { startDate } = filters;
 
-  return prisma.client.session.findMany({
-    where: {
-      websiteId,
-      createdAt: {
-        gte: startDate,
+  return prisma.client.session
+    .findMany({
+      where: {
+        websiteId,
+        createdAt: {
+          gte: startDate,
+        },
       },
-    },
-    orderBy: {
-      createdAt: 'desc',
-    },
-  });
+      orderBy: {
+        createdAt: 'desc',
+      },
+    })
+    .then(a => {
+      return Object.values(a).map(a => {
+        return {
+          ...a,
+          timestamp: new Date(a.createdAt).getTime() / 1000,
+        };
+      });
+    });
 }
 
 async function clickhouseQuery(websiteId: string, filters: QueryFilters) {