PEER-255 Standardize seed with questions

Signed-off-by: SeeuSim <[email protected]>

Author: SeeuSim

backend/question/drizzle/0000_initial_schema.sql

@@ -1,3 +1,15 @@
+DO $$ BEGIN
+ CREATE TYPE "public"."action" AS ENUM('SEED');
+EXCEPTION
+ WHEN duplicate_object THEN null;
+END $$;
+--> statement-breakpoint
+CREATE TABLE IF NOT EXISTS "admin" (
+	"id" uuid PRIMARY KEY DEFAULT gen_random_uuid() NOT NULL,
+	"created_at" timestamp DEFAULT now(),
+	"action" "action" NOT NULL
+);
+--> statement-breakpoint
 CREATE TABLE IF NOT EXISTS "questions" (
 	"id" serial PRIMARY KEY NOT NULL,
 	"title" varchar(255) NOT NULL,

backend/question/drizzle/meta/0000_snapshot.json

@@ -1,9 +1,40 @@
 {
-  "id": "537c03f5-13dd-427a-ae0d-cfd203da09ed",
+  "id": "84b2ca8d-3021-496f-8769-bbc4dada6468",
   "prevId": "00000000-0000-0000-0000-000000000000",
   "version": "7",
   "dialect": "postgresql",
   "tables": {
+    "public.admin": {
+      "name": "admin",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "uuid",
+          "primaryKey": true,
+          "notNull": true,
+          "default": "gen_random_uuid()"
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": false,
+          "default": "now()"
+        },
+        "action": {
+          "name": "action",
+          "type": "action",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {},
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {}
+    },
     "public.questions": {
       "name": "questions",
       "schema": "",
@@ -59,7 +90,15 @@
       "uniqueConstraints": {}
     }
   },
-  "enums": {},
+  "enums": {
+    "public.action": {
+      "name": "action",
+      "schema": "public",
+      "values": [
+        "SEED"
+      ]
+    }
+  },
   "schemas": {},
   "sequences": {},
   "_meta": {

backend/question/drizzle/meta/_journal.json

@@ -5,7 +5,7 @@
     {
       "idx": 0,
       "version": "7",
-      "when": 1727595727110,
+      "when": 1728143550719,
       "tag": "0000_initial_schema",
       "breakpoints": true
     }

backend/question/src/lib/db/schema.ts

@@ -1,4 +1,4 @@
-import { pgTable, serial, varchar, text, timestamp } from 'drizzle-orm/pg-core';
+import { pgEnum, pgTable, serial, text, timestamp, uuid, varchar } from 'drizzle-orm/pg-core';
 
 export const questions = pgTable('questions', {
   id: serial('id').primaryKey(),
@@ -9,3 +9,11 @@ export const questions = pgTable('questions', {
   createdAt: timestamp('created_at', { precision: 6, withTimezone: true }).defaultNow(),
   updatedAt: timestamp('updated_at', { precision: 6, withTimezone: true }).defaultNow(),
 });
+
+export const actionEnum = pgEnum('action', ['SEED']);
+
+export const admin = pgTable('admin', {
+  id: uuid('id').primaryKey().notNull().defaultRandom(),
+  createdAt: timestamp('created_at').defaultNow(),
+  action: actionEnum('action').notNull(),
+});

backend/question/src/lib/db/seed.ts

@@ -1,13 +1,20 @@
-import { sql } from 'drizzle-orm';
+import { eq, sql } from 'drizzle-orm';
 
-import { db, questions } from '@/lib/db';
+import { admin as adminTable, db, questions as questionTable } from '@/lib/db';
 import { questionData } from './sample-data/questions';
 
 const seedQuestions = async () => {
   try {
     await db.transaction(async (trx) => {
+      const seedRecords = await trx.select().from(adminTable).where(eq(adminTable.action, 'SEED'));
+      if (seedRecords && seedRecords.length > 0) {
+        console.info(
+          `[Users]: Seeded already at: ${(seedRecords[seedRecords.length - 1].createdAt ?? new Date()).toLocaleString()}`
+        );
+        return;
+      }
       // Delete all questions (not table)
-      await trx.delete(questions);
+      await trx.delete(questionTable);
 
       // Reset Serial to start index 1
       await trx.execute(sql`
@@ -21,7 +28,7 @@ const seedQuestions = async () => {
 
       for (const question of questionData) {
         await trx
-          .insert(questions)
+          .insert(questionTable)
           .values({ ...question, id: undefined }) // Let DB set ID
           .onConflictDoNothing();
       }