implementation in node

node

var msgpack = require('msgpack-js');
var unirest = require('unirest');
var http = require('http');
var net = require('net');
var clients = {};
 var Buffer = require('buffer').Buffer;

 



var HOST = '127.0.0.1';
var PORT = 6969;

net.createServer().on('connection', function(sock) {

    clients[0]=sock;
    console.log('CONNECTED: ' + sock.remoteAddress +':'+ sock.remotePort);
    

    sock.on('data', function(data) {
        
        var msgdata = msgpack.encode(data);
        var msglength = data.length;
     var buffer = new buffer(10);
     buffer = [0xd50000]+msglength;
     


        console.log('DATA in string' + sock.remoteAddress + ': ' + data);
        console.log(msgdata);
        console.log(clients[1]);
     sock.write(buffer);
        sock.write(data);

        unirest.post('http://localhost:3000/devices')
.headers({ 'Accept': 'application/json', 'Content-type' : 'application/json' })
.send({"hid":"switch1","name":"1234"} )
.end(function (response) {
  console.log(response.body);
});
console.log("sent to the server");


        
    });
    
    // Add a 'close' event handler to this instance of socket
    sock.on('close', function(data) {
        console.log('CLOSED: ' + sock.remoteAddress +' '+ sock.remotePort);
    });
    
}).listen(PORT, HOST);

var requestListener = function (req, res) {
  res.writeHead(200);
  res.end('You have posted!\n');
  sock=clients[0];
       sock.write("data from http server");


    
}

var server = http.createServer(requestListener);
server.listen(8080);
console.log("running on 8080");