@5minds/processcube_engine_client
Advanced tools
Comparing version 4.4.0-feature-84bd3b-lkql4080 to 4.4.0-feature-a4e978-lkv7nuxb
@@ -7,3 +7,3 @@ define(["require", "exports", "../HttpClient", "../Types/index"], function (require, exports, HttpClient_1, index_1) { | ||
constructor(engineUrl, identity, socketIoManager) { | ||
this.baseUrl = `${index_1.restSettings.baseRoute}/v1`; | ||
this.baseUrl = `${index_1.restSettings.baseRoute}`; | ||
const isValidEngineUrl = /^https?:\/\/.*/i; | ||
@@ -10,0 +10,0 @@ if (!isValidEngineUrl.test(engineUrl)) { |
@@ -20,5 +20,7 @@ define(["require", "exports", "@5minds/processcube_engine_sdk", "../Types/index", "./BaseClient", "./Lib/Mappers"], function (require, exports, processcube_engine_sdk_1, index_1, BaseClient_1, Mappers_1) { | ||
} | ||
async triggerMessageEvent(messageName, options) { | ||
async triggerMessageEvent(messageName, processModelIds, options) { | ||
const requestAuthHeaders = this.createRequestAuthHeaders(options === null || options === void 0 ? void 0 : options.identity); | ||
let urlRestPart = index_1.restSettings.paths.triggerMessageEvent.replace(index_1.restSettings.params.eventName, messageName); | ||
const encodedProcessModelIds = processModelIds.map((processModelId) => encodeURIComponent(processModelId)); | ||
urlRestPart = index_1.restSettings.paths.triggerMessageEvent.replace(index_1.restSettings.params.processModelIds, encodedProcessModelIds.join(',')); | ||
if (options === null || options === void 0 ? void 0 : options.processInstanceId) { | ||
@@ -25,0 +27,0 @@ urlRestPart = `${urlRestPart}?process_instance_id=${options === null || options === void 0 ? void 0 : options.processInstanceId}`; |
@@ -34,3 +34,3 @@ define(["require", "exports", "../Types/index", "./BaseClient", "./Lib/Mappers"], function (require, exports, index_1, BaseClient_1, Mappers_1) { | ||
} | ||
async triggerMessageEvent(messageName, options) { | ||
async triggerMessageEvent(messageName, processModelIds, options) { | ||
const requestAuthHeaders = this.createRequestAuthHeaders(options === null || options === void 0 ? void 0 : options.identity); | ||
@@ -37,0 +37,0 @@ let urlRestPart = index_1.restSettings.paths.triggerMessageEvent.replace(index_1.restSettings.params.eventName, messageName); |
@@ -36,2 +36,4 @@ define(["require", "exports"], function (require, exports) { | ||
userMetadataKey: ':user_metadata_key', | ||
// Ids of models to catch message | ||
processModelIds: ':process_model_ids', | ||
}; | ||
@@ -46,3 +48,3 @@ const paths = { | ||
*/ | ||
getApplicationInfo: '/info', | ||
getApplicationInfo: '/v1/info', | ||
/** | ||
@@ -54,3 +56,3 @@ * Gets the address of the authority that the host application uses for claim checks. | ||
*/ | ||
getAuthorityAddress: '/authority', | ||
getAuthorityAddress: '/v1/authority', | ||
// Anonymous Sessions | ||
@@ -63,3 +65,3 @@ /** | ||
*/ | ||
getAnonymousSessionById: `/anonymous_session/session/${params.sessionId}`, | ||
getAnonymousSessionById: `/v1/anonymous_session/session/${params.sessionId}`, | ||
/** | ||
@@ -71,3 +73,3 @@ * Returns all anonymous sessions of the given User ID. | ||
*/ | ||
getAnonymousSessionsByUserId: `/anonymous_session/user/${params.userId}`, | ||
getAnonymousSessionsByUserId: `/v1/anonymous_session/user/${params.userId}`, | ||
/** | ||
@@ -79,3 +81,3 @@ * Creates a new anonymous session and returns its ID. | ||
*/ | ||
createAnonymousSession: '/anonymous_session', | ||
createAnonymousSession: '/v1/v1/anonymous_session', | ||
// Correlations | ||
@@ -89,3 +91,3 @@ /** | ||
*/ | ||
getCorrelations: '/correlations', | ||
getCorrelations: '/v1/v1/correlations', | ||
/** | ||
@@ -98,3 +100,3 @@ * Gets a Correlation by its ID. | ||
*/ | ||
getCorrelationById: `/correlations/${params.correlationId}`, | ||
getCorrelationById: `/v1/correlations/${params.correlationId}`, | ||
// Cronjobs | ||
@@ -108,3 +110,3 @@ /** | ||
*/ | ||
getDeployedCronjobs: '/cronjobs/query', | ||
getDeployedCronjobs: '/v1/v1/cronjobs/query', | ||
/** | ||
@@ -117,3 +119,3 @@ * Gets all active Cronjobs. DEPRECATED - Use "/cronjobs/query" instead | ||
*/ | ||
getActiveCronjobs: '/cronjobs', | ||
getActiveCronjobs: '/v1/v1/cronjobs', | ||
/** | ||
@@ -126,3 +128,3 @@ * Queries a list of cronjob history entries that match the given query. | ||
*/ | ||
getCronjobHistory: '/cronjobs/history', | ||
getCronjobHistory: '/v1/v1/cronjobs/history', | ||
/** | ||
@@ -133,3 +135,3 @@ * Enables the given Cronjob for the given Process Model. | ||
*/ | ||
enableCronjob: `/cronjobs/process_models/${params.processModelId}/flow_node/${params.flowNodeId}/enable`, | ||
enableCronjob: `/v1/cronjobs/process_models/${params.processModelId}/flow_node/${params.flowNodeId}/enable`, | ||
/** | ||
@@ -140,3 +142,3 @@ * Disables the given Cronjob for the given ProcessModel. | ||
*/ | ||
disableCronjob: `/cronjobs/process_models/${params.processModelId}/flow_node/${params.flowNodeId}/disable`, | ||
disableCronjob: `/v1/cronjobs/process_models/${params.processModelId}/flow_node/${params.flowNodeId}/disable`, | ||
// DataObjects | ||
@@ -150,3 +152,3 @@ /** | ||
*/ | ||
getDataObjects: '/data_object_instances/query', | ||
getDataObjects: '/v1/v1/data_object_instances/query', | ||
// FlowNodeInstance | ||
@@ -160,3 +162,3 @@ /** | ||
*/ | ||
queryFlowNodeInstances: '/flow_node_instances', | ||
queryFlowNodeInstances: '/v1/flow_node_instances', | ||
/** | ||
@@ -169,3 +171,3 @@ * Triggers a MessageEvent by its name. | ||
*/ | ||
triggerMessageEvent: `/messages/${params.eventName}/trigger`, | ||
triggerMessageEvent: `v2/messages/${params.eventName}/${params.processModelIds}/trigger`, | ||
/** | ||
@@ -217,3 +219,3 @@ * Triggers a SignalEvent by its name. | ||
*/ | ||
getAllDeployedTopics: '/external_tasks/deployed_topics', | ||
getAllDeployedTopics: '/v1/external_tasks/deployed_topics', | ||
/** | ||
@@ -226,3 +228,3 @@ * Fetches the tasks available for an ExternalTaskWorker and locks them for a defined time. | ||
*/ | ||
fetchAndLockExternalTasks: '/external_tasks/fetch_and_lock', | ||
fetchAndLockExternalTasks: '/v1/external_tasks/fetch_and_lock', | ||
/** | ||
@@ -270,3 +272,3 @@ * Extends the lock duration of an ExternalTask by a given amount of time. | ||
*/ | ||
persistProcessDefinitions: '/process_definitions', | ||
persistProcessDefinitions: '/v1/process_definitions', | ||
/** | ||
@@ -279,3 +281,3 @@ * Gets all ProcessDefinitions the requesting user is allowed to see. | ||
*/ | ||
getProcessDefinitions: '/process_definitions', | ||
getProcessDefinitions: '/v1/process_definitions', | ||
/** | ||
@@ -303,3 +305,3 @@ * Gets a ProcessDefinition by its id. | ||
*/ | ||
getAllProcessModels: '/process_models', | ||
getAllProcessModels: '/v1/process_models', | ||
/** | ||
@@ -355,3 +357,3 @@ * Gets a deployed Process Model by its ID. | ||
*/ | ||
queryProcessInstances: '/process_instances/query', | ||
queryProcessInstances: '/v1/process_instances/query', | ||
/** | ||
@@ -408,3 +410,3 @@ * Gets the ProcessDefinition for a given ProcessInstance. | ||
*/ | ||
queryUserMetadata: '/user_metadata/query', | ||
queryUserMetadata: '/v1/user_metadata/query', | ||
/** | ||
@@ -435,3 +437,3 @@ * Gets a value by the given key | ||
*/ | ||
onCronjobCreated: '/notifications/long_polling/cronjob_created', | ||
onCronjobCreated: '/v1/notifications/long_polling/cronjob_created', | ||
/** | ||
@@ -443,3 +445,3 @@ * Wait for a CronjobExecuted notification and resolves with the notification's content. | ||
*/ | ||
onCronjobExecuted: '/notifications/long_polling/cronjob_executed', | ||
onCronjobExecuted: '/v1/notifications/long_polling/cronjob_executed', | ||
/** | ||
@@ -451,3 +453,3 @@ * Wait for a CronjobStopped notification and resolves with the notification's content. | ||
*/ | ||
onCronjobStopped: '/notifications/long_polling/cronjob_stopped', | ||
onCronjobStopped: '/v1/notifications/long_polling/cronjob_stopped', | ||
/** | ||
@@ -459,3 +461,3 @@ * Wait for a CronjobUpdated notification and resolves with the notification's content. | ||
*/ | ||
onCronjobUpdated: '/notifications/long_polling/cronjob_updated', | ||
onCronjobUpdated: '/v1/notifications/long_polling/cronjob_updated', | ||
/** | ||
@@ -467,3 +469,3 @@ * Wait for a CronjobRemoved notification and resolves with the notification's content. | ||
*/ | ||
onCronjobRemoved: '/notifications/long_polling/cronjob_removed', | ||
onCronjobRemoved: '/v1/notifications/long_polling/cronjob_removed', | ||
/** | ||
@@ -475,3 +477,3 @@ * Wait for a ProcessDeployed notification and resolves with the notification's content. | ||
*/ | ||
onProcessDeployed: '/notifications/long_polling/process_deployed', | ||
onProcessDeployed: '/v1/notifications/long_polling/process_deployed', | ||
/** | ||
@@ -483,3 +485,3 @@ * Wait for a ProcessIsExecutableChanged notification and resolves with the notification's content. | ||
*/ | ||
onProcessIsExecutableChanged: '/notifications/long_polling/process_is_executable_changed', | ||
onProcessIsExecutableChanged: '/v1/notifications/long_polling/process_is_executable_changed', | ||
/** | ||
@@ -491,3 +493,3 @@ * Wait for a CronjobEnabledChanged notification and resolves with the notification's content. | ||
*/ | ||
onCronjobEnabledChanged: '/notifications/long_polling/cronjob_enabled_changed', | ||
onCronjobEnabledChanged: '/v1/notifications/long_polling/cronjob_enabled_changed', | ||
/** | ||
@@ -499,3 +501,3 @@ * Wait for a ProcessUndeployed notification and resolves with the notification's content. | ||
*/ | ||
onProcessUndeployed: '/notifications/long_polling/process_undeployed', | ||
onProcessUndeployed: '/v1/notifications/long_polling/process_undeployed', | ||
/** | ||
@@ -507,3 +509,3 @@ * Wait for a ProcessStarting notification and resolves with the notification's content. | ||
*/ | ||
onProcessStarting: '/notifications/long_polling/process_starting', | ||
onProcessStarting: '/v1/notifications/long_polling/process_starting', | ||
/** | ||
@@ -515,3 +517,3 @@ * Wait for a ProcessStarted notification and resolves with the notification's content. | ||
*/ | ||
onProcessStarted: '/notifications/long_polling/process_started', | ||
onProcessStarted: '/v1/notifications/long_polling/process_started', | ||
/** | ||
@@ -523,3 +525,3 @@ * Wait for a ProcessResumed notification and resolves with the notification's content. | ||
*/ | ||
onProcessResumed: '/notifications/long_polling/process_resumed', | ||
onProcessResumed: '/v1/notifications/long_polling/process_resumed', | ||
/** | ||
@@ -531,3 +533,3 @@ * Wait for a ProcessEnded notification and resolves with the notification's content. | ||
*/ | ||
onProcessEnded: '/notifications/long_polling/process_ended', | ||
onProcessEnded: '/v1/notifications/long_polling/process_ended', | ||
/** | ||
@@ -539,3 +541,3 @@ * Wait for a ProcessOwnerChanged notification and resolves with the notification's content. | ||
*/ | ||
onProcessOwnerChanged: '/notifications/long_polling/process_owner_changed', | ||
onProcessOwnerChanged: '/v1/notifications/long_polling/process_owner_changed', | ||
/** | ||
@@ -547,3 +549,3 @@ * Wait for a ProcessTerminated notification and resolves with the notification's content. | ||
*/ | ||
onProcessTerminated: '/notifications/long_polling/process_terminated', | ||
onProcessTerminated: '/v1/notifications/long_polling/process_terminated', | ||
/** | ||
@@ -555,3 +557,3 @@ * Wait for a ProcessError notification and resolves with the notification's content. | ||
*/ | ||
onProcessError: '/notifications/long_polling/process_error', | ||
onProcessError: '/v1/notifications/long_polling/process_error', | ||
/** | ||
@@ -563,3 +565,3 @@ * Wait for a ProcessInstancesDeleted notification and resolves with the notification's content. | ||
*/ | ||
onProcessInstancesDeleted: '/notifications/long_polling/process_instances_deleted', | ||
onProcessInstancesDeleted: '/v1/notifications/long_polling/process_instances_deleted', | ||
/** | ||
@@ -571,3 +573,3 @@ * Wait for an ExternalTaskCreated notification and resolves with the notification's content. | ||
*/ | ||
onExternalTaskCreated: '/notifications/long_polling/external_task_created', | ||
onExternalTaskCreated: '/v1/notifications/long_polling/external_task_created', | ||
/** | ||
@@ -579,3 +581,3 @@ * Wait for a ExternalTaskLocked notification and resolves with the notification's content. | ||
*/ | ||
onExternalTaskLocked: '/notifications/long_polling/external_task_locked', | ||
onExternalTaskLocked: '/v1/notifications/long_polling/external_task_locked', | ||
/** | ||
@@ -587,3 +589,3 @@ * Wait for a ExternalTaskUnlocked notification and resolves with the notification's content. | ||
*/ | ||
onExternalTaskUnlocked: '/notifications/long_polling/external_task_unlocked', | ||
onExternalTaskUnlocked: '/v1/notifications/long_polling/external_task_unlocked', | ||
/** | ||
@@ -595,3 +597,3 @@ * Wait for a ExternalTaskExpired notification and resolves with the notification's content. | ||
*/ | ||
onExternalTaskExpired: '/notifications/long_polling/external_task_expired', | ||
onExternalTaskExpired: '/v1/notifications/long_polling/external_task_expired', | ||
/** | ||
@@ -603,3 +605,3 @@ * Wait for an ActivityReached notification and resolves with the notification's content. | ||
*/ | ||
onActivityReached: '/notifications/long_polling/activity_reached', | ||
onActivityReached: '/v1/notifications/long_polling/activity_reached', | ||
/** | ||
@@ -611,3 +613,3 @@ * Wait for an ActivityFinished notification and resolves with the notification's content. | ||
*/ | ||
onActivityFinished: '/notifications/long_polling/activity_finished', | ||
onActivityFinished: '/v1/notifications/long_polling/activity_finished', | ||
/** | ||
@@ -619,3 +621,3 @@ * Wait for an EmptyActivityWaiting notification and resolves with the notification's content. | ||
*/ | ||
onEmptyActivityWaiting: '/notifications/long_polling/empty_activity_waiting', | ||
onEmptyActivityWaiting: '/v1/notifications/long_polling/empty_activity_waiting', | ||
/** | ||
@@ -627,3 +629,3 @@ * Wait for an EmptyActivityFinished notification and resolves with the notification's content. | ||
*/ | ||
onEmptyActivityFinished: '/notifications/long_polling/empty_activity_finished', | ||
onEmptyActivityFinished: '/v1/notifications/long_polling/empty_activity_finished', | ||
/** | ||
@@ -635,3 +637,3 @@ * Wait for a ManualTaskWaiting notification and resolves with the notification's content. | ||
*/ | ||
onManualTaskWaiting: '/notifications/long_polling/manual_task_waiting', | ||
onManualTaskWaiting: '/v1/notifications/long_polling/manual_task_waiting', | ||
/** | ||
@@ -643,3 +645,3 @@ * Wait for a ManualTaskFinied notification and resolves with the notification's content. | ||
*/ | ||
onManualTaskFinished: '/notifications/long_polling/manual_task_finished', | ||
onManualTaskFinished: '/v1/notifications/long_polling/manual_task_finished', | ||
/** | ||
@@ -651,3 +653,3 @@ * Wait for a UserTaskWaiting notification and resolves with the notification's content. | ||
*/ | ||
onUserTaskWaiting: '/notifications/long_polling/user_task_waiting', | ||
onUserTaskWaiting: '/v1/notifications/long_polling/user_task_waiting', | ||
/** | ||
@@ -659,3 +661,3 @@ * Wait for a UserTaskFinished notification and resolves with the notification's content. | ||
*/ | ||
onUserTaskFinished: '/notifications/long_polling/user_task_finished', | ||
onUserTaskFinished: '/v1/notifications/long_polling/user_task_finished', | ||
/** | ||
@@ -667,3 +669,3 @@ * Wait for a UserTaskReserved notification and resolves with the notification's content. | ||
*/ | ||
onUserTaskReserved: '/notifications/long_polling/user_task_reserved', | ||
onUserTaskReserved: '/v1/notifications/long_polling/user_task_reserved', | ||
/** | ||
@@ -675,3 +677,3 @@ * Wait for a UserTaskReservationCanceled notification and resolves with the notification's content. | ||
*/ | ||
onUserTaskReservationCanceled: '/notifications/long_polling/user_task_reservation_canceled', | ||
onUserTaskReservationCanceled: '/v1/notifications/long_polling/user_task_reservation_canceled', | ||
/** | ||
@@ -683,3 +685,3 @@ * Wait for a BoundaryEventTriggered notification and resolves with the notification's content. | ||
*/ | ||
onBoundaryEventTriggered: '/notifications/long_polling/boundary_event_triggered', | ||
onBoundaryEventTriggered: '/v1/notifications/long_polling/boundary_event_triggered', | ||
/** | ||
@@ -691,3 +693,3 @@ * Wait for an IntermediateThrowEventTriggered notification and resolves with the notification's content. | ||
*/ | ||
onIntermediateThrowEventTriggered: '/notifications/long_polling/intermediate_throw_event_triggered', | ||
onIntermediateThrowEventTriggered: '/v1/notifications/long_polling/intermediate_throw_event_triggered', | ||
/** | ||
@@ -699,3 +701,3 @@ * Wait for an IntermediateCatchEventReached notification and resolves with the notification's content. | ||
*/ | ||
onIntermediateCatchEventReached: '/notifications/long_polling/intermediate_catch_event_reached', | ||
onIntermediateCatchEventReached: '/v1/notifications/long_polling/intermediate_catch_event_reached', | ||
/** | ||
@@ -708,3 +710,3 @@ * | ||
*/ | ||
onIntermediateCatchEventFinished: '/notifications/long_polling/intermediate_catch_event_finished', | ||
onIntermediateCatchEventFinished: '/v1/notifications/long_polling/intermediate_catch_event_finished', | ||
/** | ||
@@ -717,3 +719,3 @@ * | ||
*/ | ||
onFlowNodeEventRetrySending: '/notifications/long_polling/flow_node_event_retry_sending', | ||
onFlowNodeEventRetrySending: '/v1/notifications/long_polling/flow_node_event_retry_sending', | ||
/** | ||
@@ -725,3 +727,3 @@ * Wait for an MessageTriggered notification and resolves with the notification's content. | ||
*/ | ||
onMessageTriggered: '/notifications/long_polling/message_triggered', | ||
onMessageTriggered: '/v1/notifications/long_polling/message_triggered', | ||
/** | ||
@@ -733,3 +735,3 @@ * Wait for an SignalTriggered notification and resolves with the notification's content. | ||
*/ | ||
onSignalTriggered: '/notifications/long_polling/signal_triggered', | ||
onSignalTriggered: '/v1/notifications/long_polling/signal_triggered', | ||
/** | ||
@@ -741,3 +743,3 @@ * Wait for an EndEventFinished notification and resolves with the notification's content. | ||
*/ | ||
onEndEventFinished: '/notifications/long_polling/end_event_finished', | ||
onEndEventFinished: '/v1/notifications/long_polling/end_event_finished', | ||
/** | ||
@@ -749,3 +751,3 @@ * Wait for an StartEventFinished notification and resolves with the notification's content. | ||
*/ | ||
onStartEventFinished: '/notifications/long_polling/start_event_finished', | ||
onStartEventFinished: '/v1/notifications/long_polling/start_event_finished', | ||
/** | ||
@@ -757,3 +759,3 @@ * Wait for a ProcessInstanceMetadataChanged notification and resolves with the notification's content. | ||
*/ | ||
onProcessInstanceMetadataChanged: '/notifications/long_polling/process_instance_metadata_changed', | ||
onProcessInstanceMetadataChanged: '/v1/notifications/long_polling/process_instance_metadata_changed', | ||
/** | ||
@@ -765,3 +767,3 @@ * Wait for a CorrelationMetadataChanged notification and resolves with the notification's content. | ||
*/ | ||
onCorrelationMetadataChanged: '/notifications/long_polling/correlation_metadata_changed', | ||
onCorrelationMetadataChanged: '/v1/notifications/long_polling/correlation_metadata_changed', | ||
}; | ||
@@ -768,0 +770,0 @@ exports.restSettings = { |
@@ -11,3 +11,3 @@ import { DataModels, IEventExtensionAdapter, Identity, Messages, Subscription } from '@5minds/processcube_engine_sdk'; | ||
}): Promise<EventList>; | ||
triggerMessageEvent<TPayload>(messageName: string, options?: { | ||
triggerMessageEvent<TPayload>(messageName: string, processModelIds: Array<string>, options?: { | ||
processInstanceId?: string; | ||
@@ -14,0 +14,0 @@ payload?: TPayload; |
@@ -13,3 +13,3 @@ import { DataModels, IFlowNodeInstanceExtensionAdapter, Identity } from '@5minds/processcube_engine_sdk'; | ||
finishUserTask(userTaskInstanceId: string, userTaskResult: DataModels.FlowNodeInstances.UserTaskResult, identity?: Identity): Promise<void>; | ||
triggerMessageEvent<TPayload>(messageName: string, options?: { | ||
triggerMessageEvent<TPayload>(messageName: string, processModelIds: Array<string>, options?: { | ||
processInstanceId?: string; | ||
@@ -16,0 +16,0 @@ payload?: TPayload; |
@@ -8,3 +8,3 @@ "use strict"; | ||
constructor(engineUrl, identity, socketIoManager) { | ||
this.baseUrl = `${index_1.restSettings.baseRoute}/v1`; | ||
this.baseUrl = `${index_1.restSettings.baseRoute}`; | ||
const isValidEngineUrl = /^https?:\/\/.*/i; | ||
@@ -11,0 +11,0 @@ if (!isValidEngineUrl.test(engineUrl)) { |
@@ -23,5 +23,7 @@ "use strict"; | ||
} | ||
async triggerMessageEvent(messageName, options) { | ||
async triggerMessageEvent(messageName, processModelIds, options) { | ||
const requestAuthHeaders = this.createRequestAuthHeaders(options === null || options === void 0 ? void 0 : options.identity); | ||
let urlRestPart = index_1.restSettings.paths.triggerMessageEvent.replace(index_1.restSettings.params.eventName, messageName); | ||
const encodedProcessModelIds = processModelIds.map((processModelId) => encodeURIComponent(processModelId)); | ||
urlRestPart = index_1.restSettings.paths.triggerMessageEvent.replace(index_1.restSettings.params.processModelIds, encodedProcessModelIds.join(',')); | ||
if (options === null || options === void 0 ? void 0 : options.processInstanceId) { | ||
@@ -28,0 +30,0 @@ urlRestPart = `${urlRestPart}?process_instance_id=${options === null || options === void 0 ? void 0 : options.processInstanceId}`; |
@@ -36,3 +36,3 @@ "use strict"; | ||
} | ||
async triggerMessageEvent(messageName, options) { | ||
async triggerMessageEvent(messageName, processModelIds, options) { | ||
const requestAuthHeaders = this.createRequestAuthHeaders(options === null || options === void 0 ? void 0 : options.identity); | ||
@@ -39,0 +39,0 @@ let urlRestPart = index_1.restSettings.paths.triggerMessageEvent.replace(index_1.restSettings.params.eventName, messageName); |
@@ -35,2 +35,4 @@ "use strict"; | ||
userMetadataKey: ':user_metadata_key', | ||
// Ids of models to catch message | ||
processModelIds: ':process_model_ids', | ||
}; | ||
@@ -45,3 +47,3 @@ const paths = { | ||
*/ | ||
getApplicationInfo: '/info', | ||
getApplicationInfo: '/v1/info', | ||
/** | ||
@@ -53,3 +55,3 @@ * Gets the address of the authority that the host application uses for claim checks. | ||
*/ | ||
getAuthorityAddress: '/authority', | ||
getAuthorityAddress: '/v1/authority', | ||
// Anonymous Sessions | ||
@@ -62,3 +64,3 @@ /** | ||
*/ | ||
getAnonymousSessionById: `/anonymous_session/session/${params.sessionId}`, | ||
getAnonymousSessionById: `/v1/anonymous_session/session/${params.sessionId}`, | ||
/** | ||
@@ -70,3 +72,3 @@ * Returns all anonymous sessions of the given User ID. | ||
*/ | ||
getAnonymousSessionsByUserId: `/anonymous_session/user/${params.userId}`, | ||
getAnonymousSessionsByUserId: `/v1/anonymous_session/user/${params.userId}`, | ||
/** | ||
@@ -78,3 +80,3 @@ * Creates a new anonymous session and returns its ID. | ||
*/ | ||
createAnonymousSession: '/anonymous_session', | ||
createAnonymousSession: '/v1/v1/anonymous_session', | ||
// Correlations | ||
@@ -88,3 +90,3 @@ /** | ||
*/ | ||
getCorrelations: '/correlations', | ||
getCorrelations: '/v1/v1/correlations', | ||
/** | ||
@@ -97,3 +99,3 @@ * Gets a Correlation by its ID. | ||
*/ | ||
getCorrelationById: `/correlations/${params.correlationId}`, | ||
getCorrelationById: `/v1/correlations/${params.correlationId}`, | ||
// Cronjobs | ||
@@ -107,3 +109,3 @@ /** | ||
*/ | ||
getDeployedCronjobs: '/cronjobs/query', | ||
getDeployedCronjobs: '/v1/v1/cronjobs/query', | ||
/** | ||
@@ -116,3 +118,3 @@ * Gets all active Cronjobs. DEPRECATED - Use "/cronjobs/query" instead | ||
*/ | ||
getActiveCronjobs: '/cronjobs', | ||
getActiveCronjobs: '/v1/v1/cronjobs', | ||
/** | ||
@@ -125,3 +127,3 @@ * Queries a list of cronjob history entries that match the given query. | ||
*/ | ||
getCronjobHistory: '/cronjobs/history', | ||
getCronjobHistory: '/v1/v1/cronjobs/history', | ||
/** | ||
@@ -132,3 +134,3 @@ * Enables the given Cronjob for the given Process Model. | ||
*/ | ||
enableCronjob: `/cronjobs/process_models/${params.processModelId}/flow_node/${params.flowNodeId}/enable`, | ||
enableCronjob: `/v1/cronjobs/process_models/${params.processModelId}/flow_node/${params.flowNodeId}/enable`, | ||
/** | ||
@@ -139,3 +141,3 @@ * Disables the given Cronjob for the given ProcessModel. | ||
*/ | ||
disableCronjob: `/cronjobs/process_models/${params.processModelId}/flow_node/${params.flowNodeId}/disable`, | ||
disableCronjob: `/v1/cronjobs/process_models/${params.processModelId}/flow_node/${params.flowNodeId}/disable`, | ||
// DataObjects | ||
@@ -149,3 +151,3 @@ /** | ||
*/ | ||
getDataObjects: '/data_object_instances/query', | ||
getDataObjects: '/v1/v1/data_object_instances/query', | ||
// FlowNodeInstance | ||
@@ -159,3 +161,3 @@ /** | ||
*/ | ||
queryFlowNodeInstances: '/flow_node_instances', | ||
queryFlowNodeInstances: '/v1/flow_node_instances', | ||
/** | ||
@@ -168,3 +170,3 @@ * Triggers a MessageEvent by its name. | ||
*/ | ||
triggerMessageEvent: `/messages/${params.eventName}/trigger`, | ||
triggerMessageEvent: `v2/messages/${params.eventName}/${params.processModelIds}/trigger`, | ||
/** | ||
@@ -216,3 +218,3 @@ * Triggers a SignalEvent by its name. | ||
*/ | ||
getAllDeployedTopics: '/external_tasks/deployed_topics', | ||
getAllDeployedTopics: '/v1/external_tasks/deployed_topics', | ||
/** | ||
@@ -225,3 +227,3 @@ * Fetches the tasks available for an ExternalTaskWorker and locks them for a defined time. | ||
*/ | ||
fetchAndLockExternalTasks: '/external_tasks/fetch_and_lock', | ||
fetchAndLockExternalTasks: '/v1/external_tasks/fetch_and_lock', | ||
/** | ||
@@ -269,3 +271,3 @@ * Extends the lock duration of an ExternalTask by a given amount of time. | ||
*/ | ||
persistProcessDefinitions: '/process_definitions', | ||
persistProcessDefinitions: '/v1/process_definitions', | ||
/** | ||
@@ -278,3 +280,3 @@ * Gets all ProcessDefinitions the requesting user is allowed to see. | ||
*/ | ||
getProcessDefinitions: '/process_definitions', | ||
getProcessDefinitions: '/v1/process_definitions', | ||
/** | ||
@@ -302,3 +304,3 @@ * Gets a ProcessDefinition by its id. | ||
*/ | ||
getAllProcessModels: '/process_models', | ||
getAllProcessModels: '/v1/process_models', | ||
/** | ||
@@ -354,3 +356,3 @@ * Gets a deployed Process Model by its ID. | ||
*/ | ||
queryProcessInstances: '/process_instances/query', | ||
queryProcessInstances: '/v1/process_instances/query', | ||
/** | ||
@@ -407,3 +409,3 @@ * Gets the ProcessDefinition for a given ProcessInstance. | ||
*/ | ||
queryUserMetadata: '/user_metadata/query', | ||
queryUserMetadata: '/v1/user_metadata/query', | ||
/** | ||
@@ -434,3 +436,3 @@ * Gets a value by the given key | ||
*/ | ||
onCronjobCreated: '/notifications/long_polling/cronjob_created', | ||
onCronjobCreated: '/v1/notifications/long_polling/cronjob_created', | ||
/** | ||
@@ -442,3 +444,3 @@ * Wait for a CronjobExecuted notification and resolves with the notification's content. | ||
*/ | ||
onCronjobExecuted: '/notifications/long_polling/cronjob_executed', | ||
onCronjobExecuted: '/v1/notifications/long_polling/cronjob_executed', | ||
/** | ||
@@ -450,3 +452,3 @@ * Wait for a CronjobStopped notification and resolves with the notification's content. | ||
*/ | ||
onCronjobStopped: '/notifications/long_polling/cronjob_stopped', | ||
onCronjobStopped: '/v1/notifications/long_polling/cronjob_stopped', | ||
/** | ||
@@ -458,3 +460,3 @@ * Wait for a CronjobUpdated notification and resolves with the notification's content. | ||
*/ | ||
onCronjobUpdated: '/notifications/long_polling/cronjob_updated', | ||
onCronjobUpdated: '/v1/notifications/long_polling/cronjob_updated', | ||
/** | ||
@@ -466,3 +468,3 @@ * Wait for a CronjobRemoved notification and resolves with the notification's content. | ||
*/ | ||
onCronjobRemoved: '/notifications/long_polling/cronjob_removed', | ||
onCronjobRemoved: '/v1/notifications/long_polling/cronjob_removed', | ||
/** | ||
@@ -474,3 +476,3 @@ * Wait for a ProcessDeployed notification and resolves with the notification's content. | ||
*/ | ||
onProcessDeployed: '/notifications/long_polling/process_deployed', | ||
onProcessDeployed: '/v1/notifications/long_polling/process_deployed', | ||
/** | ||
@@ -482,3 +484,3 @@ * Wait for a ProcessIsExecutableChanged notification and resolves with the notification's content. | ||
*/ | ||
onProcessIsExecutableChanged: '/notifications/long_polling/process_is_executable_changed', | ||
onProcessIsExecutableChanged: '/v1/notifications/long_polling/process_is_executable_changed', | ||
/** | ||
@@ -490,3 +492,3 @@ * Wait for a CronjobEnabledChanged notification and resolves with the notification's content. | ||
*/ | ||
onCronjobEnabledChanged: '/notifications/long_polling/cronjob_enabled_changed', | ||
onCronjobEnabledChanged: '/v1/notifications/long_polling/cronjob_enabled_changed', | ||
/** | ||
@@ -498,3 +500,3 @@ * Wait for a ProcessUndeployed notification and resolves with the notification's content. | ||
*/ | ||
onProcessUndeployed: '/notifications/long_polling/process_undeployed', | ||
onProcessUndeployed: '/v1/notifications/long_polling/process_undeployed', | ||
/** | ||
@@ -506,3 +508,3 @@ * Wait for a ProcessStarting notification and resolves with the notification's content. | ||
*/ | ||
onProcessStarting: '/notifications/long_polling/process_starting', | ||
onProcessStarting: '/v1/notifications/long_polling/process_starting', | ||
/** | ||
@@ -514,3 +516,3 @@ * Wait for a ProcessStarted notification and resolves with the notification's content. | ||
*/ | ||
onProcessStarted: '/notifications/long_polling/process_started', | ||
onProcessStarted: '/v1/notifications/long_polling/process_started', | ||
/** | ||
@@ -522,3 +524,3 @@ * Wait for a ProcessResumed notification and resolves with the notification's content. | ||
*/ | ||
onProcessResumed: '/notifications/long_polling/process_resumed', | ||
onProcessResumed: '/v1/notifications/long_polling/process_resumed', | ||
/** | ||
@@ -530,3 +532,3 @@ * Wait for a ProcessEnded notification and resolves with the notification's content. | ||
*/ | ||
onProcessEnded: '/notifications/long_polling/process_ended', | ||
onProcessEnded: '/v1/notifications/long_polling/process_ended', | ||
/** | ||
@@ -538,3 +540,3 @@ * Wait for a ProcessOwnerChanged notification and resolves with the notification's content. | ||
*/ | ||
onProcessOwnerChanged: '/notifications/long_polling/process_owner_changed', | ||
onProcessOwnerChanged: '/v1/notifications/long_polling/process_owner_changed', | ||
/** | ||
@@ -546,3 +548,3 @@ * Wait for a ProcessTerminated notification and resolves with the notification's content. | ||
*/ | ||
onProcessTerminated: '/notifications/long_polling/process_terminated', | ||
onProcessTerminated: '/v1/notifications/long_polling/process_terminated', | ||
/** | ||
@@ -554,3 +556,3 @@ * Wait for a ProcessError notification and resolves with the notification's content. | ||
*/ | ||
onProcessError: '/notifications/long_polling/process_error', | ||
onProcessError: '/v1/notifications/long_polling/process_error', | ||
/** | ||
@@ -562,3 +564,3 @@ * Wait for a ProcessInstancesDeleted notification and resolves with the notification's content. | ||
*/ | ||
onProcessInstancesDeleted: '/notifications/long_polling/process_instances_deleted', | ||
onProcessInstancesDeleted: '/v1/notifications/long_polling/process_instances_deleted', | ||
/** | ||
@@ -570,3 +572,3 @@ * Wait for an ExternalTaskCreated notification and resolves with the notification's content. | ||
*/ | ||
onExternalTaskCreated: '/notifications/long_polling/external_task_created', | ||
onExternalTaskCreated: '/v1/notifications/long_polling/external_task_created', | ||
/** | ||
@@ -578,3 +580,3 @@ * Wait for a ExternalTaskLocked notification and resolves with the notification's content. | ||
*/ | ||
onExternalTaskLocked: '/notifications/long_polling/external_task_locked', | ||
onExternalTaskLocked: '/v1/notifications/long_polling/external_task_locked', | ||
/** | ||
@@ -586,3 +588,3 @@ * Wait for a ExternalTaskUnlocked notification and resolves with the notification's content. | ||
*/ | ||
onExternalTaskUnlocked: '/notifications/long_polling/external_task_unlocked', | ||
onExternalTaskUnlocked: '/v1/notifications/long_polling/external_task_unlocked', | ||
/** | ||
@@ -594,3 +596,3 @@ * Wait for a ExternalTaskExpired notification and resolves with the notification's content. | ||
*/ | ||
onExternalTaskExpired: '/notifications/long_polling/external_task_expired', | ||
onExternalTaskExpired: '/v1/notifications/long_polling/external_task_expired', | ||
/** | ||
@@ -602,3 +604,3 @@ * Wait for an ActivityReached notification and resolves with the notification's content. | ||
*/ | ||
onActivityReached: '/notifications/long_polling/activity_reached', | ||
onActivityReached: '/v1/notifications/long_polling/activity_reached', | ||
/** | ||
@@ -610,3 +612,3 @@ * Wait for an ActivityFinished notification and resolves with the notification's content. | ||
*/ | ||
onActivityFinished: '/notifications/long_polling/activity_finished', | ||
onActivityFinished: '/v1/notifications/long_polling/activity_finished', | ||
/** | ||
@@ -618,3 +620,3 @@ * Wait for an EmptyActivityWaiting notification and resolves with the notification's content. | ||
*/ | ||
onEmptyActivityWaiting: '/notifications/long_polling/empty_activity_waiting', | ||
onEmptyActivityWaiting: '/v1/notifications/long_polling/empty_activity_waiting', | ||
/** | ||
@@ -626,3 +628,3 @@ * Wait for an EmptyActivityFinished notification and resolves with the notification's content. | ||
*/ | ||
onEmptyActivityFinished: '/notifications/long_polling/empty_activity_finished', | ||
onEmptyActivityFinished: '/v1/notifications/long_polling/empty_activity_finished', | ||
/** | ||
@@ -634,3 +636,3 @@ * Wait for a ManualTaskWaiting notification and resolves with the notification's content. | ||
*/ | ||
onManualTaskWaiting: '/notifications/long_polling/manual_task_waiting', | ||
onManualTaskWaiting: '/v1/notifications/long_polling/manual_task_waiting', | ||
/** | ||
@@ -642,3 +644,3 @@ * Wait for a ManualTaskFinied notification and resolves with the notification's content. | ||
*/ | ||
onManualTaskFinished: '/notifications/long_polling/manual_task_finished', | ||
onManualTaskFinished: '/v1/notifications/long_polling/manual_task_finished', | ||
/** | ||
@@ -650,3 +652,3 @@ * Wait for a UserTaskWaiting notification and resolves with the notification's content. | ||
*/ | ||
onUserTaskWaiting: '/notifications/long_polling/user_task_waiting', | ||
onUserTaskWaiting: '/v1/notifications/long_polling/user_task_waiting', | ||
/** | ||
@@ -658,3 +660,3 @@ * Wait for a UserTaskFinished notification and resolves with the notification's content. | ||
*/ | ||
onUserTaskFinished: '/notifications/long_polling/user_task_finished', | ||
onUserTaskFinished: '/v1/notifications/long_polling/user_task_finished', | ||
/** | ||
@@ -666,3 +668,3 @@ * Wait for a UserTaskReserved notification and resolves with the notification's content. | ||
*/ | ||
onUserTaskReserved: '/notifications/long_polling/user_task_reserved', | ||
onUserTaskReserved: '/v1/notifications/long_polling/user_task_reserved', | ||
/** | ||
@@ -674,3 +676,3 @@ * Wait for a UserTaskReservationCanceled notification and resolves with the notification's content. | ||
*/ | ||
onUserTaskReservationCanceled: '/notifications/long_polling/user_task_reservation_canceled', | ||
onUserTaskReservationCanceled: '/v1/notifications/long_polling/user_task_reservation_canceled', | ||
/** | ||
@@ -682,3 +684,3 @@ * Wait for a BoundaryEventTriggered notification and resolves with the notification's content. | ||
*/ | ||
onBoundaryEventTriggered: '/notifications/long_polling/boundary_event_triggered', | ||
onBoundaryEventTriggered: '/v1/notifications/long_polling/boundary_event_triggered', | ||
/** | ||
@@ -690,3 +692,3 @@ * Wait for an IntermediateThrowEventTriggered notification and resolves with the notification's content. | ||
*/ | ||
onIntermediateThrowEventTriggered: '/notifications/long_polling/intermediate_throw_event_triggered', | ||
onIntermediateThrowEventTriggered: '/v1/notifications/long_polling/intermediate_throw_event_triggered', | ||
/** | ||
@@ -698,3 +700,3 @@ * Wait for an IntermediateCatchEventReached notification and resolves with the notification's content. | ||
*/ | ||
onIntermediateCatchEventReached: '/notifications/long_polling/intermediate_catch_event_reached', | ||
onIntermediateCatchEventReached: '/v1/notifications/long_polling/intermediate_catch_event_reached', | ||
/** | ||
@@ -707,3 +709,3 @@ * | ||
*/ | ||
onIntermediateCatchEventFinished: '/notifications/long_polling/intermediate_catch_event_finished', | ||
onIntermediateCatchEventFinished: '/v1/notifications/long_polling/intermediate_catch_event_finished', | ||
/** | ||
@@ -716,3 +718,3 @@ * | ||
*/ | ||
onFlowNodeEventRetrySending: '/notifications/long_polling/flow_node_event_retry_sending', | ||
onFlowNodeEventRetrySending: '/v1/notifications/long_polling/flow_node_event_retry_sending', | ||
/** | ||
@@ -724,3 +726,3 @@ * Wait for an MessageTriggered notification and resolves with the notification's content. | ||
*/ | ||
onMessageTriggered: '/notifications/long_polling/message_triggered', | ||
onMessageTriggered: '/v1/notifications/long_polling/message_triggered', | ||
/** | ||
@@ -732,3 +734,3 @@ * Wait for an SignalTriggered notification and resolves with the notification's content. | ||
*/ | ||
onSignalTriggered: '/notifications/long_polling/signal_triggered', | ||
onSignalTriggered: '/v1/notifications/long_polling/signal_triggered', | ||
/** | ||
@@ -740,3 +742,3 @@ * Wait for an EndEventFinished notification and resolves with the notification's content. | ||
*/ | ||
onEndEventFinished: '/notifications/long_polling/end_event_finished', | ||
onEndEventFinished: '/v1/notifications/long_polling/end_event_finished', | ||
/** | ||
@@ -748,3 +750,3 @@ * Wait for an StartEventFinished notification and resolves with the notification's content. | ||
*/ | ||
onStartEventFinished: '/notifications/long_polling/start_event_finished', | ||
onStartEventFinished: '/v1/notifications/long_polling/start_event_finished', | ||
/** | ||
@@ -756,3 +758,3 @@ * Wait for a ProcessInstanceMetadataChanged notification and resolves with the notification's content. | ||
*/ | ||
onProcessInstanceMetadataChanged: '/notifications/long_polling/process_instance_metadata_changed', | ||
onProcessInstanceMetadataChanged: '/v1/notifications/long_polling/process_instance_metadata_changed', | ||
/** | ||
@@ -764,3 +766,3 @@ * Wait for a CorrelationMetadataChanged notification and resolves with the notification's content. | ||
*/ | ||
onCorrelationMetadataChanged: '/notifications/long_polling/correlation_metadata_changed', | ||
onCorrelationMetadataChanged: '/v1/notifications/long_polling/correlation_metadata_changed', | ||
}; | ||
@@ -767,0 +769,0 @@ exports.restSettings = { |
@@ -18,2 +18,3 @@ export declare const restSettings: { | ||
userMetadataKey: string; | ||
processModelIds: string; | ||
}; | ||
@@ -20,0 +21,0 @@ paths: { |
{ | ||
"name": "@5minds/processcube_engine_client", | ||
"version": "4.4.0-feature-84bd3b-lkql4080", | ||
"version": "4.4.0-feature-a4e978-lkv7nuxb", | ||
"description": "Contains a typescript based client for accessing the Engine.", | ||
@@ -36,3 +36,3 @@ "main": "dist/commonjs/index.js", | ||
"dependencies": { | ||
"@5minds/processcube_engine_sdk": "4.0.0-feature-197d0b-lkl7hxnd", | ||
"@5minds/processcube_engine_sdk": "4.0.0-feature-928fbc-lkts3am1", | ||
"@types/socket.io": "^2.1.13", | ||
@@ -39,0 +39,0 @@ "@types/socket.io-client": "^1.4.36", |
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
588719
7385
+ Added@5minds/processcube_engine_sdk@4.0.0-feature-928fbc-lkts3am1(transitive)
- Removed@5minds/processcube_engine_sdk@4.0.0-feature-197d0b-lkl7hxnd(transitive)
Updated@5minds/processcube_engine_sdk@4.0.0-feature-928fbc-lkts3am1