rhea - npm Package Compare versions

Comparing version 0.3.1 to 0.3.2

lib/frames.js

@@ -78,2 +78,3 @@ /*
         reader.skip(2);
+        frame.channel = 0;
     } else {
@@ -80,0 +81,0 @@ throw new errors.ProtocolError('Unknown frame type ' + frame.type);

lib/sasl.js

@@ -163,3 +163,3 @@ /*
     var mechlist = Object.getOwnPropertyNames(mechanisms);
-    this.transport.encode(frames.sasl_frame(frames.sasl_mechanisms({sasl_server_mechanisms:mechlist}).described()));
+    this.transport.encode(frames.sasl_frame(frames.sasl_mechanisms({sasl_server_mechanisms:mechlist})));
 };
@@ -169,6 +169,6 @@
     if (this.mechanism.outcome === undefined) {
-        this.transport.encode(frames.sasl_frame(frames.sasl_challenge({'challenge':challenge}).described()));
+        this.transport.encode(frames.sasl_frame(frames.sasl_challenge({'challenge':challenge})));
     } else {
         this.outcome = this.mechanism.outcome ? sasl_codes.OK : sasl_codes.AUTH;
-        this.transport.encode(frames.sasl_frame(frames.sasl_outcome({code: this.outcome}).described()));
+        this.transport.encode(frames.sasl_frame(frames.sasl_outcome({code: this.outcome})));
         if (this.outcome === sasl_codes.OK) {
@@ -190,3 +190,3 @@ this.username = this.mechanism.username;
         this.outcome = sasl_codes.AUTH;
-        this.transport.encode(frames.sasl_frame(frames.sasl_outcome({code: this.outcome}).described()));
+        this.transport.encode(frames.sasl_frame(frames.sasl_outcome({code: this.outcome})));
     }
@@ -249,5 +249,5 @@ };
                 }
-                self.transport.encode(frames.sasl_frame(frames.sasl_init(init).described()));
+                self.transport.encode(frames.sasl_frame(frames.sasl_init(init)));
                 self.connection.output();
-        }
+            }
         });
@@ -266,3 +266,3 @@ } else {
         } else {
-            self.transport.encode(frames.sasl_frame(frames.sasl_response({'response':response}).described()));
+            self.transport.encode(frames.sasl_frame(frames.sasl_response({'response':response})));
             self.connection.output();
@@ -269,0 +269,0 @@ }

package.json

 {
     "name": "rhea",
-    "version": "0.3.1",
+    "version": "0.3.2",
     "description": "reactive AMQP 1.0 library",
@@ -12,3 +12,3 @@ "homepage": "http://github.com/amqp/rhea",
     "dependencies": {
-        "debug": ">=0.8.0"
+        "debug": "0.8.0 - 3.5.0"
     },
@@ -15,0 +15,0 @@ "devDependencies": {

typings/connection.d.ts

@@ -573,2 +573,3 @@ /// <reference types="node" />
   options: ConnectionOptions;
+  readonly container: Container;
   readonly hostname?: string;
@@ -575,0 +576,0 @@ readonly container_id: string;

typings/index.d.ts

@@ -15,2 +15,3 @@ /// <reference types="node" />
 export { types as Types } from "./types";
+export { sasl as Sasl } from "./sasl";
 export {
@@ -17,0 +18,0 @@ connect, create_container, filter, generate_uuid, id, message,

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

889511

Lines of code

14818

increased by0.02%

Dependency changes

• + Addeddebug@3.2.7(transitive)

• - Removeddebug@4.3.7(transitive)

• Updateddebug@0.8.0 - 3.5.0