inteligr8/alfresco-ng2-components
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-ng2-components.git synced 2025-06-30 18:15:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

[ADF-5135] Eventual Consistency Helper for e2e tests. (#5668)

Browse Source 
* [ADF-5135] Eventual Consistency Helper for e2e tests.

* [ADF-5135] Eventual Consistency Helper for e2e tests.
This commit is contained in:
dhrn 2020-05-11 16:08:51 +05:30 committed by GitHub
parent c5b4888126
commit 85457d60d8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 25 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -18,6 +18,7 @@
import { ApiService } from '../api.service'; import { ApiService } from '../api.service';
import { Logger } from '../../utils/logger'; import { Logger } from '../../utils/logger';
import { ApiUtil } from '../../structure/api.util'; import { ApiUtil } from '../../structure/api.util';
export type TaskStatus = 'COMPLETED' | 'CREATED' | 'ASSIGNED' | 'SUSPENDED' | 'CANCELLED' | 'COMPLETED';
export class QueryService { export class QueryService {
@ -90,7 +91,7 @@ export class QueryService {
return ApiUtil.waitForApi(apiCall, predicate); return ApiUtil.waitForApi(apiCall, predicate);
} }
async getTaskByName(taskName, processInstanceId, appName): Promise<any> { async getProcessInstanceTaskByStatus(processInstanceId, appName, taskName, status: TaskStatus): Promise<any> {
const predicate = (result: any) => { const predicate = (result: any) => {
return !!result; return !!result;
}; };
@ -102,6 +103,28 @@ export class QueryService {
const queryParams = {}, postBody = {}; const queryParams = {}, postBody = {};
const data = await this.api.performBpmOperation(path, method, queryParams, postBody);
return data.list && data.list.entries.length && data.list.entries.find(task => task.entry.name === taskName && task.entry.status === status);
} catch (error) {
Logger.error('get process-instances tasks by status - Service error');
}
};
return ApiUtil.waitForApi(apiCall, predicate);
}
async getTaskByStatus(taskName, appName, status: TaskStatus, standalone = false): Promise<any> {
const predicate = (result: any) => {
return !!result;
};
const apiCall = async () => {
try {
const path = `/${appName}/query/v1/tasks?standalone=${standalone}&status=${status}&maxItems=1000&skipCount=0&sort=createdDate`;
const method = 'GET';
const queryParams = {}, postBody = {};
const data = await this.api.performBpmOperation(path, method, queryParams, postBody); const data = await this.api.performBpmOperation(path, method, queryParams, postBody);
for (let i = 0; i < data.list.entries.length; i++) { for (let i = 0; i < data.list.entries.length; i++) {
if (data.list.entries[i].entry.name === taskName) { if (data.list.entries[i].entry.name === taskName) {
@ -110,7 +133,7 @@ export class QueryService {
} }
} catch (error) { } catch (error) {
Logger.error('Get Task By Name - Service error'); Logger.error('Get Task By Status - Service error');
} }
}; };