Init lib

package.json

@@ -6,14 +6,14 @@
     "ng": "ng",
     "start": "ng serve",
     "build": "ng build",
-    "test": "ng test",
+    "test": "npm run test:lib",
     "lint": "ng lint",
     "e2e": "ng e2e",
     "contributors:add": "all-contributors add",
     "release": "cd projects/@ngneat/http-cache && standard-version --infile ../../../CHANGELOG.md",
     "hooks:pre-commit": "node hooks/pre-commit.js",
     "commit": "git-cz",
-    "test:lib": "ng test @ngneat/http-cache",
+    "test:lib": "npm run test --prefix projects/ngneat/http-cache",
     "test:headless": "cross-env CI=true npm run test:lib"
   },
   "private": true,
@@ -40,17 +40,17 @@
     "@commitlint/cli": "8.1.0",
     "@commitlint/config-angular": "^8.1.0",
     "@commitlint/config-conventional": "^8.1.0",
-    "@ngneat/spectator": "^4.4.0",
     "@types/jasmine": "~2.8.8",
     "@types/jasminewd2": "~2.0.3",
-    "@types/node": "~8.9.4",
-    "all-contributors-cli": "^6.8.1",
+    "@types/jest": "^24.0.25",
     "codelyzer": "~4.5.0",
     "cross-env": "^5.2.0",
     "git-cz": "^4.0.0",
     "husky": "^3.0.1",
     "jasmine-core": "~2.99.1",
     "jasmine-spec-reporter": "~4.2.1",
+    "jest": "^24.9.0",
+    "jest-preset-angular": "^8.0.0",
     "karma": "~4.0.0",
     "karma-chrome-launcher": "~2.2.0",
     "karma-coverage-istanbul-reporter": "~2.0.1",
@@ -60,6 +60,7 @@
     "ng-packagr": "^4.2.0",
     "prettier": "^1.18.2",
     "protractor": "~5.4.0",
+    "ts-jest": "^24.1.0",
     "standard-version": "^6.0.1",
     "ts-node": "~7.0.0",
     "tsickle": ">=0.34.0",

projects/ngneat/http-cache/.cache/jest-transform-cache-81ff110996c8351163dd44ac5e2773e3-d0e7c439bf6eb5a4bf3a6371fdd259d1/04/httpCacheInterceptor_0421e29a9363fb6322c80e696df7045d

