import { Subscription } from '@essential-projects/event_aggregator_contracts'; import { IHttpClient } from '@essential-projects/http_contracts'; import { IIdentity } from '@essential-projects/iam_contracts'; import { DataModels, IConsumerApiAccessor, IConsumerSocketIoAccessor, Messages } from '@process-engine/consumer_api_contracts'; export declare class ExternalAccessor implements IConsumerApiAccessor, IConsumerSocketIoAccessor { config: any; private baseUrl; private socketCollection; private subscriptionCollection; private httpClient; constructor(httpClient: IHttpClient); initializeSocket(identity: IIdentity): void; disconnectSocket(identity: IIdentity): void; getApplicationInfo(identity: IIdentity): Promise; onActivityReached(identity: IIdentity, callback: Messages.CallbackTypes.OnActivityReachedCallback, subscribeOnce?: boolean): Promise; onActivityFinished(identity: IIdentity, callback: Messages.CallbackTypes.OnActivityFinishedCallback, subscribeOnce?: boolean): Promise; onEmptyActivityWaiting(identity: IIdentity, callback: Messages.CallbackTypes.OnEmptyActivityWaitingCallback, subscribeOnce?: boolean): Promise; onEmptyActivityFinished(identity: IIdentity, callback: Messages.CallbackTypes.OnEmptyActivityFinishedCallback, subscribeOnce?: boolean): Promise; onEmptyActivityForIdentityWaiting(identity: IIdentity, callback: Messages.CallbackTypes.OnEmptyActivityWaitingCallback, subscribeOnce?: boolean): Promise; onEmptyActivityForIdentityFinished(identity: IIdentity, callback: Messages.CallbackTypes.OnEmptyActivityFinishedCallback, subscribeOnce?: boolean): Promise; onUserTaskWaiting(identity: IIdentity, callback: Messages.CallbackTypes.OnUserTaskWaitingCallback, subscribeOnce?: boolean): Promise; onUserTaskFinished(identity: IIdentity, callback: Messages.CallbackTypes.OnUserTaskFinishedCallback, subscribeOnce?: boolean): Promise; onBoundaryEventTriggered(identity: IIdentity, callback: Messages.CallbackTypes.OnBoundaryEventTriggeredCallback, subscribeOnce?: boolean): Promise; onIntermediateThrowEventTriggered(identity: IIdentity, callback: Messages.CallbackTypes.OnIntermediateThrowEventTriggeredCallback, subscribeOnce?: boolean): Promise; onIntermediateCatchEventReached(identity: IIdentity, callback: Messages.CallbackTypes.OnIntermediateCatchEventReachedCallback, subscribeOnce?: boolean): Promise; onIntermediateCatchEventFinished(identity: IIdentity, callback: Messages.CallbackTypes.OnIntermediateCatchEventFinishedCallback, subscribeOnce?: boolean): Promise; onUserTaskForIdentityWaiting(identity: IIdentity, callback: Messages.CallbackTypes.OnUserTaskWaitingCallback, subscribeOnce?: boolean): Promise; onUserTaskForIdentityFinished(identity: IIdentity, callback: Messages.CallbackTypes.OnUserTaskFinishedCallback, subscribeOnce?: boolean): Promise; onProcessTerminated(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessTerminatedCallback, subscribeOnce?: boolean): Promise; onProcessError(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessErrorCallback, subscribeOnce?: boolean): Promise; onProcessStarted(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessStartedCallback, subscribeOnce?: boolean): Promise; onProcessWithProcessModelIdStarted(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessStartedCallback, processModelId: string, subscribeOnce?: boolean): Promise; onManualTaskWaiting(identity: IIdentity, callback: Messages.CallbackTypes.OnManualTaskWaitingCallback, subscribeOnce?: boolean): Promise; onManualTaskFinished(identity: IIdentity, callback: Messages.CallbackTypes.OnManualTaskFinishedCallback, subscribeOnce?: boolean): Promise; onManualTaskForIdentityWaiting(identity: IIdentity, callback: Messages.CallbackTypes.OnManualTaskWaitingCallback, subscribeOnce?: boolean): Promise; onManualTaskForIdentityFinished(identity: IIdentity, callback: Messages.CallbackTypes.OnManualTaskFinishedCallback, subscribeOnce?: boolean): Promise; onProcessEnded(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessEndedCallback, subscribeOnce?: boolean): Promise; removeSubscription(identity: IIdentity, subscription: Subscription): Promise; getProcessModels(identity: IIdentity, offset?: number, limit?: number): Promise; getProcessModelById(identity: IIdentity, processModelId: string): Promise; getProcessModelByProcessInstanceId(identity: IIdentity, processInstanceId: string): Promise; startProcessInstance(identity: IIdentity, processModelId: string, payload?: DataModels.ProcessModels.ProcessStartRequestPayload, startCallbackType?: DataModels.ProcessModels.StartCallbackType, startEventId?: string, endEventId?: string, processEndedCallback?: Messages.CallbackTypes.OnProcessEndedCallback): Promise; private buildStartProcessInstanceUrl; getProcessResultForCorrelation(identity: IIdentity, correlationId: string, processModelId: string): Promise; getProcessInstancesByIdentity(identity: IIdentity, offset?: number, limit?: number): Promise; getEmptyActivitiesForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise; getEmptyActivitiesForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise; getEmptyActivitiesForCorrelation(identity: IIdentity, correlationId: string, offset?: number, limit?: number): Promise; getEmptyActivitiesForProcessModelInCorrelation(identity: IIdentity, processModelId: string, correlationId: string, offset?: number, limit?: number): Promise; getWaitingEmptyActivitiesByIdentity(identity: IIdentity, offset?: number, limit?: number): Promise; finishEmptyActivity(identity: IIdentity, processInstanceId: string, correlationId: string, emptyActivityInstanceId: string): Promise; getEventsForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise; getEventsForCorrelation(identity: IIdentity, correlationId: string, offset?: number, limit?: number): Promise; getEventsForProcessModelInCorrelation(identity: IIdentity, processModelId: string, correlationId: string, offset?: number, limit?: number): Promise; triggerMessageEvent(identity: IIdentity, messageName: string, payload?: DataModels.Events.EventTriggerPayload): Promise; triggerSignalEvent(identity: IIdentity, signalName: string, payload?: DataModels.Events.EventTriggerPayload): Promise; fetchAndLockExternalTasks(identity: IIdentity, workerId: string, topicName: string, maxTasks: number, longPollingTimeout: number, lockDuration: number): Promise>>; extendLock(identity: IIdentity, workerId: string, externalTaskId: string, additionalDuration: number): Promise; handleBpmnError(identity: IIdentity, workerId: string, externalTaskId: string, errorCode: string, errorMessage?: string): Promise; handleServiceError(identity: IIdentity, workerId: string, externalTaskId: string, errorMessage: string, errorDetails: string, errorCode?: string): Promise; finishExternalTask(identity: IIdentity, workerId: string, externalTaskId: string, results: TResultType): Promise; getManualTasksForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise; getManualTasksForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise; getManualTasksForCorrelation(identity: IIdentity, correlationId: string, offset?: number, limit?: number): Promise; getManualTasksForProcessModelInCorrelation(identity: IIdentity, processModelId: string, correlationId: string, offset?: number, limit?: number): Promise; getWaitingManualTasksByIdentity(identity: IIdentity, offset?: number, limit?: number): Promise; finishManualTask(identity: IIdentity, processInstanceId: string, correlationId: string, manualTaskInstanceId: string): Promise; getUserTasksForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise; getUserTasksForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise; getUserTasksForCorrelation(identity: IIdentity, correlationId: string, offset?: number, limit?: number): Promise; getUserTasksForProcessModelInCorrelation(identity: IIdentity, processModelId: string, correlationId: string, offset?: number, limit?: number): Promise; getWaitingUserTasksByIdentity(identity: IIdentity, offset?: number, limit?: number): Promise; finishUserTask(identity: IIdentity, processInstanceId: string, correlationId: string, userTaskInstanceId: string, userTaskResult: DataModels.UserTasks.UserTaskResult): Promise; private createRequestAuthHeaders; private buildUrl; getAllSuspendedTasks(identity: IIdentity, offset?: number, limit?: number): Promise; getSuspendedTasksForProcessModel(identity: IIdentity, processModelId: string, offset?: number, limit?: number): Promise; getSuspendedTasksForProcessInstance(identity: IIdentity, processInstanceId: string, offset?: number, limit?: number): Promise; getSuspendedTasksForCorrelation(identity: IIdentity, correlationId: string, offset?: number, limit?: number): Promise; getSuspendedTasksForProcessModelInCorrelation(identity: IIdentity, processModelId: string, correlationId: string, offset?: number, limit?: number): Promise; private createSocketIoSubscription; private createSocketForIdentity; private removeSocketForIdentity; private getSocketForIdentity; }