stream.js

var Promise = require('promise');
var request = require('request');
var URLToolkit = require('url-toolkit');

var i = 0;

function Stream(config) {
  var self = this;
  this.name = config.name || ('s' + ++i);
  this.url = config.url;
  this.content = null;
  this.refreshInterval = config.refreshInterval || 1500;

  this.intervalRefresh = function () {
    setTimeout(function () {
      self.refresh().then(self.intervalRefresh, self.intervalRefresh);
    }, self.refreshInterval);
  }
}

/**
 * @returns {Promise}
 */
Stream.prototype.refresh = function () {
  var self = this;
  var promise = new Promise(function (resolve, reject) {
    request.get(self.url, {timeout: 1000}, function (err, response, body) {
      if (err) {
        reject(err);
        return;
      }
      if (response.statusCode !== 200) {
        reject(response.statusCode);
      }
      resolve(body);
    });
  });
  promise.then(function (value) {
    self.content = value.replace(/.*\.ts/g, function (match) {
      return URLToolkit.buildAbsoluteURL(self.url, './' + match);
    });
    return self.content;
  });
  return promise;
};

module.exports = Stream;