From 63d59f7ffd7d4c1a2f0e3a93413b5643b477adfc Mon Sep 17 00:00:00 2001 From: Eugenio Romano Date: Wed, 13 May 2020 01:32:09 +0100 Subject: [PATCH] revert used by app method --- .../core/actions/identity/query.service.ts | 30 ++++++++++++++++++- 1 file changed, 29 insertions(+), 1 deletion(-) diff --git a/lib/testing/src/lib/core/actions/identity/query.service.ts b/lib/testing/src/lib/core/actions/identity/query.service.ts index ce89e6ba20..25ce63d7dd 100644 --- a/lib/testing/src/lib/core/actions/identity/query.service.ts +++ b/lib/testing/src/lib/core/actions/identity/query.service.ts @@ -18,7 +18,8 @@ import { ApiService } from '../api.service'; import { Logger } from '../../utils/logger'; import { ApiUtil } from '../../structure/api.util'; -export type TaskStatus = 'COMPLETED' | 'CREATED' | 'ASSIGNED' | 'SUSPENDED' | 'CANCELLED' | 'COMPLETED'; + +export type TaskStatus = 'COMPLETED' | 'CREATED' | 'ASSIGNED' | 'SUSPENDED' | 'CANCELLED' | 'COMPLETED'; export class QueryService { @@ -140,6 +141,33 @@ export class QueryService { return ApiUtil.waitForApi(apiCall, predicate); } + async getTaskByName(taskName, processInstanceId, appName): Promise { + const predicate = (result: any) => { + return !!result; + }; + + const apiCall = async () => { + try { + const path = '/' + appName + '/query/v1/process-instances/' + processInstanceId + '/tasks'; + const method = 'GET'; + + const queryParams = {}, postBody = {}; + + const data = await this.api.performBpmOperation(path, method, queryParams, postBody); + for (let i = 0; i < data.list.entries.length; i++) { + if (data.list.entries[i].entry.name === taskName) { + return data.list.entries[i]; + } + } + + } catch (error) { + Logger.error('Get Task By Name - Service error'); + } + }; + + return ApiUtil.waitForApi(apiCall, predicate); + } + async getProcessInstanceId(processName: string, appName: string): Promise { const predicate = (result: any) => { return !!result;