amqplib - npm Package Compare versions

Comparing version 0.10.4 to 0.10.5

.github/workflows/publish.yml

+name: Publish
+
+on:
+  release:
+    types: [created]
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    services:
+      rabbitmq:
+        image: rabbitmq:3-alpine
+        ports:
+          - 5672:5672
+
+    strategy:
+      matrix:
+        node-version: [10.x, 12.x, 14.x, 16.x, 18.x, 20.x]
+        # See supported Node.js release schedule at https://nodejs.org/en/about/releases/
+
+    steps:
+      - uses: actions/checkout@v3
+
+      - name: Use Node.js ${{ matrix.node-version }}
+        uses: actions/setup-node@v3
+        with:
+          node-version: ${{ matrix.node-version }}
+          cache: "npm"
+
+      - run: npm ci
+
+      - run: |
+          n=0
+          while :
+          do
+            sleep 5
+            echo 'HELO\n\n\n\n' | nc localhost 5672 | grep AMQP
+            [[ $? = 0 ]] && break || ((n++))
+            (( n >= 5 )) && break
+          done
+
+      - run: echo 'HELO\n\n\n\n' | nc localhost 5672 | grep AMQP
+
+      - run: make test
+
+  publish:
+    needs: build
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v3
+      - uses: actions/setup-node@v3
+        with:
+          node-version: '20.x'
+          cache: "npm"
+          registry-url: https://registry.npmjs.org/
+      - run: npm ci
+      - run: npm publish --dry-run
+        env:
+          NODE_AUTH_TOKEN: ${{ secrets.NPM_AUTH_TOKEN }}

bin/amqp-rabbitmq-0.9.1.json

