@5minds/processcube_engine_sdk - npm Package Compare versions

Comparing version 6.1.0-feature-a93c79-m3rntbom to 6.1.0-feature-aba0bf-m5y16m3x

dist/commonjs/DataModels/FlowNodeInstance/FlowNodeInstance.js

@@ -42,2 +42,3 @@ "use strict";
     FlowNodeInstanceSortableColumns["embeddedProcessModelId"] = "embeddedProcessModelId";
+    FlowNodeInstanceSortableColumns["processModelName"] = "processModelName";
     FlowNodeInstanceSortableColumns["processInstanceId"] = "processInstanceId";
@@ -44,0 +45,0 @@ FlowNodeInstanceSortableColumns["correlationId"] = "correlationId";

dist/commonjs/DataModels/index.js

@@ -18,9 +18,19 @@ "use strict";
 });
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
+var __importStar = (this && this.__importStar) || (function () {
+    var ownKeys = function(o) {
+        ownKeys = Object.getOwnPropertyNames || function (o) {
+            var ar = [];
+            for (var k in o) if (Object.prototype.hasOwnProperty.call(o, k)) ar[ar.length] = k;
+            return ar;
+        };
+        return ownKeys(o);
+    };
+    return function (mod) {
+        if (mod && mod.__esModule) return mod;
+        var result = {};
+        if (mod != null) for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]);
+        __setModuleDefault(result, mod);
+        return result;
+    };
+})();
 var __exportStar = (this && this.__exportStar) || function(m, exports) {
@@ -44,2 +54,3 @@ for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
 __exportStar(require("./DataObjectInstance"), exports);
+__exportStar(require("./EngineMetadata"), exports);
 __exportStar(require("./ExternalTask/index"), exports);
@@ -46,0 +57,0 @@ __exportStar(require("./FlowNodeInstance/index"), exports);

dist/commonjs/EngineEvents/EngineEvent.js

@@ -17,3 +17,2 @@ "use strict";
 (function (EngineEventType) {
-    EngineEventType["OnActivityError"] = "OnActivityError";
     EngineEventType["OnEventProcessed"] = "OnEventProcessed";
@@ -38,5 +37,3 @@ EngineEventType["OnMessageTriggered"] = "OnMessageTriggered";
     EngineEventType["OnFlowNodeCallActivityResponseReceived"] = "OnFlowNodeCallActivityResponseReceived";
-    EngineEventType["OnFlowNodeEventSending"] = "OnFlowNodeEventSending";
-    EngineEventType["OnFlowNodeEventRetrySending"] = "OnFlowNodeEventRetrySending";
-    EngineEventType["OnFlowNodeEventResponseReceived"] = "OnFlowNodeEventResponseReceived";
+    EngineEventType["OnFlowNodeSubProcessResponseReceived"] = "OnFlowNodeSubProcessResponseReceived";
     EngineEventType["OnFlowNodeTimerStarted"] = "OnFlowNodeTimerStarted";
@@ -43,0 +40,0 @@ EngineEventType["OnFlowNodeTimerRemoved"] = "OnFlowNodeTimerRemoved";

dist/commonjs/EngineEvents/EventPayloads/index.js

@@ -24,2 +24,3 @@ "use strict";
 __exportStar(require("./FinishUserTask"), exports);
+__exportStar(require("./KillProcessInstanceMessageInternal"), exports);
 __exportStar(require("./MessageEventReached"), exports);
@@ -26,0 +27,0 @@ __exportStar(require("./MetadataChangedMessage"), exports);

dist/commonjs/EngineEvents/index.js

@@ -18,9 +18,19 @@ "use strict";
 });
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
+var __importStar = (this && this.__importStar) || (function () {
+    var ownKeys = function(o) {
+        ownKeys = Object.getOwnPropertyNames || function (o) {
+            var ar = [];
+            for (var k in o) if (Object.prototype.hasOwnProperty.call(o, k)) ar[ar.length] = k;
+            return ar;
+        };
+        return ownKeys(o);
+    };
+    return function (mod) {
+        if (mod && mod.__esModule) return mod;
+        var result = {};
+        if (mod != null) for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]);
+        __setModuleDefault(result, mod);
+        return result;
+    };
+})();
 var __exportStar = (this && this.__exportStar) || function(m, exports) {
@@ -41,3 +51,2 @@ for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
 __exportStar(require("./EventPayloads/index"), exports);
-__exportStar(require("./Subscription"), exports);
 var Messages;
@@ -44,0 +53,0 @@ (function (Messages) {

dist/commonjs/Errors/BaseError.js

@@ -18,9 +18,19 @@ "use strict";
 });
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
+var __importStar = (this && this.__importStar) || (function () {
+    var ownKeys = function(o) {
+        ownKeys = Object.getOwnPropertyNames || function (o) {
+            var ar = [];
+            for (var k in o) if (Object.prototype.hasOwnProperty.call(o, k)) ar[ar.length] = k;
+            return ar;
+        };
+        return ownKeys(o);
+    };
+    return function (mod) {
+        if (mod && mod.__esModule) return mod;
+        var result = {};
+        if (mod != null) for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]);
+        __setModuleDefault(result, mod);
+        return result;
+    };
+})();
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -27,0 +37,0 @@ exports.BaseError = void 0;

