@tdb/state.react/lib/connect.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var tslib_1 = require("tslib");
var rxjs_1 = require("rxjs");
var operators_1 = require("rxjs/operators");
var common_1 = require("./common");
var Connector_1 = require("./components/Connector");
function connect(component, options) {
    if (options === void 0) { options = {}; }
    var autoRender = options.autoRender === undefined ? true : options.autoRender;
    var ConnectWrapper = (function (_super) {
        tslib_1.__extends(ConnectWrapper, _super);
        function ConnectWrapper() {
            var _this = _super !== null && _super.apply(this, arguments) || this;
            _this.state = {};
            _this.unmounted$ = new rxjs_1.Subject();
            _this.init = function (e) {
                _this.loaded = e;
            };
            return _this;
        }
        Object.defineProperty(ConnectWrapper.prototype, "store", {
            get: function () {
                if (this.props.store) {
                    return this.props.store;
                }
                var store = this.loaded && this.loaded.store;
                var path = options.path;
                var result = path ? store.get(path) : store;
                return common_1.R.is(Object, result) ? result : undefined;
            },
            enumerable: true,
            configurable: true
        });
        ConnectWrapper.prototype.componentDidMount = function () {
            var _this = this;
            var store = this.store;
            this.setState({ store: store });
            if (store && autoRender) {
                store.state$.pipe(operators_1.takeUntil(this.unmounted$)).subscribe(function () {
                    try {
                        _this.forceUpdate();
                    }
                    catch (error) {
                        _this.unmounted$.next();
                    }
                });
            }
        };
        ConnectWrapper.prototype.componentWillUnmount = function () {
            this.unmounted$.next();
        };
        ConnectWrapper.prototype.render = function () {
            return (common_1.React.createElement(Connector_1.Connector, { onLoaded: this.init }, this.renderComponent()));
        };
        ConnectWrapper.prototype.renderComponent = function () {
            var store = this.state.store;
            if (!store) {
                return '';
            }
            var props = tslib_1.__assign({}, this.props, { store: store });
            return common_1.React.createElement(component, props);
        };
        return ConnectWrapper;
    }(common_1.React.PureComponent));
    return ConnectWrapper;
}
exports.connect = connect;
//# sourceMappingURL=connect.js.map