'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;
|