dist/commonjs/ExtensionAdapter/index.js

@@ -26,2 +26,3 @@ "use strict";
 __exportStar(require("./ManualTaskExtensionAdapter"), exports);
+__exportStar(require("./MessageEventExtensionAdapter"), exports);
 __exportStar(require("./NotificationExtensionAdapter"), exports);
@@ -28,0 +29,0 @@ __exportStar(require("./ProcessDefinitionExtensionAdapter"), exports);

dist/commonjs/index.js

@@ -25,3 +25,7 @@ "use strict";
 __exportStar(require("./Engine"), exports);
+__exportStar(require("./EngineEventBus"), exports);
 __exportStar(require("./EngineConfiguration"), exports);
+__exportStar(require("./EngineEventBusSettings"), exports);
+__exportStar(require("./EngineRestApiSettings"), exports);
+__exportStar(require("./EngineSocketIoSettings"), exports);
 __exportStar(require("./Logger"), exports);
@@ -28,0 +32,0 @@ __exportStar(require("./Serializer"), exports);

dist/commonjs/ProcessModel/Model/index.js

@@ -18,9 +18,19 @@ "use strict";
 });
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
+var __importStar = (this && this.__importStar) || (function () {
+    var ownKeys = function(o) {
+        ownKeys = Object.getOwnPropertyNames || function (o) {
+            var ar = [];
+            for (var k in o) if (Object.prototype.hasOwnProperty.call(o, k)) ar[ar.length] = k;
+            return ar;
+        };
+        return ownKeys(o);
+    };
+    return function (mod) {
+        if (mod && mod.__esModule) return mod;
+        var result = {};
+        if (mod != null) for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]);
+        __setModuleDefault(result, mod);
+        return result;
+    };
+})();
 var __exportStar = (this && this.__exportStar) || function(m, exports) {
@@ -27,0 +37,0 @@ for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);

dist/commonjs/ProcessModel/ProcessModelParser/BpmnModelParser.js

@@ -18,9 +18,19 @@ "use strict";
 });
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
+var __importStar = (this && this.__importStar) || (function () {
+    var ownKeys = function(o) {
+        ownKeys = Object.getOwnPropertyNames || function (o) {
+            var ar = [];
+            for (var k in o) if (Object.prototype.hasOwnProperty.call(o, k)) ar[ar.length] = k;
+            return ar;
+        };
+        return ownKeys(o);
+    };
+    return function (mod) {
+        if (mod && mod.__esModule) return mod;
+        var result = {};
+        if (mod != null) for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]);
+        __setModuleDefault(result, mod);
+        return result;
+    };
+})();
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -27,0 +37,0 @@ exports.BpmnModelParser = void 0;

dist/commonjs/ProcessModel/ProcessModelParser/Parser/FlowNodeParsers/ActivityParsers/index.js

