inteligr8/alfresco-ng2-components
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-ng2-components.git synced 2025-09-17 14:21:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

[ACA-3863] Update query-service api for E2E (#6032)

Browse Source 
* Get application process instances by status
This commit is contained in:
Roxana Diacenco
2020-08-19 11:37:05 +03:00
committed by GitHub
parent 60673a3818
commit 2d2bdf670b
1 changed files with 27 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
lib/testing/src/lib/core/actions/identity/query.service.ts
View File

@@ -19,7 +19,7 @@ import { ApiService } from '../api.service';
import { Logger } from '../../utils/logger'; import { Logger } from '../../utils/logger';
import { ApiUtil } from '../../actions/api.util'; import { ApiUtil } from '../../actions/api.util';
export type TaskStatus = 'COMPLETED' | 'CREATED' | 'ASSIGNED' | 'SUSPENDED' | 'CANCELLED' | 'COMPLETED'; export type TaskStatus = 'COMPLETED' | 'CREATED' | 'ASSIGNED' | 'SUSPENDED' | 'CANCELLED' | 'RUNNING';
export class QueryService { export class QueryService {
@@ -177,9 +177,7 @@ export class QueryService {
try { try {
const path = '/' + appName + '/query/v1/process-instances'; const path = '/' + appName + '/query/v1/process-instances';
const method = 'GET'; const method = 'GET';
const queryParams = { name: processName }, postBody = {}; const queryParams = { name: processName }, postBody = {};
const data = await this.api.performBpmOperation(path, method, queryParams, postBody); const data = await this.api.performBpmOperation(path, method, queryParams, postBody);
return data.list.entries && data.list.entries.length > 0 ? data.list.entries[0].entry.id : null; return data.list.entries && data.list.entries.length > 0 ? data.list.entries[0].entry.id : null;
} catch (error) { } catch (error) {
@@ -189,4 +187,30 @@ export class QueryService {
return ApiUtil.waitForApi(apiCall, predicate); return ApiUtil.waitForApi(apiCall, predicate);
} }
async getProcessInstances(processName: string, appName: string, status?: TaskStatus): Promise<any> {
const predicate = (result: any) => {
return !!result;
};
const apiCall = async () => {
try {
const path = '/' + appName + '/query/v1/process-instances';
const method = 'GET';
let queryParams;
if (status) {
queryParams = { name: processName, status: status };
} else {
queryParams = { name: processName };
}
const postBody = {};
const data = await this.api.performBpmOperation(path, method, queryParams, postBody);
return data.list.entries ?? null;
} catch (error) {
Logger.error('Get Process Instances - Service error, Response: ', JSON.parse(JSON.stringify(error)).response.text);
}
};
return ApiUtil.waitForApi(apiCall, predicate, 2, 1000);
}
} }