@5minds/processcube_engine_sdk - npm Package Compare versions

Comparing version 6.1.0-feature-1ec50c-m4jtl2k9 to 6.1.0-feature-2580b3-m5wiyj1t

dist/commonjs/DataModels/index.js

@@ -53,2 +53,3 @@ "use strict";
 __exportStar(require("./DataObjectInstance"), exports);
+__exportStar(require("./EngineMetadata"), exports);
 __exportStar(require("./ExternalTask/index"), exports);
@@ -55,0 +56,0 @@ __exportStar(require("./FlowNodeInstance/index"), exports);

dist/commonjs/EngineEventBusSettings.js

@@ -42,2 +42,3 @@ "use strict";
     intermediateCatchEventFinished: 'intermediate_catch_event_finished',
+    killProcessInstance: 'kill_process_instance',
     manualTaskReached: 'manual_task_reached',
@@ -62,2 +63,3 @@ manualTaskFinished: 'manual_task_finished',
     signalTriggered: 'signal_triggered',
+    triggerTimerEvent: `/engine/timer/${messageParams.flowNodeInstanceId}/trigger`,
     tokenPayloadChange: `token_payload_change_${messageParams.flowNodeInstanceId}`,
@@ -64,0 +66,0 @@ tokenPayloadChangeFinished: `token_payload_change_finished_${messageParams.flowNodeInstanceId}`,

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/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/DataModels/ApplicationInfo.d.ts

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

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

@@ -6,3 +6,3 @@ import * as express from 'express';
 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';
@@ -206,2 +206,3 @@ /**
     /**
+     * Registers a callback to execute after the Engine has finished starting up.
      *
@@ -361,2 +362,3 @@ * @param callback The callback to call after the Engine has finished starting up.
     manualTasks: IManualTaskExtensionAdapter;
+    messageEvents: IMessageEventExtensionAdapter;
     notification: INotificationExtensionAdapter;
@@ -363,0 +365,0 @@ processDefinitions: IProcessDefinitionExtensionAdapter;

dist/EngineConfiguration.d.ts

@@ -86,2 +86,3 @@ import { LogLevel } from './EngineEvents';
     host?: string;
+    allowedCorsOrigins?: string[];
 };
@@ -88,0 +89,0 @@ export declare type IAMConfiguration = {

dist/EngineEventBus.d.ts

@@ -81,5 +81,5 @@ /**
 export type ExternalEventBus = {
-    subscribeToWorkQueue: (queueName: string, callback: Function) => Promise<ExternalSubscription>;
-    subscribeToTopicWithRoutingKey: (topic: string, routingKey: string, callback: Function) => Promise<ExternalSubscription>;
-    subscribeToBroadcast: (topic: string, callback: Function) => Promise<ExternalSubscription>;
+    subscribeToWorkQueue: (queueName: string, callback: Function, oneTimeSubscription?: boolean) => Promise<ExternalSubscription>;
+    subscribeToTopicWithRoutingKey: (topic: string, routingKey: string, callback: Function, oneTimeSubscription?: boolean) => Promise<ExternalSubscription>;
+    subscribeToBroadcast: (topic: string, callback: Function, oneTimeSubscription?: boolean) => Promise<ExternalSubscription>;
     publishToWorkQueue: (queueName: string, payload: Record<string, any>) => Promise<void>;
@@ -86,0 +86,0 @@ publishToTopicWithRoutingKey: (topic: string, routingKey: string, payload: Record<string, any>) => Promise<void>;

dist/EngineEventBusSettings.d.ts

@@ -40,2 +40,3 @@ export declare const EngineEventBusSettings: {
         intermediateCatchEventFinished: string;
+        killProcessInstance: string;
         manualTaskReached: string;
@@ -60,2 +61,3 @@ manualTaskFinished: string;
         signalTriggered: string;
+        triggerTimerEvent: string;
         tokenPayloadChange: string;
@@ -62,0 +64,0 @@ tokenPayloadChangeFinished: string;

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/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/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/index.d.ts

@@ -19,3 +19,2 @@ import { EngineEventType } from './EngineEvents/index';
 export declare const LogEventType: {
-    OnActivityError: EngineEventType.OnActivityError;
     OnEventProcessed: EngineEventType.OnEventProcessed;
@@ -40,7 +39,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-1ec50c-m4jtl2k9",
+  "version": "6.1.0-feature-2580b3-m5wiyj1t",
   "description": "Software development kit for the Engine.",
@@ -5,0 +5,0 @@ "main": "dist/commonjs/index.js",

No alert changes

Improved metrics

Total package byte prevSize

853469

increased by1.19%

Number of package files

615

increased by0.99%

Lines of code

16222

increased by1.43%

No dependency changes