define(['moment', 'utils/router', 'leaflet', 'gui', 'helper', 'utils/language'], function (moment, Router, L, GUI, helper, Language) { 'use strict'; return function (config) { function handleData(data) { var timestamp; var nodes = []; var links = []; var gateways = {}; for (var i = 0; i < data.length; ++i) { nodes = nodes.concat(data[i].nodes); timestamp = data[i].timestamp; links = links.concat(data[i].links.filter(function (d) { return d.source !== undefined; })); } nodes.forEach(function (node) { node.firstseen = moment.utc(node.firstseen).local(); node.lastseen = moment.utc(node.lastseen).local(); }); var now = moment(); var age = moment(now).subtract(config.maxAge, 'days'); var newnodes = helper.limit('firstseen', age, helper.sortByKey('firstseen', nodes).filter(helper.online)); var lostnodes = helper.limit('lastseen', age, helper.sortByKey('lastseen', nodes).filter(helper.offline)); nodes.forEach(function (d) { d.neighbours = []; if (d.is_gateway && d.network.mesh) { var mesh = d.network.mesh; mesh[Object.keys(mesh)[0]].interfaces.tunnel.forEach(function (mac) { gateways[mac] = d.hostname; }); } }); links.forEach(function (d) { var ids; d.source = nodes.find(function (a) { return a.node_id === d.source; }); d.target = nodes.find(function (a) { return a.node_id === d.target; }); ids = [d.source.node_id, d.target.node_id]; d.source.neighbours.push({ node: d.target, link: d, incoming: false }); d.target.neighbours.push({ node: d.source, link: d, incoming: true }); d.id = ids.join('-'); try { d.latlngs = []; d.latlngs.push(L.latLng(d.source.location.latitude, d.source.location.longitude)); d.latlngs.push(L.latLng(d.target.location.latitude, d.target.location.longitude)); d.distance = d.latlngs[0].distanceTo(d.latlngs[1]); } catch (e) { // ignore exception } }); links.sort(function (a, b) { return b.source_tq - a.source_tq; }); return { now: now, timestamp: moment.utc(timestamp).local(), nodes: { all: nodes, new: newnodes, lost: lostnodes }, links: links, graph: { links: [], nodes: [] }, gateways: gateways }; } var language = new Language(config); var router = new Router(language); var urls = []; if (typeof config.dataPath === 'string' || config.dataPath instanceof String) { config.dataPath = [config.dataPath]; } for (var i in config.dataPath) { if (config.dataPath.hasOwnProperty(i)) { urls.push(config.dataPath[i] + 'meshviewer.json'); } } function update() { language.init(router); return Promise.all(urls.map(helper.getJSON)) .then(handleData); } update() .then(function (d) { var gui = new GUI(config, router, language); gui.setData(d); router.setData(d); router.resolve(); window.setInterval(function () { update().then(function (n) { gui.setData(n); router.setData(n); }); }, 60000); }) .catch(function (e) { document.querySelector('.loader').innerHTML += e.message + '


or report to your community'; console.warn(e); }); }; });