diff --git a/packages/server/api/src/app/database/database-common.ts b/packages/server/api/src/app/database/database-common.ts index 02558cf6a1..0b29ed7eb2 100644 --- a/packages/server/api/src/app/database/database-common.ts +++ b/packages/server/api/src/app/database/database-common.ts @@ -1,5 +1,7 @@ import { EntitySchemaColumnOptions } from 'typeorm' +import { getEdition } from '../helper/secret-helper' import { DatabaseType, system, SystemProp } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' const databaseType = system.get(SystemProp.DB_TYPE) @@ -43,3 +45,7 @@ export const BaseColumnSchemaPart = { updateDate: true, } as EntitySchemaColumnOptions, } + +export function isNotOneOfTheseEditions(editions: ApEdition[]): boolean { + return !editions.includes(getEdition()) +} \ No newline at end of file diff --git a/packages/server/api/src/app/database/database-connection.ts b/packages/server/api/src/app/database/database-connection.ts index fc7773dc93..0d6c5790d5 100644 --- a/packages/server/api/src/app/database/database-connection.ts +++ b/packages/server/api/src/app/database/database-connection.ts @@ -72,25 +72,6 @@ function getEntities(): EntitySchema[] { switch (edition) { case ApEdition.CLOUD: - entities.push( - ProjectMemberEntity, - AppSumoEntity, - ReferralEntity, - ProjectPlanEntity, - FlowTemplateEntity, - ConnectionKeyEntity, - AppCredentialEntity, - CustomDomainEntity, - SigningKeyEntity, - OAuthAppEntity, - OtpEntity, - ApiKeyEntity, - GitRepoEntity, - AuditEventEntity, - ActivityEntity, - ProjectBillingEntity, - ) - break case ApEdition.ENTERPRISE: entities.push( ProjectMemberEntity, @@ -104,6 +85,13 @@ function getEntities(): EntitySchema[] { GitRepoEntity, AuditEventEntity, ActivityEntity, + + // CLOUD + AppSumoEntity, + ReferralEntity, + ConnectionKeyEntity, + AppCredentialEntity, + ProjectBillingEntity, ) break case ApEdition.COMMUNITY: diff --git a/packages/server/api/src/app/database/migration/common/1696245170062-add-piece-type-and-package-type-to-flow-template.ts b/packages/server/api/src/app/database/migration/common/1696245170062-add-piece-type-and-package-type-to-flow-template.ts index f61259432a..7e768a79b9 100644 --- a/packages/server/api/src/app/database/migration/common/1696245170062-add-piece-type-and-package-type-to-flow-template.ts +++ b/packages/server/api/src/app/database/migration/common/1696245170062-add-piece-type-and-package-type-to-flow-template.ts @@ -1,8 +1,13 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class AddPieceTypeAndPackageTypeToFlowTemplate1696245170062 implements MigrationInterface { public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD])) { + return + } const connection = queryRunner.connection const templates = await connection.query('SELECT * FROM flow_template') for (const template of templates) { @@ -21,6 +26,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD])) { + return + } const connection = queryRunner.connection const templates = await connection.query('SELECT * FROM flow_template') for (const template of templates) { diff --git a/packages/server/api/src/app/database/migration/postgres/1698602417745-add-signing-key.ts b/packages/server/api/src/app/database/migration/postgres/1698602417745-add-signing-key.ts index b1c8b256d8..195a109fbd 100644 --- a/packages/server/api/src/app/database/migration/postgres/1698602417745-add-signing-key.ts +++ b/packages/server/api/src/app/database/migration/postgres/1698602417745-add-signing-key.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class AddSigningKey1698602417745 implements MigrationInterface { name = 'AddSigningKey1698602417745' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` CREATE TABLE "signing_key" ( "id" character varying(21) NOT NULL, @@ -30,6 +35,9 @@ export class AddSigningKey1698602417745 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "signing_key" DROP CONSTRAINT "fk_signing_key_generated_by" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1698698190965-AddDisplayNameToSigningKey.ts b/packages/server/api/src/app/database/migration/postgres/1698698190965-AddDisplayNameToSigningKey.ts index 86982a3e76..6d5a57a1db 100644 --- a/packages/server/api/src/app/database/migration/postgres/1698698190965-AddDisplayNameToSigningKey.ts +++ b/packages/server/api/src/app/database/migration/postgres/1698698190965-AddDisplayNameToSigningKey.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddDisplayNameToSigningKey1698698190965 implements MigrationInterface { name = 'AddDisplayNameToSigningKey1698698190965' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "signing_key" ADD "displayName" character varying NOT NULL @@ -12,6 +17,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "signing_key" DROP COLUMN "displayName" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1699221414907-AddOAuth2AppEntiity.ts b/packages/server/api/src/app/database/migration/postgres/1699221414907-AddOAuth2AppEntiity.ts index e5e22d1fe4..aa9bc8abbe 100644 --- a/packages/server/api/src/app/database/migration/postgres/1699221414907-AddOAuth2AppEntiity.ts +++ b/packages/server/api/src/app/database/migration/postgres/1699221414907-AddOAuth2AppEntiity.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddOAuth2AppEntiity1699221414907 implements MigrationInterface { name = 'AddOAuth2AppEntiity1699221414907' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` CREATE TABLE "oauth_app" ( "id" character varying(21) NOT NULL, @@ -26,6 +31,9 @@ export class AddOAuth2AppEntiity1699221414907 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "oauth_app" DROP CONSTRAINT "fk_oauth_app_platform_id" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1699281870038-add-filtered-pieces-to-platform.ts b/packages/server/api/src/app/database/migration/postgres/1699281870038-add-filtered-pieces-to-platform.ts index ee118f4063..0b5576b3ae 100644 --- a/packages/server/api/src/app/database/migration/postgres/1699281870038-add-filtered-pieces-to-platform.ts +++ b/packages/server/api/src/app/database/migration/postgres/1699281870038-add-filtered-pieces-to-platform.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddFilteredPiecesToPlatform1699281870038 implements MigrationInterface { name = 'AddFilteredPiecesToPlatform1699281870038' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" ADD "filteredPieceNames" character varying array, @@ -24,6 +29,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" DROP COLUMN "filteredPieceBehavior" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1699491705906-AddSmtpAndPrivacyUrlToPlatform.ts b/packages/server/api/src/app/database/migration/postgres/1699491705906-AddSmtpAndPrivacyUrlToPlatform.ts index 225d1a8b5e..0246def10c 100644 --- a/packages/server/api/src/app/database/migration/postgres/1699491705906-AddSmtpAndPrivacyUrlToPlatform.ts +++ b/packages/server/api/src/app/database/migration/postgres/1699491705906-AddSmtpAndPrivacyUrlToPlatform.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddSmtpAndPrivacyUrlToPlatform1699491705906 implements MigrationInterface { name = 'AddSmtpAndPrivacyUrlToPlatform1699491705906' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" ADD "smtpHost" character varying @@ -59,6 +64,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" DROP COLUMN "cloudAuthEnabled" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1700132368636-RemoveUnusedFieldsinBilling.ts b/packages/server/api/src/app/database/migration/postgres/1700132368636-RemoveUnusedFieldsinBilling.ts index 6c5e860c86..33aac4ad95 100644 --- a/packages/server/api/src/app/database/migration/postgres/1700132368636-RemoveUnusedFieldsinBilling.ts +++ b/packages/server/api/src/app/database/migration/postgres/1700132368636-RemoveUnusedFieldsinBilling.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class RemoveUnusedFieldsinBilling1700132368636 implements MigrationInterface { name = 'RemoveUnusedFieldsinBilling1700132368636' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "project_plan" DROP COLUMN "activeFlows" `) @@ -37,6 +42,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "project_usage" ADD "bots" integer NOT NULL DEFAULT '0' diff --git a/packages/server/api/src/app/database/migration/postgres/1700396157624-add-otp-entity.ts b/packages/server/api/src/app/database/migration/postgres/1700396157624-add-otp-entity.ts index df5de604eb..02fd711665 100644 --- a/packages/server/api/src/app/database/migration/postgres/1700396157624-add-otp-entity.ts +++ b/packages/server/api/src/app/database/migration/postgres/1700396157624-add-otp-entity.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class AddOtpEntity1700396157624 implements MigrationInterface { name = 'AddOtpEntity1700396157624' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` CREATE TABLE "otp" ( "id" character varying(21) NOT NULL, @@ -28,6 +33,9 @@ export class AddOtpEntity1700396157624 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "otp" DROP CONSTRAINT "fk_otp_user_id" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1700406308445-AddPlatformDefaultLanguage.ts b/packages/server/api/src/app/database/migration/postgres/1700406308445-AddPlatformDefaultLanguage.ts index ed81bb8a0b..f238f07d60 100644 --- a/packages/server/api/src/app/database/migration/postgres/1700406308445-AddPlatformDefaultLanguage.ts +++ b/packages/server/api/src/app/database/migration/postgres/1700406308445-AddPlatformDefaultLanguage.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddPlatformDefaultLanguage1700406308445 implements MigrationInterface { name = 'AddPlatformDefaultLanguage1700406308445' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" ADD "defaultLocale" character varying @@ -12,6 +17,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" DROP COLUMN "defaultLocale" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1700751925992-MakeStripeCustomerIdNullable.ts b/packages/server/api/src/app/database/migration/postgres/1700751925992-MakeStripeCustomerIdNullable.ts index cc05e6aa66..fa4c7d775b 100644 --- a/packages/server/api/src/app/database/migration/postgres/1700751925992-MakeStripeCustomerIdNullable.ts +++ b/packages/server/api/src/app/database/migration/postgres/1700751925992-MakeStripeCustomerIdNullable.ts @@ -1,11 +1,16 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class MakeStripeCustomerIdNullable1700751925992 implements MigrationInterface { name = 'MakeStripeCustomerIdNullable1700751925992' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } logger.info('MakeStripeCustomerIdNullable1700751925992 is up') await queryRunner.query(` ALTER TABLE "project_plan" @@ -18,6 +23,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } logger.info('MakeStripeCustomerIdNullable1700751925992 is down') await queryRunner.query(` ALTER TABLE "project_plan" diff --git a/packages/server/api/src/app/database/migration/postgres/1701084418793-add-state-to-otp.ts b/packages/server/api/src/app/database/migration/postgres/1701084418793-add-state-to-otp.ts index 14404a3c37..28e9518f38 100644 --- a/packages/server/api/src/app/database/migration/postgres/1701084418793-add-state-to-otp.ts +++ b/packages/server/api/src/app/database/migration/postgres/1701084418793-add-state-to-otp.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class AddStateToOtp1701084418793 implements MigrationInterface { name = 'AddStateToOtp1701084418793' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "otp" ADD "state" character varying NOT NULL @@ -14,6 +19,9 @@ export class AddStateToOtp1701084418793 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "otp" DROP COLUMN "state" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1701261357197-migrate-ee-users-to-oldest-platform.ts b/packages/server/api/src/app/database/migration/postgres/1701261357197-migrate-ee-users-to-oldest-platform.ts index a4dfaf3495..b12160e1eb 100644 --- a/packages/server/api/src/app/database/migration/postgres/1701261357197-migrate-ee-users-to-oldest-platform.ts +++ b/packages/server/api/src/app/database/migration/postgres/1701261357197-migrate-ee-users-to-oldest-platform.ts @@ -1,11 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' -import { isNil } from '@activepieces/shared' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition, isNil } from '@activepieces/shared' export class MigrateEeUsersToOldestPlatform1701261357197 implements MigrationInterface { name = 'MigrateEeUsersToOldestPlatform1701261357197' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE])) { + return + } const result = await queryRunner.query(` SELECT * FROM platform @@ -25,6 +29,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` UPDATE "user" SET "platformId" = NULL diff --git a/packages/server/api/src/app/database/migration/postgres/1701647565290-ModifyProjectMembersAndRemoveUserId.ts b/packages/server/api/src/app/database/migration/postgres/1701647565290-ModifyProjectMembersAndRemoveUserId.ts index cc98125e78..5f40c73bfa 100644 --- a/packages/server/api/src/app/database/migration/postgres/1701647565290-ModifyProjectMembersAndRemoveUserId.ts +++ b/packages/server/api/src/app/database/migration/postgres/1701647565290-ModifyProjectMembersAndRemoveUserId.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class ModifyProjectMembersAndRemoveUserId1701647565290 implements MigrationInterface { name = 'ModifyProjectMembersAndRemoveUserId1701647565290' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "project_member" ADD "email" character varying @@ -40,6 +45,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` DROP INDEX "public"."idx_project_member_project_id_email_platform_id" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1701716639135-AddApiKeys.ts b/packages/server/api/src/app/database/migration/postgres/1701716639135-AddApiKeys.ts index 1fa3b122c7..b27497e600 100644 --- a/packages/server/api/src/app/database/migration/postgres/1701716639135-AddApiKeys.ts +++ b/packages/server/api/src/app/database/migration/postgres/1701716639135-AddApiKeys.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddApiKeys1701716639135 implements MigrationInterface { name = 'AddApiKeys1701716639135' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` CREATE TABLE "api_key" ( "id" character varying(21) NOT NULL, @@ -23,6 +28,9 @@ export class AddApiKeys1701716639135 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "api_key" DROP CONSTRAINT "fk_api_key_platform_id" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1701794452891-AddEmbeddingFeatureToPlatform.ts b/packages/server/api/src/app/database/migration/postgres/1701794452891-AddEmbeddingFeatureToPlatform.ts index 708bfca2d4..726644d1b3 100644 --- a/packages/server/api/src/app/database/migration/postgres/1701794452891-AddEmbeddingFeatureToPlatform.ts +++ b/packages/server/api/src/app/database/migration/postgres/1701794452891-AddEmbeddingFeatureToPlatform.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddEmbeddingFeatureToPlatform1701794452891 implements MigrationInterface { name = 'AddEmbeddingFeatureToPlatform1701794452891' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" ADD "embeddingEnabled" boolean NOT NULL DEFAULT true @@ -17,6 +22,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" DROP COLUMN "embeddingEnabled" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1703411318826-AddPlatformIdToFlowTemplates.ts b/packages/server/api/src/app/database/migration/postgres/1703411318826-AddPlatformIdToFlowTemplates.ts index 0adcba7011..c09d77ae5d 100644 --- a/packages/server/api/src/app/database/migration/postgres/1703411318826-AddPlatformIdToFlowTemplates.ts +++ b/packages/server/api/src/app/database/migration/postgres/1703411318826-AddPlatformIdToFlowTemplates.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddPlatformIdToFlowTemplates1703411318826 implements MigrationInterface { name = 'AddPlatformIdToFlowTemplates1703411318826' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "flow_template" DROP CONSTRAINT "fk_flow_template_user_id" `) @@ -50,6 +55,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "flow_template" DROP CONSTRAINT "fk_flow_template_platform_id" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1704503804056-AddGitRepoMigrationPostgres.ts b/packages/server/api/src/app/database/migration/postgres/1704503804056-AddGitRepoMigrationPostgres.ts index da61d67ee5..c43e01dbbb 100644 --- a/packages/server/api/src/app/database/migration/postgres/1704503804056-AddGitRepoMigrationPostgres.ts +++ b/packages/server/api/src/app/database/migration/postgres/1704503804056-AddGitRepoMigrationPostgres.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddGitRepoMigrationPostgres1704503804056 implements MigrationInterface { name = 'AddGitRepoMigrationPostgres1704503804056' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` CREATE TABLE "git_repo" ( "id" character varying(21) NOT NULL, @@ -28,6 +33,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "git_repo" DROP CONSTRAINT "fk_git_repo_project_id" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1704636362533-AddGitSyncEnabledToPlatform.ts b/packages/server/api/src/app/database/migration/postgres/1704636362533-AddGitSyncEnabledToPlatform.ts index 801c9b3f94..03de016a52 100644 --- a/packages/server/api/src/app/database/migration/postgres/1704636362533-AddGitSyncEnabledToPlatform.ts +++ b/packages/server/api/src/app/database/migration/postgres/1704636362533-AddGitSyncEnabledToPlatform.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddGitSyncEnabledToPlatform1704636362533 implements MigrationInterface { name = 'AddGitSyncEnabledToPlatform1704636362533' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" ADD "gitSyncEnabled" boolean @@ -22,6 +27,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" DROP COLUMN "gitSyncEnabled" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1704667304953-AddAuthOptionsToPlatform.ts b/packages/server/api/src/app/database/migration/postgres/1704667304953-AddAuthOptionsToPlatform.ts index 7168c48722..18ade102c6 100644 --- a/packages/server/api/src/app/database/migration/postgres/1704667304953-AddAuthOptionsToPlatform.ts +++ b/packages/server/api/src/app/database/migration/postgres/1704667304953-AddAuthOptionsToPlatform.ts @@ -1,11 +1,16 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddAuthOptionsToPlatform1704667304953 implements MigrationInterface { name = 'AddAuthOptionsToPlatform1704667304953' public async up(queryRunner: QueryRunner): Promise { - // allowedAuthDomains + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } + // allowedAuthDomains await queryRunner.query(` ALTER TABLE "platform" ADD COLUMN "allowedAuthDomains" character varying[] @@ -60,6 +65,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" DROP COLUMN "federatedAuthProviders" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1704797979825-AddEnableEmailAuthToPlatform.ts b/packages/server/api/src/app/database/migration/postgres/1704797979825-AddEnableEmailAuthToPlatform.ts index c328e6d9d3..6cbe8d1648 100644 --- a/packages/server/api/src/app/database/migration/postgres/1704797979825-AddEnableEmailAuthToPlatform.ts +++ b/packages/server/api/src/app/database/migration/postgres/1704797979825-AddEnableEmailAuthToPlatform.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddEnableEmailAuthToPlatform1704797979825 implements MigrationInterface { name = 'AddEnableEmailAuthToPlatform1704797979825' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query( 'ALTER TABLE "platform" ADD "emailAuthEnabled" boolean', ) @@ -15,6 +20,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" DROP COLUMN "emailAuthEnabled" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1705586178452-RemoveUniqueonAppNameAppCredentials.ts b/packages/server/api/src/app/database/migration/postgres/1705586178452-RemoveUniqueonAppNameAppCredentials.ts index 95b8418c37..5f81fdc246 100644 --- a/packages/server/api/src/app/database/migration/postgres/1705586178452-RemoveUniqueonAppNameAppCredentials.ts +++ b/packages/server/api/src/app/database/migration/postgres/1705586178452-RemoveUniqueonAppNameAppCredentials.ts @@ -1,16 +1,24 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class RemoveUniqueonAppNameAppCredentials1705586178452 implements MigrationInterface { name = 'RemoveUniqueonAppNameAppCredentials1705586178452' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD])) { + return + } await queryRunner.query(` DROP INDEX "public"."idx_app_credentials_projectId_appName" `) } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD])) { + return + } await queryRunner.query(` CREATE UNIQUE INDEX "idx_app_credentials_projectId_appName" ON "app_credential" ("appName", "projectId") `) diff --git a/packages/server/api/src/app/database/migration/postgres/1705969874745-MakePlatformNotNullable.ts b/packages/server/api/src/app/database/migration/postgres/1705969874745-MakePlatformNotNullable.ts index d4bce4552f..82a86f06b2 100644 --- a/packages/server/api/src/app/database/migration/postgres/1705969874745-MakePlatformNotNullable.ts +++ b/packages/server/api/src/app/database/migration/postgres/1705969874745-MakePlatformNotNullable.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class MakePlatformNotNullable1705969874745 implements MigrationInterface { name = 'MakePlatformNotNullable1705969874745' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "project" DROP COLUMN "type" `) @@ -25,6 +30,9 @@ export class MakePlatformNotNullable1705969874745 implements MigrationInterface } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "project" DROP CONSTRAINT "fk_project_platform_id" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1707614902283-AddAuditEvents.ts b/packages/server/api/src/app/database/migration/postgres/1707614902283-AddAuditEvents.ts index eb2e814119..93b9c20c13 100644 --- a/packages/server/api/src/app/database/migration/postgres/1707614902283-AddAuditEvents.ts +++ b/packages/server/api/src/app/database/migration/postgres/1707614902283-AddAuditEvents.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddAuditEvents1707614902283 implements MigrationInterface { name = 'AddAuditEvents1707614902283' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` CREATE TABLE "audit_event" ( "id" character varying(21) NOT NULL, @@ -45,6 +50,9 @@ export class AddAuditEvents1707614902283 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" DROP COLUMN "auditLogEnabled" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1708515756040-create-activity-table.ts b/packages/server/api/src/app/database/migration/postgres/1708515756040-create-activity-table.ts index f3808aa23f..33564cfa3b 100644 --- a/packages/server/api/src/app/database/migration/postgres/1708515756040-create-activity-table.ts +++ b/packages/server/api/src/app/database/migration/postgres/1708515756040-create-activity-table.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class CreateActivityTable1708515756040 implements MigrationInterface { name = 'CreateActivityTable1708515756040' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` CREATE TABLE "activity" ( "id" character varying(21) NOT NULL, @@ -29,6 +34,9 @@ export class CreateActivityTable1708515756040 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "activity" DROP CONSTRAINT "fk_activity_project_id" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1708529586342-add-length-limits-to-activity.ts b/packages/server/api/src/app/database/migration/postgres/1708529586342-add-length-limits-to-activity.ts index f49e26e054..04d10cbc14 100644 --- a/packages/server/api/src/app/database/migration/postgres/1708529586342-add-length-limits-to-activity.ts +++ b/packages/server/api/src/app/database/migration/postgres/1708529586342-add-length-limits-to-activity.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class AddLengthLimitsToActivity1708529586342 implements MigrationInterface { name = 'AddLengthLimitsToActivity1708529586342' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "activity" ALTER COLUMN "event" TYPE character varying(200) USING "event"::character varying(200), @@ -16,6 +21,9 @@ export class AddLengthLimitsToActivity1708529586342 implements MigrationInterfac } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "activity" ALTER COLUMN "event" TYPE character varying USING "event"::character varying, diff --git a/packages/server/api/src/app/database/migration/postgres/1708811745694-AddProjectBilling.ts b/packages/server/api/src/app/database/migration/postgres/1708811745694-AddProjectBilling.ts index 7f164ff112..0a908d2f64 100644 --- a/packages/server/api/src/app/database/migration/postgres/1708811745694-AddProjectBilling.ts +++ b/packages/server/api/src/app/database/migration/postgres/1708811745694-AddProjectBilling.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddProjectBilling1708811745694 implements MigrationInterface { name = 'AddProjectBilling1708811745694' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` CREATE TABLE "project_billing" ( "id" character varying(21) NOT NULL, @@ -29,6 +34,9 @@ export class AddProjectBilling1708811745694 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD])) { + return + } await queryRunner.query(` ALTER TABLE "project_billing" DROP CONSTRAINT "fk_project_stripe_project_id" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1708861032399-add-show-activity-log-to-platform.ts b/packages/server/api/src/app/database/migration/postgres/1708861032399-add-show-activity-log-to-platform.ts index 0702e7525a..ecacac9ebf 100644 --- a/packages/server/api/src/app/database/migration/postgres/1708861032399-add-show-activity-log-to-platform.ts +++ b/packages/server/api/src/app/database/migration/postgres/1708861032399-add-show-activity-log-to-platform.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class AddShowActivityLogToPlatform1708861032399 implements MigrationInterface { name = 'AddShowActivityLogToPlatform1708861032399' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" ADD "showActivityLog" boolean @@ -24,6 +29,9 @@ export class AddShowActivityLogToPlatform1708861032399 implements MigrationInter } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" DROP COLUMN "showActivityLog" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1709151540095-add-slug-to-git-repo.ts b/packages/server/api/src/app/database/migration/postgres/1709151540095-add-slug-to-git-repo.ts index a99ce47b7d..08b989aec4 100644 --- a/packages/server/api/src/app/database/migration/postgres/1709151540095-add-slug-to-git-repo.ts +++ b/packages/server/api/src/app/database/migration/postgres/1709151540095-add-slug-to-git-repo.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class AddSlugToGitRepo1709151540095 implements MigrationInterface { name = 'AddSlugToGitRepo1709151540095' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "git_repo" ADD "slug" character varying @@ -24,6 +29,9 @@ export class AddSlugToGitRepo1709151540095 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "git_repo" DROP COLUMN "slug" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1709500213947-add-user-email-to-referral.ts b/packages/server/api/src/app/database/migration/postgres/1709500213947-add-user-email-to-referral.ts index e1b833f5d8..b9edbb2de6 100644 --- a/packages/server/api/src/app/database/migration/postgres/1709500213947-add-user-email-to-referral.ts +++ b/packages/server/api/src/app/database/migration/postgres/1709500213947-add-user-email-to-referral.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class AddUserEmailToReferral1709500213947 implements MigrationInterface { name = 'AddUserEmailToReferral1709500213947' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "referal" ADD "referredUserEmail" character varying(500) @@ -69,6 +74,9 @@ export class AddUserEmailToReferral1709500213947 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD])) { + return + } await queryRunner.query(` ALTER TABLE "referal" DROP CONSTRAINT "fk_referral_referring_user_id" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1709500873378-DropUnusedPlatformIndex.ts b/packages/server/api/src/app/database/migration/postgres/1709500873378-DropUnusedPlatformIndex.ts index d85ea24d74..d900649820 100644 --- a/packages/server/api/src/app/database/migration/postgres/1709500873378-DropUnusedPlatformIndex.ts +++ b/packages/server/api/src/app/database/migration/postgres/1709500873378-DropUnusedPlatformIndex.ts @@ -1,15 +1,23 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class DropUnusedPlatformIndex1709500873378 implements MigrationInterface { name = 'DropUnusedPlatformIndex1709500873378' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "project" DROP CONSTRAINT "fk_project_platform_id" `) } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "project" ADD CONSTRAINT "fk_project_platform_id" FOREIGN KEY ("platformId") REFERENCES "platform"("id") ON DELETE NO ACTION ON UPDATE NO ACTION diff --git a/packages/server/api/src/app/database/migration/postgres/1709566642531-add-platform-foreign-key-to-project-postgres.ts b/packages/server/api/src/app/database/migration/postgres/1709566642531-add-platform-foreign-key-to-project-postgres.ts index bd2c7ca7dc..220f003e0d 100644 --- a/packages/server/api/src/app/database/migration/postgres/1709566642531-add-platform-foreign-key-to-project-postgres.ts +++ b/packages/server/api/src/app/database/migration/postgres/1709566642531-add-platform-foreign-key-to-project-postgres.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class AddPlatformForeignKeyToProjectPostgres1709566642531 implements MigrationInterface { name = 'AddPlatformForeignKeyToProjectPostgres1709566642531' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "project" ADD CONSTRAINT "fk_project_platform_id" FOREIGN KEY ("platformId") REFERENCES "platform"("id") @@ -15,6 +20,9 @@ export class AddPlatformForeignKeyToProjectPostgres1709566642531 implements Migr } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "project" DROP CONSTRAINT "fk_project_platform_id" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1709581196564-migrate-webhook-templates.ts b/packages/server/api/src/app/database/migration/postgres/1709581196564-migrate-webhook-templates.ts index b72bc659da..739869770a 100644 --- a/packages/server/api/src/app/database/migration/postgres/1709581196564-migrate-webhook-templates.ts +++ b/packages/server/api/src/app/database/migration/postgres/1709581196564-migrate-webhook-templates.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class MigrateWebhookTemplate1709581196564 implements MigrationInterface { name = 'MigrateWebhookTemplate1709581196564' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } logger.info('MigrateWebhookTemplate1709581196564, started') let count = 0 @@ -39,6 +44,9 @@ export class MigrateWebhookTemplate1709581196564 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } logger.info('rolling back MigrateWebhookTemplate1709581196564, started') let count = 0 diff --git a/packages/server/api/src/app/database/migration/postgres/1709669091258-move-generated-by-from-signing-key-to-audit-event-postgres.ts b/packages/server/api/src/app/database/migration/postgres/1709669091258-move-generated-by-from-signing-key-to-audit-event-postgres.ts index d76312ec7d..8a6f71ec4f 100644 --- a/packages/server/api/src/app/database/migration/postgres/1709669091258-move-generated-by-from-signing-key-to-audit-event-postgres.ts +++ b/packages/server/api/src/app/database/migration/postgres/1709669091258-move-generated-by-from-signing-key-to-audit-event-postgres.ts @@ -1,11 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' -import { apId } from '@activepieces/shared' +import { ApEdition, apId } from '@activepieces/shared' export class MoveGeneratedByFromSigningKeyToAuditEventPostgres1709669091258 implements MigrationInterface { name = 'MoveGeneratedByFromSigningKeyToAuditEventPostgres1709669091258' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } const ids = await getAllSigningKeyIds(queryRunner) for (const id of ids) { @@ -24,6 +28,9 @@ export class MoveGeneratedByFromSigningKeyToAuditEventPostgres1709669091258 impl } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "signing_key" ADD "generatedBy" character varying(21) diff --git a/packages/server/api/src/app/database/migration/postgres/1709753080714-AddMappingStateToGit.ts b/packages/server/api/src/app/database/migration/postgres/1709753080714-AddMappingStateToGit.ts index 0c39355b00..a9d9d5d440 100644 --- a/packages/server/api/src/app/database/migration/postgres/1709753080714-AddMappingStateToGit.ts +++ b/packages/server/api/src/app/database/migration/postgres/1709753080714-AddMappingStateToGit.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddMappingStateToGit1709753080714 implements MigrationInterface { name = 'AddMappingStateToGit1709753080714' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "git_repo" ADD "mapping" jsonb @@ -11,6 +16,9 @@ export class AddMappingStateToGit1709753080714 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "git_repo" DROP COLUMN "mapping" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1710720610669-cascade-project-delete-app-credentials-and-connection-key.ts b/packages/server/api/src/app/database/migration/postgres/1710720610669-cascade-project-delete-app-credentials-and-connection-key.ts index 297210c585..432617304f 100644 --- a/packages/server/api/src/app/database/migration/postgres/1710720610669-cascade-project-delete-app-credentials-and-connection-key.ts +++ b/packages/server/api/src/app/database/migration/postgres/1710720610669-cascade-project-delete-app-credentials-and-connection-key.ts @@ -1,10 +1,21 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class CascadeProjectDeleteAppCredentialsAndConnectionKey1710720610669 implements MigrationInterface { name = 'CascadeProjectDeleteAppCredentialsAndConnectionKey1710720610669' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD])) { + return + } + await queryRunner.query(` + ALTER TABLE "connection_key" DROP CONSTRAINT "FK_03177dc6779e6e147866d43c050" + `) + await queryRunner.query(` + ALTER TABLE "app_credential" DROP CONSTRAINT "FK_d82bfb4c7432a69dc2419083a0e" + `) await queryRunner.query(` ALTER TABLE "connection_key" ADD CONSTRAINT "FK_03177dc6779e6e147866d43c050" FOREIGN KEY ("projectId") REFERENCES "project"("id") @@ -23,7 +34,15 @@ export class CascadeProjectDeleteAppCredentialsAndConnectionKey1710720610669 imp } public async down(queryRunner: QueryRunner): Promise { - + if (isNotOneOfTheseEditions([ApEdition.CLOUD])) { + return + } + await queryRunner.query(` + ALTER TABLE "app_credential" DROP CONSTRAINT "FK_d82bfb4c7432a69dc2419083a0e" + `) + await queryRunner.query(` + ALTER TABLE "connection_key" DROP CONSTRAINT "FK_03177dc6779e6e147866d43c050" + `) await queryRunner.query(` ALTER TABLE "app_credential" DROP CONSTRAINT "FK_d82bfb4c7432a69dc2419083a0e" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1710720610670-cascade-project-delete-activity.ts b/packages/server/api/src/app/database/migration/postgres/1710720610670-cascade-project-delete-activity.ts index d5d0e05227..351d632f29 100644 --- a/packages/server/api/src/app/database/migration/postgres/1710720610670-cascade-project-delete-activity.ts +++ b/packages/server/api/src/app/database/migration/postgres/1710720610670-cascade-project-delete-activity.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class CascadeProjectDeleteToActivity1710720610670 implements MigrationInterface { name = 'CascadeProjectDeleteToActivity1710720610670' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "activity" DROP CONSTRAINT "fk_activity_project_id" `) @@ -18,6 +23,9 @@ export class CascadeProjectDeleteToActivity1710720610670 implements MigrationInt } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "activity" DROP CONSTRAINT "fk_activity_project_id" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1711073772867-AddBranchTypeToGit.ts b/packages/server/api/src/app/database/migration/postgres/1711073772867-AddBranchTypeToGit.ts index 5943925150..5ba7fd0613 100644 --- a/packages/server/api/src/app/database/migration/postgres/1711073772867-AddBranchTypeToGit.ts +++ b/packages/server/api/src/app/database/migration/postgres/1711073772867-AddBranchTypeToGit.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' export class AddBranchTypeToGit1711073772867 implements MigrationInterface { name = 'AddBranchTypeToGit1711073772867' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "git_repo" ADD COLUMN "branchType" character varying DEFAULT 'DEVELOPMENT'; @@ -22,6 +27,9 @@ export class AddBranchTypeToGit1711073772867 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "git_repo" DROP COLUMN "branchType" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1712279318440-PiecesProjectLimits.ts b/packages/server/api/src/app/database/migration/postgres/1712279318440-PiecesProjectLimits.ts index 5910fa87fb..f0e3883e1d 100644 --- a/packages/server/api/src/app/database/migration/postgres/1712279318440-PiecesProjectLimits.ts +++ b/packages/server/api/src/app/database/migration/postgres/1712279318440-PiecesProjectLimits.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class PiecesProjectLimits1712279318440 implements MigrationInterface { name = 'PiecesProjectLimits1712279318440' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } logger.info({ name: 'PiecesProjectLimits1712279318440' }, 'up') @@ -54,6 +59,9 @@ export class PiecesProjectLimits1712279318440 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "project_plan" RENAME COLUMN "name" TO "flowPlanName" `) diff --git a/packages/server/api/src/app/database/migration/postgres/1714249840058-UnifyEnterpriseWithCloud.ts b/packages/server/api/src/app/database/migration/postgres/1714249840058-UnifyEnterpriseWithCloud.ts new file mode 100644 index 0000000000..01e0689466 --- /dev/null +++ b/packages/server/api/src/app/database/migration/postgres/1714249840058-UnifyEnterpriseWithCloud.ts @@ -0,0 +1,54 @@ +import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../database-common' +import { ApEdition } from '@activepieces/shared' + +export class UnifyEnterpriseWithCloud1714249840058 implements MigrationInterface { + name = 'UnifyEnterpriseWithCloud1714249840058' + + public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE])) { + return + } + await queryRunner.query(` + ALTER TABLE "connection_key" DROP CONSTRAINT "FK_03177dc6779e6e147866d43c050" + `) + await queryRunner.query(` + ALTER TABLE "app_credential" DROP CONSTRAINT "FK_d82bfb4c7432a69dc2419083a0e" + `) + await queryRunner.query(` + DROP INDEX "public"."idx_app_credentials_projectId_appName" + `) + await queryRunner.query(` + ALTER TABLE "connection_key" + ADD CONSTRAINT "FK_03177dc6779e6e147866d43c050" FOREIGN KEY ("projectId") REFERENCES "project"("id") ON DELETE CASCADE ON UPDATE NO ACTION + `) + await queryRunner.query(` + ALTER TABLE "app_credential" + ADD CONSTRAINT "FK_d82bfb4c7432a69dc2419083a0e" FOREIGN KEY ("projectId") REFERENCES "project"("id") ON DELETE CASCADE ON UPDATE NO ACTION + `) + } + + public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE])) { + return + } + await queryRunner.query(` + ALTER TABLE "app_credential" DROP CONSTRAINT "FK_d82bfb4c7432a69dc2419083a0e" + `) + await queryRunner.query(` + ALTER TABLE "connection_key" DROP CONSTRAINT "FK_03177dc6779e6e147866d43c050" + `) + await queryRunner.query(` + CREATE UNIQUE INDEX "idx_app_credentials_projectId_appName" ON "app_credential" ("appName", "projectId") + `) + await queryRunner.query(` + ALTER TABLE "app_credential" + ADD CONSTRAINT "FK_d82bfb4c7432a69dc2419083a0e" FOREIGN KEY ("projectId") REFERENCES "project"("id") ON DELETE NO ACTION ON UPDATE NO ACTION + `) + await queryRunner.query(` + ALTER TABLE "connection_key" + ADD CONSTRAINT "FK_03177dc6779e6e147866d43c050" FOREIGN KEY ("projectId") REFERENCES "project"("id") ON DELETE NO ACTION ON UPDATE NO ACTION + `) + } + +} diff --git a/packages/server/api/src/app/database/postgres-connection.ts b/packages/server/api/src/app/database/postgres-connection.ts index af630e0c0a..8e443d979c 100644 --- a/packages/server/api/src/app/database/postgres-connection.ts +++ b/packages/server/api/src/app/database/postgres-connection.ts @@ -129,6 +129,7 @@ import { RemoveUniqueEmailOnUser1713221809186 } from './migration/postgres/17132 import { AddPlatformRoleToUser1713302610746 } from './migration/postgres/1713302610746-AddPlatformRoleToUser' import { AddUniqueNameToFolder1713643694049 } from './migration/postgres/1713643694049-AddUniqueNameToFolder' import { AddFeaturesToPlatform1714145914415 } from './migration/postgres/1714145914415-AddFeaturesToPlatform' +import { UnifyEnterpriseWithCloud1714249840058 } from './migration/postgres/1714249840058-UnifyEnterpriseWithCloud' import { system, SystemProp } from '@activepieces/server-shared' import { ApEdition, ApEnvironment, isNil } from '@activepieces/shared' @@ -219,65 +220,6 @@ const getMigrations = (): (new () => MigrationInterface)[] => { const edition = getEdition() switch (edition) { case ApEdition.CLOUD: - commonMigration.push( - MakeStripeSubscriptionNullable1685053959806, - AddTemplates1685538145476, - ChangeToJsonToKeepKeysOrder1685991260335, - AddPinnedAndBlogUrlToTemplates1686133672743, - AddPinnedOrder1686154285890, - AddProjectIdToTemplate1688083336934, - AddBillingParameters1688739844617, - AddAppSumo1688943462327, - AddProjectMembers1689177797092, - AddTasksPerDays1689336533370, - RemoveCalculatedMetrics1689806173642, - AddReferral1690459469381, - ProjectMemberRelations1694381968985, - FlowTemplateAddUserIdAndImageUrl1694379223109, - AddFeaturedDescriptionAndFlagToTemplates1694604120205, - ModifyBilling1694902537045, - AddDatasourcesLimit1695916063833, - AddPieceTypeAndPackageTypeToFlowTemplate1696245170062, - AddPlatform1697717995884, - AddCustomDomain1698077078271, - AddSigningKey1698602417745, - AddDisplayNameToSigningKey1698698190965, - AddOAuth2AppEntiity1699221414907, - AddFilteredPiecesToPlatform1699281870038, - AddSmtpAndPrivacyUrlToPlatform1699491705906, - RemoveUnusedFieldsinBilling1700132368636, - AddOtpEntity1700396157624, - AddPlatformDefaultLanguage1700406308445, - MakeStripeCustomerIdNullable1700751925992, - AddStateToOtp1701084418793, - ModifyProjectMembersAndRemoveUserId1701647565290, - AddApiKeys1701716639135, - AddEmbeddingFeatureToPlatform1701794452891, - AddPlatformIdToFlowTemplates1703411318826, - AddAuthOptionsToPlatform1704667304953, - AddEnableEmailAuthToPlatform1704797979825, - AddGitRepoMigrationPostgres1704503804056, - AddGitSyncEnabledToPlatform1704636362533, - RemoveUniqueonAppNameAppCredentials1705586178452, - AddAuditEvents1707614902283, - CreateActivityTable1708515756040, - AddLengthLimitsToActivity1708529586342, - AddProjectBilling1708811745694, - AddShowActivityLogToPlatform1708861032399, - MakePlatformNotNullable1705969874745, - AddSlugToGitRepo1709151540095, - DropUnusedPlatformIndex1709500873378, - MigrateWebhookTemplate1709581196564, - AddPlatformForeignKeyToProjectPostgres1709566642531, - AddUserEmailToReferral1709500213947, - MoveGeneratedByFromSigningKeyToAuditEventPostgres1709669091258, - AddMappingStateToGit1709753080714, - CascadeProjectDeleteAppCredentialsAndConnectionKey1710720610669, - CascadeProjectDeleteToActivity1710720610670, - AddBranchTypeToGit1711073772867, - PiecesProjectLimits1712279318440, - ) - break case ApEdition.ENTERPRISE: commonMigration.push( AddTemplates1685538145476, @@ -306,7 +248,6 @@ const getMigrations = (): (new () => MigrationInterface)[] => { AddDatasourcesLimit1695916063833, MakeStripeCustomerIdNullable1700751925992, AddStateToOtp1701084418793, - MigrateEeUsersToOldestPlatform1701261357197, ModifyProjectMembersAndRemoveUserId1701647565290, AddApiKeys1701716639135, AddEmbeddingFeatureToPlatform1701794452891, @@ -329,6 +270,22 @@ const getMigrations = (): (new () => MigrationInterface)[] => { CascadeProjectDeleteToActivity1710720610670, AddBranchTypeToGit1711073772867, PiecesProjectLimits1712279318440, + // Cloud Only Migrations, before unifing the migrations. + ChangeToJsonToKeepKeysOrder1685991260335, + AddPieceTypeAndPackageTypeToFlowTemplate1696245170062, + RemoveUniqueonAppNameAppCredentials1705586178452, + CascadeProjectDeleteAppCredentialsAndConnectionKey1710720610669, + + // Enterprise Only Migrations, before unifing the migrations. + MigrateEeUsersToOldestPlatform1701261357197, + UnifyEnterpriseWithCloud1714249840058, + + // Cloud Only Entities, But we need to run them for Enterprise as well. + AddAppSumo1688943462327, + AddReferral1690459469381, + AddUserEmailToReferral1709500213947, + AddProjectBilling1708811745694, + ) break case ApEdition.COMMUNITY: diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1685053959806-MakeStripeSubscriptionNullable.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1685053959806-MakeStripeSubscriptionNullable.ts index ca8f0a02b6..74398e283d 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1685053959806-MakeStripeSubscriptionNullable.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1685053959806-MakeStripeSubscriptionNullable.ts @@ -1,16 +1,24 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class MakeStripeSubscriptionNullable1685053959806 implements MigrationInterface { name = 'MakeStripeSubscriptionNullable1685053959806' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "project_plan" ALTER COLUMN "stripeSubscriptionId" DROP NOT NULL', ) } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "project_plan" ADD "name" character varying NOT NULL', ) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1685538145476-addTemplates.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1685538145476-addTemplates.ts index ae1dc2ad8c..d27ff149f6 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1685538145476-addTemplates.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1685538145476-addTemplates.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class AddTemplates1685538145476 implements MigrationInterface { name = 'AddTemplates1685538145476' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'CREATE TABLE "flow_template" ("id" character varying(21) NOT NULL, "created" TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT now(), "updated" TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT now(), "name" character varying NOT NULL, "description" character varying NOT NULL, "template" jsonb NOT NULL, "tags" character varying array NOT NULL, "pieces" character varying array NOT NULL, CONSTRAINT "PK_fcacbf8776a0a3337eb8eca7478" PRIMARY KEY ("id"))', ) @@ -16,6 +21,9 @@ export class AddTemplates1685538145476 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query('DROP INDEX "public"."idx_flow_template_pieces"') await queryRunner.query('DROP INDEX "public"."idx_flow_template_tags"') await queryRunner.query('DROP TABLE "flow_template"') diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1685991260335-ChangeToJsonToPeserveKeys.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1685991260335-ChangeToJsonToPeserveKeys.ts index 1e277a58bb..aeca997d66 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1685991260335-ChangeToJsonToPeserveKeys.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1685991260335-ChangeToJsonToPeserveKeys.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class ChangeToJsonToKeepKeysOrder1685991260335 implements MigrationInterface { name = 'ChangeToJsonToKeepKeysOrder1685991260335' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "piece_metadata" DROP COLUMN "actions"', ) @@ -20,6 +25,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "piece_metadata" DROP COLUMN "triggers"', ) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1686133672743-AddPinnedAndBlogUrlToTemplates.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1686133672743-AddPinnedAndBlogUrlToTemplates.ts index 62c34764b1..dc570ffdac 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1686133672743-AddPinnedAndBlogUrlToTemplates.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1686133672743-AddPinnedAndBlogUrlToTemplates.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class AddPinnedAndBlogUrlToTemplates1686133672743 implements MigrationInterface { name = 'AddPinnedAndBlogUrlToTemplates1686133672743' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "flow_template" ADD "pinned" boolean NOT NULL', ) @@ -14,6 +19,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "flow_template" DROP COLUMN "blogUrl"', ) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1686154285890-add_pinned_order.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1686154285890-add_pinned_order.ts index c30ea15adc..02b7dfddef 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1686154285890-add_pinned_order.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1686154285890-add_pinned_order.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class AddPinnedOrder1686154285890 implements MigrationInterface { name = 'AddPinnedOrder1686154285890' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query('ALTER TABLE "flow_template" DROP COLUMN "pinned"') await queryRunner.query( 'ALTER TABLE "flow_template" ADD "pinnedOrder" integer', @@ -14,6 +19,9 @@ export class AddPinnedOrder1686154285890 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "flow_template" ALTER COLUMN "blogUrl" SET NOT NULL', ) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1688083336934-AddProjectIdToTemplate.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1688083336934-AddProjectIdToTemplate.ts index c0827c5215..eeb3a65ffa 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1688083336934-AddProjectIdToTemplate.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1688083336934-AddProjectIdToTemplate.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class AddProjectIdToTemplate1688083336934 implements MigrationInterface { name = 'AddProjectIdToTemplate1688083336934' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } logger.info('Running migration AddProjectIdToTemplate1688083336934') await queryRunner.query( 'ALTER TABLE "flow_template" ADD "projectId" character varying', @@ -16,6 +21,9 @@ export class AddProjectIdToTemplate1688083336934 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "flow_template" DROP CONSTRAINT "fk_flow_template_project_id"', ) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1688739844617-AddBillingParameters.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1688739844617-AddBillingParameters.ts index 6791fe84b2..aec1d1afb5 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1688739844617-AddBillingParameters.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1688739844617-AddBillingParameters.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class AddBillingParameters1688739844617 implements MigrationInterface { name = 'AddBillingParameters1688739844617' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "project_plan" ADD "minimumPollingInterval" integer NOT NULL DEFAULT 5', ) @@ -28,6 +33,9 @@ export class AddBillingParameters1688739844617 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "project_usage" DROP COLUMN "teamMembers"', ) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1688943462327-AddAppSumo.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1688943462327-AddAppSumo.ts index ef6771f316..4d54cb207e 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1688943462327-AddAppSumo.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1688943462327-AddAppSumo.ts @@ -1,15 +1,23 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class AddAppSumo1688943462327 implements MigrationInterface { name = 'AddAppSumo1688943462327' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query( 'CREATE TABLE "appsumo" ("uuid" character varying NOT NULL, "plan_id" character varying NOT NULL, "activation_email" character varying NOT NULL, CONSTRAINT "PK_3589df5be2973351814f727ae86" PRIMARY KEY ("uuid"))', ) } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query('DROP TABLE "appsumo"') } } diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1689177797092-AddProjectMembers.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1689177797092-AddProjectMembers.ts index 0e762237cf..4c2e8826be 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1689177797092-AddProjectMembers.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1689177797092-AddProjectMembers.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class AddProjectMembers1689177797092 implements MigrationInterface { name = 'AddProjectMembers1689177797092' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'CREATE TABLE "project_member" ("id" character varying(21) NOT NULL, "created" TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT now(), "updated" TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT now(), "userId" character varying(21) NOT NULL, "projectId" character varying(21) NOT NULL, "role" character varying NOT NULL, "status" character varying NOT NULL, CONSTRAINT "PK_64dba8e9dcf96ce383cfd19d6fb" PRIMARY KEY ("id"))', ) @@ -13,6 +18,9 @@ export class AddProjectMembers1689177797092 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'DROP INDEX "public"."idx_project_member_project_id_user_id"', ) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1689336533370-AddTasksPerDays.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1689336533370-AddTasksPerDays.ts index ec606468c3..05287ba3e2 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1689336533370-AddTasksPerDays.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1689336533370-AddTasksPerDays.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class AddTasksPerDays1689336533370 implements MigrationInterface { name = 'AddTasksPerDays1689336533370' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "project_plan" ADD "tasksPerDay" integer', ) @@ -31,6 +36,9 @@ export class AddTasksPerDays1689336533370 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "project_usage" ALTER COLUMN "teamMembers" SET DEFAULT \'0\'', ) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1689806173642-RemoveCalculatedMetrics.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1689806173642-RemoveCalculatedMetrics.ts index ef29637711..5f88c06251 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1689806173642-RemoveCalculatedMetrics.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1689806173642-RemoveCalculatedMetrics.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class RemoveCalculatedMetrics1689806173642 implements MigrationInterface { name = 'RemoveCalculatedMetrics1689806173642' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query( 'ALTER TABLE "project_usage" DROP COLUMN "activeFlows"', ) @@ -17,6 +22,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query( 'ALTER TABLE "project_usage" ADD "teamMembers" integer NOT NULL', ) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1690459469381-AddReferral.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1690459469381-AddReferral.ts index a19f750b1f..77cb1ea53f 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1690459469381-AddReferral.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1690459469381-AddReferral.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class AddReferral1690459469381 implements MigrationInterface { name = 'AddReferral1690459469381' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query( 'CREATE TABLE "referal" ("id" character varying(21) NOT NULL, "created" TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT now(), "updated" TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT now(), "referredUserId" character varying(21) NOT NULL, "referringUserId" character varying(21) NOT NULL, CONSTRAINT "PK_567787298ed6c13527df7887096" PRIMARY KEY ("id"))', ) @@ -19,6 +24,9 @@ export class AddReferral1690459469381 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query( 'ALTER TABLE "referal" DROP CONSTRAINT "fk_referral_referring_user_id"', ) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1694379223109-flow-template-add-user-id-and-image-url.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1694379223109-flow-template-add-user-id-and-image-url.ts index d9a267aef7..f42e8252c4 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1694379223109-flow-template-add-user-id-and-image-url.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1694379223109-flow-template-add-user-id-and-image-url.ts @@ -1,11 +1,16 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class FlowTemplateAddUserIdAndImageUrl1694379223109 implements MigrationInterface { name = 'FlowTemplateAddUserIdAndImageUrl1694379223109' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query( 'ALTER TABLE "flow_template" DROP COLUMN "pinnedOrder"', ) @@ -32,6 +37,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query( 'ALTER TABLE "flow_template" DROP CONSTRAINT "fk_flow_template_user_id"', ) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1694381968985-project-member-relations.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1694381968985-project-member-relations.ts index c08d44365a..2f0c9236d6 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1694381968985-project-member-relations.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1694381968985-project-member-relations.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class ProjectMemberRelations1694381968985 implements MigrationInterface { name = 'ProjectMemberRelations1694381968985' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "project_member" ADD CONSTRAINT "fk_project_member_user_id" FOREIGN KEY ("userId") REFERENCES "user"("id") ON DELETE CASCADE ON UPDATE NO ACTION', ) @@ -16,6 +21,9 @@ export class ProjectMemberRelations1694381968985 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "project_member" DROP CONSTRAINT "fk_project_member_project_id"', ) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1694604120205-AddFeaturedDescriptionAndFlagToTemplates.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1694604120205-AddFeaturedDescriptionAndFlagToTemplates.ts index 32a0f9639d..e92dd7582d 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1694604120205-AddFeaturedDescriptionAndFlagToTemplates.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1694604120205-AddFeaturedDescriptionAndFlagToTemplates.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class AddFeaturedDescriptionAndFlagToTemplates1694604120205 implements MigrationInterface { name = 'AddFeaturedDescriptionAndFlagToTemplates1694604120205' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "flow_template" ADD "isFeatured" boolean', ) @@ -14,6 +19,9 @@ implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "flow_template" DROP COLUMN "featuredDescription"', ) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1694902537045-ModifyBilling.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1694902537045-ModifyBilling.ts index a616462d5f..cff1bd68e1 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1694902537045-ModifyBilling.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1694902537045-ModifyBilling.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class ModifyBilling1694902537045 implements MigrationInterface { name = 'ModifyBilling1694902537045' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query( 'ALTER TABLE "project_plan" RENAME COLUMN "name" TO "flowPlanName"', ) @@ -25,6 +30,9 @@ export class ModifyBilling1694902537045 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } await queryRunner.query('ALTER TABLE "project_usage" DROP COLUMN "bots"') await queryRunner.query( 'ALTER TABLE "project_usage" DROP COLUMN "datasourcesSize"', diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1695916063833-AddDatasourcesLimit.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1695916063833-AddDatasourcesLimit.ts index 438b505d08..eb89870a9b 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1695916063833-AddDatasourcesLimit.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1695916063833-AddDatasourcesLimit.ts @@ -1,17 +1,25 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class AddDatasourcesLimit1695916063833 implements MigrationInterface { name = 'AddDatasourcesLimit1695916063833' public async up(queryRunner: QueryRunner): Promise { - // Add the "datasources" column with a default value of 1 + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } + // Add the "datasources" column with a default value of 1 await queryRunner.query( 'ALTER TABLE "project_plan" ADD "datasources" integer NOT NULL DEFAULT 1', ) } public async down(queryRunner: QueryRunner): Promise { - // Remove the "datasources" column + if (isNotOneOfTheseEditions([ApEdition.ENTERPRISE, ApEdition.CLOUD])) { + return + } + // Remove the "datasources" column await queryRunner.query( 'ALTER TABLE "project_plan" DROP COLUMN "datasources"', ) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1697717995884-add-platform.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1697717995884-add-platform.ts index eb60f82613..7990b96a90 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1697717995884-add-platform.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1697717995884-add-platform.ts @@ -1,10 +1,15 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' import { logger } from '@activepieces/server-shared' +import { ApEdition } from '@activepieces/shared' export class AddPlatform1697717995884 implements MigrationInterface { name = 'AddPlatform1697717995884' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` CREATE TABLE "platform" ( "id" character varying(21) NOT NULL, @@ -29,6 +34,9 @@ export class AddPlatform1697717995884 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "platform" DROP CONSTRAINT "fk_platform_user" `) diff --git a/packages/server/api/src/app/ee/database/migrations/postgres/1698077078271-AddCustomDomain.ts b/packages/server/api/src/app/ee/database/migrations/postgres/1698077078271-AddCustomDomain.ts index a550d9846f..9362e9d93e 100644 --- a/packages/server/api/src/app/ee/database/migrations/postgres/1698077078271-AddCustomDomain.ts +++ b/packages/server/api/src/app/ee/database/migrations/postgres/1698077078271-AddCustomDomain.ts @@ -1,9 +1,14 @@ import { MigrationInterface, QueryRunner } from 'typeorm' +import { isNotOneOfTheseEditions } from '../../../../database/database-common' +import { ApEdition } from '@activepieces/shared' export class AddCustomDomain1698077078271 implements MigrationInterface { name = 'AddCustomDomain1698077078271' public async up(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` CREATE TABLE "custom_domain" ( "id" character varying(21) NOT NULL, @@ -25,6 +30,9 @@ export class AddCustomDomain1698077078271 implements MigrationInterface { } public async down(queryRunner: QueryRunner): Promise { + if (isNotOneOfTheseEditions([ApEdition.CLOUD, ApEdition.ENTERPRISE])) { + return + } await queryRunner.query(` ALTER TABLE "custom_domain" DROP CONSTRAINT "fk_custom_domain_platform_id" `)