connection.h

Go to the documentation of this file.

/* vim: set et sw=3 tw=0 fo=croqlaw cino=t0:
 *
 * Astxx, the Asterisk C++ API and Utility Library.
 * Copyright (C) 2005-2007  Matthew A. Nicholson
 * Copyright (C) 2005-2007  Digium, Inc.
 * 
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License version 2.1 as published by the Free Software Foundation.
 * 
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

#ifndef ASTXX_MANAGER_CONNECTION_H
#define ASTXX_MANAGER_CONNECTION_H

#include <astxx/manager/message.h>
#include <astxx/manager/basic_action.h>

#include <queue>
#include <map>
#include <string>
#include <boost/function.hpp>
#include <boost/asio.hpp>
#include <boost/signal.hpp>
#include <boost/shared_ptr.hpp>

namespace astxx {
   namespace manager {
      class connection {
         private:
            std::pair<std::string, std::string> parse_header(const std::string& header);
            std::string read_line();
            void read_message();
            message::response read_response();
            message::event read_event();

         public:
            typedef boost::function<void (message::response)> response_handler_t;
            typedef boost::function<void (message::event)> event_handler_t;
            typedef std::queue<message::event> events_t;
            typedef std::queue<message::response> responses_t;
            typedef std::queue<response_handler_t> response_handlers_t;
            typedef std::map<std::string, boost::shared_ptr<boost::signal<void (message::event)> > > event_handlers_t;

            connection(const std::string& host, unsigned short port = 5038);

            void connect(const std::string& host = "", unsigned short port = 0);
            void disconnect();
            bool is_connected() const;

            std::string name() const { return m_name; }
            std::string version() const { return m_version; }

            message::response send_action(const manager::basic_action& command);
            void send_action_async(const manager::basic_action& command, response_handler_t handler);

            message::response operator()(const manager::basic_action& command);
            void operator()(const manager::basic_action& command, response_handler_t handler);

            void process_events();
            void wait_event();

            void process_responses();
            void wait_response();

            void pump_messages();

            boost::signals::connection register_event(const std::string& e, boost::function<void (message::event)> f);

         private:
            boost::asio::io_service io_service;
            boost::asio::ip::tcp::socket socket;

            std::string m_name;
            std::string m_version;

            std::string m_host;
            std::string m_port;

            events_t events;
            responses_t responses;
            response_handlers_t response_handlers;
            event_handlers_t event_handlers;
      };
   }
}

#endif