@activepieces/shared - npm Package Compare versions

Comparing version 0.10.95 to 0.10.96

package.json

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

src/index.d.ts

@@ -54,2 +54,3 @@ export * from './lib/flows/actions/action';
 export * from './lib/platform';
+export { FlowError } from './lib/flow-run/execution/flow-execution';
 export { StopResponse } from './lib/flow-run/execution/flow-execution';
@@ -56,0 +57,0 @@ export { PauseType, FlowRunStatus, FlowRunResponse } from './lib/flow-run/execution/flow-execution';

src/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.RetryFlowRequestBody = exports.STORE_KEY_MAX_LENGTH = exports.WebhookPauseMetadata = exports.PauseMetadata = exports.DelayPauseMetadata = exports.FlowRunResponse = exports.FlowRunStatus = exports.PauseType = exports.StopResponse = exports.FileResponseInterface = exports.secureApId = exports.ApId = exports.apId = exports.SeekPage = exports.FlowRetryStrategy = exports.RunEnvironment = exports.FlowRun = exports.Flow = exports.FlowVersionMetadata = exports.FlowVersionState = exports.FlowVersion = exports.AUTHENTICATION_PROPERTY_NAME = exports.TriggerType = exports.PieceTrigger = exports.PieceTriggerSettings = exports.EmptyTrigger = exports.Trigger = exports.TestFlowRunRequestBody = exports.SignInRequest = exports.SignUpRequest = exports.ExecuteCodeRequest = exports.StepOutputStatus = void 0;
+exports.RetryFlowRequestBody = exports.STORE_KEY_MAX_LENGTH = exports.WebhookPauseMetadata = exports.PauseMetadata = exports.DelayPauseMetadata = exports.FlowRunResponse = exports.FlowRunStatus = exports.PauseType = exports.StopResponse = exports.FlowError = exports.FileResponseInterface = exports.secureApId = exports.ApId = exports.apId = exports.SeekPage = exports.FlowRetryStrategy = exports.RunEnvironment = exports.FlowRun = exports.Flow = exports.FlowVersionMetadata = exports.FlowVersionState = exports.FlowVersion = exports.AUTHENTICATION_PROPERTY_NAME = exports.TriggerType = exports.PieceTrigger = exports.PieceTriggerSettings = exports.EmptyTrigger = exports.Trigger = exports.TestFlowRunRequestBody = exports.SignInRequest = exports.SignUpRequest = exports.ExecuteCodeRequest = exports.StepOutputStatus = void 0;
 const tslib_1 = require("tslib");
@@ -81,11 +81,13 @@ tslib_1.__exportStar(require("./lib/flows/actions/action"), exports);
 var flow_execution_1 = require("./lib/flow-run/execution/flow-execution");
-Object.defineProperty(exports, "StopResponse", { enumerable: true, get: function () { return flow_execution_1.StopResponse; } });
+Object.defineProperty(exports, "FlowError", { enumerable: true, get: function () { return flow_execution_1.FlowError; } });
 var flow_execution_2 = require("./lib/flow-run/execution/flow-execution");
-Object.defineProperty(exports, "PauseType", { enumerable: true, get: function () { return flow_execution_2.PauseType; } });
-Object.defineProperty(exports, "FlowRunStatus", { enumerable: true, get: function () { return flow_execution_2.FlowRunStatus; } });
-Object.defineProperty(exports, "FlowRunResponse", { enumerable: true, get: function () { return flow_execution_2.FlowRunResponse; } });
+Object.defineProperty(exports, "StopResponse", { enumerable: true, get: function () { return flow_execution_2.StopResponse; } });
 var flow_execution_3 = require("./lib/flow-run/execution/flow-execution");
