RT_Control_API.h

/***************************************************************************
*
*                       Copyright (c) 2006 - 2010  Argo SE, Inc. All rights reserved.
*
* The following source code, and the ideas, expressions and concepts
* incorporated therein, as well as the ideas, expressions and concepts of
* any other material (whether tangible or intangible) disclosed in
* conjunction with this source code, are the exclusive and proprietary
* property, and constitutes confidential information, of Argo SE, Inc.
* Accordingly, the user of this source code
* agrees that it shall continue to be bound by the terms and conditions of
* any and all confidentiality agreements executed with Argo SE, Inc.
* concerning the disclosure of the source code and any other materials in
* conjunction therewith.
*
*/


#pragma once

// stl
#include <list>
#include <map>
// ace
#include <ace/Service_Object.h>

#include "rt_parameters.h"

class LogAdapterContainer;

namespace rt_lib
{
        class RTControl;

}

namespace rt_ctrl
{

using namespace rt_lib;

struct IRobotInfoConsumer
{
        virtual void process_message(const char* server_id, const char* robot_id, const char* buf, int len) = 0;

        virtual void process_ACK_message(const std::string& server_id, RTControl&) = 0;
        virtual void process_logon_server(const std::string& server_id) = 0;
        virtual void process_logout_server(const std::string& server_id) = 0;
        virtual void process_available_robot_types(const std::string& server_id) = 0;
        virtual void process_active_robots(const std::string& server_id) = 0;
        virtual void process_xml_report(const std::string& server_id, const std::string& robot_id, const std::string& report_xml) = 0;
};

struct RobotInstanceInfo
{
        std::string     trader_name_;
        std::string robot_name_;
        std::string     robot_id_;
        time_t          init_time_;     
        int                     robot_state_;
        std::string status_str_;

        std::map<std::string,std::string> xml_reports_;
};

struct ServerInfo
{
        ServerInfo()
                        :heartbeat_interval_(10)
                        ,last_heartbeat_time_(0)
                        ,authorized_(false)
                        ,robot_types_received_(false)
                        ,active_robots_received_(false)
                {}

        void logout() 
        {
                        authorized_ = false;
                        robot_types_received_ = false;
                        active_robots_received_ = false;
                        last_heartbeat_time_ = 0;
                        heartbeat_interval_ = 0;
        }

        std::string server_id_;
        time_t          last_heartbeat_time_;
        time_t          heartbeat_interval_;
        bool            authorized_;
        bool            robot_types_received_;
        bool            active_robots_received_;

        std::map<std::string, RobotType> robot_types_;

        std::map<std::string, RobotInstanceInfo> active_robots_;
};

class IRTController
{
public:
        
        virtual int init(const char* cfg_file) = 0;
        virtual int fini() = 0;
        virtual int init_log(const LogAdapterContainer* log_adapters, const char* cfg_file) = 0;
        virtual bool authorized() = 0;

        virtual void get_available_robots_request(const std::string & server_id) = 0;
        virtual void get_active_robots_request(const std::string & server_id) = 0;
        
        virtual void new_robot_instance_request( const std::string & robot_name, const std::string& server_id, std::list<RobotTypeParameter>& params) = 0;
        
        virtual void start_robot_instance_request( const std::string & robot_name, const std::string& server_id, const std::string& robot_id) = 0;
        virtual void stop_robot_instance_request( const std::string & robot_name, const std::string& server_id, const std::string& robot_id) = 0;
        virtual void delete_robot_instance_request( const std::string & robot_name, const std::string& server_id, const std::string& robot_id) = 0;
        
        virtual void init_robot_instance_request( const std::string & robot_name, const std::string& server_id, const std::string& robot_id) = 0;
        virtual void set_robot_instance_parameters_request( const std::string & robot_name, const std::string& server_id, const std::string& robot_id, std::list<RobotTypeParameter>& params) = 0;
        virtual void set_del_on_disconnect_flag_request(const std::string& server_id, bool kill_on_disconnect) = 0;

        virtual void send_message(const char* server_id, const char* robot_id, const char* buf, int len) = 0;
        

        virtual IRobotInfoConsumer*             robot_info_consumer()           = 0;
        virtual void robot_info_consumer(IRobotInfoConsumer* val)       = 0;

        virtual const std::string& trader_name()                                        = 0;

        virtual std::map<std::string, ServerInfo >& server_map()        = 0;
};

struct IRTControllerService : public ACE_Service_Object
{
        virtual IRTController* get_controller() = 0;
};



}

---