socket.io-amqp0 - npm Package Compare versions

Comparing version 6.0.0 to 6.1.0

CHANGELOG.md

 # socket.io-amqp0
 
+## 6.1.0
+
+### Minor Changes
+
+-   8ed9152: added (broken) support for broadcastWithAck
+
 ## 6.0.0
@@ -4,0 +10,0 @@

dist/index.d.ts

@@ -35,2 +35,4 @@ import { BroadcastOptions, Room, SocketId, Adapter } from 'socket.io-adapter';
     constructor(nsp: Namespace, options: AmqpAdapterOptions, name: string);
+    serverCount(): Promise<number>;
+    broadcastWithAck(packet: any, opts: BroadcastOptions, clientCountCallback: (clientCount: number) => void, ack: (...args: any[]) => void): Promise<void>;
     handleConnection(conn: Connection): Promise<void>;
@@ -37,0 +39,0 @@ init(): Promise<void>;

dist/index.js

@@ -55,2 +55,11 @@ "use strict";
     }
+    serverCount() {
+        return Promise.resolve(10);
+    }
+    async broadcastWithAck(packet, opts, clientCountCallback, ack) {
+        await this.broadcast(packet, opts);
+        // todo: shim to handle broadcast with ack until I have time to implement it for real
+        clientCountCallback(1);
+        ack();
+    }
     async handleConnection(conn) {
@@ -57,0 +66,0 @@ conn.on('close', async () => {

package.json

 {
   "name": "socket.io-amqp0",
-  "version": "6.0.0",
+  "version": "6.1.0",
   "description": "socket.io adapter for amqp 0.9.1+ (e.g. RabbitMQ)",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

221827

increased by0.62%

Lines of code

491

increased by2.29%

No dependency changes