fetcher.js

"use strict"

/* Magic Mirror
 * Fetcher
 *
 * By Michael Teeuw http://michaelteeuw.nl edited for Wunderlist by Marcin Bielecki and Dave Richer
 * MIT Licensed.
 */

var WunderlistSDK = require('wunderlist');

/* Fetcher
 * Responsible for requesting an update on the set interval and broadcasting the data.
 *
 * attribute listID string - ID of the Wunderlist list.
 * attribute reloadInterval number - Reload interval in milliseconds.
 */

var Fetcher = function (listID, listFrom, reloadInterval, accessToken, clientID) {
  var self = this;
  if (reloadInterval < 1000) {
    reloadInterval = 1000;
  }

  var reloadTimer = null;
  var items = [];

  var fetchFailedCallback = function () { };
  var itemsReceivedCallback = function () { };

  /* private methods */

  /* fetchTodos()
   * Request the new items.
   */

  var fetchTodos = function () {
    clearTimeout(reloadTimer);
    reloadTimer = null;

    var WunderlistAPI = new WunderlistSDK({
      accessToken: accessToken,
      clientID: clientID
    });

    WunderlistAPI.initialized.done(function () {
    WunderlistAPI.http.tasks.forList(listID)
      .done(function (tasks) {
        items = tasks.map(task => Object.assign(task, {listFrom}));
        self.broadcastItems();
        scheduleTimer();
      })
      .fail(function (resp, code) {
        console.error('there was a Wunderlist problem', resp, code);
      });
    });


  };

  /* scheduleTimer()
   * Schedule the timer for the next update.
   */
  var scheduleTimer = function () {
    clearTimeout(reloadTimer);
    reloadTimer = setTimeout(function () {
      fetchTodos();
    }, reloadInterval);
  };

  /* public methods */

  /* setReloadInterval()
   * Update the reload interval, but only if we need to increase the speed.
   *
   * attribute interval number - Interval for the update in milliseconds.
   */
  this.setReloadInterval = function (interval) {
    if (interval > 1000 && interval < reloadInterval) {
      reloadInterval = interval;
    }
  };

  /* startFetch()
   * Initiate fetchTodos();
   */
  this.startFetch = function () {
    fetchTodos();
  };

  /* broadcastItems()
   * Broadcast the exsisting items.
   */
  this.broadcastItems = function () {
    if (items.length <= 0) {
      return;
    }
    itemsReceivedCallback(self);
  };

  this.onReceive = function (callback) {
    itemsReceivedCallback = callback;
  };

  this.onError = function (callback) {
    fetchFailedCallback = callback;
  };

  this.id = function () {
    return listID;
  };

  this.items = function () {
    return items;
  };
};

module.exports = Fetcher;