New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

@5minds/processcube_engine_sdk

Package Overview
Dependencies
Maintainers
4
Versions
976
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@5minds/processcube_engine_sdk - npm Package Compare versions

Comparing version 4.0.0-feature-bbe9f5-lje6iwa3 to 4.0.0-feature-cdecc7-llmatc7q

dist/amd/DataModels/FlowNodeInstance/BusinessRuleTaskInstance.js

3

dist/amd/DataModels/Cronjob/index.js

@@ -15,8 +15,7 @@ var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {

};
define(["require", "exports", "./CronjobHistory", "./Cronjob"], function (require, exports, CronjobHistory_1, Cronjob_1) {
define(["require", "exports", "./Cronjob"], function (require, exports, Cronjob_1) {
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
__exportStar(CronjobHistory_1, exports);
__exportStar(Cronjob_1, exports);
});
//# sourceMappingURL=index.js.map

@@ -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);

@@ -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";

@@ -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 @@ }

@@ -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) {

@@ -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 @@ }

@@ -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;

@@ -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 @@ }

@@ -17,4 +17,3 @@ "use strict";

Object.defineProperty(exports, "__esModule", { value: true });
__exportStar(require("./CronjobHistory"), exports);
__exportStar(require("./Cronjob"), exports);
//# sourceMappingURL=index.js.map

@@ -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);

@@ -17,2 +17,3 @@ "use strict";

(function (EngineEventType) {
EngineEventType["OnActivityError"] = "OnActivityError";
EngineEventType["OnEventProcessed"] = "OnEventProcessed";

@@ -19,0 +20,0 @@ EngineEventType["OnProcessDeployed"] = "OnProcessDeployed";

@@ -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 @@ }

@@ -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) {

@@ -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

@@ -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

@@ -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 @@ }

@@ -6,78 +6,2 @@ import { SearchQuery } from '../ProcessInstance/ProcessInstanceQuery';

* schemas:
* ActiveCronjob:
* description: Describes an active cronjob.
* type: object
* required:
* - processDefinitionId
* - processModelId
* - startEventId
* - crontab
* - nextExecution
* properties:
* processDefinitionId:
* type: string
* description: The processDefinitionId that contains the ProcessModel with the cronjob.
* processModelId:
* type: string
* description: The ID of the ProcessModel that contains the cronjob.
* startEventId:
* type: string
* description: The ID of the StartEvent that contains the cronjob.
* crontab:
* type: string
* description: The crontab that describs the cronjob.
* nextExecution:
* type: string
* description: The next time the cronjob will be triggered.
*/
export declare type ActiveCronjob = {
/**
* The processDefinitionId that contains the ProcessModel with the cronjob.
*/
processDefinitionId: string;
/**
* The ID of the ProcessModel that contains the cronjob.
*/
processModelId: string;
/**
* The ID of the StartEvent that contains the cronjob.
*/
startEventId: string;
/**
* The crontab that describs the cronjob.
*/
crontab: string;
/**
* The next time the cronjob will be triggered.
*/
nextExecution: Date;
};
/**
* @swagger
* components:
* schemas:
* CronjobList:
* description: A list of active cronjobs.
* type: object
* required:
* - cronjobs
* - totalCount
* properties:
* cronjobs:
* type: array
* items:
* $ref: '#/components/schemas/ActiveCronjob'
* description: The active cronjobs
* totalCount:
* type: number
* description: The total number of active cronjobs
*/
export declare type CronjobList = {
cronjobs: Array<ActiveCronjob>;
totalCount: number;
};
/**
* @swagger
* components:
* schemas:
* Cronjob:

@@ -84,0 +8,0 @@ * description: Describes a cronjob.

@@ -1,2 +0,1 @@

export * from './CronjobHistory';
export * from './Cronjob';

@@ -6,2 +6,3 @@ export * from './FlowNodeInstance';

export * from './TokenHistory';
export * from './BusinessRuleTaskInstance';
export * from './CallActivityInstance';

@@ -8,0 +9,0 @@ export * from './EmptyActivityInstance';

@@ -48,2 +48,3 @@ import { RuntimeExpressionParameters } from '..';

export declare enum EngineEventType {
OnActivityError = "OnActivityError",
OnEventProcessed = "OnEventProcessed",

@@ -50,0 +51,0 @@ OnProcessDeployed = "OnProcessDeployed",

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>;

@@ -1,2 +0,2 @@

import { CronjobQuery, CronjobSortSettings, DataModels, DeployedCronjobList, Identity } from '../index';
import { CronjobQuery, CronjobSortSettings, DeployedCronjobList, Identity } from '../index';
export interface ICronjobExtensionAdapter {

@@ -11,19 +11,2 @@ query(query: CronjobQuery, options?: {

disableCronjob(processModelId: string, flowNodeId: string, identity?: Identity): Promise<void>;
/**
* @deprecated Use "query" instead.
*/
getActive(options?: {
identity?: Identity;
offset?: number;
limit?: number;
}): Promise<DataModels.Cronjob.CronjobList>;
/**
* @deprecated Use "query" instead.
*/
queryHistory(query: DataModels.Cronjob.CronjobHistoryQuery, options?: {
identity?: Identity;
offset?: number;
limit?: number;
sortSettings?: DataModels.Cronjob.CronjobHistorySortSettings;
}): Promise<DataModels.Cronjob.CronjobHistoryList>;
}
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>;
}

@@ -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;

@@ -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;

@@ -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>;

@@ -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);
}
{
"name": "@5minds/processcube_engine_sdk",
"version": "4.0.0-feature-bbe9f5-lje6iwa3",
"version": "4.0.0-feature-cdecc7-llmatc7q",
"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"
}
}

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc