improve logging for requests

apps/web/prisma/migrations/20231207205533_add_api_version_to_request/migration.sql

@@ -0,0 +1,3 @@
+-- AlterTable
+ALTER TABLE `ApiRequest` ADD COLUMN `apiVersion` VARCHAR(191) NOT NULL DEFAULT 'v0',
+    MODIFY `type` ENUM('GET_CONFIG', 'GET_CONFIG_SCRIPT', 'TRACK_VIEW') NOT NULL;

apps/web/prisma/migrations/20231207205701_add_apiversion_enum/migration.sql

@@ -0,0 +1,8 @@
+/*
+  Warnings:
+
+  - You are about to alter the column `apiVersion` on the `ApiRequest` table. The data in that column could be lost. The data in that column will be cast from `VarChar(191)` to `Enum(EnumId(3))`.
+
+*/
+-- AlterTable
+ALTER TABLE `ApiRequest` MODIFY `apiVersion` ENUM('V0', 'V1') NOT NULL DEFAULT 'V0';

apps/web/prisma/schema.prisma

@@ -289,12 +289,19 @@ enum ApiRequestType {
   TRACK_VIEW
 }
 
+enum ApiVersion {
+  V0
+  V1
+}
+
 model ApiRequest {
   id           String         @id @default(cuid())
   createdAt    DateTime       @default(now())
   type         ApiRequestType
   durationInMs Int
 
+  apiVersion ApiVersion @default(V0)
+
   projectId String
   project   Project @relation(fields: [projectId], references: [id], onDelete: Cascade)
 

apps/web/src/pages/api/dashboard/[projectId]/data.ts

@@ -8,12 +8,18 @@ import { RequestCache } from "server/services/RequestCache";
 import { transformFlagValue } from "lib/flags";
 import { LegacyAbbyDataResponse } from "@tryabby/core";
 import { RequestService } from "server/services/RequestService";
+import createCache from "server/common/memory-cache";
 
 const incomingQuerySchema = z.object({
   projectId: z.string(),
   environment: z.string().optional(),
 });
 
+const configCache = createCache<string, LegacyAbbyDataResponse>({
+  name: "legacyConfigCache",
+  expireAfterMilliseconds: 1000 * 10,
+});
+
 export default async function getWeightsHandler(
   req: NextApiRequest,
   res: NextApiResponse
@@ -45,6 +51,12 @@ export default async function getWeightsHandler(
       return;
     }
 
+    const cachedData = configCache.get(projectId + environment);
+    if (cachedData) {
+      res.json(cachedData);
+      return;
+    }
+
     const [tests, flags] = await Promise.all([
       prisma.test.findMany({
         where: {
@@ -82,6 +94,8 @@ export default async function getWeightsHandler(
 
     res.json(response);
 
+    configCache.set(projectId + environment, response);
+
     if (is80PercentOfLimit) {
       await trackPlanOverage(projectId, plan, is80PercentOfLimit);
     }
@@ -92,6 +106,7 @@ export default async function getWeightsHandler(
       projectId,
       type: "GET_CONFIG",
       durationInMs: duration,
+      apiVersion: "V0",
     }).catch((e) => {
       console.error("Unable to store request", e);
     });

apps/web/src/pages/api/v1/data/[projectId]/index.ts

@@ -24,7 +24,7 @@ export async function getAbbyResponseWithCache({
   environment,
   projectId,
 }: z.infer<typeof incomingQuerySchema>) {
-  const cachedConfig = configCache.get(projectId);
+  const cachedConfig = configCache.get(projectId + environment);
 
   if (cachedConfig) {
     return cachedConfig;
@@ -71,7 +71,7 @@ export async function getAbbyResponseWithCache({
       }),
   } satisfies AbbyDataResponse;
 
-  configCache.set(projectId, response);
+  configCache.set(projectId + environment, response);
   return response;
 }
 
@@ -100,6 +100,8 @@ export default async function getWeightsHandler(
 
     res.send(response);
 
+    const duration = performance.now() - now;
+
     const { events, planLimits, plan, is80PercentOfLimit } =
       await EventService.getEventsForCurrentPeriod(projectId);
 
@@ -117,12 +119,11 @@ export default async function getWeightsHandler(
 
     await RequestCache.increment(projectId);
 
-    const duration = performance.now() - now;
-
     RequestService.storeRequest({
       projectId,
       type: "GET_CONFIG",
       durationInMs: duration,
+      apiVersion: "V1",
     }).catch((e) => {
       console.error("Unable to store request", e);
     });