@activepieces/shared - npm Package Compare versions

Comparing version 0.10.152 to 0.10.153

package.json

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

src/lib/common/telemetry.d.ts

@@ -62,3 +62,3 @@ import { RunEnvironment } from '../flow-run/flow-run';
 };
-type KeyActiviated = {
+type KeyActivated = {
     date: string;
@@ -89,3 +89,3 @@ key: string;
 };
-type OpenedFromDasahboard = {
+type OpenedFromDashboard = {
     location: 'sidenav' | 'tasks-progress';
@@ -123,3 +123,3 @@ };
     REQUEST_TRIAL_SUBMITTED = "request.trial.submitted",
-    KEY_ACTIVIATED = "key.activated",
+    KEY_ACTIVATED = "key.activated",
     FLOW_ISSUE_CLICKED = "flow.issue.clicked",
@@ -157,3 +157,3 @@ FLOW_ISSUE_RESOLVED = "flow.issue.resolved",
 };
-export type TelemetryEvent = BaseTelemetryEvent<TelemetryEventName.SIGNED_UP, SignedUp> | BaseTelemetryEvent<TelemetryEventName.REFERRAL, Referral> | BaseTelemetryEvent<TelemetryEventName.REQUEST_TRIAL_CLICKED, RequestTrialClicked> | BaseTelemetryEvent<TelemetryEventName.KEY_ACTIVIATED, KeyActiviated> | BaseTelemetryEvent<TelemetryEventName.REQUEST_TRIAL_SUBMITTED, RequestTrialSubmitted> | BaseTelemetryEvent<TelemetryEventName.FLOW_ISSUE_CLICKED, FlowIssueClicked> | BaseTelemetryEvent<TelemetryEventName.FLOW_ISSUE_RESOLVED, FlowIssueResolved> | BaseTelemetryEvent<TelemetryEventName.UPGRADE_CLICKED, UpgradeClicked> | BaseTelemetryEvent<TelemetryEventName.UPGRADE_POPUP, UpgradePopup> | BaseTelemetryEvent<TelemetryEventName.FLOW_RUN_CREATED, RunCreated> | BaseTelemetryEvent<TelemetryEventName.FLOW_PUBLISHED, FlowPublished> | BaseTelemetryEvent<TelemetryEventName.QUOTA_ALERT, QuotaAlert> | BaseTelemetryEvent<TelemetryEventName.CREATED_FLOW, FlowCreated> | BaseTelemetryEvent<TelemetryEventName.TEMPLATE_SEARCH, TemplateSearch> | BaseTelemetryEvent<TelemetryEventName.PIECES_SEARCH, PiecesSearch> | BaseTelemetryEvent<TelemetryEventName.FLOW_IMPORTED, FlowImported> | BaseTelemetryEvent<TelemetryEventName.FLOW_IMPORTED_USING_FILE, FlowImportedUsingFile> | BaseTelemetryEvent<TelemetryEventName.REFERRAL_LINK_COPIED, ReferralLinkCopied> | BaseTelemetryEvent<TelemetryEventName.FLOW_SHARED, FlowShared> | BaseTelemetryEvent<TelemetryEventName.DEMO_IMPORTED, Record<string, never>> | BaseTelemetryEvent<TelemetryEventName.OPENED_PRICING_FROM_DASHBOARD, OpenedFromDasahboard> | BaseTelemetryEvent<TelemetryEventName.COPILOT_GENERATED_CODE, CopilotGeneratedCode> | BaseTelemetryEvent<TelemetryEventName.FORMS_VIEWED, FormsViewed> | BaseTelemetryEvent<TelemetryEventName.USER_INVITED, UserInvited> | BaseTelemetryEvent<TelemetryEventName.FORMS_SUBMITTED, FormsViewed> | BaseTelemetryEvent<TelemetryEventName.REWARDS_OPENED, RewardButtonClicked> | BaseTelemetryEvent<TelemetryEventName.REWARDS_INSTRUCTION_CLICKED, RewardInstructionsClicked> | BaseTelemetryEvent<TelemetryEventName.TRIGGER_FAILURES_EXCEEDED, TriggerFailuresExceeded> | BaseTelemetryEvent<TelemetryEventName.AI_PROVIDER_USED, AiProviderConfiguredOrUsed> | BaseTelemetryEvent<TelemetryEventName.AI_PROVIDER_CONFIGURED, AiProviderConfiguredOrUsed>;
+export type TelemetryEvent = BaseTelemetryEvent<TelemetryEventName.SIGNED_UP, SignedUp> | BaseTelemetryEvent<TelemetryEventName.REFERRAL, Referral> | BaseTelemetryEvent<TelemetryEventName.REQUEST_TRIAL_CLICKED, RequestTrialClicked> | BaseTelemetryEvent<TelemetryEventName.KEY_ACTIVATED, KeyActivated> | BaseTelemetryEvent<TelemetryEventName.REQUEST_TRIAL_SUBMITTED, RequestTrialSubmitted> | BaseTelemetryEvent<TelemetryEventName.FLOW_ISSUE_CLICKED, FlowIssueClicked> | BaseTelemetryEvent<TelemetryEventName.FLOW_ISSUE_RESOLVED, FlowIssueResolved> | BaseTelemetryEvent<TelemetryEventName.UPGRADE_CLICKED, UpgradeClicked> | BaseTelemetryEvent<TelemetryEventName.UPGRADE_POPUP, UpgradePopup> | BaseTelemetryEvent<TelemetryEventName.FLOW_RUN_CREATED, RunCreated> | BaseTelemetryEvent<TelemetryEventName.FLOW_PUBLISHED, FlowPublished> | BaseTelemetryEvent<TelemetryEventName.QUOTA_ALERT, QuotaAlert> | BaseTelemetryEvent<TelemetryEventName.CREATED_FLOW, FlowCreated> | BaseTelemetryEvent<TelemetryEventName.TEMPLATE_SEARCH, TemplateSearch> | BaseTelemetryEvent<TelemetryEventName.PIECES_SEARCH, PiecesSearch> | BaseTelemetryEvent<TelemetryEventName.FLOW_IMPORTED, FlowImported> | BaseTelemetryEvent<TelemetryEventName.FLOW_IMPORTED_USING_FILE, FlowImportedUsingFile> | BaseTelemetryEvent<TelemetryEventName.REFERRAL_LINK_COPIED, ReferralLinkCopied> | BaseTelemetryEvent<TelemetryEventName.FLOW_SHARED, FlowShared> | BaseTelemetryEvent<TelemetryEventName.DEMO_IMPORTED, Record<string, never>> | BaseTelemetryEvent<TelemetryEventName.OPENED_PRICING_FROM_DASHBOARD, OpenedFromDashboard> | BaseTelemetryEvent<TelemetryEventName.COPILOT_GENERATED_CODE, CopilotGeneratedCode> | BaseTelemetryEvent<TelemetryEventName.FORMS_VIEWED, FormsViewed> | BaseTelemetryEvent<TelemetryEventName.USER_INVITED, UserInvited> | BaseTelemetryEvent<TelemetryEventName.FORMS_SUBMITTED, FormsViewed> | BaseTelemetryEvent<TelemetryEventName.REWARDS_OPENED, RewardButtonClicked> | BaseTelemetryEvent<TelemetryEventName.REWARDS_INSTRUCTION_CLICKED, RewardInstructionsClicked> | BaseTelemetryEvent<TelemetryEventName.TRIGGER_FAILURES_EXCEEDED, TriggerFailuresExceeded> | BaseTelemetryEvent<TelemetryEventName.AI_PROVIDER_USED, AiProviderConfiguredOrUsed> | BaseTelemetryEvent<TelemetryEventName.AI_PROVIDER_CONFIGURED, AiProviderConfiguredOrUsed>;
 export {};

src/lib/common/telemetry.js

@@ -10,3 +10,3 @@ "use strict";
     TelemetryEventName["REQUEST_TRIAL_SUBMITTED"] = "request.trial.submitted";
-    TelemetryEventName["KEY_ACTIVIATED"] = "key.activated";
+    TelemetryEventName["KEY_ACTIVATED"] = "key.activated";
     TelemetryEventName["FLOW_ISSUE_CLICKED"] = "flow.issue.clicked";
@@ -13,0 +13,0 @@ TelemetryEventName["FLOW_ISSUE_RESOLVED"] = "flow.issue.resolved";

src/lib/engine/requests.d.ts

@@ -7,2 +7,22 @@ import { Static } from '@sinclair/typebox';
         tasks: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TNumber>;
+        response: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TUnion<[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, import("@sinclair/typebox").TString>>;
+        }>, 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;
+            handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
+            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;
+            response: 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, import("@sinclair/typebox").TString>>;
+            }>;
+            handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
+            progressUpdateType: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof ProgressUpdateType>>;
+        }>]>]>>;
         pauseMetadata: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TUnion<[import("@sinclair/typebox").TObject<{
@@ -16,3 +36,7 @@ type: import("@sinclair/typebox").TLiteral<import("../flow-run/execution/flow-execution").PauseType.DELAY>;
             requestId: import("@sinclair/typebox").TString;
-            response: import("@sinclair/typebox").TUnknown;
+            response: 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, import("@sinclair/typebox").TString>>;
+            }>;
             handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
@@ -27,10 +51,25 @@ progressUpdateType: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof ProgressUpdateType>>;
         }>>;
