Skip to content

Commit

Permalink
Merge pull request #8815 from ever-co/fix/alter-subscription-entity-t…
Browse files Browse the repository at this point in the history 
…able

[Fix] Alter "Subscription" Entity Table
  • Loading branch information
@rahul-rocket
rahul-rocket authored Mar 1, 2025
2 parents 0f2b63f + 5838f96 commit db29fb0
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 8 deletions.
10 changes: 5 additions & 5 deletions packages/core/src/lib/database/migrations/1740723269734-AlterSubscriptionEntityTable.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ export class AlterSubscriptionEntityTable1740723269734 implements MigrationInter
await queryRunner.query(`DROP INDEX "public"."IDX_cc906b4bc892b048f1b654d2aa"`);
await queryRunner.query(`ALTER TABLE "subscription" DROP COLUMN "userId"`);
await queryRunner.query(`ALTER TABLE "subscription" ADD "actorType" integer`);
await queryRunner.query(`ALTER TABLE "subscription" ADD "employeeId" uuid NOT NULL`);
await queryRunner.query(`ALTER TABLE "subscription" ADD "employeeId" uuid`);
await queryRunner.query(`CREATE INDEX "IDX_008f567bd1dc056bf865ff4d71" ON "subscription" ("actorType") `);
await queryRunner.query(`CREATE INDEX "IDX_1aac6fc0532ebc353f9cd3615b" ON "subscription" ("employeeId") `);
await queryRunner.query(
Expand Down Expand Up @@ -148,7 +148,7 @@ export class AlterSubscriptionEntityTable1740723269734 implements MigrationInter
await queryRunner.query(`DROP INDEX "IDX_6eafe9ba53fdd744cd1cffede8"`);
await queryRunner.query(`DROP INDEX "IDX_a0ce0007cfcc8e6ee405d0272f"`);
await queryRunner.query(
`CREATE TABLE "temporary_subscription" ("deletedAt" datetime, "id" varchar PRIMARY KEY NOT NULL, "createdAt" datetime NOT NULL DEFAULT (datetime('now')), "updatedAt" datetime NOT NULL DEFAULT (datetime('now')), "isActive" boolean DEFAULT (1), "isArchived" boolean DEFAULT (0), "archivedAt" datetime, "tenantId" varchar, "organizationId" varchar, "entityId" varchar NOT NULL, "entity" varchar NOT NULL, "type" varchar NOT NULL, "actorType" integer, "employeeId" varchar NOT NULL, CONSTRAINT "FK_8ccdfc22892c16950b568145d53" FOREIGN KEY ("organizationId") REFERENCES "organization" ("id") ON DELETE CASCADE ON UPDATE CASCADE, CONSTRAINT "FK_c86077795cb9a3ce80d19d670a5" FOREIGN KEY ("tenantId") REFERENCES "tenant" ("id") ON DELETE CASCADE ON UPDATE NO ACTION)`
`CREATE TABLE "temporary_subscription" ("deletedAt" datetime, "id" varchar PRIMARY KEY NOT NULL, "createdAt" datetime NOT NULL DEFAULT (datetime('now')), "updatedAt" datetime NOT NULL DEFAULT (datetime('now')), "isActive" boolean DEFAULT (1), "isArchived" boolean DEFAULT (0), "archivedAt" datetime, "tenantId" varchar, "organizationId" varchar, "entityId" varchar NOT NULL, "entity" varchar NOT NULL, "type" varchar NOT NULL, "actorType" integer, "employeeId" varchar, CONSTRAINT "FK_8ccdfc22892c16950b568145d53" FOREIGN KEY ("organizationId") REFERENCES "organization" ("id") ON DELETE CASCADE ON UPDATE CASCADE, CONSTRAINT "FK_c86077795cb9a3ce80d19d670a5" FOREIGN KEY ("tenantId") REFERENCES "tenant" ("id") ON DELETE CASCADE ON UPDATE NO ACTION)`
);
await queryRunner.query(
`INSERT INTO "temporary_subscription"("deletedAt", "id", "createdAt", "updatedAt", "isActive", "isArchived", "archivedAt", "tenantId", "organizationId", "entityId", "entity", "type") SELECT "deletedAt", "id", "createdAt", "updatedAt", "isActive", "isArchived", "archivedAt", "tenantId", "organizationId", "entityId", "entity", "type" FROM "subscription"`
Expand All @@ -174,7 +174,7 @@ export class AlterSubscriptionEntityTable1740723269734 implements MigrationInter
await queryRunner.query(`DROP INDEX "IDX_008f567bd1dc056bf865ff4d71"`);
await queryRunner.query(`DROP INDEX "IDX_1aac6fc0532ebc353f9cd3615b"`);
await queryRunner.query(
`CREATE TABLE "temporary_subscription" ("deletedAt" datetime, "id" varchar PRIMARY KEY NOT NULL, "createdAt" datetime NOT NULL DEFAULT (datetime('now')), "updatedAt" datetime NOT NULL DEFAULT (datetime('now')), "isActive" boolean DEFAULT (1), "isArchived" boolean DEFAULT (0), "archivedAt" datetime, "tenantId" varchar, "organizationId" varchar, "entityId" varchar NOT NULL, "entity" varchar NOT NULL, "type" varchar NOT NULL, "actorType" integer, "employeeId" varchar NOT NULL, CONSTRAINT "FK_8ccdfc22892c16950b568145d53" FOREIGN KEY ("organizationId") REFERENCES "organization" ("id") ON DELETE CASCADE ON UPDATE CASCADE, CONSTRAINT "FK_c86077795cb9a3ce80d19d670a5" FOREIGN KEY ("tenantId") REFERENCES "tenant" ("id") ON DELETE CASCADE ON UPDATE NO ACTION, CONSTRAINT "FK_1aac6fc0532ebc353f9cd3615be" FOREIGN KEY ("employeeId") REFERENCES "employee" ("id") ON DELETE CASCADE ON UPDATE NO ACTION)`
`CREATE TABLE "temporary_subscription" ("deletedAt" datetime, "id" varchar PRIMARY KEY NOT NULL, "createdAt" datetime NOT NULL DEFAULT (datetime('now')), "updatedAt" datetime NOT NULL DEFAULT (datetime('now')), "isActive" boolean DEFAULT (1), "isArchived" boolean DEFAULT (0), "archivedAt" datetime, "tenantId" varchar, "organizationId" varchar, "entityId" varchar NOT NULL, "entity" varchar NOT NULL, "type" varchar NOT NULL, "actorType" integer, "employeeId" varchar, CONSTRAINT "FK_8ccdfc22892c16950b568145d53" FOREIGN KEY ("organizationId") REFERENCES "organization" ("id") ON DELETE CASCADE ON UPDATE CASCADE, CONSTRAINT "FK_c86077795cb9a3ce80d19d670a5" FOREIGN KEY ("tenantId") REFERENCES "tenant" ("id") ON DELETE CASCADE ON UPDATE NO ACTION, CONSTRAINT "FK_1aac6fc0532ebc353f9cd3615be" FOREIGN KEY ("employeeId") REFERENCES "employee" ("id") ON DELETE CASCADE ON UPDATE NO ACTION)`
);
await queryRunner.query(
`INSERT INTO "temporary_subscription"("deletedAt", "id", "createdAt", "updatedAt", "isActive", "isArchived", "archivedAt", "tenantId", "organizationId", "entityId", "entity", "type", "actorType", "employeeId") SELECT "deletedAt", "id", "createdAt", "updatedAt", "isActive", "isArchived", "archivedAt", "tenantId", "organizationId", "entityId", "entity", "type", "actorType", "employeeId" FROM "subscription"`
Expand Down Expand Up @@ -209,7 +209,7 @@ export class AlterSubscriptionEntityTable1740723269734 implements MigrationInter
await queryRunner.query(`DROP INDEX "IDX_ec9817a3b53c5dd074af96276d"`);
await queryRunner.query(`ALTER TABLE "subscription" RENAME TO "temporary_subscription"`);
await queryRunner.query(
`CREATE TABLE "subscription" ("deletedAt" datetime, "id" varchar PRIMARY KEY NOT NULL, "createdAt" datetime NOT NULL DEFAULT (datetime('now')), "updatedAt" datetime NOT NULL DEFAULT (datetime('now')), "isActive" boolean DEFAULT (1), "isArchived" boolean DEFAULT (0), "archivedAt" datetime, "tenantId" varchar, "organizationId" varchar, "entityId" varchar NOT NULL, "entity" varchar NOT NULL, "type" varchar NOT NULL, "actorType" integer, "employeeId" varchar NOT NULL, CONSTRAINT "FK_8ccdfc22892c16950b568145d53" FOREIGN KEY ("organizationId") REFERENCES "organization" ("id") ON DELETE CASCADE ON UPDATE CASCADE, CONSTRAINT "FK_c86077795cb9a3ce80d19d670a5" FOREIGN KEY ("tenantId") REFERENCES "tenant" ("id") ON DELETE CASCADE ON UPDATE NO ACTION)`
`CREATE TABLE "subscription" ("deletedAt" datetime, "id" varchar PRIMARY KEY NOT NULL, "createdAt" datetime NOT NULL DEFAULT (datetime('now')), "updatedAt" datetime NOT NULL DEFAULT (datetime('now')), "isActive" boolean DEFAULT (1), "isArchived" boolean DEFAULT (0), "archivedAt" datetime, "tenantId" varchar, "organizationId" varchar, "entityId" varchar NOT NULL, "entity" varchar NOT NULL, "type" varchar NOT NULL, "actorType" integer, "employeeId" varchar, CONSTRAINT "FK_8ccdfc22892c16950b568145d53" FOREIGN KEY ("organizationId") REFERENCES "organization" ("id") ON DELETE CASCADE ON UPDATE CASCADE, CONSTRAINT "FK_c86077795cb9a3ce80d19d670a5" FOREIGN KEY ("tenantId") REFERENCES "tenant" ("id") ON DELETE CASCADE ON UPDATE NO ACTION)`
);
await queryRunner.query(
`INSERT INTO "subscription"("deletedAt", "id", "createdAt", "updatedAt", "isActive", "isArchived", "archivedAt", "tenantId", "organizationId", "entityId", "entity", "type", "actorType", "employeeId") SELECT "deletedAt", "id", "createdAt", "updatedAt", "isActive", "isArchived", "archivedAt", "tenantId", "organizationId", "entityId", "entity", "type", "actorType", "employeeId" FROM "temporary_subscription"`
Expand Down Expand Up @@ -307,7 +307,7 @@ export class AlterSubscriptionEntityTable1740723269734 implements MigrationInter
await queryRunner.query(`DROP INDEX \`IDX_cc906b4bc892b048f1b654d2aa\` ON \`subscription\``);
await queryRunner.query(`ALTER TABLE \`subscription\` DROP COLUMN \`userId\``);
await queryRunner.query(`ALTER TABLE \`subscription\` ADD \`actorType\` int NULL`);
await queryRunner.query(`ALTER TABLE \`subscription\` ADD \`employeeId\` varchar(255) NOT NULL`);
await queryRunner.query(`ALTER TABLE \`subscription\` ADD \`employeeId\` varchar(255) NULL`);
await queryRunner.query(`CREATE INDEX \`IDX_008f567bd1dc056bf865ff4d71\` ON \`subscription\` (\`actorType\`)`);
await queryRunner.query(`CREATE INDEX \`IDX_1aac6fc0532ebc353f9cd3615b\` ON \`subscription\` (\`employeeId\`)`);
await queryRunner.query(
Expand Down
7 changes: 4 additions & 3 deletions packages/core/src/lib/entity-subscription/entity-subscription.entity.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,7 @@ export class EntitySubscription extends BasePerEntityType implements IEntitySubs
@IsOptional()
@IsObject()
@MultiORMManyToOne(() => Employee, {
nullable: true, // Indicates if relation column value can be null.
onDelete: 'CASCADE' // Database cascade action on delete.
})
@JoinColumn()
Expand All @@ -51,11 +52,11 @@ export class EntitySubscription extends BasePerEntityType implements IEntitySubs
/**
* The employee id who subscribed to the entity.
*/
@ApiProperty({ type: () => String })
@IsNotEmpty()
@ApiPropertyOptional({ type: () => String })
@IsOptional()
@IsUUID()
@RelationId((it: EntitySubscription) => it.employee)
@ColumnIndex()
@MultiORMColumn({ relationId: true })
@MultiORMColumn({ nullable: true, relationId: true })
employeeId?: ID;
}

0 comments on commit db29fb0

Please sign in to comment.