Skip to main content

Class: abstract Digestor

Defined in: core/actions/src/coalescing-manager.ts:141

Structure actions.

Extends this class to build new actions behaviors.

Extends​

Constructors​

Constructor​

new Digestor(): Digestor

Defined in: core/actions/src/workflow-manager.ts:76

Returns​

Digestor

Inherited from​

CoalescingWorkflow.constructor

Properties​

dbDoc​

dbDoc: ActionSchemaInterface<JSONObject, { actions: {[key: string]: object; }; currentStepIndex?: number; currentStepName?: string; currentTrackIds: string[]; isRollBackPossible: boolean; nTimesCurrentStep: number; oldResult: StepResult[]; preserveOldResult: StepResult[]; registeredActions: object[]; stepsHistory: number[]; }, void | Error | JSONObject>

Defined in: core/actions/src/action-manager.ts:106

Action Database Document

Inherited from​

CoalescingWorkflow.dbDoc

dBSession?​

optional dBSession: ClientSession

Defined in: core/actions/src/workflow-manager.ts:47

Inherited from​

CoalescingWorkflow.dBSession

defineCallMode​

defineCallMode: "main" | "actionFinding"

Defined in: core/actions/src/workflow-manager.ts:229

Inherited from​

CoalescingWorkflow.defineCallMode

docsToSaveAtStepStart​

docsToSaveAtStepStart: Document<any, any, any>[] = []

Defined in: core/actions/src/workflow-manager.ts:49

Inherited from​

CoalescingWorkflow.docsToSaveAtStepStart

dynamicActionFound​

dynamicActionFound: Action

Defined in: core/actions/src/workflow-manager.ts:241

Inherited from​

CoalescingWorkflow.dynamicActionFound

dynamicActionToFound​

dynamicActionToFound: ActionSchemaInterface

Defined in: core/actions/src/workflow-manager.ts:240

Inherited from​

CoalescingWorkflow.dynamicActionToFound

executingDefine​

executingDefine: boolean = false

Defined in: core/actions/src/workflow-manager.ts:228

Inherited from​

CoalescingWorkflow.executingDefine

executor?​

optional executor: Executor

Defined in: core/actions/src/action-manager.ts:40

Specify an executor in which all actions of this class will run.

Inherited from​

CoalescingWorkflow.executor

IArgument​

IArgument: JSONObject

Defined in: core/actions/src/action-manager.ts:91

Action argument

Inherited from​

CoalescingWorkflow.IArgument

IBag​

IBag: object

Defined in: core/actions/src/workflow-manager.ts:53

Action bag

actions​

actions: object

Index Signature​

[key: string]: object

currentStepIndex?​

optional currentStepIndex: number

currentStepName?​

optional currentStepName: string

currentTrackIds​

currentTrackIds: string[]

isRollBackPossible​

isRollBackPossible: boolean

nTimesCurrentStep​

nTimesCurrentStep: number

oldResult​

oldResult: StepResult[]

preserveOldResult​

preserveOldResult: StepResult[]

registeredActions​

registeredActions: object[]

stepsHistory​

stepsHistory: number[]

Inherited from​

CoalescingWorkflow.IBag

IResult​

IResult: void | Error | JSONObject

Defined in: core/actions/src/action-manager.ts:101

Action result

Inherited from​

CoalescingWorkflow.IResult

isExecutorSet​

isExecutorSet: boolean = false

Defined in: core/actions/src/action-manager.ts:497

Inherited from​

CoalescingWorkflow.isExecutorSet

isInitialized​

isInitialized: boolean = false

Defined in: core/actions/src/action-manager.ts:482

Inherited from​

CoalescingWorkflow.isInitialized

mapRefWithStrategy​

mapRefWithStrategy: Map<string, "default" | "cross-workflow">

Defined in: core/actions/src/coalescing-manager.ts:92

Inherited from​

CoalescingWorkflow.mapRefWithStrategy

notifyHealthPromise​

