lib/rates.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

const axios = require("axios");
const fs = require("fs");

let binance = require("./binance")();

let fetchRates;
(fetchRates = async () => {
  let date, fx;

  try {
    ({ date, fx } = JSON.parse(fs.readFileSync("fx")));
  } catch {
    l.warn("Failed to read fx file");
  }

  let today = JSON.stringify(new Date()).replace(/T.*/, "").replace(/"/, "");

  if (date !== today) {
    try {
      let { data: { rates: fx }} = await axios.get('https://api.exchangerate.host/latest?base=USD');
      fs.writeFileSync("fx", JSON.stringify({ date, fx }));
    } catch (e) {
      l.error("error fetching rates", e.message);
    }
  }

  app.set("fx", fx);

  setTimeout(fetchRates, 7200000);
})();

setInterval(() => {
  broadcast("rate", app.get("last"));
}, 1000);

setInterval(() => {
  binance.terminate();
  binance = require("./binance")();
}, 360000);