xcv

var fs = require('fs');
var fileName = "test.csv";
var fileToArray = [];
var fileToJson;
fs.exists(fileName, function(exists) {
  if (exists) {
    fs.stat(fileName, function(error, stats) {
      fs.open(fileName, "r", function(error, fd) {
        var buffer = new Buffer(stats.size);
        fs.read(fd, buffer, 0, buffer.length, null, function(error, bytesRead, buffer) {
          var data = buffer.toString("utf8", 0, buffer.length);
          var lines = data.split("\r\n");
          var fileColCount = 6;
          var lineInArray = [];
          lines.forEach(function(line) {
            lineInArray = line.split(',');
            lineInArray.pop();
            fileToArray.push(lineInArray);
          })
          console.log(fileToArray);
          console.log('***********');
          fileToJson = JSON.stringify(fileToArray);
          console.log(fileToJson);
          fs.close(fd);
        });
      });
    });
  }
});

var socketio = require('socket.io');
var io = socketio.listen(3636);


if (fileToJson) { // Empty?
  console.log(fileToJson);
} else {
  console.log('fileToJson empty !!!');
}
io.sockets.on('connection', function(socket) {
  var clientIp = socket.request.connection.remoteAddress
  console.log('Connection ip address: ' + clientIp);

  socket.emit('candles', {
    'jsoncandles': fileToJson
  });

  //send data to client
  setInterval(function() {
    socket.emit('date', {
      'date': new Date()
    });
  }, 1000);

  //recieve client data
  socket.on('client_data', function(data) {
    process.stdout.write(data.letter);
  });

});