@@ -0,0 +1,56 @@
+da20607a301fffdf08aa6beb8b20763b
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+var tslib_1 = require("tslib");
+var core_1 = require("@angular/core");
+var http_1 = require("@angular/common/http");
+var rxjs_1 = require("rxjs");
+var operators_1 = require("rxjs/operators");
+var httpCacheManager_service_1 = require("./httpCacheManager.service");
+var cloneWithoutParams_1 = require("./cloneWithoutParams");
+var keySerializer_1 = require("./keySerializer");
+var HttpCacheInterceptor = /** @class */ (function () {
+    function HttpCacheInterceptor(cacheFacade, keySerializer) {
+        this.cacheFacade = cacheFacade;
+        this.keySerializer = keySerializer;
+    }
+    HttpCacheInterceptor.prototype.intercept = function (request, next) {
+        var _this = this;
+        var canActivate = this.cacheFacade._canActivate(request);
+        var cache = request.params.get('cache$');
+        var ttl = request.params.get('ttl$');
+        var customKey = request.params.get('key$');
+        var bucket = request.params.get('bucket$');
+        var clone = cloneWithoutParams_1.cloneWithoutParams(request, customKey);
+        var key = this.keySerializer.serialize(clone);
+        if (this.cacheFacade._isCacheable(canActivate, cache)) {
+            bucket && bucket.add(key);
+            // TODO: wouldn't _queue be better instead of ts-ignore it.
+            // @ts-ignore
+            if (this.cacheFacade.queue.has(key)) {
+                // @ts-ignore
+                return this.cacheFacade.queue.get(key);
+            }
+            if (this.cacheFacade.validate(key)) {
+                return rxjs_1.of(this.cacheFacade.get(key));
+            }
+            //TODO: I would split that to function (for readability sake).
+            var shared = next.handle(clone).pipe(operators_1.tap(function (event) {
+                if (event instanceof http_1.HttpResponse) {
+                    _this.cacheFacade._set(key, event, +ttl);
+                }
+            }), operators_1.share());
+            // @ts-ignore
+            this.cacheFacade.queue.set(key, shared);
+            return shared;
+        }
+        return next.handle(clone);
+    };
+    HttpCacheInterceptor = tslib_1.__decorate([
+        core_1.Injectable(),
+        tslib_1.__metadata("design:paramtypes", [httpCacheManager_service_1.HttpCacheManager, keySerializer_1.KeySerializer])
+    ], HttpCacheInterceptor);
+    return HttpCacheInterceptor;
+}());
+exports.HttpCacheInterceptor = HttpCacheInterceptor;
+//# sourceMappingURL=data:application/json;charset=utf-8;base64,eyJmaWxlIjoiQzpcXFVzZXJzXFxJdGF5XFxwcm9qZWN0c1xcb3BlbnNvdXJjZXNcXGh0dHAtY2FjaGVcXHByb2plY3RzXFxuZ25lYXRcXGh0dHAtY2FjaGVcXHNyY1xcbGliXFxodHRwQ2FjaGVJbnRlcmNlcHRvci50cyIsIm1hcHBpbmdzIjoiOzs7QUFBQSxzQ0FBMkM7QUFDM0MsNkNBQTBHO0FBQzFHLDZCQUFzQztBQUN0Qyw0Q0FBNEM7QUFFNUMsdUVBQThEO0FBQzlELDJEQUEwRDtBQUMxRCxpREFBZ0Q7QUFJaEQ7SUFDRSw4QkFBb0IsV0FBNkIsRUFBVSxhQUE0QjtRQUFuRSxnQkFBVyxHQUFYLFdBQVcsQ0FBa0I7UUFBVSxrQkFBYSxHQUFiLGFBQWEsQ0FBZTtJQUFHLENBQUM7SUFFM0Ysd0NBQVMsR0FBVCxVQUFVLE9BQXlCLEVBQUUsSUFBaUI7UUFBdEQsaUJBdUNDO1FBdENDLElBQU0sV0FBVyxHQUFHLElBQUksQ0FBQyxXQUFXLENBQUMsWUFBWSxDQUFDLE9BQU8sQ0FBQyxDQUFDO1FBQzNELElBQU0sS0FBSyxHQUFHLE9BQU8sQ0FBQyxNQUFNLENBQUMsR0FBRyxDQUFDLFFBQVEsQ0FBQyxDQUFDO1FBQzNDLElBQU0sR0FBRyxHQUFHLE9BQU8sQ0FBQyxNQUFNLENBQUMsR0FBRyxDQUFDLE1BQU0sQ0FBQyxDQUFDO1FBQ3ZDLElBQU0sU0FBUyxHQUFHLE9BQU8sQ0FBQyxNQUFNLENBQUMsR0FBRyxDQUFDLE1BQU0sQ0FBQyxDQUFDO1FBQzdDLElBQU0sTUFBTSxHQUFRLE9BQU8sQ0FBQyxNQUFNLENBQUMsR0FBRyxDQUFDLFNBQVMsQ0FBQyxDQUFDO1FBRWxELElBQU0sS0FBSyxHQUFHLHVDQUFrQixDQUFDLE9BQU8sRUFBRSxTQUFTLENBQUMsQ0FBQztRQUNyRCxJQUFNLEdBQUcsR0FBRyxJQUFJLENBQUMsYUFBYSxDQUFDLFNBQVMsQ0FBQyxLQUFLLENBQUMsQ0FBQztRQUVoRCxJQUFJLElBQUksQ0FBQyxXQUFXLENBQUMsWUFBWSxDQUFDLFdBQVcsRUFBRSxLQUFLLENBQUMsRUFBRTtZQUNyRCxNQUFNLElBQUssTUFBc0IsQ0FBQyxHQUFHLENBQUMsR0FBRyxDQUFDLENBQUM7WUFDM0MsMkRBQTJEO1lBQzNELGFBQWE7WUFDYixJQUFJLElBQUksQ0FBQyxXQUFXLENBQUMsS0FBSyxDQUFDLEdBQUcsQ0FBQyxHQUFHLENBQUMsRUFBRTtnQkFDbkMsYUFBYTtnQkFDYixPQUFPLElBQUksQ0FBQyxXQUFXLENBQUMsS0FBSyxDQUFDLEdBQUcsQ0FBQyxHQUFHLENBQUMsQ0FBQzthQUN4QztZQUVELElBQUksSUFBSSxDQUFDLFdBQVcsQ0FBQyxRQUFRLENBQUMsR0FBRyxDQUFDLEVBQUU7Z0JBQ2xDLE9BQU8sU0FBRSxDQUFDLElBQUksQ0FBQyxXQUFXLENBQUMsR0FBRyxDQUFDLEdBQUcsQ0FBQyxDQUFDLENBQUM7YUFDdEM7WUFDRCw4REFBOEQ7WUFDOUQsSUFBTSxNQUFNLEdBQUcsSUFBSSxDQUFDLE1BQU0sQ0FBQyxLQUFLLENBQUMsQ0FBQyxJQUFJLENBQ3BDLGVBQUcsQ0FBQyxVQUFBLEtBQUs7Z0JBQ1AsSUFBSSxLQUFLLFlBQVksbUJBQVksRUFBRTtvQkFDakMsS0FBSSxDQUFDLFdBQVcsQ0FBQyxJQUFJLENBQUMsR0FBRyxFQUFFLEtBQUssRUFBRSxDQUFDLEdBQUcsQ0FBQyxDQUFDO2lCQUN6QztZQUNILENBQUMsQ0FBQyxFQUNGLGlCQUFLLEVBQUUsQ0FDUixDQUFDO1lBRUYsYUFBYTtZQUNiLElBQUksQ0FBQyxXQUFXLENBQUMsS0FBSyxDQUFDLEdBQUcsQ0FBQyxHQUFHLEVBQUUsTUFBTSxDQUFDLENBQUM7WUFFeEMsT0FBTyxNQUFNLENBQUM7U0FDZjtRQUVELE9BQU8sSUFBSSxDQUFDLE1BQU0sQ0FBQyxLQUFLLENBQUMsQ0FBQztJQUM1QixDQUFDO0lBMUNVLG9CQUFvQjtRQURoQyxpQkFBVSxFQUFFO2lEQUVzQiwyQ0FBZ0IsRUFBeUIsNkJBQWE7T0FENUUsb0JBQW9CLENBMkNoQztJQUFELDJCQUFDO0NBQUEsQUEzQ0QsSUEyQ0M7QUEzQ1ksb0RBQW9CIiwibmFtZXMiOltdLCJzb3VyY2VzIjpbIkM6XFxVc2Vyc1xcSXRheVxccHJvamVjdHNcXG9wZW5zb3VyY2VzXFxodHRwLWNhY2hlXFxwcm9qZWN0c1xcbmduZWF0XFxodHRwLWNhY2hlXFxzcmNcXGxpYlxcaHR0cENhY2hlSW50ZXJjZXB0b3IudHMiXSwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgSW5qZWN0YWJsZSB9IGZyb20gJ0Bhbmd1bGFyL2NvcmUnO1xuaW1wb3J0IHsgSHR0cEV2ZW50LCBIdHRwSGFuZGxlciwgSHR0cEludGVyY2VwdG9yLCBIdHRwUmVxdWVzdCwgSHR0cFJlc3BvbnNlIH0gZnJvbSAnQGFuZ3VsYXIvY29tbW9uL2h0dHAnO1xuaW1wb3J0IHsgT2JzZXJ2YWJsZSwgb2YgfSBmcm9tICdyeGpzJztcbmltcG9ydCB7IHNoYXJlLCB0YXAgfSBmcm9tICdyeGpzL29wZXJhdG9ycyc7XG5cbmltcG9ydCB7IEh0dHBDYWNoZU1hbmFnZXIgfSBmcm9tICcuL2h0dHBDYWNoZU1hbmFnZXIuc2VydmljZSc7XG5pbXBvcnQgeyBjbG9uZVdpdGhvdXRQYXJhbXMgfSBmcm9tICcuL2Nsb25lV2l0aG91dFBhcmFtcyc7XG5pbXBvcnQgeyBLZXlTZXJpYWxpemVyIH0gZnJvbSAnLi9rZXlTZXJpYWxpemVyJztcbmltcG9ydCB7IENhY2hlQnVja2V0IH0gZnJvbSAnLi9jYWNoZUJ1Y2tldCc7XG5cbkBJbmplY3RhYmxlKClcbmV4cG9ydCBjbGFzcyBIdHRwQ2FjaGVJbnRlcmNlcHRvciBpbXBsZW1lbnRzIEh0dHBJbnRlcmNlcHRvciB7XG4gIGNvbnN0cnVjdG9yKHByaXZhdGUgY2FjaGVGYWNhZGU6IEh0dHBDYWNoZU1hbmFnZXIsIHByaXZhdGUga2V5U2VyaWFsaXplcjogS2V5U2VyaWFsaXplcikge31cblxuICBpbnRlcmNlcHQocmVxdWVzdDogSHR0cFJlcXVlc3Q8YW55PiwgbmV4dDogSHR0cEhhbmRsZXIpOiBPYnNlcnZhYmxlPEh0dHBFdmVudDxhbnk+PiB7XG4gICAgY29uc3QgY2FuQWN0aXZhdGUgPSB0aGlzLmNhY2hlRmFjYWRlLl9jYW5BY3RpdmF0ZShyZXF1ZXN0KTtcbiAgICBjb25zdCBjYWNoZSA9IHJlcXVlc3QucGFyYW1zLmdldCgnY2FjaGUkJyk7XG4gICAgY29uc3QgdHRsID0gcmVxdWVzdC5wYXJhbXMuZ2V0KCd0dGwkJyk7XG4gICAgY29uc3QgY3VzdG9tS2V5ID0gcmVxdWVzdC5wYXJhbXMuZ2V0KCdrZXkkJyk7XG4gICAgY29uc3QgYnVja2V0OiBhbnkgPSByZXF1ZXN0LnBhcmFtcy5nZXQoJ2J1Y2tldCQnKTtcblxuICAgIGNvbnN0IGNsb25lID0gY2xvbmVXaXRob3V0UGFyYW1zKHJlcXVlc3QsIGN1c3RvbUtleSk7XG4gICAgY29uc3Qga2V5ID0gdGhpcy5rZXlTZXJpYWxpemVyLnNlcmlhbGl6ZShjbG9uZSk7XG5cbiAgICBpZiAodGhpcy5jYWNoZUZhY2FkZS5faXNDYWNoZWFibGUoY2FuQWN0aXZhdGUsIGNhY2hlKSkge1xuICAgICAgYnVja2V0ICYmIChidWNrZXQgYXMgQ2FjaGVCdWNrZXQpLmFkZChrZXkpO1xuICAgICAgLy8gVE9ETzogd291bGRuJ3QgX3F1ZXVlIGJlIGJldHRlciBpbnN0ZWFkIG9mIHRzLWlnbm9yZSBpdC5cbiAgICAgIC8vIEB0cy1pZ25vcmVcbiAgICAgIGlmICh0aGlzLmNhY2hlRmFjYWRlLnF1ZXVlLmhhcyhrZXkpKSB7XG4gICAgICAgIC8vIEB0cy1pZ25vcmVcbiAgICAgICAgcmV0dXJuIHRoaXMuY2FjaGVGYWNhZGUucXVldWUuZ2V0KGtleSk7XG4gICAgICB9XG5cbiAgICAgIGlmICh0aGlzLmNhY2hlRmFjYWRlLnZhbGlkYXRlKGtleSkpIHtcbiAgICAgICAgcmV0dXJuIG9mKHRoaXMuY2FjaGVGYWNhZGUuZ2V0KGtleSkpO1xuICAgICAgfVxuICAgICAgLy9UT0RPOiBJIHdvdWxkIHNwbGl0IHRoYXQgdG8gZnVuY3Rpb24gKGZvciByZWFkYWJpbGl0eSBzYWtlKS5cbiAgICAgIGNvbnN0IHNoYXJlZCA9IG5leHQuaGFuZGxlKGNsb25lKS5waXBlKFxuICAgICAgICB0YXAoZXZlbnQgPT4ge1xuICAgICAgICAgIGlmIChldmVudCBpbnN0YW5jZW9mIEh0dHBSZXNwb25zZSkge1xuICAgICAgICAgICAgdGhpcy5jYWNoZUZhY2FkZS5fc2V0KGtleSwgZXZlbnQsICt0dGwpO1xuICAgICAgICAgIH1cbiAgICAgICAgfSksXG4gICAgICAgIHNoYXJlKClcbiAgICAgICk7XG5cbiAgICAgIC8vIEB0cy1pZ25vcmVcbiAgICAgIHRoaXMuY2FjaGVGYWNhZGUucXVldWUuc2V0KGtleSwgc2hhcmVkKTtcblxuICAgICAgcmV0dXJuIHNoYXJlZDtcbiAgICB9XG5cbiAgICByZXR1cm4gbmV4dC5oYW5kbGUoY2xvbmUpO1xuICB9XG59XG4iXSwidmVyc2lvbiI6M30=