notifyHealthPromise: Promise<any> = undefined

Defined in: core/actions/src/action-manager.ts:930

Send a signal to indicate that the action is still in progress.. Useful for preventing timeouts when the action's duration is long but not precisely predictable.

Inherited from​

CoalescingWorkflow.notifyHealthPromise

registeredActionIds​

registeredActionIds: any[] = []

Defined in: core/actions/src/workflow-manager.ts:497

Inherited from​

CoalescingWorkflow.registeredActionIds

resolveDefineIteration()​

resolveDefineIteration: (actionState?) => void

Defined in: core/actions/src/workflow-manager.ts:275

Parameters​

actionState?​

ActionState

Returns​

void

Inherited from​

CoalescingWorkflow.resolveDefineIteration

runtime​

runtime: ActionRuntime = ActionRuntime.activeRuntime

Defined in: core/actions/src/action-manager.ts:42

Inherited from​

CoalescingWorkflow.runtime

steps​

steps: Step[] = []

Defined in: core/actions/src/workflow-manager.ts:51

Inherited from​

CoalescingWorkflow.steps

cronDefaultSettings​

static cronDefaultSettings: object

Defined in: core/actions/src/action-manager.ts:82

Configure the frequency at which a cron will launch Action.resume. It is also possible to dynamically modify the dbDoc.cronActivity property to modify the call to a cron. If not set, this property will be 'inherited' from the first parent class where it is.

activityFrequency​

activityFrequency: number

Inherited from​

CoalescingWorkflow.cronDefaultSettings

defaultDelay​

static defaultDelay: number = Infinity

Defined in: core/actions/src/workflow-manager.ts:43

Shortcut to [ActionState.IN_PROGRESS].

If not set, this property will be 'inherited' from the first parent class where it is.

Inherited from​

CoalescingWorkflow.defaultDelay

defaultDelays​

static defaultDelays: object

Defined in: core/actions/src/action-manager.ts:70

For the states ActionState.EXECUTING_MAIN and ActionState.IN_PROGRESS, this object configures the time after which, if no change happened, an action is considered in error.

For example, an action can only be in the ActionState.IN_PROGRESS state for as long as defaultDelays[ActionState.IN_PROGRESS] time.

1?​

optional 1: number

2?​

optional 2: number

Default Value​

{
   [ActionState.IN_PROGRESS]: this.defaultDelay,
   [ActionState.EXECUTING_MAIN]: 2*60*1000,
}

You should configure this if your actions have longer timeouts.

If not set, this property will be 'inherited' from the first parent class where it is.

Inherited from​

CoalescingWorkflow.defaultDelays

permanentRef​

static permanentRef: string | string[]

Defined in: core/actions/src/action-manager.ts:35

Id of the action stored in database. It should be a permanent id that designates the action instance.

Inherited from​

CoalescingWorkflow.permanentRef

Accessors​

_id​

Get Signature​

get _id(): this["dbDoc"]["_id"]

Defined in: core/actions/src/action-manager.ts:157

Returns​

this["dbDoc"]["_id"]

Inherited from​

CoalescingWorkflow._id

argument​

Get Signature​

get argument(): this["dbDoc"]["argument"]

Defined in: core/actions/src/action-manager.ts:121

Returns​

this["dbDoc"]["argument"]

Set Signature​

set argument(argument): void

Defined in: core/actions/src/action-manager.ts:125

Parameters​
argument​

this["dbDoc"]["argument"]

Returns​

void

Inherited from​

CoalescingWorkflow.argument

bag​

Get Signature​

get bag(): this["dbDoc"]["bag"]

Defined in: core/actions/src/action-manager.ts:112

Returns​

this["dbDoc"]["bag"]

Set Signature​

set bag(bag): void

Defined in: core/actions/src/action-manager.ts:116

Parameters​
bag​

this["dbDoc"]["bag"]

Returns​

void

Inherited from​

CoalescingWorkflow.bag

cronActivity​

Get Signature​

