Estoy haciendo una especie de canal de comunicaciones, que envía peticiones y recibe respuestas.
La función que envía una petición, quiero que devuelva una Promise
, que será resuelta por la función de recepción (interna de la clase).
Y ahí me he atascado:
class IOChannel {
constructor( channel ) {
this.$channel = channel;
this.$queue = { };
channel.on( 'message', ( data ) => {
if( 'error' in data ) {
// Es una respuesta con un error. // <- ¿ ?
} else if( 'result' in data ) {
// Es una respuesta. // <- ¿ ?
} );
}
$nextId( ) { ... }
async sendRequest( params ) {
this.$channel.send( {
id: this.$nextId( ),
params: params
} );
return new Promise( ); // <- ¿ ?
}
}
Tanto las solicitudes salientes como las respuestas entrantes están relacionadas mediante el atributo id
del mensaje. La idea era usar la variable this.$queue
como punto de unión entre las solicitudes salientes y las respuestas entrantes, basándome en ese atributo id
.
Pero no se me ocurre como relacionar la función callback de respuesta a un message
con la Promise
generada en la función sendRequest( )
.
¿ Como tengo que modificar mi código para que la función sendMessage( )
devuelva una promesa válida, que será resuelta o rechazada por mi función callback ?
Edito
La intención es invocar esa función sendRequest( )
desde manejadores de rutas de express
:
const express = require( 'express' );
const app = express( );
const ioChannel = new IOChannel( process );
app.post( '/login', body-parser, function( req, res ) {
const view = await ioChannel.send( {
login: req.body.userId,
pass: req.body.pass
} );
res.status( view ? 200 : 401 ).end( );
}
channel
pertenece a la API de node y no lo puedo cambiar :-) Le echo un vistazo al enlace que indicas, gracias :-)