projects/ngneat/http-cache/.cache/jest-transform-cache-81ff110996c8351163dd44ac5e2773e3-d0e7c439bf6eb5a4bf3a6371fdd259d1/04/httpCacheInterceptor_0421e29a9363fb6322c80e696df7045d.map

@@ -0,0 +1 @@
+{"file":"C:\\Users\\Itay\\projects\\opensources\\http-cache\\projects\\ngneat\\http-cache\\src\\lib\\httpCacheInterceptor.ts","mappings":";;;AAAA,sCAA2C;AAC3C,6CAA0G;AAC1G,6BAAsC;AACtC,4CAA4C;AAE5C,uEAA8D;AAC9D,2DAA0D;AAC1D,iDAAgD;AAIhD;IACE,8BAAoB,WAA6B,EAAU,aAA4B;QAAnE,gBAAW,GAAX,WAAW,CAAkB;QAAU,kBAAa,GAAb,aAAa,CAAe;IAAG,CAAC;IAE3F,wCAAS,GAAT,UAAU,OAAyB,EAAE,IAAiB;QAAtD,iBAuCC;QAtCC,IAAM,WAAW,GAAG,IAAI,CAAC,WAAW,CAAC,YAAY,CAAC,OAAO,CAAC,CAAC;QAC3D,IAAM,KAAK,GAAG,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QAC3C,IAAM,GAAG,GAAG,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC;QACvC,IAAM,SAAS,GAAG,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC;QAC7C,IAAM,MAAM,GAAQ,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC;QAElD,IAAM,KAAK,GAAG,uCAAkB,CAAC,OAAO,EAAE,SAAS,CAAC,CAAC;QACrD,IAAM,GAAG,GAAG,IAAI,CAAC,aAAa,CAAC,SAAS,CAAC,KAAK,CAAC,CAAC;QAEhD,IAAI,IAAI,CAAC,WAAW,CAAC,YAAY,CAAC,WAAW,EAAE,KAAK,CAAC,EAAE;YACrD,MAAM,IAAK,MAAsB,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;YAC3C,2DAA2D;YAC3D,aAAa;YACb,IAAI,IAAI,CAAC,WAAW,CAAC,KAAK,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE;gBACnC,aAAa;gBACb,OAAO,IAAI,CAAC,WAAW,CAAC,KAAK,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;aACxC;YAED,IAAI,IAAI,CAAC,WAAW,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAE;gBAClC,OAAO,SAAE,CAAC,IAAI,CAAC,WAAW,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,CAAC;aACtC;YACD,8DAA8D;YAC9D,IAAM,MAAM,GAAG,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,IAAI,CACpC,eAAG,CAAC,UAAA,KAAK;gBACP,IAAI,KAAK,YAAY,mBAAY,EAAE;oBACjC,KAAI,CAAC,WAAW,CAAC,IAAI,CAAC,GAAG,EAAE,KAAK,EAAE,CAAC,GAAG,CAAC,CAAC;iBACzC;YACH,CAAC,CAAC,EACF,iBAAK,EAAE,CACR,CAAC;YAEF,aAAa;YACb,IAAI,CAAC,WAAW,CAAC,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,MAAM,CAAC,CAAC;YAExC,OAAO,MAAM,CAAC;SACf;QAED,OAAO,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC;IAC5B,CAAC;IA1CU,oBAAoB;QADhC,iBAAU,EAAE;iDAEsB,2CAAgB,EAAyB,6BAAa;OAD5E,oBAAoB,CA2ChC;IAAD,2BAAC;CAAA,AA3CD,IA2CC;AA3CY,oDAAoB","names":[],"sources":["C:\\Users\\Itay\\projects\\opensources\\http-cache\\projects\\ngneat\\http-cache\\src\\lib\\httpCacheInterceptor.ts"],"sourcesContent":["import { Injectable } from '@angular/core';\nimport { HttpEvent, HttpHandler, HttpInterceptor, HttpRequest, HttpResponse } from '@angular/common/http';\nimport { Observable, of } from 'rxjs';\nimport { share, tap } from 'rxjs/operators';\n\nimport { HttpCacheManager } from './httpCacheManager.service';\nimport { cloneWithoutParams } from './cloneWithoutParams';\nimport { KeySerializer } from './keySerializer';\nimport { CacheBucket } from './cacheBucket';\n\n@Injectable()\nexport class HttpCacheInterceptor implements HttpInterceptor {\n  constructor(private cacheFacade: HttpCacheManager, private keySerializer: KeySerializer) {}\n\n  intercept(request: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {\n    const canActivate = this.cacheFacade._canActivate(request);\n    const cache = request.params.get('cache$');\n    const ttl = request.params.get('ttl$');\n    const customKey = request.params.get('key$');\n    const bucket: any = request.params.get('bucket$');\n\n    const clone = cloneWithoutParams(request, customKey);\n    const key = this.keySerializer.serialize(clone);\n\n    if (this.cacheFacade._isCacheable(canActivate, cache)) {\n      bucket && (bucket as CacheBucket).add(key);\n      // TODO: wouldn't _queue be better instead of ts-ignore it.\n      // @ts-ignore\n      if (this.cacheFacade.queue.has(key)) {\n        // @ts-ignore\n        return this.cacheFacade.queue.get(key);\n      }\n\n      if (this.cacheFacade.validate(key)) {\n        return of(this.cacheFacade.get(key));\n      }\n      //TODO: I would split that to function (for readability sake).\n      const shared = next.handle(clone).pipe(\n        tap(event => {\n          if (event instanceof HttpResponse) {\n            this.cacheFacade._set(key, event, +ttl);\n          }\n        }),\n        share()\n      );\n\n      // @ts-ignore\n      this.cacheFacade.queue.set(key, shared);\n\n      return shared;\n    }\n\n    return next.handle(clone);\n  }\n}\n"],"version":3}

