@5minds/processcube_engine_sdk - npm Package Compare versions

Comparing version 4.0.0-develop-92a52b-ljeclwvo to 4.0.0-develop-93ce00-llm9etng

dist/amd/DataModels/FlowNodeInstance/index.js

@@ -15,3 +15,3 @@ var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
 };
-define(["require", "exports", "./FlowNodeInstance", "./FlowNodeInstanceResult", "./ProcessToken", "./Queries", "./TokenHistory", "./CallActivityInstance", "./EmptyActivityInstance", "./EventInstance", "./ManualTaskInstance", "./ReceiveTaskInstance", "./SendTaskInstance", "./ServiceTaskInstance", "./SubprocessInstance", "./UserTaskInstance"], function (require, exports, FlowNodeInstance_1, FlowNodeInstanceResult_1, ProcessToken_1, Queries_1, TokenHistory_1, CallActivityInstance_1, EmptyActivityInstance_1, EventInstance_1, ManualTaskInstance_1, ReceiveTaskInstance_1, SendTaskInstance_1, ServiceTaskInstance_1, SubprocessInstance_1, UserTaskInstance_1) {
+define(["require", "exports", "./FlowNodeInstance", "./FlowNodeInstanceResult", "./ProcessToken", "./Queries", "./TokenHistory", "./BusinessRuleTaskInstance", "./CallActivityInstance", "./EmptyActivityInstance", "./EventInstance", "./ManualTaskInstance", "./ReceiveTaskInstance", "./SendTaskInstance", "./ServiceTaskInstance", "./SubprocessInstance", "./UserTaskInstance"], function (require, exports, FlowNodeInstance_1, FlowNodeInstanceResult_1, ProcessToken_1, Queries_1, TokenHistory_1, BusinessRuleTaskInstance_1, CallActivityInstance_1, EmptyActivityInstance_1, EventInstance_1, ManualTaskInstance_1, ReceiveTaskInstance_1, SendTaskInstance_1, ServiceTaskInstance_1, SubprocessInstance_1, UserTaskInstance_1) {
     "use strict";
@@ -24,2 +24,3 @@ Object.defineProperty(exports, "__esModule", { value: true });
     __exportStar(TokenHistory_1, exports);
+    __exportStar(BusinessRuleTaskInstance_1, exports);
     __exportStar(CallActivityInstance_1, exports);
@@ -26,0 +27,0 @@ __exportStar(EmptyActivityInstance_1, exports);

dist/amd/EngineEvents/EngineEvent.js

@@ -18,2 +18,3 @@ define(["require", "exports"], function (require, exports) {
     (function (EngineEventType) {
+        EngineEventType["OnActivityError"] = "OnActivityError";
         EngineEventType["OnEventProcessed"] = "OnEventProcessed";
@@ -20,0 +21,0 @@ EngineEventType["OnProcessDeployed"] = "OnProcessDeployed";

dist/amd/Errors/BaseError.js

@@ -40,3 +40,4 @@ define(["require", "exports", "./index"], function (require, exports, errorClasses) {
             const callStackUndefined = errorInfo.callStack === undefined;
-            const structureIsIncorrect = errorClassUndefined || codeUndefined || callStackUndefined;
+            const errorTypeUndefined = errorInfo.errorType === undefined;
+            const structureIsIncorrect = errorClassUndefined || codeUndefined || callStackUndefined || errorTypeUndefined;
             if (structureIsIncorrect) {
@@ -61,2 +62,4 @@ throw new Error('Error while deserializing error: Serialized object has an incompatible structure.');
                 additionalInformation: this.additionalInformation,
+                errorType: 'Error',
+                ...this,
             });
@@ -63,0 +66,0 @@ }

dist/amd/ProcessModel/ProcessModelFacade/SubProcessModelFacade.js

@@ -34,5 +34,2 @@ define(["require", "exports", "../../Errors/index", "../Model/index", "./index"], function (require, exports, index_1, index_2, index_3) {
         }
-        getProcessModelHasLanes() {
-            throw new index_1.NotImplementedError('Subprocesses cannot have lanes!');
-        }
         getIncomingSequenceFlowsFor(flowNodeId) {
@@ -144,4 +141,3 @@ const flowNodeExists = this.subProcessActivity.flowNodes.some((flowNode) => flowNode.id === flowNodeId);
             }
-            const matchingLane = super.findLaneForFlowNodeIdFromLaneSet(this.subProcessActivity.id, this.processModel.laneSet);
-            return matchingLane;
+            return super.getLaneForFlowNode(this.subProcessActivity.id);
         }
@@ -148,0 +144,0 @@ getLinkCatchEventsByLinkName(linkName) {

dist/amd/ProcessModel/ProcessModelParser/Parser/FlowNodeParsers/ActivityParsers/BusinessRuleTaskParser.js

@@ -28,3 +28,3 @@ define(["require", "exports", "../../../../Model/index", "../../../TypeFactory", "./ActivityFactory", "./ExtensionPropertyParser"], function (require, exports, index_1, TypeFactory_1, ActivityFactory_1, ExtensionPropertyParser_1) {
     function parseBusinessRuleTask(businessRuletasksRaw) {
-        var _a, _b, _c;
+        var _a, _b, _c, _d, _e, _f, _g;
         const businessRuleTask = (0, ActivityFactory_1.createActivityInstance)(businessRuletasksRaw, index_1.Model.Activities.BusinessRuleTask);
@@ -34,2 +34,6 @@ businessRuleTask.decisionRef = (_a = (0, ExtensionPropertyParser_1.findExtensionPropertyByName)('decisionRef', businessRuleTask.extensionElements.camundaExtensionProperties)) === null || _a === void 0 ? void 0 : _a.value;
         businessRuleTask.decisionRefVersion = (_c = (0, ExtensionPropertyParser_1.findExtensionPropertyByName)('decisionRefVersion', businessRuleTask.extensionElements.camundaExtensionProperties)) === null || _c === void 0 ? void 0 : _c.value;
+        businessRuleTask.topic = businessRuletasksRaw[index_1.BpmnTags.CamundaProperty.Topic];
+        const extensionProperties = (_e = (_d = businessRuleTask.extensionElements) === null || _d === void 0 ? void 0 : _d.camundaExtensionProperties) !== null && _e !== void 0 ? _e : [];
+        businessRuleTask.payload = (_f = (0, ExtensionPropertyParser_1.findExtensionPropertyByName)('payload', extensionProperties)) === null || _f === void 0 ? void 0 : _f.value;
+        businessRuleTask.isSingleTry = ((_g = (0, ExtensionPropertyParser_1.findExtensionPropertyByName)('engine.isSingleTry', extensionProperties)) === null || _g === void 0 ? void 0 : _g.value) === 'true';
         return businessRuleTask;
@@ -36,0 +40,0 @@ }

dist/amd/ProcessModel/ViewModel/Activities/BusinessRuleTaskViewModel.js

@@ -6,2 +6,8 @@ define(["require", "exports", "./ActivityViewModel"], function (require, exports, ActivityViewModel_1) {
     class BusinessRuleTaskViewModel extends ActivityViewModel_1.ActivityViewModel {
+        constructor(businessRuleTask, processModel) {
+            super(businessRuleTask, processModel);
+            this.topic = businessRuleTask.topic;
+            this.payload = businessRuleTask.payload;
+            this.isSingleTry = businessRuleTask.isSingleTry;
+        }
     }
@@ -8,0 +14,0 @@ exports.BusinessRuleTaskViewModel = BusinessRuleTaskViewModel;

dist/amd/Serializer.js

@@ -70,3 +70,7 @@ define(["require", "exports", "./DataModels/ProcessInstance/BpmnError", "./Errors/BaseError"], function (require, exports, BpmnError_1, BaseError_1) {
         const deserializedValue = tryParse(stringifiedError, reviverFunction);
-        const notAnErrorOrEmpty = deserializedValue == undefined || deserializedValue.name == undefined || deserializedValue.message == undefined || deserializedValue.stack == undefined;
+        const notAnErrorOrEmpty = deserializedValue == undefined ||
+            deserializedValue.name == undefined ||
+            deserializedValue.message == undefined ||
+            deserializedValue.stack == undefined ||
+            deserializedValue.errorType == undefined;
         if (notAnErrorOrEmpty) {
@@ -80,2 +84,7 @@ return deserializedValue;
             }
+            Object.keys(deserializedValue).forEach((key) => {
+                if (!error[key]) {
+                    error[key] = deserializedValue[key];
+                }
+            });
             return error;
@@ -87,2 +96,7 @@ }
         error.name = deserializedValue.name;
+        Object.keys(deserializedValue).forEach((key) => {
+            if (!error[key]) {
+                error[key] = deserializedValue[key];
+            }
+        });
         return error;
@@ -89,0 +103,0 @@ }

dist/commonjs/DataModels/FlowNodeInstance/index.js

@@ -22,2 +22,3 @@ "use strict";
 __exportStar(require("./TokenHistory"), exports);
+__exportStar(require("./BusinessRuleTaskInstance"), exports);
 __exportStar(require("./CallActivityInstance"), exports);
@@ -24,0 +25,0 @@ __exportStar(require("./EmptyActivityInstance"), exports);

dist/commonjs/EngineEvents/EngineEvent.js

@@ -17,2 +17,3 @@ "use strict";
 (function (EngineEventType) {
+    EngineEventType["OnActivityError"] = "OnActivityError";
     EngineEventType["OnEventProcessed"] = "OnEventProcessed";
@@ -19,0 +20,0 @@ EngineEventType["OnProcessDeployed"] = "OnProcessDeployed";

dist/commonjs/Errors/BaseError.js

@@ -40,3 +40,4 @@ "use strict";
         const callStackUndefined = errorInfo.callStack === undefined;
-        const structureIsIncorrect = errorClassUndefined || codeUndefined || callStackUndefined;
+        const errorTypeUndefined = errorInfo.errorType === undefined;
+        const structureIsIncorrect = errorClassUndefined || codeUndefined || callStackUndefined || errorTypeUndefined;
         if (structureIsIncorrect) {
@@ -61,2 +62,4 @@ throw new Error('Error while deserializing error: Serialized object has an incompatible structure.');
             additionalInformation: this.additionalInformation,
+            errorType: 'Error',
+            ...this,
         });
@@ -63,0 +66,0 @@ }

dist/commonjs/ProcessModel/ProcessModelFacade/SubProcessModelFacade.js

@@ -36,5 +36,2 @@ "use strict";
     }
-    getProcessModelHasLanes() {
-        throw new index_1.NotImplementedError('Subprocesses cannot have lanes!');
-    }
     getIncomingSequenceFlowsFor(flowNodeId) {
@@ -146,4 +143,3 @@ const flowNodeExists = this.subProcessActivity.flowNodes.some((flowNode) => flowNode.id === flowNodeId);
         }
-        const matchingLane = super.findLaneForFlowNodeIdFromLaneSet(this.subProcessActivity.id, this.processModel.laneSet);
-        return matchingLane;
+        return super.getLaneForFlowNode(this.subProcessActivity.id);
     }
@@ -150,0 +146,0 @@ getLinkCatchEventsByLinkName(linkName) {

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

@@ -31,3 +31,3 @@ "use strict";
 function parseBusinessRuleTask(businessRuletasksRaw) {
-    var _a, _b, _c;
+    var _a, _b, _c, _d, _e, _f, _g;
     const businessRuleTask = (0, ActivityFactory_1.createActivityInstance)(businessRuletasksRaw, index_1.Model.Activities.BusinessRuleTask);
@@ -37,4 +37,8 @@ businessRuleTask.decisionRef = (_a = (0, ExtensionPropertyParser_1.findExtensionPropertyByName)('decisionRef', businessRuleTask.extensionElements.camundaExtensionProperties)) === null || _a === void 0 ? void 0 : _a.value;
     businessRuleTask.decisionRefVersion = (_c = (0, ExtensionPropertyParser_1.findExtensionPropertyByName)('decisionRefVersion', businessRuleTask.extensionElements.camundaExtensionProperties)) === null || _c === void 0 ? void 0 : _c.value;
+    businessRuleTask.topic = businessRuletasksRaw[index_1.BpmnTags.CamundaProperty.Topic];
+    const extensionProperties = (_e = (_d = businessRuleTask.extensionElements) === null || _d === void 0 ? void 0 : _d.camundaExtensionProperties) !== null && _e !== void 0 ? _e : [];
+    businessRuleTask.payload = (_f = (0, ExtensionPropertyParser_1.findExtensionPropertyByName)('payload', extensionProperties)) === null || _f === void 0 ? void 0 : _f.value;
+    businessRuleTask.isSingleTry = ((_g = (0, ExtensionPropertyParser_1.findExtensionPropertyByName)('engine.isSingleTry', extensionProperties)) === null || _g === void 0 ? void 0 : _g.value) === 'true';
     return businessRuleTask;
 }
 //# sourceMappingURL=BusinessRuleTaskParser.js.map

dist/commonjs/ProcessModel/ViewModel/Activities/BusinessRuleTaskViewModel.js

@@ -6,4 +6,10 @@ "use strict";
 class BusinessRuleTaskViewModel extends ActivityViewModel_1.ActivityViewModel {
+    constructor(businessRuleTask, processModel) {
+        super(businessRuleTask, processModel);
+        this.topic = businessRuleTask.topic;
+        this.payload = businessRuleTask.payload;
+        this.isSingleTry = businessRuleTask.isSingleTry;
+    }
 }
 exports.BusinessRuleTaskViewModel = BusinessRuleTaskViewModel;
 //# sourceMappingURL=BusinessRuleTaskViewModel.js.map

dist/commonjs/Serializer.js

@@ -71,3 +71,7 @@ "use strict";
     const deserializedValue = tryParse(stringifiedError, reviverFunction);
-    const notAnErrorOrEmpty = deserializedValue == undefined || deserializedValue.name == undefined || deserializedValue.message == undefined || deserializedValue.stack == undefined;
+    const notAnErrorOrEmpty = deserializedValue == undefined ||
+        deserializedValue.name == undefined ||
+        deserializedValue.message == undefined ||
+        deserializedValue.stack == undefined ||
+        deserializedValue.errorType == undefined;
     if (notAnErrorOrEmpty) {
@@ -81,2 +85,7 @@ return deserializedValue;
         }
+        Object.keys(deserializedValue).forEach((key) => {
+            if (!error[key]) {
+                error[key] = deserializedValue[key];
+            }
+        });
         return error;
@@ -88,2 +97,7 @@ }
     error.name = deserializedValue.name;
+    Object.keys(deserializedValue).forEach((key) => {
+        if (!error[key]) {
+            error[key] = deserializedValue[key];
+        }
+    });
     return error;
@@ -90,0 +104,0 @@ }

dist/DataModels/FlowNodeInstance/index.d.ts

@@ -6,2 +6,3 @@ export * from './FlowNodeInstance';
 export * from './TokenHistory';
+export * from './BusinessRuleTaskInstance';
 export * from './CallActivityInstance';
@@ -8,0 +9,0 @@ export * from './EmptyActivityInstance';

dist/EngineEvents/EngineEvent.d.ts

@@ -48,2 +48,3 @@ import { RuntimeExpressionParameters } from '..';
 export declare enum EngineEventType {
+    OnActivityError = "OnActivityError",
     OnEventProcessed = "OnEventProcessed",
@@ -50,0 +51,0 @@ OnProcessDeployed = "OnProcessDeployed",

dist/EngineEvents/EventCallbackTypes.d.ts

 import { CronjobEventMessage, CronjobEnabledChangedMessage, EventMessage, ExternalTaskCreatedMessage, ExternalTaskExpiredMessage, ExternalTaskLockedMessage, ExternalTaskUnlockedMessage, MetadataChangedMessage, ProcessDeploymentMessage, ProcessInstancesDeletedMessage, ProcessIsExecutableChangedMessage, UserTaskFinishedMessage } from './EventPayloads/index';
+export type OnActivityErrorCallback = (activityError: EventMessage) => void | Promise<void>;
 export type OnProcessDeployedCallback = (message: ProcessDeploymentMessage) => void | Promise<void>;
@@ -43,1 +44,2 @@ export type OnProcessInstancesDeletedCallback = (message: ProcessInstancesDeletedMessage) => void | Promise<void>;
 export type OnCorrelationMetadataChangedCallback = (metadataChanged: MetadataChangedMessage) => void | Promise<void>;
+export type OnGatewayFinishedCallback = (gatewayFinished: EventMessage) => void | Promise<void>;

dist/ExtensionAdapter/NotificationExtensionAdapter.d.ts

 import { Identity, Messages, Subscription } from '../index';
 export interface INotificationExtensionAdapter {
     removeSubscription(subscription: Subscription, identity?: Identity): void;
+    onActivityError(callback: Messages.CallbackTypes.OnActivityErrorCallback, options?: {
+        subscribeOnce?: boolean;
+        identity?: Identity;
+    }): Promise<Subscription>;
     onProcessDeployed(callback: Messages.CallbackTypes.OnProcessDeployedCallback, options?: {
@@ -164,2 +168,6 @@ subscribeOnce?: boolean;
     }): Promise<Subscription>;
+    onGatewayFinished(callback: Messages.CallbackTypes.OnGatewayFinishedCallback, options?: {
+        subscribeOnce?: boolean;
+        identity?: Identity;
+    }): Promise<Subscription>;
 }

dist/index.d.ts

@@ -15,2 +15,3 @@ import { EngineEventType } from './EngineEvents/index';
 export declare const LogEventType: {
+    OnActivityError: EngineEventType.OnActivityError;
     OnEventProcessed: EngineEventType.OnEventProcessed;
@@ -17,0 +18,0 @@ OnProcessDeployed: EngineEventType.OnProcessDeployed;

dist/ProcessModel/Model/Activities/BusinessRuleTask.d.ts

@@ -10,2 +10,14 @@ import { BpmnType } from '../Constants';
     get bpmnType(): BpmnType;
+    /**
+     * The topic to use in conjunction with external ServiceTasks.
+     */
+    topic?: string;
+    /**
+     * The payload to use in conjunction with external ServiceTasks.
+     */
+    payload?: string;
+    /**
+     * If set to 'true', the Service Task will fail, if it is not processed after the first lock ends.
+     */
+    isSingleTry?: boolean;
     decisionRef: string;
@@ -12,0 +24,0 @@ decisionRefBinding: string;

dist/ProcessModel/ProcessModelFacade/SubProcessModelFacade.d.ts

@@ -12,3 +12,2 @@ import { BpmnType, Model } from '../Model/index';
     getFlowNodeById(flowNodeId: string): Model.Base.FlowNode;
-    getProcessModelHasLanes(): boolean;
     getIncomingSequenceFlowsFor(flowNodeId: string): Array<Model.ProcessElements.SequenceFlow>;
@@ -15,0 +14,0 @@ getOutgoingSequenceFlowsFor(flowNodeId: string): Array<Model.ProcessElements.SequenceFlow>;

dist/ProcessModel/ViewModel/Activities/BusinessRuleTaskViewModel.d.ts

@@ -0,3 +1,9 @@
+import { BusinessRuleTask } from '../../Model/Activities';
+import { ProcessModelLike } from '../BaseElementViewModel';
 import { ActivityViewModel } from './ActivityViewModel';
 export declare class BusinessRuleTaskViewModel extends ActivityViewModel {
+    topic?: string;
+    payload?: string;
+    isSingleTry?: boolean;
+    constructor(businessRuleTask: BusinessRuleTask, processModel: ProcessModelLike);
 }

package.json

 {
   "name": "@5minds/processcube_engine_sdk",
-  "version": "4.0.0-develop-92a52b-ljeclwvo",
+  "version": "4.0.0-develop-93ce00-llm9etng",
   "description": "Software development kit for the Engine.",
@@ -40,3 +40,3 @@ "main": "dist/commonjs/index.js",
     "pino": "^6.12.0",
-    "xml2js": "^0.5.0"
+    "xml2js": "^0.6.2"
   },
@@ -51,4 +51,4 @@ "devDependencies": {
     "ts-mocha": "^10.0.0",
-    "typescript": "^5.0.4"
+    "typescript": "~5.0.4"
   }
 }

No alert changes

Improved metrics

Total package byte prevSize

1188053

increased by0.63%

Number of package files

1078

increased by0.47%

Lines of code

18707

increased by0.55%

Dependency changes

• + Addedxml2js@0.6.2(transitive)

• - Removedxml2js@0.5.0(transitive)

• Updatedxml2js@^0.6.2