@neo-one/node-storage-cache/read.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
function createReadStorage({ cache, storage, serializeKeyString, }) {
    const get = async (key) => {
        const keyString = serializeKeyString(key);
        const value = cache.get(keyString);
        if (value !== undefined) {
            return value;
        }
        return storage.get(key).then((val) => {
            cache.set(keyString, val);
            return val;
        });
    };
    const tryGet = async (key) => {
        const keyString = serializeKeyString(key);
        const value = cache.get(keyString);
        if (value !== undefined) {
            return value;
        }
        return storage.tryGet(key).then((val) => {
            if (val !== undefined) {
                cache.set(keyString, val);
            }
            return val;
        });
    };
    return { get, tryGet };
}
exports.createReadStorage = createReadStorage;
function createReadAllStorage({ cache, storage, serializeKeyString, }) {
    const readStorage = createReadStorage({
        cache,
        storage,
        serializeKeyString,
    });
    return {
        get: readStorage.get,
        tryGet: readStorage.tryGet,
        all$: storage.all$,
    };
}
exports.createReadAllStorage = createReadAllStorage;
function createReadGetAllStorage({ cache, storage, serializeKeyString, }) {
    const readStorage = createReadStorage({
        cache,
        storage,
        serializeKeyString,
    });
    return {
        get: readStorage.get,
        tryGet: readStorage.tryGet,
        getAll$: storage.getAll$,
    };
}
exports.createReadGetAllStorage = createReadGetAllStorage;

