@5minds/processcube_engine_client
Advanced tools
Comparing version 5.1.9-develop-052d41-m6jrj0ty to 5.1.9-feature-56e04d-m6ks0rqu
import { DataModels, IApplicationInfoExtensionAdapter, Subscription } from '@5minds/processcube_engine_sdk'; | ||
import { IdentityLike } from '../IdentityAccessor'; | ||
import { Messages as ClientMessages } from '../Types/index'; | ||
import { OnConnected, OnDisconnected, OnReconnected } from '../Types/NotificationCallbackTypes'; | ||
import { BaseClient } from './BaseClient'; | ||
@@ -8,5 +8,5 @@ export declare class ApplicationInfoHttpClient extends BaseClient implements IApplicationInfoExtensionAdapter { | ||
getAuthorityAddress(): Promise<string>; | ||
onConnected(callback: ClientMessages.CallbackTypes.OnConnected, subscribeOnce?: boolean, identity?: IdentityLike): Subscription; | ||
onDisconnected(callback: ClientMessages.CallbackTypes.OnDisconnected, subscribeOnce?: boolean, identity?: IdentityLike): Subscription; | ||
onReconnected(callback: ClientMessages.CallbackTypes.OnReconnected, subscribeOnce?: boolean, identity?: IdentityLike): Subscription; | ||
onConnected(callback: OnConnected, subscribeOnce?: boolean, identity?: IdentityLike): Subscription; | ||
onDisconnected(callback: OnDisconnected, subscribeOnce?: boolean, identity?: IdentityLike): Subscription; | ||
onReconnected(callback: OnReconnected, subscribeOnce?: boolean, identity?: IdentityLike): Subscription; | ||
} |
import { INotificationExtensionAdapter, Messages, Subscription } from '@5minds/processcube_engine_sdk'; | ||
import { IdentityLike } from '../IdentityAccessor'; | ||
import { Messages as ClientMessages } from '../Types/index'; | ||
import { OnConnected, OnDisconnected, OnReconnected } from '../Types/NotificationCallbackTypes'; | ||
import { BaseClient } from './BaseClient'; | ||
export interface INotificationHttpClient extends INotificationExtensionAdapter { | ||
onConnected(callback: ClientMessages.CallbackTypes.OnConnected, subscribeOnce?: boolean): Subscription; | ||
onDisconnected(callback: ClientMessages.CallbackTypes.OnDisconnected, subscribeOnce?: boolean): Subscription; | ||
onReconnected(callback: ClientMessages.CallbackTypes.OnReconnected, subscribeOnce?: boolean): Subscription; | ||
onConnected(callback: OnConnected, subscribeOnce?: boolean): Subscription; | ||
onDisconnected(callback: OnDisconnected, subscribeOnce?: boolean): Subscription; | ||
onReconnected(callback: OnReconnected, subscribeOnce?: boolean): Subscription; | ||
} | ||
export declare class NotificationHttpClient extends BaseClient implements INotificationHttpClient { | ||
removeSubscription(subscription: Subscription, identity?: IdentityLike): void; | ||
onConnected(callback: ClientMessages.CallbackTypes.OnConnected, subscribeOnce?: boolean, identity?: IdentityLike): Subscription; | ||
onDisconnected(callback: ClientMessages.CallbackTypes.OnDisconnected, subscribeOnce?: boolean, identity?: IdentityLike): Subscription; | ||
onReconnected(callback: ClientMessages.CallbackTypes.OnReconnected, subscribeOnce?: boolean, identity?: IdentityLike): Subscription; | ||
onConnected(callback: OnConnected, subscribeOnce?: boolean, identity?: IdentityLike): Subscription; | ||
onDisconnected(callback: OnDisconnected, subscribeOnce?: boolean, identity?: IdentityLike): Subscription; | ||
onReconnected(callback: OnReconnected, subscribeOnce?: boolean, identity?: IdentityLike): Subscription; | ||
onActivityError(callback: Messages.CallbackTypes.OnActivityErrorCallback, options?: { | ||
@@ -16,0 +16,0 @@ subscribeOnce?: boolean; |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.ApplicationInfoHttpClient = void 0; | ||
const index_1 = require("../Types/index"); | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const BaseClient_1 = require("./BaseClient"); | ||
@@ -9,3 +9,3 @@ class ApplicationInfoHttpClient extends BaseClient_1.BaseClient { | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(); | ||
const url = this.buildUrl(index_1.restSettings.paths.getApplicationInfo); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.getApplicationInfo); | ||
const httpResponse = await this.httpClient.get(url, requestAuthHeaders); | ||
@@ -16,3 +16,3 @@ return httpResponse.result; | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(); | ||
const url = this.buildUrl(index_1.restSettings.paths.getAuthorityAddress); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.getAuthorityAddress); | ||
const httpResponse = await this.httpClient.get(url, requestAuthHeaders); | ||
@@ -19,0 +19,0 @@ return httpResponse.result; |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.BaseClient = void 0; | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const HttpClient_1 = require("../HttpClient"); | ||
const IdentityAccessor_1 = require("../IdentityAccessor"); | ||
const index_1 = require("../Types/index"); | ||
class BaseClient { | ||
@@ -11,3 +11,3 @@ identityAccessor; | ||
socketIoManager; | ||
baseUrl = `${index_1.restSettings.baseRoute}/v1`; | ||
baseUrl = `${processcube_engine_sdk_1.EngineRestApiSettings.baseRoute}/v1`; | ||
engineUrl; | ||
@@ -14,0 +14,0 @@ constructor(engineUrl, identity, socketIoManager) { |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.CorrelationHttpClient = void 0; | ||
const index_1 = require("../Types/index"); | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const BaseClient_1 = require("./BaseClient"); | ||
class CorrelationHttpClient extends BaseClient_1.BaseClient { | ||
async getAll(options) { | ||
let urlRestPart = index_1.restSettings.paths.getCorrelations; | ||
let urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.getCorrelations; | ||
if (options?.includeProcessInstances) { | ||
@@ -18,3 +18,3 @@ urlRestPart = `${urlRestPart}?includeProcessInstances=${options?.includeProcessInstances}`; | ||
async getById(correlationId, options) { | ||
let urlRestPart = index_1.restSettings.paths.getCorrelationById.replace(index_1.restSettings.params.correlationId, correlationId); | ||
let urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.getCorrelationById.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.correlationId, correlationId); | ||
if (options?.includeProcessInstances) { | ||
@@ -21,0 +21,0 @@ urlRestPart = `${urlRestPart}?includeProcessInstances=${options?.includeProcessInstances}`; |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.CronjobHttpClient = void 0; | ||
const index_1 = require("../Types/index"); | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const BaseClient_1 = require("./BaseClient"); | ||
@@ -9,3 +9,3 @@ const Mappers_1 = require("./Lib/Mappers"); | ||
async query(query, options) { | ||
const url = this.buildUrl(index_1.restSettings.paths.getDeployedCronjobs, options?.offset, options?.limit, query, options?.sortSettings); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.queryCronjobs, options?.offset, options?.limit, query, options?.sortSettings); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
@@ -20,3 +20,5 @@ const response = await this.httpClient.get(url, requestAuthHeaders); | ||
async enableCronjob(processModelId, flowNodeId, identity) { | ||
const url = this.buildUrl(index_1.restSettings.paths.enableCronjob).replace(index_1.restSettings.params.processModelId, processModelId).replace(index_1.restSettings.params.flowNodeId, flowNodeId); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.enableCronjob) | ||
.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processModelId, processModelId) | ||
.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.flowNodeId, flowNodeId); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
@@ -26,3 +28,5 @@ await this.httpClient.post(url, undefined, requestAuthHeaders); | ||
async disableCronjob(processModelId, flowNodeId, identity) { | ||
const url = this.buildUrl(index_1.restSettings.paths.disableCronjob).replace(index_1.restSettings.params.processModelId, processModelId).replace(index_1.restSettings.params.flowNodeId, flowNodeId); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.disableCronjob) | ||
.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processModelId, processModelId) | ||
.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.flowNodeId, flowNodeId); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
@@ -29,0 +33,0 @@ await this.httpClient.post(url, undefined, requestAuthHeaders); |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.DataObjectInstanceHttpClient = void 0; | ||
const index_1 = require("../Types/index"); | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const BaseClient_1 = require("./BaseClient"); | ||
@@ -9,3 +9,3 @@ const Mappers_1 = require("./Lib/Mappers"); | ||
async query(query, options) { | ||
const url = this.buildUrl(index_1.restSettings.paths.getDataObjects, options?.offset, options?.limit, query, options?.sortSettings); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.getDataObjects, options?.offset, options?.limit, query, options?.sortSettings); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
@@ -12,0 +12,0 @@ const response = await this.httpClient.get(url, requestAuthHeaders); |
@@ -5,3 +5,2 @@ "use strict"; | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const index_1 = require("../Types/index"); | ||
const BaseClient_1 = require("./BaseClient"); | ||
@@ -15,3 +14,3 @@ const Mappers_1 = require("./Lib/Mappers"); | ||
}; | ||
const url = this.buildUrl(index_1.restSettings.paths.queryFlowNodeInstances, options?.offset, options?.limit, enhancedQuery, options?.sortSettings); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.queryFlowNodeInstances, options?.offset, options?.limit, enhancedQuery, options?.sortSettings); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
@@ -27,3 +26,3 @@ const response = await this.httpClient.get(url, requestAuthHeaders); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
let urlRestPart = index_1.restSettings.paths.triggerMessageEvent.replace(index_1.restSettings.params.eventName, messageName); | ||
let urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.triggerMessageEvent.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.eventName, messageName); | ||
if (options?.processInstanceId) { | ||
@@ -37,3 +36,3 @@ urlRestPart = `${urlRestPart}?process_instance_id=${options?.processInstanceId}`; | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
let urlRestPart = index_1.restSettings.paths.triggerSignalEvent.replace(index_1.restSettings.params.eventName, signalName); | ||
let urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.triggerSignalEvent.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.eventName, signalName); | ||
if (options?.processInstanceId) { | ||
@@ -47,3 +46,3 @@ urlRestPart = `${urlRestPart}?process_instance_id=${options?.processInstanceId}`; | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
let urlRestPart = index_1.restSettings.paths.triggerTimerEvent.replace(index_1.restSettings.params.flowNodeInstanceId, flowNodeInstanceId); | ||
let urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.triggerTimerEvent.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.flowNodeInstanceId, flowNodeInstanceId); | ||
const url = this.buildUrl(urlRestPart); | ||
@@ -53,27 +52,27 @@ await this.httpClient.post(url, undefined, requestAuthHeaders); | ||
async onBoundaryEventTriggered(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.boundaryEventTriggered, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.boundaryEventTriggered, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onBoundaryEventFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.boundaryEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.boundaryEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onIntermediateThrowEventTriggered(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.intermediateThrowEventTriggered, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.intermediateThrowEventTriggered, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onIntermediateCatchEventReached(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.intermediateCatchEventReached, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.intermediateCatchEventReached, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onIntermediateCatchEventFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.intermediateCatchEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.intermediateCatchEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onMessageTriggered(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.messageTriggered, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.messageTriggered, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onSignalTriggered(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.signalTriggered, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.signalTriggered, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onStartEventFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.startEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.startEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onEndEventFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.endEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.endEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
@@ -80,0 +79,0 @@ removeSubscription(subscription, identity) { |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.ExternalTaskApiClient = void 0; | ||
const index_1 = require("../Types/index"); | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const BaseClient_1 = require("./BaseClient"); | ||
@@ -9,3 +9,3 @@ const Mappers_1 = require("./Lib/Mappers"); | ||
async getAllDeployedTopics(identity) { | ||
const url = this.buildUrl(index_1.restSettings.paths.getAllDeployedTopics); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.getAllDeployedTopics); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
@@ -24,3 +24,3 @@ const response = await this.httpClient.get(url, requestAuthHeaders); | ||
}; | ||
const url = this.buildUrl(index_1.restSettings.paths.fetchAndLockExternalTasks); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.fetchAndLockExternalTasks); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
@@ -36,3 +36,3 @@ const response = await this.httpClient.post(url, httpPayload, requestAuthHeaders, abortSignal); | ||
}; | ||
const endpoint = index_1.restSettings.paths.extendExternalTaskLock.replace(index_1.restSettings.params.externalTaskId, externalTaskId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.extendExternalTaskLock.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.externalTaskId, externalTaskId); | ||
const url = this.buildUrl(endpoint); | ||
@@ -47,3 +47,3 @@ const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
}; | ||
const endpoint = index_1.restSettings.paths.finishExternalTaskWithError.replace(index_1.restSettings.params.externalTaskId, externalTaskId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.finishExternalTaskWithError.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.externalTaskId, externalTaskId); | ||
const url = this.buildUrl(endpoint); | ||
@@ -58,3 +58,3 @@ const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
}; | ||
const endpoint = index_1.restSettings.paths.finishExternalTask.replace(index_1.restSettings.params.externalTaskId, externalTaskId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.finishExternalTask.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.externalTaskId, externalTaskId); | ||
const url = this.buildUrl(endpoint); | ||
@@ -61,0 +61,0 @@ const requestAuthHeaders = await this.createRequestAuthHeaders(identity); |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.FlowNodeInstanceHttpClient = void 0; | ||
const index_1 = require("../Types/index"); | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const BaseClient_1 = require("./BaseClient"); | ||
@@ -9,3 +9,3 @@ const Mappers_1 = require("./Lib/Mappers"); | ||
async query(query, options) { | ||
const url = this.buildUrl(index_1.restSettings.paths.queryFlowNodeInstances, options?.offset, options?.limit, query, options?.sortSettings); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.queryFlowNodeInstances, options?.offset, options?.limit, query, options?.sortSettings); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
@@ -21,3 +21,3 @@ const response = await this.httpClient.get(url, requestAuthHeaders); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
const urlRestPart = index_1.restSettings.paths.finishUntypedTask.replace(index_1.restSettings.params.untypedTaskInstanceId, taskInstanceId); | ||
const urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.finishUntypedTask.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.untypedTaskInstanceId, taskInstanceId); | ||
const url = this.buildUrl(urlRestPart); | ||
@@ -28,3 +28,3 @@ await this.httpClient.put(url, {}, requestAuthHeaders); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
const urlRestPart = index_1.restSettings.paths.finishManualTask.replace(index_1.restSettings.params.manualTaskInstanceId, manualTaskInstanceId); | ||
const urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.finishManualTask.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.manualTaskInstanceId, manualTaskInstanceId); | ||
const url = this.buildUrl(urlRestPart); | ||
@@ -35,3 +35,3 @@ await this.httpClient.put(url, {}, requestAuthHeaders); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
const urlRestPart = index_1.restSettings.paths.finishUserTask.replace(index_1.restSettings.params.userTaskInstanceId, userTaskInstanceId); | ||
const urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.finishUserTask.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.userTaskInstanceId, userTaskInstanceId); | ||
const url = this.buildUrl(urlRestPart); | ||
@@ -42,3 +42,3 @@ await this.httpClient.put(url, userTaskResult, requestAuthHeaders); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
let urlRestPart = index_1.restSettings.paths.triggerMessageEvent.replace(index_1.restSettings.params.eventName, messageName); | ||
let urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.triggerMessageEvent.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.eventName, messageName); | ||
if (options?.processInstanceId) { | ||
@@ -52,3 +52,3 @@ urlRestPart = `${urlRestPart}?process_instance_id=${options?.processInstanceId}`; | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
let urlRestPart = index_1.restSettings.paths.triggerSignalEvent.replace(index_1.restSettings.params.eventName, signalName); | ||
let urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.triggerSignalEvent.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.eventName, signalName); | ||
if (options?.processInstanceId) { | ||
@@ -55,0 +55,0 @@ urlRestPart = `${urlRestPart}?process_instance_id=${options?.processInstanceId}`; |
@@ -40,3 +40,2 @@ "use strict"; | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const index_1 = require("../../Types/index"); | ||
class SocketIoManager { | ||
@@ -122,3 +121,3 @@ engineUrl; | ||
const hostPath = indexOfLastSlash === -1 ? this.engineUrl : this.engineUrl.split('://')[0] + '://' + urlWithoutProtocol.substring(0, indexOfLastSlash); | ||
const socketUrl = `${hostPath}/${index_1.socketSettings.namespace}`; | ||
const socketUrl = `${hostPath}/${processcube_engine_sdk_1.EngineSocketIoSettings.namespace}`; | ||
const urlPath = indexOfLastSlash === -1 ? undefined : urlWithoutProtocol.substring(indexOfLastSlash); | ||
@@ -125,0 +124,0 @@ const socket = (0, socket_io_client_1.io)(socketUrl, { |
@@ -5,3 +5,2 @@ "use strict"; | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const index_1 = require("../Types/index"); | ||
const BaseClient_1 = require("./BaseClient"); | ||
@@ -15,3 +14,3 @@ const Mappers_1 = require("./Lib/Mappers"); | ||
}; | ||
const url = this.buildUrl(index_1.restSettings.paths.queryFlowNodeInstances, options?.offset, options?.limit, enhancedQuery, options?.sortSettings); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.queryFlowNodeInstances, options?.offset, options?.limit, enhancedQuery, options?.sortSettings); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
@@ -27,3 +26,3 @@ const response = await this.httpClient.get(url, requestAuthHeaders); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
const urlRestPart = index_1.restSettings.paths.finishManualTask.replace(index_1.restSettings.params.manualTaskInstanceId, manualTaskInstanceId); | ||
const urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.finishManualTask.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.manualTaskInstanceId, manualTaskInstanceId); | ||
const url = this.buildUrl(urlRestPart); | ||
@@ -33,6 +32,6 @@ await this.httpClient.put(url, {}, requestAuthHeaders); | ||
async onManualTaskWaiting(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.manualTaskWaiting, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.manualTaskWaiting, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onManualTaskFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.manualTaskFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.manualTaskFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
@@ -39,0 +38,0 @@ removeSubscription(subscription, identity) { |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.NotificationHttpClient = void 0; | ||
const index_1 = require("../Types/index"); | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const BaseClient_1 = require("./BaseClient"); | ||
@@ -20,138 +20,138 @@ class NotificationHttpClient extends BaseClient_1.BaseClient { | ||
async onActivityError(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.activityError, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.activityError, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onProcessDeployed(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.processDeployed, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.processDeployed, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onProcessUndeployed(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.processUndeployed, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.processUndeployed, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onProcessIsExecutableChanged(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.processExecutableChanged, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.processExecutableChanged, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onCronjobEnabledChanged(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.cronjobEnabledChanged, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.cronjobEnabledChanged, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onProcessStarting(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.processStarting, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.processStarting, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onProcessStarted(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.processStarted, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.processStarted, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onProcessResumed(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.processResumed, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.processResumed, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onProcessEnded(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.processEnded, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.processEnded, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onProcessOwnerChanged(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.processInstanceOwnerChanged, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.processInstanceOwnerChanged, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onProcessTerminated(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.processTerminated, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.processTerminated, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onProcessError(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.processError, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.processError, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onProcessInstancesDeleted(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.processInstancesDeleted, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.processInstancesDeleted, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onCronjobCreated(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.cronjobCreated, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.cronjobCreated, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onCronjobStopped(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.cronjobStopped, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.cronjobStopped, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onCronjobUpdated(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.cronjobUpdated, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.cronjobUpdated, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onCronjobExecuted(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.cronjobExecuted, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.cronjobExecuted, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onCronjobRemoved(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.cronjobRemoved, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.cronjobRemoved, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onActivityReached(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.activityReached, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.activityReached, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onActivityFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.activityFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.activityFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onActivityCanceled(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.activityCanceled, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.activityCanceled, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onUntypedTaskWaiting(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.untypedTaskWaiting, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.untypedTaskWaiting, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onUntypedTaskFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.untypedTaskFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.untypedTaskFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onManualTaskWaiting(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.manualTaskWaiting, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.manualTaskWaiting, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onManualTaskFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.manualTaskFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.manualTaskFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onUserTaskWaiting(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.userTaskWaiting, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.userTaskWaiting, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onUserTaskFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.userTaskFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.userTaskFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onUserTaskReserved(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.userTaskReserved, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.userTaskReserved, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onUserTaskReservationCanceled(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.userTaskReservationCanceled, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.userTaskReservationCanceled, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onBoundaryEventWaiting(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.boundaryEventWaiting, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.boundaryEventWaiting, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onBoundaryEventTriggered(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.boundaryEventTriggered, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.boundaryEventTriggered, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onBoundaryEventFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.boundaryEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.boundaryEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onIntermediateThrowEventTriggered(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.intermediateThrowEventTriggered, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.intermediateThrowEventTriggered, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onIntermediateCatchEventReached(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.intermediateCatchEventReached, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.intermediateCatchEventReached, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onIntermediateCatchEventFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.intermediateCatchEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.intermediateCatchEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onFlowNodeEventRetrySending(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.flowNodeEventRetrySending, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.flowNodeEventRetrySending, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onMessageTriggered(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.messageTriggered, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.messageTriggered, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onSignalTriggered(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.signalTriggered, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.signalTriggered, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onStartEventFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.startEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.startEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onEndEventFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.endEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.endEventFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onExternalTaskCreated(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.externalTaskCreated, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.externalTaskCreated, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onExternalTaskLocked(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.externalTaskLocked, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.externalTaskLocked, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onExternalTaskUnlocked(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.externalTaskUnlocked, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.externalTaskUnlocked, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onProcessInstanceMetadataChanged(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.processInstanceMetadataChanged, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.processInstanceMetadataChanged, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onCorrelationMetadataChanged(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.correlationMetadataChanged, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.correlationMetadataChanged, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onGatewayFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.gatewayFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.gatewayFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
@@ -158,0 +158,0 @@ } |
@@ -5,3 +5,2 @@ "use strict"; | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const index_1 = require("../Types/index"); | ||
const BaseClient_1 = require("./BaseClient"); | ||
@@ -11,3 +10,3 @@ const Mappers_1 = require("./Lib/Mappers"); | ||
async getAll(options) { | ||
const url = this.buildUrl(index_1.restSettings.paths.getProcessDefinitions, options?.offset, options?.limit); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.getProcessDefinitions, options?.offset, options?.limit); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
@@ -22,3 +21,3 @@ const response = await this.httpClient.get(url, requestAuthHeaders); | ||
async getById(processDefinitionId, identity) { | ||
const endpoint = index_1.restSettings.paths.getProcessDefinitionById.replace(index_1.restSettings.params.processDefinitionId, processDefinitionId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.getProcessDefinitionById.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processDefinitionId, processDefinitionId); | ||
const url = this.buildUrl(endpoint); | ||
@@ -31,3 +30,3 @@ const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
async getByProcessModelId(processModelId, identity) { | ||
const endpoint = index_1.restSettings.paths.getProcessDefinitionForProcessModel.replace(index_1.restSettings.params.processModelId, processModelId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.getProcessDefinitionForProcessModel.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processModelId, processModelId); | ||
const url = this.buildUrl(endpoint); | ||
@@ -44,3 +43,3 @@ const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
}; | ||
const url = this.buildUrl(index_1.restSettings.paths.persistProcessDefinitions); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.persistProcessDefinitions); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
@@ -53,3 +52,3 @@ await this.httpClient.post(url, httpPayload, requestAuthHeaders); | ||
async startProcessInstance(options, identity) { | ||
const url = this.buildUrl(index_1.restSettings.paths.startProcessInstance).replace(index_1.restSettings.params.processModelId, options?.processModelId); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.startProcessInstance).replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processModelId, options?.processModelId); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
@@ -64,3 +63,3 @@ const processStartRequest = { | ||
async startProcessInstanceAndAwaitEndEvent(options, identity) { | ||
const url = this.buildUrl(index_1.restSettings.paths.startProcessInstance); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.startProcessInstance); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
@@ -75,3 +74,3 @@ const processStartRequest = { | ||
async startProcessInstanceAndAwaitSpecificEndEvent(options, endEventId, identity) { | ||
const url = this.buildUrl(index_1.restSettings.paths.startProcessInstance); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.startProcessInstance); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
@@ -92,3 +91,3 @@ const processStartRequest = { | ||
async deleteById(processDefinitionId, identity, deleteAllRelatedData = false) { | ||
const endpoint = index_1.restSettings.paths.deleteProcessDefinition.replace(index_1.restSettings.params.processDefinitionId, processDefinitionId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.deleteProcessDefinition.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processDefinitionId, processDefinitionId); | ||
let url = this.buildUrl(endpoint); | ||
@@ -95,0 +94,0 @@ if (deleteAllRelatedData) { |
@@ -5,3 +5,2 @@ "use strict"; | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const index_1 = require("../Types/index"); | ||
const BaseClient_1 = require("./BaseClient"); | ||
@@ -11,3 +10,3 @@ const Mappers_1 = require("./Lib/Mappers"); | ||
async query(query, options) { | ||
let url = this.buildUrl(index_1.restSettings.paths.queryProcessInstances, options?.offset, options?.limit, query, options?.sortSettings); | ||
let url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.queryProcessInstances, options?.offset, options?.limit, query, options?.sortSettings); | ||
url = this.addParameterToUrl(url, 'includeXml', options?.includeXml ?? true); | ||
@@ -23,3 +22,3 @@ const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
async getChildProcessInstanceIds(processInstanceId, options) { | ||
const endpoint = index_1.restSettings.paths.getChildProcessInstanceIds.replace(index_1.restSettings.params.processInstanceId, processInstanceId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.getChildProcessInstanceIds.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processInstanceId, processInstanceId); | ||
const url = this.buildUrl(endpoint, undefined, undefined, { parentFlowNodeType: options.parentFlowNodeType, includeNested: options.includeNested }); | ||
@@ -31,3 +30,3 @@ const requestAuthHeaders = await this.createRequestAuthHeaders(options.identity); | ||
async getAncestorProcessInstanceIds(processInstanceId, options) { | ||
const endpoint = index_1.restSettings.paths.getAncestorProcessInstanceIds.replace(index_1.restSettings.params.processInstanceId, processInstanceId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.getAncestorProcessInstanceIds.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processInstanceId, processInstanceId); | ||
const url = this.buildUrl(endpoint, undefined, undefined, { onlyForEmbeddedProcesses: options.onlyForEmbeddedProcesses }); | ||
@@ -39,3 +38,3 @@ const requestAuthHeaders = await this.createRequestAuthHeaders(options.identity); | ||
async getProcessDefinition(processInstanceId, identity) { | ||
const endpoint = index_1.restSettings.paths.getProcessDefinitionForProcessInstance.replace(index_1.restSettings.params.processInstanceId, processInstanceId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.getProcessDefinitionForProcessInstance.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processInstanceId, processInstanceId); | ||
const url = this.buildUrl(endpoint); | ||
@@ -48,3 +47,3 @@ const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
async getProcessModel(processInstanceId, identity) { | ||
const endpoint = index_1.restSettings.paths.getProcessModelForProcessInstance.replace(index_1.restSettings.params.processInstanceId, processInstanceId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.getProcessModelForProcessInstance.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processInstanceId, processInstanceId); | ||
const url = this.buildUrl(endpoint); | ||
@@ -57,3 +56,3 @@ const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
async transferOwnership(processInstanceId, newOwner, identity) { | ||
const endpoint = index_1.restSettings.paths.changeProcessInstanceOwner.replace(index_1.restSettings.params.processInstanceId, processInstanceId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.changeProcessInstanceOwner.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processInstanceId, processInstanceId); | ||
const url = this.buildUrl(endpoint); | ||
@@ -64,3 +63,3 @@ const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
async terminateProcessInstance(processInstanceId, identity) { | ||
const endpoint = index_1.restSettings.paths.terminateProcessInstances.replace(index_1.restSettings.params.processInstanceId, processInstanceId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.terminateProcessInstances.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processInstanceId, processInstanceId); | ||
const url = this.buildUrl(endpoint); | ||
@@ -76,3 +75,3 @@ const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
async retryProcessInstance(processInstanceId, options) { | ||
const endpoint = index_1.restSettings.paths.retryProcessInstance.replace(index_1.restSettings.params.processInstanceId, processInstanceId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.retryProcessInstance.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processInstanceId, processInstanceId); | ||
let url = this.buildUrl(endpoint); | ||
@@ -95,3 +94,3 @@ if (options?.flowNodeInstanceId) { | ||
const serializedProcessInstanceIds = Array.isArray(processInstanceIds) ? processInstanceIds.join(';') : processInstanceIds; | ||
let url = this.buildUrl(index_1.restSettings.paths.deleteProcessInstances); | ||
let url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.deleteProcessInstances); | ||
url = this.addParameterToUrl(url, 'process_instance_ids', serializedProcessInstanceIds); | ||
@@ -98,0 +97,0 @@ if (deleteAllRelatedData) { |
@@ -5,3 +5,2 @@ "use strict"; | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const index_1 = require("../Types/index"); | ||
const BaseClient_1 = require("./BaseClient"); | ||
@@ -11,3 +10,3 @@ const Mappers_1 = require("./Lib/Mappers"); | ||
async getAll(options) { | ||
const url = this.buildUrl(index_1.restSettings.paths.getAllProcessModels, options?.offset, options?.limit); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.getAllProcessModels, options?.offset, options?.limit); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
@@ -22,3 +21,3 @@ const response = await this.httpClient.get(url, requestAuthHeaders); | ||
async getById(processModelId, identity) { | ||
const endpoint = index_1.restSettings.paths.getProcessModelById.replace(index_1.restSettings.params.processModelId, processModelId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.getProcessModelById.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processModelId, processModelId); | ||
const url = this.buildUrl(endpoint); | ||
@@ -31,3 +30,3 @@ const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
async getByProcessInstanceId(processInstanceId, identity) { | ||
const endpoint = index_1.restSettings.paths.getProcessModelForProcessInstance.replace(index_1.restSettings.params.processInstanceId, processInstanceId); | ||
const endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.getProcessModelForProcessInstance.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processInstanceId, processInstanceId); | ||
const url = this.buildUrl(endpoint); | ||
@@ -40,3 +39,3 @@ const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
async startProcessInstance(options, identity) { | ||
const url = this.buildUrl(index_1.restSettings.paths.startProcessInstance).replace(index_1.restSettings.params.processModelId, options?.processModelId); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.startProcessInstance).replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processModelId, options?.processModelId); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
@@ -51,3 +50,3 @@ const processStartRequest = { | ||
async startProcessInstanceAndAwaitEndEvent(options, identity) { | ||
const url = this.buildUrl(index_1.restSettings.paths.startProcessInstance); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.startProcessInstance); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
@@ -62,3 +61,3 @@ const processStartRequest = { | ||
async startProcessInstanceAndAwaitSpecificEndEvent(options, endEventId, identity) { | ||
const url = this.buildUrl(index_1.restSettings.paths.startProcessInstance); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.startProcessInstance); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
@@ -79,3 +78,3 @@ const processStartRequest = { | ||
async deleteDefinitionByProcessModelId(processModelId, options) { | ||
let endpoint = index_1.restSettings.paths.deleteProcessDefinitionByProcessModelId.replace(index_1.restSettings.params.processModelId, processModelId); | ||
let endpoint = processcube_engine_sdk_1.EngineRestApiSettings.paths.deleteProcessDefinitionByProcessModelId.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processModelId, processModelId); | ||
let url = this.buildUrl(endpoint); | ||
@@ -92,3 +91,3 @@ if (options?.force) { | ||
async enableProcessModel(processModelId, identity) { | ||
const url = this.buildUrl(index_1.restSettings.paths.enableProcessModel).replace(index_1.restSettings.params.processModelId, processModelId); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.enableProcessModel).replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processModelId, processModelId); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
@@ -98,3 +97,3 @@ await this.httpClient.post(url, undefined, requestAuthHeaders); | ||
async disableProcessModel(processModelId, identity) { | ||
const url = this.buildUrl(index_1.restSettings.paths.disableProcessModel).replace(index_1.restSettings.params.processModelId, processModelId); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.disableProcessModel).replace(processcube_engine_sdk_1.EngineRestApiSettings.params.processModelId, processModelId); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
@@ -101,0 +100,0 @@ await this.httpClient.post(url, undefined, requestAuthHeaders); |
@@ -5,3 +5,2 @@ "use strict"; | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const index_1 = require("../Types/index"); | ||
const BaseClient_1 = require("./BaseClient"); | ||
@@ -15,3 +14,3 @@ const Mappers_1 = require("./Lib/Mappers"); | ||
}; | ||
const url = this.buildUrl(index_1.restSettings.paths.queryFlowNodeInstances, options?.offset, options?.limit, enhancedQuery, options?.sortSettings); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.queryFlowNodeInstances, options?.offset, options?.limit, enhancedQuery, options?.sortSettings); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
@@ -27,3 +26,3 @@ const response = await this.httpClient.get(url, requestAuthHeaders); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
const urlRestPart = index_1.restSettings.paths.finishUntypedTask.replace(index_1.restSettings.params.untypedTaskInstanceId, taskInstanceId); | ||
const urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.finishUntypedTask.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.untypedTaskInstanceId, taskInstanceId); | ||
const url = this.buildUrl(urlRestPart); | ||
@@ -33,6 +32,6 @@ await this.httpClient.put(url, {}, requestAuthHeaders); | ||
async onUntypedTaskWaiting(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.untypedTaskWaiting, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.untypedTaskWaiting, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onUntypedTaskFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.untypedTaskFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.untypedTaskFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
@@ -39,0 +38,0 @@ removeSubscription(subscription, identity) { |
@@ -5,3 +5,2 @@ "use strict"; | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const index_1 = require("../Types/index"); | ||
const BaseClient_1 = require("./BaseClient"); | ||
@@ -15,3 +14,3 @@ const Mappers_1 = require("./Lib/Mappers"); | ||
}; | ||
const url = this.buildUrl(index_1.restSettings.paths.queryFlowNodeInstances, options?.offset, options?.limit, enhancedQuery, options?.sortSettings); | ||
const url = this.buildUrl(processcube_engine_sdk_1.EngineRestApiSettings.paths.queryFlowNodeInstances, options?.offset, options?.limit, enhancedQuery, options?.sortSettings); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(options?.identity); | ||
@@ -27,3 +26,3 @@ const response = await this.httpClient.get(url, requestAuthHeaders); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
const urlRestPart = index_1.restSettings.paths.reserveUserTaskInstance.replace(index_1.restSettings.params.userTaskInstanceId, flowNodeInstanceId); | ||
const urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.reserveUserTaskInstance.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.userTaskInstanceId, flowNodeInstanceId); | ||
const url = this.buildUrl(urlRestPart); | ||
@@ -34,3 +33,3 @@ await this.httpClient.put(url, { actualOwnerId: actualOwnerId }, requestAuthHeaders); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
const urlRestPart = index_1.restSettings.paths.cancelUserTaskInstanceReservation.replace(index_1.restSettings.params.userTaskInstanceId, flowNodeInstanceId); | ||
const urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.cancelUserTaskInstanceReservation.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.userTaskInstanceId, flowNodeInstanceId); | ||
const url = this.buildUrl(urlRestPart); | ||
@@ -41,3 +40,3 @@ await this.httpClient.delete(url, requestAuthHeaders); | ||
const requestAuthHeaders = await this.createRequestAuthHeaders(identity); | ||
const urlRestPart = index_1.restSettings.paths.finishUserTask.replace(index_1.restSettings.params.userTaskInstanceId, userTaskInstanceId); | ||
const urlRestPart = processcube_engine_sdk_1.EngineRestApiSettings.paths.finishUserTask.replace(processcube_engine_sdk_1.EngineRestApiSettings.params.userTaskInstanceId, userTaskInstanceId); | ||
const url = this.buildUrl(urlRestPart); | ||
@@ -47,12 +46,12 @@ await this.httpClient.put(url, userTaskResult, requestAuthHeaders); | ||
async onUserTaskWaiting(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.userTaskWaiting, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.userTaskWaiting, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onUserTaskFinished(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.userTaskFinished, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.userTaskFinished, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onUserTaskReserved(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.userTaskReserved, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.userTaskReserved, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
async onUserTaskReservationCanceled(callback, options) { | ||
return this.createSocketIoSubscription(index_1.socketSettings.paths.userTaskReservationCanceled, callback, options?.subscribeOnce, options?.identity); | ||
return this.createSocketIoSubscription(processcube_engine_sdk_1.EngineSocketIoSettings.paths.userTaskReservationCanceled, callback, options?.subscribeOnce, options?.identity); | ||
} | ||
@@ -59,0 +58,0 @@ removeSubscription(subscription, identity) { |
@@ -17,3 +17,3 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.Model = exports.EventType = exports.DataModels = exports.BpmnType = exports.ClientCredentialsIdentityAccessor = exports.IdentityAccessor = void 0; | ||
exports.Model = exports.Messages = exports.EventType = exports.DataModels = exports.BpmnType = exports.ClientCredentialsIdentityAccessor = exports.IdentityAccessor = void 0; | ||
__exportStar(require("./Client"), exports); | ||
@@ -32,3 +32,4 @@ __exportStar(require("./ClientFactory"), exports); | ||
Object.defineProperty(exports, "EventType", { enumerable: true, get: function () { return processcube_engine_sdk_1.EventType; } }); | ||
Object.defineProperty(exports, "Messages", { enumerable: true, get: function () { return processcube_engine_sdk_1.Messages; } }); | ||
Object.defineProperty(exports, "Model", { enumerable: true, get: function () { return processcube_engine_sdk_1.Model; } }); | ||
//# sourceMappingURL=index.js.map |
@@ -13,24 +13,2 @@ "use strict"; | ||
})); | ||
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) { | ||
Object.defineProperty(o, "default", { enumerable: true, value: v }); | ||
}) : function(o, v) { | ||
o["default"] = v; | ||
}); | ||
var __importStar = (this && this.__importStar) || (function () { | ||
var ownKeys = function(o) { | ||
ownKeys = Object.getOwnPropertyNames || function (o) { | ||
var ar = []; | ||
for (var k in o) if (Object.prototype.hasOwnProperty.call(o, k)) ar[ar.length] = k; | ||
return ar; | ||
}; | ||
return ownKeys(o); | ||
}; | ||
return function (mod) { | ||
if (mod && mod.__esModule) return mod; | ||
var result = {}; | ||
if (mod != null) for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]); | ||
__setModuleDefault(result, mod); | ||
return result; | ||
}; | ||
})(); | ||
var __exportStar = (this && this.__exportStar) || function(m, exports) { | ||
@@ -40,15 +18,4 @@ for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p); | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.Messages = void 0; | ||
const processcube_engine_sdk_1 = require("@5minds/processcube_engine_sdk"); | ||
const callbackTypes = __importStar(require("./CallbackTypes")); | ||
// Message Types are exported this way to remain compatible with older client versions. | ||
var Messages; | ||
(function (Messages) { | ||
Messages.BpmnEvents = processcube_engine_sdk_1.Messages.BpmnEvents; | ||
Messages.SystemEvents = processcube_engine_sdk_1.Messages.SystemEvents; | ||
Messages.CallbackTypes = callbackTypes; | ||
})(Messages || (exports.Messages = Messages = {})); | ||
__exportStar(require("./IExternalTaskWorker"), exports); | ||
__exportStar(require("./RestSettings"), exports); | ||
__exportStar(require("./SocketSettings"), exports); | ||
__exportStar(require("./NotificationCallbackTypes"), exports); | ||
//# sourceMappingURL=index.js.map |
@@ -8,2 +8,2 @@ export * from './Client'; | ||
export { ClientCredentialsIdentityAccessor } from './IdentityAccessorClientCredentials'; | ||
export { BpmnType, DataModels, EventType, Identity, Model, EventReceivedCallback, Subscription } from '@5minds/processcube_engine_sdk'; | ||
export { BpmnType, DataModels, EventType, Identity, Messages, Model, EventReceivedCallback, Subscription } from '@5minds/processcube_engine_sdk'; |
@@ -1,15 +0,2 @@ | ||
import { Messages as SDKMessages } from '@5minds/processcube_engine_sdk'; | ||
import * as callbackTypes from './CallbackTypes'; | ||
export declare namespace Messages { | ||
export import EventMessage = SDKMessages.EventMessage; | ||
export import IConstructor = SDKMessages.IConstructor; | ||
export import BpmnEvents = SDKMessages.BpmnEvents; | ||
export import SystemEvents = SDKMessages.SystemEvents; | ||
export import CallbackTypes = callbackTypes; | ||
} | ||
export type OnConnected = callbackTypes.OnConnected; | ||
export type OnDisconnected = callbackTypes.OnDisconnected; | ||
export type OnReconnected = callbackTypes.OnReconnected; | ||
export * from './IExternalTaskWorker'; | ||
export * from './RestSettings'; | ||
export * from './SocketSettings'; | ||
export * from './NotificationCallbackTypes'; |
@@ -7,3 +7,3 @@ { | ||
"name": "@5minds/processcube_engine_client", | ||
"version": "5.1.9-develop-052d41-m6jrj0ty", | ||
"version": "5.1.9-feature-56e04d-m6ks0rqu", | ||
"description": "Contains a typescript based client for accessing the Engine.", | ||
@@ -43,3 +43,3 @@ "main": "dist/commonjs/index.js", | ||
"dependencies": { | ||
"@5minds/processcube_engine_sdk": "6.1.0-alpha.7", | ||
"@5minds/processcube_engine_sdk": "6.1.0-feature-086e86-m6krxsym", | ||
"async-lock": "^1.4.1", | ||
@@ -46,0 +46,0 @@ "bufferutil": "4.0.9", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
280813
100
3397
+ Added@5minds/processcube_engine_sdk@6.1.0-feature-086e86-m6krxsym(transitive)
- Removed@5minds/processcube_engine_sdk@6.1.0-alpha.7(transitive)
Updated@5minds/processcube_engine_sdk@6.1.0-feature-086e86-m6krxsym