+{
+    "name": "AMQP",
+    "major-version": 0,
+    "minor-version": 9,
+    "revision": 1,
+    "port": 5672,
+    "copyright": [
+        "Copyright (C) 2008-2020 VMware, Inc. or its affiliates.\n",
+        "\n",
+        "Permission is hereby granted, free of charge, to any person\n",
+        "obtaining a copy of this file (the \"Software\"), to deal in the\n",
+        "Software without restriction, including without limitation the \n",
+        "rights to use, copy, modify, merge, publish, distribute, \n",
+        "sublicense, and/or sell copies of the Software, and to permit \n",
+        "persons to whom the Software is furnished to do so, subject to \n",
+        "the following conditions:\n",
+        "\n",
+        "The above copyright notice and this permission notice shall be\n",
+        "included in all copies or substantial portions of the Software.\n",
+        "\n",
+        "THE SOFTWARE IS PROVIDED \"AS IS\", WITHOUT WARRANTY OF ANY KIND,\n",
+        "EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES\n",
+        "OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND\n",
+        "NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT\n",
+        "HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,\n",
+        "WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING\n",
+        "FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR\n",
+        "OTHER DEALINGS IN THE SOFTWARE.\n",
+        "\n",
+        "Class information entered from amqp_xml0-8.pdf and domain types from amqp-xml-doc0-9.pdf\n",
+        "Updated for 0-9-1 by Tony Garnock-Jones\n",
+        "\n",
+        "b3cb053f15e7b98808c0ccc67f23cb3e  amqp_xml0-8.pdf\n",
+        "http://twiststandards.org/?option=com_docman&task=cat_view&gid=28&Itemid=90\n",
+        "8444db91e2949dbecfb2585e9eef6d64  amqp-xml-doc0-9.pdf\n",
+        "https://jira.amqp.org/confluence/download/attachments/720900/amqp-xml-doc0-9.pdf?version=1\n"],
+
+    "domains": [
+        ["bit", "bit"],
+        ["channel-id", "longstr"],
+        ["class-id", "short"],
+        ["consumer-tag", "shortstr"],
+        ["delivery-tag", "longlong"],
+        ["destination", "shortstr"],
+        ["duration", "longlong"],
+        ["exchange-name", "shortstr"],
+        ["long", "long"],
+        ["longlong", "longlong"],
+        ["longstr", "longstr"],
+        ["message-count", "long"],
+        ["method-id", "short"],
+        ["no-ack", "bit"],
+        ["no-local", "bit"],
+        ["octet", "octet"],
+        ["offset", "longlong"],
+        ["path", "shortstr"],
+        ["peer-properties", "table"],
+        ["queue-name", "shortstr"],
+        ["redelivered", "bit"],
+        ["reference", "longstr"],
+        ["reject-code", "short"],
+        ["reject-text", "shortstr"],
+        ["reply-code", "short"],
+        ["reply-text", "shortstr"],
+        ["security-token", "longstr"],
+        ["short", "short"],
+        ["shortstr", "shortstr"],
+        ["table", "table"],
+        ["timestamp", "timestamp"]
+    ],
+
+    "constants": [
+        {"name": "FRAME-METHOD", "value": 1},
+        {"name": "FRAME-HEADER", "value": 2},
+        {"name": "FRAME-BODY", "value": 3},
+        {"name": "FRAME-HEARTBEAT", "value": 8},
+        {"name": "FRAME-MIN-SIZE", "value": 4096},
+        {"name": "FRAME-END", "value": 206},
+        {"name": "REPLY-SUCCESS", "value": 200},
+        {"name": "CONTENT-TOO-LARGE", "value": 311, "class": "soft-error"},
+        {"name": "NO-ROUTE", "value": 312, "class": "soft-error"},
+        {"name": "NO-CONSUMERS", "value": 313, "class": "soft-error"},
+        {"name": "ACCESS-REFUSED", "value": 403, "class": "soft-error"},
+        {"name": "NOT-FOUND", "value": 404, "class": "soft-error"},
+        {"name": "RESOURCE-LOCKED", "value": 405, "class": "soft-error"},
+        {"name": "PRECONDITION-FAILED", "value": 406, "class": "soft-error"},
+        {"name": "CONNECTION-FORCED", "value": 320, "class": "hard-error"},
+        {"name": "INVALID-PATH", "value": 402, "class": "hard-error"},
+        {"name": "FRAME-ERROR", "value": 501, "class": "hard-error"},
+        {"name": "SYNTAX-ERROR", "value": 502, "class": "hard-error"},
+        {"name": "COMMAND-INVALID", "value": 503, "class": "hard-error"},
+        {"name": "CHANNEL-ERROR", "value": 504, "class": "hard-error"},
+        {"name": "UNEXPECTED-FRAME", "value": 505, "class": "hard-error"},
+        {"name": "RESOURCE-ERROR", "value": 506, "class": "hard-error"},
+        {"name": "NOT-ALLOWED", "value": 530, "class": "hard-error"},
+        {"name": "NOT-IMPLEMENTED", "value": 540, "class": "hard-error"},
+        {"name": "INTERNAL-ERROR", "value": 541, "class": "hard-error"}
+    ],
+
+    "classes": [
+        {
+            "id": 60,
+            "methods": [{"id": 10,
+                         "arguments": [{"type": "long", "name": "prefetch-size", "default-value": 0},
+                                       {"type": "short", "name": "prefetch-count", "default-value": 0},
+                                       {"type": "bit", "name": "global", "default-value": false}],
+                         "name": "qos",
+                         "synchronous" : true},
+                        {"id": 11,
+                         "arguments": [],
+                         "name": "qos-ok"},
+                        {"id": 20,
+                         "arguments": [{"domain": "short", "name": "ticket", "default-value": 0},
+                                       {"domain": "queue-name", "name": "queue", "default-value": ""},
+                                       {"type": "shortstr", "name": "consumer-tag", "default-value": ""},
+                                       {"type": "bit", "name": "no-local", "default-value": false},
+                                       {"type": "bit", "name": "no-ack", "default-value": false},
+                                       {"type": "bit", "name": "exclusive", "default-value": false},
+                                       {"type": "bit", "name": "nowait", "default-value": false},
+                                       {"type": "table", "name": "arguments", "default-value": {}}],
+                         "name": "consume",
+                         "synchronous" : true},
+                        {"id": 21,
+                         "arguments": [{"type": "shortstr", "name": "consumer-tag"}],
+                         "name": "consume-ok"},
+                        {"id": 30,
+                         "arguments": [{"type": "shortstr", "name": "consumer-tag"},
+                                       {"type": "bit", "name": "nowait", "default-value": false}],
+                         "name": "cancel",
+                         "synchronous" : true},
+                        {"id": 31,
+                         "arguments": [{"type": "shortstr", "name": "consumer-tag"}],
+                         "name": "cancel-ok"},
+                        {"content": true,
+                         "id": 40,
+                         "arguments": [{"type": "short", "name": "ticket", "default-value": 0},
+                                       {"domain": "exchange-name", "name": "exchange", "default-value": ""},
+                                       {"type": "shortstr", "name": "routing-key", "default-value": ""},
+                                       {"type": "bit", "name": "mandatory", "default-value": false},
+                                       {"type": "bit", "name": "immediate", "default-value": false}],
+                         "name": "publish"},
+                        {"content": true,
+                         "id": 50,
+                         "arguments": [{"type": "short", "name": "reply-code"},
+                                       {"type": "shortstr", "name": "reply-text", "default-value": ""},
+                                       {"domain": "exchange-name", "name": "exchange"},
+                                       {"type": "shortstr", "name": "routing-key"}],
+                         "name": "return"},
+                        {"content": true,
+                         "id": 60,
+                         "arguments": [{"type": "shortstr", "name": "consumer-tag"},
+                                       {"type": "longlong", "name": "delivery-tag"},
+                                       {"type": "bit", "name": "redelivered", "default-value": false},
+                                       {"domain": "exchange-name", "name": "exchange"},
+                                       {"type": "shortstr", "name": "routing-key"}],
+                         "name": "deliver"},
+                        {"id": 70,
+                         "arguments": [{"type": "short", "name": "ticket", "default-value": 0},
+                                       {"domain": "queue-name", "name": "queue", "default-value": ""},
+                                       {"type": "bit", "name": "no-ack", "default-value": false}],
+                         "name": "get",
+                         "synchronous" : true},
+                        {"content": true,
+                         "id": 71,
+                         "arguments": [{"type": "longlong", "name": "delivery-tag"},
+                                       {"type": "bit", "name": "redelivered", "default-value": false},
+                                       {"domain": "exchange-name", "name": "exchange"},
+                                       {"type": "shortstr", "name": "routing-key"},
+                                       {"domain": "message-count", "name": "message-count"}],
+                         "name": "get-ok"},
+                        {"id": 72,
+                         "arguments": [{"type": "shortstr", "name": "cluster-id", "default-value": ""}],
+                         "name": "get-empty"},
+                        {"id": 80,
+                         "arguments": [{"type": "longlong", "name": "delivery-tag", "default-value": 0},
+                                       {"type": "bit", "name": "multiple", "default-value": false}],
+                         "name": "ack"},
+                        {"id": 90,
+                         "arguments": [{"type": "longlong", "name": "delivery-tag"},
+                                       {"type": "bit", "name": "requeue", "default-value": true}],
+                         "name": "reject"},
+                        {"id": 100,
+                         "arguments": [{"type": "bit", "name": "requeue", "default-value": false}],
+                         "name": "recover-async"},
+                        {"id": 110,
+                         "arguments": [{"type": "bit", "name": "requeue", "default-value": false}],
+                         "name": "recover",
+                         "synchronous" : true},
+                        {"id": 111,
+                         "arguments": [],
+                         "name": "recover-ok"},
+                        {"id": 120,
+                         "arguments": [{"type": "longlong", "name": "delivery-tag", "default-value": 0},
+                                       {"type": "bit", "name": "multiple", "default-value": false},
+                                       {"type": "bit", "name": "requeue", "default-value": true}],
+                         "name": "nack"}],
+            "name": "basic",
+            "properties": [{"type": "shortstr", "name": "content-type"},
+                           {"type": "shortstr", "name": "content-encoding"},
+                           {"type": "table", "name": "headers"},
+                           {"type": "octet", "name": "delivery-mode"},
+                           {"type": "octet", "name": "priority"},
+                           {"type": "shortstr", "name": "correlation-id"},
+                           {"type": "shortstr", "name": "reply-to"},
+                           {"type": "shortstr", "name": "expiration"},
+                           {"type": "shortstr", "name": "message-id"},
+                           {"type": "timestamp", "name": "timestamp"},
+                           {"type": "shortstr", "name": "type"},
+                           {"type": "shortstr", "name": "user-id"},
+                           {"type": "shortstr", "name": "app-id"},
+                           {"type": "shortstr", "name": "cluster-id"}]
+        },
+        {
+            "id": 10,
+            "methods": [{"id": 10,
+                         "arguments": [{"type": "octet", "name": "version-major", "default-value": 0},
+                                       {"type": "octet", "name": "version-minor", "default-value": 9},
+                                       {"domain": "peer-properties", "name": "server-properties"},
+                                       {"type": "longstr", "name": "mechanisms", "default-value": "PLAIN"},
+                                       {"type": "longstr", "name": "locales", "default-value": "en_US"}],
+                         "name": "start",
+                         "synchronous" : true},
+                        {"id": 11,
+                         "arguments": [{"domain": "peer-properties", "name": "client-properties"},
+                                       {"type": "shortstr", "name": "mechanism", "default-value": "PLAIN"},
+                                       {"type": "longstr", "name": "response"},
+                                       {"type": "shortstr", "name": "locale", "default-value": "en_US"}],
+                         "name": "start-ok"},
+                        {"id": 20,
+                         "arguments": [{"type": "longstr", "name": "challenge"}],
+                         "name": "secure",
+                         "synchronous" : true},
+                        {"id": 21,
+                         "arguments": [{"type": "longstr", "name": "response"}],
+                         "name": "secure-ok"},
+                        {"id": 30,
+                         "arguments": [{"type": "short", "name": "channel-max", "default-value": 0},
+                                       {"type": "long", "name": "frame-max", "default-value": 0},
+                                       {"type": "short", "name": "heartbeat", "default-value": 0}],
+                         "name": "tune",
+                         "synchronous" : true},
+                        {"id": 31,
+                         "arguments": [{"type": "short", "name": "channel-max", "default-value": 0},
+                                       {"type": "long", "name": "frame-max", "default-value": 0},
+                                       {"type": "short", "name": "heartbeat", "default-value": 0}],
+                         "name": "tune-ok"},
+                        {"id": 40,
+                         "arguments": [{"type": "shortstr", "name": "virtual-host", "default-value": "/"},
+                                       {"type": "shortstr", "name": "capabilities", "default-value": ""},
+                                       {"type": "bit", "name": "insist", "default-value": false}],
+                         "name": "open",
+                         "synchronous" : true},
+                        {"id": 41,
+                         "arguments": [{"type": "shortstr", "name": "known-hosts", "default-value": ""}],
+                         "name": "open-ok"},
+                        {"id": 50,
+                         "arguments": [{"type": "short", "name": "reply-code"},
+                                       {"type": "shortstr", "name": "reply-text", "default-value": ""},
+                                       {"type": "short", "name": "class-id"},
+                                       {"type": "short", "name": "method-id"}],
+                         "name": "close",
+                         "synchronous" : true},
+                        {"id": 51,
+                         "arguments": [],
+                         "name": "close-ok"},
+                        {"id": 60,
+                         "arguments": [{"type": "shortstr", "name": "reason", "default-value": ""}],
+                         "name": "blocked"},
+                        {"id": 61,
+                         "arguments": [],
+                         "name": "unblocked"},
+                        {"id": 70,
+                         "arguments": [{"type": "longstr", "name": "new-secret"},
+                                       {"type": "shortstr", "name": "reason"}],
+                         "name": "update-secret",
+                         "synchronous" : true},
+                        {"id": 71,
+                         "arguments": [],
+                         "name": "update-secret-ok"}
+           ],
+            "name": "connection",
+            "properties": []
+        },
+        {
+            "id": 20,
+            "methods": [{"id": 10,
+                         "arguments": [{"type": "shortstr", "name": "out-of-band", "default-value": ""}],
+                         "name": "open",
+                         "synchronous" : true},
+                        {"id": 11,
+                         "arguments": [{"type": "longstr", "name": "channel-id", "default-value": ""}],
+                         "name": "open-ok"},
+                        {"id": 20,
+                         "arguments": [{"type": "bit", "name": "active"}],
+                         "name": "flow",
+                         "synchronous" : true},
+                        {"id": 21,
+                         "arguments": [{"type": "bit", "name": "active"}],
+                         "name": "flow-ok"},
+                        {"id": 40,
+                         "arguments": [{"type": "short", "name": "reply-code"},
+                                       {"type": "shortstr", "name": "reply-text", "default-value": ""},
+                                       {"type": "short", "name": "class-id"},
+                                       {"type": "short", "name": "method-id"}],
+                         "name": "close",
+                         "synchronous" : true},
+                        {"id": 41,
+                         "arguments": [],
+                         "name": "close-ok"}],
+            "name": "channel"
+        },
+        {
+            "id": 30,
+            "methods": [{"id": 10,
+                         "arguments": [{"type": "shortstr", "name": "realm", "default-value": "/data"},
+                                       {"type": "bit", "name": "exclusive", "default-value": false},
+                                       {"type": "bit", "name": "passive", "default-value": true},
+                                       {"type": "bit", "name": "active", "default-value": true},
+                                       {"type": "bit", "name": "write", "default-value": true},
+                                       {"type": "bit", "name": "read", "default-value": true}],
+                         "name": "request",
+                         "synchronous" : true},
+                        {"id": 11,
+                    "arguments": [{"type": "short", "name": "ticket", "default-value": 1}],
+                         "name": "request-ok"}],
+            "name": "access"
+        },
+        {
+            "id": 40,
+            "methods": [{"id": 10,
+                         "arguments": [{"type": "short", "name": "ticket", "default-value": 0},
+                                       {"domain": "exchange-name", "name": "exchange"},
+                                       {"type": "shortstr", "name": "type", "default-value": "direct"},
+                                       {"type": "bit", "name": "passive", "default-value": false},
+                                       {"type": "bit", "name": "durable", "default-value": false},
+                                       {"type": "bit", "name": "auto-delete", "default-value": false},
+                                       {"type": "bit", "name": "internal", "default-value": false},
+                                       {"type": "bit", "name": "nowait", "default-value": false},
+                                       {"type": "table", "name": "arguments", "default-value": {}}],
+                         "name": "declare",
+                         "synchronous" : true},
+                        {"id": 11,
+                         "arguments": [],
+                         "name": "declare-ok"},
+                        {"id": 20,
+                         "arguments": [{"type": "short", "name": "ticket", "default-value": 0},
+                                       {"domain": "exchange-name", "name": "exchange"},
+                                       {"type": "bit", "name": "if-unused", "default-value": false},
+                                       {"type": "bit", "name": "nowait", "default-value": false}],
+                         "name": "delete",
+                         "synchronous" : true},
+                        {"id": 21,
+                         "arguments": [],
+                         "name": "delete-ok"},
+                        {"id": 30,
+                         "arguments": [{"type": "short", "name": "ticket", "default-value": 0},
+                                       {"domain": "exchange-name", "name": "destination"},
+                                       {"domain": "exchange-name", "name": "source"},
+                                       {"type": "shortstr", "name": "routing-key", "default-value": ""},
+                                       {"type": "bit", "name": "nowait", "default-value": false},
+                                       {"type": "table", "name": "arguments", "default-value": {}}],
+                         "name": "bind",
+                         "synchronous" : true},
+                        {"id": 31,
+                         "arguments": [],
+                         "name": "bind-ok"},
+                        {"id": 40,
+                         "arguments": [{"type": "short", "name": "ticket", "default-value": 0},
+                                       {"domain": "exchange-name", "name": "destination"},
+                                       {"domain": "exchange-name", "name": "source"},
+                                       {"type": "shortstr", "name": "routing-key", "default-value": ""},
+                                       {"type": "bit", "name": "nowait", "default-value": false},
+                                       {"type": "table", "name": "arguments", "default-value": {}}],
+                         "name": "unbind",
+                         "synchronous" : true},
+                        {"id": 51,
+                         "arguments": [],
+                         "name": "unbind-ok"}],
+            "name": "exchange"
+        },
+        {
+            "id": 50,
+            "methods": [{"id": 10,
+                         "arguments": [{"type": "short", "name": "ticket", "default-value": 0},
+                                       {"domain": "queue-name", "name": "queue", "default-value": ""},
+                                       {"type": "bit", "name": "passive", "default-value": false},
+                                       {"type": "bit", "name": "durable", "default-value": false},
+                                       {"type": "bit", "name": "exclusive", "default-value": false},
+                                       {"type": "bit", "name": "auto-delete", "default-value": false},
+                                       {"type": "bit", "name": "nowait", "default-value": false},
+                                       {"type": "table", "name": "arguments", "default-value": {}}],
+                         "name": "declare",
+                         "synchronous" : true},
+                        {"id": 11,
+                         "arguments": [{"domain": "queue-name", "name": "queue"},
+                                       {"domain": "message-count", "name": "message-count"},
+                                       {"type": "long", "name": "consumer-count"}],
+                         "name": "declare-ok"},
+                        {"id": 20,
+                         "arguments": [{"type": "short", "name": "ticket", "default-value": 0},
+                                       {"domain": "queue-name", "name": "queue", "default-value": ""},
+                                       {"domain": "exchange-name", "name": "exchange"},
+                                       {"type": "shortstr", "name": "routing-key", "default-value": ""},
+                                       {"type": "bit", "name": "nowait", "default-value": false},
+                                       {"type": "table", "name": "arguments", "default-value": {}}],
+                         "name": "bind",
+                         "synchronous" : true},
+                        {"id": 21,
+                         "arguments": [],
+                         "name": "bind-ok"},
+                        {"id": 30,
+                         "arguments": [{"type": "short", "name": "ticket", "default-value": 0},
+                                       {"domain": "queue-name", "name": "queue", "default-value": ""},
+                                       {"type": "bit", "name": "nowait", "default-value": false}],
+                         "name": "purge",
+                         "synchronous" : true},
+                        {"id": 31,
+                         "arguments": [{"domain": "message-count", "name": "message-count"}],
+                         "name": "purge-ok"},
+                        {"id": 40,
+                         "arguments": [{"type": "short", "name": "ticket", "default-value": 0},
+                                       {"domain": "queue-name", "name": "queue", "default-value": ""},
+                                       {"type": "bit", "name": "if-unused", "default-value": false},
+                                       {"type": "bit", "name": "if-empty", "default-value": false},
+                                       {"type": "bit", "name": "nowait", "default-value": false}],
+                         "name": "delete",
+                         "synchronous" : true},
+                        {"id": 41,
+                         "arguments": [{"domain": "message-count", "name": "message-count"}],
+                         "name": "delete-ok"},
+                        {"id": 50,
+                         "arguments": [{"type": "short", "name": "ticket", "default-value": 0},
+                                       {"domain": "queue-name", "name": "queue", "default-value": ""},
+                                       {"domain": "exchange-name", "name": "exchange"},
+                                       {"type": "shortstr", "name": "routing-key", "default-value": ""},
+                                       {"type": "table", "name": "arguments", "default-value": {}}],
+                         "name": "unbind",
+                         "synchronous" : true},
+                        {"id": 51,
+                         "arguments": [],
+                         "name": "unbind-ok"}
+                        ],
+            "name": "queue"
+        },
+        {
+            "id": 90,
+            "methods": [{"id": 10,
+                         "arguments": [],
+                         "name": "select",
+                         "synchronous" : true},
+                        {"id": 11,
+                         "arguments": [],
+                         "name": "select-ok"},
+                        {"id": 20,
+                         "arguments": [],
+                         "name": "commit",
+                         "synchronous" : true},
+                        {"id": 21,
+                         "arguments": [],
+                         "name": "commit-ok"},
+                        {"id": 30,
+                         "arguments": [],
+                         "name": "rollback",
+                         "synchronous" : true},
+                        {"id": 31,
+                         "arguments": [],
+                         "name": "rollback-ok"}],
+            "name": "tx"
+        },
+        {
+            "id": 85,
+            "methods": [{"id": 10,
+                         "arguments": [
+                             {"type": "bit", "name": "nowait", "default-value": false}],
+                         "name": "select",
+                         "synchronous": true},
+                        {"id": 11,
+                         "arguments": [],
+                         "name": "select-ok"}],
+            "name": "confirm"
+        }
+    ]
+}

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;

