const express = require('express');

const app = express();

const server = require('http').Server(app);

const io = require('socket.io')(server);

const hbs = require('hbs');

const ttn = require('ttn');

const fs = require('fs');

const Path = require('path');

// improved database

const dbFile = Path.join(__dirname, 'db.json');

// Some options for express (node.js web app library)

hbs.registerPartials(__dirname + '/views/partials');

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

app.set('view engine', 'html');

app.set('views', __dirname + '/views');

app.engine('html', hbs.__express);

// Store some state about all applications

let applications = {};

// Store some state about all devices

let devices = {};

// Note here what data you're interested in, and how it can be obtained from a payload message

const config = {

// Replace this with your own key

mapsApiKey: 'AIzaSyBVHcLKC3ja-ZCsyWQLe0eBB3q28F7V6X0',

title: 'IPG - Redes de Sensores MCM 2019',

dataMapping: {

temperature: {

graphTitle: 'Temperatura',

yAxisLabel: 'Temperatura (°C)',

minY: 0, // suggested numbers, if numbers out of this range are received the graph will adjust

maxY: 50,

numberOfEvents: 30, // no. of events we send to the client

data: payload => payload.payload_fields.Temperatura

},

humidity: {

graphTitle: 'Humidade',

yAxisLabel: 'Humidade (%)',

minY: 0, // suggested numbers, if numbers out of this range are received the graph will adjust

maxY: 50,

numberOfEvents: 30, // no. of events we send to the client

data: payload => payload.payload_fields.Humidade

},

lux: {

graphTitle: 'Lux',

yAxisLabel: 'Lux (lux)',

minY: 0, // suggested numbers, if numbers out of this range are received the graph will adjust

maxY: 10,

numberOfEvents: 30, // no. of events we send to the client

data: payload => payload.payload_fields.Luminosidade

},

// want more properties? just add more objects here

},

mapCenter: {

lat: 40.771888732910156,

lng: -7.353153228759766

}

};

const dataMapping = config.dataMapping;

const mapCenter = config.mapCenter;

if (fs.existsSync(dbFile)) {

console.time('LoadingDB');

let db = JSON.parse(fs.readFileSync(dbFile, 'utf-8'));

devices = db.devices;

for (appId in db.applications) {

if (db.applications.hasOwnProperty(appId)) {

connectApplication(appId, db.applications[appId]).catch(err => console.error(err));

}

}

console.timeEnd('LoadingDB');

}

// And handle requests

app.get('/', function (req, res, next) {

let d = Object.keys(devices).map(k => {

let keys = k.split(/\:/g);

let o = {

appId: keys[0],

devId: keys[1],

eui: devices[k].eui,

lat: 40.771888732910156,

lng: -7.353153228759766,

//lat: payload => payload.payload_fields.latitude,

//lng: payload => payload.payload_fields.longitude,

// lat: devices[k].lat,

// lng: devices[k].lng,

};

for (let mapKey of Object.keys(dataMapping)) {

devices[k][mapKey] = devices[k][mapKey] || [];

// grab last X events from the device

o[mapKey] = devices[k][mapKey].slice(Math.max(devices[k][mapKey].length - (dataMapping[mapKey].numberOfEvents || 30), 1));

}

return o;

})

// Render index view, with the devices based on mapToView function

res.render('index', {

devices: JSON.stringify(d),

config: JSON.stringify(config),

title: config.title,

mapsApiKey: config.mapsApiKey

});

});

io.on('connection', socket => {

socket.on('connect-application', (appId, accessKey) => {

console.log('Connecting to application', appId, accessKey);

connectApplication(appId, accessKey)

.then(() => socket.emit('connected', appId))

.catch(err => socket.emit('connect-failed', JSON.stringify(err)));

});

socket.on('location-change', (appId, devId, lat, lng) => {

let key = appId + ':' + devId;

if (!devices[key]) {

console.error('Device not found', appId, devId);

return;

}

console.log('Location changed', appId, devId, lat, lng);

let d = devices[key];

d.lat = lat;

d.lng = lng;

io.emit('location-change', {

appId: appId,

devId: devId,

eui: d.eui,

lat: d.lat,

lng: d.lng

}, lat, lng);

});

});

//server.listen(process.env.PORT || 3000, process.env.HOST || '0.0.0.0', function () {

// console.log('Web server listening on port %s!', process.env.PORT || 3000);

//});

const port=process.env.PORT || 3000

server.listen(port,() => {

console.log('Server running at port '+port);

});

function connectApplication(appId, accessKey) {

}

function exitHandler(options, err) {

}

process.on('exit', exitHandler.bind(null, { cleanup: true }));

process.on('SIGINT', exitHandler.bind(null, { exit: true }));

process.on('SIGUSR1', exitHandler.bind(null, { exit: true }));

process.on('SIGUSR2', exitHandler.bind(null, { exit: true }));

process.on('uncaughtException', exitHandler.bind(null, { exit: true }));