get cronActivity(): this["dbDoc"]["cronActivity"]

Defined in: core/actions/src/action-manager.ts:148

Returns​

this["dbDoc"]["cronActivity"]

Set Signature​

set cronActivity(cronActivity): void

Defined in: core/actions/src/action-manager.ts:152

Parameters​
cronActivity​

this["dbDoc"]["cronActivity"]

Returns​

void

Inherited from​

CoalescingWorkflow.cronActivity

repeat​

Get Signature​

get repeat(): this["dbDoc"]["repeat"]

Defined in: core/actions/src/action-manager.ts:139

Returns​

this["dbDoc"]["repeat"]

Set Signature​

set repeat(repeat): void

Defined in: core/actions/src/action-manager.ts:143

Parameters​
repeat​

this["dbDoc"]["repeat"]

Returns​

void

Inherited from​

CoalescingWorkflow.repeat

result​

Get Signature​

get result(): this["dbDoc"]["result"]

Defined in: core/actions/src/action-manager.ts:130

Returns​

this["dbDoc"]["result"]

Set Signature​

set result(result): void

Defined in: core/actions/src/action-manager.ts:134

Parameters​
result​

this["dbDoc"]["result"]

Returns​

void

Inherited from​

CoalescingWorkflow.result

Methods​

_resume()​

_resume(): any

Defined in: core/actions/src/action-manager.ts:631

The function resumes the action by calling the appropriate function depending on the current state of the action. It doesn't take into account the executor.

Returns​

any

A promise. You can not rely on this to know when an action is finished.

Inherited from​

CoalescingWorkflow._resume

activityLogs()​

activityLogs(options): any[] | Promise<any[]>

Defined in: core/actions/src/action-manager.ts:775

Parameters​

options​

any

Returns​

any[] | Promise<any[]>

Inherited from​

CoalescingWorkflow.activityLogs

breakAndReject()​

breakAndReject(result): RejectAction

Defined in: core/actions/src/workflow-manager.ts:200

Parameters​

result​

any

Returns​

RejectAction

Inherited from​

CoalescingWorkflow.breakAndReject

breakAndReturn()​

breakAndReturn(result): ResolveAction

Defined in: core/actions/src/workflow-manager.ts:193

Parameters​

result​

any

Returns​

ResolveAction

Inherited from​

CoalescingWorkflow.breakAndReturn

clone()​

clone(): any

Defined in: core/actions/src/action-manager.ts:899

Clone the action.

Returns​

any

a new action with the same argument

Inherited from​

CoalescingWorkflow.clone

define()​

define(): Promise<{ }>

Defined in: core/actions/src/coalescing-manager.ts:142

Defines the workflow logic. Called multiple times for a single workflow process. Use the do method to apply mutating operations.

Returns​

Promise<{ }>

Promise that resolves with an argument of type this['IResult'].

Overrides​

CoalescingWorkflow.define

defineDynamicAction()​

defineDynamicAction(actionDb): Promise<Action>

Defined in: core/actions/src/workflow-manager.ts:243

Parameters​

actionDb​

ActionSchemaInterface

Returns​

Promise<Action>

Inherited from​

CoalescingWorkflow.defineDynamicAction

digest()​

digest(): Promise<string[]>

Defined in: core/actions/src/coalescing-manager.ts:155

Returns​

Promise<string[]>

do()​

Call Signature​

do<T>(ref, action): DoPromise<T["IResult"]>

Defined in: core/actions/src/workflow-manager.ts:507

Executes an action in the workflow. If the action already exists, it will be tracked and resumed. If not, it will be started.

Type Parameters​
T​

T extends Action

Parameters​
ref​

string

the step reference of the action to execute

action​

T

Returns​

DoPromise<T["IResult"]>

a promise that resolves with the result of the action

Inherited from​

CoalescingWorkflow.do

Call Signature​

do<T>(ref, cb): DoPromise<T>

Defined in: core/actions/src/workflow-manager.ts:517

Executes an action in the workflow. If the action already exists, it will be tracked and resumed. If not, it will be started.

Type Parameters​
T​

T

Parameters​
ref​

string

the step reference of the action to execute

cb​

() => Promise<T>

a callback that returns a promise

Returns​

DoPromise<T>

a promise that resolves with the result of the promise

Inherited from​

CoalescingWorkflow.do

Call Signature​

do(ref, opts): DoPromise<any>

Defined in: core/actions/src/workflow-manager.ts:530

Executes an action in the workflow. If the action already exists, it will be tracked and resumed. If not, it will be started.

Parameters​
ref​

string

the step reference of the action to execute

opts​

an object containing a pattern of the action to execute

init?​

() => Promise<any>

the init method of the action

main​

() => ActionState | Promise<ActionState>

the main method of the action

watcher?​

() => Promise<ActionState>

the watcher method of the action

Returns​

DoPromise<any>

a promise that resolves with the result of the action

Inherited from​

CoalescingWorkflow.do

Call Signature​

do<T>(ref, opts): any

Defined in: core/actions/src/workflow-manager.ts:548

Executes an action in the workflow. If the action already exists, it will be tracked and resumed. If not, it will be started.

Type Parameters​
T​

T extends Action

Parameters​
ref​

string

the step reference of the action to execute

opts​

an object containing an instantiation of a dynamic action

dynamicAction​

T | () => T

an action or a function that returns an action

Returns​

any

a promise that resolves with the result of the action

Inherited from​

CoalescingWorkflow.do

Call Signature​

do<T>(ref, opts, params?): DoPromise<T>

Defined in: core/actions/src/workflow-manager.ts:554

Executes an action in the workflow. If the action already exists, it will be tracked and resumed. If not, it will be started.

Type Parameters​
T​

T

Parameters​
ref​

string

the step reference of the action to execute

opts​

Action |

{ init?: () => Promise<any>; main: () => ActionState | Promise<ActionState>; watcher?: () => Promise<ActionState>; }

init?​

() => Promise<any>

main​

() => ActionState | Promise<ActionState>

watcher?​

() => Promise<ActionState>

| { dynamicAction: Action | () => Action; } | () => Promise<any>

params?​
nCall​

number

Returns​

DoPromise<T>

a promise that resolves with the result of the action

Inherited from​

CoalescingWorkflow.do

dynamicallyDefineFromWorkflowStep()​

dynamicallyDefineFromWorkflowStep(workflow, marker): void

Defined in: core/actions/src/action-manager.ts:312

Parameters​

workflow​

Workflow

marker​

string

Returns​

void

Inherited from​

CoalescingWorkflow.dynamicallyDefineFromWorkflowStep

findIfEquivalentActionAlreadyExists()​

findIfEquivalentActionAlreadyExists(ref, action): Promise<ActionSchemaInterface<any, any, any>>

Defined in: core/actions/src/coalescing-manager.ts:93

Parameters​

ref​

string

action​

Action

Returns​

Promise<ActionSchemaInterface<any, any, any>>

Inherited from​

CoalescingWorkflow.findIfEquivalentActionAlreadyExists

getLogs()​

getLogs(options): Promise<any[]>

Defined in: core/actions/src/action-manager.ts:779

Parameters​

options​
endTime?​

number

Returns​

Promise<any[]>

Inherited from​

CoalescingWorkflow.getLogs

goTo()​

goTo(name, onState): Digestor

Defined in: core/actions/src/workflow-manager.ts:185

Parameters​

name​

string

onState​

ActionState

Returns​

Digestor

Inherited from​

CoalescingWorkflow.goTo

goToStep()​

goToStep(name): ResolveAction

Defined in: core/actions/src/workflow-manager.ts:176

Parameters​

name​

string

Returns​

ResolveAction

Inherited from​

CoalescingWorkflow.goToStep

identity()​

identity(): any

Defined in: core/actions/src/coalescing-manager.ts:26

Returns​

any

Inherited from​