Makefile

@@ -12,20 +12,12 @@ RABBITMQ_SRC_VERSION=v3.12.13
 
-.PHONY: test test-all-nodejs all clean coverage
+.PHONY: test test-all-nodejs coverage lib/defs.js
 
-all: lib/defs.js
+error:
+	@echo "Please choose one of the following targets: test, test-all-nodejs, coverage, lib/defs.js"
+	@exit 1
 
-clean:
-	rm lib/defs.js bin/amqp-rabbitmq-0.9.1.json
-	rm -rf ./coverage
-
-lib/defs.js: $(UGLIFY) bin/generate-defs.js bin/amqp-rabbitmq-0.9.1.json
-	(cd bin; node ./generate-defs.js > ../lib/defs.js)
-	$(UGLIFY) ./lib/defs.js -o ./lib/defs.js \
-		-c 'sequences=false' --comments \
-		-b 'indent-level=2' 2>&1 | (grep -v 'WARN' || true)
-
-test: lib/defs.js
+test:
 	$(MOCHA) --check-leaks -u tdd --exit test/
 
-test-all-nodejs: lib/defs.js
+test-all-nodejs:
 	for v in $(NODEJS_VERSIONS); \
@@ -36,6 +28,17 @@ do echo "-- Node version $$v --"; \
 
