@process-engine/management_api_client - npm Package Compare versions

Comparing version 6.1.0-feature-159852-k0nwlw20 to 6.1.0-feature-1964df-k0o0hroy

dist/accessors/external_accessor.d.ts

@@ -45,10 +45,10 @@ import { Subscription } from '@essential-projects/event_aggregator_contracts';
     removeSubscription(identity: IIdentity, subscription: Subscription): Promise<void>;
-    getAllCorrelations(identity: IIdentity, offset?: number, limit?: number): Promise<Array<DataModels.Correlations.Correlation>>;
-    getActiveCorrelations(identity: IIdentity, offset?: number, limit?: number): Promise<Array<DataModels.Correlations.Correlation>>;
+    getAllCorrelations(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.Correlations.CorrelationList>;
+    getActiveCorrelations(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.Correlations.CorrelationList>;
     getCorrelationById(identity: IIdentity, correlationId: string): Promise<DataModels.Correlations.Correlation>;
     getCorrelationByProcessInstanceId(identity: IIdentity, processInstanceId: string): Promise<DataModels.Correlations.Correlation>;
-    getCorrelationsByProcessModelId(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<Array<DataModels.Correlations.Correlation>>;
-    getAllActiveCronjobs(identity: IIdentity, offset?: number, limit?: number): Promise<Array<DataModels.Cronjobs.CronjobConfiguration>>;
-    getCronjobExecutionHistoryForProcessModel(identity: IIdentity, processModelId: string, startEventId?: string, offset?: number, limit?: number): Promise<Array<DataModels.Cronjobs.CronjobHistoryEntry>>;
-    getCronjobExecutionHistoryForCrontab(identity: IIdentity, crontab: string, offset?: number, limit?: number): Promise<Array<DataModels.Cronjobs.CronjobHistoryEntry>>;
+    getCorrelationsByProcessModelId(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Correlations.CorrelationList>;
+    getAllActiveCronjobs(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobList>;
+    getCronjobExecutionHistoryForProcessModel(identity: IIdentity, processModelId: string, startEventId?: string, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobHistoryList>;
+    getCronjobExecutionHistoryForCrontab(identity: IIdentity, crontab: string, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobHistoryList>;
     getProcessModels(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.ProcessModels.ProcessModelList>;
@@ -72,8 +72,3 @@ getProcessModelById(identity: IIdentity, processModelId: string): Promise<DataModels.ProcessModels.ProcessModel>;
     triggerSignalEvent(identity: IIdentity, signalName: string, payload?: DataModels.Events.EventTriggerPayload): Promise<void>;
-    getFlowNodeInstancesForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<Array<DataModels.FlowNodeInstances.FlowNodeInstance>>;
-    getAllSuspendedTasks(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
-    getSuspendedTasksForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
-    getSuspendedTasksForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
-    getSuspendedTasksForCorrelation(identity: IIdentity, correlationId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
-    getSuspendedTasksForProcessModelInCorrelation(identity: IIdentity, processModelId: string, correlationId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
+    getFlowNodeInstancesForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.FlowNodeInstanceList>;
     getManualTasksForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.ManualTasks.ManualTaskList>;
@@ -89,11 +84,11 @@ getManualTasksForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.ManualTasks.ManualTaskList>;
     finishUserTask(identity: IIdentity, processInstanceId: string, correlationId: string, userTaskInstanceId: string, userTaskResult: DataModels.UserTasks.UserTaskResult): Promise<void>;
-    getRuntimeInformationForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.FlowNodeRuntimeInformation>>;
+    getRuntimeInformationForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.FlowNodeRuntimeInformationList>;
     getRuntimeInformationForFlowNode(identity: IIdentity, processModelId: string, flowNodeId: string): Promise<DataModels.Kpi.FlowNodeRuntimeInformation>;
-    getActiveTokensForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.ActiveToken>>;
-    getActiveTokensForCorrelationAndProcessModel(identity: IIdentity, correlationId: string, processModelId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.ActiveToken>>;
-    getActiveTokensForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.ActiveToken>>;
-    getActiveTokensForFlowNode(identity: IIdentity, flowNodeId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.ActiveToken>>;
-    getProcessModelLog(identity: IIdentity, processModelId: string, correlationId?: string, offset?: number, limit?: number): Promise<Array<DataModels.Logging.LogEntry>>;
-    getProcessInstanceLog(identity: IIdentity, processModelId: string, processInstanceId: string, offset?: number, limit?: number): Promise<Array<DataModels.Logging.LogEntry>>;
-    getTokensForFlowNode(identity: IIdentity, correlationId: string, processModelId: string, flowNodeId: string, offset?: number, limit?: number): Promise<Array<DataModels.TokenHistory.TokenHistoryEntry>>;
+    getActiveTokensForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.ActiveTokenList>;
+    getActiveTokensForCorrelationAndProcessModel(identity: IIdentity, correlationId: string, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.ActiveTokenList>;
+    getActiveTokensForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.ActiveTokenList>;
+    getActiveTokensForFlowNode(identity: IIdentity, flowNodeId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.ActiveTokenList>;
+    getProcessModelLog(identity: IIdentity, processModelId: string, correlationId?: string, offset?: number, limit?: number): Promise<DataModels.Logging.LogEntryList>;
+    getProcessInstanceLog(identity: IIdentity, processModelId: string, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.Logging.LogEntryList>;
+    getTokensForFlowNode(identity: IIdentity, correlationId: string, processModelId: string, flowNodeId: string, offset?: number, limit?: number): Promise<DataModels.TokenHistory.TokenHistoryEntryList>;
     getTokensForFlowNodeByProcessInstanceId(identity: IIdentity, processInstanceId: string, flowNodeId: string): Promise<DataModels.TokenHistory.TokenHistoryGroup>;
@@ -100,0 +95,0 @@ getTokensForCorrelationAndProcessModel(identity: IIdentity, correlationId: string, processModelId: string): Promise<DataModels.TokenHistory.TokenHistoryGroup>;

dist/accessors/internal_accessor.d.ts

@@ -49,10 +49,10 @@ import { Subscription } from '@essential-projects/event_aggregator_contracts';
     removeSubscription(identity: IIdentity, subscription: Subscription): Promise<void>;
-    getAllCorrelations(identity: IIdentity, offset?: number, limit?: number): Promise<Array<DataModels.Correlations.Correlation>>;
-    getActiveCorrelations(identity: IIdentity, offset?: number, limit?: number): Promise<Array<DataModels.Correlations.Correlation>>;
+    getAllCorrelations(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.Correlations.CorrelationList>;
+    getActiveCorrelations(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.Correlations.CorrelationList>;
     getCorrelationById(identity: IIdentity, correlationId: string): Promise<DataModels.Correlations.Correlation>;
     getCorrelationByProcessInstanceId(identity: IIdentity, processInstanceId: string): Promise<DataModels.Correlations.Correlation>;
-    getCorrelationsByProcessModelId(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<Array<DataModels.Correlations.Correlation>>;
-    getAllActiveCronjobs(identity: IIdentity, offset?: number, limit?: number): Promise<Array<DataModels.Cronjobs.CronjobConfiguration>>;
-    getCronjobExecutionHistoryForProcessModel(identity: IIdentity, processModelId: string, startEventId?: string, offset?: number, limit?: number): Promise<Array<DataModels.Cronjobs.CronjobHistoryEntry>>;
-    getCronjobExecutionHistoryForCrontab(identity: IIdentity, crontab: string, offset?: number, limit?: number): Promise<Array<DataModels.Cronjobs.CronjobHistoryEntry>>;
+    getCorrelationsByProcessModelId(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Correlations.CorrelationList>;
+    getAllActiveCronjobs(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobList>;
+    getCronjobExecutionHistoryForProcessModel(identity: IIdentity, processModelId: string, startEventId?: string, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobHistoryList>;
+    getCronjobExecutionHistoryForCrontab(identity: IIdentity, crontab: string, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobHistoryList>;
     getProcessModels(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.ProcessModels.ProcessModelList>;
@@ -76,8 +76,3 @@ getProcessModelById(identity: IIdentity, processModelId: string): Promise<DataModels.ProcessModels.ProcessModel>;
     triggerSignalEvent(identity: IIdentity, signalName: string, payload?: DataModels.Events.EventTriggerPayload): Promise<void>;
-    getFlowNodeInstancesForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<Array<DataModels.FlowNodeInstances.FlowNodeInstance>>;
-    getAllSuspendedTasks(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
-    getSuspendedTasksForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
-    getSuspendedTasksForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
-    getSuspendedTasksForCorrelation(identity: IIdentity, correlationId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
-    getSuspendedTasksForProcessModelInCorrelation(identity: IIdentity, processModelId: string, correlationId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
+    getFlowNodeInstancesForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.FlowNodeInstanceList>;
     getManualTasksForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.ManualTasks.ManualTaskList>;
@@ -93,11 +88,11 @@ getManualTasksForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.ManualTasks.ManualTaskList>;
     finishUserTask(identity: IIdentity, processInstanceId: string, correlationId: string, userTaskInstanceId: string, userTaskResult: DataModels.UserTasks.UserTaskResult): Promise<void>;
-    getRuntimeInformationForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.FlowNodeRuntimeInformation>>;
+    getRuntimeInformationForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.FlowNodeRuntimeInformationList>;
     getRuntimeInformationForFlowNode(identity: IIdentity, processModelId: string, flowNodeId: string): Promise<DataModels.Kpi.FlowNodeRuntimeInformation>;
-    getActiveTokensForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.ActiveToken>>;
-    getActiveTokensForCorrelationAndProcessModel(identity: IIdentity, correlationId: string, processModelId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.ActiveToken>>;
-    getActiveTokensForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.ActiveToken>>;
-    getActiveTokensForFlowNode(identity: IIdentity, flowNodeId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.ActiveToken>>;
-    getProcessModelLog(identity: IIdentity, processModelId: string, correlationId?: string, offset?: number, limit?: number): Promise<Array<DataModels.Logging.LogEntry>>;
-    getProcessInstanceLog(identity: IIdentity, processModelId: string, processInstanceId: string, offset?: number, limit?: number): Promise<Array<DataModels.Logging.LogEntry>>;
-    getTokensForFlowNode(identity: IIdentity, correlationId: string, processModelId: string, flowNodeId: string, offset?: number, limit?: number): Promise<Array<DataModels.TokenHistory.TokenHistoryEntry>>;
+    getActiveTokensForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.ActiveTokenList>;
+    getActiveTokensForCorrelationAndProcessModel(identity: IIdentity, correlationId: string, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.ActiveTokenList>;
+    getActiveTokensForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.ActiveTokenList>;
+    getActiveTokensForFlowNode(identity: IIdentity, flowNodeId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.ActiveTokenList>;
+    getProcessModelLog(identity: IIdentity, processModelId: string, correlationId?: string, offset?: number, limit?: number): Promise<DataModels.Logging.LogEntryList>;
+    getProcessInstanceLog(identity: IIdentity, processModelId: string, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.Logging.LogEntryList>;
+    getTokensForFlowNode(identity: IIdentity, correlationId: string, processModelId: string, flowNodeId: string, offset?: number, limit?: number): Promise<DataModels.TokenHistory.TokenHistoryEntryList>;
     getTokensForFlowNodeByProcessInstanceId(identity: IIdentity, processInstanceId: string, flowNodeId: string): Promise<DataModels.TokenHistory.TokenHistoryGroup>;
@@ -104,0 +99,0 @@ getTokensForCorrelationAndProcessModel(identity: IIdentity, correlationId: string, processModelId: string): Promise<DataModels.TokenHistory.TokenHistoryGroup>;

dist/amd/accessors/external_accessor.js

@@ -180,3 +180,3 @@ define(["require", "exports", "moment", "node-uuid", "socket.io-client", "@essential-projects/errors_ts", "@essential-projects/event_aggregator_contracts", "@process-engine/management_api_contracts"], function (require, exports, moment, uuid, io, errors_ts_1, event_aggregator_contracts_1, management_api_contracts_1) {
             // We need to restore the datatype of `nextExecution`, since that property gets stringified when transported over http.
-            const mappedResult = httpResponse.result.map((entry) => {
+            const mappedCronjobs = httpResponse.result.cronjobs.map((entry) => {
                 const mappedEntry = entry;
@@ -188,3 +188,6 @@ if (entry.nextExecution) {
             });
-            return mappedResult;
+            const result = new management_api_contracts_1.DataModels.Cronjobs.CronjobList();
+            result.cronjobs = mappedCronjobs;
+            result.totalCount = httpResponse.result.totalCount;
+            return result;
         }
@@ -201,3 +204,3 @@ async getCronjobExecutionHistoryForProcessModel(identity, processModelId, startEventId, offset = 0, limit = 0) {
             // We need to restore the datatype of `executedAt`, since that property gets stringified when transported over http.
-            const mappedResult = httpResponse.result.map((entry) => {
+            const mappedCronjobHistories = httpResponse.result.cronjobHistories.map((entry) => {
                 const mappedEntry = entry;
@@ -209,3 +212,6 @@ if (entry.executedAt) {
             });
-            return mappedResult;
+            const result = new management_api_contracts_1.DataModels.Cronjobs.CronjobHistoryList();
+            result.cronjobHistories = mappedCronjobHistories;
+            result.totalCount = httpResponse.result.totalCount;
+            return result;
         }
@@ -218,3 +224,3 @@ async getCronjobExecutionHistoryForCrontab(identity, crontab, offset = 0, limit = 0) {
             // We need to restore the datatype of `executedAt`, since that property gets stringified when transported over http.
-            const mappedResult = httpResponse.result.map((entry) => {
+            const mappedCronjobHistories = httpResponse.result.cronjobHistories.map((entry) => {
                 const mappedEntry = entry;
@@ -226,3 +232,6 @@ if (entry.executedAt) {
             });
-            return mappedResult;
+            const result = new management_api_contracts_1.DataModels.Cronjobs.CronjobHistoryList();
+            result.cronjobHistories = mappedCronjobHistories;
+            result.totalCount = httpResponse.result.totalCount;
+            return result;
         }
@@ -374,40 +383,2 @@ // ProcessModels
         }
-        // Tasks
-        async getAllSuspendedTasks(identity, offset = 0, limit = 0) {
-            const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-            const urlRestPath = management_api_contracts_1.restSettings.paths.allSuspendedTasks;
-            const url = this.buildUrl(urlRestPath, offset, limit);
-            const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
-            return httpResponse.result;
-        }
-        async getSuspendedTasksForProcessModel(identity, processModelId, offset = 0, limit = 0) {
-            const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-            const urlRestPath = management_api_contracts_1.restSettings.paths.suspendedProcessModelTasks.replace(management_api_contracts_1.restSettings.params.processModelId, processModelId);
-            const url = this.buildUrl(urlRestPath, offset, limit);
-            const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
-            return httpResponse.result;
-        }
-        async getSuspendedTasksForProcessInstance(identity, processInstanceId, offset = 0, limit = 0) {
-            const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-            const urlRestPath = management_api_contracts_1.restSettings.paths.suspendedProcessInstanceTasks.replace(management_api_contracts_1.restSettings.params.processInstanceId, processInstanceId);
-            const url = this.buildUrl(urlRestPath, offset, limit);
-            const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
-            return httpResponse.result;
-        }
-        async getSuspendedTasksForCorrelation(identity, correlationId, offset = 0, limit = 0) {
-            const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-            const urlRestPath = management_api_contracts_1.restSettings.paths.suspendedCorrelationTasks.replace(management_api_contracts_1.restSettings.params.correlationId, correlationId);
-            const url = this.buildUrl(urlRestPath, offset, limit);
-            const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
-            return httpResponse.result;
-        }
-        async getSuspendedTasksForProcessModelInCorrelation(identity, processModelId, correlationId, offset = 0, limit = 0) {
-            const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-            const urlRestPath = management_api_contracts_1.restSettings.paths.suspendedProcessModelCorrelationTasks
-                .replace(management_api_contracts_1.restSettings.params.processModelId, processModelId)
-                .replace(management_api_contracts_1.restSettings.params.correlationId, correlationId);
-            const url = this.buildUrl(urlRestPath, offset, limit);
-            const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
-            return httpResponse.result;
-        }
         // ManualTasks
@@ -414,0 +385,0 @@ async getManualTasksForProcessModel(identity, processModelId, offset = 0, limit = 0) {

dist/amd/accessors/internal_accessor.js

@@ -202,18 +202,2 @@ define(["require", "exports", "@process-engine/management_api_contracts"], function (require, exports, management_api_contracts_1) {
         }
-        // Tasks
-        async getAllSuspendedTasks(identity, offset = 0, limit = 0) {
-            return this.flowNodeInstanceService.getAllSuspendedTasks(identity, offset, limit);
-        }
-        async getSuspendedTasksForProcessModel(identity, processModelId, offset = 0, limit = 0) {
-            return this.flowNodeInstanceService.getSuspendedTasksForProcessModel(identity, processModelId, offset, limit);
-        }
-        async getSuspendedTasksForProcessInstance(identity, processInstanceId, offset = 0, limit = 0) {
-            return this.flowNodeInstanceService.getSuspendedTasksForProcessInstance(identity, processInstanceId, offset, limit);
-        }
-        async getSuspendedTasksForCorrelation(identity, correlationId, offset = 0, limit = 0) {
-            return this.flowNodeInstanceService.getSuspendedTasksForCorrelation(identity, correlationId, offset, limit);
-        }
-        async getSuspendedTasksForProcessModelInCorrelation(identity, processModelId, correlationId, offset = 0, limit = 0) {
-            return this.flowNodeInstanceService.getSuspendedTasksForProcessModelInCorrelation(identity, processModelId, correlationId, offset, limit);
-        }
         // ManualTasks
@@ -220,0 +204,0 @@ async getManualTasksForProcessModel(identity, processModelId, offset = 0, limit = 0) {

dist/amd/management_api_client.js

@@ -302,23 +302,2 @@ define(["require", "exports", "loggerhythm", "@essential-projects/errors_ts", "@process-engine/management_api_contracts"], function (require, exports, loggerhythm_1, EssentialProjectErrors, management_api_contracts_1) {
         }
-        // Tasks
-        async getAllSuspendedTasks(identity, offset = 0, limit = 0) {
-            this.ensureIsAuthorized(identity);
-            return this.managementApiAccessor.getAllSuspendedTasks(identity, offset, limit);
-        }
-        async getSuspendedTasksForProcessModel(identity, processModelId, offset = 0, limit = 0) {
-            this.ensureIsAuthorized(identity);
-            return this.managementApiAccessor.getSuspendedTasksForProcessModel(identity, processModelId, offset, limit);
-        }
-        async getSuspendedTasksForProcessInstance(identity, processInstanceId, offset = 0, limit = 0) {
-            this.ensureIsAuthorized(identity);
-            return this.managementApiAccessor.getSuspendedTasksForProcessInstance(identity, processInstanceId, offset, limit);
-        }
-        async getSuspendedTasksForCorrelation(identity, correlationId, offset = 0, limit = 0) {
-            this.ensureIsAuthorized(identity);
-            return this.managementApiAccessor.getSuspendedTasksForCorrelation(identity, correlationId, offset, limit);
-        }
-        async getSuspendedTasksForProcessModelInCorrelation(identity, processModelId, correlationId, offset = 0, limit = 0) {
-            this.ensureIsAuthorized(identity);
-            return this.managementApiAccessor.getSuspendedTasksForProcessModelInCorrelation(identity, processModelId, correlationId, offset, limit);
-        }
         // Heatmap related features
@@ -325,0 +304,0 @@ async getRuntimeInformationForProcessModel(identity, processModelId, offset = 0, limit = 0) {

dist/commonjs/accessors/external_accessor.js

@@ -187,3 +187,3 @@ "use strict";
         // We need to restore the datatype of `nextExecution`, since that property gets stringified when transported over http.
-        const mappedResult = httpResponse.result.map((entry) => {
+        const mappedCronjobs = httpResponse.result.cronjobs.map((entry) => {
             const mappedEntry = entry;
@@ -195,3 +195,6 @@ if (entry.nextExecution) {
         });
-        return mappedResult;
+        const result = new management_api_contracts_1.DataModels.Cronjobs.CronjobList();
+        result.cronjobs = mappedCronjobs;
+        result.totalCount = httpResponse.result.totalCount;
+        return result;
     }
@@ -208,3 +211,3 @@ async getCronjobExecutionHistoryForProcessModel(identity, processModelId, startEventId, offset = 0, limit = 0) {
         // We need to restore the datatype of `executedAt`, since that property gets stringified when transported over http.
-        const mappedResult = httpResponse.result.map((entry) => {
+        const mappedCronjobHistories = httpResponse.result.cronjobHistories.map((entry) => {
             const mappedEntry = entry;
@@ -216,3 +219,6 @@ if (entry.executedAt) {
         });
-        return mappedResult;
+        const result = new management_api_contracts_1.DataModels.Cronjobs.CronjobHistoryList();
+        result.cronjobHistories = mappedCronjobHistories;
+        result.totalCount = httpResponse.result.totalCount;
+        return result;
     }
@@ -225,3 +231,3 @@ async getCronjobExecutionHistoryForCrontab(identity, crontab, offset = 0, limit = 0) {
         // We need to restore the datatype of `executedAt`, since that property gets stringified when transported over http.
-        const mappedResult = httpResponse.result.map((entry) => {
+        const mappedCronjobHistories = httpResponse.result.cronjobHistories.map((entry) => {
             const mappedEntry = entry;
@@ -233,3 +239,6 @@ if (entry.executedAt) {
         });
-        return mappedResult;
+        const result = new management_api_contracts_1.DataModels.Cronjobs.CronjobHistoryList();
+        result.cronjobHistories = mappedCronjobHistories;
+        result.totalCount = httpResponse.result.totalCount;
+        return result;
     }
@@ -381,40 +390,2 @@ // ProcessModels
     }
-    // Tasks
-    async getAllSuspendedTasks(identity, offset = 0, limit = 0) {
-        const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-        const urlRestPath = management_api_contracts_1.restSettings.paths.allSuspendedTasks;
-        const url = this.buildUrl(urlRestPath, offset, limit);
-        const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
-        return httpResponse.result;
-    }
-    async getSuspendedTasksForProcessModel(identity, processModelId, offset = 0, limit = 0) {
-        const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-        const urlRestPath = management_api_contracts_1.restSettings.paths.suspendedProcessModelTasks.replace(management_api_contracts_1.restSettings.params.processModelId, processModelId);
-        const url = this.buildUrl(urlRestPath, offset, limit);
-        const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
-        return httpResponse.result;
-    }
-    async getSuspendedTasksForProcessInstance(identity, processInstanceId, offset = 0, limit = 0) {
-        const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-        const urlRestPath = management_api_contracts_1.restSettings.paths.suspendedProcessInstanceTasks.replace(management_api_contracts_1.restSettings.params.processInstanceId, processInstanceId);
-        const url = this.buildUrl(urlRestPath, offset, limit);
-        const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
-        return httpResponse.result;
-    }
-    async getSuspendedTasksForCorrelation(identity, correlationId, offset = 0, limit = 0) {
-        const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-        const urlRestPath = management_api_contracts_1.restSettings.paths.suspendedCorrelationTasks.replace(management_api_contracts_1.restSettings.params.correlationId, correlationId);
-        const url = this.buildUrl(urlRestPath, offset, limit);
-        const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
-        return httpResponse.result;
-    }
-    async getSuspendedTasksForProcessModelInCorrelation(identity, processModelId, correlationId, offset = 0, limit = 0) {
-        const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-        const urlRestPath = management_api_contracts_1.restSettings.paths.suspendedProcessModelCorrelationTasks
-            .replace(management_api_contracts_1.restSettings.params.processModelId, processModelId)
-            .replace(management_api_contracts_1.restSettings.params.correlationId, correlationId);
-        const url = this.buildUrl(urlRestPath, offset, limit);
-        const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
-        return httpResponse.result;
-    }
     // ManualTasks
@@ -421,0 +392,0 @@ async getManualTasksForProcessModel(identity, processModelId, offset = 0, limit = 0) {

dist/commonjs/accessors/internal_accessor.js

@@ -202,18 +202,2 @@ "use strict";
     }
-    // Tasks
-    async getAllSuspendedTasks(identity, offset = 0, limit = 0) {
-        return this.flowNodeInstanceService.getAllSuspendedTasks(identity, offset, limit);
-    }
-    async getSuspendedTasksForProcessModel(identity, processModelId, offset = 0, limit = 0) {
-        return this.flowNodeInstanceService.getSuspendedTasksForProcessModel(identity, processModelId, offset, limit);
-    }
-    async getSuspendedTasksForProcessInstance(identity, processInstanceId, offset = 0, limit = 0) {
-        return this.flowNodeInstanceService.getSuspendedTasksForProcessInstance(identity, processInstanceId, offset, limit);
-    }
-    async getSuspendedTasksForCorrelation(identity, correlationId, offset = 0, limit = 0) {
-        return this.flowNodeInstanceService.getSuspendedTasksForCorrelation(identity, correlationId, offset, limit);
-    }
-    async getSuspendedTasksForProcessModelInCorrelation(identity, processModelId, correlationId, offset = 0, limit = 0) {
-        return this.flowNodeInstanceService.getSuspendedTasksForProcessModelInCorrelation(identity, processModelId, correlationId, offset, limit);
-    }
     // ManualTasks
@@ -220,0 +204,0 @@ async getManualTasksForProcessModel(identity, processModelId, offset = 0, limit = 0) {

dist/commonjs/management_api_client.js

@@ -304,23 +304,2 @@ "use strict";
     }
-    // Tasks
-    async getAllSuspendedTasks(identity, offset = 0, limit = 0) {
-        this.ensureIsAuthorized(identity);
-        return this.managementApiAccessor.getAllSuspendedTasks(identity, offset, limit);
-    }
-    async getSuspendedTasksForProcessModel(identity, processModelId, offset = 0, limit = 0) {
-        this.ensureIsAuthorized(identity);
-        return this.managementApiAccessor.getSuspendedTasksForProcessModel(identity, processModelId, offset, limit);
-    }
-    async getSuspendedTasksForProcessInstance(identity, processInstanceId, offset = 0, limit = 0) {
-        this.ensureIsAuthorized(identity);
-        return this.managementApiAccessor.getSuspendedTasksForProcessInstance(identity, processInstanceId, offset, limit);
-    }
-    async getSuspendedTasksForCorrelation(identity, correlationId, offset = 0, limit = 0) {
-        this.ensureIsAuthorized(identity);
-        return this.managementApiAccessor.getSuspendedTasksForCorrelation(identity, correlationId, offset, limit);
-    }
-    async getSuspendedTasksForProcessModelInCorrelation(identity, processModelId, correlationId, offset = 0, limit = 0) {
-        this.ensureIsAuthorized(identity);
-        return this.managementApiAccessor.getSuspendedTasksForProcessModelInCorrelation(identity, processModelId, correlationId, offset, limit);
-    }
     // Heatmap related features
@@ -327,0 +306,0 @@ async getRuntimeInformationForProcessModel(identity, processModelId, offset = 0, limit = 0) {

dist/management_api_client.d.ts

@@ -38,10 +38,10 @@ import { Subscription } from '@essential-projects/event_aggregator_contracts';
     removeSubscription(identity: IIdentity, subscription: Subscription): Promise<void>;
-    getAllCorrelations(identity: IIdentity, offset?: number, limit?: number): Promise<Array<DataModels.Correlations.Correlation>>;
-    getActiveCorrelations(identity: IIdentity, offset?: number, limit?: number): Promise<Array<DataModels.Correlations.Correlation>>;
+    getAllCorrelations(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.Correlations.CorrelationList>;
+    getActiveCorrelations(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.Correlations.CorrelationList>;
     getCorrelationById(identity: IIdentity, correlationId: string): Promise<DataModels.Correlations.Correlation>;
     getCorrelationByProcessInstanceId(identity: IIdentity, processInstanceId: string): Promise<DataModels.Correlations.Correlation>;
-    getCorrelationsByProcessModelId(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<Array<DataModels.Correlations.Correlation>>;
-    getAllActiveCronjobs(identity: IIdentity, offset?: number, limit?: number): Promise<Array<DataModels.Cronjobs.CronjobConfiguration>>;
-    getCronjobExecutionHistoryForProcessModel(identity: IIdentity, processModelId: string, startEventId?: string, offset?: number, limit?: number): Promise<Array<DataModels.Cronjobs.CronjobHistoryEntry>>;
-    getCronjobExecutionHistoryForCrontab(identity: IIdentity, crontab: string, offset?: number, limit?: number): Promise<Array<DataModels.Cronjobs.CronjobHistoryEntry>>;
+    getCorrelationsByProcessModelId(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Correlations.CorrelationList>;
+    getAllActiveCronjobs(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobList>;
+    getCronjobExecutionHistoryForProcessModel(identity: IIdentity, processModelId: string, startEventId?: string, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobHistoryList>;
+    getCronjobExecutionHistoryForCrontab(identity: IIdentity, crontab: string, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobHistoryList>;
     getProcessModels(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.ProcessModels.ProcessModelList>;
@@ -65,3 +65,3 @@ getProcessModelById(identity: IIdentity, processModelId: string): Promise<DataModels.ProcessModels.ProcessModel>;
     triggerSignalEvent(identity: IIdentity, signalName: string, payload?: DataModels.Events.EventTriggerPayload): Promise<void>;
-    getFlowNodeInstancesForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<Array<DataModels.FlowNodeInstances.FlowNodeInstance>>;
+    getFlowNodeInstancesForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.FlowNodeInstanceList>;
     getManualTasksForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.ManualTasks.ManualTaskList>;
@@ -77,16 +77,11 @@ getManualTasksForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.ManualTasks.ManualTaskList>;
     finishUserTask(identity: IIdentity, processInstanceId: string, correlationId: string, userTaskInstanceId: string, userTaskResult: DataModels.UserTasks.UserTaskResult): Promise<void>;
-    getAllSuspendedTasks(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
-    getSuspendedTasksForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
-    getSuspendedTasksForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
-    getSuspendedTasksForCorrelation(identity: IIdentity, correlationId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
-    getSuspendedTasksForProcessModelInCorrelation(identity: IIdentity, processModelId: string, correlationId: string, offset?: number, limit?: number): Promise<DataModels.FlowNodeInstances.TaskList>;
-    getRuntimeInformationForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.FlowNodeRuntimeInformation>>;
+    getRuntimeInformationForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.FlowNodeRuntimeInformationList>;
     getRuntimeInformationForFlowNode(identity: IIdentity, processModelId: string, flowNodeId: string): Promise<DataModels.Kpi.FlowNodeRuntimeInformation>;
-    getActiveTokensForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.ActiveToken>>;
-    getActiveTokensForCorrelationAndProcessModel(identity: IIdentity, correlationId: string, processModelId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.ActiveToken>>;
-    getActiveTokensForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.ActiveToken>>;
-    getActiveTokensForFlowNode(identity: IIdentity, flowNodeId: string, offset?: number, limit?: number): Promise<Array<DataModels.Kpi.ActiveToken>>;
-    getProcessModelLog(identity: IIdentity, processModelId: string, correlationId?: string, offset?: number, limit?: number): Promise<Array<DataModels.Logging.LogEntry>>;
-    getProcessInstanceLog(identity: IIdentity, processModelId: string, processInstanceId: string, offset?: number, limit?: number): Promise<Array<DataModels.Logging.LogEntry>>;
-    getTokensForFlowNode(identity: IIdentity, correlationId: string, processModelId: string, flowNodeId: string, offset?: number, limit?: number): Promise<Array<DataModels.TokenHistory.TokenHistoryEntry>>;
+    getActiveTokensForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.ActiveTokenList>;
+    getActiveTokensForCorrelationAndProcessModel(identity: IIdentity, correlationId: string, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.ActiveTokenList>;
+    getActiveTokensForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.ActiveTokenList>;
+    getActiveTokensForFlowNode(identity: IIdentity, flowNodeId: string, offset?: number, limit?: number): Promise<DataModels.Kpi.ActiveTokenList>;
+    getProcessModelLog(identity: IIdentity, processModelId: string, correlationId?: string, offset?: number, limit?: number): Promise<DataModels.Logging.LogEntryList>;
+    getProcessInstanceLog(identity: IIdentity, processModelId: string, processInstanceId: string, offset?: number, limit?: number): Promise<DataModels.Logging.LogEntryList>;
+    getTokensForFlowNode(identity: IIdentity, correlationId: string, processModelId: string, flowNodeId: string, offset?: number, limit?: number): Promise<DataModels.TokenHistory.TokenHistoryEntryList>;
     getTokensForFlowNodeByProcessInstanceId(identity: IIdentity, processInstanceId: string, flowNodeId: string): Promise<DataModels.TokenHistory.TokenHistoryGroup>;
@@ -93,0 +88,0 @@ getTokensForCorrelationAndProcessModel(identity: IIdentity, correlationId: string, processModelId: string): Promise<DataModels.TokenHistory.TokenHistoryGroup>;

package.json

 {
   "name": "@process-engine/management_api_client",
-  "version": "6.1.0-feature-159852-k0nwlw20",
+  "version": "6.1.0-feature-1964df-k0o0hroy",
   "description": "client implementation for using the process-engine.io Management API",
@@ -34,3 +34,3 @@ "main": "dist/commonjs/index.js",
     "@essential-projects/iam_contracts": "^3.5.0",
-    "@process-engine/management_api_contracts": "feature~add_get-tasks_functionality",
+    "@process-engine/management_api_contracts": "12.1.0-71b8cf24-b29",
     "loggerhythm": "^3.0.4",
@@ -37,0 +37,0 @@ "moment": "^2.24.0",

src/accessors/external_accessor.ts

@@ -367,3 +367,3 @@ /* eslint-disable max-lines */
     limit: number = 0,
-  ): Promise<Array<DataModels.Correlations.Correlation>> {
+  ): Promise<DataModels.Correlations.CorrelationList> {
 
@@ -374,3 +374,3 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.Correlations.Correlation>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Correlations.CorrelationList>(url, requestAuthHeaders);
 
@@ -384,3 +384,3 @@ return httpResponse.result;
     limit: number = 0,
-  ): Promise<Array<DataModels.Correlations.Correlation>> {
+  ): Promise<DataModels.Correlations.CorrelationList> {
 
@@ -391,3 +391,3 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.Correlations.Correlation>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Correlations.CorrelationList>(url, requestAuthHeaders);
 
@@ -431,3 +431,3 @@ return httpResponse.result;
     limit: number = 0,
-  ): Promise<Array<DataModels.Correlations.Correlation>> {
+  ): Promise<DataModels.Correlations.CorrelationList> {
 
@@ -441,3 +441,3 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.Correlations.Correlation>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Correlations.CorrelationList>(url, requestAuthHeaders);
 
@@ -452,3 +452,3 @@ return httpResponse.result;
     limit: number = 0,
-  ): Promise<Array<DataModels.Cronjobs.CronjobConfiguration>> {
+  ): Promise<DataModels.Cronjobs.CronjobList> {
 
@@ -459,6 +459,6 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.Cronjobs.CronjobConfiguration>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Cronjobs.CronjobList>(url, requestAuthHeaders);
 
     // We need to restore the datatype of `nextExecution`, since that property gets stringified when transported over http.
-    const mappedResult = httpResponse.result.map((entry): DataModels.Cronjobs.CronjobConfiguration => {
+    const mappedCronjobs = httpResponse.result.cronjobs.map((entry): DataModels.Cronjobs.CronjobConfiguration => {
       const mappedEntry = entry;
@@ -472,3 +472,8 @@ if (entry.nextExecution) {
 
-    return mappedResult;
+    const result = new DataModels.Cronjobs.CronjobList();
+
+    result.cronjobs = mappedCronjobs;
+    result.totalCount = httpResponse.result.totalCount;
+
+    return result;
   }
@@ -482,3 +487,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.Cronjobs.CronjobHistoryEntry>> {
+  ): Promise<DataModels.Cronjobs.CronjobHistoryList> {
 
@@ -496,6 +501,6 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.Cronjobs.CronjobHistoryEntry>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Cronjobs.CronjobHistoryList>(url, requestAuthHeaders);
 
     // We need to restore the datatype of `executedAt`, since that property gets stringified when transported over http.
-    const mappedResult = httpResponse.result.map((entry): DataModels.Cronjobs.CronjobHistoryEntry => {
+    const mappedCronjobHistories = httpResponse.result.cronjobHistories.map((entry): DataModels.Cronjobs.CronjobHistoryEntry => {
       const mappedEntry = entry;
@@ -509,3 +514,8 @@ if (entry.executedAt) {
 
-    return mappedResult;
+    const result = new DataModels.Cronjobs.CronjobHistoryList();
+
+    result.cronjobHistories = mappedCronjobHistories;
+    result.totalCount = httpResponse.result.totalCount;
+
+    return result;
   }
@@ -518,3 +528,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.Cronjobs.CronjobHistoryEntry>> {
+  ): Promise<DataModels.Cronjobs.CronjobHistoryList> {
 
@@ -526,6 +536,6 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.Cronjobs.CronjobHistoryEntry>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Cronjobs.CronjobHistoryList>(url, requestAuthHeaders);
 
     // We need to restore the datatype of `executedAt`, since that property gets stringified when transported over http.
-    const mappedResult = httpResponse.result.map((entry): DataModels.Cronjobs.CronjobHistoryEntry => {
+    const mappedCronjobHistories = httpResponse.result.cronjobHistories.map((entry): DataModels.Cronjobs.CronjobHistoryEntry => {
       const mappedEntry = entry;
@@ -539,3 +549,8 @@ if (entry.executedAt) {
 
-    return mappedResult;
+    const result = new DataModels.Cronjobs.CronjobHistoryList();
+
+    result.cronjobHistories = mappedCronjobHistories;
+    result.totalCount = httpResponse.result.totalCount;
+
+    return result;
   }
@@ -833,3 +848,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.FlowNodeInstances.FlowNodeInstance>> {
+  ): Promise<DataModels.FlowNodeInstances.FlowNodeInstanceList> {
 
@@ -841,3 +856,3 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.FlowNodeInstances.FlowNodeInstance>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.FlowNodeInstances.FlowNodeInstanceList>(url, requestAuthHeaders);
 
@@ -847,91 +862,2 @@ return httpResponse.result;
 
-  // Tasks
-  public async getAllSuspendedTasks(
-    identity: IIdentity,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-
-    const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-
-    const urlRestPath = restSettings.paths.allSuspendedTasks;
-    const url = this.buildUrl(urlRestPath, offset, limit);
-
-    const httpResponse = await this.httpClient.get<DataModels.FlowNodeInstances.TaskList>(url, requestAuthHeaders);
-
-    return httpResponse.result;
-  }
-
-  public async getSuspendedTasksForProcessModel(
-    identity: IIdentity,
-    processModelId: string,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-
-    const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-
-    const urlRestPath = restSettings.paths.suspendedProcessModelTasks.replace(restSettings.params.processModelId, processModelId);
-    const url = this.buildUrl(urlRestPath, offset, limit);
-
-    const httpResponse = await this.httpClient.get<DataModels.FlowNodeInstances.TaskList>(url, requestAuthHeaders);
-
-    return httpResponse.result;
-  }
-
-  public async getSuspendedTasksForProcessInstance(
-    identity: IIdentity,
-    processInstanceId: string,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-
-    const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-
-    const urlRestPath = restSettings.paths.suspendedProcessInstanceTasks.replace(restSettings.params.processInstanceId, processInstanceId);
-    const url = this.buildUrl(urlRestPath, offset, limit);
-
-    const httpResponse = await this.httpClient.get<DataModels.FlowNodeInstances.TaskList>(url, requestAuthHeaders);
-
-    return httpResponse.result;
-  }
-
-  public async getSuspendedTasksForCorrelation(
-    identity: IIdentity,
-    correlationId: string,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-
-    const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-
-    const urlRestPath = restSettings.paths.suspendedCorrelationTasks.replace(restSettings.params.correlationId, correlationId);
-    const url = this.buildUrl(urlRestPath, offset, limit);
-
-    const httpResponse = await this.httpClient.get<DataModels.FlowNodeInstances.TaskList>(url, requestAuthHeaders);
-
-    return httpResponse.result;
-  }
-
-  public async getSuspendedTasksForProcessModelInCorrelation(
-    identity: IIdentity,
-    processModelId: string,
-    correlationId: string,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-
-    const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-
-    const urlRestPath = restSettings.paths.suspendedProcessModelCorrelationTasks
-      .replace(restSettings.params.processModelId, processModelId)
-      .replace(restSettings.params.correlationId, correlationId);
-
-    const url = this.buildUrl(urlRestPath, offset, limit);
-
-    const httpResponse = await this.httpClient.get<DataModels.FlowNodeInstances.TaskList>(url, requestAuthHeaders);
-
-    return httpResponse.result;
-  }
-
   // ManualTasks
@@ -1128,3 +1054,3 @@ public async getManualTasksForProcessModel(
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.FlowNodeRuntimeInformation>> {
+  ): Promise<DataModels.Kpi.FlowNodeRuntimeInformationList> {
 
@@ -1138,3 +1064,3 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.Kpi.FlowNodeRuntimeInformation>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Kpi.FlowNodeRuntimeInformationList>(url, requestAuthHeaders);
 
@@ -1168,3 +1094,3 @@ return httpResponse.result;
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.ActiveToken>> {
+  ): Promise<DataModels.Kpi.ActiveTokenList> {
 
@@ -1178,3 +1104,3 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.Kpi.ActiveToken>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Kpi.ActiveTokenList>(url, requestAuthHeaders);
 
@@ -1190,3 +1116,3 @@ return httpResponse.result;
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.ActiveToken>> {
+  ): Promise<DataModels.Kpi.ActiveTokenList> {
 
@@ -1201,3 +1127,3 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.Kpi.ActiveToken>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Kpi.ActiveTokenList>(url, requestAuthHeaders);
 
@@ -1212,3 +1138,3 @@ return httpResponse.result;
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.ActiveToken>> {
+  ): Promise<DataModels.Kpi.ActiveTokenList> {
 
@@ -1222,3 +1148,3 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.Kpi.ActiveToken>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Kpi.ActiveTokenList>(url, requestAuthHeaders);
 
@@ -1233,3 +1159,3 @@ return httpResponse.result;
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.ActiveToken>> {
+  ): Promise<DataModels.Kpi.ActiveTokenList> {
 
@@ -1243,3 +1169,3 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.Kpi.ActiveToken>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Kpi.ActiveTokenList>(url, requestAuthHeaders);
 
@@ -1255,3 +1181,3 @@ return httpResponse.result;
     limit: number = 0,
-  ): Promise<Array<DataModels.Logging.LogEntry>> {
+  ): Promise<DataModels.Logging.LogEntryList> {
 
@@ -1269,3 +1195,3 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.Logging.LogEntry>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Logging.LogEntryList>(url, requestAuthHeaders);
 
@@ -1281,3 +1207,3 @@ return httpResponse.result;
     limit: number = 0,
-  ): Promise<Array<DataModels.Logging.LogEntry>> {
+  ): Promise<DataModels.Logging.LogEntryList> {
 
@@ -1292,3 +1218,3 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.Logging.LogEntry>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Logging.LogEntryList>(url, requestAuthHeaders);
 
@@ -1305,3 +1231,3 @@ return httpResponse.result;
     limit: number = 0,
-  ): Promise<Array<DataModels.TokenHistory.TokenHistoryEntry>> {
+  ): Promise<DataModels.TokenHistory.TokenHistoryEntryList> {
 
@@ -1317,3 +1243,3 @@ const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const httpResponse = await this.httpClient.get<Array<DataModels.TokenHistory.TokenHistoryEntry>>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.TokenHistory.TokenHistoryEntryList>(url, requestAuthHeaders);
 
@@ -1320,0 +1246,0 @@ return httpResponse.result;

src/accessors/internal_accessor.ts

@@ -328,3 +328,3 @@ import {Subscription} from '@essential-projects/event_aggregator_contracts';
     limit: number = 0,
-  ): Promise<Array<DataModels.Correlations.Correlation>> {
+  ): Promise<DataModels.Correlations.CorrelationList> {
     return this.correlationService.getAllCorrelations(identity, offset, limit);
@@ -337,3 +337,3 @@ }
     limit: number = 0,
-  ): Promise<Array<DataModels.Correlations.Correlation>> {
+  ): Promise<DataModels.Correlations.CorrelationList> {
     return this.correlationService.getActiveCorrelations(identity, offset, limit);
@@ -355,3 +355,3 @@ }
     limit: number = 0,
-  ): Promise<Array<DataModels.Correlations.Correlation>> {
+  ): Promise<DataModels.Correlations.CorrelationList> {
     return this.correlationService.getCorrelationsByProcessModelId(identity, processModelId, offset, limit);
@@ -365,3 +365,3 @@ }
     limit: number = 0,
-  ): Promise<Array<DataModels.Cronjobs.CronjobConfiguration>> {
+  ): Promise<DataModels.Cronjobs.CronjobList> {
     return this.cronjobService.getAllActiveCronjobs(identity, offset, limit);
@@ -376,3 +376,3 @@ }
     limit: number = 0,
-  ): Promise<Array<DataModels.Cronjobs.CronjobHistoryEntry>> {
+  ): Promise<DataModels.Cronjobs.CronjobHistoryList> {
     return this.cronjobService.getCronjobExecutionHistoryForProcessModel(identity, processModelId, startEventId, offset, limit);
@@ -386,3 +386,3 @@ }
     limit: number = 0,
-  ): Promise<Array<DataModels.Cronjobs.CronjobHistoryEntry>> {
+  ): Promise<DataModels.Cronjobs.CronjobHistoryList> {
     return this.cronjobService.getCronjobExecutionHistoryForCrontab(identity, crontab, offset, limit);
@@ -532,53 +532,6 @@ }
     limit: number = 0,
-  ): Promise<Array<DataModels.FlowNodeInstances.FlowNodeInstance>> {
+  ): Promise<DataModels.FlowNodeInstances.FlowNodeInstanceList> {
     return this.flowNodeInstanceService.getFlowNodeInstancesForProcessInstance(identity, processInstanceId, offset, limit);
   }
 
-  // Tasks
-  public async getAllSuspendedTasks(
-    identity: IIdentity,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-    return this.flowNodeInstanceService.getAllSuspendedTasks(identity, offset, limit);
-  }
-
-  public async getSuspendedTasksForProcessModel(
-    identity: IIdentity,
-    processModelId: string,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-    return this.flowNodeInstanceService.getSuspendedTasksForProcessModel(identity, processModelId, offset, limit);
-  }
-
-  public async getSuspendedTasksForProcessInstance(
-    identity: IIdentity,
-    processInstanceId: string,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-    return this.flowNodeInstanceService.getSuspendedTasksForProcessInstance(identity, processInstanceId, offset, limit);
-  }
-
-  public async getSuspendedTasksForCorrelation(
-    identity: IIdentity,
-    correlationId: string,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-    return this.flowNodeInstanceService.getSuspendedTasksForCorrelation(identity, correlationId, offset, limit);
-  }
-
-  public async getSuspendedTasksForProcessModelInCorrelation(
-    identity: IIdentity,
-    processModelId: string,
-    correlationId: string,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-
-    return this.flowNodeInstanceService.getSuspendedTasksForProcessModelInCorrelation(identity, processModelId, correlationId, offset, limit);
-  }
-
   // ManualTasks
@@ -685,3 +638,3 @@ public async getManualTasksForProcessModel(
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.FlowNodeRuntimeInformation>> {
+  ): Promise<DataModels.Kpi.FlowNodeRuntimeInformationList> {
     return this.kpiService.getRuntimeInformationForProcessModel(identity, processModelId, offset, limit);
@@ -703,3 +656,3 @@ }
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.ActiveToken>> {
+  ): Promise<DataModels.Kpi.ActiveTokenList> {
     return this.kpiService.getActiveTokensForProcessModel(identity, processModelId, offset, limit);
@@ -714,3 +667,3 @@ }
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.ActiveToken>> {
+  ): Promise<DataModels.Kpi.ActiveTokenList> {
     return this.kpiService.getActiveTokensForCorrelationAndProcessModel(identity, correlationId, processModelId, offset, limit);
@@ -724,3 +677,3 @@ }
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.ActiveToken>> {
+  ): Promise<DataModels.Kpi.ActiveTokenList> {
     return this.kpiService.getActiveTokensForProcessInstance(identity, processInstanceId, offset, limit);
@@ -734,3 +687,3 @@ }
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.ActiveToken>> {
+  ): Promise<DataModels.Kpi.ActiveTokenList> {
     return this.kpiService.getActiveTokensForFlowNode(identity, flowNodeId, offset, limit);
@@ -745,3 +698,3 @@ }
     limit: number = 0,
-  ): Promise<Array<DataModels.Logging.LogEntry>> {
+  ): Promise<DataModels.Logging.LogEntryList> {
     return this.loggingService.getProcessModelLog(identity, processModelId, correlationId, offset, limit);
@@ -756,3 +709,3 @@ }
     limit: number = 0,
-  ): Promise<Array<DataModels.Logging.LogEntry>> {
+  ): Promise<DataModels.Logging.LogEntryList> {
     return this.loggingService.getProcessInstanceLog(identity, processModelId, processInstanceId, offset, limit);
@@ -768,3 +721,3 @@ }
     limit: number = 0,
-  ): Promise<Array<DataModels.TokenHistory.TokenHistoryEntry>> {
+  ): Promise<DataModels.TokenHistory.TokenHistoryEntryList> {
     return this.tokenHistoryService.getTokensForFlowNode(identity, correlationId, processModelId, flowNodeId, offset, limit);
@@ -771,0 +724,0 @@ }

src/management_api_client.ts

@@ -344,3 +344,3 @@ import {Logger} from 'loggerhythm';
     limit: number = 0,
-  ): Promise<Array<DataModels.Correlations.Correlation>> {
+  ): Promise<DataModels.Correlations.CorrelationList> {
     this.ensureIsAuthorized(identity);
@@ -355,3 +355,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.Correlations.Correlation>> {
+  ): Promise<DataModels.Correlations.CorrelationList> {
     this.ensureIsAuthorized(identity);
@@ -379,3 +379,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.Correlations.Correlation>> {
+  ): Promise<DataModels.Correlations.CorrelationList> {
     this.ensureIsAuthorized(identity);
@@ -391,3 +391,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.Cronjobs.CronjobConfiguration>> {
+  ): Promise<DataModels.Cronjobs.CronjobList> {
     this.ensureIsAuthorized(identity);
@@ -404,3 +404,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.Cronjobs.CronjobHistoryEntry>> {
+  ): Promise<DataModels.Cronjobs.CronjobHistoryList> {
     this.ensureIsAuthorized(identity);
@@ -416,3 +416,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.Cronjobs.CronjobHistoryEntry>> {
+  ): Promise<DataModels.Cronjobs.CronjobHistoryList> {
     this.ensureIsAuthorized(identity);
@@ -610,3 +610,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.FlowNodeInstances.FlowNodeInstance>> {
+  ): Promise<DataModels.FlowNodeInstances.FlowNodeInstanceList> {
     this.ensureIsAuthorized(identity);
@@ -732,57 +732,2 @@
 
-  // Tasks
-  public async getAllSuspendedTasks(
-    identity: IIdentity,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-    this.ensureIsAuthorized(identity);
-
-    return this.managementApiAccessor.getAllSuspendedTasks(identity, offset, limit);
-  }
-
-  public async getSuspendedTasksForProcessModel(
-    identity: IIdentity, processModelId: string,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-    this.ensureIsAuthorized(identity);
-
-    return this.managementApiAccessor.getSuspendedTasksForProcessModel(identity, processModelId, offset, limit);
-  }
-
-  public async getSuspendedTasksForProcessInstance(
-    identity: IIdentity,
-    processInstanceId: string,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-    this.ensureIsAuthorized(identity);
-
-    return this.managementApiAccessor.getSuspendedTasksForProcessInstance(identity, processInstanceId, offset, limit);
-  }
-
-  public async getSuspendedTasksForCorrelation(
-    identity: IIdentity,
-    correlationId: string,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-    this.ensureIsAuthorized(identity);
-
-    return this.managementApiAccessor.getSuspendedTasksForCorrelation(identity, correlationId, offset, limit);
-  }
-
-  public async getSuspendedTasksForProcessModelInCorrelation(
-    identity: IIdentity,
-    processModelId: string,
-    correlationId: string,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.FlowNodeInstances.TaskList> {
-    this.ensureIsAuthorized(identity);
-
-    return this.managementApiAccessor.getSuspendedTasksForProcessModelInCorrelation(identity, processModelId, correlationId, offset, limit);
-  }
-
   // Heatmap related features
@@ -794,3 +739,3 @@ public async getRuntimeInformationForProcessModel(
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.FlowNodeRuntimeInformation>> {
+  ): Promise<DataModels.Kpi.FlowNodeRuntimeInformationList> {
     this.ensureIsAuthorized(identity);
@@ -816,3 +761,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.ActiveToken>> {
+  ): Promise<DataModels.Kpi.ActiveTokenList> {
     this.ensureIsAuthorized(identity);
@@ -829,3 +774,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.ActiveToken>> {
+  ): Promise<DataModels.Kpi.ActiveTokenList> {
     this.ensureIsAuthorized(identity);
@@ -841,3 +786,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.ActiveToken>> {
+  ): Promise<DataModels.Kpi.ActiveTokenList> {
     this.ensureIsAuthorized(identity);
@@ -853,3 +798,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.Kpi.ActiveToken>> {
+  ): Promise<DataModels.Kpi.ActiveTokenList> {
     this.ensureIsAuthorized(identity);
@@ -866,3 +811,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.Logging.LogEntry>> {
+  ): Promise<DataModels.Logging.LogEntryList> {
     this.ensureIsAuthorized(identity);
@@ -879,3 +824,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.Logging.LogEntry>> {
+  ): Promise<DataModels.Logging.LogEntryList> {
     this.ensureIsAuthorized(identity);
@@ -893,3 +838,3 @@
     limit: number = 0,
-  ): Promise<Array<DataModels.TokenHistory.TokenHistoryEntry>> {
+  ): Promise<DataModels.TokenHistory.TokenHistoryEntryList> {
     this.ensureIsAuthorized(identity);
@@ -896,0 +841,0 @@

No alert changes

Worsened metrics

Total package byte prevSize

458828

decreased by-5.36%

Lines of code

5241

decreased by-5.19%

Dependency changes

• + Added@essential-projects/event_aggregator_contracts@4.1.2(transitive)

• + Added@process-engine/management_api_contracts@12.1.0-71b8cf24-b29(transitive)

• + Added@types/node@10.17.60(transitive)

• - Removed@types/node@20.14.2(transitive)

• - Removedundici-types@5.26.5(transitive)

• Updated@process-engine/management_api_contracts@12.1.0-71b8cf24-b29