From: Leandro Lucarella <llucax@gmail.com>
Date: Tue, 18 Nov 2003 18:27:35 +0000 (+0000)
Subject: El ControlClient ya puede recibir "frames" con el estado de la planta! :-D
X-Git-Tag: svn_import~264
X-Git-Url: https://git.llucax.com/z.facultad/75.42/plaqui.git/commitdiff_plain/81fe1238505972c209c81f1c729ae910c275cfe9?ds=sidebyside;hp=667418327423ba116d24751926a95a2f1235849c

El ControlClient ya puede recibir "frames" con el estado de la planta! :-D
Esta hecho un poco a las patadas, pero asi puedo laburar un poco mas tranquilo
sabiendo que no trabo el avance del cliente grafico.
El Receiver se levanta cuando se crea el ControlClient, asi que todo lo que hay
que hacer es mandar un comando /transmission/start/default/localhost/7528 para
que empiece a transmitirnos el server (bueno, localhost si corre local).
Se actualiza el ejemplo para tener de referencia (igual todo lo que hay que
hacer es atender la signal_frame_received(const std::string& frame) que entrega
el XML del frame recibido).
---

diff --git a/Server/include/plaqui/server/controlclient.h b/Server/include/plaqui/server/controlclient.h
index 669fba4..f225240 100644
--- a/Server/include/plaqui/server/controlclient.h
+++ b/Server/include/plaqui/server/controlclient.h
@@ -30,6 +30,7 @@
 
 #include "plaqui/server/command.h"
 #include "plaqui/server/connection.h"
+#include "plaqui/server/receiver.h" // TODO TEMPRORAL
 #include <string>
 
 namespace PlaQui {
@@ -65,6 +66,9 @@ namespace Server {
 			/// Señal para indicar que se recibió un error.
 			SignalErrorReceived error_received;
 
+			/// Receptor del estado de la planta TODO Temporal.
+			Receiver receiver;
+
 		// Métodos.
 
 		private:
@@ -113,6 +117,11 @@ namespace Server {
 			 */
 			SignalErrorReceived& signal_error_received(void);
 
+			/**
+			 * Obtiene la señal que avisa cuando se recibió un cuadro.
+			 */
+			Receiver::SignalFrameReceived& signal_frame_received(void);
+
 	};
 
 }
diff --git a/Server/src/controlclient.cpp b/Server/src/controlclient.cpp
index 511def5..48ef328 100644
--- a/Server/src/controlclient.cpp
+++ b/Server/src/controlclient.cpp
@@ -41,6 +41,8 @@ ControlClient::~ControlClient(void) {
 #ifdef DEBUG
 	cerr << __FILE__ << ": destructor." << endl;
 #endif // DEBUG
+	// TODO Temporal: espero que el receiver muera.
+	receiver.finish(true);
 }
 
 ControlClient::ControlClient(const string& host, const Connection::Port& port):
@@ -65,8 +67,10 @@ void ControlClient::real_run(void) {
 	}
 	host = socket->localhost();
 	port = socket->localport();
-	// TODO sacar a la mierda?
+	// TODO sacar signal_connected?
 	connected();
+	// TODO Temporal: el receiver empieza a escuchar.
+	receiver.run();
 	while (!stop) {
 		HTTPResponse response;
 		try {
@@ -115,6 +119,11 @@ ControlClient::SignalErrorReceived& ControlClient::signal_error_received(void) {
 	return error_received;
 }
 
+// TODO - temporal
+Receiver::SignalFrameReceived& ControlClient::signal_frame_received(void) {
+	return receiver.signal_frame_received();
+}
+
 } // namespace Server
 
 } // namespace PlaQui
diff --git a/Server/tests/client_test.cpp b/Server/tests/client_test.cpp
index 0ab975b..c5fc75f 100644
--- a/Server/tests/client_test.cpp
+++ b/Server/tests/client_test.cpp
@@ -50,6 +50,11 @@ void on_ok_received(const string& body) {
 	cout << "       Body: " << body << endl;
 }
 
+void on_frame_received(const string& frame) {
+	cout << "   Frame recibido! :-D" << endl;
+	cout << frame << endl;
+}
+
 void on_error_received(unsigned code) {
 	cout << "   Respuesta recibida: Error nro " << code << "! :-(" << endl;
 }
@@ -88,6 +93,7 @@ int main(int argc, char* argv[]) {
 		client->signal_connected().connect(SigC::slot(on_connected));
 		client->signal_ok_received().connect(SigC::slot(on_ok_received));
 		client->signal_error_received().connect(SigC::slot(on_error_received));
+		client->signal_frame_received().connect(SigC::slot(on_frame_received));
 		client->run();
 		char buf[BUFSIZ];
 		while (cin.getline(buf, BUFSIZ)) {