-coverage: $(NYC) lib/defs.js
-	$(NYC) --reporter=lcov --reporter=text $(_MOCHA) -u tdd -R progress test/
+coverage: $(NYC)
+	$(NYC) --clean --reporter=lcov --reporter=text $(_MOCHA) -u tdd --exit -R progress test/
 	@echo "HTML report at file://$$(pwd)/coverage/lcov-report/index.html"
 
+lib/defs.js: clean bin/generate-defs test
+
+clean:
+	rm -f lib/defs.js bin/amqp-rabbitmq-0.9.1.json
+
+bin/generate-defs: $(UGLIFY) bin/generate-defs.js bin/amqp-rabbitmq-0.9.1.json
+	(cd bin; node ./generate-defs.js > ../lib/defs.js)
+	$(UGLIFY) ./lib/defs.js -o ./lib/defs.js \
+		-c 'sequences=false' --comments \
+		-b 'indent-level=2' 2>&1 | (grep -v 'WARN' || true)
+
 bin/amqp-rabbitmq-0.9.1.json:
@@ -42,0 +45,0 @@ curl -L $(AMQP_JSON) > $@

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

Network access

Supply chain risk

This module accesses the network.

Found 2 instances in 1 package

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 2 instances in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

URL strings

Supply chain risk

Package contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.

Found 1 instance in 1 package

Fixed alerts

Network access

Supply chain risk

This module accesses the network.

Found 2 instances in 1 package

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 2 instances in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

URL strings

Supply chain risk

Package contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

448506

7.5%

Dependency count

3

-25%

Number of package files

76

2.7%

Lines of code

12543

4.26%

Worsened metrics

Number of lines in readme file

157

-0.63%

Dependency changes

• - Removed

  readable-stream@1.x >=1.1.9

• - Removed

  core-util-is@1.0.3
  (transitive)

• - Removed

  inherits@2.0.4
  (transitive)

• - Removed

  isarray@0.0.1
  (transitive)

• - Removed

  readable-stream@1.1.14
  (transitive)

• - Removed

  string_decoder@0.10.31
  (transitive)