Merge pull request #457 from dora-rs/update-ros2-client

Update `ros2-client` to latest version

examples/rust-ros2-dataflow/node/src/main.rs

@@ -25,7 +25,9 @@ fn main() -> eyre::Result<()> {
 
     // spawn a background spinner task that is handles service discovery (and other things)
     let pool = futures::executor::ThreadPool::new()?;
-    let spinner = ros_node.spinner();
+    let spinner = ros_node
+        .spinner()
+        .map_err(|e| eyre::eyre!("failed to create spinner: {e:?}"))?;
     pool.spawn(async {
         if let Err(err) = spinner.spin().await {
             eprintln!("ros2 spinner failed: {err:?}");
@@ -150,7 +152,7 @@ async fn add_two_ints_request(
 
     let response = add_client.async_receive_response(request_id);
     futures::pin_mut!(response);
-    let timeout = futures_timer::Delay::new(Duration::from_secs(5));
+    let timeout = futures_timer::Delay::new(Duration::from_secs(15));
     match futures::future::select(response, timeout).await {
         futures::future::Either::Left((Ok(response), _)) => {
             println!("received response: {response:?}");
@@ -172,7 +174,7 @@ fn init_ros_node() -> eyre::Result<ros2_client::Node> {
                 .map_err(|e| eyre!("failed to create ROS2 node name: {e}"))?,
             NodeOptions::new().enable_rosout(true),
         )
-        .context("failed to create ros2 node")
+        .map_err(|e| eyre::eyre!("failed to create ros2 node: {e:?}"))
 }
 
 fn create_vel_publisher(

libraries/extensions/ros2-bridge/Cargo.toml

@@ -17,8 +17,8 @@ array-init = "2.1.0"
 serde = { version = "1.0.164", features = ["derive"] }
 serde-big-array = "0.5.1"
 widestring = "1.0.2"
-ros2-client = { git = "https://github.com/dora-rs/ros2-client.git", branch = "deserialize-seed-2" }
-rustdds = { git = "https://github.com/dora-rs/RustDDS.git", branch = "deserialize-seed-2" }
+ros2-client = "0.7.1"
+rustdds = "0.10.0"
 eyre = { version = "0.6.8", optional = true }
 tokio = { version = "1.29.1", features = ["full"], optional = true }
 dora-daemon = { path = "../../../binaries/daemon", optional = true }

libraries/extensions/ros2-bridge/msg-gen/src/lib.rs

@@ -126,9 +126,10 @@ where
 
                         let name = ros2_client::NodeName::new(name_space, base_name).map_err(|e| eyre::eyre!(e))?;
                         let options = ros2_client::NodeOptions::new().enable_rosout(true);
-                        let mut node = self.context.new_node(name, options)?;
+                        let mut node = self.context.new_node(name, options)
+                            .map_err(|e| eyre::eyre!("failed to create ROS2 node: {e:?}"))?;
 
-                        let spinner = node.spinner();
+                        let spinner = node.spinner().context("failed to create spinner")?;
                         self.executor.spawn(async {
                             if let Err(err) = spinner.spin().await {
                                 eprintln!("ros2 spinner failed: {err:?}");

libraries/extensions/ros2-bridge/python/src/lib.rs

@@ -81,7 +81,10 @@ impl Ros2Context {
         let name = ros2_client::NodeName::new(namespace, name)
             .map_err(|err| eyre!("invalid node name: {err}"))?;
         Ok(Ros2Node {
-            node: self.context.new_node(name, options.into())?,
+            node: self
+                .context
+                .new_node(name, options.into())
+                .map_err(|e| eyre::eyre!("failed to create ROS2 node: {e:?}"))?,
             messages: self.messages.clone(),
         })
     }