rtt_rosparam_service.cpp

Go to the documentation of this file.

#include <rtt/RTT.hpp>
#include <rtt/Property.hpp>
#include <rtt/plugin/ServicePlugin.hpp>
#include <rtt/types/PropertyDecomposition.hpp>

#include <boost/utility/enable_if.hpp>
#include <boost/type_traits/is_convertible.hpp>

#include <XmlRpcException.h>

#include <Eigen/Dense>

#include <ros/ros.h>

using namespace RTT;
using namespace std;

class ROSParamService: public RTT::Service
{
public:

  typedef enum  {
    RELATIVE, 
    ABSOLUTE, 
    PRIVATE,  
    COMPONENT 
  }ResolutionPolicy;

  ROSParamService(TaskContext* owner) :
    Service("rosparam", owner)
  {
    this->doc("RTT Service for synchronizing ROS parameters with the properties of a corresponding RTT component");

    this->addConstant("RELATIVE",static_cast<int>(RELATIVE));
    this->addConstant("ABSOLUTE",static_cast<int>(ABSOLUTE));
    this->addConstant("PRIVATE",static_cast<int>(PRIVATE));
    this->addConstant("COMPONENT",static_cast<int>(COMPONENT));

    this->addOperation("getAllRelative", &ROSParamService::getParamsRelative, this)
      .doc("Gets all properties of this component (and its sub-services) from the ROS param server in the relative namespace.");
    this->addOperation("getAllAbsolute", &ROSParamService::getParamsAbsolute, this)
      .doc("Gets all properties of this component (and its sub-services) from the ROS param server in the absolute namespace.");
    this->addOperation("getAllPrivate", &ROSParamService::getParamsPrivate, this)
      .doc("Gets all properties of this component (and its sub-services) from the ROS param server in the node's private namespace.");
    this->addOperation("getAllComponentPrivate", &ROSParamService::getParamsComponentPrivate, this)
      .doc("Gets all properties of this component (and its sub-services) from the ROS param server in the component's private namespace.");
    this->addOperation("getAll", &ROSParamService::getParamsComponentPrivate, this)
      .doc("Gets all properties of this component (and its sub-services) from the ROS param server in the component's private namespace. This is an alias for getAllComponentPrivate().");

    this->addOperation("setAllRelative", &ROSParamService::setParamsRelative, this)
      .doc("Stores all properties of this component (and its sub-services) on the ROS param server from the similarly-named property in the relative namespace.");
    this->addOperation("setAllAbsolute", &ROSParamService::setParamsAbsolute, this)
      .doc("Stores all properties of this component (and its sub-services) on the ROS param server from the similarly-named property in the absolute namespace.");
    this->addOperation("setAllPrivate", &ROSParamService::setParamsPrivate, this)
      .doc("Stores all properties of this component (and its sub-services) on the ROS param server from the similarly-named property in the node's private namespace.");
    this->addOperation("setAllComponentPrivate", &ROSParamService::setParamsComponentPrivate, this)
      .doc("Stores all properties of this component (and its sub-services) on the ROS param server from the similarly-named property in the component's private namespace.");
    this->addOperation("setAll", &ROSParamService::setParamsComponentPrivate, this)
      .doc("Stores all properties of this component (and its sub-services) on the ROS param server from the similarly-named property in the component's private namespace. This is an alias for setAllComponentPrivate().");

    this->addOperation("get", &ROSParamService::get, this) 
      .doc("Gets one property of this component (or populates the properties of a named RTT sub-service) from the ROS param server based on the given resolution policy.")
      .arg("name", "Name of the property / service / parameter.")
      .arg("policy", "ROS parameter namespace resolution policy.");
    this->addOperation("getParam", &ROSParamService::getParam, this) 
      .doc("Gets one property of this component (or populates the properties of a named RTT sub-service) from the ROS param server based on the given ROS parameter name.")
      .arg("param_name", "Name of the ROS parameter. Use '~' and '/' leaders for private or absolute resolution.")
      .arg("name", "Name of the RTT property or service.");

    this->addOperation("getRelative", &ROSParamService::getParamRelative, this) 
      .doc("Gets one property of this component (or populates the properties of a named RTT sub-service) from the ROS param server in the relative namespace.")
      .arg("name", "Name of the property / service / parameter.");
    this->addOperation("getAbsolute", &ROSParamService::getParamAbsolute, this) 
      .doc("Gets one property of this component (or populates the properties of a named RTT sub-service) from the ROS param server in the absolute namespace.")
      .arg("name", "Name of the property / service / parameter.");
    this->addOperation("getPrivate", &ROSParamService::getParamPrivate, this) 
      .doc("Gets one property of this component (or populates the properties of a named RTT sub-service) from the ROS param server in the node's private namespace.")
      .arg("name", "Name of the property / service / parameter.");
    this->addOperation("getComponentPrivate", &ROSParamService::getParamComponentPrivate, this) 
      .doc("Gets one property of this component (or populates the properties of a named RTT sub-service) from the ROS param server in the component's private namespace.")
      .arg("name", "Name of the property / service / parameter.");

    this->addOperation("set", &ROSParamService::set, this) 
      .doc("Sets one parameter on the ROS param server from the similarly-named property of this component (or stores the properties of a named RTT sub-service) in the ROS parameter namespace based on the given resolution policy.")
      .arg("name", "Name of the property / service / parameter.")
      .arg("policy", "ROS parameter namespace resolution policy.");
    this->addOperation("setParam", &ROSParamService::setParam, this) 
      .doc("Sets one parameter on the ROS param server from the similarly-named property of this component (or stores the properties of a named RTT sub-service) in the ROS parameter namespace based on the given ROS parameter name.")
      .arg("param_name", "Name of the ROS parameter. Use '~' and '/' leaders for private or absolute resolution.")
      .arg("name", "Name of the RTT property or service.");

    this->addOperation("setRelative", &ROSParamService::setParamRelative, this) 
      .doc("Sets one parameter on the ROS param server from the similarly-named property of this component (or stores the properties of a named RTT sub-service) in the relative namespace.")
      .arg("name", "Name of the property / service / parameter.");
    this->addOperation("setAbsolute", &ROSParamService::setParamAbsolute, this) 
      .doc("Sets one parameter on the ROS param server from the similarly-named property of this component (or stores the properties of a named RTT sub-service) in the absolute namespace.")
      .arg("name", "Name of the property / service / parameter.");
    this->addOperation("setPrivate", &ROSParamService::setParamPrivate, this) 
      .doc("Sets one parameter on the ROS param server from the similarly-named property of this component (or stores the properties of a named RTT sub-service) in the node's private namespace.")
      .arg("name", "Name of the property / service / parameter.");
    this->addOperation("setComponentPrivate", &ROSParamService::setParamComponentPrivate, this) 
      .doc("Sets one parameter on the ROS param server from the similarly-named property of this component (or stores the properties of a named RTT sub-service) in the component's private namespace.")
      .arg("name", "Name of the property / service / parameter.");
  
  }
private:

