cloudamqp · baelter · Mar 9, 2026 · Mar 9, 2026 · Mar 9, 2026 · Mar 9, 2026
@@ -0,0 +1,3 @@
+REVIEWER=copilot
+CRITERIA=.github/copilot-instructions.md
+MODEL=gpt-4.1
@@ -0,0 +1,38 @@
+# amqp-client.js
+
+AMQP 0-9-1 client library for Node.js and browsers.
+
+## Before committing
+
+Run these checks and fix any issues:
+
+```sh
+npm run format:check   # prettier
+npm run lint           # eslint
+npm run typecheck      # tsc --noEmit
+```
+
+To auto-fix formatting: `npm run format`
+
+## Testing
+
+```sh
+npx vitest run test/<file>.ts   # run specific test file
+npm run test:local              # run local tests with coverage
+```
+
+Full `npm test` (with coverage for all tests) may OOM — prefer targeted runs.
+
+## Project structure
+
+- `src/` — TypeScript source (ESM)
+- `test/` — vitest tests
+- `lib/` — build output (gitignored)
+- `types/` — generated declarations (gitignored)
+
+## Key conventions
+
+- Prettier for formatting, eslint for linting
+- `CodecMode` generic (`"plain" | "codec"`) threads through session/queue/exchange/rpc classes
+- `AMQPMessage.body` starts as raw bytes, gets replaced by decoded value when codecs are configured
+- `@internal` JSDoc + `stripInternal: true` hides internal API from declarations
@@ -10,6 +10,13 @@ export default tseslint.config(
   eslint.configs.recommended,
   tseslint.configs.recommended,
   prettierConfig,
+  {
+    files: ["src/**/*.ts", "test/**/*.ts", "test-browser/**/*.ts"],
+    rules: {
+      // {} is used extensively as a default for ParserMap/CoderMap generics
+      "@typescript-eslint/no-empty-object-type": ["error", { allowObjectTypes: "always" }],
+    },
+  },
   {
     files: ["examples/*.js", "scripts/*.js"],
     languageOptions: {

@@ -25,7 +25,7 @@
   },
   "sideEffects": false,
   "engines": {
-    "node": ">=16.0.0"
+    "node": ">=18.0.0"
   },
   "scripts": {
     "docs": "typedoc src/index.ts",

@@ -413,7 +413,6 @@ export abstract class AMQPBaseClient {
                   const err = new AMQPError(msg, this)
                   channel.setClosed(err)
                   delete this.channels[channelId]
-
                   const closeOk = new AMQPFrame.Writer({
                     bufferSize: 12,
                     type: AMQPFrame.Type.METHOD,
@@ -669,7 +668,7 @@ export abstract class AMQPBaseClient {
           if (message) {
             message.bodySize = bodySize
             message.properties = properties
-            message.body = new Uint8Array(bodySize)
+            message._rawBytes = new Uint8Array(bodySize)
             if (bodySize === 0) channel.onMessageReady(message)
           } else {
             this.logger?.warn("Header frame but no message")
@@ -678,9 +677,9 @@ export abstract class AMQPBaseClient {
         }
         case AMQPFrame.Type.BODY: {
           const message = channel.delivery || channel.getMessage || channel.returned
-          if (message && message.body) {
+          if (message && message._rawBytes) {
             const bodyPart = new Uint8Array(view.buffer, view.byteOffset + i, frameSize)
-            message.body.set(bodyPart, message.bodyPos)
+            message._rawBytes.set(bodyPart, message.bodyPos)
             message.bodyPos += frameSize
             i += frameSize
             if (message.bodyPos === message.bodySize) channel.onMessageReady(message)

@@ -885,6 +885,7 @@ export class AMQPChannel {
    * @param message
    */
   onMessageReady(message: AMQPMessage): void {
+    message.body = message._rawBytes
     if (this.delivery) {
       delete this.delivery
       this.deliver(message)