@activepieces/shared - npm Package Compare versions

Comparing version 0.3.18 to 0.3.19

package.json

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

src/index.d.ts

@@ -24,4 +24,3 @@ export * from "./lib/flows/actions/action";
 export * from "./lib/webhook";
-export { CodeRunStatus } from "./lib/workers/code-worker/code-run-status";
-export { CodeExecutionResult } from "./lib/workers/code-worker/code-execution-result";
+export * from "./lib/workers/code-worker/code-execution-result";
 export { ExecuteCodeRequest } from './lib/code/dto/code-request';
@@ -28,0 +27,0 @@ export { AuthenticationResponse } from './lib/authentication/dto/authentication-response';

src/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.ApId = exports.apId = exports.ListFlowsRequest = exports.ExecutionState = exports.RunEnvironment = exports.FlowVersionState = exports.TriggerType = exports.WebhookTrigger = exports.PieceTrigger = exports.PieceTriggerSettings = exports.EmptyTrigger = exports.Trigger = exports.CreateFlowRunRequest = exports.CodeActionSettings = exports.ActionType = exports.Action = exports.LoopOnItemsActionSettings = exports.PieceActionSettings = exports.PrincipalType = exports.SignInRequest = exports.SignUpRequest = exports.ExecuteCodeRequest = exports.CodeRunStatus = exports.StepOutputStatus = void 0;
+exports.ApId = exports.apId = exports.ListFlowsRequest = exports.ExecutionState = exports.RunEnvironment = exports.FlowVersionState = exports.TriggerType = exports.WebhookTrigger = exports.PieceTrigger = exports.PieceTriggerSettings = exports.EmptyTrigger = exports.Trigger = exports.CreateFlowRunRequest = exports.CodeActionSettings = exports.ActionType = exports.Action = exports.LoopOnItemsActionSettings = exports.PieceActionSettings = exports.PrincipalType = exports.SignInRequest = exports.SignUpRequest = exports.ExecuteCodeRequest = exports.StepOutputStatus = void 0;
 const tslib_1 = require("tslib");
@@ -29,4 +29,3 @@ tslib_1.__exportStar(require("./lib/flows/actions/action"), exports);
 tslib_1.__exportStar(require("./lib/webhook"), exports);
-var code_run_status_1 = require("./lib/workers/code-worker/code-run-status");
-Object.defineProperty(exports, "CodeRunStatus", { enumerable: true, get: function () { return code_run_status_1.CodeRunStatus; } });
+tslib_1.__exportStar(require("./lib/workers/code-worker/code-execution-result"), exports);
 var code_request_1 = require("./lib/code/dto/code-request");
@@ -33,0 +32,0 @@ Object.defineProperty(exports, "ExecuteCodeRequest", { enumerable: true, get: function () { return code_request_1.ExecuteCodeRequest; } });

src/lib/common/activepieces-error.d.ts

@@ -12,3 +12,3 @@ import { AppConnectionId } from "../app-connection/app-connection";
 }
-declare type ErrorParams = ConfigNotFoundErrorParams | ExistingUserErrorParams | FileNotFoundErrorParams | FlowNotFoundErrorParams | FlowRunNotFoundErrorParams | FlowVersionNotFoundErrorParams | FlowInstanceNotFoundErrorParams | InvalidBearerTokenParams | InvalidCredentialsErrorParams | JobRemovalFailureErrorParams | PieceNotFoundErrorParams | PieceTriggerNotFoundErrorParams | StepNotFoundErrorParams | AppConnectionNotFoundErrorParams | InvalidClaimParams | InvalidCloudClaimParams | InvalidJwtTokenErrorParams | TaskQuotaExeceededErrorParams | TriggerFailedErrorParams | SystemInvalidErrorParams | SystemPropNotDefinedErrorParams | OpenAiFailedErrorParams | TestTriggerFailedErrorParams | FlowOperationErrorParams | EntityNotFoundErrorParams | ValidationErrorParams;
+declare type ErrorParams = ConfigNotFoundErrorParams | ExistingUserErrorParams | FileNotFoundErrorParams | FlowNotFoundErrorParams | FlowRunNotFoundErrorParams | FlowVersionNotFoundErrorParams | FlowInstanceNotFoundErrorParams | InvalidBearerTokenParams | InvalidCredentialsErrorParams | JobRemovalFailureErrorParams | PieceNotFoundErrorParams | PieceTriggerNotFoundErrorParams | StepNotFoundErrorParams | AppConnectionNotFoundErrorParams | InvalidClaimParams | InvalidCloudClaimParams | InvalidJwtTokenErrorParams | TaskQuotaExeceededErrorParams | TriggerFailedErrorParams | SystemInvalidErrorParams | SystemPropNotDefinedErrorParams | OpenAiFailedErrorParams | TestTriggerFailedErrorParams | FlowOperationErrorParams | EntityNotFoundErrorParams | ValidationErrorParams | ExecutionTimeoutErrorParams;
 export interface BaseErrorParams<T, V> {
@@ -72,3 +72,3 @@ code: T;
     triggerName: string;
-    error: Error;
+    error: string | undefined;
 }>;
@@ -101,2 +101,3 @@ export declare type ConfigNotFoundErrorParams = BaseErrorParams<ErrorCode.CONFIG_NOT_FOUND, {
 }>;
