Merge pull request #172 from cuappdev/ashley/migrations

Ashley/migrations

Author: ashleynhs

src/migrations/1767386999887-AddUserStats.ts

@@ -3,11 +3,20 @@ import {MigrationInterface, QueryRunner} from "typeorm";
 export class AddUserStats1767386999887 implements MigrationInterface {
 
     public async up(queryRunner: QueryRunner): Promise<void> {
-        await queryRunner.query(`CREATE TABLE "user_following_users" ("follower_id" character varying NOT NULL, "following_id" character varying NOT NULL, CONSTRAINT "PK_user_following_users" PRIMARY KEY ("follower_id", "following_id"))`);
-        await queryRunner.query(`CREATE INDEX "IDX_user_following_users_follower_id" ON "user_following_users" ("follower_id")`);
-        await queryRunner.query(`CREATE INDEX "IDX_user_following_users_following_id" ON "user_following_users" ("following_id")`);
-        await queryRunner.query(`ALTER TABLE "user_following_users" ADD CONSTRAINT "FK_user_following_users_follower_id" FOREIGN KEY ("follower_id") REFERENCES "User"("firebaseUid") ON DELETE CASCADE ON UPDATE CASCADE`);
-        await queryRunner.query(`ALTER TABLE "user_following_users" ADD CONSTRAINT "FK_user_following_users_following_id" FOREIGN KEY ("following_id") REFERENCES "User"("firebaseUid") ON DELETE CASCADE ON UPDATE CASCADE`);
+        await queryRunner.query(`CREATE TABLE IF NOT EXISTS "user_following_users" ("follower_id" character varying NOT NULL, "following_id" character varying NOT NULL, CONSTRAINT "PK_user_following_users" PRIMARY KEY ("follower_id", "following_id"))`);
+        await queryRunner.query(`CREATE INDEX IF NOT EXISTS "IDX_user_following_users_follower_id" ON "user_following_users" ("follower_id")`);
+        await queryRunner.query(`CREATE INDEX IF NOT EXISTS "IDX_user_following_users_following_id" ON "user_following_users" ("following_id")`);
+        
+        // Add fks only if they don't exist
+        const fk1Exists = await queryRunner.query(`SELECT 1 FROM pg_constraint WHERE conname = 'FK_user_following_users_follower_id'`);
+        if (!fk1Exists || fk1Exists.length === 0) {
+            await queryRunner.query(`ALTER TABLE "user_following_users" ADD CONSTRAINT "FK_user_following_users_follower_id" FOREIGN KEY ("follower_id") REFERENCES "User"("firebaseUid") ON DELETE CASCADE ON UPDATE CASCADE`);
+        }
+        
+        const fk2Exists = await queryRunner.query(`SELECT 1 FROM pg_constraint WHERE conname = 'FK_user_following_users_following_id'`);
+        if (!fk2Exists || fk2Exists.length === 0) {
+            await queryRunner.query(`ALTER TABLE "user_following_users" ADD CONSTRAINT "FK_user_following_users_following_id" FOREIGN KEY ("following_id") REFERENCES "User"("firebaseUid") ON DELETE CASCADE ON UPDATE CASCADE`);
+        }
 
         await queryRunner.query(`ALTER TABLE "User" ADD COLUMN IF NOT EXISTS "soldPosts" integer NOT NULL DEFAULT 0`);
     }

src/migrations/1769500000000-AddConfirmationSentToTransaction.ts

@@ -4,7 +4,7 @@ export class AddConfirmationSentToTransaction1769500000000 implements MigrationI
     name = 'AddConfirmationSentToTransaction1769500000000'
 
     public async up(queryRunner: QueryRunner): Promise<void> {
-        await queryRunner.query(`ALTER TABLE "Transaction" ADD "confirmationSent" boolean NOT NULL DEFAULT false`);
+        await queryRunner.query(`ALTER TABLE "Transaction" ADD COLUMN IF NOT EXISTS "confirmationSent" boolean NOT NULL DEFAULT false`);
     }
 
     public async down(queryRunner: QueryRunner): Promise<void> {

src/utils/DB.ts

@@ -9,7 +9,7 @@ export default async function resellConnection(): Promise<Connection> {
     logging: true,
     password: process.env.DB_PASSWORD,
     port: +(process.env.DB_PORT || 5432),
-    synchronize: true,
+    synchronize: false,
     type: "postgres",
     username: process.env.DB_USERNAME || "postgres",
     extra: {