  const std::string resolvedName(
    const std::string &param_name, 
    const ROSParamService::ResolutionPolicy policy);

  bool getParams(RTT::Service::shared_ptr service, const std::string& ns);
  bool getParams(const ROSParamService::ResolutionPolicy policy);
  bool getParamsRelative() { return getParams(RELATIVE); }
  bool getParamsAbsolute() { return getParams(ABSOLUTE); }
  bool getParamsPrivate() { return getParams(PRIVATE); }
  bool getParamsComponentPrivate() { return getParams(COMPONENT); }

  bool get(
    const std::string &param_name, 
    const unsigned int policy = (unsigned int)ROSParamService::COMPONENT);
  bool getParam(
    const std::string &ros_name, 
    const std::string &rtt_name);
  bool getParamRelative(const std::string &name) { return get(name, RELATIVE); }
  bool getParamAbsolute(const std::string &name) { return get(name, ABSOLUTE); }
  bool getParamPrivate(const std::string &name) { return get(name, PRIVATE); }
  bool getParamComponentPrivate(const std::string &name) { return get(name, COMPONENT); }

  bool setParams(RTT::Service::shared_ptr service, const std::string& ns);
  bool setParams(const ROSParamService::ResolutionPolicy policy);
  bool setParamsRelative() { return setParams(RELATIVE); }
  bool setParamsAbsolute() { return setParams(ABSOLUTE); }
  bool setParamsPrivate() { return setParams(PRIVATE); }
  bool setParamsComponentPrivate() { return setParams(COMPONENT); }

