cyboard/dist/mergeWidgetBackends.js

'use strict';

Object.defineProperty(exports, "__esModule", {
    value: true
});
exports.mergeWidgetBackends = mergeWidgetBackends;

var _Observable = require('rxjs/Observable');

var _debug = require('debug');

var _debug2 = _interopRequireDefault(_debug);

require('rxjs/add/observable/merge');

require('rxjs/add/observable/from');

require('rxjs/add/observable/timer');

require('rxjs/add/operator/map');

require('rxjs/add/operator/publishReplay');

require('rxjs/add/operator/retryWhen');

require('rxjs/add/operator/do');

require('rxjs/add/operator/delay');

require('rxjs/add/operator/switchMap');

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

function _toConsumableArray(arr) { if (Array.isArray(arr)) { for (var i = 0, arr2 = Array(arr.length); i < arr.length; i++) { arr2[i] = arr[i]; } return arr2; } else { return Array.from(arr); } }

var debug = (0, _debug2.default)('cyboard.server');

var handleRetry = function handleRetry(id) {
    return function (errors) {
        var timer = 1;
        return errors.switchMap(function () {
            var delay = 2 * timer;
            timer += 1;
            debug('widget backend ' + id + ' failed. Retry in ' + delay + ' seconds.');
            return _Observable.Observable.timer(delay * 1000);
        });
    };
};

var wrapWidgetData = function wrapWidgetData(id) {
    return function (data) {
        return { id: id, data: data };
    };
};

var wrapWidgetBackend = function wrapWidgetBackend(widget) {
    return _Observable.Observable.from(widget.backend).map(wrapWidgetData(widget.id)).retryWhen(handleRetry(widget.id)).publishReplay(1).refCount();
};

function mergeWidgetBackends(config) {
    var backends = Object.values(config).reduce(function (widgets, board) {
        return widgets.concat(board.widgets);
    }, []).filter(function (widget) {
        return !!widget;
    }).map(function (widget) {
        return wrapWidgetBackend(widget);
    });

    return _Observable.Observable.merge.apply(_Observable.Observable, _toConsumableArray(backends));
}