feat: add vhost to ConnectionInfo

Author: david-mohr

src/connection.ts

@@ -62,6 +62,7 @@ export type ConnectionInfo = {
   port: number
   id: string
   ready: boolean
+  vhost: string
   readable?: boolean
   writable?: boolean
   localPort?: number
@@ -376,6 +377,7 @@ export class Connection {
       writable: this.socket.writable,
       localPort: this.socket.localPort,
       ready: this.ready,
+      vhost: this.vhost
     }
   }
 

src/consumer.ts

@@ -76,8 +76,8 @@ export class StreamConsumer implements Consumer {
   }
 
   public getConnectionInfo(): ConnectionInfo {
-    const { host, port, id, readable, localPort, ready } = this.connection.getConnectionInfo()
-    return { host, port, id, readable, localPort, ready }
+    const { host, port, id, readable, localPort, ready, vhost } = this.connection.getConnectionInfo()
+    return { host, port, id, readable, localPort, ready, vhost }
   }
 
   public get localOffset() {

src/publisher.ts

@@ -180,8 +180,8 @@ export class StreamPublisher implements Publisher {
   }
 
   public getConnectionInfo(): ConnectionInfo {
-    const { host, port, id, writable, localPort, ready } = this.connection.getConnectionInfo()
-    return { host, port, id, writable, localPort, ready }
+    const { host, port, id, writable, localPort, ready, vhost } = this.connection.getConnectionInfo()
+    return { host, port, id, writable, localPort, ready, vhost }
   }
 
   public on(event: "metadata_update", listener: MetadataUpdateListener): void

test/e2e/stream_cache.test.ts

@@ -81,10 +81,10 @@ describe("cache", () => {
     const publisher1 = await client.declarePublisher({
       stream: streamName,
     })
-    expect(publisher1.connection.params.vhost).eql("/")
+    expect(publisher1.getConnectionInfo().vhost).eql("/")
     const publisher2 = await client2.declarePublisher({
       stream: streamName,
     })
-    expect(publisher2.connection.params.vhost).eql(vhost1)
+    expect(publisher2.getConnectionInfo().vhost).eql(vhost1)
   })
 })