MeshView/main.js at master · bhaumik90/MeshView · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
/*--------------------------------------------------------------------------------*/
/*  REQUIRED MODULES   */
var express = require('express');
var app = express();
var httpServer = require('http').createServer(app);
var path = require("path");
var io = require("socket.io")(httpServer);
var coap = require('coap');
var infoParser = require("./info-parser.js");
var fota = require("./fota-server.js")(coap);
/*--------------------------------------------------------------------------------*/
/*  GLOBAL VARIABLES   */
var httpPort = 8000;
var coapPort = 5683;
var fotaInstances = {};
var fotaStatusUpdateTimer = null;
/*--------------------------------------------------------------------------------*/
/*  SOCKET IO - INTERACTING WITH UI   */
io.on('connection', function(socket) {
  socket.emit('clientConnected', JSON.stringify(infoParser.getGraphNodes()));

  socket.on('getNodeInfo', function(data) {
    let _nodeData = infoParser.getNodeInfo(data);
    socket.emit('sendNodeInfo', JSON.stringify(_nodeData));
    coap.request({host: _nodeData['GLOBAL IP'], method: 'PUT', pathname: '/led'})
        .on('response', function(res) {
          res.on('end', function() {
            process.exit(0)
          });
        })
        .on('error', function(err){
          console.error(err);
        }).end();
  });

  socket.on('labelNode', function(_data){ infoParser.addNodeLabel(_data); });

  socket.on('otaUpload', function(_ota){
    if(_ota.nodeId in fotaInstances) return;
    let _node = infoParser.getNodeInfo(_ota.nodeId)
    startFotaUpdateTimer();
    fotaInstances[_ota.nodeId] = new fota(_node['GLOBAL IP'], _ota.image);
  });
});

infoParser.infoEvent.on('nodeAdded', function(_node){
  io.emit('uiAddNode', JSON.stringify(_node));
});

infoParser.infoEvent.on('nodeRemoved', function(_node){
  io.emit('uiRemoveNode', _node);
});

infoParser.infoEvent.on('nodeParentChanged', function(_node){
  io.emit('uiNodeParentChanged', JSON.stringify(_node));
});

infoParser.infoEvent.on('logAdd', function(_log){
  io.emit('uiAddLog', _log);
});
/*--------------------------------------------------------------------------------*/
/*  CoAP SERVER - RECEIVING DATA FROM NODES   */
var coapServer = coap.createServer({ type: 'udp6' });
coapServer.on('request', function(req, res) {
  if(req.url==="/mv") infoParser.parse(req.payload);
  else if(req.url.split('/')[1]==='5') fotaInstances[req.payload.toString('hex')].handleRequest(req);
  res.end('Hello ' + req.url.split('/')[1] + '\n');
});

coapServer.listen(coapPort, null);
/*--------------------------------------------------------------------------------*/
/*  HTTP SERVER - RENDERING UI   */
app.get('/', function (req, res) {
  res.sendFile(__dirname+'/ui/index.html');
})

app.use(express.static(__dirname+'/ui/'));

httpServer.listen(httpPort);
/*--------------------------------------------------------------------------------*/
function startFotaUpdateTimer()
{
  fotaStatusUpdateTimer = setInterval(function() {
    if(fotaInstances!=={})
    {
      for(let id in fotaInstances)
      {
        if(fotaInstances[id].otaState==="DOWNLOADING")
          io.emit('otaStatus', {id: id, state: fotaInstances[id].otaState, percent: Math.floor(fotaInstances[id].nextBlockNumber/fotaInstances[id].lastBlockNumber*100)});
        else if(fotaInstances[id].otaState==="IDLE")
        {
          io.emit('otaStatus', {id: id, state: fotaInstances[id].otaState, percent: Math.floor(fotaInstances[id].nextBlockNumber/fotaInstances[id].lastBlockNumber*100)});
          delete fotaInstances[id];
        }
      }
    }
    else stopFotaUpdateTimer();
  }, 5000);
}

function stopFotaUpdateTimer()
{
  if(fotaStatusUpdateTimer!==null)
  {
    clearInterval(fotaStatusUpdateTimer);
  }
}
/*--------------------------------------------------------------------------------*/