CCats/daemon/include/Server.h

#ifndef SERVER_H
#define SERVER_H

#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/enable_shared_from_this.hpp>

#include <json/json.h>

#include "JsonCommander.h"

using namespace boost::asio;
using ip::tcp;

/**
 * @class con_handler
 *
 * Handler for a connection.
 *
 * Handles and manages a connection between client and server.
 */
class con_handler : public boost::enable_shared_from_this<con_handler> {
private:
	tcp::socket sock;

	/**
	 * max buffer length
	 */
	enum { max_length = 1024 };

	/**
	 * data buffer
	 */
	streambuf buf;

	/**
	 * string builder for json
	 */
	Json::StreamWriterBuilder jsonStringBuilder;

	/**
	 * json reader to parse json strings
	 */
	std::unique_ptr<Json::CharReader> jsonReader;

	/**
	 * Executes json commands
	 */
	JsonCommander jsonCommander;

	/**
	 * File manager used by jsonCommander
	 */
	FileManager fileManager;

	/**
	 * Reads data and binds it to a handler.
	 *
	 * @param handler method pointer to a handler_read_* method
	 */
	void read(void (con_handler::*handler)(const boost::system::error_code &err, size_t bytes_transferred));

	/**
	 * Sends json data over the network.
	 *
	 * @param json json object
	 */
	void sendJson(const Json::Value &json);

	/**
	 * Parses a line of the buffer to a json value object.
	 *
	 * @return json object
	 */
	Json::Value parseMessage();

public:
	/**
	 * Pointer to a con_handler.
	 */
	typedef boost::shared_ptr<con_handler> pointer;

	/**
	 * con_handler constructor
	 *
	 * Creates a con_handler
	 *
	 * @param io_service connection info
	 */
	con_handler(basic_socket_acceptor<ip::tcp>::executor_type &io_service);

	/**
	 * con_handler destructor.
	 */
	~con_handler();

	/**
	 * Creates a new con_handler.
	 *
	 * Allocates a new con_hanlder and returns the pointer.
	 *
	 * @param io_service connection info
	 *
	 * @return con_handler pointer
	 */
	static pointer create(basic_socket_acceptor<ip::tcp>::executor_type &io_service);

	/**
	 * socket getter
	 *
	 * Returns the socket of the connection.
	 *
	 * @return the socket
	 */
	tcp::socket &socket();

	/**
	 * Starts a connection.
	 *
	 * Negotiates a connection and sets everything important to the connection up.
	 */
	void start();

	/**
	 * Read handler
	 *
	 * Will be called if the server expected a version and received something.
	 *
	 * @param err error
	 * @param bytes_transferred amount of transferred bytes
	 */
	void handle_read_version(const boost::system::error_code &err, size_t bytes_transferred);

	/**
	 * Read handler
	 *
	 * Will be called after the version was verifyed. Checks login data.
	 *
	 * @param err error
	 * @param bytes_transferred amount of transferred bytes
	 */
	void handle_read_login(const boost::system::error_code &err, size_t bytes_transferred);

	/**
	 * Read handler
	 *
	 * Will be called after the version and login was verifyed. Executes commands.
	 *
	 * @param err error
	 * @param bytes_transferred amount of transferred bytes
	 */
	void handle_read_command(const boost::system::error_code &err, size_t bytes_transferred);

	/**
	 * Write handler
	 *
	 * Will be called if the server sends something.
	 *
	 * @param err error
	 * @param bytes_transferred amount of transferred bytes
	 */
	void handle_write(const boost::system::error_code &err, size_t bytes_transferred);
};

/**
 * @class Server
 *
 * boost server
 *
 * boost server which creates the handler for the connections.
 */
class Server {
private:
	tcp::acceptor acceptor_;

	/**
	 * Accepts traffic
	 */
	void start_accept();

public:
	/**
	 * Creates a boost server
	 *
	 * @param io_service connection info
	 */
	Server(io_service &io_service);

	/**
	 * Destroys the server
	 */
	~Server();

	/**
	 * Handles traffic?
	 *
	 * @param connection con_handler
	 * @param err error
	 */
	void handle_accept(con_handler::pointer connection, const boost::system::error_code &err);
};

#endif