@activepieces/shared - npm Package Compare versions

Comparing version 0.10.107 to 0.10.108

package.json

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

src/lib/authentication/model/principal-type.d.ts

 export declare enum PrincipalType {
     USER = "USER",
+    ENGINE = "ENGINE",
+    SERVICE = "SERVICE",
     WORKER = "WORKER",
-    SERVICE = "SERVICE",
     UNKNOWN = "UNKNOWN",
@@ -6,0 +7,0 @@ /**

src/lib/authentication/model/principal-type.js

@@ -7,4 +7,5 @@ "use strict";
     PrincipalType["USER"] = "USER";
+    PrincipalType["ENGINE"] = "ENGINE";
+    PrincipalType["SERVICE"] = "SERVICE";
     PrincipalType["WORKER"] = "WORKER";
-    PrincipalType["SERVICE"] = "SERVICE";
     PrincipalType["UNKNOWN"] = "UNKNOWN";
@@ -11,0 +12,0 @@ /**

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

@@ -0,1 +1,2 @@
+import { Static } from '@sinclair/typebox';
 import { AppConnectionValue } from '../app-connection/app-connection';
@@ -10,3 +11,2 @@ import { ExecutionState, ExecutionType, ResumePayload } from '../flow-run/execution/execution-output';
     EXECUTE_STEP = "EXECUTE_STEP",
-    EXECUTE_TEST_FLOW = "EXECUTE_TEST_FLOW",
     EXECUTE_FLOW = "EXECUTE_FLOW",
@@ -28,3 +28,3 @@ EXECUTE_PROPERTY = "EXECUTE_PROPERTY",
     projectId: ProjectId;
-    workerToken: string;
+    engineToken: string;
     serverUrl: string;
@@ -55,2 +55,3 @@ };
     serverHandlerId: string | null;
+    httpRequestId: string | null;
     progressUpdateType: ProgressUpdateType;
@@ -71,9 +72,2 @@ };
 export type ExecuteFlowOperation = BeginExecuteFlowOperation | ResumeExecuteFlowOperation;
-export type EngineTestOperation = BeginExecuteFlowOperation & {
-    /**
-     * original flow version that the current test flow version is derived from.
-     * Used to generate the test execution context.
-     */
-    sourceFlowVersion: FlowVersion;
-};
 export type ExecuteTriggerOperation<HT extends TriggerHookType> = BaseEngineOperation & {
@@ -84,3 +78,2 @@ hookType: HT;
     triggerPayload?: TriggerPayload;
-    edition?: string;
     appWebhookUrl?: string;
@@ -131,2 +124,8 @@ webhookSecret?: string;
 };
+export declare const EngineHttpResponse: import("@sinclair/typebox").TObject<{
+    status: import("@sinclair/typebox").TNumber;
+    body: import("@sinclair/typebox").TUnknown;
+    headers: import("@sinclair/typebox").TRecord<import("@sinclair/typebox").TString<string>, import("@sinclair/typebox").TString<string>>;
+}>;
+export type EngineHttpResponse = Static<typeof EngineHttpResponse>;
 export type ExecuteTriggerResponse<H extends TriggerHookType> = H extends TriggerHookType.RUN ? ExecuteTestOrRunTriggerResponse : H extends TriggerHookType.HANDSHAKE ? ExecuteHandshakeTriggerResponse : H extends TriggerHookType.TEST ? ExecuteTestOrRunTriggerResponse : H extends TriggerHookType.RENEW ? Record<string, never> : H extends TriggerHookType.ON_DISABLE ? Record<string, never> : ExecuteOnEnableTriggerResponse;