  bool set(
    const std::string &param_name, 
    const unsigned int policy = (unsigned int)ROSParamService::COMPONENT);
  bool setParam(
    const std::string &ros_name, 
    const std::string &rtt_name);
  bool setParamRelative(const std::string &name) { return set(name, RELATIVE); }
  bool setParamAbsolute(const std::string &name) { return set(name, ABSOLUTE); }
  bool setParamPrivate(const std::string &name) { return set(name, PRIVATE); }
  bool setParamComponentPrivate(const std::string &name) { return set(name, COMPONENT); }
};

const std::string ROSParamService::resolvedName(
    const std::string &param_name, 
    const ROSParamService::ResolutionPolicy policy)
{
  std::string leader = "";
  std::string resolved_name = "";

  if(param_name.length() > 0) {
    leader = param_name[0];
  }

  switch(policy) {
    case ROSParamService::RELATIVE:
      resolved_name = param_name;
      break;
    case ROSParamService::ABSOLUTE:
      resolved_name = (leader == "/") ? param_name : std::string("/") + param_name;
      break;
    case ROSParamService::PRIVATE:
      resolved_name = (leader == "~") ? param_name : std::string("~") + param_name;
      break;
    case ROSParamService::COMPONENT:
      resolved_name = std::string("~") + ros::names::append(this->getOwner()->getName(),param_name);
      break;
  };

  RTT::log(RTT::Debug) << "["<<this->getOwner()->getName()<<"] Resolving ROS param \""<<param_name<<"\" to \""<<resolved_name<<"\"" << RTT::endlog();

  return resolved_name;
}



template<class T>
bool castable(const RTT::base::PropertyBase *prop);
template<class T>
XmlRpc::XmlRpcValue rttPropertyToXmlParam(const T &prop);
template<>
XmlRpc::XmlRpcValue rttPropertyToXmlParam<RTT::PropertyBag>(const RTT::PropertyBag &bag);
template<class T>
XmlRpc::XmlRpcValue rttPropertyToXmlParam(const std::vector<T> &vec);
XmlRpc::XmlRpcValue rttPropertyBaseToXmlParam(RTT::base::PropertyBase *prop);

template<class T>
bool castable(const RTT::base::PropertyBase *prop) 
{
  return dynamic_cast<const Property<T>*>(prop);
}

template<class T>
XmlRpc::XmlRpcValue rttPropertyToXmlParam(const T &prop)
{
  return XmlRpc::XmlRpcValue(prop);
}

template<>
XmlRpc::XmlRpcValue rttPropertyToXmlParam<float>(const float &prop)
{
  return XmlRpc::XmlRpcValue(static_cast<double>(prop));
}

template<>
XmlRpc::XmlRpcValue rttPropertyToXmlParam<unsigned int>(const unsigned int &prop)
{
  return XmlRpc::XmlRpcValue(static_cast<int>(prop));
}

template<>
XmlRpc::XmlRpcValue rttPropertyToXmlParam<char>(const char &prop)
{
  return XmlRpc::XmlRpcValue(static_cast<int>(prop));
}

template<>
XmlRpc::XmlRpcValue rttPropertyToXmlParam<unsigned char>(const unsigned char &prop)
{
  return XmlRpc::XmlRpcValue(static_cast<int>(prop));
}

