Migrate payload related fields to jsonb field type

Author: Pabl0cks

packages/nextjs/services/database/config/schema.ts

@@ -1,5 +1,5 @@
 import { relations } from "drizzle-orm";
-import { boolean, pgEnum, pgTable, serial, text, timestamp, varchar } from "drizzle-orm/pg-core";
+import { boolean, jsonb, pgEnum, pgTable, serial, text, timestamp, varchar } from "drizzle-orm/pg-core";
 
 export const reviewActionEnum = pgEnum("review_action_enum", ["REJECTED", "ACCEPTED", "SUBMITTED"]);
 export const eventTypeEnum = pgEnum("event_type_enum", ["challenge.submit", "challenge.autograde", "user.create"]);
@@ -45,11 +45,9 @@ export const events = pgTable("events", {
   userAddress: varchar("user_address", { length: 42 })
     .notNull()
     .references(() => users.userAddress),
-  challengeId: varchar("challenge_id", { length: 255 }).references(() => challenges.id),
-  frontendUrl: varchar("frontend_url", { length: 255 }),
-  contractUrl: varchar("contract_url", { length: 255 }),
-  reviewAction: reviewActionEnum("review_action"),
-  reviewMessage: text("review_message"),
+  payload: jsonb("payload")
+    .notNull()
+    .$defaultFn(() => ({})), // Flexible event payload stored as JSONB
 });
 
 export const usersRelations = relations(users, ({ many }) => ({
@@ -78,8 +76,4 @@ export const eventsRelations = relations(events, ({ one }) => ({
     fields: [events.userAddress],
     references: [users.userAddress],
   }),
-  challenge: one(challenges, {
-    fields: [events.challengeId],
-    references: [challenges.id],
-  }),
 }));

packages/nextjs/services/database/seed.ts

@@ -37,14 +37,17 @@ interface EventPayload {
   challengeId?: string;
   contractUrl?: string;
   frontendUrl?: string;
-  userAddress: string;
   autograding?: boolean;
   reviewAction?: "ACCEPTED" | "REJECTED";
   reviewMessage?: string;
+  [key: string]: any; // Allow for additional fields in the payload
 }
 
 interface Event {
-  payload: EventPayload;
+  payload: {
+    userAddress: string; // This is in the original Firebase data
+    [key: string]: any;
+  };
   signature: string;
   timestamp: number;
   type: "challenge.submit" | "challenge.autograde" | "user.create";
@@ -208,18 +211,22 @@ async function seed() {
     // Insert events
     console.log("Inserting events...");
     for (const event of typedSeedData.events) {
+      // Create a new payload without userAddress
+      const { userAddress, ...payloadWithoutUser } = event.payload;
+      const eventPayload = {
+        ...payloadWithoutUser,
+        // Convert reviewAction to proper enum value if present
+        reviewAction: event.payload.reviewAction as "ACCEPTED" | "REJECTED" | undefined,
+      };
+
       await db
         .insert(events)
         .values({
           eventType: event.type,
           eventAt: createValidDate(event.timestamp),
           signature: event.signature,
-          userAddress: event.payload.userAddress,
-          challengeId: event.payload.challengeId,
-          frontendUrl: event.payload.frontendUrl,
-          contractUrl: event.payload.contractUrl,
-          reviewAction: event.payload.reviewAction,
-          reviewMessage: event.payload.reviewMessage,
+          userAddress: userAddress, // Use the extracted userAddress
+          payload: eventPayload,
         })
         .execute();
     }