feat: centralize flow issues

packages/ee/shared/src/index.ts

@@ -17,4 +17,6 @@ export * from './lib/managed-authn'
 export * from './lib/oauth-apps'
 export * from './lib/otp'
 export * from './lib/authn'
-export * from './lib/activity'
+export * from './lib/activity'
+
+export * from './lib/issues'

packages/ee/shared/src/lib/issues/index.ts

@@ -0,0 +1,2 @@
+export * from './issues-requests'
+export * from './issue-dto'

packages/ee/shared/src/lib/issues/issue-dto.ts

@@ -0,0 +1,25 @@
+import { Static, Type } from "@sinclair/typebox";
+import { ApId, BaseModelSchema } from "@activepieces/shared";
+
+export enum IssueStatus {
+    ONGOING = 'ONGOING',
+    RESOLEVED = 'RESOLEVED',
+}
+
+export const Issue = Type.Object({
+    ...BaseModelSchema,
+    projectId: ApId,
+    flowId: ApId,
+    status: Type.Enum(IssueStatus),
+    count: Type.Number(),
+    lastOccurrence: Type.String(),
+})
+
+export type Issue = Static<typeof Issue>
+
+
+export const PopulatedIssue = Type.Composite([Issue, Type.Object({
+    flowDisplayName: Type.String()
+})])
+
+export type PopulatedIssue = Static<typeof PopulatedIssue>

packages/ee/shared/src/lib/issues/issues-requests.ts

@@ -0,0 +1,17 @@
+
+import { Type, Static } from '@sinclair/typebox'
+import { ApId } from '@activepieces/shared'
+import { IssueStatus } from './issue-dto'
+
+export const ListIssuesParams = Type.Object({
+    projectId: ApId,
+    cursor: Type.Optional(Type.String()),
+    limit: Type.Optional(Type.Integer({ minimum: 1, maximum: 100 })),
+})
+export type ListIssuesParams = Static<typeof ListIssuesParams>
+
+export const UpdateIssueRequestBody = Type.Object({
+    status: Type.Enum(IssueStatus),
+})
+
+export type UpdateIssueRequestBody = Static<typeof UpdateIssueRequestBody>

packages/pieces/community/activepieces/package.json

@@ -3,7 +3,7 @@
   "version": "0.0.5",
   "dependencies": {
     "@activepieces/pieces-common": "0.2.12",
-    "@activepieces/pieces-framework": "0.7.29",
+    "@activepieces/pieces-framework": "0.7.30",
     "tslib": "2.6.2"
   }
 }

packages/pieces/community/brilliant-directories/package.json

@@ -2,7 +2,7 @@
   "name": "@activepieces/piece-brilliant-directories",
   "version": "0.0.7",
   "dependencies": {
-    "@activepieces/pieces-framework": "0.7.29",
+    "@activepieces/pieces-framework": "0.7.30",
     "@activepieces/pieces-common": "0.2.12",
     "tslib": "^2.6.2",
     "@activepieces/shared": "*"

packages/pieces/community/convertkit/package.json

@@ -2,7 +2,7 @@
   "name": "@activepieces/piece-convertkit",
   "version": "0.2.0",
   "dependencies": {
-    "@activepieces/pieces-framework": "0.7.29",
+    "@activepieces/pieces-framework": "0.7.30",
     "@activepieces/pieces-common": "0.2.12",
     "tslib": "^2.6.2",
     "@activepieces/shared": "*"

packages/pieces/community/math-helper/package.json

@@ -2,8 +2,8 @@
   "name": "@activepieces/piece-math-helper",
   "version": "0.0.7",
   "dependencies": {
-    "@activepieces/pieces-framework": "0.7.29",
-    "@activepieces/shared": "0.10.104",
+    "@activepieces/pieces-framework": "0.7.30",
+    "@activepieces/shared": "0.10.105",
     "tslib": "2.6.2"
   }
 }

packages/pieces/community/retune/package.json

@@ -3,8 +3,8 @@
   "version": "0.0.6",
   "dependencies": {
     "@activepieces/pieces-common": "0.2.12",
-    "@activepieces/pieces-framework": "0.7.29",
-    "@activepieces/shared": "0.10.104",
+    "@activepieces/pieces-framework": "0.7.30",
+    "@activepieces/shared": "0.10.105",
     "tslib": "2.6.2"
   }
 }

packages/pieces/community/saastic/package.json