-        stopResponse: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TObject<{
+    }>, 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.MEMORY_LIMIT_EXCEEDED>, import("@sinclair/typebox").TLiteral<import("../flow-run/execution/flow-execution").FlowRunStatus.STOPPED>]>;
+        tasks: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TNumber>;
+        response: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TUnion<[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, import("@sinclair/typebox").TString>>;
-        }>>;
-    }>, 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.MEMORY_LIMIT_EXCEEDED>, import("@sinclair/typebox").TLiteral<import("../flow-run/execution/flow-execution").FlowRunStatus.STOPPED>]>;
-        tasks: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TNumber>;
+        }>, 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;
+            handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
+            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;
+            response: 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, import("@sinclair/typebox").TString>>;
+            }>;
+            handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
+            progressUpdateType: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof ProgressUpdateType>>;
+        }>]>]>>;
         duration: import("@sinclair/typebox").TNumber;
@@ -42,7 +81,2 @@ tags: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TArray<import("@sinclair/typebox").TString>>;
         }>>;
-        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, import("@sinclair/typebox").TString>>;
-        }>>;
     }>]>;
@@ -75,2 +109,12 @@ executionStateBuffer: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
 }
+export declare const SendFlowResponseRequest: import("@sinclair/typebox").TObject<{
+    workerHandlerId: import("@sinclair/typebox").TString;
+    httpRequestId: import("@sinclair/typebox").TString;
+    runResponse: import("@sinclair/typebox").TObject<{
+        status: import("@sinclair/typebox").TNumber;
+        body: import("@sinclair/typebox").TAny;
+        headers: import("@sinclair/typebox").TRecord<import("@sinclair/typebox").TString, import("@sinclair/typebox").TString>;
+    }>;
+}>;
+export type SendFlowResponseRequest = Static<typeof SendFlowResponseRequest>;
 export declare const GetFlowVersionForWorkerRequest: import("@sinclair/typebox").TUnion<[import("@sinclair/typebox").TObject<{
@@ -77,0 +121,0 @@ type: import("@sinclair/typebox").TLiteral<GetFlowVersionForWorkerRequestType.LATEST>;

src/lib/engine/requests.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.GetFlowVersionForWorkerRequest = exports.GetFlowVersionForWorkerRequestType = exports.RemoveStableJobEngineRequest = exports.NotifyFrontendRequest = exports.UpdateRunProgressResponse = exports.UpdateRunProgressRequest = void 0;
+exports.GetFlowVersionForWorkerRequest = exports.SendFlowResponseRequest = exports.GetFlowVersionForWorkerRequestType = exports.RemoveStableJobEngineRequest = exports.NotifyFrontendRequest = exports.UpdateRunProgressResponse = exports.UpdateRunProgressRequest = void 0;
 const typebox_1 = require("@sinclair/typebox");
@@ -33,2 +33,11 @@ const common_1 = require("../common");
 })(GetFlowVersionForWorkerRequestType || (exports.GetFlowVersionForWorkerRequestType = GetFlowVersionForWorkerRequestType = {}));