template<>
XmlRpc::XmlRpcValue rttPropertyToXmlParam<RTT::PropertyBag>(const RTT::PropertyBag &bag)
{
  // Make the xml value a struct
  XmlRpc::XmlRpcValue xml_struct;
  const XmlRpc::XmlRpcValue::ValueStruct &xml_map = (const XmlRpc::XmlRpcValue::ValueStruct &)(xml_struct);

  // Get the properties
  const RTT::PropertyBag::Properties &properties = bag.getProperties();

  for(RTT::PropertyBag::Properties::const_iterator it = properties.begin();
      it != properties.end();
      ++it)
  {
    xml_struct[(*it)->getName()] = rttPropertyBaseToXmlParam(*it);
  }

  return xml_struct;
}

template<class T>
XmlRpc::XmlRpcValue rttPropertyToXmlParam(const std::vector<T> &vec)
{
  XmlRpc::XmlRpcValue xml_array;
  xml_array.setSize(vec.size());

  for(unsigned i=0; i<vec.size(); i++) {
    xml_array[i] = rttPropertyToXmlParam<T>(vec.at(i));
  }

  return xml_array;
}

template<>
XmlRpc::XmlRpcValue rttPropertyToXmlParam(const Eigen::VectorXd &vec)
{
  XmlRpc::XmlRpcValue xml_array;
  xml_array.setSize(vec.size());

  for(unsigned i=0; i<vec.size(); i++) {
    xml_array[i] = rttPropertyToXmlParam<double>(vec(i));
  }

  return xml_array;
}

template<>
XmlRpc::XmlRpcValue rttPropertyToXmlParam(const Eigen::VectorXf &vec)
{
  XmlRpc::XmlRpcValue xml_array;
  xml_array.setSize(vec.size());

  for(unsigned i=0; i<vec.size(); i++) {
    xml_array[i] = rttPropertyToXmlParam<double>(vec(i));
  }

  return xml_array;
}


// These just save typing
#define RETURN_RTT_PROPERTY_TO_XML_PARAM(type,prop)\
  if(castable< type >(prop)) { return rttPropertyToXmlParam< type >(static_cast<const RTT::Property< type >*>(prop)->rvalue()); }

#define RETURN_RTT_PROPERTY_CONTAINER_TO_XML_PARAM(type,elem_type,prop)\
  if(castable< type >(prop)) { return rttPropertyToXmlParam< elem_type >(static_cast<const RTT::Property< type >*>(prop)->rvalue()); }

XmlRpc::XmlRpcValue rttPropertyBaseToXmlParam(RTT::base::PropertyBase *prop)
{
  // Primitive parameters
  RETURN_RTT_PROPERTY_TO_XML_PARAM(std::string,prop);
  RETURN_RTT_PROPERTY_TO_XML_PARAM(double,prop);
  RETURN_RTT_PROPERTY_TO_XML_PARAM(float,prop);
  RETURN_RTT_PROPERTY_TO_XML_PARAM(int,prop);
  RETURN_RTT_PROPERTY_TO_XML_PARAM(unsigned int,prop);
  RETURN_RTT_PROPERTY_TO_XML_PARAM(char,prop);
  RETURN_RTT_PROPERTY_TO_XML_PARAM(unsigned char,prop);
  RETURN_RTT_PROPERTY_TO_XML_PARAM(bool,prop);

  // Vector parameters
  RETURN_RTT_PROPERTY_CONTAINER_TO_XML_PARAM(std::vector<std::string>, std::string, prop);
  RETURN_RTT_PROPERTY_CONTAINER_TO_XML_PARAM(std::vector<double>, double, prop);
  RETURN_RTT_PROPERTY_CONTAINER_TO_XML_PARAM(std::vector<float>, float, prop);
  RETURN_RTT_PROPERTY_CONTAINER_TO_XML_PARAM(std::vector<int>, int, prop);
  RETURN_RTT_PROPERTY_CONTAINER_TO_XML_PARAM(std::vector<unsigned int>, unsigned int, prop);
  RETURN_RTT_PROPERTY_CONTAINER_TO_XML_PARAM(std::vector<char>, char, prop);
  RETURN_RTT_PROPERTY_CONTAINER_TO_XML_PARAM(std::vector<unsigned char>, unsigned char, prop);
  RETURN_RTT_PROPERTY_CONTAINER_TO_XML_PARAM(std::vector<bool>, bool, prop);

  RETURN_RTT_PROPERTY_TO_XML_PARAM(Eigen::VectorXd, prop);
  RETURN_RTT_PROPERTY_TO_XML_PARAM(Eigen::VectorXf, prop);

  // Struct parameters
  RETURN_RTT_PROPERTY_TO_XML_PARAM(RTT::PropertyBag,prop);

  // Try to decompose property into a property bag
  RTT::PropertyBag bag;
  if (RTT::types::propertyDecomposition(prop, bag)) {
    return rttPropertyToXmlParam(bag);
  }

  return XmlRpc::XmlRpcValue();
}