@@ -133,0 +132,0 @@ export type ExecuteActionResponse = {

src/lib/engine/engine-operation.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.EngineResponseStatus = exports.ProgressUpdateType = exports.TriggerHookType = exports.EngineOperationType = void 0;
+exports.EngineResponseStatus = exports.EngineHttpResponse = exports.ProgressUpdateType = exports.TriggerHookType = exports.EngineOperationType = void 0;
+const typebox_1 = require("@sinclair/typebox");
 var EngineOperationType;
@@ -8,3 +9,2 @@ (function (EngineOperationType) {
     EngineOperationType["EXECUTE_STEP"] = "EXECUTE_STEP";
-    EngineOperationType["EXECUTE_TEST_FLOW"] = "EXECUTE_TEST_FLOW";
     EngineOperationType["EXECUTE_FLOW"] = "EXECUTE_FLOW";
@@ -30,2 +30,7 @@ EngineOperationType["EXECUTE_PROPERTY"] = "EXECUTE_PROPERTY";
 })(ProgressUpdateType || (exports.ProgressUpdateType = ProgressUpdateType = {}));
+exports.EngineHttpResponse = typebox_1.Type.Object({
+    status: typebox_1.Type.Number(),
+    body: typebox_1.Type.Unknown(),
+    headers: typebox_1.Type.Record(typebox_1.Type.String(), typebox_1.Type.String()),
+});
 var EngineResponseStatus;
@@ -32,0 +37,0 @@ (function (EngineResponseStatus) {

src/lib/engine/index.d.ts

 export * from './code-sandbox-type';
 export * from './engine-operation';
+export * from './requests';

src/lib/engine/index.js

@@ -6,2 +6,3 @@ "use strict";
 tslib_1.__exportStar(require("./engine-operation"), exports);
+tslib_1.__exportStar(require("./requests"), exports);
 //# sourceMappingURL=index.js.map

src/lib/flag/flag.d.ts

@@ -33,3 +33,3 @@ import { BaseModel } from '../common/base-model';
     PRIVATE_PIECES_ENABLED = "PRIVATE_PIECES_ENABLED",
-    SANDBOX_RUN_TIME_SECONDS = "SANDBOX_RUN_TIME_SECONDS",
+    FLOW_RUN_TIME_SECONDS = "FLOW_RUN_TIME_SECONDS",
     SHOW_BILLING = "SHOW_BILLING",
@@ -36,0 +36,0 @@ INSTALL_PROJECT_PIECES_ENABLED = "INSTALL_PROJECT_PIECES_ENABLED",

src/lib/flag/flag.js

@@ -33,3 +33,3 @@ "use strict";
     ApFlagId["PRIVATE_PIECES_ENABLED"] = "PRIVATE_PIECES_ENABLED";
-    ApFlagId["SANDBOX_RUN_TIME_SECONDS"] = "SANDBOX_RUN_TIME_SECONDS";
+    ApFlagId["FLOW_RUN_TIME_SECONDS"] = "FLOW_RUN_TIME_SECONDS";
     ApFlagId["SHOW_BILLING"] = "SHOW_BILLING";
@@ -36,0 +36,0 @@ ApFlagId["INSTALL_PROJECT_PIECES_ENABLED"] = "INSTALL_PROJECT_PIECES_ENABLED";

src/lib/flows/form.d.ts

@@ -40,1 +40,2 @@ import { Static } from '@sinclair/typebox';
 export type FormResponse = Static<typeof FormResponse>;
+export declare const USE_DRAFT_QUERY_PARAM_NAME = "useDraft";

src/lib/flows/form.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.FormResponse = exports.FormProps = exports.FormInput = exports.FormInputType = void 0;
+exports.USE_DRAFT_QUERY_PARAM_NAME = exports.FormResponse = exports.FormProps = exports.FormInput = exports.FormInputType = void 0;
 const typebox_1 = require("@sinclair/typebox");
@@ -28,2 +28,3 @@ var FormInputType;
 });
+exports.USE_DRAFT_QUERY_PARAM_NAME = 'useDraft';
 //# sourceMappingURL=form.js.map

src/lib/flows/step-run/dto/test-step-request.d.ts

 import { Static } from '@sinclair/typebox';
-import { ProgressUpdateType } from '../../../engine';
 export declare const CreateStepRunRequestBody: import("@sinclair/typebox").TObject<{
@@ -19,50 +18,1 @@ flowVersionId: import("@sinclair/typebox").TString<string>;
 export type StepExecutionPath = Static<typeof StepExecutionPath>;
-export declare const UpdateRunProgressRequest: import("@sinclair/typebox").TObject<{
-    runDetails: import("@sinclair/typebox").TUnion<[import("@sinclair/typebox").TObject<{
-        status: import("@sinclair/typebox").TLiteral<import("../../../flow-run/execution/flow-execution").FlowRunStatus.PAUSED>;
-        pauseMetadata: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TUnion<[import("@sinclair/typebox").TObject<{
-            type: import("@sinclair/typebox").TLiteral<import("../../../flow-run/execution/flow-execution").PauseType.DELAY>;
-            resumeDateTime: import("@sinclair/typebox").TString<string>;
-            handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString<string>>;
-            progressUpdateType: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof ProgressUpdateType>>;
-        }>, import("@sinclair/typebox").TObject<{
-            type: import("@sinclair/typebox").TLiteral<import("../../../flow-run/execution/flow-execution").PauseType.WEBHOOK>;
-            requestId: import("@sinclair/typebox").TString<string>;
-            response: import("@sinclair/typebox").TUnknown;
-            handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString<string>>;
-            progressUpdateType: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof ProgressUpdateType>>;
-        }>]>>;
-        steps: import("@sinclair/typebox").TRecord<import("@sinclair/typebox").TString<string>, import("@sinclair/typebox").TUnknown>;
-        duration: import("@sinclair/typebox").TNumber;
-        tasks: import("@sinclair/typebox").TNumber;
-        tags: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TArray<import("@sinclair/typebox").TString<string>>>;
-        error: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TObject<{
-            stepName: import("@sinclair/typebox").TString<string>;
-            message: import("@sinclair/typebox").TString<string>;
-        }>>;
-        stopResponse: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TObject<{
-            status: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TNumber>;
-            body: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TUnknown>;
-            headers: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TRecord<import("@sinclair/typebox").TString<string>, import("@sinclair/typebox").TString<string>>>;
-        }>>;
-    }>, import("@sinclair/typebox").TObject<{
-        status: import("@sinclair/typebox").TUnion<[import("@sinclair/typebox").TLiteral<import("../../../flow-run/execution/flow-execution").FlowRunStatus.FAILED>, import("@sinclair/typebox").TLiteral<import("../../../flow-run/execution/flow-execution").FlowRunStatus.SUCCEEDED>, import("@sinclair/typebox").TLiteral<import("../../../flow-run/execution/flow-execution").FlowRunStatus.RUNNING>, import("@sinclair/typebox").TLiteral<import("../../../flow-run/execution/flow-execution").FlowRunStatus.QUOTA_EXCEEDED>, import("@sinclair/typebox").TLiteral<import("../../../flow-run/execution/flow-execution").FlowRunStatus.TIMEOUT>, import("@sinclair/typebox").TLiteral<import("../../../flow-run/execution/flow-execution").FlowRunStatus.INTERNAL_ERROR>, import("@sinclair/typebox").TLiteral<import("../../../flow-run/execution/flow-execution").FlowRunStatus.STOPPED>]>;
-        steps: import("@sinclair/typebox").TRecord<import("@sinclair/typebox").TString<string>, import("@sinclair/typebox").TUnknown>;
-        duration: import("@sinclair/typebox").TNumber;
-        tasks: import("@sinclair/typebox").TNumber;
-        tags: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TArray<import("@sinclair/typebox").TString<string>>>;
-        error: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TObject<{
-            stepName: import("@sinclair/typebox").TString<string>;
-            message: import("@sinclair/typebox").TString<string>;
-        }>>;
-        stopResponse: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TObject<{
-            status: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TNumber>;
-            body: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TUnknown>;
-            headers: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TRecord<import("@sinclair/typebox").TString<string>, import("@sinclair/typebox").TString<string>>>;
-        }>>;
-    }>]>;
-    runId: import("@sinclair/typebox").TString<string>;
-    progressUpdateType: import("@sinclair/typebox").TEnum<typeof ProgressUpdateType>;
-    workerHandlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TUnsafe<string | null>>;
-}>;
-export type UpdateRunProgressRequest = Static<typeof UpdateRunProgressRequest>;

src/lib/flows/step-run/dto/test-step-request.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.UpdateRunProgressRequest = exports.StepExecutionPath = exports.StepRunResponse = exports.CreateStepRunRequestBody = void 0;
+exports.StepExecutionPath = exports.StepRunResponse = exports.CreateStepRunRequestBody = void 0;
 const typebox_1 = require("@sinclair/typebox");
-const common_1 = require("../../../common");
-const engine_1 = require("../../../engine");
-const flow_execution_1 = require("../../../flow-run/execution/flow-execution");
 exports.CreateStepRunRequestBody = typebox_1.Type.Object({
@@ -21,8 +18,2 @@ flowVersionId: typebox_1.Type.String(),
 exports.StepExecutionPath = typebox_1.Type.Array(typebox_1.Type.Tuple([typebox_1.Type.String(), typebox_1.Type.Number()]));
-exports.UpdateRunProgressRequest = typebox_1.Type.Object({
-    runDetails: flow_execution_1.FlowRunResponse,
-    runId: typebox_1.Type.String(),
-    progressUpdateType: typebox_1.Type.Enum(engine_1.ProgressUpdateType),
-    workerHandlerId: (0, common_1.Nullable)(typebox_1.Type.String()),
-});
 //# sourceMappingURL=test-step-request.js.map

src/lib/pieces/piece.d.ts

@@ -24,3 +24,2 @@ import { Static } from '@sinclair/typebox';
     pieceVersion: import("@sinclair/typebox").TString<string>;
-    directoryPath: import("@sinclair/typebox").TUnion<[import("@sinclair/typebox").TUndefined, import("@sinclair/typebox").TString<string>]>;
 }>;
@@ -27,0 +26,0 @@ export type PublicPiecePackage = Static<typeof PublicPiecePackage>;

src/lib/pieces/piece.js

@@ -28,3 +28,2 @@ "use strict";
     pieceVersion: typebox_1.Type.String(),
-    directoryPath: typebox_1.Type.Union([typebox_1.Type.Undefined(), typebox_1.Type.String()]),
 });
@@ -31,0 +30,0 @@ var PieceCategory;

No alert changes

Improved metrics

Total package byte prevSize

537529

increased by0.82%

Number of package files

266

increased by1.14%

Lines of code

7321

increased by0.83%

No dependency changes