+export declare type ExecutionTimeoutErrorParams = BaseErrorParams<ErrorCode.EXECUTION_TIMEOUT, Record<string, never>>;
 export declare type ValidationErrorParams = BaseErrorParams<ErrorCode.VALIDATION, {
@@ -131,4 +132,5 @@ message: string;
     ENTITY_NOT_FOUND = "ENTITY_NOT_FOUND",
-    VALIDATION = "VALIDATION"
+    VALIDATION = "VALIDATION",
+    EXECUTION_TIMEOUT = "EXECUTION_TIMEOUT"
 }
 export {};

src/lib/common/activepieces-error.js

@@ -39,3 +39,4 @@ "use strict";
     ErrorCode["VALIDATION"] = "VALIDATION";
+    ErrorCode["EXECUTION_TIMEOUT"] = "EXECUTION_TIMEOUT";
 })(ErrorCode = exports.ErrorCode || (exports.ErrorCode = {}));
 //# sourceMappingURL=activepieces-error.js.map

src/lib/engine/engine-operation.d.ts

@@ -15,3 +15,3 @@ import { FlowVersion, FlowVersionId } from "../flows/flow-version";
 }
-export declare type EngineOperation = ExecuteActionOperation | ExecuteFlowOperation | ExecutePropsOptions | ExecuteTriggerOperation;
+export declare type EngineOperation = ExecuteActionOperation | ExecuteFlowOperation | ExecutePropsOptions | ExecuteTriggerOperation<TriggerHookType>;
 export declare type ExecuteActionOperation = {
@@ -44,7 +44,7 @@ actionName: string;
 }
-export interface ExecuteTriggerOperation {
-    hookType: TriggerHookType;
+export interface ExecuteTriggerOperation<HT extends TriggerHookType> {
+    hookType: HT;
     flowVersion: FlowVersion;
     webhookUrl: string;
-    triggerPayload?: unknown;
+    triggerPayload?: TriggerPayload;
     projectId: ProjectId;
@@ -57,2 +57,7 @@ workerToken?: string;
 }
+export declare type TriggerPayload = Record<string, never> | {
+    body: any;
+    headers: Record<string, string>;
+    queryParams: Record<string, string>;
+};
 export interface EventPayload {
@@ -77,3 +82,3 @@ body: any;
 }
-export interface ExecuteTestOrRunTriggerResponse {
+interface ExecuteTestOrRunTriggerResponse {
     success: boolean;
@@ -83,6 +88,12 @@ message?: string;
 }
-export interface ExecuteTriggerResponse {
+interface ExecuteOnEnableTriggerResponse {
     listeners: AppEventListener[];
     scheduleOptions: ScheduleOptions;
 }
+export declare type ExecuteTriggerResponse<H extends TriggerHookType> = H extends TriggerHookType.RUN ? ExecuteTestOrRunTriggerResponse : H extends TriggerHookType.TEST ? ExecuteTestOrRunTriggerResponse : H extends TriggerHookType.ON_DISABLE ? Record<string, never> : ExecuteOnEnableTriggerResponse;
+export declare type ExecuteActionResponse = {
+    success: boolean;
+    output: unknown;
+    message?: string;
+};
 export interface ScheduleOptions {
@@ -92,1 +103,11 @@ cronExpression: string;
 }
+export declare type EngineResponse<T> = {
+    status: EngineResponseStatus;
+    response: T;
+};
+export declare enum EngineResponseStatus {
+    OK = "OK",
+    ERROR = "ERROR",
+    TIMEOUT = "TIMEOUT"
+}
+export {};

src/lib/engine/engine-operation.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.TriggerHookType = exports.EngineOperationType = void 0;
+exports.EngineResponseStatus = exports.TriggerHookType = exports.EngineOperationType = void 0;
 var EngineOperationType;
@@ -19,2 +19,8 @@ (function (EngineOperationType) {
 ;
+var EngineResponseStatus;
+(function (EngineResponseStatus) {
+    EngineResponseStatus["OK"] = "OK";
+    EngineResponseStatus["ERROR"] = "ERROR";
+    EngineResponseStatus["TIMEOUT"] = "TIMEOUT";
+})(EngineResponseStatus = exports.EngineResponseStatus || (exports.EngineResponseStatus = {}));
 //# sourceMappingURL=engine-operation.js.map

src/lib/workers/code-worker/code-execution-result.d.ts

@@ -1,2 +0,1 @@
-import { CodeRunStatus } from "./code-run-status";
 export interface CodeExecutionResult {
@@ -9,1 +8,6 @@ verdict: CodeRunStatus;
 }
+export declare enum CodeRunStatus {
+    OK = "OK",
+    RUNTIME_ERROR = "RUNTIME_ERROR",
+    TIMEOUT = "TIMEOUT"
+}

src/lib/workers/code-worker/code-execution-result.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.CodeRunStatus = void 0;
+var CodeRunStatus;
+(function (CodeRunStatus) {
+    CodeRunStatus["OK"] = "OK";
+    CodeRunStatus["RUNTIME_ERROR"] = "RUNTIME_ERROR";
+    CodeRunStatus["TIMEOUT"] = "TIMEOUT";
+})(CodeRunStatus = exports.CodeRunStatus || (exports.CodeRunStatus = {}));
 //# sourceMappingURL=code-execution-result.js.map

No alert changes

Improved metrics

Total package byte prevSize

198329

increased by0.32%

Lines of code

2909

increased by0.69%

Worsened metrics

Number of package files

197

decreased by-1.5%

No dependency changes