X-Git-Url: https://git.llucax.com/z.facultad/75.42/plaqui.git/blobdiff_plain/802f79cdb0d688127b8a639cd3173d801a1466cd..63715b9ec8f3b126b4e495a4c4485cd68fd6973a:/Server/include/plaqui/server/server.h diff --git a/Server/include/plaqui/server/server.h b/Server/include/plaqui/server/server.h index 6265b6f..21a1958 100644 --- a/Server/include/plaqui/server/server.h +++ b/Server/include/plaqui/server/server.h @@ -28,11 +28,14 @@ #ifndef PLAQUI_SERVER_H #define PLAQUI_SERVER_H +#include "plaqui/server/tcpserver.h" #include "plaqui/server/controlserver.h" #include "plaqui/server/transmitter.h" +#include "plaqui/server/plant.h" +#include "plaqui/server/command.h" #include #include -#include +#include namespace PlaQui { @@ -40,75 +43,119 @@ namespace Server { /** * Servidor de plantas químicas. - * Maneja muchas conexiones, de control o de transmisión. + * Maneja múltiples conexiones, de control o de transmisión. */ - class Server: public Runnable { + class Server: public TCPServer { + + // Tipos. + + private: + + /// Lista de plantas químicas. + typedef std::map PlantList; + + // Atributos. private: - /// Lista de conexiones de control. - typedef std::list ControllerList; + // Plantas disponibles en el servidor. + PlantList plants; + + /// Mutex para las plantas. + Glib::Mutex plants_mutex; + + // Métodos. + + protected: + + /** + * Obtiene una nueva \ref Connection "conexión". + * + * \param sd Descriptor del socket de la nueva conexión. + * + * \return Nueva conexión. + */ + virtual Connection* new_connection(const sockbuf::sockdesc& sd); + + /** + * Maneja el comando server/status. + */ + HTTPResponse* cmd_server_status(void) const; + + /** + * Maneja el comando connection/list. + */ + HTTPResponse* cmd_connection_list(void); + + /** + * Maneja el comando connection/stop. + */ + HTTPResponse* cmd_connection_stop(const Command& command); + + /** + * Maneja el comando transmission/list. + */ + HTTPResponse* cmd_transmission_list(void); - /// Lista de conexiones de control. - typedef std::list TransmitterList; + /** + * Maneja el comando transmission/start. + */ + HTTPResponse* cmd_transmission_start(const Command& command); - /// Socket para escuchar conexiones. - sockinetbuf socket; + /** + * Maneja el comando transmission/stop. + */ + HTTPResponse* cmd_transmission_stop(const Command& command); - /// Conexiones de control. - ControllerList controllers; + /** + * Maneja el comando plant/list. + */ + HTTPResponse* cmd_plant_list(void); - /// Transmisiones del estado de las plantas. - TransmitterList transmissions; + /** + * Maneja el comando plant/get. + */ + HTTPResponse* cmd_plant_get(const Command& command); /** - * Entra en el loop para atender conexiones. + * Maneja el comando plant/stop. */ - virtual void real_run(void); + HTTPResponse* cmd_plant_stop(const Command& command); public: /** * Destructor. */ - virtual ~Server(void) {} + virtual ~Server(void); /** * Constructor. * * \param port Puerto en el cual escuchar. */ - Server(int port = 7522); + Server(const std::string& plant_filename, + const Connection::Port& port = 7522); /** - * Comienza la transimisión del estado de una planta. - * - * \param host Host al cual se quiere transmitir. - * \param port Puerto al cual transmitir. - * - * \return true si se pudo empezar a transmitir, false si no. - * - * \todo Ver si es necesario que devuelva algo y si devuelve ver si - * no sería mejor que dé más información (si no se pudo abrir - * o si ya estaba abierto por ejemplo. + * Maneja los comandos recibidos por las conexiones. */ - bool start_transmission(std::string host = "localhost", - int port = 7528); + void on_control_command_received(const Command& command, + ControlServer* controlserver); /** - * Finaliza la transimisión del estado de una planta. - * - * \param host Host al cual se quiere dejar de transmitir. - * \param port Puerto al cual dejar de transmitir. + * Se encarga de borrar una planta de la lista cuando finaliza. * - * \return true si se pudo empezar a transmitir, false si no. + * \param connection Conexión a eliminar. + */ + void on_plant_finished(const char* plant); + + /** + * Envia el estado de una planta cuando esta se actualiza. * - * \todo Ver si es necesario que devuelva algo y si devuelve ver si - * no sería mejor que dé más información (si no se pudo abrir - * o si ya estaba abierto por ejemplo. + * \param plant Planta actualizada. */ - bool stop_transmission(std::string host = "localhost", - int port = 7528); + void on_plant_updated(const Plant* const); };