CoalescingWorkflow.identity

init()​

init(): Promise<any>

Defined in: core/actions/src/action-manager.ts:398

Initialize the action from the action stored in the database.

Example: In order to not store secrets in the database, you can set a vault id in the argument and retrieve the secret at the initialization of the action.

Example: You cannot store class object on the database. If your action use complex object, they can be initialized here.

Returns​

Promise<any>

Inherited from​

CoalescingWorkflow.init

initialization()​

initialization(): Promise<void>

Defined in: core/actions/src/action-manager.ts:489

Mainly used for workflows. Can also complement init(). If it gets too complex, use hooks.

Returns​

Promise<void>

Inherited from​

CoalescingWorkflow.initialization

internalLog()​

internalLog(message, opts): void

Defined in: core/actions/src/action-manager.ts:840

Log a message in the internal logger.

Parameters​

message​

string

The message to log.

opts​

Options for logging, such as the log level. the final log message will be:

{
    actionRef: this.dbDoc.actionRef,
    actionId: this.dbDoc._id.toString(),
    filter: this.dbDoc.filter,
    definedIn: this.dbDoc.definitionFrom.workflow?.toObject(),
    timestamp: new Date().toISOString(),
    level: opts.level || 'info',
    message: message,
}
level​

string = 'debug'

Returns​

void

Inherited from​

CoalescingWorkflow.internalLog

internalLogError()​

internalLogError(err): void

Defined in: core/actions/src/workflow-manager.ts:835

Log an error in the internal logger.

Parameters​

err​

Error

The error to log. the final log message will be:

{
    actionRef: this.dbDoc.actionRef,
    actionId: this.dbDoc._id.toString(),
    filter: this.dbDoc.filter,
    definedIn: this.dbDoc.definitionFrom.workflow?.toObject(),
    err: err,
    timestamp: new Date().toISOString(),
}

Returns​

void

Inherited from​

CoalescingWorkflow.internalLogError

isActionActive()​

isActionActive(action): boolean

Defined in: core/actions/src/workflow-manager.ts:217

Parameters​

action​

Action

Returns​

boolean

Inherited from​

CoalescingWorkflow.isActionActive

lastOutput()​

lastOutput(): Promise<any>

Defined in: core/actions/src/coalescing-manager.ts:132

Returns​

Promise<any>

Inherited from​

CoalescingWorkflow.lastOutput

main()​

main(): Promise<ActionState>

Defined in: core/actions/src/workflow-manager.ts:319

This method should launched the main action process It is called only one time. It returns a state value.

Returns​

Promise<ActionState>

Inherited from​

CoalescingWorkflow.main

name()​

name(name): Digestor

Defined in: core/actions/src/workflow-manager.ts:169

Parameters​

name​

string

Returns​

Digestor

Inherited from​

CoalescingWorkflow.name

next()​

next(cb, opts?): Digestor

Defined in: core/actions/src/workflow-manager.ts:92

Parameters​

cb​

(...args) => void | Action | Action[] | Promise<void | Action | Action[]>

opts?​
retry​

number

Returns​

Digestor

Inherited from​

CoalescingWorkflow.next

notifyHealth()​

notifyHealth(): Promise<any>

Defined in: core/actions/src/action-manager.ts:931

Returns​

Promise<any>

Inherited from​

CoalescingWorkflow.notifyHealth

once()​

once(ref, opts): Promise<unknown>

Defined in: core/actions/src/coalescing-manager.ts:114

Parameters​

ref​

string

opts​

Action |

{ init?: () => Promise<any>; main: () => ActionState | Promise<ActionState>; watcher?: () => Promise<ActionState>; }

init?​

() => Promise<any>

main​

() => ActionState | Promise<ActionState>

watcher?​

() => Promise<ActionState>

| { dynamicAction: Action | () => Action; } | () => Promise<any>

Returns​

Promise<unknown>

Inherited from​

CoalescingWorkflow.once

onComplete()​

