yas-redis/Cached.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.Cached = void 0;
const os_1 = require("os");
const path_1 = require("path");
const FileReader_1 = require("yaml-scene/src/elements/File/reader/FileReader");
const JsonReader_1 = require("yaml-scene/src/elements/File/reader/JsonReader");
const FileWriter_1 = require("yaml-scene/src/elements/File/writer/FileWriter");
const JsonWriter_1 = require("yaml-scene/src/elements/File/writer/JsonWriter");
const VariableManager_1 = require("yaml-scene/src/singleton/VariableManager");
const FileUtils_1 = require("yaml-scene/src/utils/FileUtils");
class Cached {
    tmpFile;
    reader;
    writer;
    data;
    limit = 50;
    constructor(uri, history) {
        const key = VariableManager_1.VariableManager.Instance.vars.$$md5.encrypt(uri);
        this.tmpFile = (0, path_1.join)((0, os_1.tmpdir)(), key);
        if (history === 'clean')
            this.clean();
        this.writer = new JsonWriter_1.JsonWriter(new FileWriter_1.FileWriter(this.tmpFile));
        this.reader = new JsonReader_1.JsonReader(new FileReader_1.FileReader(this.tmpFile));
        this.data = [];
    }
    clean() {
        FileUtils_1.FileUtils.RemoveFilesDirs(this.tmpFile);
    }
    async load() {
        try {
            const cnt = await this.reader.read();
            if (cnt) {
                cnt.forEach(cmd => this.data.push(cmd));
            }
        }
        catch { }
    }
    async push(cmd) {
        const idx = this.data.indexOf(cmd);
        if (idx !== -1) {
            this.data.splice(idx, 1);
        }
        this.data.splice(0, 0, cmd);
        if (this.data.length > this.limit) {
            this.data.splice(this.limit - 10, 10);
        }
        await this.save();
    }
    async save() {
        await this.writer.write(this.data);
    }
}
exports.Cached = Cached;
//# sourceMappingURL=Cached.js.map