projects/ngneat/http-cache/.cache/jest-transform-cache-81ff110996c8351163dd44ac5e2773e3-d0e7c439bf6eb5a4bf3a6371fdd259d1/08/httpCacheDecorator_080e8187a38eb7b152ebfe542747e471

@@ -0,0 +1,28 @@
+4d1d4c6cb4160579416e8e753df81704
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+var operators_1 = require("rxjs/operators");
+function HttpCache(config, ttl) {
+    if (config === void 0) { config = { bufferSize: 1, refCount: false }; }
+    var cache = new Map();
+    return function (target, propertyKey, descriptor) {
+        var method = descriptor.value;
+        descriptor.value = function () {
+            var key = JSON.stringify(arguments);
+            var cached = cache.get(key);
+            if (cached) {
+                return cached;
+            }
+            var call$ = method.apply(this, arguments).pipe(operators_1.shareReplay(config));
+            cache.set(key, call$);
+            if (ttl) {
+                setTimeout(function () {
+                    cache.delete(key);
+                }, ttl);
+            }
+            return call$;
+        };
+    };
+}
+exports.HttpCache = HttpCache;
+//# sourceMappingURL=data:application/json;charset=utf-8;base64,eyJmaWxlIjoiQzpcXFVzZXJzXFxJdGF5XFxwcm9qZWN0c1xcb3BlbnNvdXJjZXNcXGh0dHAtY2FjaGVcXHByb2plY3RzXFxuZ25lYXRcXGh0dHAtY2FjaGVcXHNyY1xcbGliXFxodHRwQ2FjaGVEZWNvcmF0b3IudHMiLCJtYXBwaW5ncyI6Ijs7QUFDQSw0Q0FBNkM7QUFFN0MsU0FBZ0IsU0FBUyxDQUFVLE1BQTJDLEVBQUUsR0FBWTtJQUF6RCx1QkFBQSxFQUFBLFdBQVcsVUFBVSxFQUFFLENBQUMsRUFBRSxRQUFRLEVBQUUsS0FBSyxFQUFFO0lBQzVFLElBQU0sS0FBSyxHQUFHLElBQUksR0FBRyxFQUF5QixDQUFDO0lBRS9DLE9BQU8sVUFBUyxNQUFXLEVBQUUsV0FBbUIsRUFBRSxVQUE4QjtRQUM5RSxJQUFNLE1BQU0sR0FBRyxVQUFVLENBQUMsS0FBSyxDQUFDO1FBRWhDLFVBQVUsQ0FBQyxLQUFLLEdBQUc7WUFDakIsSUFBTSxHQUFHLEdBQUcsSUFBSSxDQUFDLFNBQVMsQ0FBQyxTQUFTLENBQUMsQ0FBQztZQUN0QyxJQUFNLE1BQU0sR0FBRyxLQUFLLENBQUMsR0FBRyxDQUFDLEdBQUcsQ0FBQyxDQUFDO1lBRTlCLElBQUksTUFBTSxFQUFFO2dCQUNWLE9BQU8sTUFBTSxDQUFDO2FBQ2Y7WUFFRCxJQUFNLEtBQUssR0FBRyxNQUFNLENBQUMsS0FBSyxDQUFDLElBQUksRUFBRSxTQUFTLENBQUMsQ0FBQyxJQUFJLENBQUMsdUJBQVcsQ0FBQyxNQUFNLENBQUMsQ0FBQyxDQUFDO1lBQ3RFLEtBQUssQ0FBQyxHQUFHLENBQUMsR0FBRyxFQUFFLEtBQUssQ0FBQyxDQUFDO1lBQ3RCLElBQUcsR0FBRyxFQUFFO2dCQUNOLFVBQVUsQ0FBQztvQkFDVCxLQUFLLENBQUMsTUFBTSxDQUFDLEdBQUcsQ0FBQyxDQUFDO2dCQUNwQixDQUFDLEVBQUUsR0FBRyxDQUFDLENBQUM7YUFDVDtZQUVELE9BQU8sS0FBSyxDQUFDO1FBQ2YsQ0FBQyxDQUFDO0lBQ0osQ0FBQyxDQUFDO0FBQ0osQ0FBQztBQXpCRCw4QkF5QkMiLCJuYW1lcyI6W10sInNvdXJjZXMiOlsiQzpcXFVzZXJzXFxJdGF5XFxwcm9qZWN0c1xcb3BlbnNvdXJjZXNcXGh0dHAtY2FjaGVcXHByb2plY3RzXFxuZ25lYXRcXGh0dHAtY2FjaGVcXHNyY1xcbGliXFxodHRwQ2FjaGVEZWNvcmF0b3IudHMiXSwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgT2JzZXJ2YWJsZSB9IGZyb20gJ3J4anMnO1xuaW1wb3J0IHsgc2hhcmVSZXBsYXkgfSBmcm9tICdyeGpzL29wZXJhdG9ycyc7XG5cbmV4cG9ydCBmdW5jdGlvbiBIdHRwQ2FjaGU8VCA9IGFueT4oY29uZmlnID0geyBidWZmZXJTaXplOiAxLCByZWZDb3VudDogZmFsc2UgfSwgdHRsPzogbnVtYmVyKSB7XG4gIGNvbnN0IGNhY2hlID0gbmV3IE1hcDxzdHJpbmcsIE9ic2VydmFibGU8VD4+KCk7XG5cbiAgcmV0dXJuIGZ1bmN0aW9uKHRhcmdldDogYW55LCBwcm9wZXJ0eUtleTogc3RyaW5nLCBkZXNjcmlwdG9yOiBQcm9wZXJ0eURlc2NyaXB0b3IpIHtcbiAgICBjb25zdCBtZXRob2QgPSBkZXNjcmlwdG9yLnZhbHVlO1xuXG4gICAgZGVzY3JpcHRvci52YWx1ZSA9IGZ1bmN0aW9uKCk6IE9ic2VydmFibGU8VD4ge1xuICAgICAgY29uc3Qga2V5ID0gSlNPTi5zdHJpbmdpZnkoYXJndW1lbnRzKTtcbiAgICAgIGNvbnN0IGNhY2hlZCA9IGNhY2hlLmdldChrZXkpO1xuXG4gICAgICBpZiAoY2FjaGVkKSB7XG4gICAgICAgIHJldHVybiBjYWNoZWQ7XG4gICAgICB9XG5cbiAgICAgIGNvbnN0IGNhbGwkID0gbWV0aG9kLmFwcGx5KHRoaXMsIGFyZ3VtZW50cykucGlwZShzaGFyZVJlcGxheShjb25maWcpKTtcbiAgICAgIGNhY2hlLnNldChrZXksIGNhbGwkKTtcbiAgICAgIGlmKHR0bCkge1xuICAgICAgICBzZXRUaW1lb3V0KCgpID0+IHtcbiAgICAgICAgICBjYWNoZS5kZWxldGUoa2V5KTtcbiAgICAgICAgfSwgdHRsKTtcbiAgICAgIH1cblxuICAgICAgcmV0dXJuIGNhbGwkO1xuICAgIH07XG4gIH07XG59XG4iXSwidmVyc2lvbiI6M30=