onComplete(cb, opts?): Digestor

Defined in: core/actions/src/workflow-manager.ts:109

Parameters​

cb​

(...args) => void | Action | Action[] | Promise<void | Action | Action[]>

opts?​
retry​

number

Returns​

Digestor

Inherited from​

CoalescingWorkflow.onComplete

onError()​

onError(cb, opts?): Digestor

Defined in: core/actions/src/workflow-manager.ts:100

Parameters​

cb​

(...args) => void | Action | Action[] | Promise<void | Action | Action[]>

opts?​
retry​

number

Returns​

Digestor

Inherited from​

CoalescingWorkflow.onError

onErrorGoTo()​

onErrorGoTo(name): Digestor

Defined in: core/actions/src/workflow-manager.ts:212

Parameters​

name​

string

Returns​

Digestor

Inherited from​

CoalescingWorkflow.onErrorGoTo

onMainTimeout()​

onMainTimeout(): ActionState | Promise<ActionState>

Defined in: core/actions/src/workflow-manager.ts:737

Called in case of timeout in ActionState.EXECUTING_MAIN state.

It can return ActionState.SLEEPING if the process infers that main() has not run and the action must be retried.

Returns​

ActionState | Promise<ActionState>

a ActionState value.

Inherited from​

CoalescingWorkflow.onMainTimeout

onSuccessGoTo()​

onSuccessGoTo(name): Digestor

Defined in: core/actions/src/workflow-manager.ts:207

Parameters​

name​

string

Returns​

Digestor

Inherited from​

CoalescingWorkflow.onSuccessGoTo

repeatDo()​

Call Signature​

repeatDo<T>(ref, cb, repeat): DoPromise<T>

Defined in: core/actions/src/workflow-manager.ts:694

Repeats a do a number of times.

Type Parameters​
T​

T

Parameters​
ref​

string

the step reference of the action to repeat

cb​

() => Promise<T>

a callback that returns a promise

repeat​

object & object

an object containing the number of times to repeat the action

Returns​

DoPromise<T>

a promise that resolves with the result of the last action

Inherited from​

CoalescingWorkflow.repeatDo

Call Signature​

repeatDo<T>(ref, opts, repeat): DoPromise<T>

Defined in: core/actions/src/workflow-manager.ts:699

Repeats a do a number of times.

Type Parameters​
T​

T

Parameters​
ref​

string

the step reference of the action to repeat

opts​

() => Promise<T>

repeat​

object & object

an object containing the number of times to repeat the action

Returns​

DoPromise<T>

a promise that resolves with the result of the last action

Inherited from​

CoalescingWorkflow.repeatDo

resolveDynamicActionFinding()​

resolveDynamicActionFinding(): void

Defined in: core/actions/src/workflow-manager.ts:242

Returns​

void

Inherited from​

CoalescingWorkflow.resolveDynamicActionFinding

resume()​

resume(): Promise<any>

Defined in: core/actions/src/action-manager.ts:600

The function resumes the action by calling the appropriate executor if needed and then by calling the appropriate function depending on the current state of the action

Returns​

Promise<any>

A promise. You can not rely on this to know when an action is finished.

Inherited from​

CoalescingWorkflow.resume

resyncWithDb()​

resyncWithDb(): Promise<void>

Defined in: core/actions/src/action-manager.ts:327

Update the current model instance with latest data from database

Returns​

Promise<void>

a promise that resolves when the document has been loaded

Inherited from​

CoalescingWorkflow.resyncWithDb

rollback()​

rollback(cb, opts?): Digestor

Defined in: core/actions/src/workflow-manager.ts:160

Parameters​

cb​

(...args) => void | Action | Action[] | Promise<void | Action | Action[]>

opts?​
retry​

number

Returns​

Digestor

Inherited from​

CoalescingWorkflow.rollback

save()​

save(params): any

Defined in: core/actions/src/coalescing-manager.ts:49

Save an action in the database. Will then be managed by the worker.

Parameters​

params​
isNew​