@@ -18,9 +18,19 @@ "use strict";
 });
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
+var __importStar = (this && this.__importStar) || (function () {
+    var ownKeys = function(o) {
+        ownKeys = Object.getOwnPropertyNames || function (o) {
+            var ar = [];
+            for (var k in o) if (Object.prototype.hasOwnProperty.call(o, k)) ar[ar.length] = k;
+            return ar;
+        };
+        return ownKeys(o);
+    };
+    return function (mod) {
+        if (mod && mod.__esModule) return mod;
+        var result = {};
+        if (mod != null) for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]);
+        __setModuleDefault(result, mod);
+        return result;
+    };
+})();
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -27,0 +37,0 @@ exports.ActivityParsers = void 0;

dist/commonjs/ProcessModel/ProcessModelParser/Parser/FlowNodeParsers/index.js

@@ -18,9 +18,19 @@ "use strict";
 });
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
+var __importStar = (this && this.__importStar) || (function () {
+    var ownKeys = function(o) {
+        ownKeys = Object.getOwnPropertyNames || function (o) {
+            var ar = [];
+            for (var k in o) if (Object.prototype.hasOwnProperty.call(o, k)) ar[ar.length] = k;
+            return ar;
+        };
+        return ownKeys(o);
+    };
+    return function (mod) {
+        if (mod && mod.__esModule) return mod;
+        var result = {};
+        if (mod != null) for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]);
+        __setModuleDefault(result, mod);
+        return result;
+    };
+})();
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -27,0 +37,0 @@ exports.FlowNodeParsers = void 0;

dist/DataModels/ApplicationInfo.d.ts

@@ -0,1 +1,2 @@
+import { EngineMetadata } from './EngineMetadata';
 /**
@@ -59,3 +60,4 @@ * @swagger
     }>;
+    clusterInfo?: Array<EngineMetadata>;
     extraInfo: any;
 };

dist/DataModels/FlowNodeInstance/FlowNodeInstance.d.ts

@@ -81,2 +81,5 @@ import { BpmnType, EventType } from '../../ProcessModel/index';
  *           type: string
+ *         processModelName:
+ *           description: The Name of the ProcessModel that contains this FlowNodeInstance
+ *           type: string
  *         processInstanceId:
@@ -149,2 +152,3 @@ *           description: The ID of the ProcessInstance that contains this FlowNodeInstance
     embeddedProcessModelId?: string;
+    processModelName?: string;
     processInstanceId: string;
@@ -210,2 +214,3 @@ correlationId: string;
     embeddedProcessModelId = "embeddedProcessModelId",
+    processModelName = "processModelName",
     processInstanceId = "processInstanceId",
@@ -212,0 +217,0 @@ correlationId = "correlationId",

dist/DataModels/FlowNodeInstance/Queries.d.ts

@@ -12,2 +12,3 @@ import { BpmnType, EventType } from '../../ProcessModel/index';
     embeddedProcessModelId?: Array<string> | string;
+    processModelName?: Array<string> | string;
     processInstanceId?: Array<string> | string;
@@ -14,0 +15,0 @@ correlationId?: Array<string> | string;

dist/DataModels/index.d.ts

@@ -19,2 +19,3 @@ /**
 export * from './DataObjectInstance';
+export * from './EngineMetadata';
 export * from './ExternalTask/index';
@@ -21,0 +22,0 @@ export * from './FlowNodeInstance/index';

dist/Engine.d.ts

 import * as express from 'express';
 import { UserTaskInstance } from './DataModels';
 import { Identity } from './DataModels/Iam/index';
+import { ExternalEventBus } from './EngineEventBus';
 import { EngineEventType, MiddlewareCallback } from './EngineEvents/index';
-import { IApplicationInfoExtensionAdapter, ICorrelationExtensionAdapter, ICronjobExtensionAdapter, IDataObjectInstanceExtensionAdapter, IEventExtensionAdapter, IExternalTaskExtensionAdapter, IFlowNodeInstanceExtensionAdapter, IIamExtensionAdapter, IManualTaskExtensionAdapter, INotificationExtensionAdapter, IProcessDefinitionExtensionAdapter, IProcessInstanceExtensionAdapter, IProcessModelExtensionAdapter, IUntypedTaskExtensionAdapter, IUserTaskExtensionAdapter } from './ExtensionAdapter';
+import { IApplicationInfoExtensionAdapter, ICorrelationExtensionAdapter, ICronjobExtensionAdapter, IDataObjectInstanceExtensionAdapter, IEventExtensionAdapter, IExternalTaskExtensionAdapter, IFlowNodeInstanceExtensionAdapter, IIamExtensionAdapter, IManualTaskExtensionAdapter, IMessageEventExtensionAdapter, INotificationExtensionAdapter, IProcessDefinitionExtensionAdapter, IProcessInstanceExtensionAdapter, IProcessModelExtensionAdapter, IUntypedTaskExtensionAdapter, IUserTaskExtensionAdapter } from './ExtensionAdapter';
 import { EventViewModel, FlowNodeViewModel } from './ProcessModel/index';
@@ -210,2 +211,10 @@ /**
     /**
+     * Registers a custom Event Bus, which will replace the Engine's own internal Event Bus.
+     *
+     * **NOTE:** Can only be used BEFORE the {@link Engine.onReady} Event was fired!
+     *
+     * @param eventBus A custom {@link ExternalEventBus}.
+     */
+    registerCustomEventBus(eventBus: ExternalEventBus): void;
+    /**
      * Registers the given callback as an Event Middleware.
@@ -352,2 +361,3 @@ * This middleware gets called whenever a Log Event occurs at the Engine.
     manualTasks: IManualTaskExtensionAdapter;
+    messageEvents: IMessageEventExtensionAdapter;
     notification: INotificationExtensionAdapter;
@@ -354,0 +364,0 @@ processDefinitions: IProcessDefinitionExtensionAdapter;

dist/EngineConfiguration.d.ts

@@ -28,5 +28,4 @@ import { LogLevel } from './EngineEvents';
 export declare type RuntimeExpressionConfig = {
-    timeoutInSeconds?: number;
+    timeoutInMiliseconds?: number;
     workerPoolSize?: number;
-    maxMemoryInMb?: number;
 };
@@ -88,2 +87,3 @@ export declare type DatabaseConfig = {
     host?: string;
+    allowedCorsOrigins?: string[];
 };
@@ -90,0 +90,0 @@ export declare type IAMConfiguration = {

dist/EngineEvents/EngineEvent.d.ts

@@ -18,3 +18,5 @@ import { RuntimeExpressionParameters } from '..';
 export declare type EngineEvent = {
+    eventId?: string;
     eventType: EngineEventType;
+    logLevel: LogLevel;
     timestamp: Date;
@@ -30,12 +32,38 @@ processStartedAt?: Date;
     processDefinitionHash: string;
+    processInstanceId: string;
+    parentProcessInstanceId?: string;
+    correlationId: string;
+    /**
+     * Only included with OnFlowNodeXX events.
+     */
     flowNodeId?: string;
