ravendb/dist/Http/HttpCache.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const moment = require("moment");
const Cache = require("safe-memory-cache/map");
class HttpCache {
    constructor(maxKeysSize = 500) {
        this._items = new Cache({
            limit: maxKeysSize
        });
    }
    dispose() {
        this._items.clear();
        this._items = null;
    }
    set(url, changeVector, result) {
        const httpCacheItem = new HttpCacheItem();
        httpCacheItem.changeVector = changeVector;
        httpCacheItem.payload = result;
        httpCacheItem.cache = this;
        this._items.set(url, httpCacheItem);
    }
    get(url, itemInfoCallback) {
        const item = this._items.get(url);
        if (item) {
            if (itemInfoCallback) {
                itemInfoCallback({
                    changeVector: item.changeVector,
                    response: item.payload
                });
            }
            return new ReleaseCacheItem(item);
        }
        if (itemInfoCallback) {
            itemInfoCallback({
                changeVector: null,
                response: null
            });
        }
        return new ReleaseCacheItem(null);
    }
    setNotFound(url) {
        const httpCacheItem = new HttpCacheItem();
        httpCacheItem.changeVector = "404 response";
        httpCacheItem.cache = this;
        this._items.set(url, httpCacheItem);
    }
    get numberOfItems() {
        return this._items["_get_buckets"]().reduce((result, next) => {
            return result + next.size;
        }, 0);
    }
    getMightHaveBeenModified() {
        return false;
    }
}
exports.HttpCache = HttpCache;
class ReleaseCacheItem {
    constructor(item) {
        this.item = item;
    }
    notModified() {
        if (this.item) {
            this.item.lastServerUpdate = moment().toDate();
        }
    }
    get age() {
        if (!this.item) {
            return Number.MAX_VALUE;
        }
        return new Date().valueOf() - this.item.lastServerUpdate.valueOf();
    }
    get mightHaveBeenModified() {
        return false;
    }
}
exports.ReleaseCacheItem = ReleaseCacheItem;
class HttpCacheItem {
    constructor() {
        this.lastServerUpdate = moment().toDate();
    }
}
exports.HttpCacheItem = HttpCacheItem;