boolean = ...

nCall​

number = 0

Returns​

any

a promise that resolves when the action has been saved

Inherited from​

CoalescingWorkflow.save

setArgument()​

setArgument(args): Digestor

Defined in: core/actions/src/action-manager.ts:407

Set the argument that will be stored in the database. Once set, the argument of an action should not be modified.

Parameters​

args​

JSONObject

The argument to set.

Returns​

Digestor

Inherited from​

CoalescingWorkflow.setArgument

setExecutor()​

setExecutor(): void | Executor | Promise<void | Executor>

Defined in: core/actions/src/action-manager.ts:516

Set the executor for this action. It is called only once when the action is created. If you want to set an executor, you should override this method.

Returns​

void | Executor | Promise<void | Executor>

a promise that resolves when you have set the executor is set

Inherited from​

CoalescingWorkflow.setExecutor

setFilter()​

setFilter(filter): Digestor

Defined in: core/actions/src/action-manager.ts:438

Make filtering actions easier with the filter property. These filters are stored in database with the filter property and allow to search for an action or a group of actions

Parameters​

filter​

Object

Returns​

Digestor

Inherited from​

CoalescingWorkflow.setFilter

setRepeat()​

setRepeat(opts): Digestor

Defined in: core/actions/src/action-manager.ts:422

Configure the number of times an action is repeated.

Parameters​

opts​
4?​

number

5?​

number

Returns​

Digestor

Inherited from​

CoalescingWorkflow.setRepeat

setResult()​

setResult(...results): Digestor

Defined in: core/actions/src/action-manager.ts:448

Set the action result.

Parameters​

results​

...any[]

Returns​

Digestor

Inherited from​

CoalescingWorkflow.setResult

startAction()​

protected startAction(ref, action): Promise<void>

Defined in: core/actions/src/workflow-manager.ts:437

Parameters​

ref​

string

action​

Action

Returns​

Promise<void>

Inherited from​

CoalescingWorkflow.startAction

startActionTransaction()​

protected startActionTransaction(ref, action): Promise<any[]>

Defined in: core/actions/src/workflow-manager.ts:403

Parameters​

ref​

string

action​

Action

Returns​

Promise<any[]>

Inherited from​

CoalescingWorkflow.startActionTransaction

stringifyIdentity()​

stringifyIdentity(): string

Defined in: core/actions/src/coalescing-manager.ts:31

Returns​

string

Inherited from​

CoalescingWorkflow.stringifyIdentity

substitute()​

substitute(otherPendingActionsWithSameIdentity): ActionSchemaInterface<JSONObject, { actions: {[key: string]: object; }; currentStepIndex?: number; currentStepName?: string; currentTrackIds: string[]; isRollBackPossible: boolean; nTimesCurrentStep: number; oldResult: StepResult[]; preserveOldResult: StepResult[]; registeredActions: object[]; stepsHistory: number[]; }, void | Error | JSONObject>

Defined in: core/actions/src/coalescing-manager.ts:43

Parameters​

otherPendingActionsWithSameIdentity​

ActionSchemaInterface<JSONObject, { actions: {[key: string]: object; }; currentStepIndex?: number; currentStepName?: string; currentTrackIds: string[]; isRollBackPossible: boolean; nTimesCurrentStep: number; oldResult: StepResult[]; preserveOldResult: StepResult[]; registeredActions: object[]; stepsHistory: number[]; }, void | Error | JSONObject>[]

Returns​

ActionSchemaInterface<JSONObject, { actions: {[key: string]: object; }; currentStepIndex?: number; currentStepName?: string; currentTrackIds: string[]; isRollBackPossible: boolean; nTimesCurrentStep: number; oldResult: StepResult[]; preserveOldResult: StepResult[]; registeredActions: object[]; stepsHistory: number[]; }, void | Error | JSONObject>

Inherited from​

CoalescingWorkflow.substitute

toPromise()​

protected toPromise(ref, dbDoc): DoPromise<unknown>

