cb_connect_micro_ros_agent.cpp

Go to the documentation of this file.

// Copyright 2025 Robosoft Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
 
#include <cl_px4_mr/client_behaviors/cb_connect_micro_ros_agent.hpp>
#include <cl_px4_mr/components/cp_micro_ros_agent.hpp>
 
#include <chrono>
 
namespace cl_px4_mr
{
 
CbConnectMicroRosAgent::CbConnectMicroRosAgent(double timeoutSec)
: timeoutSec_(timeoutSec), rate_(5)
{
}
 
void CbConnectMicroRosAgent::onEntry()
{
  this->requiresComponent(microRosAgent_);
 
  if (!microRosAgent_->isLaunched())
  {
    RCLCPP_INFO(getLogger(), "CbConnectMicroRosAgent: launching micro_ros_agent...");
    microRosAgent_->launch();
  }
 
  std::string targetNodeName = microRosAgent_->getNodeName();
  RCLCPP_INFO(
    getLogger(), "CbConnectMicroRosAgent: waiting for node '%s' (timeout %.1fs)",
    targetNodeName.c_str(), timeoutSec_);
 
  auto startTime = std::chrono::steady_clock::now();
  bool found = false;
 
  while (!this->isShutdownRequested() && !found)
  {
    // Check timeout
    auto elapsed = std::chrono::steady_clock::now() - startTime;
    double elapsedSec = std::chrono::duration<double>(elapsed).count();
    if (elapsedSec > timeoutSec_)
    {
      RCLCPP_ERROR(
        getLogger(), "CbConnectMicroRosAgent: timeout (%.1fs) waiting for '%s'", timeoutSec_,
        targetNodeName.c_str());
      this->postFailureEvent();
      return;
    }
 
    // Poll for node
    std::stringstream ss;
    auto nodeNames = getNode()->get_node_names();
 
    for (const auto & n : nodeNames)
    {
      ss << " - " << n << std::endl;
 
      if (n == targetNodeName)
      {
        found = true;
      }
    }
 
    RCLCPP_INFO_STREAM(
      getLogger(), "[" << getName() << "] listing nodes (" << nodeNames.size() << ")" << std::endl
                       << ss.str());
 
    rate_.sleep();
  }
 
  if (!found)
  {
    RCLCPP_WARN(getLogger(), "CbConnectMicroRosAgent: shutdown requested before node found");
    this->postFailureEvent();
    return;
  }
 
  RCLCPP_INFO(
    getLogger(), "CbConnectMicroRosAgent: node '%s' detected - starting failsafe health check",
    targetNodeName.c_str());
 
  // Phase 2: Wait for PX4 failsafe health flags to clear
  healthOk_.store(false);
  attitudeInvalid_.store(true);
  localAltitudeInvalid_.store(true);
  localPositionInvalid_.store(true);
 
  failsafeSub_ = getNode()->create_subscription<px4_msgs::msg::FailsafeFlags>(
    "/fmu/out/failsafe_flags", rclcpp::SensorDataQoS(),
    [this](const px4_msgs::msg::FailsafeFlags::SharedPtr msg)
    {
      attitudeInvalid_.store(msg->attitude_invalid);
      localAltitudeInvalid_.store(msg->local_altitude_invalid);
      localPositionInvalid_.store(msg->local_position_invalid);
      healthOk_.store(
        !msg->attitude_invalid && !msg->local_altitude_invalid && !msg->local_position_invalid);
    });
 
  rclcpp::Rate healthRate(2.0);
  while (!this->isShutdownRequested() && !healthOk_.load())
  {
    auto elapsed = std::chrono::steady_clock::now() - startTime;
    double elapsedSec = std::chrono::duration<double>(elapsed).count();
    if (elapsedSec > timeoutSec_)
    {
      RCLCPP_ERROR(
        getLogger(),
        "CbConnectMicroRosAgent: timeout (%.1fs) waiting for health check. "
        "attitude_invalid=%d, local_altitude_invalid=%d, local_position_invalid=%d",
        timeoutSec_, attitudeInvalid_.load(), localAltitudeInvalid_.load(),
        localPositionInvalid_.load());
      this->postFailureEvent();
      return;
    }
 
    RCLCPP_INFO(
      getLogger(),
      "CbConnectMicroRosAgent: health check: attitude_invalid=%d, "
      "local_altitude_invalid=%d, local_position_invalid=%d",
      attitudeInvalid_.load(), localAltitudeInvalid_.load(), localPositionInvalid_.load());
 
    healthRate.sleep();
  }
 
  if (healthOk_.load())
  {
    RCLCPP_INFO(getLogger(), "CbConnectMicroRosAgent: health check passed - posting success");
    this->postSuccessEvent();
  }
  else
  {
    RCLCPP_WARN(
      getLogger(), "CbConnectMicroRosAgent: shutdown requested before health check passed");
    this->postFailureEvent();
  }
}
 
void CbConnectMicroRosAgent::onExit() { failsafeSub_.reset(); }
 
}  // namespace cl_px4_mr