amqplib - npm Package Compare versions

Comparing version 0.10.4 to 0.10.5

CHANGELOG.md

 # Change log for amqplib
 
+## Changes in v0.10.5
+
+    git log v0.10.4..v0.10.5
+
+- Removed readable stream - See https://github.com/amqp-node/amqplib/issues/729
+- Added support for unsigned integers - See https://github.com/amqp-node/amqplib/pull/773
+- Committed protocol definitions - See https://github.com/amqp-node/amqplib/commit/0a87ee480311633cff41e43350a90cb3c1221506
+
 ## Changes in v0.10.4
@@ -4,0 +12,0 @@

lib/codec.js

@@ -191,2 +191,7 @@ //
         break;
+    case 'unsignedbyte':
+    case 'uint8':
+        tag('B');
+        buffer.writeUInt8(val, offset); offset++;
+        break;
     case 'short':
@@ -197,2 +202,7 @@ case 'int16':
         break;
+    case 'unsignedshort':
+    case 'uint16':
+        tag('u');
+        buffer.writeUInt16BE(val, offset); offset += 2;
+        break;
     case 'int':
@@ -203,2 +213,7 @@ case 'int32':
         break;
+    case 'unsignedint':
+    case 'uint32':
+        tag('i');
+        buffer.writeUInt32BE(val, offset); offset += 4;
+        break;
     case 'long':
@@ -249,2 +264,5 @@ case 'int64':
             break;
+        case 'B':
+            val = slice.readUInt8(offset); offset++;
+            break;
         case 'S':
@@ -258,2 +276,5 @@ len = slice.readUInt32BE(offset); offset += 4;
             break;
+        case 'i':
+            val = slice.readUInt32BE(offset); offset += 4;
+            break;
         case 'D': // only positive decimals, apparently.
@@ -290,2 +311,5 @@ var places = slice[offset]; offset++;
             break;
+        case 'u':
+            val = slice.readUInt16BE(offset); offset += 2;
+            break;
         case 't':
@@ -292,0 +316,0 @@ val = slice[offset] != 0; offset++;

lib/connection.js

@@ -13,5 +13,3 @@ //
 
-var Duplex =
-  require('stream').Duplex ||
-  require('readable-stream/duplex');
+var Duplex = require('stream').Duplex;
 var EventEmitter = require('events');
@@ -26,4 +24,3 @@ var Heart = require('./heartbeat').Heart;
 var fmt = require('util').format;
-var PassThrough = require('stream').PassThrough ||
-  require('readable-stream/passthrough');
+var PassThrough = require('stream').PassThrough;
 var IllegalOperationError = require('./error').IllegalOperationError;
@@ -30,0 +27,0 @@ var stackCapture = require('./error').stackCapture;

package.json