Defined in: core/actions/src/workflow-manager.ts:478

Parameters​

ref​

string

dbDoc​

ActionSchemaInterface

Returns​

DoPromise<unknown>

Inherited from​

CoalescingWorkflow.toPromise

transform()​

transform(ref, action): Action

Defined in: core/actions/src/workflow-manager.ts:88

Proxy that will be called before the start of any action. Use this method to transform any action before it is started.

Parameters​

ref​

string

the step reference of the action to transform

action​

Action

the action to transform

Returns​

Action

the transformed action

Inherited from​

CoalescingWorkflow.transform

watcher()​

watcher(): Promise<IN_PROGRESS | PAUSED>

Defined in: core/actions/src/workflow-manager.ts:742

Watch the action state.

It is called :

  • potentially many times when the action is in IN_PROGRESS state
  • one time if the action is in EXECUTING_MAIN state and the executing_main delay has expired.

Returns​

Promise<IN_PROGRESS | PAUSED>

promise

Inherited from​

CoalescingWorkflow.watcher

_constructFromDb()​

static _constructFromDb(actionDb): Action

Defined in: core/actions/src/action-manager.ts:256

Construct an action from a document stored in the database.

Parameters​

actionDb​

ActionSchemaInterface<any>

a document coming from the database

Returns​

Action

an action for which dbDoc property is equal to actionDb

Inherited from​

CoalescingWorkflow._constructFromDb

_constructFromWorkflow()​

static _constructFromWorkflow(dbDoc): Promise<Action>

Defined in: core/actions/src/action-manager.ts:281

Construct an action from a document stored in the database and whose definition depends on a workflow.

Parameters​

dbDoc​

ActionSchemaInterface<any>

Returns​

Promise<Action>

an action for which dbDoc property is equal to actionDb

Inherited from​

CoalescingWorkflow._constructFromWorkflow

constructFromDb()​

static constructFromDb(actionDb): Promise<Action>

Defined in: core/actions/src/action-manager.ts:304

Construct an action from a document stored in the database.

Parameters​

actionDb​

ActionSchemaInterface<any>

a document coming from the database

Returns​

Promise<Action>

an action for which dbDoc property is equal to actionDb

Inherited from​

CoalescingWorkflow.constructFromDb

findPendingWorkflowUsingAction()​

static findPendingWorkflowUsingAction(actionDbDoc): Query<ActionSchemaInterface<any, any, any> & object[], ActionSchemaInterface<any, any, any> & object, { }, ActionSchemaInterface<any, any, any>>

Defined in: core/actions/src/workflow-manager.ts:802

Parameters​

actionDbDoc​

ActionSchemaInterface

Returns​

Query<ActionSchemaInterface<any, any, any> & object[], ActionSchemaInterface<any, any, any> & object, { }, ActionSchemaInterface<any, any, any>>

Inherited from​

CoalescingWorkflow.findPendingWorkflowUsingAction

reject()​

static reject(result?): RejectAction

Defined in: core/actions/src/action-manager.ts:355

Return a new RejectAction object.

Parameters​

result?​

any

action result

Returns​

RejectAction

new RejectActioninstance

Inherited from​

CoalescingWorkflow.reject

resolve()​

static resolve(result?): ResolveAction

Defined in: core/actions/src/action-manager.ts:344

Return a new ResolveAction object.

Parameters​

result?​

any

action result

Returns​

ResolveAction

new ResolveActioninstance

Inherited from​

CoalescingWorkflow.resolve

trackActionAsPromise()​

static trackActionAsPromise(action, states): Promise<unknown>

Defined in: core/actions/src/action-manager.ts:911

Track an action until it reaches one of the given states.

Parameters​

action​

Action

The action to track.

states​

ActionState[] = ...

The states to reach.

Returns​

Promise<unknown>

A promise that resolves when the action reaches one of the given states. The promise resolves with the state reached.

Inherited from​

CoalescingWorkflow.trackActionAsPromise