-Object.defineProperty(exports, "DelayPauseMetadata", { enumerable: true, get: function () { return flow_execution_3.DelayPauseMetadata; } });
-Object.defineProperty(exports, "PauseMetadata", { enumerable: true, get: function () { return flow_execution_3.PauseMetadata; } });
-Object.defineProperty(exports, "WebhookPauseMetadata", { enumerable: true, get: function () { return flow_execution_3.WebhookPauseMetadata; } });
+Object.defineProperty(exports, "PauseType", { enumerable: true, get: function () { return flow_execution_3.PauseType; } });
+Object.defineProperty(exports, "FlowRunStatus", { enumerable: true, get: function () { return flow_execution_3.FlowRunStatus; } });
+Object.defineProperty(exports, "FlowRunResponse", { enumerable: true, get: function () { return flow_execution_3.FlowRunResponse; } });
+var flow_execution_4 = require("./lib/flow-run/execution/flow-execution");
+Object.defineProperty(exports, "DelayPauseMetadata", { enumerable: true, get: function () { return flow_execution_4.DelayPauseMetadata; } });
+Object.defineProperty(exports, "PauseMetadata", { enumerable: true, get: function () { return flow_execution_4.PauseMetadata; } });
+Object.defineProperty(exports, "WebhookPauseMetadata", { enumerable: true, get: function () { return flow_execution_4.WebhookPauseMetadata; } });
 tslib_1.__exportStar(require("./lib/federated-authn"), exports);
@@ -92,0 +94,0 @@ var store_entry_1 = require("./lib/store-entry/store-entry");

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

@@ -43,2 +43,7 @@ import { Static } from '@sinclair/typebox';
 export type StopResponse = Static<typeof StopResponse>;
+export declare const FlowError: import("@sinclair/typebox").TObject<{
+    stepName: import("@sinclair/typebox").TString<string>;
+    message: import("@sinclair/typebox").TString<string>;
+}>;
+export type FlowError = Static<typeof FlowError>;
 export declare const FlowRunResponse: import("@sinclair/typebox").TUnion<[import("@sinclair/typebox").TObject<{
@@ -45,0 +50,0 @@ status: import("@sinclair/typebox").TLiteral<FlowRunStatus.PAUSED>;

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

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.FlowRunResponse = exports.StopResponse = exports.PauseMetadata = exports.WebhookPauseMetadata = exports.DelayPauseMetadata = exports.PauseType = exports.FlowRunStatus = void 0;
+exports.FlowRunResponse = exports.FlowError = exports.StopResponse = exports.PauseMetadata = exports.WebhookPauseMetadata = exports.DelayPauseMetadata = exports.PauseType = exports.FlowRunStatus = void 0;
 const typebox_1 = require("@sinclair/typebox");
@@ -37,6 +37,7 @@ const execution_output_1 = require("./execution-output");
 });
-const BaseExecutionResponse = Object.assign(Object.assign({}, execution_output_1.ExecutionState), { duration: typebox_1.Type.Number(), tasks: typebox_1.Type.Number(), tags: typebox_1.Type.Optional(typebox_1.Type.Array(typebox_1.Type.String())), error: typebox_1.Type.Optional(typebox_1.Type.Object({
-        stepName: typebox_1.Type.String(),
-        message: typebox_1.Type.String(),
-    })), stopResponse: typebox_1.Type.Optional(exports.StopResponse) });
+exports.FlowError = typebox_1.Type.Object({
+    stepName: typebox_1.Type.String(),
+    message: typebox_1.Type.String(),
+});
+const BaseExecutionResponse = Object.assign(Object.assign({}, execution_output_1.ExecutionState), { duration: typebox_1.Type.Number(), tasks: typebox_1.Type.Number(), tags: typebox_1.Type.Optional(typebox_1.Type.Array(typebox_1.Type.String())), error: typebox_1.Type.Optional(exports.FlowError), stopResponse: typebox_1.Type.Optional(exports.StopResponse) });
 exports.FlowRunResponse = typebox_1.Type.Union([
@@ -43,0 +44,0 @@ typebox_1.Type.Object(Object.assign(Object.assign({}, BaseExecutionResponse), { status: typebox_1.Type.Literal(FlowRunStatus.PAUSED), pauseMetadata: typebox_1.Type.Optional(exports.PauseMetadata) })),

No alert changes

Improved metrics

Total package byte prevSize

482893

increased by0.13%

Lines of code

6588

increased by0.14%

No dependency changes