//# sourceMappingURL=data:application/json;charset=utf8;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbInJlYWQudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7QUFLQSxTQUFnQixpQkFBaUIsQ0FBYSxFQUM1QyxLQUFLLEVBQ0wsT0FBTyxFQUNQLGtCQUFrQixHQUtuQjtJQUNDLE1BQU0sR0FBRyxHQUFHLEtBQUssRUFBRSxHQUFRLEVBQWtCLEVBQUU7UUFDN0MsTUFBTSxTQUFTLEdBQUcsa0JBQWtCLENBQUMsR0FBRyxDQUFDLENBQUM7UUFDMUMsTUFBTSxLQUFLLEdBQUcsS0FBSyxDQUFDLEdBQUcsQ0FBQyxTQUFTLENBQUMsQ0FBQztRQUNuQyxJQUFJLEtBQUssS0FBSyxTQUFTLEVBQUU7WUFDdkIsT0FBTyxLQUFLLENBQUM7U0FDZDtRQUVELE9BQU8sT0FBTyxDQUFDLEdBQUcsQ0FBQyxHQUFHLENBQUMsQ0FBQyxJQUFJLENBQUMsQ0FBQyxHQUFHLEVBQUUsRUFBRTtZQUNuQyxLQUFLLENBQUMsR0FBRyxDQUFDLFNBQVMsRUFBRSxHQUFHLENBQUMsQ0FBQztZQUUxQixPQUFPLEdBQUcsQ0FBQztRQUNiLENBQUMsQ0FBQyxDQUFDO0lBQ0wsQ0FBQyxDQUFDO0lBRUYsTUFBTSxNQUFNLEdBQUcsS0FBSyxFQUFFLEdBQVEsRUFBOEIsRUFBRTtRQUM1RCxNQUFNLFNBQVMsR0FBRyxrQkFBa0IsQ0FBQyxHQUFHLENBQUMsQ0FBQztRQUMxQyxNQUFNLEtBQUssR0FBRyxLQUFLLENBQUMsR0FBRyxDQUFDLFNBQVMsQ0FBQyxDQUFDO1FBQ25DLElBQUksS0FBSyxLQUFLLFNBQVMsRUFBRTtZQUN2QixPQUFPLEtBQUssQ0FBQztTQUNkO1FBRUQsT0FBTyxPQUFPLENBQUMsTUFBTSxDQUFDLEdBQUcsQ0FBQyxDQUFDLElBQUksQ0FBQyxDQUFDLEdBQUcsRUFBRSxFQUFFO1lBQ3RDLElBQUksR0FBRyxLQUFLLFNBQVMsRUFBRTtnQkFDckIsS0FBSyxDQUFDLEdBQUcsQ0FBQyxTQUFTLEVBQUUsR0FBRyxDQUFDLENBQUM7YUFDM0I7WUFFRCxPQUFPLEdBQUcsQ0FBQztRQUNiLENBQUMsQ0FBQyxDQUFDO0lBQ0wsQ0FBQyxDQUFDO0lBRUYsT0FBTyxFQUFFLEdBQUcsRUFBRSxNQUFNLEVBQUUsQ0FBQztBQUN6QixDQUFDO0FBeENELDhDQXdDQztBQUVELFNBQWdCLG9CQUFvQixDQUFhLEVBQy9DLEtBQUssRUFDTCxPQUFPLEVBQ1Asa0JBQWtCLEdBS25CO0lBQ0MsTUFBTSxXQUFXLEdBQUcsaUJBQWlCLENBQUM7UUFDcEMsS0FBSztRQUNMLE9BQU87UUFDUCxrQkFBa0I7S0FDbkIsQ0FBQyxDQUFDO0lBRUgsT0FBTztRQUNMLEdBQUcsRUFBRSxXQUFXLENBQUMsR0FBRztRQUNwQixNQUFNLEVBQUUsV0FBVyxDQUFDLE1BQU07UUFDMUIsSUFBSSxFQUFFLE9BQU8sQ0FBQyxJQUFJO0tBQ25CLENBQUM7QUFDSixDQUFDO0FBcEJELG9EQW9CQztBQUVELFNBQWdCLHVCQUF1QixDQUFtQixFQUN4RCxLQUFLLEVBQ0wsT0FBTyxFQUNQLGtCQUFrQixHQUtuQjtJQUNDLE1BQU0sV0FBVyxHQUFHLGlCQUFpQixDQUFDO1FBQ3BDLEtBQUs7UUFDTCxPQUFPO1FBQ1Asa0JBQWtCO0tBQ25CLENBQUMsQ0FBQztJQUVILE9BQU87UUFDTCxHQUFHLEVBQUUsV0FBVyxDQUFDLEdBQUc7UUFDcEIsTUFBTSxFQUFFLFdBQVcsQ0FBQyxNQUFNO1FBQzFCLE9BQU8sRUFBRSxPQUFPLENBQUMsT0FBTztLQUN6QixDQUFDO0FBQ0osQ0FBQztBQXBCRCwwREFvQkMiLCJmaWxlIjoibmVvLW9uZS1ub2RlLXN0b3JhZ2UtY2FjaGUvc3JjL3JlYWQuanMiLCJzb3VyY2VzQ29udGVudCI6WyJpbXBvcnQgeyBSZWFkQWxsU3RvcmFnZSwgUmVhZEdldEFsbFN0b3JhZ2UsIFJlYWRTdG9yYWdlIH0gZnJvbSAnQG5lby1vbmUvbm9kZS1jb3JlJztcbmltcG9ydCBMUlVDYWNoZSBmcm9tICdscnUtY2FjaGUnO1xuXG50eXBlIFNlcmlhbGl6ZUtleVN0cmluZzxLZXk+ID0gKGtleTogS2V5KSA9PiBzdHJpbmc7XG5cbmV4cG9ydCBmdW5jdGlvbiBjcmVhdGVSZWFkU3RvcmFnZTxLZXksIFZhbHVlPih7XG4gIGNhY2hlLFxuICBzdG9yYWdlLFxuICBzZXJpYWxpemVLZXlTdHJpbmcsXG59OiB7XG4gIHJlYWRvbmx5IGNhY2hlOiBMUlVDYWNoZTxzdHJpbmcsIFZhbHVlPjtcbiAgcmVhZG9ubHkgc3RvcmFnZTogUmVhZFN0b3JhZ2U8S2V5LCBWYWx1ZT47XG4gIHJlYWRvbmx5IHNlcmlhbGl6ZUtleVN0cmluZzogU2VyaWFsaXplS2V5U3RyaW5nPEtleT47XG59KTogUmVhZFN0b3JhZ2U8S2V5LCBWYWx1ZT4ge1xuICBjb25zdCBnZXQgPSBhc3luYyAoa2V5OiBLZXkpOiBQcm9taXNlPFZhbHVlPiA9PiB7XG4gICAgY29uc3Qga2V5U3RyaW5nID0gc2VyaWFsaXplS2V5U3RyaW5nKGtleSk7XG4gICAgY29uc3QgdmFsdWUgPSBjYWNoZS5nZXQoa2V5U3RyaW5nKTtcbiAgICBpZiAodmFsdWUgIT09IHVuZGVmaW5lZCkge1xuICAgICAgcmV0dXJuIHZhbHVlO1xuICAgIH1cblxuICAgIHJldHVybiBzdG9yYWdlLmdldChrZXkpLnRoZW4oKHZhbCkgPT4ge1xuICAgICAgY2FjaGUuc2V0KGtleVN0cmluZywgdmFsKTtcblxuICAgICAgcmV0dXJuIHZhbDtcbiAgICB9KTtcbiAgfTtcblxuICBjb25zdCB0cnlHZXQgPSBhc3luYyAoa2V5OiBLZXkpOiBQcm9taXNlPFZhbHVlIHwgdW5kZWZpbmVkPiA9PiB7XG4gICAgY29uc3Qga2V5U3RyaW5nID0gc2VyaWFsaXplS2V5U3RyaW5nKGtleSk7XG4gICAgY29uc3QgdmFsdWUgPSBjYWNoZS5nZXQoa2V5U3RyaW5nKTtcbiAgICBpZiAodmFsdWUgIT09IHVuZGVmaW5lZCkge1xuICAgICAgcmV0dXJuIHZhbHVlO1xuICAgIH1cblxuICAgIHJldHVybiBzdG9yYWdlLnRyeUdldChrZXkpLnRoZW4oKHZhbCkgPT4ge1xuICAgICAgaWYgKHZhbCAhPT0gdW5kZWZpbmVkKSB7XG4gICAgICAgIGNhY2hlLnNldChrZXlTdHJpbmcsIHZhbCk7XG4gICAgICB9XG5cbiAgICAgIHJldHVybiB2YWw7XG4gICAgfSk7XG4gIH07XG5cbiAgcmV0dXJuIHsgZ2V0LCB0cnlHZXQgfTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIGNyZWF0ZVJlYWRBbGxTdG9yYWdlPEtleSwgVmFsdWU+KHtcbiAgY2FjaGUsXG4gIHN0b3JhZ2UsXG4gIHNlcmlhbGl6ZUtleVN0cmluZyxcbn06IHtcbiAgcmVhZG9ubHkgY2FjaGU6IExSVUNhY2hlPHN0cmluZywgVmFsdWU+O1xuICByZWFkb25seSBzdG9yYWdlOiBSZWFkQWxsU3RvcmFnZTxLZXksIFZhbHVlPjtcbiAgcmVhZG9ubHkgc2VyaWFsaXplS2V5U3RyaW5nOiBTZXJpYWxpemVLZXlTdHJpbmc8S2V5Pjtcbn0pOiBSZWFkQWxsU3RvcmFnZTxLZXksIFZhbHVlPiB7XG4gIGNvbnN0IHJlYWRTdG9yYWdlID0gY3JlYXRlUmVhZFN0b3JhZ2Uoe1xuICAgIGNhY2hlLFxuICAgIHN0b3JhZ2UsXG4gICAgc2VyaWFsaXplS2V5U3RyaW5nLFxuICB9KTtcblxuICByZXR1cm4ge1xuICAgIGdldDogcmVhZFN0b3JhZ2UuZ2V0LFxuICAgIHRyeUdldDogcmVhZFN0b3JhZ2UudHJ5R2V0LFxuICAgIGFsbCQ6IHN0b3JhZ2UuYWxsJCxcbiAgfTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIGNyZWF0ZVJlYWRHZXRBbGxTdG9yYWdlPEtleSwgS2V5cywgVmFsdWU+KHtcbiAgY2FjaGUsXG4gIHN0b3JhZ2UsXG4gIHNlcmlhbGl6ZUtleVN0cmluZyxcbn06IHtcbiAgcmVhZG9ubHkgY2FjaGU6IExSVUNhY2hlPHN0cmluZywgVmFsdWU+O1xuICByZWFkb25seSBzdG9yYWdlOiBSZWFkR2V0QWxsU3RvcmFnZTxLZXksIEtleXMsIFZhbHVlPjtcbiAgcmVhZG9ubHkgc2VyaWFsaXplS2V5U3RyaW5nOiBTZXJpYWxpemVLZXlTdHJpbmc8S2V5Pjtcbn0pOiBSZWFkR2V0QWxsU3RvcmFnZTxLZXksIEtleXMsIFZhbHVlPiB7XG4gIGNvbnN0IHJlYWRTdG9yYWdlID0gY3JlYXRlUmVhZFN0b3JhZ2Uoe1xuICAgIGNhY2hlLFxuICAgIHN0b3JhZ2UsXG4gICAgc2VyaWFsaXplS2V5U3RyaW5nLFxuICB9KTtcblxuICByZXR1cm4ge1xuICAgIGdldDogcmVhZFN0b3JhZ2UuZ2V0LFxuICAgIHRyeUdldDogcmVhZFN0b3JhZ2UudHJ5R2V0LFxuICAgIGdldEFsbCQ6IHN0b3JhZ2UuZ2V0QWxsJCxcbiAgfTtcbn1cbiJdfQ==