api: improve get events sql and setup simple caching

apps/web/src/pages/api/cron/cache/update.tsx

@@ -0,0 +1,18 @@
+import * as cache from '@/server/cache';
+import { db } from '@/server/db';
+import { getUniqueEvents } from '@/server/services/event.service';
+import type { NextApiRequest, NextApiResponse } from 'next';
+
+export default async function handler(
+  req: NextApiRequest,
+  res: NextApiResponse
+) {
+  const projects = await db.project.findMany();
+
+  for (const project of projects) {
+    const events = await getUniqueEvents({ projectId: project.id });
+    cache.set(`events_${project.id}`, 1000 * 60 * 60 * 24, events);
+  }
+
+  res.status(200).json({ ok: true });
+}

apps/web/src/server/api/routers/chart.ts

@@ -1,6 +1,7 @@
 import { createTRPCRouter, protectedProcedure } from '@/server/api/trpc';
 import * as cache from '@/server/cache';
 import { db } from '@/server/db';
+import { getUniqueEvents } from '@/server/services/event.service';
 import { getProjectBySlug } from '@/server/services/project.service';
 import type {
   IChartEvent,
@@ -27,15 +28,8 @@ export const chartRouter = createTRPCRouter({
       const project = await getProjectBySlug(projectSlug);
       const events = await cache.getOr(
         `events_${project.id}`,
-        1000 * 60 * 60,
-        () =>
-          db.event.findMany({
-            take: 500,
-            distinct: ['name'],
-            where: {
-              project_id: project.id,
-            },
-          })
+        1000 * 60 * 60 * 24,
+        () => getUniqueEvents({ projectId: project.id })
       );
 
       return events;

apps/web/src/server/services/event.service.ts

@@ -0,0 +1,12 @@
+import { db } from '../db';
+
+export function getUniqueEvents({ projectId }: { projectId: string }) {
+  return db.event.findMany({
+    take: 500,
+    distinct: ['name'],
+    select: { name: true },
+    where: {
+      project_id: projectId,
+    },
+  });
+}