@process-engine/management_api_client - npm Package Compare versions

Comparing version 6.1.0-alpha.10 to 6.1.0-alpha.11

dist/accessors/external_accessor.d.ts

@@ -46,4 +46,7 @@ import { Subscription } from '@essential-projects/event_aggregator_contracts';
     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<DataModels.Correlations.CorrelationList>;
+    getProcessInstanceById(identity: IIdentity, processInstanceId: string): Promise<DataModels.Correlations.ProcessInstance>;
+    getProcessInstancesForCorrelation(identity: IIdentity, correlationId: string, offset?: number, limit?: number): Promise<DataModels.Correlations.ProcessInstanceList>;
+    getProcessInstancesForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Correlations.ProcessInstanceList>;
+    getProcessInstancesByState(identity: IIdentity, state: DataModels.Correlations.CorrelationState, offset?: number, limit?: number): Promise<DataModels.Correlations.ProcessInstanceList>;
     getAllActiveCronjobs(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobList>;
@@ -50,0 +53,0 @@ getCronjobExecutionHistoryForProcessModel(identity: IIdentity, processModelId: string, startEventId?: string, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobHistoryList>;

dist/accessors/internal_accessor.d.ts

@@ -50,4 +50,7 @@ import { Subscription } from '@essential-projects/event_aggregator_contracts';
     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<DataModels.Correlations.CorrelationList>;
+    getProcessInstanceById(identity: IIdentity, processInstanceId: string): Promise<DataModels.Correlations.ProcessInstance>;
+    getProcessInstancesForCorrelation(identity: IIdentity, correlationId: string, offset?: number, limit?: number): Promise<DataModels.Correlations.ProcessInstanceList>;
+    getProcessInstancesForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Correlations.ProcessInstanceList>;
+    getProcessInstancesByState(identity: IIdentity, state: DataModels.Correlations.CorrelationState, offset?: number, limit?: number): Promise<DataModels.Correlations.ProcessInstanceList>;
     getAllActiveCronjobs(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobList>;
@@ -54,0 +57,0 @@ getCronjobExecutionHistoryForProcessModel(identity: IIdentity, processModelId: string, startEventId?: string, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobHistoryList>;

dist/amd/accessors/external_accessor.js

@@ -150,5 +150,13 @@ 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) {
         }
-        async getCorrelationByProcessInstanceId(identity, processInstanceId) {
+        async getCorrelationsByProcessModelId(identity, processModelId, offset = 0, limit = 0) {
             const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-            const restPath = management_api_contracts_1.restSettings.paths.getCorrelationByProcessInstanceId
+            const restPath = management_api_contracts_1.restSettings.paths.getCorrelationsByProcessModelId
+                .replace(management_api_contracts_1.restSettings.params.processModelId, processModelId);
+            const url = this.buildUrl(restPath, offset, limit);
+            const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
+            return httpResponse.result;
+        }
+        async getProcessInstanceById(identity, processInstanceId) {
+            const requestAuthHeaders = this.createRequestAuthHeaders(identity);
+            const restPath = management_api_contracts_1.restSettings.paths.getProcessInstanceById
                 .replace(management_api_contracts_1.restSettings.params.processInstanceId, processInstanceId);
@@ -159,5 +167,13 @@ const url = this.buildUrl(restPath);
         }
-        async getCorrelationsByProcessModelId(identity, processModelId, offset = 0, limit = 0) {
+        async getProcessInstancesForCorrelation(identity, correlationId, offset, limit) {
             const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-            const restPath = management_api_contracts_1.restSettings.paths.getCorrelationsByProcessModelId
+            const restPath = management_api_contracts_1.restSettings.paths.getProcessInstancesForCorrelation
+                .replace(management_api_contracts_1.restSettings.params.correlationId, correlationId);
+            const url = this.buildUrl(restPath, offset, limit);
+            const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
+            return httpResponse.result;
+        }
+        async getProcessInstancesForProcessModel(identity, processModelId, offset, limit) {
+            const requestAuthHeaders = this.createRequestAuthHeaders(identity);
+            const restPath = management_api_contracts_1.restSettings.paths.getProcessInstancesForProcessModel
                 .replace(management_api_contracts_1.restSettings.params.processModelId, processModelId);
@@ -168,2 +184,10 @@ const url = this.buildUrl(restPath, offset, limit);
         }
+        async getProcessInstancesByState(identity, state, offset, limit) {
+            const requestAuthHeaders = this.createRequestAuthHeaders(identity);
+            const restPath = management_api_contracts_1.restSettings.paths.getProcessInstancesByState
+                .replace(management_api_contracts_1.restSettings.params.processInstanceState, state);
+            const url = this.buildUrl(restPath, offset, limit);
+            const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
+            return httpResponse.result;
+        }
         // Cronjobs
@@ -170,0 +194,0 @@ async getAllActiveCronjobs(identity, offset = 0, limit = 0) {

dist/amd/accessors/internal_accessor.js

@@ -117,8 +117,17 @@ define(["require", "exports", "@process-engine/management_api_contracts"], function (require, exports, management_api_contracts_1) {
         }
-        async getCorrelationByProcessInstanceId(identity, processInstanceId) {
-            return this.correlationService.getCorrelationByProcessInstanceId(identity, processInstanceId);
-        }
         async getCorrelationsByProcessModelId(identity, processModelId, offset = 0, limit = 0) {
             return this.correlationService.getCorrelationsByProcessModelId(identity, processModelId, offset, limit);
         }
+        async getProcessInstanceById(identity, processInstanceId) {
+            return this.correlationService.getProcessInstanceById(identity, processInstanceId);
+        }
+        async getProcessInstancesForCorrelation(identity, correlationId, offset, limit) {
+            return this.correlationService.getProcessInstancesForCorrelation(identity, correlationId, offset, limit);
+        }
+        async getProcessInstancesForProcessModel(identity, processModelId, offset, limit) {
+            return this.correlationService.getProcessInstancesForProcessModel(identity, processModelId, offset, limit);
+        }
+        async getProcessInstancesByState(identity, state, offset, limit) {
+            return this.correlationService.getProcessInstancesByState(identity, state, offset, limit);
+        }
         // Cronjobs
@@ -125,0 +134,0 @@ async getAllActiveCronjobs(identity, offset = 0, limit = 0) {

dist/amd/management_api_client.js

@@ -140,5 +140,5 @@ define(["require", "exports", "@essential-projects/errors_ts", "@process-engine/management_api_contracts"], function (require, exports, EssentialProjectErrors, management_api_contracts_1) {
         }
-        async getCorrelationByProcessInstanceId(identity, processInstanceId) {
+        async getProcessInstanceById(identity, processInstanceId) {
             this.ensureIsAuthorized(identity);
-            return this.managementApiAccessor.getCorrelationByProcessInstanceId(identity, processInstanceId);
+            return this.managementApiAccessor.getProcessInstanceById(identity, processInstanceId);
         }
@@ -149,2 +149,14 @@ async getCorrelationsByProcessModelId(identity, processModelId, offset = 0, limit = 0) {
         }
+        async getProcessInstancesForCorrelation(identity, correlationId, offset, limit) {
+            this.ensureIsAuthorized(identity);
+            return this.managementApiAccessor.getProcessInstancesForCorrelation(identity, correlationId, offset, limit);
+        }
+        async getProcessInstancesForProcessModel(identity, processModelId, offset, limit) {
+            this.ensureIsAuthorized(identity);
+            return this.managementApiAccessor.getProcessInstancesForProcessModel(identity, processModelId, offset, limit);
+        }
+        async getProcessInstancesByState(identity, state, offset, limit) {
+            this.ensureIsAuthorized(identity);
+            return this.managementApiAccessor.getProcessInstancesByState(identity, state, offset, limit);
+        }
         // Cronjobs
@@ -151,0 +163,0 @@ async getAllActiveCronjobs(identity, offset = 0, limit = 0) {

dist/commonjs/accessors/external_accessor.js

@@ -157,5 +157,13 @@ "use strict";
     }
-    async getCorrelationByProcessInstanceId(identity, processInstanceId) {
+    async getCorrelationsByProcessModelId(identity, processModelId, offset = 0, limit = 0) {
         const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-        const restPath = management_api_contracts_1.restSettings.paths.getCorrelationByProcessInstanceId
+        const restPath = management_api_contracts_1.restSettings.paths.getCorrelationsByProcessModelId
+            .replace(management_api_contracts_1.restSettings.params.processModelId, processModelId);
+        const url = this.buildUrl(restPath, offset, limit);
+        const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
+        return httpResponse.result;
+    }
+    async getProcessInstanceById(identity, processInstanceId) {
+        const requestAuthHeaders = this.createRequestAuthHeaders(identity);
+        const restPath = management_api_contracts_1.restSettings.paths.getProcessInstanceById
             .replace(management_api_contracts_1.restSettings.params.processInstanceId, processInstanceId);
@@ -166,5 +174,13 @@ const url = this.buildUrl(restPath);
     }
-    async getCorrelationsByProcessModelId(identity, processModelId, offset = 0, limit = 0) {
+    async getProcessInstancesForCorrelation(identity, correlationId, offset, limit) {
         const requestAuthHeaders = this.createRequestAuthHeaders(identity);
-        const restPath = management_api_contracts_1.restSettings.paths.getCorrelationsByProcessModelId
+        const restPath = management_api_contracts_1.restSettings.paths.getProcessInstancesForCorrelation
+            .replace(management_api_contracts_1.restSettings.params.correlationId, correlationId);
+        const url = this.buildUrl(restPath, offset, limit);
+        const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
+        return httpResponse.result;
+    }
+    async getProcessInstancesForProcessModel(identity, processModelId, offset, limit) {
+        const requestAuthHeaders = this.createRequestAuthHeaders(identity);
+        const restPath = management_api_contracts_1.restSettings.paths.getProcessInstancesForProcessModel
             .replace(management_api_contracts_1.restSettings.params.processModelId, processModelId);
@@ -175,2 +191,10 @@ const url = this.buildUrl(restPath, offset, limit);
     }
+    async getProcessInstancesByState(identity, state, offset, limit) {
+        const requestAuthHeaders = this.createRequestAuthHeaders(identity);
+        const restPath = management_api_contracts_1.restSettings.paths.getProcessInstancesByState
+            .replace(management_api_contracts_1.restSettings.params.processInstanceState, state);
+        const url = this.buildUrl(restPath, offset, limit);
+        const httpResponse = await this.httpClient.get(url, requestAuthHeaders);
+        return httpResponse.result;
+    }
     // Cronjobs
@@ -177,0 +201,0 @@ async getAllActiveCronjobs(identity, offset = 0, limit = 0) {

dist/commonjs/accessors/internal_accessor.js

@@ -117,8 +117,17 @@ "use strict";
     }
-    async getCorrelationByProcessInstanceId(identity, processInstanceId) {
-        return this.correlationService.getCorrelationByProcessInstanceId(identity, processInstanceId);
-    }
     async getCorrelationsByProcessModelId(identity, processModelId, offset = 0, limit = 0) {
         return this.correlationService.getCorrelationsByProcessModelId(identity, processModelId, offset, limit);
     }
+    async getProcessInstanceById(identity, processInstanceId) {
+        return this.correlationService.getProcessInstanceById(identity, processInstanceId);
+    }
+    async getProcessInstancesForCorrelation(identity, correlationId, offset, limit) {
+        return this.correlationService.getProcessInstancesForCorrelation(identity, correlationId, offset, limit);
+    }
+    async getProcessInstancesForProcessModel(identity, processModelId, offset, limit) {
+        return this.correlationService.getProcessInstancesForProcessModel(identity, processModelId, offset, limit);
+    }
+    async getProcessInstancesByState(identity, state, offset, limit) {
+        return this.correlationService.getProcessInstancesByState(identity, state, offset, limit);
+    }
     // Cronjobs
@@ -125,0 +134,0 @@ async getAllActiveCronjobs(identity, offset = 0, limit = 0) {

dist/commonjs/management_api_client.js

@@ -141,5 +141,5 @@ "use strict";
     }
-    async getCorrelationByProcessInstanceId(identity, processInstanceId) {
+    async getProcessInstanceById(identity, processInstanceId) {
         this.ensureIsAuthorized(identity);
-        return this.managementApiAccessor.getCorrelationByProcessInstanceId(identity, processInstanceId);
+        return this.managementApiAccessor.getProcessInstanceById(identity, processInstanceId);
     }
@@ -150,2 +150,14 @@ async getCorrelationsByProcessModelId(identity, processModelId, offset = 0, limit = 0) {
     }
+    async getProcessInstancesForCorrelation(identity, correlationId, offset, limit) {
+        this.ensureIsAuthorized(identity);
+        return this.managementApiAccessor.getProcessInstancesForCorrelation(identity, correlationId, offset, limit);
+    }
+    async getProcessInstancesForProcessModel(identity, processModelId, offset, limit) {
+        this.ensureIsAuthorized(identity);
+        return this.managementApiAccessor.getProcessInstancesForProcessModel(identity, processModelId, offset, limit);
+    }
+    async getProcessInstancesByState(identity, state, offset, limit) {
+        this.ensureIsAuthorized(identity);
+        return this.managementApiAccessor.getProcessInstancesByState(identity, state, offset, limit);
+    }
     // Cronjobs
@@ -152,0 +164,0 @@ async getAllActiveCronjobs(identity, offset = 0, limit = 0) {

dist/management_api_client.d.ts

@@ -39,4 +39,7 @@ import { Subscription } from '@essential-projects/event_aggregator_contracts';
     getCorrelationById(identity: IIdentity, correlationId: string): Promise<DataModels.Correlations.Correlation>;
-    getCorrelationByProcessInstanceId(identity: IIdentity, processInstanceId: string): Promise<DataModels.Correlations.Correlation>;
+    getProcessInstanceById(identity: IIdentity, processInstanceId: string): Promise<DataModels.Correlations.ProcessInstance>;
     getCorrelationsByProcessModelId(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Correlations.CorrelationList>;
+    getProcessInstancesForCorrelation(identity: IIdentity, correlationId: string, offset?: number, limit?: number): Promise<DataModels.Correlations.ProcessInstanceList>;
+    getProcessInstancesForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise<DataModels.Correlations.ProcessInstanceList>;
+    getProcessInstancesByState(identity: IIdentity, state: DataModels.Correlations.CorrelationState, offset?: number, limit?: number): Promise<DataModels.Correlations.ProcessInstanceList>;
     getAllActiveCronjobs(identity: IIdentity, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobList>;
@@ -43,0 +46,0 @@ getCronjobExecutionHistoryForProcessModel(identity: IIdentity, processModelId: string, startEventId?: string, offset?: number, limit?: number): Promise<DataModels.Cronjobs.CronjobHistoryList>;

package.json

 {
   "name": "@process-engine/management_api_client",
-  "version": "6.1.0-alpha.10",
+  "version": "6.1.0-alpha.11",
   "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": "13.0.0-alpha.1",
+    "@process-engine/management_api_contracts": "14.0.0-alpha.1",
     "loggerhythm": "^3.0.4",
@@ -37,0 +37,0 @@ "moment": "^2.24.0",

src/accessors/external_accessor.ts

@@ -388,7 +388,26 @@ /* eslint-disable max-lines */
 
-  public async getCorrelationByProcessInstanceId(identity: IIdentity, processInstanceId: string): Promise<DataModels.Correlations.Correlation> {
+  public async getCorrelationsByProcessModelId(
+    identity: IIdentity,
+    processModelId: string,
+    offset: number = 0,
+    limit: number = 0,
+  ): Promise<DataModels.Correlations.CorrelationList> {
 
     const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const restPath = restSettings.paths.getCorrelationByProcessInstanceId
+    const restPath = restSettings.paths.getCorrelationsByProcessModelId
+      .replace(restSettings.params.processModelId, processModelId);
+
+    const url = this.buildUrl(restPath, offset, limit);
+
+    const httpResponse = await this.httpClient.get<DataModels.Correlations.CorrelationList>(url, requestAuthHeaders);
+
+    return httpResponse.result;
+  }
+
+  public async getProcessInstanceById(identity: IIdentity, processInstanceId: string): Promise<DataModels.Correlations.ProcessInstance> {
+
+    const requestAuthHeaders = this.createRequestAuthHeaders(identity);
+
+    const restPath = restSettings.paths.getProcessInstanceById
       .replace(restSettings.params.processInstanceId, processInstanceId);
@@ -398,3 +417,3 @@
 
-    const httpResponse = await this.httpClient.get<DataModels.Correlations.Correlation>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Correlations.ProcessInstance>(url, requestAuthHeaders);
 
@@ -404,12 +423,31 @@ return httpResponse.result;
 
-  public async getCorrelationsByProcessModelId(
+  public async getProcessInstancesForCorrelation(
     identity: IIdentity,
+    correlationId: string,
+    offset?: number,
+    limit?: number,
+  ): Promise<DataModels.Correlations.ProcessInstanceList> {
+
+    const requestAuthHeaders = this.createRequestAuthHeaders(identity);
+
+    const restPath = restSettings.paths.getProcessInstancesForCorrelation
+      .replace(restSettings.params.correlationId, correlationId);
+
+    const url = this.buildUrl(restPath, offset, limit);
+
+    const httpResponse = await this.httpClient.get<DataModels.Correlations.ProcessInstanceList>(url, requestAuthHeaders);
+
+    return httpResponse.result;
+  }
+
+  public async getProcessInstancesForProcessModel(
+    identity: IIdentity,
     processModelId: string,
-    offset: number = 0,
-    limit: number = 0,
-  ): Promise<DataModels.Correlations.CorrelationList> {
+    offset?: number,
+    limit?: number,
+  ): Promise<DataModels.Correlations.ProcessInstanceList> {
 
     const requestAuthHeaders = this.createRequestAuthHeaders(identity);
 
-    const restPath = restSettings.paths.getCorrelationsByProcessModelId
+    const restPath = restSettings.paths.getProcessInstancesForProcessModel
       .replace(restSettings.params.processModelId, processModelId);
@@ -419,3 +457,3 @@
 
-    const httpResponse = await this.httpClient.get<DataModels.Correlations.CorrelationList>(url, requestAuthHeaders);
+    const httpResponse = await this.httpClient.get<DataModels.Correlations.ProcessInstanceList>(url, requestAuthHeaders);
 
@@ -425,2 +463,21 @@ return httpResponse.result;
 
+  public async getProcessInstancesByState(
+    identity: IIdentity,
+    state: DataModels.Correlations.CorrelationState,
+    offset?: number,
+    limit?: number,
+  ): Promise<DataModels.Correlations.ProcessInstanceList> {
+
+    const requestAuthHeaders = this.createRequestAuthHeaders(identity);
+
+    const restPath = restSettings.paths.getProcessInstancesByState
+      .replace(restSettings.params.processInstanceState, state);
+
+    const url = this.buildUrl(restPath, offset, limit);
+
+    const httpResponse = await this.httpClient.get<DataModels.Correlations.ProcessInstanceList>(url, requestAuthHeaders);
+
+    return httpResponse.result;
+  }
+
   // Cronjobs
@@ -427,0 +484,0 @@ public async getAllActiveCronjobs(

src/accessors/internal_accessor.ts

@@ -324,6 +324,2 @@ import {Subscription} from '@essential-projects/event_aggregator_contracts';
 
-  public async getCorrelationByProcessInstanceId(identity: IIdentity, processInstanceId: string): Promise<DataModels.Correlations.Correlation> {
-    return this.correlationService.getCorrelationByProcessInstanceId(identity, processInstanceId);
-  }
-
   public async getCorrelationsByProcessModelId(
@@ -338,2 +334,33 @@ identity: IIdentity,
 
+  public async getProcessInstanceById(identity: IIdentity, processInstanceId: string): Promise<DataModels.Correlations.ProcessInstance> {
+    return this.correlationService.getProcessInstanceById(identity, processInstanceId);
+  }
+
+  public async getProcessInstancesForCorrelation(
+    identity: IIdentity,
+    correlationId: string,
+    offset?: number,
+    limit?: number,
+  ): Promise<DataModels.Correlations.ProcessInstanceList> {
+    return this.correlationService.getProcessInstancesForCorrelation(identity, correlationId, offset, limit);
+  }
+
+  public async getProcessInstancesForProcessModel(
+    identity: IIdentity,
+    processModelId: string,
+    offset?: number,
+    limit?: number,
+  ): Promise<DataModels.Correlations.ProcessInstanceList> {
+    return this.correlationService.getProcessInstancesForProcessModel(identity, processModelId, offset, limit);
+  }
+
+  public async getProcessInstancesByState(
+    identity: IIdentity,
+    state: DataModels.Correlations.CorrelationState,
+    offset?: number,
+    limit?: number,
+  ): Promise<DataModels.Correlations.ProcessInstanceList> {
+    return this.correlationService.getProcessInstancesByState(identity, state, offset, limit);
+  }
+
   // Cronjobs
@@ -340,0 +367,0 @@ public async getAllActiveCronjobs(

src/management_api_client.ts

@@ -334,6 +334,6 @@ import * as EssentialProjectErrors from '@essential-projects/errors_ts';
 
-  public async getCorrelationByProcessInstanceId(identity: IIdentity, processInstanceId: string): Promise<DataModels.Correlations.Correlation> {
+  public async getProcessInstanceById(identity: IIdentity, processInstanceId: string): Promise<DataModels.Correlations.ProcessInstance> {
     this.ensureIsAuthorized(identity);
 
-    return this.managementApiAccessor.getCorrelationByProcessInstanceId(identity, processInstanceId);
+    return this.managementApiAccessor.getProcessInstanceById(identity, processInstanceId);
   }
@@ -352,2 +352,35 @@
 
+  public async getProcessInstancesForCorrelation(
+    identity: IIdentity,
+    correlationId: string,
+    offset?: number,
+    limit?: number,
+  ): Promise<DataModels.Correlations.ProcessInstanceList> {
+    this.ensureIsAuthorized(identity);
+
+    return this.managementApiAccessor.getProcessInstancesForCorrelation(identity, correlationId, offset, limit);
+  }
+
+  public async getProcessInstancesForProcessModel(
+    identity: IIdentity,
+    processModelId: string,
+    offset?: number,
+    limit?: number,
+  ): Promise<DataModels.Correlations.ProcessInstanceList> {
+    this.ensureIsAuthorized(identity);
+
+    return this.managementApiAccessor.getProcessInstancesForProcessModel(identity, processModelId, offset, limit);
+  }
+
+  public async getProcessInstancesByState(
+    identity: IIdentity,
+    state: DataModels.Correlations.CorrelationState,
+    offset?: number,
+    limit?: number,
+  ): Promise<DataModels.Correlations.ProcessInstanceList> {
+    this.ensureIsAuthorized(identity);
+
+    return this.managementApiAccessor.getProcessInstancesByState(identity, state, offset, limit);
+  }
+
   // Cronjobs
@@ -354,0 +387,0 @@ public async getAllActiveCronjobs(

No alert changes

Improved metrics

Total package byte prevSize

498808

increased by3.43%

Lines of code

5670

increased by3.45%

Dependency changes

• + Added@process-engine/management_api_contracts@14.0.0-alpha.1(transitive)

• - Removed@process-engine/management_api_contracts@13.0.0-alpha.1(transitive)

• Updated@process-engine/management_api_contracts@14.0.0-alpha.1