Estoy tratando de crear una API que envíe una información obtenida por un socket.
Para obtener la información de mi socket, estoy usando zmq.
La idea es que cuando obtenga la información del socket, envíe esta información como respuesta en mi API. El siguiente código pretende hacer eso.
[...] enclaveSocket.on('message', function (message) { res_json.info = message.toString('base64'); res.json(res_json); }); enclaveSocket.send('chesf:public'); [...]En la primera solicitud a mi API express, el retorno es el esperado:
{ "organization": "my_org", "info": "AjCWyQeBNeuMnA3nAUrbprxctrdOgZmjDR5Rmuw6LzzMpALspfNapLMoRGPx9YEGFrqrE5vdHKPb/z0S23i8v" }Pero en la segunda solicitud, mi API falla con el siguiente error:
events.js:160 throw er; // Unhandled 'error' event ^ Error: Can't set headers after they are sent. at ServerResponse.setHeader (_http_outgoing.js:367:11) at ServerResponse.header (/home/matteus/keyvault-node/node_modules/express/lib/response.js:725:10) at ServerResponse.send (/home/matteus/keyvault-node/node_modules/express/lib/response.js:170:12) at ServerResponse.json (/home/matteus/keyvault-node/node_modules/express/lib/response.js:256:15) at exports.Socket.<anonymous> (/home/matteus/keyvault-node/routes/keys.js:58:21) at emitOne (events.js:101:20) at exports.Socket.emit (events.js:188:7) at exports.Socket.Socket._flushRead (/home/matteus/keyvault-node/node_modules/zmq/lib/index.js:636:10) at exports.Socket.Socket._flushReads (/home/matteus/keyvault-node/node_modules/zmq/lib/index.js:676:23) at Object._zmq.onReadReady (/home/matteus/keyvault-node/node_modules/zmq/lib/index.js:297:10)Eso es todo.
Resolví mi problema usando enclaveSocket.once() en lugar de enclaveSocket.on() .
El método once() elimina los detectores de eventos cuando el evento es manejado por la misma función.
Más información aquí: http://nodeguide.com/beginner.html#using-eventemitters