Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- router.route('/envelopes').post(function(req, res) {
- var contype = req.headers['content-type'];
- if (!contype || contype.indexOf('application/json') !== 0)
- return res.send(400);
- var payload = req.body;
- if(!payload)
- return res.send(400);
- if(!payload.data)
- return res.json({ warning: "Empty data field."}); // Hmm... okay?
- var event_list = payload.data;
- for(let event of event_list){
- // As per the Caliper implementation, @type and @action are URIs:
- var event_name = event["@type"].split("/")[5];
- if(event["action"])
- event_name += "." + event["action"].split("#")[1];
- var event_body = JSON.stringify(event);
- client.publish(event_name, event_body);
- }
- return res.send(200);
- });
- /*
- events.js:141
- throw er; // Unhandled 'error' event
- ^
- Error: listen EADDRINUSE :::8080
- at Object.exports._errnoException (util.js:870:11)
- at exports._exceptionWithHostPort (util.js:893:20)
- at Server._listen2 (net.js:1237:14)
- at listen (net.js:1273:10)
- at Server.listen (net.js:1369:5)
- at Function.app.listen (/home/tin/Projects/ExtensionEngine/mqtt-node-api/node_modules/express/lib/application.js:531:24)
- at MqttClient.<anonymous> (/home/tin/Projects/ExtensionEngine/mqtt-node-api/server.js:37:7)
- at emitOne (events.js:82:20)
- at MqttClient.emit (events.js:169:7)
- at MqttClient._handleConnack (/home/tin/Projects/ExtensionEngine/mqtt-node-api/node_modules/mqtt/lib/client.js:757:10)
- */
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement