Update

client/js/src/video/types.ts

@@ -1,6 +1,5 @@
 /**
  * Type definitions for RobotHub TransportServer Video Client
- * ✅ Fully synchronized with server-side models.py
  */
 
 // ============= CORE TYPES =============

client/python/examples/basic_consumer.py

@@ -86,8 +86,8 @@ async def main():
         logger.info(f"Received {len(received_updates)} joint updates")
         logger.info(f"Received {len(received_states)} state syncs")
 
-    except Exception as e:
-        logger.exception(f"Error: {e}")
+    except Exception:
+        logger.exception("Exception: ")
     finally:
         # Always disconnect
         if consumer.is_connected():

client/python/examples/basic_producer.py

@@ -76,8 +76,8 @@ async def main():
 
         logger.info("Example completed successfully!")
 
-    except Exception as e:
-        logger.exception(f"Error: {e}")
+    except Exception:
+        logger.exception("Error")
     finally:
         # Always disconnect and cleanup
         if producer.is_connected():
@@ -89,8 +89,8 @@ async def main():
             try:
                 await producer.delete_room(workspace_id, room_id)
                 logger.info("Room cleaned up")
-            except Exception as e:
-                logger.warning(f"Failed to clean up room: {e}")
+            except Exception:
+                logger.exception("Failed to clean up room")
 
 
 if __name__ == "__main__":

client/python/examples/consumer_first_recorder.py

@@ -122,8 +122,8 @@ class VideoRecorder:
                     f"🎬 Recording: {elapsed:.1f}s / {self.duration_seconds}s ({remaining:.1f}s remaining)"
                 )
 
-        except Exception as e:
-            logger.exception(f"❌ Error adding frame to recording: {e}")
+        except Exception:
+            logger.exception("❌ Error adding frame to recording")
 
         return False
 
@@ -291,11 +291,8 @@ async def main():
         else:
             logger.warning("⚠️ No recording was made - producer may not have joined")
 
-    except Exception as e:
-        logger.exception(f"❌ Consumer-first recorder failed: {e}")
-        import traceback
-
-        traceback.print_exc()
+    except Exception:
+        logger.exception("❌ Consumer-first recorder failed")
 
     finally:
         # Cleanup
@@ -309,12 +306,12 @@ async def main():
                 try:
                     await consumer.delete_room(workspace_id, room_id)
                     logger.info("🗑️ Room cleaned up")
-                except Exception as e:
-                    logger.warning(f"Failed to clean up room: {e}")
+                except Exception:
+                    logger.exception("Failed to clean up room")
 
             logger.info("👋 Consumer disconnected successfully")
-        except Exception as e:
-            logger.exception(f"Error during cleanup: {e}")
+        except Exception:
+            logger.exception("Error during cleanup")
 
 
 if __name__ == "__main__":
@@ -323,8 +320,5 @@ if __name__ == "__main__":
     except KeyboardInterrupt:
         logger.info("🛑 Stopped by user")
         logger.info("👋 Goodbye!")
-    except Exception as e:
-        logger.exception(f"💥 Fatal error: {e}")
-        import traceback
-
-        traceback.print_exc()
+    except Exception:
+        logger.exception("💥 Fatal error")

client/python/examples/context_manager_example.py

@@ -45,8 +45,8 @@ async def basic_context_manager_example():
         try:
             # This might fail if room doesn't exist
             await producer.send_joint_update([{"name": "invalid", "value": 999.0}])
-        except Exception as e:
-            logger.warning(f"Handled exception: {e}")
+        except Exception:
+            logger.exception("Handled exception")
 
         # Clean up room before context exit
         await producer.delete_room(workspace_id, room_id)
@@ -118,8 +118,8 @@ async def exception_handling_example():
                 logger.info(f"Sent update {i}")
                 await asyncio.sleep(0.1)
 
-    except ValueError as e:
-        logger.exception(f"Caught expected error: {e}")
+    except ValueError:
+        logger.exception("Caught expected error")
         logger.info("Context manager still ensures cleanup")
 
     # Clean up room after exception
@@ -128,8 +128,8 @@ async def exception_handling_example():
             temp_producer = RoboticsProducer("http://localhost:8000")
             await temp_producer.delete_room(workspace_id, room_id)
             logger.info("Room cleaned up after exception")
-        except Exception as e:
-            logger.warning(f"Failed to clean up room: {e}")
+        except Exception:
+            logger.exception("Failed to clean up room")
 
     logger.info("Exception handling example completed")
 
@@ -185,8 +185,8 @@ async def multiple_clients_example():
             temp_producer = RoboticsProducer("http://localhost:8000")
             await temp_producer.delete_room(workspace_id, room_id)
             logger.info("Room cleaned up")
-        except Exception as e:
-            logger.warning(f"Failed to clean up room: {e}")
+        except Exception:
+            logger.exception("Failed to clean up room")
 
     logger.info("Multiple clients example completed")
 
@@ -203,8 +203,8 @@ async def main():
 
         logger.info("\n✅ All context manager examples completed successfully!")
 
-    except Exception as e:
-        logger.exception(f"❌ Example failed: {e}")
+    except Exception:
+        logger.exception("❌ Example failed")
 
 
 if __name__ == "__main__":

client/python/examples/producer_consumer_demo.py

@@ -97,7 +97,7 @@ async def simulate_robot_movement(producer: RoboticsProducer):
     for step in range(20):  # 20 movement steps
         # Occasionally set new random targets
         if step % 5 == 0:
-            for joint_name, joint_data in joints.items():
+            for joint_data in joints.values():
                 joint_data["target"] = random.uniform(
                     joint_data["min"], joint_data["max"]
                 )