bool ROSParamService::set(
    const std::string &param_name, 
    const unsigned int policy)
{
  RTT::Logger::In in("ROSParamService::set");

  const std::string resolved_name = resolvedName(param_name,ResolutionPolicy(policy));

  return this->setParam(resolved_name, param_name);
}

bool ROSParamService::setParam(
    const std::string &ros_name,
    const std::string &rtt_name)
{
  RTT::Logger::In in("ROSParamService::setParam");

  XmlRpc::XmlRpcValue xml_value;

  // Try to find a property named rtt_name
  RTT::base::PropertyBase *property = this->getOwner()->getProperty(rtt_name);
  if (property) {
    xml_value = rttPropertyBaseToXmlParam(this->getOwner()->getProperty(rtt_name));
    ros::param::set(ros_name, xml_value);
    return true;
  }

  // Try to find a sub-service named rtt_name 
  RTT::Service::shared_ptr service = this->getOwner()->provides()->getService(rtt_name);
  if (service) {
    // Set all parameters of the sub-service
    return setParams(service, ros_name);
  }

  RTT::log(RTT::Debug) << "RTT component does not have a property or service named \"" << rtt_name << "\"" << RTT::endlog();
  return false;
}

bool ROSParamService::setParams(const ROSParamService::ResolutionPolicy policy)
{
  return setParams(this->getOwner()->provides(), resolvedName(std::string(), policy));
}

bool ROSParamService::setParams(
    RTT::Service::shared_ptr service, 
    const std::string& ns) {
  XmlRpc::XmlRpcValue xml_value;
  xml_value = rttPropertyToXmlParam(*(service->properties()));
  ros::param::set(ns, xml_value);

  // Recurse into sub-services
  RTT::Service::ProviderNames names = service->getProviderNames();
  for (RTT::Service::ProviderNames::const_iterator it = names.begin(); it != names.end(); ++it)
  {
    RTT::Service::shared_ptr sub(service->getService(*it));
    if (sub) {
      if (!setParams(sub, ros::names::append(ns,sub->getName()))) return false;
    }
  }

  return true;
}

// Declarations
template <class T>
bool xmlParamToProp(const XmlRpc::XmlRpcValue &xml_value, RTT::Property<T>* prop);
template <class T>
bool xmlParamToProp(const XmlRpc::XmlRpcValue &xml_value, RTT::Property<std::vector<T> >* prop);
template <>
bool xmlParamToProp(const XmlRpc::XmlRpcValue &xml_value, RTT::Property<Eigen::VectorXd>* prop);
template <>
bool xmlParamToProp(const XmlRpc::XmlRpcValue &xml_value, RTT::Property<Eigen::VectorXf>* prop);
template <> 
bool xmlParamToProp<RTT::PropertyBag>(const XmlRpc::XmlRpcValue &xml_value, RTT::Property<RTT::PropertyBag>* prop);
bool xmlParamToProp( const XmlRpc::XmlRpcValue &xml_value, RTT::base::PropertyBase* prop_base);

template <class XMLRPCType,class PropertyType, class enabled=void> struct XmlParamToValue{
    static bool assign(const XMLRPCType& xml_value, PropertyType &prop_value)
    {
        return false;
    }
};

