index.js

'use strict'

let express = require('express');
let cors = require('cors');
let bodyParser = require('body-parser');
let TemperatureSensor = require('./temperature-sensor');
let MovementSensor = require('./movement-sensor');
let Controller = require('./controller');

// Init Controller
let controller = new Controller();

// Init API
let app = express();

app.use(bodyParser.json());
app.use(cors());

app.get('/', (req, res) => {
  TemperatureSensor.listSensors().then((sensors) => {
    res.send(sensors);
  });
});

app.get('/movement', (req, res) => {
  let movementSensor = new MovementSensor(23);
  movementSensor.detectMovement().then((movementDetected) => {
    res.send(movementDetected);
  });
});

app.get('/:id/', (req, res) => {
  let name = req.params.id;
  let tempSensor = new TemperatureSensor(name);

  tempSensor.getTemperature().then((temperature) => {
    let response = {
      date: new Date(),
      temp: temperature
    };

    res.send(response);
  });
});

app.get('/status/:active/:type', (req, res) => {
  let active = req.params.active;
  let type = req.params.type;

  if (type === 'movement') {
    controller.toggleMovementMeasurement(active);
  } else if (type === 'temperature') {
    controller.toggleTemperatureMeasurement(active);
  }

  res.send({});
});

app.get('/confirm/:id', (req, res) => {
  let id = req.params.id;

  let unsentAlarms = controller.restConnector.sentAlarms.filter((alarm) => {
    return !alarm.confirmed;
  });

  unsentAlarms.forEach((alarm) => {
    if (alarm.id === id) {
      alarm.confirm();
    }
  });

  console.log('Alarm with ID ' + id + ' confirmed.');
  console.log('Other unconfirmed alarms: ', unsentAlarms);

  res.send({});
});

app.listen(3000, () => {
  console.log('API listening on port 3000!');
});