Asincronía en proxy

[sergimbo]

Hola. Estoy implementando una especie de proxy entre dos servidores llamados A y B respectivamente. El proxy lo llamare P.
Por un lado el servidor A importa funciones del proxy P (mediante require) y lo utiliza para intercambiar información con B. Aquí el codigo en cuestion:

Servidor A

Código:

....
...
var p = require('./p.js');

...
...
console.log(p.getMessages());

Por otro lado, aqui el codigo del proxy P que contacta con el servidor B para conseguir una lista de mensajes:

Código:

var net = require('net');

var HOST = '127.0.0.1';
var PORT = 10100;

var client = new net.Socket();

exports.getMessages = function () {
	client.write('getMessages);

        client.on('data', function(data) {
	console.log("Received: " + data);
	        return data;
        });
}
......

El problema, como podreis haber podido deducir, es que cuando A realiza el console.log, P todavía no ha obtenido el valor "data" de B por lo que se muestra vacio.
He estado buscando información y no se si deberia usar promesas para solucionar esto.
Podríais ponerme un ejemplo de solución a este problema?

Saludos y gracias de antemano.

[Carlangueitor]

Puedes usar promesas o callbacks. Por ejemplo:

Con callbacks:

Código Javascript:

exports.getMessages = function (cb) {
    client.write('getMessages');
 
        client.on('data', cb);
};
 
////////
 
p.getMessages(function(data){
    console.log("Received: " + data);
});
 

Con promesas:

Código Javascript:

exports.getMessages = function (cb) {
        return new Promise(function(resolve) {
        client.write('getMessages');
 
            client.on('data', resolve);
       });
};
 
////////
 
p
  .getMessages()
  .then(function(data) {
     console.log("Received: " + data);
  });
 

Saludos

[sergimbo]

Hola,
Muchas gracias por tu respuesta. Me ha sido de gran ayuda.

Ahora bien, con el console.log("Received: " + data); me muestra por lo que recibe, pero en cambio, si hago por ejemplo

Código:

sock.emit ('sending data', data);

parece que no envia nada. Sabrias decirme por que?

Soy nuevo en la programacion de servidor asincrona y me esta costanto un poco el tema de los callbacks.
Gracias por tu ayuda.

Saludos

[Carlangueitor]

Habría que ver más código para no adivinar.

Saludos