@5minds/processcube_engine_sdk - npm Package Compare versions

Comparing version 4.0.0-feature-6fdcaa-ljcx6gd8 to 4.0.0-feature-758110-lkqrmrtr

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/ProcessModel/Model/Activities/ReceiveTask.js

@@ -15,2 +15,5 @@ define(["require", "exports", "../Constants", "./ActivityBase"], function (require, exports, Constants_1, ActivityBase_1) {
         }
+        get eventType() {
+            return Constants_1.EventType.messageEvent;
+        }
     }
@@ -17,0 +20,0 @@ exports.ReceiveTask = ReceiveTask;

dist/amd/ProcessModel/Model/Activities/SendTask.js

@@ -15,2 +15,5 @@ define(["require", "exports", "../Constants", "./ActivityBase"], function (require, exports, Constants_1, ActivityBase_1) {
         }
+        get eventType() {
+            return Constants_1.EventType.messageEvent;
+        }
     }
@@ -17,0 +20,0 @@ exports.SendTask = SendTask;

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/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/ProcessModel/Model/Activities/ReceiveTask.js

@@ -16,4 +16,7 @@ "use strict";
     }
+    get eventType() {
+        return Constants_1.EventType.messageEvent;
+    }
 }
 exports.ReceiveTask = ReceiveTask;
 //# sourceMappingURL=ReceiveTask.js.map

dist/commonjs/ProcessModel/Model/Activities/SendTask.js

@@ -16,4 +16,7 @@ "use strict";
     }
+    get eventType() {
+        return Constants_1.EventType.messageEvent;
+    }
 }
 exports.SendTask = SendTask;
 //# sourceMappingURL=SendTask.js.map

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/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>;
@@ -3,0 +4,0 @@ export type OnProcessInstancesDeletedCallback = (message: ProcessInstancesDeletedMessage) => 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?: {
@@ -5,0 +9,0 @@ subscribeOnce?: boolean;

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/Model/Activities/ReceiveTask.d.ts

@@ -1,2 +0,2 @@
-import { BpmnType } from '../Constants';
+import { BpmnType, EventType } from '../Constants';
 import { MessageEventDefinition } from '../Events/index';
@@ -12,2 +12,3 @@ import { Activity } from './ActivityBase';
     get bpmnType(): BpmnType;
+    get eventType(): EventType;
     /**
@@ -14,0 +15,0 @@ * This is the user defined Message which is expected by this ReceiveTask.

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

@@ -1,2 +0,2 @@
-import { BpmnType } from '../Constants';
+import { BpmnType, EventType } from '../Constants';
 import { MessageEventDefinition } from '../Events/index';
@@ -12,2 +12,3 @@ import { Activity } from './ActivityBase';
     get bpmnType(): BpmnType;
+    get eventType(): EventType;
     /**
@@ -14,0 +15,0 @@ * The message that should be send.

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-feature-6fdcaa-ljcx6gd8",
+  "version": "4.0.0-feature-758110-lkqrmrtr",
   "description": "Software development kit for the Engine.",
@@ -9,3 +9,3 @@ "main": "dist/commonjs/index.js",
     "type": "git",
-    "url": "git+https://github.com/atlas-engine/AtlasEngine.SDK.git"
+    "url": "git+https://github.com/atlas-engine/Engine.SDK.git"
   },
@@ -23,5 +23,5 @@ "author": {
   "license": "MIT",
-  "homepage": "https://github.com/atlas-engine/AtlasEngine.SDK#readme",
+  "homepage": "https://github.com/atlas-engine/Engine.SDK#readme",
   "bugs": {
-    "url": "https://github.com/atlas-engine/AtlasEngine.SDK/issues"
+    "url": "https://github.com/atlas-engine/Engine.SDK/issues"
   },
@@ -28,0 +28,0 @@ "scripts": {

New alerts

No bug tracker

Maintenance

Package does not have a linked bug tracker in package.json.

Found 1 instance in 1 package

No website

Quality

Package does not have a website.

Found 1 instance in 1 package

Fixed alerts

No bug tracker

Maintenance

Package does not have a linked bug tracker in package.json.

Found 1 instance in 1 package

No website

Quality

Package does not have a website.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

1185560

increased by0.47%

Number of package files

1078

increased by0.47%

Lines of code

18668

increased by0.42%

No dependency changes