Update migrations to include content-moderation-requests table deletion and old status handling

Author: flopez7

packages/apps/job-launcher/server/src/database/migrations/1774453578372-removeContentModeration.ts

@@ -4,6 +4,30 @@ export class RemoveContentModeration1774453578372 implements MigrationInterface
   name = 'RemoveContentModeration1774453578372';
 
   public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+            UPDATE "hmt"."jobs"
+            SET "status" = 'paid'
+            WHERE "status" IN ('moderation_passed', 'under_moderation')
+        `);
+    await queryRunner.query(`
+            UPDATE "hmt"."jobs"
+            SET "status" = 'failed'
+            WHERE "status" = 'possible_abuse_in_review'
+        `);
+    await queryRunner.query(`
+            DELETE FROM "hmt"."cron-jobs"
+            WHERE "cron_job_type" = 'content-moderation'
+        `);
+    await queryRunner.query(`
+            ALTER TABLE "hmt"."content-moderation-requests"
+            DROP CONSTRAINT IF EXISTS "FK_d4f313caf54945a83b00abc02af"
+        `);
+    await queryRunner.query(`
+            DROP TABLE IF EXISTS "hmt"."content-moderation-requests"
+        `);
+    await queryRunner.query(`
+            DROP TYPE IF EXISTS "hmt"."content-moderation-requests_status_enum"
+        `);
     await queryRunner.query(`
             ALTER TYPE "hmt"."jobs_status_enum"
             RENAME TO "jobs_status_enum_old"
@@ -50,6 +74,28 @@ export class RemoveContentModeration1774453578372 implements MigrationInterface
   }
 
   public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+            CREATE TYPE "hmt"."content-moderation-requests_status_enum" AS ENUM(
+                'pending',
+                'processed',
+                'positive_abuse',
+                'passed',
+                'failed'
+            )
+        `);
+    await queryRunner.query(`
+            CREATE TABLE "hmt"."content-moderation-requests" (
+                "id" SERIAL NOT NULL,
+                "created_at" TIMESTAMP WITH TIME ZONE NOT NULL,
+                "updated_at" TIMESTAMP WITH TIME ZONE NOT NULL,
+                "data_url" character varying NOT NULL,
+                "from" integer NOT NULL,
+                "to" integer NOT NULL,
+                "status" "hmt"."content-moderation-requests_status_enum" NOT NULL,
+                "job_id" integer NOT NULL,
+                CONSTRAINT "PK_e81154211cbfb9f8dcd56158313" PRIMARY KEY ("id")
+            )
+        `);
     await queryRunner.query(`
             CREATE TYPE "hmt"."cron-jobs_cron_job_type_enum_old" AS ENUM(
                 'abuse',
@@ -97,5 +143,9 @@ export class RemoveContentModeration1774453578372 implements MigrationInterface
             ALTER TYPE "hmt"."jobs_status_enum_old"
             RENAME TO "jobs_status_enum"
         `);
+    await queryRunner.query(`
+            ALTER TABLE "hmt"."content-moderation-requests"
+            ADD CONSTRAINT "FK_d4f313caf54945a83b00abc02af" FOREIGN KEY ("job_id") REFERENCES "hmt"."jobs"("id") ON DELETE NO ACTION ON UPDATE NO ACTION
+        `);
   }
 }