app.js

const { calcTimeout } = require('./utils');
const { triggerEmailSend } = require('./emails');
const { getSensorData } = require('./purple_air');
const express = require('express');
const app = express();

let currentTimout = null;
let lastReading = null;

async function run() {
  aqi = await getSensorData();
  console.log(aqi, 'returned aqi');
  triggerEmailSend(aqi, lastReading);
  return aqi;
}

async function setSleepInt() {
  const aqi = await run();
  const timeout = calcTimeout(aqi, lastReading, currentTimout);
  lastReading = aqi;
  currentTimout = timeout;
  console.log(`Waiting ${timeout} minutes between checks`);
  setTimeout(setSleepInt, timeout * 60000);
}

setSleepInt();

const port = 8080;
app.listen(port, () => {
  console.log(`aqiapp: listening on port ${port}`);
});