template <class XMLRPCType, class PropertyType >
struct XmlParamToValue <XMLRPCType, PropertyType, typename boost::enable_if<boost::is_convertible<XMLRPCType,PropertyType> >::type >{
    static bool assign(const XMLRPCType& xml_value, PropertyType &prop_value)
    {
        prop_value = xml_value;
        return true;
    }
};

template <class PropertyType> bool xmlParamToValue(const XmlRpc::XmlRpcValue &xml_value, PropertyType &value) {
    switch(xml_value.getType()) {
    case XmlRpc::XmlRpcValue::TypeString:
        return XmlParamToValue<std::string, PropertyType>::assign(static_cast<const std::string&>(const_cast<XmlRpc::XmlRpcValue &>(xml_value)),value);
    case XmlRpc::XmlRpcValue::TypeDouble:
        return XmlParamToValue<double, PropertyType>::assign(static_cast<double>(const_cast<XmlRpc::XmlRpcValue &>(xml_value)),value);
    case XmlRpc::XmlRpcValue::TypeInt:
        return XmlParamToValue<int, PropertyType>::assign(static_cast<int>(const_cast<XmlRpc::XmlRpcValue &>(xml_value)),value);
    case XmlRpc::XmlRpcValue::TypeBoolean:
        return XmlParamToValue<bool, PropertyType>::assign(static_cast<bool>(const_cast<XmlRpc::XmlRpcValue &>(xml_value)),value);
    }
    return false;
}

template <class T>
bool xmlParamToProp(
    const XmlRpc::XmlRpcValue &xml_value,
    RTT::Property<T>* prop)
{
  // Check if the property value is the requested type T
  if(!prop) {
    return false;
  }

  // Set the value
  return xmlParamToValue(xml_value, prop->set());

}

template <class T>
bool xmlParamToProp(
    const XmlRpc::XmlRpcValue &xml_value,
    RTT::Property<std::vector<T> >* prop)
{
  // Check if the property value is the requested type T
  if(!prop) {
    return false;
  }

  // Make sure it's an array 
  if(xml_value.getType() != XmlRpc::XmlRpcValue::TypeArray) {
    return false;
  }

  // Copy the data into the vector property
  std::vector<T> &vec = prop->value();
  vec.resize(xml_value.size());
  bool result = true;
  for(size_t i=0; i<vec.size(); i++) {
    result &= xmlParamToValue(xml_value[i], vec[i]);
  }

  return result;
}

template <>
bool xmlParamToProp<bool>(
    const XmlRpc::XmlRpcValue &xml_value,
    RTT::Property<std::vector<bool> >* prop)
{
  // Check if the property value is the requested type T
  if(!prop) {
    return false;
  }

  // Make sure it's an array
  if(xml_value.getType() != XmlRpc::XmlRpcValue::TypeArray) {
    return false;
  }

  // Copy the data into the vector property
  std::vector<bool> &vec = prop->value();
  vec.resize(xml_value.size());
  bool result = true;
  for(size_t i=0; i<vec.size(); i++) {
    bool temp;
    result &= xmlParamToValue(xml_value[i], temp);
    vec[i] = temp;
  }

  return result;
}

template <>
bool xmlParamToProp(
    const XmlRpc::XmlRpcValue &xml_value,
    RTT::Property<Eigen::VectorXd >* prop)
{
  // Check if the property value is the requested type T
  if(!prop) {
    return false;
  }

  // Make sure it's an array
  if(xml_value.getType() != XmlRpc::XmlRpcValue::TypeArray) {
    return false;
  }

  // Copy the data into the vector property
  Eigen::VectorXd &vec = prop->value();
  vec.resize(xml_value.size());
  bool result = true;
  for(size_t i=0; i<vec.size(); i++) {
    double temp;
    result &= xmlParamToValue(xml_value[i], temp);
    vec[i] = temp;
  }

  return result;
}

