Fix integration tests to use new parameter storage

.github/workflows/ci.yaml

@@ -51,4 +51,4 @@ jobs:
           colcon test
       - if: always()
         run: |
-          colcon test-result
+          colcon test-result --verbose

.gitignore

@@ -2,3 +2,5 @@
 build/
 install/
 log/
+
+**__pycache__

src/picknik_ur_studio_integration_testing/picknik_ur_studio_integration_testing/generate_agent_plus_drivers_launch_description.py

@@ -81,7 +81,7 @@ def generate_agent_plus_drivers_launch_description(
 
     # Get path to test objective directory defined within this repo
     test_objective_path = Path(
-        get_package_share_directory("moveit_studio_integration_testing"),
+        get_package_share_directory("picknik_ur_studio_integration_testing"),
         "test",
         "objectives",
     )
@@ -110,7 +110,7 @@ def generate_agent_plus_drivers_launch_description(
 
     # Get path to test objective directory defined within this repo
     test_objective_path = Path(
-        get_package_share_directory("moveit_studio_integration_testing"),
+        get_package_share_directory("picknik_ur_studio_integration_testing"),
         "test",
         "objectives",
     )

src/picknik_ur_studio_integration_testing/test/CMakeLists.txt

@@ -18,3 +18,10 @@ add_ros_test(launch/test_get_planning_groups.test.py TIMEOUT 120 ARGS "test_bina
 ament_add_gtest_executable(test_ur5e_pinch_p_stop test_ur5e_pinch_p_stop.cpp)
 target_link_libraries(test_ur5e_pinch_p_stop moveit_studio_agent::do_objective_test_fixture)
 add_ros_test(launch/test_ur5e_pinch_p_stop.test.py TIMEOUT 120 ARGS "test_binary_dir:=${CMAKE_CURRENT_BINARY_DIR}")
+
+# Install config files needed at runtime by integration tests
+install(
+  DIRECTORY
+    objectives
+  DESTINATION share/${PROJECT_NAME}/test
+)

src/picknik_ur_studio_integration_testing/test/launch/test_basic_ur5e_objectives.test.py

@@ -29,8 +29,6 @@
 # POSSIBILITY OF SUCH DAMAGE.
 
 
-import os
-import sys
 import unittest
 
 import launch_testing

src/picknik_ur_studio_integration_testing/test/launch/test_get_planning_groups.test.py

@@ -29,8 +29,6 @@
 # POSSIBILITY OF SUCH DAMAGE.
 
 
-import os
-import sys
 import unittest
 
 import launch_testing

src/picknik_ur_studio_integration_testing/test/launch/test_ur5e_pinch_p_stop.test.py

@@ -29,8 +29,6 @@
 # POSSIBILITY OF SUCH DAMAGE.
 
 
-import os
-import sys
 import unittest
 
 import launch_testing

src/picknik_ur_studio_integration_testing/test/test_basic_ur5e_objectives.cpp

@@ -28,22 +28,28 @@
 
 #include <moveit_studio_agent/test/do_objective_test_fixture.hpp>
 
+#include <chrono>
 #include <geometry_msgs/msg/point.hpp>
 #include <geometry_msgs/msg/pose_stamped.hpp>
 #include <geometry_msgs/msg/quaternion.hpp>
 #include <geometry_msgs/msg/vector3.hpp>
 #include <moveit_studio_agent_msgs/srv/set_transform.hpp>
+#include <moveit_studio_agent_msgs/srv/store_joint_state.hpp>
+#include <rclcpp/rclcpp.hpp>
 
 namespace
 {
 using BehaviorParameter = moveit_studio_sdk_msgs::msg::BehaviorParameter;
 using BehaviorParameterDescription = moveit_studio_sdk_msgs::msg::BehaviorParameterDescription;
+
+constexpr auto kServiceWaitTime = std::chrono::seconds{ 1 };
 }  // namespace
 
 namespace moveit_studio::agent::testing
 {
 using Point = geometry_msgs::msg::Point;
 using PoseStamped = geometry_msgs::msg::PoseStamped;
+using StoreJointState = moveit_studio_agent_msgs::srv::StoreJointState;
 using Quaternion = geometry_msgs::msg::Quaternion;
 using TransformStamped = geometry_msgs::msg::TransformStamped;
 using Vector3 = geometry_msgs::msg::Vector3;
@@ -54,42 +60,6 @@ TEST_F(ObjectiveFixture, Trivial)
   ASSERT_TRUE(true);
 }
 
-TEST_F(ObjectiveFixture, TestMoveToNamedState)
-{
-  ASSERT_TRUE(setupDoObjectiveSequenceClient());
-
-  auto do_objective_goal = std::make_unique<DoObjectiveSequence::Goal>();
-  do_objective_goal->objective_name = "Move to Known Pose";
-
-  BehaviorParameter pose_name_parameter;
-  pose_name_parameter.behavior_namespaces.emplace_back("move_to_known_pose");
-  pose_name_parameter.description.name = "target_state_name";
-  pose_name_parameter.description.type = BehaviorParameterDescription::TYPE_STRING;
-  pose_name_parameter.string_value = "Home";
-
-  do_objective_goal->parameter_overrides.push_back(pose_name_parameter);
-
-  EXPECT_TRUE(sendDoObjectiveSequenceGoal(std::move(do_objective_goal)));
-}
-
-TEST_F(ObjectiveFixture, TestMoveToWaypoint)
-{
-  ASSERT_TRUE(setupDoObjectiveSequenceClient());
-
-  auto do_objective_goal = std::make_unique<DoObjectiveSequence::Goal>();
-  do_objective_goal->objective_name = "Move to Waypoint";
-
-  BehaviorParameter waypoint_name_parameter;
-  waypoint_name_parameter.behavior_namespaces.emplace_back("move_to_waypoint");
-  waypoint_name_parameter.description.name = "waypoint_name";
-  waypoint_name_parameter.description.type = BehaviorParameterDescription::TYPE_STRING;
-  waypoint_name_parameter.string_value = "Forward Down";
-
-  do_objective_goal->parameter_overrides.push_back(waypoint_name_parameter);
-
-  EXPECT_TRUE(sendDoObjectiveSequenceGoal(std::move(do_objective_goal)));
-}
-
 TEST_F(ObjectiveFixture, TestCloseGripper)
 {
   ASSERT_TRUE(setupDoObjectiveSequenceClient());
@@ -170,24 +140,53 @@ TEST_F(ObjectiveFixture, DISABLED_TestInspectSurface)
   EXPECT_TRUE(sendDoObjectiveSequenceGoal(std::move(do_objective_goal), 30.0));
 }
 
+TEST_F(ObjectiveFixture, TestMoveToJointState)
+{
+  ASSERT_TRUE(setupDoObjectiveSequenceClient());
+
+  // Store a joint state parameter
+  rclcpp::Client<StoreJointState>::SharedPtr store_client = node_->create_client<StoreJointState>("store_joint_state");
+  ASSERT_TRUE(store_client->wait_for_service(kServiceWaitTime));
+
+  auto store_request = std::make_shared<StoreJointState::Request>();
+  store_request->joint_state.name = { "shoulder_pan_joint", "shoulder_lift_joint", "elbow_joint",
+                                      "wrist_1_joint",      "wrist_2_joint",       "wrist_3_joint" };
+  store_request->joint_state.position = { 0, -0.78, -0.51, -1.57, 1.65, 0 };
+
+  auto store_result_future = store_client->async_send_request(store_request);
+  ASSERT_EQ(store_result_future.wait_for(kServiceWaitTime), std::future_status::ready)
+      << "Timed out waiting for store joint state service response.";
+  ASSERT_TRUE(store_result_future.get()->success);
+
+  // Run the Objective
+  auto do_objective_goal = std::make_unique<DoObjectiveSequence::Goal>();
+  do_objective_goal->objective_name = "Move to Joint State";
+
+  EXPECT_TRUE(sendDoObjectiveSequenceGoal(std::move(do_objective_goal), 30.0));
+}
+
 TEST_F(ObjectiveFixture, TestInterpolateToJointState)
 {
   ASSERT_TRUE(setupDoObjectiveSequenceClient());
 
+  // Store a joint state parameter
+  rclcpp::Client<StoreJointState>::SharedPtr store_client = node_->create_client<StoreJointState>("store_joint_state");
+  ASSERT_TRUE(store_client->wait_for_service(kServiceWaitTime));
+
+  auto store_request = std::make_shared<StoreJointState::Request>();
+  store_request->joint_state.name = { "shoulder_pan_joint", "shoulder_lift_joint", "elbow_joint",
+                                      "wrist_1_joint",      "wrist_2_joint",       "wrist_3_joint" };
+  store_request->joint_state.position = { 0, -0.78, -0.51, -1.57, 1.65, 0 };
+
+  auto store_result_future = store_client->async_send_request(store_request);
+  ASSERT_EQ(store_result_future.wait_for(kServiceWaitTime), std::future_status::ready)
+      << "Timed out waiting for store joint state service response.";
+  ASSERT_TRUE(store_result_future.get()->success);
+
+  // Run the Objective
   auto do_objective_goal = std::make_unique<DoObjectiveSequence::Goal>();
   do_objective_goal->objective_name = "Interpolate to Joint State";
 
-  // Update the joint_state parameter used when planning the objective
-  BehaviorParameter pose_name_parameter;
-  pose_name_parameter.behavior_namespaces = { "interpolate_to_joint_state" };
-  pose_name_parameter.description.name = "target_joint_state";
-  pose_name_parameter.description.type = BehaviorParameterDescription::TYPE_JOINT_STATE;
-  pose_name_parameter.joint_state_value.name = { "shoulder_pan_joint", "shoulder_lift_joint", "elbow_joint",
-                                                 "wrist_1_joint",      "wrist_2_joint",       "wrist_3_joint" };
-  pose_name_parameter.joint_state_value.position = { 0, -0.78, -0.51, -1.57, 1.65, 0 };
-
-  do_objective_goal->parameter_overrides = { pose_name_parameter };
-
   EXPECT_TRUE(sendDoObjectiveSequenceGoal(std::move(do_objective_goal), 30.0));
 }
 

src/picknik_ur_studio_integration_testing/test/test_ur5e_pinch_p_stop.cpp

@@ -28,23 +28,30 @@
 
 #include <moveit_studio_agent/test/do_objective_test_fixture.hpp>
 
+#include <chrono>
+
 #include <geometry_msgs/msg/point.hpp>
 #include <geometry_msgs/msg/pose_stamped.hpp>
 #include <geometry_msgs/msg/quaternion.hpp>
 #include <geometry_msgs/msg/vector3.hpp>
 #include <moveit_studio_agent_msgs/srv/set_transform.hpp>
 #include <moveit_studio_sdk_msgs/msg/behavior_parameter.hpp>
+#include <moveit_studio_agent_msgs/srv/store_joint_state.hpp>
+#include <rclcpp/rclcpp.hpp>
 
 namespace
 {
 using BehaviorParameter = moveit_studio_sdk_msgs::msg::BehaviorParameter;
 using BehaviorParameterDescription = moveit_studio_sdk_msgs::msg::BehaviorParameterDescription;
+
+constexpr auto kServiceWaitTime = std::chrono::seconds{ 1 };
 }  // namespace
 
 namespace moveit_studio::agent::testing
 {
 using Point = geometry_msgs::msg::Point;
 using PoseStamped = geometry_msgs::msg::PoseStamped;
+using StoreJointState = moveit_studio_agent_msgs::srv::StoreJointState;
 using Quaternion = geometry_msgs::msg::Quaternion;
 using TransformStamped = geometry_msgs::msg::TransformStamped;
 using Vector3 = geometry_msgs::msg::Vector3;
@@ -59,19 +66,23 @@ TEST_F(ObjectiveFixture, InterpolateToPinchJointState)
 {
   ASSERT_TRUE(setupDoObjectiveSequenceClient());
 
-  auto do_objective_goal = std::make_unique<DoObjectiveSequence::Goal>();
-  do_objective_goal->objective_name = "Interpolate to Joint State";
+  // Store a joint state parameter
+  rclcpp::Client<StoreJointState>::SharedPtr store_client = node_->create_client<StoreJointState>("store_joint_state");
+  ASSERT_TRUE(store_client->wait_for_service(kServiceWaitTime));
 
-  // Update the joint_state parameter used when planning the objective
-  BehaviorParameter pose_name_parameter;
-  pose_name_parameter.behavior_namespaces = { "interpolate_to_joint_state" };
-  pose_name_parameter.description.name = "target_joint_state";
-  pose_name_parameter.description.type = BehaviorParameterDescription::TYPE_JOINT_STATE;
-  pose_name_parameter.joint_state_value.name = { "shoulder_pan_joint", "shoulder_lift_joint", "elbow_joint",
-                                                 "wrist_1_joint",      "wrist_2_joint",       "wrist_3_joint" };
-  pose_name_parameter.joint_state_value.position = { -0.66, -2.10, -1.27, 0.60, 2.87, 0.36 };
+  auto store_request = std::make_shared<StoreJointState::Request>();
+  store_request->joint_state.name = { "shoulder_pan_joint", "shoulder_lift_joint", "elbow_joint",
+                                      "wrist_1_joint",      "wrist_2_joint",       "wrist_3_joint" };
+  store_request->joint_state.position = { -0.66, -2.10, -1.27, 0.60, 2.87, 0.36 };
 
-  do_objective_goal->parameter_overrides = { pose_name_parameter };
+  auto store_result_future = store_client->async_send_request(store_request);
+  ASSERT_EQ(store_result_future.wait_for(kServiceWaitTime), std::future_status::ready)
+      << "Timed out waiting for store joint state service response.";
+  ASSERT_TRUE(store_result_future.get()->success);
+
+  // Run the Objective
+  auto do_objective_goal = std::make_unique<DoObjectiveSequence::Goal>();
+  do_objective_goal->objective_name = "Interpolate to Joint State";
 
   // Expect to fail due to pinch links blocking entering a pinch stop zone
   EXPECT_FALSE(sendDoObjectiveSequenceGoal(std::move(do_objective_goal), 30.0));
@@ -81,21 +92,24 @@ TEST_F(ObjectiveFixture, InterpolateToNearPinchJointState)
 {
   ASSERT_TRUE(setupDoObjectiveSequenceClient());
 
+  // Store a joint state parameter
+  rclcpp::Client<StoreJointState>::SharedPtr store_client = node_->create_client<StoreJointState>("store_joint_state");
+  ASSERT_TRUE(store_client->wait_for_service(kServiceWaitTime));
+
+  auto store_request = std::make_shared<StoreJointState::Request>();
+  store_request->joint_state.name = { "shoulder_pan_joint", "shoulder_lift_joint", "elbow_joint",
+                                      "wrist_1_joint",      "wrist_2_joint",       "wrist_3_joint" };
+  store_request->joint_state.position = { -0.66, -2.10, -1.27, 0.60, 2.70, 0.36 };
+
+  auto store_result_future = store_client->async_send_request(store_request);
+  ASSERT_EQ(store_result_future.wait_for(kServiceWaitTime), std::future_status::ready)
+      << "Timed out waiting for store joint state service response.";
+  ASSERT_TRUE(store_result_future.get()->success);
+
+  // Run the Objective
   auto do_objective_goal = std::make_unique<DoObjectiveSequence::Goal>();
   do_objective_goal->objective_name = "Interpolate to Joint State";
 
-  // Update the joint_state parameter used when planning the objective
-  BehaviorParameter pose_name_parameter;
-  pose_name_parameter.behavior_namespaces = { "interpolate_to_joint_state" };
-  pose_name_parameter.description.name = "target_joint_state";
-  pose_name_parameter.description.type = BehaviorParameterDescription::TYPE_JOINT_STATE;
-  pose_name_parameter.joint_state_value.name = { "shoulder_pan_joint", "shoulder_lift_joint", "elbow_joint",
-                                                 "wrist_1_joint",      "wrist_2_joint",       "wrist_3_joint" };
-  // Now we put wrist_2_joint around 10 degrees more relaxed from the pinch point.
-  pose_name_parameter.joint_state_value.position = { -0.66, -2.10, -1.27, 0.60, 2.70, 0.36 };
-
-  do_objective_goal->parameter_overrides = { pose_name_parameter };
-
   // Expect the pinch link geometries to be unobtrusive enough that planning to just outside the
   // pinch zone still works.
   EXPECT_TRUE(sendDoObjectiveSequenceGoal(std::move(do_objective_goal), 30.0));