+exports.SendFlowResponseRequest = typebox_1.Type.Object({
+    workerHandlerId: typebox_1.Type.String(),
+    httpRequestId: typebox_1.Type.String(),
+    runResponse: typebox_1.Type.Object({
+        status: typebox_1.Type.Number(),
+        body: typebox_1.Type.Any(),
+        headers: typebox_1.Type.Record(typebox_1.Type.String(), typebox_1.Type.String()),
+    }),
+});
 exports.GetFlowVersionForWorkerRequest = typebox_1.Type.Union([
@@ -35,0 +44,0 @@ typebox_1.Type.Object({

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

@@ -25,6 +25,22 @@ import { Static } from '@sinclair/typebox';
 export type DelayPauseMetadata = Static<typeof DelayPauseMetadata>;
+export declare const RespondResponse: 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, import("@sinclair/typebox").TString>>;
+}>;
+export type RespondResponse = Static<typeof RespondResponse>;
+export declare const StopResponse: 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, import("@sinclair/typebox").TString>>;
+}>;
+export type StopResponse = Static<typeof StopResponse>;
 export declare const WebhookPauseMetadata: import("@sinclair/typebox").TObject<{
     type: import("@sinclair/typebox").TLiteral<PauseType.WEBHOOK>;
     requestId: import("@sinclair/typebox").TString;
-    response: import("@sinclair/typebox").TUnknown;
+    response: 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, import("@sinclair/typebox").TString>>;
+    }>;
     handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
@@ -42,3 +58,7 @@ progressUpdateType: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof ProgressUpdateType>>;
     requestId: import("@sinclair/typebox").TString;
-    response: import("@sinclair/typebox").TUnknown;
+    response: 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, import("@sinclair/typebox").TString>>;
+    }>;
     handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
@@ -48,14 +68,2 @@ progressUpdateType: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof ProgressUpdateType>>;
 export type PauseMetadata = Static<typeof PauseMetadata>;
-export declare const StopResponse: 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, import("@sinclair/typebox").TString>>;
-}>;
-export type StopResponse = Static<typeof StopResponse>;
-export declare const RespondResponse: 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, import("@sinclair/typebox").TString>>;
-}>;
-export type RespondResponse = Static<typeof RespondResponse>;
 export declare const FlowError: import("@sinclair/typebox").TObject<{
@@ -76,3 +84,7 @@ stepName: import("@sinclair/typebox").TString;
         requestId: import("@sinclair/typebox").TString;
-        response: import("@sinclair/typebox").TUnknown;
+        response: 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, import("@sinclair/typebox").TString>>;
+        }>;
         handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
