/*!
 * \file json_rpc_http_server.h
 * \brief Header for Json_rpc_http_server class
 */

#include "json_rpc_http_server.h"

#include <iostream>

/*!
 * \namespace RPC
 * \brief RPC related utilities
 */
namespace RPC
{

  /**
   * \brief Constructor
   * \param ip IP address to bind
   * \param port Port number to bind
   * \param ev_handler Event handler function pointer
   */
  Json_rpc_http_server::Json_rpc_http_server(const std::string &ip, const std::string &port,
    const std::string &path, void (*ev_handler)(struct ns_connection *nc, int ev, void *ev_data))
  {
    m_ip = ip;
    m_port = port;
    m_path = path;
    m_is_running = false;
    m_ev_handler = ev_handler;
  }

  /**
   * \brief Destructor
   */
  Json_rpc_http_server::~Json_rpc_http_server()
  {
    stop();
  }

  /*!
   * \brief Starts the server
   * \return True if start was successful
   */
  bool Json_rpc_http_server::start()
  {
    if (m_is_running)
    {
      return false;
    }
    m_is_running = true;
    ns_mgr_init(&mgr, NULL);
    nc = ns_bind(&mgr, (m_ip + ":" + m_port + "/" + m_path).c_str(), m_ev_handler);
    if (!nc)
    {
      return false;
    }
    ns_set_protocol_http_websocket(nc);
    // Start a new thread so it doesn't block.
    server_thread = new boost::thread(&Json_rpc_http_server::poll, this);
    return true;
  }

  /*!
   * \brief Repeatedly loops processing requests if any.
   */
  void Json_rpc_http_server::poll()
  {
    // Loop until the server is running and poll.
    while (m_is_running) {
      ns_mgr_poll(&mgr, 1000);
    }
  }

  /*!
   * \brief Stops the server
   */
  void Json_rpc_http_server::stop()
  {
    m_is_running = false;
    server_thread->join();
    delete server_thread;
    ns_mgr_free(&mgr);
  }
}