'use strict'; var logger = require('log4js').getLogger(); var mdot = require('./mdot.js'); var db = require('../server/db-connector').dbConnection; var dbSave = require('../server/db-save')(db); module.exports = function(app) { var express = require('express'); var messageRouter = express.Router(); messageRouter.post('/', function(req, res) { var obj = req.body; if (req.body.type !== 'mDot') { logger.error('Not of the required type!'); res.status(500).json({}); return -1; } else { logger.debug(req.body.type, req.body.device); dbSave.addProcessedEvent(obj) .then(function(d) { 'use strict'; // Logger.info('Finished - Processed'); res.status(200).json({}); }) .catch(function(e) { 'use strict'; logger.error(e); res.status(500).json({}); }); } /* If (!req.params.id) { logger.error('MDot','Missing required parameter'); res.status(400).send({ status: 'error', error: 'missing required parameter' }); return; } if (req.query.hasOwnProperty('start') && req.query.hasOwnProperty('end')) { data.start = req.query.start; data.end = req.query.end; } if (req.params.hasOwnProperty('id')) { data.id = req.params.id; dbMdot.doGet(data) .then((d) => { res.json({events:d}); }) .catch((e) => { logger.error(e); res.status(500).json({}); }); }*/ }); app.use('/apiv2/message/', messageRouter); };