migration update

sogebot · Nov 8, 2021 · c2d42bc · c2d42bc
1 parent fa5519a
commit c2d42bc
Show file tree

Hide file tree

Showing 2 changed files with 70 additions and 0 deletions.
diff --git a/src/database/migration/mysql/14.0.x/1635631125262-serviceMigration.ts b/src/database/migration/mysql/14.0.x/1635631125262-serviceMigration.ts
@@ -0,0 +1,35 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class serviceMigration1635631125262 implements MigrationInterface {
+  name = 'serviceMigration1635631125262';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    const items = (await queryRunner.query(`SELECT * from \`settings\``)).filter((o: any) => {
+      return o.namespace === '/core/oauth'
+        || o.namespace === '/core/tmi'
+        || o.namespace === '/core/twitch';
+    });
+    for (const item of items) {
+      await queryRunner.query(`UPDATE \`settings\` SET \`namespace\`="/services/twitch" WHERE \`id\`="${item.id}"`);
+    }
+    await queryRunner.query(`INSERT INTO \`settings\`(\`namespace\`, \`value\`, \`name\`) VALUES ("/services/twitch", "${JSON.stringify(true)}", "enabled")`);
+
+    const items2 = (await queryRunner.query(`SELECT * from \`settings\``)).filter((o: any) => {
+      return o.namespace === '/core/eventsub';
+    });
+
+    for (const item of items2) {
+      if (item.name === 'useTunneling' || item.name === 'domain' || item.name === 'appToken' || item.name === 'secret') {
+        await queryRunner.query(`UPDATE \`settings\` SET \`namespace\`="/services/twitch" WHERE \`id\`="${item.id}"`);
+      } else {
+        await queryRunner.query(`UPDATE \`settings\` SET \`namespace\`="/services/twitch", \`name\`="eventSub${item.name.charAt(0).toUpperCase() + item.name.slice(1)}" WHERE \`id\`="${item.id}"`);
+      }
+
+    }
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    console.log('Please revert you db from backup.');
+  }
+
+}
diff --git a/src/database/migration/postgres/14.0.x/1635631125262-serviceMigration.ts b/src/database/migration/postgres/14.0.x/1635631125262-serviceMigration.ts
@@ -0,0 +1,35 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class serviceMigration1635631125262 implements MigrationInterface {
+  name = 'serviceMigration1635631125262';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    const items = (await queryRunner.query(`SELECT * from "settings"`)).filter((o: any) => {
+      return o.namespace === '/core/oauth'
+        || o.namespace === '/core/tmi'
+        || o.namespace === '/core/twitch';
+    });
+    for (const item of items) {
+      await queryRunner.query(`UPDATE "settings" SET "namespace"='/services/twitch' WHERE "id"='${item.id}'`);
+    }
+    await queryRunner.query(`INSERT INTO "settings"("namespace", "value", "name") VALUES ('/services/twitch', '${JSON.stringify(true)}', 'enabled')`);
+
+    const items2 = (await queryRunner.query(`SELECT * from "settings"`)).filter((o: any) => {
+      return o.namespace === '/core/eventsub';
+    });
+
+    for (const item of items2) {
+      if (item.name === 'useTunneling' || item.name === 'domain' || item.name === 'appToken' || item.name === 'secret') {
+        await queryRunner.query(`UPDATE "settings" SET "namespace"='/services/twitch' WHERE "id"='${item.id}'`);
+      } else {
+        await queryRunner.query(`UPDATE "settings" SET "namespace"='/services/twitch', "name"='eventSub${item.name.charAt(0).toUpperCase() + item.name.slice(1)}' WHERE "id"='${item.id}'`);
+      }
+
+    }
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    console.log('Please revert you db from backup.');
+  }
+
+}