projects/ngneat/http-cache/.cache/jest-transform-cache-81ff110996c8351163dd44ac5e2773e3-d0e7c439bf6eb5a4bf3a6371fdd259d1/08/httpCacheDecorator_080e8187a38eb7b152ebfe542747e471.map

@@ -0,0 +1 @@
+{"file":"C:\\Users\\Itay\\projects\\opensources\\http-cache\\projects\\ngneat\\http-cache\\src\\lib\\httpCacheDecorator.ts","mappings":";;AACA,4CAA6C;AAE7C,SAAgB,SAAS,CAAU,MAA2C,EAAE,GAAY;IAAzD,uBAAA,EAAA,WAAW,UAAU,EAAE,CAAC,EAAE,QAAQ,EAAE,KAAK,EAAE;IAC5E,IAAM,KAAK,GAAG,IAAI,GAAG,EAAyB,CAAC;IAE/C,OAAO,UAAS,MAAW,EAAE,WAAmB,EAAE,UAA8B;QAC9E,IAAM,MAAM,GAAG,UAAU,CAAC,KAAK,CAAC;QAEhC,UAAU,CAAC,KAAK,GAAG;YACjB,IAAM,GAAG,GAAG,IAAI,CAAC,SAAS,CAAC,SAAS,CAAC,CAAC;YACtC,IAAM,MAAM,GAAG,KAAK,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;YAE9B,IAAI,MAAM,EAAE;gBACV,OAAO,MAAM,CAAC;aACf;YAED,IAAM,KAAK,GAAG,MAAM,CAAC,KAAK,CAAC,IAAI,EAAE,SAAS,CAAC,CAAC,IAAI,CAAC,uBAAW,CAAC,MAAM,CAAC,CAAC,CAAC;YACtE,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,KAAK,CAAC,CAAC;YACtB,IAAG,GAAG,EAAE;gBACN,UAAU,CAAC;oBACT,KAAK,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;gBACpB,CAAC,EAAE,GAAG,CAAC,CAAC;aACT;YAED,OAAO,KAAK,CAAC;QACf,CAAC,CAAC;IACJ,CAAC,CAAC;AACJ,CAAC;AAzBD,8BAyBC","names":[],"sources":["C:\\Users\\Itay\\projects\\opensources\\http-cache\\projects\\ngneat\\http-cache\\src\\lib\\httpCacheDecorator.ts"],"sourcesContent":["import { Observable } from 'rxjs';\nimport { shareReplay } from 'rxjs/operators';\n\nexport function HttpCache<T = any>(config = { bufferSize: 1, refCount: false }, ttl?: number) {\n  const cache = new Map<string, Observable<T>>();\n\n  return function(target: any, propertyKey: string, descriptor: PropertyDescriptor) {\n    const method = descriptor.value;\n\n    descriptor.value = function(): Observable<T> {\n      const key = JSON.stringify(arguments);\n      const cached = cache.get(key);\n\n      if (cached) {\n        return cached;\n      }\n\n      const call$ = method.apply(this, arguments).pipe(shareReplay(config));\n      cache.set(key, call$);\n      if(ttl) {\n        setTimeout(() => {\n          cache.delete(key);\n        }, ttl);\n      }\n\n      return call$;\n    };\n  };\n}\n"],"version":3}