humotion

/*

* This file is part of humotion

*

* Copyright(c) sschulz <AT> techfak.uni-bielefeld.de

* http://opensource.cit-ec.de/projects/humotion

*

* This file may be licensed under the terms of the

* GNU Lesser General Public License Version 3 (the ``LGPL''),

* or (at your option) any later version.

*

* Software distributed under the License is distributed

* on an ``AS IS'' basis, WITHOUT WARRANTY OF ANY KIND, either

* express or implied. See the LGPL for the specific language

* governing rights and limitations.

*

* You should have received a copy of the LGPL along with this

* program. If not, go to http://www.gnu.org/licenses/lgpl.html

* or write to the Free Software Foundation, Inc.,

* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

*

* The development of this software was supported by the

* Excellence Cluster EXC 277 Cognitive Interaction Technology.

* The Excellence Cluster EXC 277 is a grant of the Deutsche

* Forschungsgemeinschaft (DFG) in the context of the German

* Excellence Initiative.

*/

#include <boost/algorithm/string/classification.hpp>

#include <string>

#include "humotion/server/middleware_ros.h"

using humotion::server::MiddlewareROS;

//! constructor

MiddlewareROS::MiddlewareROS(std::string scope, Controller *c)

    : Middleware(scope, c) {

    printf("> using ROS middleware\n");

    // start ros core?

    if (ros::isInitialized()) {

        // oh another process is doing ros comm, fine, we do not need to call it

        tick_necessary_ = false;

    } else {

        // we have to take care of ros

        printf("> no active ros middleware, calling ros::init() "

               "and we will call tick() periodically!\n");

        std::string node_name = "humotion_server__"+ scope;

        node_name.erase(std::remove(node_name.begin(), node_name.end(), '/'), node_name.end());

        printf("> registering on ROS as node %s\n", node_name.c_str());

        ros::M_string no_remapping;

        ros::init(no_remapping, node_name);

        tick_necessary_ = true;

    }

    // create node handle

    ros::NodeHandle n;

    ros::NodeHandle pnh("~");

    // set up subscribers

    mouth_target_subscriber_ = n.subscribe(scope + "/humotion/mouth/target", 150,

                                          &MiddlewareROS::incoming_mouth_target ,

                                          this, ros::TransportHints().unreliable());

    gaze_target_subscriber_  = n.subscribe(scope + "/humotion/gaze/target",  150,

                                          &MiddlewareROS::incoming_gaze_target,

                                          this, ros::TransportHints().unreliable());

    // set up dynamic reconfiguration service

    attach_to_reconfiguration_server(pnh);

}

//! callback for incoming dynamic reconfigure requests:

void MiddlewareROS::dynamic_reconfigure_callback(const humotion::humotionConfig &config,

                                                  uint32_t level) {

  /*// ignore incoming requests as long cam is not set up properly

  if (!hasValidHandle()) {

      return;

  }

  // use some tricks to iterate through all config entries:

  std::vector<ximea_camera::xiAPIConfig::AbstractParamDescriptionConstPtr>::const_iterator _i;

  for (_i = config.__getParamDescriptions__().begin();

       _i != config.__getParamDescriptions__().end(); ++_i) {

      boost::any val;

      boost::shared_ptr<const ximea_camera::xiAPIConfig::AbstractParamDescription>

              description = *_i;

      // fetch actual value:

      description->getValue(config, val);

      //  std::cout << description->name << " " << description->type << "\n";

      // copy data to ximea api:

      if (description->type == "double") {

          dynamicReconfigureFloat(description->name.c_str(),

                                    static_cast<float>(boost::any_cast<double>(val)));

      } else if (description->type == "bool") {

          dynamicReconfigureInt(description->name.c_str(), (boost::any_cast<bool>(val))?1:0);

      } else if (description->type == "int") {

          dynamicReconfigureInt(description->name.c_str(), boost::any_cast<int>(val));

      } else {

          std::cerr << "ERROR: unsupported config type " << description->type  << "\n";

      }

    }*/

}

//! attach to dynamic reconfigure server

void MiddlewareROS::attach_to_reconfiguration_server(ros::NodeHandle priv_nodehandle) {

    ROS_DEBUG("connecting to dynamic reconfiguration server");

    ros::NodeHandle reconf_node(priv_nodehandle, "configuration");

    reconf_server_ = new dynamic_reconfigure::Server<humotion::humotionConfig>(reconf_node);

    reconf_server_->setCallback(boost::bind(

                                    &MiddlewareROS::dynamic_reconfigure_callback, this, _1, _2));

}

//! destructor

MiddlewareROS::~MiddlewareROS() {

}

//! connection ok?

//! \return true if conn is alive

bool MiddlewareROS::ok() {

    return ros::ok();

}

//! do a single tick

void MiddlewareROS::tick() {

    if (tick_necessary_) {

        ros::spinOnce();

    }

}

//! callback to handle incoming mouth  target

void MiddlewareROS::incoming_mouth_target(const humotion::mouth::ConstPtr& msg) {

    // printf("> incoming mouth_target\n");

    MouthState mouth_state;

    mouth_state.position_left   = msg->position.left;

    mouth_state.position_center = msg->position.center;

    mouth_state.position_right  = msg->position.right;

    mouth_state.opening_left   = msg->opening.left;

    mouth_state.opening_center = msg->opening.center;

    mouth_state.opening_right  = msg->opening.right;

    controller_->set_mouth_target(mouth_state);

}

//! callback to handle incoming gaze  target

void MiddlewareROS::incoming_gaze_target(const humotion::gaze::ConstPtr& msg) {

    GazeState gaze_state;

    // printf("> incoming gaze_target [P:%3.1f, T:%3.1f, R:%3.1f] %d = %s\n",

    //          msg->pan, msg->tilt, msg->roll, msg->type,

    //          msg->type==humotion::gaze::GAZETYPE_ABSOLUTE?"ABSOLUTE":"RELATIVE");

    gaze_state.pan  = msg->pan;

    gaze_state.tilt = msg->tilt;

    gaze_state.roll = msg->roll;

    gaze_state.vergence = msg->vergence;

    gaze_state.pan_offset  = msg->pan_offset;

    gaze_state.tilt_offset = msg->tilt_offset;

    gaze_state.roll_offset = msg->roll_offset;

    gaze_state.eyelid_opening_upper = msg->eyelid_opening_upper;

    gaze_state.eyelid_opening_lower = msg->eyelid_opening_lower;

    gaze_state.eyebrow_left = msg->eyebrow_left;

    gaze_state.eyebrow_right = msg->eyebrow_right;

    gaze_state.eyeblink_request_left = msg->eyeblink_request_left;

    gaze_state.eyeblink_request_right = msg->eyeblink_request_right;

    if (msg->gaze_type == humotion::gaze::GAZETYPE_ABSOLUTE) {

        gaze_state.gaze_type = GazeState::GAZETYPE_ABSOLUTE;

    } else {

        gaze_state.gaze_type = GazeState::GAZETYPE_RELATIVE;

    }

    gaze_state.timestamp.set(msg->gaze_timestamp.sec, msg->gaze_timestamp.nsec);

    controller_->set_gaze_target(gaze_state);

}