template <>
bool xmlParamToProp(
    const XmlRpc::XmlRpcValue &xml_value,
    RTT::Property<Eigen::VectorXf >* prop)
{
  // Check if the property value is the requested type T
  if(!prop) {
    return false;
  }

  // Make sure it's an array
  if(xml_value.getType() != XmlRpc::XmlRpcValue::TypeArray) {
    return false;
  }

  // Copy the data into the vector property
  Eigen::VectorXf &vec = prop->value();
  vec.resize(xml_value.size());
  bool result = true;
  for(size_t i=0; i<vec.size(); i++) {
    double temp;
    result &= xmlParamToValue(xml_value[i], temp);
    vec[i] = temp;
  }

  return result;
}

template <>
bool xmlParamToProp<RTT::PropertyBag>(
    const XmlRpc::XmlRpcValue &xml_value,
    RTT::Property<RTT::PropertyBag>* prop)
{
  // Check if the property value is the requested type T
  if(!prop) {
    return false;
  }

  // Make sure it's a struct
  if(xml_value.getType() != XmlRpc::XmlRpcValue::TypeStruct) {
    return false;
  }

  // Copy the properties
  bool success = true;
  // We need to copy the struct because XmlRpc++ doesn't have const operations for this
  XmlRpc::XmlRpcValue xml_value_struct(xml_value);
  for(XmlRpc::XmlRpcValue::ValueStruct::iterator it = xml_value_struct.begin();
      it != xml_value_struct.end();
      ++it)
  {
    RTT::base::PropertyBase *sub_prop_base = prop->value().getProperty(it->first);
    if(sub_prop_base) {
      success &= xmlParamToProp(it->second, sub_prop_base);
    }
  }

  return success;
}

bool xmlParamToProp(
    const XmlRpc::XmlRpcValue &xml_value,
    RTT::base::PropertyBase* prop_base)
{
  bool array_ret = false;

  // Switch based on the type of XmlRpcValue 
  switch(xml_value.getType()) {
    case XmlRpc::XmlRpcValue::TypeString:
      return 
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<std::string>*>(prop_base)); 
    case XmlRpc::XmlRpcValue::TypeDouble:
      return 
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<double>*>(prop_base)) ||
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<float>*>(prop_base));
    case XmlRpc::XmlRpcValue::TypeInt:
      return 
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<double>*>(prop_base)) ||
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<float>*>(prop_base)) ||
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<int>*>(prop_base)) ||
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<unsigned int>*>(prop_base)) ||
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<char>*>(prop_base)) ||
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<unsigned char>*>(prop_base));
    case XmlRpc::XmlRpcValue::TypeBoolean:
      return 
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<bool>*>(prop_base)); 
    case XmlRpc::XmlRpcValue::TypeArray:
      array_ret =
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<std::vector<std::string> >*>(prop_base)) ||
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<std::vector<double> >*>(prop_base)) ||
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<std::vector<float> >*>(prop_base)) ||
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<std::vector<int> >*>(prop_base)) ||
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<std::vector<unsigned int> >*>(prop_base)) ||
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<std::vector<char> >*>(prop_base)) ||
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<std::vector<unsigned char> >*>(prop_base)) ||
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<std::vector<bool> >*>(prop_base)) ||
        xmlParamToProp(xml_value, dynamic_cast<RTT::Property<Eigen::VectorXd >*>(prop_base));
      // Return true if it gets parsed into an array structure, otherwise, try property bag decomposition
      if(array_ret) {
        return true;
      }
    case XmlRpc::XmlRpcValue::TypeStruct:
      // Try to decompose the property in a property bag:
      if(xmlParamToProp(xml_value, dynamic_cast<RTT::Property<RTT::PropertyBag>*>(prop_base))) {
        return true;
      }
      {
        RTT::Property<RTT::PropertyBag> bag(prop_base->getName());
        if(RTT::types::propertyDecomposition(prop_base, bag.set()) && xmlParamToProp(xml_value, &bag)) {
          return true;
        } else {
          RTT::log(RTT::Debug) << "Could not decompose property bag for property type \"" << prop_base->getName() << "\"" << RTT::endlog();
          return false;
        }

      }
  };

  RTT::log(RTT::Debug) << "No appropriate conversion for property \"" << prop_base->getName() << "\"" << RTT::endlog();

  return false;
}

