im trying..
This commit is contained in:
parent
f170962c64
commit
b8039917d0
@ -1,44 +1,69 @@
|
|||||||
import { MigrationInterface, QueryRunner } from "typeorm";
|
import { MigrationInterface, QueryRunner } from "typeorm";
|
||||||
|
|
||||||
export class MakeKeysNullable1766283926503 implements MigrationInterface {
|
export class MakeKeysNullable1766283926503 implements MigrationInterface {
|
||||||
|
public async up(queryRunner: QueryRunner): Promise<void> {
|
||||||
|
await queryRunner.query(`
|
||||||
|
CREATE TABLE "temporary_push_subscriptions" (
|
||||||
|
"id" varchar PRIMARY KEY NOT NULL,
|
||||||
|
"user_id" varchar,
|
||||||
|
"endpoint" varchar NOT NULL,
|
||||||
|
"expiration_time" bigint,
|
||||||
|
"auth" varchar,
|
||||||
|
"p256dh" varchar,
|
||||||
|
"type" text NOT NULL DEFAULT 'webpush',
|
||||||
|
CONSTRAINT "UQ_push_subscriptions_endpoint" UNIQUE ("endpoint"),
|
||||||
|
CONSTRAINT "FK_push_subscriptions_user"
|
||||||
|
FOREIGN KEY ("user_id") REFERENCES "users"("id")
|
||||||
|
ON DELETE SET NULL ON UPDATE NO ACTION
|
||||||
|
)
|
||||||
|
`);
|
||||||
|
|
||||||
public async up(queryRunner: QueryRunner): Promise<void> {
|
await queryRunner.query(`
|
||||||
await queryRunner.query(`
|
INSERT INTO "temporary_push_subscriptions"("id", "user_id", "endpoint", "expiration_time", "auth", "p256dh", "type")
|
||||||
ALTER TABLE "push_subscriptions"
|
SELECT "id", "user_id", "endpoint", "expiration_time", "auth", "p256dh", 'webpush'
|
||||||
ALTER COLUMN "auth" DROP NOT NULL;
|
FROM "push_subscriptions"
|
||||||
`);
|
`);
|
||||||
|
|
||||||
await queryRunner.query(`
|
await queryRunner.query(`DROP TABLE "push_subscriptions"`);
|
||||||
ALTER TABLE "push_subscriptions"
|
|
||||||
ALTER COLUMN "p256dh" DROP NOT NULL;
|
|
||||||
`);
|
|
||||||
|
|
||||||
await queryRunner.query(`
|
await queryRunner.query(`ALTER TABLE "temporary_push_subscriptions" RENAME TO "push_subscriptions"`);
|
||||||
ALTER TABLE "push_subscriptions"
|
|
||||||
ADD COLUMN "type" text;
|
|
||||||
`);
|
|
||||||
|
|
||||||
await queryRunner.query(`
|
await queryRunner.query(`
|
||||||
UPDATE "push_subscriptions"
|
CREATE UNIQUE INDEX IF NOT EXISTS "idx_push_subscriptions_endpoint"
|
||||||
SET "type" = 'webpush'
|
ON "push_subscriptions" ("endpoint")
|
||||||
WHERE "type" IS NULL;
|
`);
|
||||||
`);
|
}
|
||||||
}
|
|
||||||
|
|
||||||
public async down(queryRunner: QueryRunner): Promise<void> {
|
public async down(queryRunner: QueryRunner): Promise<void> {
|
||||||
await queryRunner.query(`
|
await queryRunner.query(`
|
||||||
ALTER TABLE "push_subscriptions"
|
CREATE TABLE "temporary_push_subscriptions" (
|
||||||
DROP COLUMN "type";
|
"id" varchar PRIMARY KEY NOT NULL,
|
||||||
`);
|
"user_id" varchar,
|
||||||
|
"endpoint" varchar NOT NULL,
|
||||||
|
"expiration_time" bigint,
|
||||||
|
"auth" varchar NOT NULL,
|
||||||
|
"p256dh" varchar NOT NULL,
|
||||||
|
CONSTRAINT "UQ_push_subscriptions_endpoint" UNIQUE ("endpoint"),
|
||||||
|
CONSTRAINT "FK_push_subscriptions_user"
|
||||||
|
FOREIGN KEY ("user_id") REFERENCES "users"("id")
|
||||||
|
ON DELETE SET NULL ON UPDATE NO ACTION
|
||||||
|
)
|
||||||
|
`);
|
||||||
|
|
||||||
await queryRunner.query(`
|
await queryRunner.query(`
|
||||||
ALTER TABLE "push_subscriptions"
|
INSERT INTO "temporary_push_subscriptions"("id", "user_id", "endpoint", "expiration_time", "auth", "p256dh")
|
||||||
ALTER COLUMN "auth" SET NOT NULL;
|
SELECT "id", "user_id", "endpoint", "expiration_time", "auth", "p256dh"
|
||||||
`);
|
FROM "push_subscriptions"
|
||||||
|
WHERE "auth" IS NOT NULL AND "p256dh" IS NOT NULL
|
||||||
|
`);
|
||||||
|
|
||||||
await queryRunner.query(`
|
await queryRunner.query(`DROP TABLE "push_subscriptions"`);
|
||||||
ALTER TABLE "push_subscriptions"
|
|
||||||
ALTER COLUMN "p256dh" SET NOT NULL;
|
await queryRunner.query(`ALTER TABLE "temporary_push_subscriptions" RENAME TO "push_subscriptions"`);
|
||||||
`);
|
|
||||||
}
|
await queryRunner.query(`
|
||||||
|
CREATE UNIQUE INDEX IF NOT EXISTS "idx_push_subscriptions_endpoint"
|
||||||
|
ON "push_subscriptions" ("endpoint")
|
||||||
|
`);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user