jobs.js

/* eslint-disable no-console, no-unused-vars */
var config = require('./config.js');
var storage = config.getStorage();

var moment = require('moment');

var jobs = require('require-all')(__dirname + '/jobs');

function update_widget(name, data, next_time) {
  console.log("updating widget: " + name);
  storage.set(name, JSON.stringify({
    payload: data,
    next_time: next_time
  }), function(err, res) {
    if(err) {
      console.log(err);
    }
  });
}

function reschedule(job) {
  setTimeout(function() {start_recurring_job(job)}, job.interval)
}

function start_recurring_job(job) {
    new Promise(job.promise)
    .then(
      function(widget_data) {
        for (var widget in widget_data) {
          update_widget(widget, widget_data[widget], moment().add(job.interval, 'ms'));
        }
        reschedule(job);
      }
    )
    .catch(
      function(error) {
        console.log(error);
        reschedule(job);
      }
    );
}

for (var job in jobs) {
  console.log("Starting job: " + job)
  start_recurring_job(jobs[job]);
}