@@ -89,7 +101,22 @@ progressUpdateType: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof ProgressUpdateType>>;
     }>>;
-    stopResponse: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TObject<{
+    response: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TUnion<[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, import("@sinclair/typebox").TString>>;
-    }>>;
+    }>, import("@sinclair/typebox").TUnion<[import("@sinclair/typebox").TObject<{
+        type: import("@sinclair/typebox").TLiteral<PauseType.DELAY>;
+        resumeDateTime: import("@sinclair/typebox").TString;
+        handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
+        progressUpdateType: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof ProgressUpdateType>>;
+    }>, import("@sinclair/typebox").TObject<{
+        type: import("@sinclair/typebox").TLiteral<PauseType.WEBHOOK>;
+        requestId: import("@sinclair/typebox").TString;
+        response: 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, import("@sinclair/typebox").TString>>;
+        }>;
+        handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
+        progressUpdateType: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof ProgressUpdateType>>;
+    }>]>]>>;
 }>, import("@sinclair/typebox").TObject<{
@@ -105,7 +132,22 @@ status: import("@sinclair/typebox").TUnion<[import("@sinclair/typebox").TLiteral<FlowRunStatus.FAILED>, import("@sinclair/typebox").TLiteral<FlowRunStatus.SUCCEEDED>, import("@sinclair/typebox").TLiteral<FlowRunStatus.RUNNING>, import("@sinclair/typebox").TLiteral<FlowRunStatus.QUOTA_EXCEEDED>, import("@sinclair/typebox").TLiteral<FlowRunStatus.TIMEOUT>, import("@sinclair/typebox").TLiteral<FlowRunStatus.INTERNAL_ERROR>, import("@sinclair/typebox").TLiteral<FlowRunStatus.MEMORY_LIMIT_EXCEEDED>, import("@sinclair/typebox").TLiteral<FlowRunStatus.STOPPED>]>;
     }>>;
