heissepreise/index.js

const fs = require("fs");
const analysis = require("./analysis");

let items = [];
let itemsJson = "";
(async () => {
  if (!fs.existsSync("data")) {
    fs.mkdirSync("data");
  }

  if (fs.existsSync("data/latest-canonical.json")) {
    items = JSON.parse(fs.readFileSync("data/latest-canonical.json"));
    itemsJson = JSON.stringify(items)
    analysis.updateData("data", newItems => {
      items = newItems;
      itemsJson = JSON.stringify(items)
    });
  } else {
    items = await analysis.updateData("data");
    itemsJson = JSON.stringify(items)
  }
  setInterval(async () => { items = await analysis.updateData("data") }, 1000 * 60 * 60 * 24);

  const express = require('express')
  const compression = require('compression');
  const app = express()
  const port = 3000

  app.use(express.static('site'));
  app.use(compression());

  app.get('/api/index', (req, res) => {
    res.send(itemsJson)
  })

  app.listen(port, () => {
    console.log(`Example app listening on port ${port}`)
  })
})();