bool ROSParamService::get(
    const std::string &param_name, 
    const unsigned int policy)
{
  RTT::Logger::In in("ROSParamService::get");

  const std::string resolved_name = resolvedName(
      param_name,ResolutionPolicy(policy));

  return this->getParam(resolved_name, param_name);
}

bool ROSParamService::getParam(
    const std::string &ros_name,
    const std::string &rtt_name)
{
  RTT::Logger::In in("ROSParamService::getParam");

  try {
    // Get the parameter
    XmlRpc::XmlRpcValue xml_value;

    if(!ros::param::get(ros_name, xml_value)) {
      RTT::log(RTT::Debug) << "ROS Parameter \"" << ros_name << "\" not found on the parameter server!" << RTT::endlog();
      return false;
    }

    // Try to get the property if it exists
    RTT::base::PropertyBase *prop_base = this->getOwner()->getProperty(rtt_name);
    if(prop_base) {
      // Deal with the xml value
      bool ret = xmlParamToProp(xml_value, prop_base);
      if(!ret) {
        RTT::log(RTT::Warning) << "Could not convert \"" << ros_name << "\" from an XMLRPC value to an RTT property." << RTT::endlog();
      }
      return ret;
    }

    // Try to get the properties of a sub-service if it exists
    RTT::Service::shared_ptr service = this->getOwner()->provides()->getService(rtt_name);
    if(service) {
      // Get all parameters of the sub-service
      return getParams(service, ros_name);
    }

    RTT::log(RTT::Debug) << "RTT component does not have a property or service named \"" << rtt_name << "\"" << RTT::endlog();

  } catch(XmlRpc::XmlRpcException &err) {
    RTT::log(RTT::Error) << "XmlRpcException when getting ROS parameter \""<<ros_name<<"\": " << err.getMessage() << RTT::endlog();
    RTT::log(RTT::Debug) << " -- Make sure your parameters are the right primitive type." << RTT::endlog();
  }

  return false;
}


bool ROSParamService::getParams(const ROSParamService::ResolutionPolicy policy)
{
  return getParams(this->getOwner()->provides(), resolvedName(std::string(), policy));
}

bool ROSParamService::getParams(
    RTT::Service::shared_ptr service, 
    const std::string& ns)
{
  RTT::Logger::In in("ROSParamService::getParams");

  // Get the parameter
  XmlRpc::XmlRpcValue xml_value;

  if(!ros::param::get(ns, xml_value)) {
    RTT::log(RTT::Debug) << "ROS Parameter namespace \"" << ns << "\" not found on the parameter server!" << RTT::endlog();
    return false;
  }

  // Create a Property<> wrapper around the propertybag
  RTT::PropertyBag *properties = service->properties();
  RTT::internal::AssignableDataSource<RTT::PropertyBag>::shared_ptr datasource(new RTT::internal::ReferenceDataSource<RTT::PropertyBag>(*properties));
  RTT::Property<RTT::PropertyBag> prop(this->getOwner()->getName(),"",datasource);

  // Deal with the xml value
  bool ret = xmlParamToProp(xml_value, &prop);
  if (!ret) {
    RTT::log(RTT::Warning) << "Could not convert \"" << ns << "\" from an XMLRPC value to an RTT property." << RTT::endlog();
    return false;
  }

  // Recurse into sub-services
  RTT::Service::ProviderNames names = service->getProviderNames();
  for (RTT::Service::ProviderNames::const_iterator it = names.begin(); it != names.end(); ++it)
  {
    RTT::Service::shared_ptr sub(service->getService(*it));
    if (sub) {
      std::string sub_ns = sub->getName();
      if (!ns.empty()) sub_ns = ros::names::append(ns,sub_ns);
      getParams(sub, sub_ns);
    }
  }

  return true;
}

ORO_SERVICE_NAMED_PLUGIN(ROSParamService, "rosparam")