-    stopResponse: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TObject<{
+    response: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TUnion<[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, import("@sinclair/typebox").TString>>;
-    }>>;
+    }>, import("@sinclair/typebox").TUnion<[import("@sinclair/typebox").TObject<{
+        type: import("@sinclair/typebox").TLiteral<PauseType.DELAY>;
+        resumeDateTime: import("@sinclair/typebox").TString;
+        handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
+        progressUpdateType: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof ProgressUpdateType>>;
+    }>, import("@sinclair/typebox").TObject<{
+        type: import("@sinclair/typebox").TLiteral<PauseType.WEBHOOK>;
+        requestId: import("@sinclair/typebox").TString;
+        response: 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, import("@sinclair/typebox").TString>>;
+        }>;
+        handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
+        progressUpdateType: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof ProgressUpdateType>>;
+    }>]>]>>;
 }>]>;
@@ -112,0 +154,0 @@ export type FlowRunResponse = Static<typeof FlowRunResponse>;

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

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.isFailedState = exports.isFlowStateTerminal = exports.isFlowUserTerminalState = exports.FlowRunResponse = exports.FlowError = exports.RespondResponse = exports.StopResponse = exports.PauseMetadata = exports.WebhookPauseMetadata = exports.DelayPauseMetadata = exports.PauseType = exports.FlowRunStatus = void 0;
+exports.isFailedState = exports.isFlowStateTerminal = exports.isFlowUserTerminalState = exports.FlowRunResponse = exports.FlowError = exports.PauseMetadata = exports.WebhookPauseMetadata = exports.StopResponse = exports.RespondResponse = exports.DelayPauseMetadata = exports.PauseType = exports.FlowRunStatus = void 0;
 const typebox_1 = require("@sinclair/typebox");
@@ -29,11 +29,3 @@ const engine_1 = require("../../engine");
 });
