X-Git-Url: https://git.llucax.com/z.facultad/75.42/plaqui.git/blobdiff_plain/6e0194f46ac77c18bfeabf84ef94a32f23e41073..d53ded00c10a30a17c7f0aad90acca933a7f4db9:/Server/src/server.cpp?ds=sidebyside diff --git a/Server/src/server.cpp b/Server/src/server.cpp index 6507d6d..37f5c1c 100644 --- a/Server/src/server.cpp +++ b/Server/src/server.cpp @@ -26,40 +26,185 @@ // #include "plaqui/server/server.h" +#include "plaqui/server/connection.h" +#include "plaqui/server/controlserver.h" +#include +// FIXME - sacar sstream (a menos que se necesite) +#include #ifdef DEBUG +# include "plaqui/server/string.h" # include #endif // DEBUG -using namespace Plaqui; +using namespace std; + +namespace PlaQui { + +namespace Server { + +Server::~Server(void) { +#ifdef DEBUG + cerr << __FILE__ << ": destructor." << endl; +#endif // DEBUG +} Server::Server(int port): - socket(sockbuf::sock_stream) { - socket.bind(port); + TCPServer(port) { #ifdef DEBUG - std::cerr << "Escuchando en " << socket.localhost() << - ":" << socket.localport() << "." << std::endl; + cerr << __FILE__ << ": port = " << port << endl; #endif // DEBUG - socket.listen(); } -bool Server::start_transmission(std::string host, int port) { +/// \todo Implementar. +bool Server::start_transmission(string host, int port) { +#ifdef DEBUG + cerr << __FILE__ << ": start_transmission(host = " << host + << " | port = " << port << ")" << endl; +#endif // DEBUG // TODO return false; } + +Connection* Server::new_connection( + const sockbuf::sockdesc& sd) { +#ifdef DEBUG + cerr << __FILE__ << ": new_connection(sd = " << sd.sock << ")" + << endl; +#endif // DEBUG + ControlServer* connection = new ControlServer(sd); + // TODO verificar si el new se hace bien? no creo. + connection->signal_command_received().connect( + SigC::bind( + SigC::slot_class(*this, &Server::on_control_command_received), + connection)); + // TODO: + return connection; +} -bool Server::stop_transmission(std::string host, int port) { +/// \todo Implementar. +bool Server::stop_transmission(string host, int port) { +#ifdef DEBUG + cerr << __FILE__ << ": stop_transmission(host = " << host + << " | port = " << port << ")" << endl; +#endif // DEBUG // TODO return false; } -void Server::real_run(void) { - // FIXME se tiene que ir a la clase para poder frenarlo desde afuera. - bool stop = false; - ControlServer* control_server; - while (!stop) { - control_server = new ControlServer(socket.accept()); - controllers.push_back(control_server); - control_server->run(); +/// \todo Implementar. +void Server::on_control_command_received(const Command& command, + ControlServer* server) { +#ifdef DEBUG + cerr << __FILE__ << ": on_control_command_received(target = " + << command.get_target() << ", command = " << command.get_command() + << ", args = [" << String::join(command.get_args(), ", ") << "])" + << endl; +#endif // DEBUG + HTTPResponse response(HTTPMessage::OK); + if (command.get_target() == "server") { +#ifdef DEBUG + cerr << __FILE__ << ": server" << endl; +#endif // DEBUG + if (command.get_command() == "status") { + // FIXME + stringstream response_xml; + response_xml << "" << endl; + response_xml << " " << endl; + response_xml << " PlaQui v0.6" << endl; + response_xml << " " << endl; + response_xml << " " << endl; + response_xml << "

PlaQui

" << endl; + response_xml << "

versión 0.6

" << endl; + response_xml << "

Comando

" << endl; + response_xml << "

Target: " << command.get_target() << endl; + response_xml << "
Command: " << command.get_command() << endl; + response_xml << "
Argumentos:" << endl; + response_xml << "
1. " << *i << "
" << endl; + response_xml << "

" << endl; + response_xml << "

Desarrollado por

" << endl; + response_xml << "

Nicolás Dimov.
Leandro Lucarella.
Ricardo Markiewicz.

" << endl; + response_xml << "

" << endl; + response_xml << " Copyleft 2003 - bajo los " << endl; + response_xml << " términos de la licencia GPL" << endl; + response_xml << "

PlaQui

" << endl; + response_xml << "

versión 0.6

" << endl; + response_xml << "

Lista de conexiones:

" << endl; + response_xml << "

" << i->host + << ":" << i->port << " [host << "/" << i->port << "\">deconectar]

" << endl; + response_xml << "

" << endl; + response_xml << " Copyleft 2003 - bajo los " << endl; + response_xml << " términos de la licencia GPL" << endl; + response_xml << "

" << endl; + response_xml << " " << endl; + response_xml << "" << endl; + response.status_code = HTTPMessage::OK; + response.set_body(response_xml.str()); + } else if (command.get_command() == "stop") { + // TODO server->finish(); + response.set_body("La conexión se cerrará en instantes..."); + } else { + response.status_code = HTTPMessage::NOT_FOUND; + response.set_body("Invalid command for 'connection' taget!"); + } + } else if (command.get_target() == "transmission") { + response.status_code = HTTPMessage::NOT_FOUND; + response.set_body("Invalid command for 'transmission' taget!"); + } else if (command.get_target() == "plant") { + response.status_code = HTTPMessage::NOT_FOUND; + response.set_body("Invalid command for 'plant' taget!"); + } else { + response.status_code = HTTPMessage::NOT_FOUND; + response.set_body("Invalid Target!"); } + // FIXME + response.headers["Content-Type"] = "text/html; charset=iso-8859-1"; + response.headers["Connection"] = "close"; + server->send(response); + // FIXME con timeout no debería ser necesario. Verificar cabecera Connection + // para saber si hay que finish()earlo o no. + // server->finish(); } +} // namespace Server + +} // namespace PlaQui +