Make time duration since last server data available

Author: ngbrown

src/amqp-base-client.ts

@@ -23,6 +23,7 @@ export abstract class AMQPBaseClient {
   channelMax = 0
   frameMax: number
   heartbeat: number
+  lastDataReceived: number | undefined = undefined
   onerror: (error: AMQPError) => void
   /** Used for string -> arraybuffer when publishing */
   readonly textEncoder = new TextEncoder()
@@ -94,6 +95,7 @@ export abstract class AMQPBaseClient {
   close(reason = "", code = 200): Promise<void> {
     if (this.closed) return this.rejectClosed()
     this.closed = true
+    this.lastDataReceived = undefined
     let j = 0
     const frame = new AMQPView(new ArrayBuffer(512))
     frame.setUint8(j, 1); j += 1 // type: method
@@ -589,5 +591,18 @@ export abstract class AMQPBaseClient {
       }
       i += 1 // frame end
     }
+    this.lastDataReceived = performance.now()
+  }
+
+  /**
+   * Get the time since since connection or last data received
+   * @returns milliseconds; Infinity if disconnected
+   */
+  durationSinceLastData(): number {
+    if (typeof this.lastDataReceived === 'number') {
+      return performance.now() - this.lastDataReceived;
+    } else {
+      return Infinity
+    }
   }
 }

src/amqp-socket-client.ts

@@ -53,6 +53,7 @@ export class AMQPClient extends AMQPBaseClient {
       writable: true,
       enumerable: false // hide it from console.log etc.
     })
+    this.lastDataReceived = performance.now()
     return new Promise((resolve, reject) => {
       socket.on('error', (err) => reject(new AMQPError(err.message, this)))
       this.connectPromise = [resolve, reject]

src/amqp-websocket-client.ts

@@ -50,6 +50,7 @@ export class AMQPWebSocketClient extends AMQPBaseClient {
     this.socket = socket
     socket.binaryType = "arraybuffer"
     socket.onmessage = this.handleMessage.bind(this)
+    this.lastDataReceived = performance.now()
     return new Promise((resolve, reject) => {
       this.connectPromise = [resolve, reject]
       socket.onclose = reject