-exports.WebhookPauseMetadata = typebox_1.Type.Object({
-    type: typebox_1.Type.Literal(PauseType.WEBHOOK),
-    requestId: typebox_1.Type.String(),
-    response: typebox_1.Type.Unknown(),
-    handlerId: typebox_1.Type.Optional(typebox_1.Type.String({})),
-    progressUpdateType: typebox_1.Type.Optional(typebox_1.Type.Enum(engine_1.ProgressUpdateType)),
-});
-exports.PauseMetadata = typebox_1.Type.Union([exports.DelayPauseMetadata, exports.WebhookPauseMetadata]);
-exports.StopResponse = typebox_1.Type.Object({
+exports.RespondResponse = typebox_1.Type.Object({
     status: typebox_1.Type.Optional(typebox_1.Type.Number()),
@@ -43,3 +35,3 @@ body: typebox_1.Type.Optional(typebox_1.Type.Unknown()),
 });
-exports.RespondResponse = typebox_1.Type.Object({
+exports.StopResponse = typebox_1.Type.Object({
     status: typebox_1.Type.Optional(typebox_1.Type.Number()),
@@ -49,2 +41,10 @@ body: typebox_1.Type.Optional(typebox_1.Type.Unknown()),
 });
+exports.WebhookPauseMetadata = typebox_1.Type.Object({
+    type: typebox_1.Type.Literal(PauseType.WEBHOOK),
+    requestId: typebox_1.Type.String(),
+    response: exports.RespondResponse,
+    handlerId: typebox_1.Type.Optional(typebox_1.Type.String({})),
+    progressUpdateType: typebox_1.Type.Optional(typebox_1.Type.Enum(engine_1.ProgressUpdateType)),
+});
+exports.PauseMetadata = typebox_1.Type.Union([exports.DelayPauseMetadata, exports.WebhookPauseMetadata]);
 exports.FlowError = typebox_1.Type.Object({
@@ -60,3 +60,3 @@ stepName: typebox_1.Type.String(),
     error: typebox_1.Type.Optional(exports.FlowError),
-    stopResponse: typebox_1.Type.Optional(exports.StopResponse),
+    response: typebox_1.Type.Optional(typebox_1.Type.Union([exports.RespondResponse, exports.PauseMetadata])),
 };
@@ -63,0 +63,0 @@ exports.FlowRunResponse = typebox_1.Type.Union([

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

@@ -39,3 +39,7 @@ import { Static } from '@sinclair/typebox';
         requestId: import("@sinclair/typebox").TString;
-        response: import("@sinclair/typebox").TUnknown;
+        response: 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, import("@sinclair/typebox").TString>>;
+        }>;
         handlerId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
@@ -42,0 +46,0 @@ progressUpdateType: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof import("../engine").ProgressUpdateType>>;

src/lib/flows/dto/flow-template-request.d.ts

@@ -85,3 +85,3 @@ import { Static } from '@sinclair/typebox';
     }>;
-    projectId: import("@sinclair/typebox").TString;
+    projectId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString>;
     platformId: import("@sinclair/typebox").TString;
@@ -88,0 +88,0 @@ id: import("@sinclair/typebox").TString;

src/lib/flows/dto/flow-template-request.js

@@ -13,3 +13,3 @@ "use strict";
 })(TemplateType || (exports.TemplateType = TemplateType = {}));
-exports.FlowTemplate = typebox_1.Type.Object(Object.assign(Object.assign({}, common_1.BaseModelSchema), { name: typebox_1.Type.String(), description: typebox_1.Type.String(), type: typebox_1.Type.Enum(TemplateType), tags: typebox_1.Type.Array(typebox_1.Type.String()), pieces: typebox_1.Type.Array(typebox_1.Type.String()), schemaVersion: (0, common_1.Nullable)(typebox_1.Type.String()), blogUrl: typebox_1.Type.Optional(typebox_1.Type.String()), template: exports.FlowVersionTemplate, projectId: typebox_1.Type.String(), platformId: typebox_1.Type.String() }));
+exports.FlowTemplate = typebox_1.Type.Object(Object.assign(Object.assign({}, common_1.BaseModelSchema), { name: typebox_1.Type.String(), description: typebox_1.Type.String(), type: typebox_1.Type.Enum(TemplateType), tags: typebox_1.Type.Array(typebox_1.Type.String()), pieces: typebox_1.Type.Array(typebox_1.Type.String()), schemaVersion: (0, common_1.Nullable)(typebox_1.Type.String()), blogUrl: typebox_1.Type.Optional(typebox_1.Type.String()), template: exports.FlowVersionTemplate, projectId: typebox_1.Type.Optional(typebox_1.Type.String()), platformId: typebox_1.Type.String() }));
 exports.FlowTemplateWithoutProjectInformation = typebox_1.Type.Omit(exports.FlowTemplate, ['projectId', 'platformId', 'id', 'type']);
@@ -16,0 +16,0 @@ exports.ListFlowTemplatesRequest = typebox_1.Type.Object({

src/lib/flows/operations/add-action-util.d.ts

@@ -5,3 +5,3 @@ import { Action } from '../actions/action';
 declare function clone(step: Action, oldNameToNewName: Record<string, string>): Action;
-export declare const addActionUtls: {
+export declare const addActionUtils: {
     mapToNewNames: typeof mapToNewNames;
@@ -8,0 +8,0 @@ clone: typeof clone;

src/lib/flows/operations/add-action-util.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.addActionUtls = void 0;
+exports.addActionUtils = void 0;
 const common_1 = require("../../common");
@@ -48,3 +48,3 @@ const flow_structure_util_1 = require("../util/flow-structure-util");
 }
-exports.addActionUtls = {
+exports.addActionUtils = {
     mapToNewNames,
@@ -51,0 +51,0 @@ clone,

src/lib/flows/operations/duplicate-step.js

@@ -14,5 +14,5 @@ "use strict";
     const clonedActionWithoutNextAction = Object.assign(Object.assign({}, clonedAction), { nextAction: undefined });
-    const oldNameToNewName = add_action_util_1.addActionUtls.mapToNewNames(flowVersion, [clonedActionWithoutNextAction]);
+    const oldNameToNewName = add_action_util_1.addActionUtils.mapToNewNames(flowVersion, [clonedActionWithoutNextAction]);
     const clonedSubflow = flow_structure_util_1.flowStructureUtil.transferStep(clonedActionWithoutNextAction, (step) => {
-        return add_action_util_1.addActionUtls.clone(step, oldNameToNewName);
+        return add_action_util_1.addActionUtils.clone(step, oldNameToNewName);
     });
@@ -46,5 +46,5 @@ const importOperations = (0, import_flow_1._getImportOperations)(clonedSubflow);
     if (!(0, common_1.isNil)(childRouter)) {
-        const oldNameToNewName = add_action_util_1.addActionUtls.mapToNewNames(flowVersion, [childRouter]);
+        const oldNameToNewName = add_action_util_1.addActionUtils.mapToNewNames(flowVersion, [childRouter]);
         const clonedSubflow = flow_structure_util_1.flowStructureUtil.transferStep(childRouter, (step) => {
-            return add_action_util_1.addActionUtls.clone(step, oldNameToNewName);
+            return add_action_util_1.addActionUtils.clone(step, oldNameToNewName);
         });
@@ -51,0 +51,0 @@ const importOperations = (0, import_flow_1._getImportOperations)(clonedSubflow);

src/lib/flows/operations/paste-operations.js

@@ -9,5 +9,5 @@ "use strict";
 const _getOperationsForPaste = (actions, flowVersion, pastingDetails) => {
-    const newNamesMap = add_action_util_1.addActionUtls.mapToNewNames(flowVersion, actions);
+    const newNamesMap = add_action_util_1.addActionUtils.mapToNewNames(flowVersion, actions);
     const clonedActions = actions.map(action => flow_structure_util_1.flowStructureUtil.transferStep(action, (step) => {
-        return add_action_util_1.addActionUtls.clone(step, newNamesMap);
+        return add_action_util_1.addActionUtils.clone(step, newNamesMap);
     }));
@@ -14,0 +14,0 @@ const operations = [];

src/lib/platform/platform.model.d.ts

@@ -140,3 +140,3 @@ import { Static } from '@sinclair/typebox';
     smtp: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TUnsafe<{} | null>>;
-    defaultLocale: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TEnum<typeof LocalesEnum>>;
+    defaultLocale: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TUnsafe<string | null>>;
     federatedAuthProviders: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TUnsafe<{
@@ -143,0 +143,0 @@ google?: {

src/lib/platform/platform.model.js

@@ -63,3 +63,3 @@ "use strict";
         federatedAuthProviders: (0, base_model_1.Nullable)(federated_authn_1.FederatedAuthnProviderConfigWithoutSensitiveData),
-        defaultLocale: typebox_1.Type.Optional(typebox_1.Type.Enum(common_1.LocalesEnum)),
+        defaultLocale: (0, base_model_1.Nullable)(typebox_1.Type.String()),
         copilotSettings: typebox_1.Type.Optional(exports.CopilotSettingsWithoutSensitiveData),
@@ -66,0 +66,0 @@ smtp: (0, base_model_1.Nullable)(typebox_1.Type.Object({})),

No alert changes

Improved metrics

Total package byte prevSize

807054

1.1%

Lines of code

11441

0.87%

No dependency changes