feat: performance tracker

lib/cache/performance.ts

@@ -0,0 +1,86 @@
+import * as cache from "@lib/cache/cache.ts";
+
+export type PerformancePoint = {
+  path: string;
+  search: string;
+  time: number;
+  date: Date;
+};
+
+export type PerformanceRes = {
+  max: number;
+  res: {
+    url: string;
+    data: readonly [number, number, number, number];
+  }[];
+};
+
+export const savePerformance = (url: string, milliseconds: number) => {
+  const d = new Date();
+  const year = d.getFullYear();
+  const month = d.getMonth().toString().padStart(2, "0");
+  const day = d.getDay().toString().padStart(2, "0");
+  const hour = d.getHours().toString().padStart(2, "0");
+  const minute = d.getMinutes().toString().padStart(2, "0");
+  const seconds = d.getSeconds().toString().padStart(2, "0");
+
+  const u = new URL(url);
+  if (u.pathname.includes("_frsh/")) return;
+  u.searchParams.delete("__frsh_c");
+
+  cache.set(
+    `performance:${year}:${month}:${day}:${hour}:${minute}:${seconds}`,
+    JSON.stringify({
+      path: decodeURIComponent(u.pathname),
+      search: u.search,
+      time: Math.floor(milliseconds * 1000),
+    }),
+  );
+};
+
+export async function getPerformances(): Promise<PerformanceRes> {
+  const d = new Date();
+  const year = d.getFullYear();
+  const month = d.getMonth().toString().padStart(2, "0");
+  const day = d.getDay().toString().padStart(2, "0");
+
+  const keys = await cache.keys(
+    `performance:${year}:${month}:${day}:*`,
+  );
+
+  const performances = await Promise.all(
+    keys.map(async (key) =>
+      JSON.parse(await cache.get<string>(key)) as PerformancePoint
+    ),
+  );
+
+  let maximum = 0;
+
+  const res = new Map<string, number[]>();
+  for (const p of performances) {
+    const id = p.path;
+    const timings = res.get(id) || [];
+    if (p.time > maximum) maximum = p.time;
+    timings.push(p.time);
+    res.set(id, timings);
+  }
+
+  return {
+    max: maximum,
+    res: [...res.entries()].map(([url, timings]) => {
+      let total = 0;
+      let min = Infinity;
+      let max = -Infinity;
+      for (const t of timings) {
+        total += t;
+        if (t < min) min = t;
+        if (t > max) max = t;
+      }
+
+      return {
+        url,
+        data: [timings.length, min, total / timings.length, max] as const,
+      };
+    }).sort((a, b) => a.data[2] < b.data[2] ? 1 : -1),
+  };
+}

lib/search.ts

@@ -71,8 +71,6 @@ export async function searchResource(
     }
   }
 
-  console.log({ q, query_by, filter_by });
-
   return await typesenseClient.collections("resources")
     .documents().search({
       q,