YarpNetworkManager.hpp

// Authors: see AUTHORS.md at project root.
// CopyPolicy: released under the terms of the LGPLv2.1, see LICENSE at project root.
// URL: https://github.com/asrob-uc3m/robotDevastation
 
#ifndef __RD_YARP_NETWORK_MANAGER_HPP__
#define __RD_YARP_NETWORK_MANAGER_HPP__
 
#include <string>
 
#include <yarp/os/PeriodicThread.h>
#include <yarp/os/PortReaderBuffer.h>
#include <yarp/os/Bottle.h>
#include <yarp/os/RpcClient.h>
#include <yarp/os/BufferedPort.h>
 
#include "NetworkManager.hpp"
#include "Player.hpp"
 
namespace rd{
 
class YarpNetworkManager : public NetworkManager,
                           private yarp::os::PeriodicThread,
                           public yarp::os::TypedReaderCallback<yarp::os::Bottle>
{
    public:
        //------------------ Creation and configuration --------------------------------------------------------------//
        static bool RegisterManager();
 
        virtual ~YarpNetworkManager();
 
        static const std::string id;
 
        //------------------ Manager Startup & Halting ---------------------------------------------------------------//
        virtual bool start();
        virtual bool stop();
        virtual bool isStopped() const;
 
        //------------------------------ Configuration & Listeners ----------------------------------------------------//
        virtual bool configure(const std::string & parameter, const Player & value);
 
        //------------------ Server API ----------------------------------------------------------------------------//
        virtual bool sendPlayerHit(const Player & player, int damage);
        virtual bool login();
        virtual bool logout();
        virtual bool keepAlive();
 
    protected:
        YarpNetworkManager();
 
        void onRead(yarp::os::Bottle& b);
 
        void run();
 
    private:
        YarpNetworkManager(const YarpNetworkManager &);
        YarpNetworkManager & operator=(const YarpNetworkManager &);
 
        static YarpNetworkManager * uniqueInstance;
 
        static const int KEEPALIVE_RATE_MS;
 
 
        yarp::os::RpcClient rpcClient;
        yarp::os::BufferedPort<yarp::os::Bottle> callbackPort;
 
        Player player;
 
        bool started;
};
 
}
 
#endif //-- __RD_NETWORK_MANAGER_HPP__