+    /**
+     * Only included with OnFlowNodeXX events.
+     */
     flowNodeInstanceId?: string;
+    /**
+     * Only included with OnFlowNodeXX events.
+     */
     flowNodeType?: BpmnType;
+    /**
+     * Only included with OnFlowNodeXX events.
+     */
     currentFlowNode?: BaseElementViewModel;
-    processInstanceId: string;
-    parentProcessInstanceId?: string;
-    correlationId: string;
-    logLevel: LogLevel;
-    tokenPayload?: object;
-    eventId?: string;
+    /**
+     * For "OnFlowNodeXX" Events, this will contain the current token on the FlowNodeInstance.
+     * For "OnProcessXX" Events, this will contain either the ProcessInstance's initial token, or its end token.
+     */
+    tokenPayload?: Record<string, any>;
+    /**
+     * Only included with OnFlowNodeExited events.
+     */
+    writtenDataObjectValues?: Record<string, any>;
+    /**
+     * Only included with OnFlowNodeEntered events.
+     */
+    writtenCorrelationMetadata?: Record<string, string>;
+    /**
+     * Only included with OnFlowNodeEntered events.
+     */
+    writtenProcessInstanceMetadata?: Record<string, string>;
     messageChannel?: string;
@@ -53,3 +81,2 @@ signalChannel?: string;
 export declare enum EngineEventType {
-    OnActivityError = "OnActivityError",
     OnEventProcessed = "OnEventProcessed",
@@ -74,5 +101,3 @@ OnMessageTriggered = "OnMessageTriggered",
     OnFlowNodeCallActivityResponseReceived = "OnFlowNodeCallActivityResponseReceived",
-    OnFlowNodeEventSending = "OnFlowNodeEventSending",
-    OnFlowNodeEventRetrySending = "OnFlowNodeEventRetrySending",
-    OnFlowNodeEventResponseReceived = "OnFlowNodeEventResponseReceived",
+    OnFlowNodeSubProcessResponseReceived = "OnFlowNodeSubProcessResponseReceived",
     OnFlowNodeTimerStarted = "OnFlowNodeTimerStarted",
@@ -79,0 +104,0 @@ OnFlowNodeTimerRemoved = "OnFlowNodeTimerRemoved"

dist/EngineEvents/EventPayloads/index.d.ts

@@ -8,2 +8,3 @@ export * from './BaseMessage';
 export * from './FinishUserTask';
+export * from './KillProcessInstanceMessageInternal';
 export * from './MessageEventReached';
@@ -10,0 +11,0 @@ export * from './MetadataChangedMessage';

dist/EngineEvents/EventPayloads/TerminateProcessInstance.d.ts

@@ -6,2 +6,3 @@ import { Identity } from '../../DataModels/Iam/index';
 export type TerminateProcessInstanceMessage = {
+    processInstanceId: string;
     /**
@@ -8,0 +9,0 @@ * If the Process Instance is terminated by a user, this will contain the users identity.

dist/EngineEvents/index.d.ts

@@ -12,3 +12,2 @@ /**
 export * from './EventPayloads/index';
-export * from './Subscription';
 export declare namespace Messages {
@@ -15,0 +14,0 @@ export import EventMessage = eventPayloads.EventMessage;

dist/ExtensionAdapter/CronjobExtensionAdapter.d.ts

@@ -11,2 +11,4 @@ import { CronjobQuery, CronjobSortSettings, DeployedCronjobList, Identity } from '../index';
     disableCronjob(processModelId: string, flowNodeId: string, identity?: Identity): Promise<void>;
+    startCronjobService(): Promise<void>;
+    stopCronjobService(): Promise<void>;
 }

dist/ExtensionAdapter/EventExtensionAdapter.d.ts

@@ -22,2 +22,8 @@ import { DataModels, Identity, Messages, Subscription } from '../index';
     }): Promise<void>;
+    /**
+     * @requires Engine v19
+     */
+    triggerTimerEvent(flowNodeInstanceId: string, options?: {
+        identity?: Identity;
+    }): Promise<void>;
     onBoundaryEventTriggered(callback: Messages.CallbackTypes.OnBoundaryEventTriggeredCallback, options?: {
@@ -24,0 +30,0 @@ subscribeOnce?: boolean;

dist/ExtensionAdapter/FlowNodeInstanceExtensionAdapter.d.ts

@@ -22,2 +22,3 @@ import { DataModels, Identity } from '../index';
     }): Promise<void>;
+    cleanUpOrphanedFlowNodeInstances(identity?: Identity): Promise<void>;
 }

dist/ExtensionAdapter/index.d.ts

@@ -10,2 +10,3 @@ export * from './ApplicationInfoExtensionAdapter';
 export * from './ManualTaskExtensionAdapter';
+export * from './MessageEventExtensionAdapter';
 export * from './NotificationExtensionAdapter';
@@ -12,0 +13,0 @@ export * from './ProcessDefinitionExtensionAdapter';

dist/ExtensionAdapter/NotificationExtensionAdapter.d.ts

@@ -80,2 +80,6 @@ import { Identity, Messages, Subscription } from '../index';
     }): Promise<Subscription>;
