fix: casing issue with broadcast connection state

src/jdom/bus.ts

@@ -53,10 +53,10 @@ import {
     REGISTER_POLL_REPORT_VOLATILE_MAX_INTERVAL,
     REGISTER_POLL_REPORT_VOLATILE_INTERVAL,
     SRV_INFRASTRUCTURE,
-    CONNECTION_STATE,
     PACKET_RECEIVE_NO_DEVICE,
     FRAME_PROCESS,
     FRAME_SEND,
+    CONNECTION_STATE,
 } from "./constants"
 import { serviceClass } from "./pretty"
 import { JDNode } from "./node"
@@ -309,21 +309,6 @@ export class JDBus extends JDNode {
         // the purpose of this code is to orchestrate
         // interactions with multiple tabs and windows
         const channel = new BroadcastChannel("jacdac")
-        const postConnectionState = () => {
-            channel.postMessage({
-                id: this.selfDevice.shortId,
-                event: CONNECTION_STATE,
-                transports: this._transports.map(tr => ({
-                    type: tr.type,
-                    connectionState: tr.connectionState,
-                })),
-            })
-        }
-        // update other windows with connection status
-        const unsubConnectionState = this.subscribe(
-            CONNECTION_STATE,
-            postConnectionState
-        )
         this._postBroadcastMessage = (
             event: BusBroadcastMessageType,
             msg: Partial<BusBroadcastMessage>
@@ -336,8 +321,23 @@ export class JDBus extends JDNode {
             //console.debug(`jacdac broadcast: ${bmsg.event}`, bmsg)
             channel.postMessage(bmsg)
         }
+        const handleConnectionState = () => {
+            this._postBroadcastMessage?.("connectionstate", <
+                BusBroadcastConnectionStateMessage
+            >{
+                transports: this._transports.map(tr => ({
+                    type: tr.type,
+                    connectionState: tr.connectionState,
+                })),
+            })
+        }
+        // update other windows with connection status
+        const unsubConnectionState = this.subscribe(
+            CONNECTION_STATE,
+            handleConnectionState
+        )
         const handleVisibilityChange = () =>
-            this._postBroadcastMessage("visibilitychange", <
+            this._postBroadcastMessage?.("visibilitychange", <
                 BusBroadcastVisibilityChangeMessage
             >{
                 visibilityState: document.visibilityState,
@@ -381,7 +381,9 @@ export class JDBus extends JDNode {
                         )
                         .forEach(ctr => {
                             this.transports
-                                .filter(tr => tr.type === ctr.type)
+                                .filter(
+                                    tr => !tr.shared && tr.type === ctr.type
+                                )
                                 .forEach(tr => tr.disconnect())
                         })
                 }

src/jdom/transport/nodesocket.ts

@@ -18,6 +18,7 @@ class NodeSocketTransport extends Transport {
         options?: NodeSocketTransportOptions
     ) {
         super(NODESOCKET_TRANSPORT, options)
+        this.shared = true;
     }
 
     protected transportConnectAsync(background?: boolean): Promise<void> {

src/jdom/transport/nodespi.ts

@@ -74,6 +74,7 @@ class SpiTransport extends Transport {
         readonly options: SpiTransportOptions
     ) {
         super("spi", options)
+        this.shared = true
         this.handleRxPinRising = this.handleRxPinRising.bind(this)
         this.handleTxPinRising = this.handleTxPinRising.bind(this)
 

src/jdom/transport/transport.ts

@@ -87,6 +87,11 @@ export abstract class Transport extends JDEventSource {
         ].filter(c => !!c)
     }
 
+    /**
+     * Allows multiple clients
+     */
+    shared: boolean;
+
     get bus() {
         return this._bus
     }

src/jdom/transport/websockettransport.ts

@@ -31,6 +31,7 @@ export class WebSocketTransport extends Transport {
 
     constructor(readonly url: string, options?: WebSocketTransportOptions) {
         super(WEBSOCKET_TRANSPORT, options)
+        this.shared = true
         this.protocols = options?.protocols
         this.on(FRAME_SEND_DISCONNECT, this.handleSendDisconnect.bind(this))
     }

src/jdom/transport/workertransport.ts

@@ -27,9 +27,11 @@ class WorkerTransport extends Transport {
         public readonly worker: Worker,
         public readonly options: {
             requestDevice: () => Promise<string>
+            shared: boolean
         } & TransportOptions
     ) {
         super(type, options)
+        this.shared = options.shared
         this.worker.addEventListener("message", this.handleMessage.bind(this))
     }
 
@@ -119,6 +121,7 @@ export function createUSBWorkerTransport(worker: Worker) {
         isWebUSBEnabled() &&
         new WorkerTransport(USB_TRANSPORT, worker, {
             checkPulse: true,
+            shared: false,
             requestDevice: () =>
                 usbRequestDevice(USB_FILTERS).then(dev => dev?.serialNumber),
             connectObservable: new EventTargetObservable(