@activepieces/shared
Advanced tools
Comparing version 0.3.47 to 0.3.48
{ | ||
"name": "@activepieces/shared", | ||
"version": "0.3.47", | ||
"version": "0.3.48", | ||
"type": "commonjs", | ||
@@ -5,0 +5,0 @@ "dependencies": { |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.ApId = exports.apId = exports.ExecutionState = exports.RunEnvironment = exports.FlowVersionState = exports.FlowVersion = 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; | ||
exports.ApId = exports.apId = exports.ExecutionState = exports.RunEnvironment = exports.Flow = exports.FlowVersionState = exports.FlowVersion = 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"); | ||
@@ -58,2 +58,4 @@ tslib_1.__exportStar(require("./lib/flows/actions/action"), exports); | ||
Object.defineProperty(exports, "FlowVersionState", { enumerable: true, get: function () { return flow_version_1.FlowVersionState; } }); | ||
var flow_1 = require("./lib/flows/flow"); | ||
Object.defineProperty(exports, "Flow", { enumerable: true, get: function () { return flow_1.Flow; } }); | ||
tslib_1.__exportStar(require("./lib/flows/flow-helper"), exports); | ||
@@ -60,0 +62,0 @@ var flow_run_1 = require("./lib/flow-run/flow-run"); |
@@ -108,3 +108,3 @@ import { ResumeStepMetadata } from "../flow-run/execution/execution-output"; | ||
listeners: AppEventListener[]; | ||
scheduleOptions: ScheduleOptions; | ||
scheduleOptions?: ScheduleOptions; | ||
} | ||
@@ -119,3 +119,3 @@ 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; | ||
cronExpression: string; | ||
timezone?: string; | ||
timezone: string; | ||
} | ||
@@ -122,0 +122,0 @@ export declare type EngineResponse<T> = { |
@@ -7,2 +7,5 @@ import { Static } from "@sinclair/typebox"; | ||
export declare type FlowInstanceId = ApId; | ||
export declare enum ScheduleType { | ||
CRON_EXPRESSION = "CRON_EXPRESSION" | ||
} | ||
export declare enum FlowInstanceStatus { | ||
@@ -13,2 +16,8 @@ ENABLED = "ENABLED", | ||
} | ||
export declare const FlowScheduleOptions: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TObject<{ | ||
type: import("@sinclair/typebox").TLiteral<ScheduleType>; | ||
cronExpression: import("@sinclair/typebox").TString<string>; | ||
timezone: import("@sinclair/typebox").TString<string>; | ||
}>>; | ||
export declare type FlowScheduleOptions = Static<typeof FlowScheduleOptions>; | ||
export declare const FlowInstance: import("@sinclair/typebox").TObject<{ | ||
@@ -18,2 +27,7 @@ projectId: import("@sinclair/typebox").TString<string>; | ||
flowVersionId: import("@sinclair/typebox").TString<string>; | ||
schedule: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TObject<{ | ||
type: import("@sinclair/typebox").TLiteral<ScheduleType>; | ||
cronExpression: import("@sinclair/typebox").TString<string>; | ||
timezone: import("@sinclair/typebox").TString<string>; | ||
}>>; | ||
status: import("@sinclair/typebox").TEnum<typeof FlowInstanceStatus>; | ||
@@ -20,0 +34,0 @@ id: import("@sinclair/typebox").TString<string>; |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.FlowInstance = exports.FlowInstanceStatus = void 0; | ||
exports.FlowInstance = exports.FlowScheduleOptions = exports.FlowInstanceStatus = exports.ScheduleType = void 0; | ||
const typebox_1 = require("@sinclair/typebox"); | ||
const common_1 = require("../../common"); | ||
var ScheduleType; | ||
(function (ScheduleType) { | ||
ScheduleType["CRON_EXPRESSION"] = "CRON_EXPRESSION"; | ||
})(ScheduleType = exports.ScheduleType || (exports.ScheduleType = {})); | ||
var FlowInstanceStatus; | ||
@@ -12,3 +16,8 @@ (function (FlowInstanceStatus) { | ||
})(FlowInstanceStatus = exports.FlowInstanceStatus || (exports.FlowInstanceStatus = {})); | ||
exports.FlowInstance = typebox_1.Type.Object(Object.assign(Object.assign({}, common_1.BaseModelSchema), { projectId: typebox_1.Type.String(), flowId: typebox_1.Type.String(), flowVersionId: typebox_1.Type.String(), status: typebox_1.Type.Enum(FlowInstanceStatus) })); | ||
exports.FlowScheduleOptions = typebox_1.Type.Optional(typebox_1.Type.Object({ | ||
type: typebox_1.Type.Literal(ScheduleType.CRON_EXPRESSION), | ||
cronExpression: typebox_1.Type.String(), | ||
timezone: typebox_1.Type.String(), | ||
})); | ||
exports.FlowInstance = typebox_1.Type.Object(Object.assign(Object.assign({}, common_1.BaseModelSchema), { projectId: typebox_1.Type.String(), flowId: typebox_1.Type.String(), flowVersionId: typebox_1.Type.String(), schedule: exports.FlowScheduleOptions, status: typebox_1.Type.Enum(FlowInstanceStatus) })); | ||
//# sourceMappingURL=flow-instance.js.map |
@@ -1,13 +0,65 @@ | ||
import { BaseModel } from "../common/base-model"; | ||
import { ApId } from "../common/id-generator"; | ||
import { FlowVersion } from "./flow-version"; | ||
import { ProjectId } from "../project/project"; | ||
import { FolderId } from "./folders/folder"; | ||
import { FlowInstanceStatus } from "./flow-instances"; | ||
import { Static } from "@sinclair/typebox"; | ||
export declare type FlowId = ApId; | ||
export interface Flow extends BaseModel<FlowId> { | ||
projectId: ProjectId; | ||
folderId?: FolderId | null; | ||
version: FlowVersion; | ||
status: FlowInstanceStatus; | ||
} | ||
export declare const Flow: import("@sinclair/typebox").TObject<{ | ||
projectId: import("@sinclair/typebox").TString<string>; | ||
folderId: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString<string>>; | ||
version: import("@sinclair/typebox").TObject<{ | ||
flowId: import("@sinclair/typebox").TString<string>; | ||
displayName: import("@sinclair/typebox").TString<string>; | ||
trigger: import("@sinclair/typebox").TUnion<[import("@sinclair/typebox").TObject<{ | ||
type: import("@sinclair/typebox").TLiteral<import("./triggers/trigger").TriggerType.WEBHOOK>; | ||
settings: import("@sinclair/typebox").TObject<{ | ||
inputUiInfo: import("@sinclair/typebox").TObject<{ | ||
currentSelectedData: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TUnknown>; | ||
customizedInputs: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TRecord<import("@sinclair/typebox").TString<string>, import("@sinclair/typebox").TUnknown>>; | ||
lastTestDate: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString<string>>; | ||
}>; | ||
}>; | ||
name: import("@sinclair/typebox").TString<string>; | ||
valid: import("@sinclair/typebox").TBoolean; | ||
displayName: import("@sinclair/typebox").TString<string>; | ||
nextAction: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TAny>; | ||
}>, import("@sinclair/typebox").TObject<{ | ||
type: import("@sinclair/typebox").TLiteral<import("./triggers/trigger").TriggerType.PIECE>; | ||
settings: import("@sinclair/typebox").TObject<{ | ||
pieceName: import("@sinclair/typebox").TString<string>; | ||
pieceVersion: import("@sinclair/typebox").TString<string>; | ||
triggerName: import("@sinclair/typebox").TString<string>; | ||
input: import("@sinclair/typebox").TRecord<import("@sinclair/typebox").TString<string>, import("@sinclair/typebox").TAny>; | ||
inputUiInfo: import("@sinclair/typebox").TObject<{ | ||
currentSelectedData: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TUnknown>; | ||
customizedInputs: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TRecord<import("@sinclair/typebox").TString<string>, import("@sinclair/typebox").TUnknown>>; | ||
lastTestDate: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TString<string>>; | ||
}>; | ||
}>; | ||
name: import("@sinclair/typebox").TString<string>; | ||
valid: import("@sinclair/typebox").TBoolean; | ||
displayName: import("@sinclair/typebox").TString<string>; | ||
nextAction: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TAny>; | ||
}>, import("@sinclair/typebox").TObject<{ | ||
type: import("@sinclair/typebox").TLiteral<import("./triggers/trigger").TriggerType.EMPTY>; | ||
settings: import("@sinclair/typebox").TAny; | ||
name: import("@sinclair/typebox").TString<string>; | ||
valid: import("@sinclair/typebox").TBoolean; | ||
displayName: import("@sinclair/typebox").TString<string>; | ||
nextAction: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TAny>; | ||
}>]>; | ||
valid: import("@sinclair/typebox").TBoolean; | ||
state: import("@sinclair/typebox").TEnum<typeof import("./flow-version").FlowVersionState>; | ||
id: import("@sinclair/typebox").TString<string>; | ||
created: import("@sinclair/typebox").TString<string>; | ||
updated: import("@sinclair/typebox").TString<string>; | ||
}>; | ||
status: import("@sinclair/typebox").TEnum<typeof FlowInstanceStatus>; | ||
schedule: import("@sinclair/typebox").TOptional<import("@sinclair/typebox").TObject<{ | ||
type: import("@sinclair/typebox").TLiteral<import("./flow-instances").ScheduleType>; | ||
cronExpression: import("@sinclair/typebox").TString<string>; | ||
timezone: import("@sinclair/typebox").TString<string>; | ||
}>>; | ||
id: import("@sinclair/typebox").TString<string>; | ||
created: import("@sinclair/typebox").TString<string>; | ||
updated: import("@sinclair/typebox").TString<string>; | ||
}>; | ||
export declare type Flow = Static<typeof Flow>; |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.Flow = void 0; | ||
const base_model_1 = require("../common/base-model"); | ||
const flow_version_1 = require("./flow-version"); | ||
const flow_instances_1 = require("./flow-instances"); | ||
const typebox_1 = require("@sinclair/typebox"); | ||
exports.Flow = typebox_1.Type.Object(Object.assign(Object.assign({}, base_model_1.BaseModelSchema), { projectId: typebox_1.Type.String(), folderId: typebox_1.Type.Optional(typebox_1.Type.String()), version: flow_version_1.FlowVersion, | ||
// TODO revisit this area as these filled from Instance during listing. | ||
status: typebox_1.Type.Enum(flow_instances_1.FlowInstanceStatus), schedule: flow_instances_1.FlowScheduleOptions })); | ||
//# sourceMappingURL=flow.js.map |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
301101
4224