@@ -203,8 +203,8 @@ async def main():
 
         logger.info("Demo completed successfully!")
 
-    except Exception as e:
-        logger.exception(f"Demo error: {e}")
+    except Exception:
+        logger.exception("Demo error")
     finally:
         # Cleanup
         logger.info("Cleaning up...")
@@ -222,8 +222,8 @@ async def main():
             try:
                 await producer.delete_room(workspace_id, room_id)
                 logger.info("Room cleaned up")
-            except Exception as e:
-                logger.warning(f"Failed to clean up room: {e}")
+            except Exception:
+                logger.exception("Failed to clean up room")
 
         logger.info("Demo cleanup completed")
 

client/python/examples/room_management.py

@@ -27,7 +27,7 @@ async def main():
 
     try:
         # Generate a workspace ID for this demo
-        workspace_id = client._generate_workspace_id()
+        workspace_id = client.generate_workspace_id()
         logger.info(f"Using workspace: {workspace_id}")
 
         # List existing rooms in this workspace
@@ -93,8 +93,8 @@ async def main():
 
         logger.info("\nRoom management example completed!")
 
-    except Exception as e:
-        logger.exception(f"Error: {e}")
+    except Exception:
+        logger.exception("Error")
 
 
 if __name__ == "__main__":

client/python/examples/video_consumer_example.py

@@ -80,8 +80,8 @@ class VideoFrameHandler:
 
                 self.last_log_time = current_time
 
-        except Exception as e:
-            logger.exception(f"❌ Error handling frame {self.frame_count}: {e}")
+        except Exception:
+            logger.exception(f"❌ Error handling frame {self.frame_count}")
 
 
 async def main():

client/python/examples/video_producer_example.py

@@ -242,8 +242,8 @@ async def screen_share_example():
         # Share for demo duration
         await asyncio.sleep(20)
 
-    except Exception as e:
-        logger.exception(f"❌ Screen share error: {e}")
+    except Exception:
+        logger.exception("❌ Screen share error")
     finally:
         if "producer" in locals():
             await producer.disconnect()
@@ -251,8 +251,8 @@ async def screen_share_example():
                 try:
                     await producer.delete_room(workspace_id, room_id)
                     logger.info("🗑️ Room cleaned up")
-                except Exception as e:
-                    logger.warning(f"Failed to clean up room: {e}")
+                except Exception:
+                    logger.exception("Failed to clean up room")
 
 
 if __name__ == "__main__":

client/python/src/transport_server_client/client.py

@@ -47,7 +47,7 @@ class RoboticsClientCore:
     ) -> tuple[str, str]:
         """Create a new room and return (workspace_id, room_id)"""
         # Generate workspace ID if not provided
-        final_workspace_id = workspace_id or self._generate_workspace_id()
+        final_workspace_id = workspace_id or self.generate_workspace_id()
 
         payload = {}
         if room_id:
@@ -304,7 +304,7 @@ class RoboticsClientCore:
 
     # ============= WORKSPACE HELPERS =============
 
-    def _generate_workspace_id(self) -> str:
+    def generate_workspace_id(self) -> str:
         """Generate a UUID-like workspace ID"""
         import uuid
 

client/python/src/transport_server_client/video/core.py

@@ -122,7 +122,7 @@ class VideoClientCore:
     ) -> tuple[str, str]:
         """Create a new room and return (workspace_id, room_id)"""
         # Generate workspace ID if not provided
-        final_workspace_id = workspace_id or self._generate_workspace_id()
+        final_workspace_id = workspace_id or self.generate_workspace_id()
 
         payload = {}
         if room_id:
@@ -726,7 +726,7 @@ class VideoClientCore:
 
     # ============= WORKSPACE HELPERS =============
 
-    def _generate_workspace_id(self) -> str:
+    def generate_workspace_id(self) -> str:
         """Generate a UUID-like workspace ID"""
         import uuid
 

client/python/tests/test_rest_api.py

@@ -17,7 +17,7 @@ class TestRestAPI:
     async def test_list_rooms_empty(self, producer):
         """Test listing rooms when no rooms exist."""
         # Use a temporary workspace ID
-        workspace_id = producer._generate_workspace_id()
+        workspace_id = producer.generate_workspace_id()
         rooms = await producer.list_rooms(workspace_id)
         assert isinstance(rooms, list)
 
@@ -129,7 +129,7 @@ class TestRestAPI:
     @pytest.mark.asyncio
     async def test_delete_nonexistent_room(self, producer):
         """Test deleting a room that doesn't exist."""
-        workspace_id = producer._generate_workspace_id()
+        workspace_id = producer.generate_workspace_id()
         fake_room_id = "nonexistent-room-id"
         success = await producer.delete_room(workspace_id, fake_room_id)
         assert success is False
@@ -137,7 +137,7 @@ class TestRestAPI:
     @pytest.mark.asyncio
     async def test_get_room_info_nonexistent(self, producer):
         """Test getting info for a room that doesn't exist."""
-        workspace_id = producer._generate_workspace_id()
+        workspace_id = producer.generate_workspace_id()
         fake_room_id = "nonexistent-room-id"
 
         # This should raise an exception or return error info
@@ -151,7 +151,7 @@ class TestRestAPI:
     @pytest.mark.asyncio
     async def test_get_room_state_nonexistent(self, producer):
         """Test getting state for a room that doesn't exist."""
-        workspace_id = producer._generate_workspace_id()
+        workspace_id = producer.generate_workspace_id()
         fake_room_id = "nonexistent-room-id"
 
         # This should raise an exception or return error info