@5minds/processcube_engine_client - npm Package Compare versions

Comparing version 4.4.0-feature-6f3370-lkv3q6xk to 4.4.0-feature-7d569d-ll3mv2db

dist/amd/Clients/EventHttpClient.js

@@ -20,7 +20,5 @@ 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, processModelIds, options) {
+        async triggerMessageEvent(messageName, 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) {
@@ -27,0 +25,0 @@ urlRestPart = `${urlRestPart}?process_instance_id=${options === null || options === void 0 ? void 0 : options.processInstanceId}`;

dist/amd/Clients/FlowNodeInstanceHttpClient.js

@@ -34,3 +34,3 @@ define(["require", "exports", "../Types/index", "./BaseClient", "./Lib/Mappers"], function (require, exports, index_1, BaseClient_1, Mappers_1) {
         }
-        async triggerMessageEvent(messageName, processModelIds, options) {
+        async triggerMessageEvent(messageName, 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);

dist/amd/Clients/NotificationHttpClient.js

@@ -144,2 +144,5 @@ define(["require", "exports", "../Types/index", "./BaseClient"], function (require, exports, index_1, BaseClient_1) {
         }
+        async onGatewayFinished(callback, options) {
+            return this.createSocketIoSubscription(index_1.socketSettings.paths.gatewayFinished, callback, options === null || options === void 0 ? void 0 : options.subscribeOnce, options === null || options === void 0 ? void 0 : options.identity);
+        }
     }
@@ -146,0 +149,0 @@ exports.NotificationHttpClient = NotificationHttpClient;

dist/amd/Types/RestSettings.js

@@ -36,4 +36,2 @@ define(["require", "exports"], function (require, exports) {
         userMetadataKey: ':user_metadata_key',
-        // Ids of models to catch message
-        processModelIds: ':process_model_ids',
     };
@@ -157,3 +155,3 @@ const paths = {
          */
-        triggerMessageEvent: `/messages/${params.eventName}/${params.processModelIds}/trigger`,
+        triggerMessageEvent: `/messages/${params.eventName}/trigger`,
         /**
@@ -160,0 +158,0 @@ * Triggers a SignalEvent by its name.

dist/amd/Types/SocketSettings.js

@@ -33,2 +33,3 @@ define(["require", "exports"], function (require, exports) {
         flowNodeTimerRemoved: 'OnFlowNodeTimerRemoved',
+        gatewayFinished: 'OnGatewayFinished',
         intermediateThrowEventTriggered: 'intermediate_throw_event_triggered',
@@ -35,0 +36,0 @@ intermediateCatchEventReached: 'intermediate_catch_event_reached',

dist/Clients/EventHttpClient.d.ts

@@ -11,3 +11,3 @@ import { DataModels, IEventExtensionAdapter, Identity, Messages, Subscription } from '@5minds/processcube_engine_sdk';
     }): Promise<EventList>;
-    triggerMessageEvent<TPayload>(messageName: string, processModelIds: Array<string>, options?: {
+    triggerMessageEvent<TPayload>(messageName: string, options?: {
         processInstanceId?: string;
@@ -14,0 +14,0 @@ payload?: TPayload;

dist/Clients/FlowNodeInstanceHttpClient.d.ts

@@ -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, processModelIds: Array<string>, options?: {
+    triggerMessageEvent<TPayload>(messageName: string, options?: {
         processInstanceId?: string;
@@ -16,0 +16,0 @@ payload?: TPayload;

dist/Clients/NotificationHttpClient.d.ts

@@ -182,2 +182,6 @@ import { INotificationExtensionAdapter, Identity, Messages, Subscription } from '@5minds/processcube_engine_sdk';
     }): Promise<Subscription>;
+    onGatewayFinished(callback: Messages.CallbackTypes.OnGatewayFinishedCallback, options?: {
+        subscribeOnce?: boolean;
+        identity?: Identity;
+    }): Promise<Subscription>;
 }

dist/commonjs/Clients/EventHttpClient.js

@@ -23,7 +23,5 @@ "use strict";
     }
-    async triggerMessageEvent(messageName, processModelIds, options) {
+    async triggerMessageEvent(messageName, 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) {
@@ -30,0 +28,0 @@ urlRestPart = `${urlRestPart}?process_instance_id=${options === null || options === void 0 ? void 0 : options.processInstanceId}`;

dist/commonjs/Clients/FlowNodeInstanceHttpClient.js

@@ -36,3 +36,3 @@ "use strict";
     }
-    async triggerMessageEvent(messageName, processModelIds, options) {
+    async triggerMessageEvent(messageName, 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);

dist/commonjs/Clients/NotificationHttpClient.js

@@ -145,4 +145,7 @@ "use strict";
     }
+    async onGatewayFinished(callback, options) {
+        return this.createSocketIoSubscription(index_1.socketSettings.paths.gatewayFinished, callback, options === null || options === void 0 ? void 0 : options.subscribeOnce, options === null || options === void 0 ? void 0 : options.identity);
+    }
 }
 exports.NotificationHttpClient = NotificationHttpClient;
 //# sourceMappingURL=NotificationHttpClient.js.map

dist/commonjs/Types/RestSettings.js

@@ -35,4 +35,2 @@ "use strict";
     userMetadataKey: ':user_metadata_key',
-    // Ids of models to catch message
-    processModelIds: ':process_model_ids',
 };
@@ -156,3 +154,3 @@ const paths = {
      */
-    triggerMessageEvent: `/messages/${params.eventName}/${params.processModelIds}/trigger`,
+    triggerMessageEvent: `/messages/${params.eventName}/trigger`,
     /**
@@ -159,0 +157,0 @@ * Triggers a SignalEvent by its name.

dist/commonjs/Types/SocketSettings.js

@@ -32,2 +32,3 @@ "use strict";
     flowNodeTimerRemoved: 'OnFlowNodeTimerRemoved',
+    gatewayFinished: 'OnGatewayFinished',
     intermediateThrowEventTriggered: 'intermediate_throw_event_triggered',
@@ -34,0 +35,0 @@ intermediateCatchEventReached: 'intermediate_catch_event_reached',

dist/Types/CallbackTypes.d.ts

@@ -41,1 +41,2 @@ import { CronjobEventMessage, EventMessage, ExternalTaskCreatedMessage, ExternalTaskLockedMessage, ExternalTaskUnlockedMessage, ProcessDeploymentMessage, ProcessInstancesDeletedMessage, ProcessIsExecutableChangedMessage, UserTaskFinishedMessage } from '@5minds/processcube_engine_sdk';
 export declare type OnExternalTaskUnlockedCallback = (externaTask: ExternalTaskUnlockedMessage) => void | Promise<void>;
+export declare type OnGatewayFinishedCallback = (gatewayFinished: EventMessage) => void | Promise<void>;

dist/Types/RestSettings.d.ts

@@ -18,3 +18,2 @@ export declare const restSettings: {
         userMetadataKey: string;
-        processModelIds: string;
     };
@@ -21,0 +20,0 @@ paths: {

dist/Types/SocketSettings.d.ts

@@ -31,2 +31,3 @@ export declare const socketSettings: {
         flowNodeTimerRemoved: string;
+        gatewayFinished: string;
         intermediateThrowEventTriggered: string;
@@ -33,0 +34,0 @@ intermediateCatchEventReached: string;

package.json

 {
   "name": "@5minds/processcube_engine_client",
-  "version": "4.4.0-feature-6f3370-lkv3q6xk",
+  "version": "4.4.0-feature-7d569d-ll3mv2db",
   "description": "Contains a typescript based client for accessing the Engine.",
@@ -36,6 +36,6 @@ "main": "dist/commonjs/index.js",
   "dependencies": {
-    "@5minds/processcube_engine_sdk": "4.0.0-feature-928fbc-lkts3am1",
-    "@types/socket.io": "^2.1.13",
+    "@5minds/processcube_engine_sdk": "4.0.0-feature-a85089-ll3kadxw",
+    "@types/socket.io": "^3.0.0",
     "@types/socket.io-client": "^1.4.36",
-    "cross-fetch": "3.1.6",
+    "cross-fetch": "4.0.0",
     "socket.io-client": "2.5.0",
@@ -42,0 +42,0 @@ "uuid": "^9.0.0"

No alert changes

Worsened metrics

Total package byte prevSize

588160

decreased by-0.02%

Number of package files

163

decreased by-0.61%

Published versions last year

384

decreased by-0.26%

Dependency changes

• + Added@5minds/processcube_engine_sdk@4.0.0-feature-a85089-ll3kadxw(transitive)

• + Added@types/cors@2.8.17(transitive)

• + Added@types/socket.io@3.0.2(transitive)

• + Addedaccepts@1.3.8(transitive)

• + Addedbase64id@2.0.0(transitive)

• + Addedcookie@0.7.2(transitive)

• + Addedcors@2.8.5(transitive)

• + Addedcross-fetch@4.0.0(transitive)

• + Addedengine.io@6.6.4(transitive)

• + Addedengine.io-parser@5.2.3(transitive)

• + Addedmime-db@1.52.0(transitive)

• + Addedmime-types@2.1.35(transitive)

• + Addednegotiator@0.6.3(transitive)

• + Addedobject-assign@4.1.1(transitive)

• + Addedsocket.io@4.8.1(transitive)

• + Addedsocket.io-adapter@2.5.5(transitive)

• + Addedvary@1.1.2(transitive)

• + Addedws@8.17.1(transitive)

• + Addedxml2js@0.6.2(transitive)

• - Removed@5minds/processcube_engine_sdk@4.0.0-feature-928fbc-lkts3am1(transitive)

• - Removed@types/engine.io@3.1.10(transitive)

• - Removed@types/socket.io@2.1.13(transitive)

• - Removed@types/socket.io-parser@3.0.0(transitive)

• - Removedcross-fetch@3.1.6(transitive)

• - Removedxml2js@0.5.0(transitive)

• Updated@5minds/processcube_engine_sdk@4.0.0-feature-a85089-ll3kadxw

• Updated@types/socket.io@^3.0.0

• Updatedcross-fetch@4.0.0