+    onActivityError(callback: Messages.CallbackTypes.OnActivityErrorCallback, options?: {
+        subscribeOnce?: boolean;
+        identity?: Identity;
+    }): Promise<Subscription>;
     onUntypedTaskWaiting(callback: Messages.CallbackTypes.OnUntypedTaskWaitingCallback, options?: {
@@ -141,6 +145,2 @@ subscribeOnce?: boolean;
     }): Promise<Subscription>;
-    onFlowNodeEventRetrySending(callback: Messages.CallbackTypes.OnFlowNodeEventRetrySendingCallback, options?: {
-        subscribeOnce?: boolean;
-        identity?: Identity;
-    }): Promise<Subscription>;
     onMessageTriggered(callback: Messages.CallbackTypes.OnMessageTriggeredCallback, options?: {
@@ -147,0 +147,0 @@ subscribeOnce?: boolean;

dist/ExtensionAdapter/ProcessInstanceExtensionAdapter.d.ts

@@ -1,2 +0,2 @@
-import { DataModels, Identity } from '../index';
+import { DataModels, Identity, ProcessInstanceState } from '../index';
 export interface IProcessInstanceExtensionAdapter {
@@ -12,2 +12,5 @@ query(query: DataModels.ProcessInstances.ProcessInstanceQuery, options?: {
     getProcessModel(processInstanceId: string, identity?: Identity): Promise<DataModels.ProcessDefinitions.ProcessModel>;
+    getRunningProcessInstanceIds(engineId?: string, identity?: Identity): Promise<Array<string>>;
+    getProcessInstanceCountByEngineId(engineId: string, state?: ProcessInstanceState): Promise<number>;
+    getDistinctEngineIds(): Promise<Array<string>>;
     transferOwnership(processInstanceId: string, newOwner: Identity, identity?: Identity): Promise<void>;
@@ -21,2 +24,4 @@ terminateProcessInstance(processInstanceId: string, identity?: Identity): Promise<void>;
     deleteProcessInstances(processInstanceIds: Array<string>, deleteAllRelatedData: boolean, identity?: Identity): Promise<void>;
+    killProcessInstance(processInstanceId: string, identity?: Identity): Promise<void>;
+    subscribeToProcessKillTopic(): Promise<void>;
 }

dist/index.d.ts

@@ -8,3 +8,7 @@ import { EngineEventType } from './EngineEvents/index';
 export * from './Engine';
+export * from './EngineEventBus';
 export * from './EngineConfiguration';
+export * from './EngineEventBusSettings';
+export * from './EngineRestApiSettings';
+export * from './EngineSocketIoSettings';
 export * from './Logger';
@@ -16,3 +20,2 @@ export * from './Serializer';
 export declare const LogEventType: {
-    OnActivityError: EngineEventType.OnActivityError;
     OnEventProcessed: EngineEventType.OnEventProcessed;
@@ -37,7 +40,5 @@ OnMessageTriggered: EngineEventType.OnMessageTriggered;
     OnFlowNodeCallActivityResponseReceived: EngineEventType.OnFlowNodeCallActivityResponseReceived;
-    OnFlowNodeEventSending: EngineEventType.OnFlowNodeEventSending;
-    OnFlowNodeEventRetrySending: EngineEventType.OnFlowNodeEventRetrySending;
-    OnFlowNodeEventResponseReceived: EngineEventType.OnFlowNodeEventResponseReceived;
+    OnFlowNodeSubProcessResponseReceived: EngineEventType.OnFlowNodeSubProcessResponseReceived;
     OnFlowNodeTimerStarted: EngineEventType.OnFlowNodeTimerStarted;
     OnFlowNodeTimerRemoved: EngineEventType.OnFlowNodeTimerRemoved;
 };

package.json

 {
   "name": "@5minds/processcube_engine_sdk",
-  "version": "6.1.0-feature-a93c79-m3rntbom",
+  "version": "6.1.0-feature-aba0bf-m5y16m3x",
   "description": "Software development kit for the Engine.",
@@ -41,3 +41,3 @@ "main": "dist/commonjs/index.js",
   "devDependencies": {
-    "@trivago/prettier-plugin-sort-imports": "^4.2.0",
+    "@trivago/prettier-plugin-sort-imports": "^5.0.0",
     "@types/express": "^5.0.0",
@@ -51,4 +51,4 @@ "@types/mocha": "^10.0.3",
     "ts-mocha": "^10.0.0",
-    "typescript": "~5.6.0"
+    "typescript": "~5.7.0"
   }
 }

No alert changes

Improved metrics

Total package byte prevSize

854723

increased by31.64%

Number of package files

618

increased by3%

Lines of code

16243

increased by41.89%

No dependency changes