@@ -2,7 +2,7 @@
   "name": "@activepieces/piece-saastic",
   "version": "0.0.7",
   "dependencies": {
-    "@activepieces/pieces-framework": "0.7.29",
+    "@activepieces/pieces-framework": "0.7.30",
     "@activepieces/pieces-common": "0.2.12",
     "tslib": "^2.6.2",
     "@activepieces/shared": "*"

packages/server/api/src/app/app.ts

@@ -41,6 +41,7 @@ import { platformFlowTemplateModule } from './ee/flow-template/platform-flow-tem
 import { platformWorkerHooks } from './ee/flow-worker/cloud-flow-worker-hooks'
 import { gitRepoModule } from './ee/git-repos/git-repo.module'
 import { platformDomainHelper } from './ee/helper/platform-domain-helper'
+import { issuesModule } from './ee/issues/issues-module'
 import { managedAuthnModule } from './ee/managed-authn/managed-authn-module'
 import { oauthAppModule } from './ee/oauth-apps/oauth-app.module'
 import { otpModule } from './ee/otp/otp-module'
@@ -252,6 +253,8 @@ export const setupApp = async (): Promise<FastifyInstance> => {
     await pieceSyncService.setup()
     await app.register(flowWorkerModule)
     await app.register(platformUserModule)
+    await app.register(issuesModule)
+
     await setupBullMQBoard(app)
 
     app.get(

packages/server/api/src/app/database/database-connection.ts

@@ -16,6 +16,7 @@ import { ConnectionKeyEntity } from '../ee/connection-keys/connection-key.entity
 import { CustomDomainEntity } from '../ee/custom-domains/custom-domain.entity'
 import { FlowTemplateEntity } from '../ee/flow-template/flow-template.entity'
 import { GitRepoEntity } from '../ee/git-repos/git-repo.entity'
+import { IssueEntity } from '../ee/issues/issues-entity'
 import { OAuthAppEntity } from '../ee/oauth-apps/oauth-app.entity'
 import { OtpEntity } from '../ee/otp/otp-entity'
 import { ProjectMemberEntity } from '../ee/project-members/project-member.entity'
@@ -68,6 +69,7 @@ function getEntities(): EntitySchema<unknown>[] {
         PlatformEntity,
         TagEntity,
         PieceTagEntity,
+        IssueEntity,
     ]
 
     switch (edition) {
@@ -120,9 +122,9 @@ export const commonProperties = {
 }
 
 export const databaseConnection =
-  databaseType === DatabaseType.SQLITE3
-      ? createSqlLiteDataSource()
-      : createPostgresDataSource()
+    databaseType === DatabaseType.SQLITE3
+        ? createSqlLiteDataSource()
+        : createPostgresDataSource()
 
 export function APArrayContains<T extends ObjectLiteral>(
     columnName: string,

packages/server/api/src/app/database/migration/postgres/1714904516114-AddIssueEntityPostgres.ts

@@ -0,0 +1,71 @@
+import { MigrationInterface, QueryRunner } from 'typeorm'
+
+export class AddIssueEntityPostgres1714904516114 implements MigrationInterface {
+    name = 'AddIssueEntityPostgres1714904516114'
+
+    public async up(queryRunner: QueryRunner): Promise<void> {
+        await queryRunner.query(`
+            CREATE TABLE "issue" (
+                "id" character varying(21) NOT NULL,
+                "created" TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT now(),
+                "updated" TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT now(),
+                "projectId" character varying(21) NOT NULL,
+                "flowId" character varying(21) NOT NULL,
+                "status" character varying NOT NULL,
+                "count" integer NOT NULL,
+                "lastOccurrence" TIMESTAMP WITH TIME ZONE NOT NULL,
+                CONSTRAINT "REL_6c7309a7ac3112d264f5d7b49f" UNIQUE ("flowId"),
+                CONSTRAINT "PK_f80e086c249b9f3f3ff2fd321b7" PRIMARY KEY ("id")
+            )
+        `)
+        await queryRunner.query(`
+            CREATE UNIQUE INDEX "idx_issue_flow_id" ON "issue" ("flowId")
+        `)
+        await queryRunner.query(`
+            CREATE INDEX "idx_issue_project_id_flow_id" ON "issue" ("projectId", "flowId")
+        `)
+        await queryRunner.query(`
+            ALTER TABLE "platform"
+            ADD "flowIssuesEnabled" boolean
+        `)
+        await queryRunner.query(`
+            UPDATE "platform"
+            SET "flowIssuesEnabled" = false
+        `)
+        await queryRunner.query(`
+            ALTER TABLE "platform"
+            ALTER COLUMN "flowIssuesEnabled" SET NOT NULL
+        `)
+
+        await queryRunner.query(`
+            ALTER TABLE "issue"
+            ADD CONSTRAINT "fk_issue_flow_id" FOREIGN KEY ("flowId") REFERENCES "flow"("id") ON DELETE CASCADE ON UPDATE NO ACTION
+        `)
+        await queryRunner.query(`
+            ALTER TABLE "issue"
+            ADD CONSTRAINT "fk_issue_project_id" FOREIGN KEY ("projectId") REFERENCES "project"("id") ON DELETE CASCADE ON UPDATE RESTRICT
+        `)
+    }
+
+    public async down(queryRunner: QueryRunner): Promise<void> {
+        await queryRunner.query(`
+            ALTER TABLE "issue" DROP CONSTRAINT "fk_issue_project_id"
+        `)
+        await queryRunner.query(`
+            ALTER TABLE "issue" DROP CONSTRAINT "fk_issue_flow_id"
+        `)
+        await queryRunner.query(`
+            ALTER TABLE "platform" DROP COLUMN "flowIssuesEnabled"
+        `)
+        await queryRunner.query(`
+            DROP INDEX "public"."idx_issue_project_id_flow_id"
+        `)
+        await queryRunner.query(`
+            DROP INDEX "public"."idx_issue_flow_id"
+        `)
+        await queryRunner.query(`
+            DROP TABLE "issue"
+        `)
+    }
+
+}