Add exponential backoff to all WebSocket clients; update setup step to mention dashboard login

index.html

@@ -70,7 +70,7 @@
 						<li><strong>Create a Hugging Face account</strong> (free) at <a href="https://huggingface.co/join" target="_blank" style="color: #10b981; text-decoration: underline;">huggingface.co/join</a></li>
 						<li><strong>Create an access token</strong> at <a href="https://huggingface.co/settings/tokens" target="_blank" style="color: #10b981; text-decoration: underline;">huggingface.co/settings/tokens</a> with 'read' permissions</li>
 						<li><strong>Install this app</strong> on your Reachy Mini robot</li>
-						<li><strong>Set your token:</strong> Open the app's settings page on your robot and paste your access token</li>
+						<li><strong>Log in to HuggingFace:</strong> Open the robot dashboard or desktop app and sign in with your HuggingFace account — the token is picked up automatically</li>
 						<li><strong>Open the control interface</strong> in your browser and sign in with your Hugging Face account: <a href="https://huggingfacem4-reachy-mini-remote-control.hf.space" target="_blank" style="color: #10b981; text-decoration: underline;">huggingfacem4-reachy-mini-remote-control.hf.space</a></li>
 						<li><strong>Start controlling!</strong> Your robot should appear connected in the interface</li>
 					</ol>

src/reachy_mini_remote_control_app/websocket_clients/audio_stream.py

@@ -67,6 +67,7 @@ class AsyncWebSocketAudioStreamer:
 
     async def _run(self) -> None:
         """Run the main reconnect loop."""
+        retry_delay = 1.0
         while not self.stop_flag:
             try:
                 # Add authentication header if token is provided
@@ -80,6 +81,7 @@ class AsyncWebSocketAudioStreamer:
                 ) as ws:
                     logger.info("[Audio Stream] Connected to remote server")
                     self.connected.set()
+                    retry_delay = 1.0  # Reset backoff on successful connection
 
                     # Update connection status
                     if self.monitor:
@@ -103,13 +105,14 @@ class AsyncWebSocketAudioStreamer:
                             pass
 
             except Exception as e:
-                logger.info(f"[Audio Stream] Connection failed: {e}")
+                logger.info(f"[Audio Stream] Connection failed: {e} (retrying in {retry_delay:.0f}s)")
 
                 # Update connection status
                 if self.monitor:
                     self.monitor.update_audio_metrics(connected=False)
 
-                await asyncio.sleep(1.0)
+                await asyncio.sleep(retry_delay)
+                retry_delay = min(retry_delay * 2, 60.0)
 
             self.connected.clear()
 

src/reachy_mini_remote_control_app/websocket_clients/robot_control.py

@@ -101,6 +101,7 @@ class AsyncWebSocketController:
 
     async def _run(self) -> None:
         """Run the WebSocket controller loop with automatic reconnection."""
+        retry_delay = 1.0
         while not self.stop_flag:
             try:
                 ws: ClientConnection
@@ -116,6 +117,7 @@ class AsyncWebSocketController:
                     additional_headers=extra_headers if extra_headers else None,
                 ) as ws:
                     logger.info("[Robot Control] Connected to remote server")
+                    retry_delay = 1.0  # Reset backoff on successful connection
 
                     # Update connection status
                     if self.monitor:
@@ -133,14 +135,14 @@ class AsyncWebSocketController:
                         await self.on_command(data)
 
             except Exception as e:
-                logger.info("[Robot Control] Connection failed: %s", e)
+                logger.info("[Robot Control] Connection failed: %s (retrying in %.0fs)", e, retry_delay)
 
                 # Update connection status
                 if self.monitor:
                     self.monitor.update_control_metrics(connected=False)
 
-                # Backoff before reconnect
-                await asyncio.sleep(1)
+                await asyncio.sleep(retry_delay)
+                retry_delay = min(retry_delay * 2, 60.0)
 
     def stop(self) -> None:
         """Stop the WebSocket controller."""

src/reachy_mini_remote_control_app/websocket_clients/robot_state.py

@@ -80,6 +80,7 @@ class AsyncWebSocketRobotStatePublisher:
     async def _run(self) -> None:
         """Run the WebSocket robot state publisher loop with automatic reconnection."""
         interval = 1.0 / self.update_rate
+        retry_delay = 1.0
 
         while not self.stop_flag:
             try:
@@ -100,6 +101,7 @@ class AsyncWebSocketRobotStatePublisher:
                         f"[Robot State] Connected to remote server, publishing at {self.update_rate} Hz"
                     )
                     self.connected.set()
+                    retry_delay = 1.0  # Reset backoff on successful connection
 
                     # Update connection status
                     if self.monitor:
@@ -123,24 +125,15 @@ class AsyncWebSocketRobotStatePublisher:
                             logger.error(f"[Robot State] Send error: {e}")
                             break
 
-            except ConnectionClosed as e:
-                logger.error(f"[Robot State] Connection lost ({type(e).__name__}). Retrying...")
-                self.connected.clear()
-
-                # Update connection status
-                if self.monitor:
-                    self.monitor.update_control_metrics(connected=False)
-
-                await asyncio.sleep(0.5)
-
             except Exception as e:
-                logger.error(f"[Robot State] Unexpected error: {e}")
+                logger.error(f"[Robot State] Connection error: {e} (retrying in {retry_delay:.0f}s)")
 
                 # Update connection status
                 if self.monitor:
                     self.monitor.update_control_metrics(connected=False)
 
-                await asyncio.sleep(1)
+                await asyncio.sleep(retry_delay)
+                retry_delay = min(retry_delay * 2, 60.0)
 
             self.connected.clear()
 

src/reachy_mini_remote_control_app/websocket_clients/video_stream.py

@@ -70,6 +70,7 @@ class AsyncWebSocketFrameSender:
 
     async def _run(self) -> None:
         """Run the WebSocket frame sender loop with automatic reconnection."""
+        retry_delay = 1.0
         while not self.stop_flag:
             try:
                 ws: ClientConnection
@@ -88,6 +89,7 @@ class AsyncWebSocketFrameSender:
                     logger.info("[Video Stream] Connected to remote server")
                     self.connected.set()
                     self._clear_queue()
+                    retry_delay = 1.0  # Reset backoff on successful connection
 
                     # Update connection status
                     if self.monitor:
@@ -113,25 +115,15 @@ class AsyncWebSocketFrameSender:
                             logger.error(f"[Video Stream] Send error: {e}")
                             break
 
-            except ConnectionClosed as e:
-                logger.error(f"[Video Stream] Connection lost ({type(e).__name__}). Retrying...")
-                self.connected.clear()
-                self._last_frame = None
-
-                # Update connection status
-                if self.monitor:
-                    self.monitor.update_video_metrics(connected=False)
-
-                await asyncio.sleep(0.5)
-
             except Exception as e:
-                logger.error(f"[Video Stream] Unexpected error: {e}")
+                logger.error(f"[Video Stream] Connection error: {e} (retrying in {retry_delay:.0f}s)")
 
                 # Update connection status
                 if self.monitor:
                     self.monitor.update_video_metrics(connected=False)
 
-                await asyncio.sleep(1)
+                await asyncio.sleep(retry_delay)
+                retry_delay = min(retry_delay * 2, 60.0)
 
             self.connected.clear()
             self._last_frame = None