Add encode and decode support for unsigned short

amqp-node · Jul 8, 2024 · 6ccf30e · 6ccf30e
1 parent 64d1c1e
commit 6ccf30e
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/lib/codec.js b/lib/codec.js
@@ -193,6 +193,10 @@ function encodeFieldValue(buffer, value, offset) {
         tag('s');
         buffer.writeInt16BE(val, offset); offset += 2;
         break;
+    case 'unsignedshort':
+    case 'uint16':
+        tag('u');
+        buffer.writeUInt16BE(val, offset); offset += 2;
     case 'int':
     case 'int32':
         tag('I');
@@ -282,6 +286,9 @@ function decodeFields(slice) {
         case 's':
             val = slice.readInt16BE(offset); offset += 2;
             break;
+        case 'u':
+            val = slice.readUInt16BE(offset); offset += 2;
+            break;
         case 't':
             val = slice[offset] != 0; offset++;
             break;