@5minds/processcube_engine_sdk - npm Package Compare versions

Comparing version 6.1.0-feature-e2b846-m6582l6g to 6.1.0-feature-e3c0d8-m6rsoo0t

dist/commonjs/DataModels/Iam/Claims.js

@@ -14,3 +14,4 @@ "use strict";
     canWriteProcessModel: 'can_write_process_model',
+    canMonitorEngine: 'can_monitor_engine',
 };
 //# sourceMappingURL=Claims.js.map

dist/commonjs/DataModels/index.js

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

dist/commonjs/EngineEvents/EventPayloads/index.js

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

dist/commonjs/EngineEvents/index.js

@@ -50,2 +50,3 @@ "use strict";
 __exportStar(require("./EventPayloads/index"), exports);
+__exportStar(require("./Subscription"), exports);
 var Messages;
@@ -52,0 +53,0 @@ (function (Messages) {

dist/commonjs/ExtensionAdapter/index.js

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

dist/commonjs/index.js

@@ -25,7 +25,3 @@ "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);
@@ -32,0 +28,0 @@ __exportStar(require("./Serializer"), exports);

dist/commonjs/ProcessModel/ViewModel/Events/BoundaryEventViewModel.js

@@ -13,4 +13,2 @@ "use strict";
     condition;
-    messageChannel;
-    signalChannel;
     constructor(boundaryEvent, processModel) {
@@ -17,0 +15,0 @@ super(boundaryEvent, processModel);

dist/commonjs/ProcessModel/ViewModel/Events/EndEventViewModel.js

@@ -35,4 +35,2 @@ "use strict";
     errorMessage;
-    messageChannel;
-    signalChannel;
     constructor(endEvent, processModel) {
@@ -39,0 +37,0 @@ super(endEvent, processModel);

dist/commonjs/ProcessModel/ViewModel/Events/EventBaseViewModel.js

@@ -18,4 +18,6 @@ "use strict";
     messageId;
+    messageChannel;
     signalName;
     signalId;
+    signalChannel;
     constructor(event, processModel) {
@@ -25,4 +27,6 @@ super(event, processModel);
         this.messageId = event.messageEventDefinition?.id;
+        this.messageChannel = event.messageChannel;
         this.signalName = event.signalEventDefinition?.name;
         this.signalId = event.signalEventDefinition?.id;
+        this.signalChannel = event.signalChannel;
     }
@@ -29,0 +33,0 @@ }

dist/commonjs/ProcessModel/ViewModel/Events/IntermediateCatchEventViewModel.js

@@ -11,4 +11,2 @@ "use strict";
     condition;
-    messageChannel;
-    signalChannel;
     constructor(intermediateCatchEvent, processModel) {
@@ -15,0 +13,0 @@ super(intermediateCatchEvent, processModel);

dist/commonjs/ProcessModel/ViewModel/Events/IntermediateThrowEventViewModel.js

@@ -7,4 +7,2 @@ "use strict";
     linkName;
-    messageChannel;
-    signalChannel;
     constructor(intermediateThrowEvent, processModel) {
@@ -11,0 +9,0 @@ super(intermediateThrowEvent, processModel);

dist/commonjs/ProcessModel/ViewModel/Events/StartEventViewModel.js

@@ -32,4 +32,2 @@ "use strict";
     timerValue;
-    messageChannel;
-    signalChannel;
     constructor(startEvent, processModel) {
@@ -36,0 +34,0 @@ super(startEvent, processModel);

dist/DataModels/ApplicationInfo.d.ts

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

dist/DataModels/Iam/Claims.d.ts

@@ -11,2 +11,3 @@ export declare const claims: {
     canWriteProcessModel: string;
+    canMonitorEngine: string;
 };

dist/DataModels/Iam/IIamService.d.ts

 import { Identity } from './Identity';
 export interface IIamService {
     getAuthorityAddress(): string;
-    ensureHasClaim(identity: Identity, claimName: string, claimValue?: string): Promise<void>;
-    checkIfUserIsSuperAdmin(identity: Identity): Promise<boolean>;
+    ensureHasClaim(identity: Identity, claimName: string, claimValue?: string): void | Promise<void>;
+    checkIfUserIsSuperAdmin(identity: Identity): boolean | Promise<boolean>;
     checkIfTokenIsInternalToken(token: string): boolean;
     checkIfTokenIsRootAccessToken(token: string): boolean;
 }

dist/DataModels/index.d.ts

@@ -19,3 +19,2 @@ /**
 export * from './DataObjectInstance';
-export * from './EngineMetadata';
 export * from './ExternalTask/index';
@@ -22,0 +21,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, IMessageEventExtensionAdapter, INotificationExtensionAdapter, IProcessDefinitionExtensionAdapter, IProcessInstanceExtensionAdapter, IProcessModelExtensionAdapter, IUntypedTaskExtensionAdapter, IUserTaskExtensionAdapter } from './ExtensionAdapter';
+import { IApplicationInfoExtensionAdapter, ICorrelationExtensionAdapter, ICronjobExtensionAdapter, IDataObjectInstanceExtensionAdapter, IEventExtensionAdapter, IExternalTaskExtensionAdapter, IFlowNodeInstanceExtensionAdapter, IIamExtensionAdapter, IManualTaskExtensionAdapter, INotificationExtensionAdapter, IProcessDefinitionExtensionAdapter, IProcessInstanceExtensionAdapter, IProcessModelExtensionAdapter, IUntypedTaskExtensionAdapter, IUserTaskExtensionAdapter } from './ExtensionAdapter';
 import { EventViewModel, FlowNodeViewModel } from './ProcessModel/index';
@@ -211,10 +210,2 @@ /**
     /**
-     * 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.
@@ -361,3 +352,2 @@ * This middleware gets called whenever a Log Event occurs at the Engine.
     manualTasks: IManualTaskExtensionAdapter;
-    messageEvents: IMessageEventExtensionAdapter;
     notification: INotificationExtensionAdapter;
@@ -364,0 +354,0 @@ processDefinitions: IProcessDefinitionExtensionAdapter;

dist/EngineEvents/EventPayloads/index.d.ts

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

dist/EngineEvents/EventPayloads/TerminateProcessInstance.d.ts

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

dist/EngineEvents/index.d.ts

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

dist/ExtensionAdapter/CronjobExtensionAdapter.d.ts

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

dist/ExtensionAdapter/FlowNodeInstanceExtensionAdapter.d.ts

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

dist/ExtensionAdapter/index.d.ts

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

dist/ExtensionAdapter/NotificationExtensionAdapter.d.ts

@@ -80,6 +80,2 @@ 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?: {
@@ -145,2 +141,6 @@ 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, ProcessInstanceState } from '../index';
+import { DataModels, Identity } from '../index';
 export interface IProcessInstanceExtensionAdapter {
@@ -12,5 +12,2 @@ 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>;
@@ -24,3 +21,2 @@ terminateProcessInstance(processInstanceId: string, identity?: Identity): Promise<void>;
     deleteProcessInstances(processInstanceIds: Array<string>, deleteAllRelatedData: boolean, identity?: Identity): Promise<void>;
-    killProcessInstance(processInstanceId: string, identity?: Identity): Promise<void>;
 }

dist/index.d.ts

@@ -8,7 +8,3 @@ 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';
@@ -15,0 +11,0 @@ export * from './Serializer';

dist/ProcessModel/ViewModel/Events/BoundaryEventViewModel.d.ts

@@ -11,5 +11,3 @@ import { BoundaryEvent } from '../../Model/Events/index';
     condition?: string;
-    messageChannel?: string;
-    signalChannel?: string;
     constructor(boundaryEvent: BoundaryEvent, processModel: ProcessModelLike);
 }

dist/ProcessModel/ViewModel/Events/EndEventViewModel.d.ts

@@ -34,5 +34,3 @@ import { EndEvent } from '../../Model/Events/index';
     errorMessage?: string;
-    messageChannel?: string;
-    signalChannel?: string;
     constructor(endEvent: EndEvent, processModel: ProcessModelLike);
 }

dist/ProcessModel/ViewModel/Events/EventBaseViewModel.d.ts

@@ -17,5 +17,7 @@ import { Event } from '../../Model/Events/index';
     messageId?: string;
+    messageChannel?: string;
     signalName?: string;
     signalId?: string;
+    signalChannel?: string;
     constructor(event: Event, processModel: ProcessModelLike);
 }

dist/ProcessModel/ViewModel/Events/IntermediateCatchEventViewModel.d.ts

@@ -9,5 +9,3 @@ import { IntermediateCatchEvent } from '../../Model/Events/index';
     condition?: string;
-    messageChannel?: string;
-    signalChannel?: string;
     constructor(intermediateCatchEvent: IntermediateCatchEvent, processModel: ProcessModelLike);
 }

dist/ProcessModel/ViewModel/Events/IntermediateThrowEventViewModel.d.ts

@@ -6,5 +6,3 @@ import { IntermediateThrowEvent } from '../../Model/Events/index';
     linkName?: string;
-    messageChannel?: string;
-    signalChannel?: string;
     constructor(intermediateThrowEvent: IntermediateThrowEvent, processModel: ProcessModelLike);
 }

dist/ProcessModel/ViewModel/Events/StartEventViewModel.d.ts

@@ -30,5 +30,3 @@ import { StartEvent } from '../../Model/Events/index';
     timerValue?: string;
-    messageChannel?: string;
-    signalChannel?: string;
     constructor(startEvent: StartEvent, processModel: ProcessModelLike);
 }

package.json

 {
   "name": "@5minds/processcube_engine_sdk",
-  "version": "6.1.0-feature-e2b846-m6582l6g",
+  "version": "6.1.0-feature-e3c0d8-m6rsoo0t",
   "description": "Software development kit for the Engine.",
@@ -5,0 +5,0 @@ "main": "dist/commonjs/index.js",

No alert changes

Worsened metrics

Total package byte prevSize

652254

decreased by-23.73%

Number of package files

600

decreased by-3.38%

Lines of code

11538

decreased by-28.99%

No dependency changes