serialize big int and auto parse json at global level to deal with prisma migration

Author: abhishek2021005

packages/alea-frontend/pages/api/prisma-comments.ts

@@ -10,11 +10,60 @@ function getCommentsDatabaseUrl(): string {
   return `mysql://${user}:${password}@${host}:${port}/${database}`;
 }
 
+function serializeBigInt(obj: any): any {
+  if (obj === null || obj === undefined) return obj;
+  if (typeof obj === 'bigint') return obj.toString();
+  if (Array.isArray(obj)) return obj.map(serializeBigInt);
+  if (typeof obj === 'object' && !(obj instanceof Date)) {
+    return Object.fromEntries(
+      Object.entries(obj).map(([key, value]) => [key, serializeBigInt(value)])
+    );
+  }
+  return obj;
+}
+
+function autoParseJson(obj: any): any {
+  if (obj === null || obj === undefined) return obj;
+  if (typeof obj === 'string' || Buffer.isBuffer(obj)) {
+    const str = obj.toString().trim();
+    if ((str.startsWith('{') && str.endsWith('}')) || (str.startsWith('[') && str.endsWith(']'))) {
+      try {
+        const parsed = JSON.parse(str);
+        return autoParseJson(parsed);
+      } catch {
+        return obj; 
+      }
+    }
+  }
+
+  if (Array.isArray(obj)) return obj.map(autoParseJson);
+  if (typeof obj === 'object' && !(obj instanceof Date)) {
+    return Object.fromEntries(
+      Object.entries(obj).map(([key, value]) => [key, autoParseJson(value)])
+    );
+  }
+  return obj;
+}
+
+const globalTransform = async ({ args, query }: any) => {
+  const result = await query(args);
+  const parsed = autoParseJson(result);
+  return serializeBigInt(parsed);
+};
+
 const adapter = new PrismaMariaDb(getCommentsDatabaseUrl());
+const baseClient = new PrismaClient({ adapter });
+
+export const commentsDb = baseClient.$extends({
+  query: {
+    $allModels: { $allOperations: globalTransform },
+    $queryRaw: globalTransform,
+    $executeRaw: globalTransform,
+  },
+});
 
-const globalForPrisma = globalThis as unknown as { commentsDb: PrismaClient };
-export const commentsDb =
-  globalForPrisma.commentsDb ?? new PrismaClient({ adapter });
+type ExtendedPrismaClient = typeof commentsDb;
+const globalForPrisma = globalThis as unknown as { commentsDb: ExtendedPrismaClient };
 if (process.env.NEXT_PUBLIC_SITE_VERSION !== 'production') {
   globalForPrisma.commentsDb = commentsDb;
 }