Lint, fix ts warnings

baelter · baelter · commit fa06e2dbe137 · 2025-09-11T10:47:53.000+02:00
diff --git a/README.md b/README.md
@@ -54,7 +54,7 @@ run()
 
 This library can be used in the browser to access an AMQP server over WebSockets. For servers such as RabbitMQ that doesn't (yet?) support WebSockets natively a [WebSocket TCP relay](https://github.com/cloudamqp/websocket-tcp-relay/) have to be used as a proxy. More information can be found [in this blog post](https://www.cloudamqp.com/blog/cloudamqp-releases-amqp-websockets.html).
 
-For web browsers a [compiled](https://www.typescriptlang.org/) and [rolled up](https://www.rollupjs.org/) version is available at https://github.com/cloudamqp/amqp-client.js/releases.
+For web browsers a [compiled](https://www.typescriptlang.org/) and [rolled up](https://www.rollupjs.org/) version is available at <https://github.com/cloudamqp/amqp-client.js/releases>.
 
 Using AMQP over WebSockets in a browser:
 
diff --git a/src/amqp-channel.ts b/src/amqp-channel.ts
@@ -750,7 +750,7 @@ export class AMQPChannel {
       this.rpcQueue = this.rpcQueue.then(() => {
         // Add the callbacks to the queue before sending
         this.rpcCallbacks.push([resolve, reject])
-        
+
         return this.connection.send(new Uint8Array(frame.buffer, 0, frameSize))
           .catch((err) => {
             // Remove the callbacks from the queue if send fails
@@ -780,11 +780,11 @@ export class AMQPChannel {
       this.closed = true
       this.consumers.forEach((consumer) => consumer.setClosed(err))
       this.consumers.clear()
-      
+
       // Reject all pending RPC callbacks
       this.rpcCallbacks.forEach(([, reject]) => reject(err))
       this.rpcCallbacks.length = 0
-      
+
       // Reject and clear all unconfirmed publishes
       this.unconfirmedPublishes.forEach(([, , reject]) => reject(err))
       this.unconfirmedPublishes.length = 0
diff --git a/test-browser/websocket.ts b/test-browser/websocket.ts
@@ -95,7 +95,7 @@ test('can unsubscribe from a queue', async () => {
   const conn = await amqp.connect()
   const ch = await conn.channel()
   const q = await ch.queue("")
-  const consumer = await q.subscribe({}, () => "")
+  const consumer = await q.subscribe({}, () => {})
   await expect(q.unsubscribe(consumer.tag)).resolves.toBeDefined()
 })
 
@@ -129,7 +129,7 @@ test('will throw an error after consumer timeout', async () => {
   const conn = await amqp.connect()
   const ch = await conn.channel()
   const q = await ch.queue("")
-  const consumer = await q.subscribe({noAck: false}, () => "")
+  const consumer = await q.subscribe({noAck: false}, () => {})
   await expect(consumer.wait(1)).rejects.toThrow()
 })
 
@@ -138,7 +138,7 @@ test('will throw an error if consumer is closed', async () => {
   const conn = await amqp.connect()
   const ch = await conn.channel()
   const q = await ch.queue("")
-  const consumer = await q.subscribe({noAck: false}, () => "")
+  const consumer = await q.subscribe({noAck: false}, () => {})
   consumer.setClosed(new Error("testing"))
   try {
     await consumer.wait(1);
@@ -162,7 +162,7 @@ test('will clear consumer wait timeout on cancel', async () => {
   const conn = await amqp.connect()
   const ch = await conn.channel()
   const q = await ch.queue("")
-  const consumer = await q.subscribe({noAck: false}, () => "")
+  const consumer = await q.subscribe({noAck: false}, () => {})
   const wait = consumer.wait(5000);
   consumer.cancel()
   await expect(wait).resolves.toBeUndefined()
@@ -189,7 +189,7 @@ test('consumer stops wait on cancel', async () => {
   const conn = await amqp.connect()
   const ch = await conn.channel()
   const q = await ch.queue()
-  const consumer = await q.subscribe({}, () => ({}))
+  const consumer = await q.subscribe({}, () => {})
   await q.publish("foobar")
   await consumer.cancel()
   await expect(consumer.wait()).resolves.toBeUndefined()
@@ -200,7 +200,7 @@ test('consumer stops wait on channel error', async () => {
   const conn = await amqp.connect()
   const ch = await conn.channel()
   const q = await ch.queue()
-  const consumer = await q.subscribe({}, () => ({}))
+  const consumer = await q.subscribe({}, () => {})
   // acking invalid delivery tag should close channel
   setTimeout(() => ch.basicAck(99999), 1)
   await expect(consumer.wait()).rejects.toThrow()
@@ -577,7 +577,7 @@ test("can handle cancel from server", async () => {
   const conn = await amqp.connect()
   const ch = await conn.channel()
   const q = await ch.queue("")
-  const consumer = await q.subscribe({}, () => "")
+  const consumer = await q.subscribe({}, () => {})
   await q.delete()
   await expect(consumer.wait()).rejects.toThrow(/Consumer cancelled by the server/)
 }, 10_000)
diff --git a/vite-env.d.ts b/vite-env.d.ts
@@ -0,0 +1,9 @@
+/// <reference types="vite/client" />
+
+interface ImportMetaEnv {
+  readonly VITE_WS_URL?: string
+}
+
+interface ImportMeta {
+  readonly env: ImportMetaEnv
+}
