'use strict';
var __assign = (this && this.__assign) || Object.assign || function(t) {
    for (var s, i = 1, n = arguments.length; i < n; i++) {
        s = arguments[i];
        for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
            t[p] = s[p];
    }
    return t;
};
exports.__esModule = true;
var stream_1 = require("stream");
var concat = require("concat-stream");
var MemoryCache = /** @class */ (function () {
    function MemoryCache() {
        this._cache = {};
    }
    MemoryCache.prototype.getResponse = function (url, callback) {
        var cache = this._cache;
        if (cache[url]) {
            var body = new stream_1.PassThrough();
            body.end(cache[url].body);
            callback(null, {
                statusCode: cache[url].statusCode,
                headers: cache[url].headers,
                body: body,
                requestHeaders: cache[url].requestHeaders,
                requestTimestamp: cache[url].requestTimestamp
            });
        }
        else {
            callback(null, null);
        }
    };
    MemoryCache.prototype.updateResponseHeaders = function (url, response) {
        this._cache[url] = __assign({}, this._cache[url], { headers: response.headers, requestTimestamp: response.requestTimestamp });
    };
    MemoryCache.prototype.setResponse = function (url, response) {
        var cache = this._cache;
        response.body.pipe(concat(function (body) {
            cache[url] = {
                statusCode: response.statusCode,
                headers: response.headers,
                body: body,
                requestHeaders: response.requestHeaders,
                requestTimestamp: response.requestTimestamp
            };
        }));
    };
    MemoryCache.prototype.invalidateResponse = function (url, callback) {
        var cache = this._cache;
        delete cache[url];
        callback(null);
    };
    return MemoryCache;
}());
exports["default"] = MemoryCache;