Skip to content

Commit 8c08dd7

Browse files
committed
Added support for NonKeyedWithNestedKey.
Signed-off-by: Miguel Company <[email protected]>
1 parent c976fe0 commit 8c08dd7

File tree

5 files changed

+31
-0
lines changed

5 files changed

+31
-0
lines changed

test_communication/test/subscribe_key_types.cpp

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
#include "rclcpp/rclcpp.hpp"
1919
#include "test_msgs/msg/keyed_string.hpp"
20+
#include "test_msgs/msg/non_keyed_with_nested_key.hpp"
2021

2122
#include "subscribe_helper.hpp"
2223
#include "subscribe_key_types.hpp"
@@ -30,3 +31,13 @@ rclcpp::SubscriptionBase::SharedPtr subscribe_keyed_string(
3031
return subscribe<test_msgs::msg::KeyedString>(
3132
node, message_type, expected_messages, received_messages);
3233
}
34+
35+
rclcpp::SubscriptionBase::SharedPtr subscribe_non_keyed_with_nested_key(
36+
rclcpp::Node::SharedPtr node,
37+
const std::string & message_type,
38+
const std::vector<test_msgs::msg::NonKeyedWithNestedKey::SharedPtr> & expected_messages,
39+
std::vector<bool> & received_messages)
40+
{
41+
return subscribe<test_msgs::msg::NonKeyedWithNestedKey>(
42+
node, message_type, expected_messages, received_messages);
43+
}

test_communication/test/subscribe_key_types.hpp

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,11 +20,18 @@
2020

2121
#include "rclcpp/rclcpp.hpp"
2222
#include "test_msgs/msg/keyed_string.hpp"
23+
#include "test_msgs/msg/non_keyed_with_nested_key.hpp"
2324

2425
rclcpp::SubscriptionBase::SharedPtr subscribe_keyed_string(
2526
rclcpp::Node::SharedPtr node,
2627
const std::string & message_type,
2728
const std::vector<test_msgs::msg::KeyedString::SharedPtr> & expected_messages,
2829
std::vector<bool> & received_messages);
2930

31+
rclcpp::SubscriptionBase::SharedPtr subscribe_non_keyed_with_nested_key(
32+
rclcpp::Node::SharedPtr node,
33+
const std::string & message_type,
34+
const std::vector<test_msgs::msg::NonKeyedWithNestedKey::SharedPtr> & expected_messages,
35+
std::vector<bool> & received_messages);
36+
3037
#endif // SUBSCRIBE_KEY_TYPES_HPP_

test_communication/test/test_publisher.cpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,9 @@ int main(int argc, char ** argv)
109109
publish<test_msgs::msg::WStrings>(node, message, get_messages_wstrings());
110110
} else if (message == "KeyedString") {
111111
publish<test_msgs::msg::KeyedString>(node, message, get_messages_keyed_string());
112+
} else if (message == "NonKeyedWithNestedKey") {
113+
publish<test_msgs::msg::NonKeyedWithNestedKey>(
114+
node, message, get_messages_non_keyed_with_nested_key());
112115
} else {
113116
fprintf(stderr, "Unknown message argument '%s'\n", message.c_str());
114117
rclcpp::shutdown();

test_communication/test/test_publisher_subscriber.cpp

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -100,6 +100,7 @@ int main(int argc, char ** argv)
100100
auto messages_strings = get_messages_strings();
101101
auto messages_wstrings = get_messages_wstrings();
102102
auto messages_keyed_string = get_messages_keyed_string();
103+
auto messages_non_keyed_with_nested_key = get_messages_non_keyed_with_nested_key();
103104

104105
std::thread spin_thread([node]() {
105106
rclcpp::spin(node);
@@ -153,6 +154,11 @@ int main(int argc, char ** argv)
153154
} else if (message == "KeyedString") {
154155
subscriber = subscribe_keyed_string(node, message, messages_keyed_string, received_messages);
155156
publish<test_msgs::msg::KeyedString>(node, message, messages_keyed_string);
157+
} else if (message == "NonKeyedWithNestedKey") {
158+
subscriber = subscribe_non_keyed_with_nested_key(
159+
node, message, messages_non_keyed_with_nested_key, received_messages);
160+
publish<test_msgs::msg::NonKeyedWithNestedKey>(
161+
node, message, messages_non_keyed_with_nested_key);
156162
} else {
157163
fprintf(stderr, "Unknown message argument '%s'\n", message.c_str());
158164
return 1;

test_communication/test/test_subscriber.cpp

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,7 @@ int main(int argc, char ** argv)
5555
auto messages_strings = get_messages_strings();
5656
auto messages_wstrings = get_messages_wstrings();
5757
auto messages_keyed_string = get_messages_keyed_string();
58+
auto messages_non_keyed_with_nested_key = get_messages_non_keyed_with_nested_key();
5859

5960
rclcpp::SubscriptionBase::SharedPtr subscriber;
6061
std::vector<bool> received_messages; // collect flags about received messages
@@ -89,6 +90,9 @@ int main(int argc, char ** argv)
8990
subscriber = subscribe_wstrings(node, message, messages_wstrings, received_messages);
9091
} else if (message == "KeyedString") {
9192
subscriber = subscribe_keyed_string(node, message, messages_keyed_string, received_messages);
93+
} else if (message == "NonKeyedWithNestedKey") {
94+
subscriber = subscribe_non_keyed_with_nested_key(
95+
node, message, messages_non_keyed_with_nested_key, received_messages);
9296
} else {
9397
fprintf(stderr, "Unknown message argument '%s'\n", message.c_str());
9498
rclcpp::shutdown();

0 commit comments

Comments
 (0)