yas-redis/Live.js

"use strict";
var __importDefault = (this && this.__importDefault) || function (mod) {
    return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.Live = void 0;
const ElementFactory_1 = require("yaml-scene/src/elements/ElementFactory");
const UserInput_1 = __importDefault(require("yaml-scene/src/elements/UserInput"));
const AutoCompleteSuggestion_1 = require("yaml-scene/src/elements/UserInput/question/AutoCompleteSuggestion");
const VariableManager_1 = require("yaml-scene/src/singleton/VariableManager");
const Functional_1 = require("yaml-scene/src/tags/model/Functional");
const Cached_1 = require("./Cached");
const Redis_1 = require("./Redis");
class Live extends Redis_1.Redis {
    history;
    limit;
    _cmdCaches;
    constructor() {
        super();
        if (this.history === undefined)
            this.history = true;
        if (this.limit === undefined)
            this.limit = 3;
    }
    init(props) {
        super.init(props);
        if (this.history === undefined)
            this.history = true;
        if (this.limit === undefined)
            this.limit = 3;
    }
    async prepare() {
        await this.proxy.applyVars(this, 'history', 'limit');
        await super.prepare();
    }
    async exec() {
        if (this.title)
            this.proxy.logger.info(this.title);
        this.proxy.logger.debug(VariableManager_1.VariableManager.Instance.vars.$$text.gray.underline(this.uri));
        if (this.title)
            console.group();
        try {
            if (!this._cmdCaches && this.history) {
                this._cmdCaches = new Cached_1.Cached(this.uri, this.history);
                await this._cmdCaches.load();
            }
            while (true) {
                const inputCmd = ElementFactory_1.ElementFactory.CreateTheElement(UserInput_1.default);
                inputCmd.init({
                    title: 'Enter command',
                    fallback: '  ',
                    type: 'autocomplete',
                    limit: this.limit,
                    choices: Array.from(this._cmdCaches?.data || []).map(e => {
                        return {
                            title: e,
                            value: e
                        };
                    }),
                    suggest: AutoCompleteSuggestion_1.AutoCompleteSuggestion.INCLUDE_AND_ALLOW_NEW,
                    required: true,
                    var: 'cmd'
                });
                await inputCmd.prepare();
                const { cmd } = await inputCmd.exec();
                try {
                    const newCmd = await this.runCommand({
                        cmd
                    });
                    if (!(newCmd instanceof Functional_1.Functional))
                        this._cmdCaches?.push(cmd);
                    this.proxy.logger.info('');
                }
                catch (err) {
                    this.proxy.logger.error(VariableManager_1.VariableManager.Instance.vars.$$text.red(err.message));
                }
                finally {
                    await inputCmd.dispose();
                }
            }
        }
        finally {
            if (this.title)
                console.groupEnd();
        }
    }
}
exports.Live = Live;
//# sourceMappingURL=Live.js.map