1 files changed, 41 insertions, 3 deletions
diff --git a/packages/meshbay-hub/src/meshbay_hub/static/platform.js b/packages/meshbay-hub/src/meshbay_hub/static/platform.js
index 19f12a6..c131495 100644
--- a/packages/meshbay-hub/src/meshbay_hub/static/platform.js
+++ b/packages/meshbay-hub/src/meshbay_hub/static/platform.js
@@ -430,6 +430,8 @@ export async function waitForRootsIndexed(groupId, onProgress,
  * Absent in a browser, where the relay cannot run: there is no main process
  * to bind a server socket in, and a page cannot open one.
  */
+const CAST_POLL_MS = 250;
+
 export const cast = {
   available: Boolean(bridge && bridge.cast),
   async start(opts) {
@@ -456,9 +458,32 @@ export const cast = {
     if (!bridge || !bridge.cast) return null;
     return bridge.cast.status();
   },
-  async discover() {
-    if (!bridge || !bridge.cast) return [];
-    return bridge.cast.discover();
+  // Lists receivers as they answer rather than at the end of the scan: most
+  // answer within two seconds, and the scan runs on for the ones coming back
+  // from a reset. `onUpdate(devices, scanning)` is called on each poll until
+  // the scan ends; the returned function stops it being called at all.
+  discover(onUpdate) {
+    if (!bridge || !bridge.cast) {
+      onUpdate([], false);
+      return () => {};
+    }
+    let stopped = false;
+    let timer = null;
+    const poll = async () => {
+      const snap = await bridge.cast.devices().catch(() => null);
+      if (stopped) return;
+      if (!snap) {
+        onUpdate([], false);
+        return;
+      }
+      onUpdate(snap.devices, snap.scanning);
+      if (snap.scanning) timer = setTimeout(poll, CAST_POLL_MS);
+    };
+    bridge.cast.scan().then(poll, () => { if (!stopped) onUpdate([], false); });
+    return () => {
+      stopped = true;
+      clearTimeout(timer);
+    };
   },
   async chromecastConnect(opts) {
     if (!bridge || !bridge.cast) return null;
@@ -472,6 +497,19 @@ export const cast = {
     if (!bridge || !bridge.cast) return false;
     return bridge.cast.chromecastDisconnect();
   },
+  // Remote control of the receiver. Absent from an older bridge, so callers
+  // check `canControl` rather than catching a TypeError.
+  get canControl() {
+    return Boolean(bridge && bridge.cast && bridge.cast.chromecastPause && bridge.cast.chromecastPlay);
+  },
+  async chromecastPause() {
+    if (!this.canControl) return null;
+    return bridge.cast.chromecastPause();
+  },
+  async chromecastPlay() {
+    if (!this.canControl) return null;
+    return bridge.cast.chromecastPlay();
+  },
 };
 
 /**