fix: build for node esm and cjs and example

Author: magne

examples/package-lock.json

@@ -3,6 +3,7 @@
   "version": "1.0.0",
   "description": "",
   "main": "index.js",
+  "type": "module",
   "scripts": {
     "start": "node index.js",
     "rebuild-source": "cd .. && npm run build && cd - && npm install --force",
@@ -11,7 +12,8 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
-    "rabbitmq-amqp-js-client": "file:../."
+    "rabbitmq-amqp-js-client": "file:../.",
+    "rhea": "^3.0.4"
   },
   "engines": {
     "node": "22.x.x"

examples/package.json

@@ -1,23 +1,22 @@
-const rabbit = require("rabbitmq-amqp-js-client")
-const { randomUUID } = require("crypto")
+import { createEnvironment, createAmqpMessage, OutcomeState } from "rabbitmq-amqp-js-client"
+import { randomUUID } from "crypto"
 
-const rabbitUser = process.env.RABBITMQ_USER ?? "guest"
-const rabbitPassword = process.env.RABBITMQ_PASSWORD ?? "guest"
+const rabbitUser = process.env.RABBITMQ_USER ?? "rabbit"
+const rabbitPassword = process.env.RABBITMQ_PASSWORD ?? "rabbit"
 const rabbitHost = process.env.RABBITMQ_HOSTNAME ?? "localhost"
-const rabbitPort = process.env.RABBITMQ_PORT ?? 15678
+const rabbitPort = process.env.RABBITMQ_PORT ?? 5672
 
 async function main() {
   const testExchange = `test-exchange-${randomUUID()}`
   const testQueue = `test-queue-${randomUUID()}`
   const routingKey = `test-key-${randomUUID()}`
 
   console.log("Creating the environment...")
-  const environment = rabbit.createEnvironment({
+  const environment = createEnvironment({
     host: rabbitHost,
     port: rabbitPort,
     username: rabbitUser,
     password: rabbitPassword,
-    webSocket: WebSocket,
   })
 
   console.log("Opening a connection...")
@@ -34,15 +33,15 @@ async function main() {
   console.log("Opening a publisher and publishing 10 messages...")
   const publisher = await connection.createPublisher({ exchange: { name: testExchange, routingKey: routingKey } })
   for (const i of Array(10).keys()) {
-    const publishResult = await publisher.publish(rabbit.createAmqpMessage({ body: `Hello - ${i} - ` }))
+    const publishResult = await publisher.publish(createAmqpMessage({ body: `Hello - ${i} - ` }))
     switch (publishResult.outcome) {
-      case rabbit.OutcomeState.ACCEPTED:
+      case OutcomeState.ACCEPTED:
         console.log("Message Accepted")
         break
-      case rabbit.OutcomeState.RELEASED:
+      case OutcomeState.RELEASED:
         console.log("Message Released")
         break
-      case rabbit.OutcomeState.REJECTED:
+      case OutcomeState.REJECTED:
         console.log("Message Rejected")
         break
       default:

examples/websocket_example.js renamed to examples/socket_example.js

@@ -2,32 +2,32 @@
   "name": "rabbitmq-amqp-js-client",
   "version": "0.3.2",
   "description": "Rabbit AMQP 1.0 client for JS/TS application",
-  "main": "dist/index.cjs.js",
-  "module": "dist/index.es.js",
+  "main": "dist/index.cjs",
+  "module": "dist/index.js",
   "types": "dist/index.d.ts",
   "type": "module",
   "exports": {
     ".": {
       "browser": "./dist/index.umd.js",
       "import": {
         "types": "./dist/index.d.ts",
-        "default": "./dist/index.es.js"
+        "default": "./dist/index.js"
       },
       "require": {
-        "default": "./dist/index.cjs.js"
+        "default": "./dist/index.cjs"
       },
-      "default": "./dist/index.es.js"
+      "default": "./dist/index.js"
     },
     "./dist/*": {
       "types": "./dist/*.d.ts",
-      "import": "./dist/*.es.js",
-      "require": "./dist/*.cjs.js"
+      "import": "./dist/*.js",
+      "require": "./dist/*.cjs"
     }
   },
   "scripts": {
     "test": "vitest run",
     "build": "npm run build:node && npm run build:browser",
-    "build:node": "vite build --config vite.config.ts",
+    "build:node": "vite build --config vite.config.cjs.ts && vite build --config vite.config.esm.ts",
     "build:browser": "vite build --config vite.config.browser.ts",
     "build:clean": "rm -rf dist && npm run build",
     "check": "npm run check-ts && npm run check-lint && npm run check-format && npm run check-spell",

package.json

@@ -0,0 +1,32 @@
+import { defineConfig } from "vite"
+import { resolve } from "path"
+
+export default defineConfig({
+  plugins: [],
+  build: {
+    lib: {
+      entry: resolve(__dirname, "src/index.ts"),
+      name: "RabbitmqAmqpClient",
+      formats: ["cjs"],
+      fileName: () => `index.cjs`,
+    },
+    rollupOptions: {
+      external: ["rhea", "crypto"],
+      output: {
+        globals: {
+          rhea: "rhea",
+        },
+      },
+    },
+    outDir: "dist",
+    emptyOutDir: false,
+    sourcemap: true,
+    minify: false,
+    target: "node16",
+  },
+  resolve: {
+    alias: {
+      "@": resolve(__dirname, "src"),
+    },
+  },
+})

vite.config.cjs.ts

@@ -1,18 +1,9 @@
 import { defineConfig } from "vite"
 import { resolve } from "path"
-import { nodePolyfills } from "vite-plugin-node-polyfills"
 import dts from "vite-plugin-dts"
 
 export default defineConfig({
   plugins: [
-    nodePolyfills({
-      globals: {
-        Buffer: true,
-        global: true,
-        process: true,
-      },
-      protocolImports: true,
-    }),
     dts({
       include: ["src/**/*"],
       exclude: ["src/**/*.test.ts", "src/**/*.spec.ts", "test/**/*"],
@@ -25,29 +16,41 @@ export default defineConfig({
     lib: {
       entry: resolve(__dirname, "src/index.ts"),
       name: "RabbitmqAmqpClient",
-      formats: ["es", "cjs"],
-      fileName: (format) => `index.${format}.js`,
+      formats: ["es"],
+      fileName: () => `index.js`,
     },
     rollupOptions: {
-      external: ["rhea"],
+      external: [
+        "crypto",
+        // Node.js built-in modules that rhea needs
+        "net",
+        "tls",
+        "os",
+        "path",
+        "util",
+        "events",
+        "stream",
+        "buffer",
+        "fs",
+        "dns"
+      ],
       output: {
-        globals: {
-          rhea: "rhea",
-        },
+        globals: {},
       },
     },
     outDir: "dist",
-    emptyOutDir: true,
+    emptyOutDir: false,
     sourcemap: true,
     minify: false,
-    target: ["node16", "es2020"],
-    commonjsOptions: {
-      include: [/node_modules/],
-    },
+    target: "node16",
   },
   resolve: {
     alias: {
       "@": resolve(__dirname, "src"),
     },
   },
-})
+  define: {
+    // Ensure we're building for Node.js, not browser
+    global: 'globalThis',
+  },
+})