Advertisement
UrQuan

Untitled

Feb 27th, 2017
371
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. router.route('/envelopes').post(function(req, res) {
  2.       var contype = req.headers['content-type'];
  3.       if (!contype || contype.indexOf('application/json') !== 0)
  4.         return res.send(400);
  5.      
  6.       var payload = req.body;
  7.       if(!payload)
  8.         return res.send(400);
  9.       if(!payload.data)
  10.         return res.json({ warning: "Empty data field."}); // Hmm... okay?
  11.  
  12.       var event_list = payload.data;
  13.  
  14.       for(let event of event_list){
  15.         // As per the Caliper implementation, @type and @action are URIs:
  16.         var event_name = event["@type"].split("/")[5];
  17.         if(event["action"])
  18.           event_name += "." + event["action"].split("#")[1];
  19.         var event_body = JSON.stringify(event);
  20.  
  21.         client.publish(event_name, event_body);
  22.       }
  23.      
  24.       return res.send(200);
  25.     });
  26.  
  27. /*
  28.  
  29. events.js:141
  30.       throw er; // Unhandled 'error' event
  31.       ^
  32.  
  33. Error: listen EADDRINUSE :::8080
  34.     at Object.exports._errnoException (util.js:870:11)
  35.     at exports._exceptionWithHostPort (util.js:893:20)
  36.     at Server._listen2 (net.js:1237:14)
  37.     at listen (net.js:1273:10)
  38.     at Server.listen (net.js:1369:5)
  39.     at Function.app.listen (/home/tin/Projects/ExtensionEngine/mqtt-node-api/node_modules/express/lib/application.js:531:24)
  40.     at MqttClient.<anonymous> (/home/tin/Projects/ExtensionEngine/mqtt-node-api/server.js:37:7)
  41.     at emitOne (events.js:82:20)
  42.     at MqttClient.emit (events.js:169:7)
  43.     at MqttClient._handleConnack (/home/tin/Projects/ExtensionEngine/mqtt-node-api/node_modules/mqtt/lib/client.js:757:10)
  44.  
  45. */
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement