fix: added extra vendorized messages

Signed-off-by: Esteve Fernandez <[email protected]>

Author: esteve

rclrs/src/client.rs

@@ -162,7 +162,9 @@ where
     /// # let node = Context::default()
     /// #   .create_basic_executor()
     /// #   .create_node("test_node")?;
-    /// use test_msgs::srv::{Empty, Empty_Request, Empty_Response};
+    /// # The following line of code is only needed for rclrs internal purposes,
+    /// # please use the test_msgs crate instead.
+    /// use vendor::test_msgs::srv::{Empty, Empty_Request, Empty_Response};
     ///
     /// async fn print_hello(_response: Empty_Response) {
     ///     print!("Hello!");
@@ -191,7 +193,9 @@ where
     /// # let node = Context::default()
     /// #   .create_basic_executor()
     /// #   .create_node("test_node")?;
-    /// use test_msgs::srv::{Empty, Empty_Request, Empty_Response};
+    /// # The following line of code is only needed for rclrs internal purposes,
+    /// # please use the test_msgs crate instead.
+    /// use vendor::test_msgs::srv::{Empty, Empty_Request, Empty_Response};
     ///
     /// fn print_greeting(_response: Empty_Response) -> impl Future<Output=()> {
     ///     let greeting = "Hello!";
@@ -219,7 +223,9 @@ where
     /// # let node = Context::default()
     /// #   .create_basic_executor()
     /// #   .create_node("test_node")?;
-    /// use test_msgs::srv::{Empty, Empty_Request, Empty_Response};
+    /// # The following line of code is only needed for rclrs internal purposes,
+    /// # please use the test_msgs crate instead.
+    /// use vendor::test_msgs::srv::{Empty, Empty_Request, Empty_Response};
     ///
     /// let greeting = "Hello!";
     /// let client = node.create_client::<Empty>("my_service")?;
@@ -568,7 +574,7 @@ unsafe impl Send for rcl_client_t {}
 mod tests {
     use super::*;
     use crate::test_helpers::*;
-    use test_msgs::srv;
+    use crate::vendor::test_msgs::srv;
 
     #[test]
     fn traits() {

rclrs/src/lib.rs

@@ -36,6 +36,9 @@
 //! let context = Context::default_from_env()?;
 //! let mut executor = context.create_basic_executor();
 //! let node = executor.create_node("example_node")?;
+//! # The following line of code is only needed for rclrs internal purposes,
+//! # please use the example_interfaces crate instead.
+//! use vendor::example_interfaces;
 //!
 //! let subscription = node.create_subscription(
 //!     "topic_name",

rclrs/src/node.rs

@@ -662,6 +662,9 @@ impl NodeState {
     /// # use rclrs::*;
     /// # let executor = Context::default().create_basic_executor();
     /// # let node = executor.create_node("my_node").unwrap();
+    /// # The following line of code is only needed for rclrs internal purposes,
+    /// # please use the test_msgs crate instead.
+    /// use vendor::test_msgs;
     /// let subscription = node.create_subscription(
     ///     "my_topic",
     ///     |_msg: test_msgs::msg::Empty| {
@@ -677,6 +680,9 @@ impl NodeState {
     /// # use rclrs::*;
     /// # let executor = Context::default().create_basic_executor();
     /// # let node = executor.create_node("my_node").unwrap();
+    /// # The following line of code is only needed for rclrs internal purposes,
+    /// # please use the test_msgs crate instead.
+    /// use vendor::test_msgs;
     /// let subscription = node.create_subscription(
     ///     "my_topic"
     ///     .keep_last(100)
@@ -1094,7 +1100,7 @@ mod tests {
 
     #[test]
     fn test_topic_names_and_types() -> Result<(), RclrsError> {
-        use test_msgs::msg;
+        use crate::vendor::test_msgs::msg;
 
         let graph = construct_test_graph("test_topics_graph")?;
 

rclrs/src/publisher.rs

@@ -337,14 +337,15 @@ mod tests {
 
     #[test]
     fn traits() {
+        use crate::vendor::test_msgs;
         assert_send::<Publisher<test_msgs::msg::BoundedSequences>>();
         assert_sync::<Publisher<test_msgs::msg::BoundedSequences>>();
     }
 
     #[test]
     fn test_publishers() -> Result<(), RclrsError> {
         use crate::TopicEndpointInfo;
-        use test_msgs::msg;
+        use crate::vendor::test_msgs::msg;
 
         let namespace = "/test_publishers_graph";
         let graph = construct_test_graph(namespace)?;

rclrs/src/publisher/loaned_message.rs

@@ -99,6 +99,7 @@ mod tests {
     #[test]
     fn traits() {
         use crate::test_helpers::*;
+        use crate::vendor::test_msgs;
 
         assert_send::<LoanedMessage<test_msgs::msg::rmw::BoundedSequences>>();
         assert_sync::<LoanedMessage<test_msgs::msg::rmw::BoundedSequences>>();

rclrs/src/service.rs

@@ -393,14 +393,15 @@ mod tests {
 
     #[test]
     fn traits() {
+        use crate::vendor::test_msgs;
         assert_send::<Service<test_msgs::srv::Arrays>>();
         assert_sync::<Service<test_msgs::srv::Arrays>>();
     }
 
     #[test]
     fn test_services() -> Result<(), RclrsError> {
         use crate::TopicNamesAndTypes;
-        use test_msgs::srv;
+        use crate::vendor::test_msgs::srv;
 
         let namespace = "/test_services_graph";
         let graph = construct_test_graph(namespace)?;

rclrs/src/subscription.rs

@@ -412,7 +412,7 @@ impl Drop for SubscriptionHandle {
 mod tests {
     use super::*;
     use crate::test_helpers::*;
-    use test_msgs::msg;
+    use crate::vendor::test_msgs::msg;
 
     #[test]
     fn traits() {
@@ -524,7 +524,7 @@ mod tests {
     #[test]
     fn test_delayed_subscription() {
         use crate::*;
-        use example_interfaces::msg::Empty;
+        use crate::vendor::example_interfaces::msg::Empty;
         use futures::{
             channel::{mpsc, oneshot},
             StreamExt,

rclrs/src/subscription/into_async_subscription_callback.rs

@@ -103,7 +103,7 @@ where
 mod tests {
     use super::*;
 
-    type TestMessage = test_msgs::msg::BoundedSequences;
+    type TestMessage = crate::vendor::test_msgs::msg::BoundedSequences;
 
     #[test]
     fn callback_conversion() {

rclrs/src/subscription/into_node_subscription_callback.rs

@@ -131,7 +131,7 @@ where
 mod tests {
     use super::*;
 
-    type TestMessage = test_msgs::msg::BoundedSequences;
+    type TestMessage = crate::vendor::test_msgs::msg::BoundedSequences;
 
     #[test]
     fn callback_conversion() {

rclrs/src/subscription/readonly_loaned_message.rs

@@ -61,6 +61,7 @@ mod tests {
     #[test]
     fn traits() {
         use crate::test_helpers::*;
+        use crate::vendor::test_msgs;
 
         assert_send::<ReadOnlyLoanedMessage<test_msgs::msg::rmw::BoundedSequences>>();
         assert_sync::<ReadOnlyLoanedMessage<test_msgs::msg::rmw::BoundedSequences>>();