{"version":3,"sources":["../../../packages/core/workflow/persistent-workflow-store.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,UAAU,EAAE,MAAM,MAAM,CAAC;AAClC,OAAO,EAAE,uBAAuB,EAAE,MAAM,8BAA8B,CAAC;AACvE,OAAO,EAAE,0BAA0B,EAAE,MAAM,gCAAgC,CAAC;AAE5E;;GAEG;AACH,8BAAsB,uBAAuB;IAM7B,SAAS,CAAC,UAAU,EAAE,MAAM;IAAE,SAAS,CAAC,IAAI,EAAE,MAAM;IALhE;;;;OAIG;gBACmB,UAAU,EAAE,MAAM,EAAY,IAAI,EAAE,MAAM;IAEhE;;;;;;;;OAQG;IACH,QAAQ,CAAC,IAAI,CACT,OAAO,EAAE,MAAM,EACf,UAAU,EAAE,MAAM,EAClB,aAAa,EAAE,uBAAuB,EACtC,YAAY,EAAE,GAAG,EACjB,UAAU,CAAC,EAAE,MAAM,GAAG,UAAU,CAAC,0BAA0B,CAAC;IAEhE;;OAEG;IACH,QAAQ,CAAC,OAAO,IAAI,UAAU,CAAC,0BAA0B,EAAE,CAAC;IAE5D;;;;OAIG;IACH,QAAQ,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,MAAM,GAAG,UAAU,CAAC,IAAI,CAAC;CACxD","file":"persistent-workflow-store.d.ts","sourcesContent":["import { Observable } from 'rxjs';\r\nimport { PersistentWorkItemState } from './persistent-work-item-state';\r\nimport { PersistentWorkflowSnapshot } from './persistent-workflow-snapshot';\r\n\r\n/**\r\n * Persistent workflow store class.\r\n */\r\nexport abstract class PersistentWorkflowStore {\r\n    /**\r\n     * Initializes a new instance of the PersistentWorkflowStore abstract class.\r\n     * @param moduleName the module name.\r\n     * @param name the key name to index the same workflow.\r\n     */\r\n    constructor(protected moduleName: string, protected name: string) {}\r\n\r\n    /**\r\n     * Save the checkpoint data of work item processing.\r\n     *\r\n     * @param version the version number.\r\n     * @param workItemId the identification id of work item.\r\n     * @param workItemState the state of work item.\r\n     * @param workItemData the persistent data to store.\r\n     * @param instanceId the instance id for indexing.\r\n     */\r\n    abstract save(\r\n        version: number,\r\n        workItemId: number,\r\n        workItemState: PersistentWorkItemState,\r\n        workItemData: any,\r\n        instanceId?: number): Observable<PersistentWorkflowSnapshot>;\r\n\r\n    /**\r\n     * Restore all checkpoint data of work items processing.\r\n     */\r\n    abstract restore(): Observable<PersistentWorkflowSnapshot[]>;\r\n\r\n    /**\r\n     * Clear all or specified instance of checkpoint data of work item.\r\n     *\r\n     * @param instanceId the instance id.\r\n     */\r\n    abstract clear(instanceId?: number): Observable<void>;\r\n}\r\n"]}