@activepieces/shared - npm Package Compare versions

Comparing version 0.6.1 to 0.6.2

package.json

 {
   "name": "@activepieces/shared",
-  "version": "0.6.1",
+  "version": "0.6.2",
   "type": "commonjs",
@@ -5,0 +5,0 @@ "dependencies": {

src/lib/flow-run/dto/list-flow-runs-request.d.ts

@@ -6,2 +6,3 @@ import { Cursor } from "../../common/seek-page";
     flowId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString<string>>;
+    tags: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TArray<import("@sinclair/typebox").TString<string>>>;
     status: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof ExecutionOutputStatus>>;
@@ -8,0 +9,0 @@ limit: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TNumber>;

src/lib/flow-run/dto/list-flow-runs-request.js

@@ -9,2 +9,3 @@ "use strict";
     flowId: typebox_1.Type.Optional(id_generator_1.ApId),
+    tags: typebox_1.Type.Optional(typebox_1.Type.Array(typebox_1.Type.String({}))),
     status: typebox_1.Type.Optional(typebox_1.Type.Enum(execution_output_1.ExecutionOutputStatus)),
@@ -11,0 +12,0 @@ limit: typebox_1.Type.Optional(typebox_1.Type.Number({})),

src/lib/flow-run/execution/execution-output.d.ts

@@ -22,2 +22,3 @@ import { ActionType } from '../../flows/actions/action';
     tasks: number;
+    tags?: string[];
     errorMessage?: ExecutionError;
@@ -24,0 +25,0 @@ };

src/lib/flow-run/execution/execution-state.d.ts

@@ -8,6 +8,9 @@ import { StepOutput } from './step-output';
     private _taskCount;
+    private _tags;
     steps: Record<string, StepOutput>;
     lastStepState: Record<string, unknown>;
     constructor(executionState?: ExecutionState);
+    get tags(): string[];
     get taskCount(): number;
+    addConnectionTags(tags: string[]): void;
     private adjustTaskCount;
@@ -14,0 +17,0 @@ insertStep(stepOutput: StepOutput, stepName: string, ancestors: [string, number][]): void;

src/lib/flow-run/execution/execution-state.js

@@ -8,2 +8,3 @@ "use strict";
         this._taskCount = 0;
+        this._tags = [];
         this.steps = {};
@@ -17,5 +18,17 @@ this.lastStepState = {};
     }
+    get tags() {
+        return this._tags;
+    }
     get taskCount() {
         return this._taskCount;
     }
+    addConnectionTags(tags) {
+        this._tags.push(...tags.map(tag => `connection:${tag}`));
+        // Sorting the array
+        this._tags.sort();
+        // Removing duplicates
+        this._tags = this._tags.filter((value, index, self) => {
+            return self.indexOf(value) === index;
+        });
+    }
     adjustTaskCount({ stepOutput }) {
@@ -22,0 +35,0 @@ const nonCountableSteps = [

src/lib/flow-run/flow-run.d.ts

@@ -13,2 +13,3 @@ import { BaseModel } from '../common/base-model';
     flowId: FlowId;
+    tags?: string[];
     flowVersionId: FlowVersionId;
@@ -15,0 +16,0 @@ flowDisplayName: string;

No alert changes

Improved metrics

Total package byte prevSize

355984

increased by0.37%

Lines of code

4790

increased by0.42%

No dependency changes