@@ -5,7 +5,7 @@ {
   "main": "./channel_api.js",
-  "version": "0.10.4",
+  "version": "0.10.5",
   "description": "An AMQP 0-9-1 (e.g., RabbitMQ) library and client.",
   "repository": {
     "type": "git",
-    "url": "https://github.com/amqp-node/amqplib.git"
+    "url": "git+https://github.com/amqp-node/amqplib.git"
   },
@@ -18,3 +18,2 @@ "engines": {
     "buffer-more-ints": "~1.0.0",
-    "readable-stream": "1.x >=1.1.9",
     "url-parse": "~1.5.10"
@@ -29,4 +28,3 @@ },
   "scripts": {
-    "test": "make test",
-    "prepare": "make"
+    "test": "make test"
   },
@@ -33,0 +31,0 @@ "keywords": [

README.md

@@ -16,3 +16,2 @@ # AMQP 0-9-1 library and client for Node.JS
 
-
 A library for making AMQP 0-9-1 clients for Node.JS, and an AMQP 0-9-1 client for Node.JS v10+.
@@ -19,0 +18,0 @@

test/codec.js

@@ -47,15 +47,12 @@ 'use strict';
     // array, object
-    ['array', {array: [6, true, "foo"]},
-     [5,97,114,114,97,121,65,0,0,0,12,98,6,116,1,83,0,0,0,3,102,111,111]],
-    ['object', {object: {foo: "bar", baz: 12}},
-     [6,111,98,106,101,99,116,70,0,0,0,18,3,102,111,111,83,0,
-      0,0,3,98,97,114,3,98,97,122,98,12]],
+    ['array', {array: [6, true, "foo"]},[5,97,114,114,97,121,65,0,0,0,12,98,6,116,1,83,0,0,0,3,102,111,111]],
+    ['object', {object: {foo: "bar", baz: 12}},[6,111,98,106,101,99,116,70,0,0,0,18,3,102,111,111,83,0,0,0,3,98,97,114,3,98,97,122,98,12]],
 
     // exotic types
-    ['timestamp', {timestamp: {'!': 'timestamp', value: 1357212277527}},
-     [9,116,105,109,101,115,116,97,109,112,84,0,0,1,60,0,39,219,23]],
-    ['decimal', {decimal: {'!': 'decimal', value: {digits: 2345, places: 2}}},
-     [7,100,101,99,105,109,97,108,68,2,0,0,9,41]],
-    ['float', {float: {'!': 'float', value: 0.1}},
-     [5,102,108,111,97,116,102,61,204,204,205]],
+    ['timestamp', {timestamp: {'!': 'timestamp', value: 1357212277527}},[9,116,105,109,101,115,116,97,109,112,84,0,0,1,60,0,39,219,23]],
+    ['decimal', {decimal: {'!': 'decimal', value: {digits: 2345, places: 2}}},[7,100,101,99,105,109,97,108,68,2,0,0,9,41]],
+    ['float', {float: {'!': 'float', value: 0.1}},[5,102,108,111,97,116,102,61,204,204,205]],
+    ['unsignedbyte', {unsignedbyte:{'!': 'unsignedbyte', value: 255}}, [12,117,110,115,105,103,110,101,100,98,121,116,101,66,255]],
+    ['unsignedshort', {unsignedshort:{'!': 'unsignedshort', value: 65535}}, [13,117,110,115,105,103,110,101,100,115,104,111,114,116,117,255,255]],
+    ['unsignedint', {unsignedint:{'!': 'unsignedint', value: 4294967295}}, [11,117,110,115,105,103,110,101,100,105,110,116,105,255,255,255,255]],
 ];
@@ -113,2 +110,5 @@
     amqp.Timestamp,
+    amqp.UnsignedByte,
+    amqp.UnsignedShort,
+    amqp.UnsignedInt,
     amqp.Double,
@@ -115,0 +115,0 @@ amqp.Float,

test/data.js

@@ -92,2 +92,14 @@ // Property-based testing representations of various things in AMQP
   }, sequence(arb.UInt, Octet)));
+var UnsignedByte = label('unsignedbyte', transform(
+  function(n) {
+    return {'!': 'unsignedbyte', value: n};
+  }, Octet));
+var UnsignedShort = label('unsignedshort', transform(
+  function(n) {
+    return {'!': 'unsignedshort', value: n};
+  }, UShort));
+var UnsignedInt = label('unsignedint', transform(
+  function(n) {
+    return {'!': 'unsignedint', value: n};
+  }, ULong));
 
@@ -248,2 +260,5 @@ // Signed 8 bit int
   Decimal: Decimal,
+  UnsignedByte: UnsignedByte,
+  UnsignedShort: UnsignedShort,
+  UnsignedInt: UnsignedInt,
   FieldArray: FieldArray,
@@ -250,0 +265,0 @@ FieldTable: FieldTable,

test/frame.js

@@ -10,4 +10,3 @@ 'use strict';
 var Stream = require('stream');
-var PassThrough = Stream.PassThrough ||
-    require('readable-stream/passthrough');
+var PassThrough = Stream.PassThrough;
 
@@ -14,0 +13,0 @@ var defs = require('../lib/defs');

test/mux.js

@@ -5,4 +5,3 @@ 'use strict';
 var Mux = require('../lib/mux').Mux;
-var PassThrough = require('stream').PassThrough ||
-  require('readable-stream/passthrough');
+var PassThrough = require('stream').PassThrough;
 
@@ -9,0 +8,0 @@ var latch = require('./util').latch;

test/util.js

@@ -5,5 +5,3 @@ 'use strict';
 var Connection = require('../lib/connection').Connection;
-var PassThrough =
-  require('stream').PassThrough ||
-  require('readable-stream/passthrough');
+var PassThrough = require('stream').PassThrough;
 var defs = require('../lib/defs');
@@ -10,0 +8,0 @@ var assert = require('assert');

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

448506

increased by7.5%

Dependency count

3

decreased by-25%

Number of package files

76

increased by2.7%

Lines of code

12543

increased by4.26%

Worsened metrics

Number of lines in readme file

157

decreased by-0.63%

Dependency changes

• - Removedreadable-stream@1.x >=1.1.9

• - Removedcore-util-is@1.0.3(transitive)

• - Removedinherits@2.0.4(transitive)

• - Removedisarray@0.0.1(transitive)

• - Removedreadable-stream@1.1.14(transitive)

• - Removedstring_decoder@0.10.31(transitive)