@newbility/core - npm Package Compare versions

Comparing version 0.2.49 to 0.2.50

build/src/cache/Cache.d.ts

+import { ILogger } from '../logger/Logger';
+import { ISettingManager } from '../setting/SettingManager';
+import { CacheEntryOptions } from './options/CacheEntryOptions';
+export interface ICache {
+    GetAsync<TCache = any>(key: string): Promise<TCache | undefined>;
+    SetAsync<TCache = any>(key: string, data: TCache, options?: CacheEntryOptions): Promise<void>;
+    RemoveAsync(key: string): Promise<void>;
+    GetOrAddAsync<TCache = any>(key: string, func: () => Promise<TCache> | TCache, options?: CacheEntryOptions): Promise<TCache>;
+}
+export declare abstract class Cache implements ICache {
+    private readonly _settingManager;
+    protected get SettingManager(): ISettingManager;
+    private readonly _logger;
+    protected get Logger(): ILogger;
+    constructor();
+    abstract GetAsync<TCache = any>(key: string): Promise<TCache | undefined>;
+    abstract SetAsync<TCache = any>(key: string, data: TCache, options?: CacheEntryOptions | undefined): Promise<void>;
+    abstract RemoveAsync(key: string): Promise<void>;
+    GetOrAddAsync<TCache = any>(key: string, func: () => Promise<TCache> | TCache, options?: CacheEntryOptions): Promise<TCache>;
+}

build/src/cache/Cache.js

+"use strict";
+var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
+    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
+    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
+    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
+    return c > 3 && r && Object.defineProperty(target, key, r), r;
+};
+var __metadata = (this && this.__metadata) || function (k, v) {
+    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.Cache = void 0;
+const Dependency_1 = require("../di/Dependency");
+const Logger_1 = require("../logger/Logger");
+const SettingManager_1 = require("../setting/SettingManager");
+let Cache = class Cache {
+    get SettingManager() {
+        return this._settingManager;
+    }
+    get Logger() {
+        return this._logger;
+    }
+    constructor() {
+        this._logger = Dependency_1.Container.resolve(Logger_1.LOGGER_INJECT_TOKEN);
+        this._settingManager = Dependency_1.Container.resolve(SettingManager_1.SETTING_INJECT_TOKEN);
+    }
+    async GetOrAddAsync(key, func, options) {
+        const nullResult = null;
+        if (!func)
+            return nullResult;
+        let cacheData = await this.GetAsync(key);
+        if (cacheData !== null && cacheData !== undefined)
+            return cacheData;
+        const cacheDataResult = func();
+        if (cacheDataResult instanceof Promise) {
+            cacheData = await cacheDataResult;
+        }
+        else {
+            cacheData = cacheDataResult;
+        }
+        if (cacheData != null && cacheData != undefined) {
+            await this.SetAsync(key, cacheData, options);
+        }
+        return cacheData;
+    }
+};
+exports.Cache = Cache;
+exports.Cache = Cache = __decorate([
+    (0, Dependency_1.Abstract)(),
+    __metadata("design:paramtypes", [])
+], Cache);
+//# sourceMappingURL=Cache.js.map

build/src/cache/Cache.js.map

+{"version":3,"file":"Cache.js","sourceRoot":"","sources":["../../../src/cache/Cache.ts"],"names":[],"mappings":";;;;;;;;;;;;AAAA,iDAAuD;AACvD,6CAAgE;AAChE,8DAAkF;AAW3E,IAAe,KAAK,GAApB,MAAe,KAAK;IAEzB,IAAc,cAAc;QAC1B,OAAO,IAAI,CAAC,eAAe,CAAC;IAC9B,CAAC;IAGD,IAAc,MAAM;QAClB,OAAO,IAAI,CAAC,OAAO,CAAC;IACtB,CAAC;IAED;QACE,IAAI,CAAC,OAAO,GAAG,sBAAS,CAAC,OAAO,CAAU,4BAAmB,CAAC,CAAC;QAC/D,IAAI,CAAC,eAAe,GAAG,sBAAS,CAAC,OAAO,CAAkB,qCAAoB,CAAC,CAAC;IAClF,CAAC;IAMD,KAAK,CAAC,aAAa,CAAe,GAAW,EAAE,IAAoC,EAAE,OAA2B;QAC9G,MAAM,UAAU,GAAQ,IAAI,CAAC;QAC7B,IAAI,CAAC,IAAI;YAAE,OAAO,UAAU,CAAC;QAE7B,IAAI,SAAS,GAAQ,MAAM,IAAI,CAAC,QAAQ,CAAS,GAAG,CAAC,CAAC;QACtD,IAAI,SAAS,KAAK,IAAI,IAAI,SAAS,KAAK,SAAS;YAAE,OAAO,SAAS,CAAC;QAEpE,MAAM,eAAe,GAAG,IAAI,EAAE,CAAC;QAE/B,IAAI,eAAe,YAAY,OAAO,EAAE;YACtC,SAAS,GAAG,MAAM,eAAe,CAAC;SACnC;aAAM;YACL,SAAS,GAAG,eAAe,CAAC;SAC7B;QAED,IAAI,SAAS,IAAI,IAAI,IAAI,SAAS,IAAI,SAAS,EAAE;YAC/C,MAAM,IAAI,CAAC,QAAQ,CAAC,GAAG,EAAE,SAAS,EAAE,OAAO,CAAC,CAAC;SAC9C;QAED,OAAO,SAAS,CAAC;IACnB,CAAC;CACF,CAAA;AAzCqB,sBAAK;gBAAL,KAAK;IAD1B,IAAA,qBAAQ,GAAE;;GACW,KAAK,CAyC1B"}

build/src/cache/distributed/DistributedCache.d.ts

+import { Cache, ICache } from '../Cache';
+import { IMemoryCache } from '../memory/MemoryCache';
+import { CacheEntryOptions } from '../options/CacheEntryOptions';
+export declare const DISTRIBUTED_CACHE_INJECT_TOKEN: string;
+export interface IDistributedCache extends ICache {
+}
+export declare class DefaultDistributedCache extends Cache implements IDistributedCache {
+    private readonly _memoryCache;
+    protected get MemoryCache(): IMemoryCache;
+    constructor();
+    GetAsync<TCache = any>(key: string): Promise<TCache | undefined>;
+    SetAsync<TCache = any>(key: string, data: TCache, options?: CacheEntryOptions | undefined): Promise<void>;
+    RemoveAsync(key: string): Promise<void>;
+    GetOrAddAsync<TCache = any>(key: string, func: () => TCache | Promise<TCache>, options?: CacheEntryOptions | undefined): Promise<TCache>;
+}

build/src/cache/distributed/DistributedCache.js

+"use strict";
+var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
+    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
+    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
+    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
+    return c > 3 && r && Object.defineProperty(target, key, r), r;
+};
+var __metadata = (this && this.__metadata) || function (k, v) {
+    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.DefaultDistributedCache = exports.DISTRIBUTED_CACHE_INJECT_TOKEN = void 0;
+const Dependency_1 = require("../../di/Dependency");
+const Cache_1 = require("../Cache");
+const MemoryCache_1 = require("../memory/MemoryCache");
+exports.DISTRIBUTED_CACHE_INJECT_TOKEN = (0, Dependency_1.GetInjectToken)('Sys:IDistributedCache');
+let DefaultDistributedCache = class DefaultDistributedCache extends Cache_1.Cache {
+    get MemoryCache() {
+        return this._memoryCache;
+    }
+    constructor() {
+        super();
+        this._memoryCache = Dependency_1.Container.resolve(MemoryCache_1.MEMORY_CACHE_INJECT_TOKEN);
+    }
+    GetAsync(key) {
+        return this._memoryCache.GetAsync(key);
+    }
+    SetAsync(key, data, options) {
+        return this._memoryCache.SetAsync(key, data, options);
+    }
+    RemoveAsync(key) {
+        return this._memoryCache.RemoveAsync(key);
+    }
+    GetOrAddAsync(key, func, options) {
+        return this._memoryCache.GetOrAddAsync(key, func, options);
+    }
+};
+exports.DefaultDistributedCache = DefaultDistributedCache;
+exports.DefaultDistributedCache = DefaultDistributedCache = __decorate([
+    (0, Dependency_1.Injectable)(),
+    (0, Dependency_1.Singleton)(exports.DISTRIBUTED_CACHE_INJECT_TOKEN),
+    __metadata("design:paramtypes", [])
+], DefaultDistributedCache);
+//# sourceMappingURL=DistributedCache.js.map

build/src/cache/distributed/DistributedCache.js.map

+{"version":3,"file":"DistributedCache.js","sourceRoot":"","sources":["../../../../src/cache/distributed/DistributedCache.ts"],"names":[],"mappings":";;;;;;;;;;;;AAAA,oDAAuF;AACvF,oCAAyC;AACzC,uDAAgF;AAGnE,QAAA,8BAA8B,GAAG,IAAA,2BAAc,EAAC,uBAAuB,CAAC,CAAC;AAK/E,IAAM,uBAAuB,GAA7B,MAAM,uBAAwB,SAAQ,aAAK;IAEhD,IAAc,WAAW;QACvB,OAAO,IAAI,CAAC,YAAY,CAAC;IAC3B,CAAC;IAED;QACE,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,YAAY,GAAG,sBAAS,CAAC,OAAO,CAAe,uCAAyB,CAAC,CAAC;IACjF,CAAC;IACD,QAAQ,CAAe,GAAW;QAChC,OAAO,IAAI,CAAC,YAAY,CAAC,QAAQ,CAAS,GAAG,CAAC,CAAC;IACjD,CAAC;IACD,QAAQ,CAAe,GAAW,EAAE,IAAY,EAAE,OAAuC;QACvF,OAAO,IAAI,CAAC,YAAY,CAAC,QAAQ,CAAS,GAAG,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;IAChE,CAAC;IACD,WAAW,CAAC,GAAW;QACrB,OAAO,IAAI,CAAC,YAAY,CAAC,WAAW,CAAC,GAAG,CAAC,CAAC;IAC5C,CAAC;IACD,aAAa,CAAe,GAAW,EAAE,IAAoC,EAAE,OAAuC;QACpH,OAAO,IAAI,CAAC,YAAY,CAAC,aAAa,CAAS,GAAG,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;IACrE,CAAC;CACF,CAAA;AAtBY,0DAAuB;kCAAvB,uBAAuB;IAFnC,IAAA,uBAAU,GAAE;IACZ,IAAA,sBAAS,EAAC,sCAA8B,CAAC;;GAC7B,uBAAuB,CAsBnC"}

build/src/cache/memory/MemoryCache.d.ts

+import { Cache, ICache } from '../Cache';
+import { CacheEntryOptions } from '../options/CacheEntryOptions';
+import { LRUCache as LRUCacheDrive } from 'lru-cache';
+import { CacheOptions } from '../options/CacheOptions';
+export declare const MEMORY_CACHE_INJECT_TOKEN: string;
+export interface IMemoryCache extends ICache {
+}
+export declare class LRUCache extends Cache implements IMemoryCache {
+    private readonly _cacheIns;
+    get CacheIns(): LRUCacheDrive<string, any>;
+    private readonly _slidingMap;
+    protected get SlidingMap(): Map<string, number>;
+    constructor();
+    GetAsync<TCache = any>(key: string): Promise<TCache | undefined>;
+    SetAsync<TCache = any>(key: string, data: TCache, options?: CacheEntryOptions | undefined): Promise<void>;
+    RemoveAsync(key: string): Promise<void>;
+    protected GetOptions(): CacheOptions;
+    protected GenCacheIns(): LRUCacheDrive<string, any>;
+    protected SizeCalculation(value: any, key: string): number;
+    protected IsSlidingCache(key: string): boolean;
+    protected AddSlidingCache(key: string, ttl: number): void;
+    protected RemoveSlidingCache(key: string): void;
+}

build/src/cache/memory/MemoryCache.js

+"use strict";
+var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
+    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
+    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
+    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
+    return c > 3 && r && Object.defineProperty(target, key, r), r;
+};
+var __metadata = (this && this.__metadata) || function (k, v) {
+    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.LRUCache = exports.MEMORY_CACHE_INJECT_TOKEN = void 0;
+const Dependency_1 = require("../../di/Dependency");
+const Cache_1 = require("../Cache");
+const lru_cache_1 = require("lru-cache");
+exports.MEMORY_CACHE_INJECT_TOKEN = (0, Dependency_1.GetInjectToken)('Sys:IMemoryCache');
+let LRUCache = class LRUCache extends Cache_1.Cache {
+    get CacheIns() {
+        return this._cacheIns;
+    }
+    get SlidingMap() {
+        return this._slidingMap;
+    }
+    constructor() {
+        super();
+        this._cacheIns = this.GenCacheIns();
+        this._slidingMap = new Map();
+    }
+    GetAsync(key) {
+        let opt = undefined;
+        if (this.IsSlidingCache(key))
+            opt = { updateAgeOnGet: true };
+        const data = this.CacheIns.get(key, opt);
+        return Promise.resolve(data);
+    }
+    SetAsync(key, data, options) {
+        let opt = undefined;
+        if (options && options.ttl)
+            opt = { ttl: options.ttl * 1000, noUpdateTTL: false };
+        this.CacheIns.set(key, data, opt);
+        if (options && options.ttl && options.type === 'sliding')
+            this.AddSlidingCache(key, options.ttl * 1000); // 缓存塞进去后添加滑动过期Key
+        return Promise.resolve();
+    }
+    RemoveAsync(key) {
+        this.CacheIns.delete(key);
+        return Promise.resolve();
+    }
+    GetOptions() {
+        let setting = this.SettingManager.GetConfig('cache');
+        if (!setting) {
+            setting = {
+                max: 5000,
+                maxSize: 5000 * 1024,
+                ttl: 20 * 60 * 1000,
+            };
+        }
+        return setting;
+    }
+    GenCacheIns() {
+        const cacheOpt = this.GetOptions();
+        return new lru_cache_1.LRUCache({
+            ...cacheOpt,
+            noUpdateTTL: false,
+            sizeCalculation: (val, key) => this.SizeCalculation(val, key),
+            dispose: (val, key) => this.RemoveSlidingCache(key),
+        });
+    }
+    SizeCalculation(value, key) {
+        if (Buffer.isBuffer(value)) {
+            return value.byteLength;
+        }
+        return Buffer.from(JSON.stringify(value), 'utf-8').byteLength;
+    }
+    IsSlidingCache(key) {
+        return !!this.SlidingMap.get(key);
+    }
+    AddSlidingCache(key, ttl) {
+        this.SlidingMap.set(key, ttl);
+    }
+    RemoveSlidingCache(key) {
+        this.SlidingMap.delete(key);
+    }
+};
+exports.LRUCache = LRUCache;
+exports.LRUCache = LRUCache = __decorate([
+    (0, Dependency_1.Injectable)(),
+    (0, Dependency_1.Singleton)(exports.MEMORY_CACHE_INJECT_TOKEN),
+    __metadata("design:paramtypes", [])
+], LRUCache);
+//# sourceMappingURL=MemoryCache.js.map

build/src/cache/memory/MemoryCache.js.map

+{"version":3,"file":"MemoryCache.js","sourceRoot":"","sources":["../../../../src/cache/memory/MemoryCache.ts"],"names":[],"mappings":";;;;;;;;;;;;AAAA,oDAA4E;AAC5E,oCAAyC;AAEzC,yCAAsD;AAGzC,QAAA,yBAAyB,GAAG,IAAA,2BAAc,EAAC,kBAAkB,CAAC,CAAC;AAKrE,IAAM,QAAQ,GAAd,MAAM,QAAS,SAAQ,aAAK;IAEjC,IAAW,QAAQ;QACjB,OAAO,IAAI,CAAC,SAAS,CAAC;IACxB,CAAC;IAGD,IAAc,UAAU;QACtB,OAAO,IAAI,CAAC,WAAW,CAAC;IAC1B,CAAC;IAED;QACE,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,SAAS,GAAG,IAAI,CAAC,WAAW,EAAE,CAAC;QACpC,IAAI,CAAC,WAAW,GAAG,IAAI,GAAG,EAAkB,CAAC;IAC/C,CAAC;IAED,QAAQ,CAAe,GAAW;QAChC,IAAI,GAAG,GAA+D,SAAS,CAAC;QAChF,IAAI,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC;YAAE,GAAG,GAAG,EAAE,cAAc,EAAE,IAAI,EAAE,CAAC;QAC7D,MAAM,IAAI,GAAG,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,GAAG,EAAE,GAAG,CAAuB,CAAC;QAC/D,OAAO,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;IAC/B,CAAC;IAED,QAAQ,CAAe,GAAW,EAAE,IAAY,EAAE,OAAuC;QACvF,IAAI,GAAG,GAA+D,SAAS,CAAC;QAChF,IAAI,OAAO,IAAI,OAAO,CAAC,GAAG;YAAE,GAAG,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,GAAG,GAAG,IAAI,EAAE,WAAW,EAAE,KAAK,EAAE,CAAC;QAElF,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,GAAG,EAAE,IAAI,EAAE,GAAG,CAAC,CAAC;QAElC,IAAI,OAAO,IAAI,OAAO,CAAC,GAAG,IAAI,OAAO,CAAC,IAAI,KAAK,SAAS;YAAE,IAAI,CAAC,eAAe,CAAC,GAAG,EAAE,OAAO,CAAC,GAAG,GAAG,IAAI,CAAC,CAAC,CAAC,kBAAkB;QAE3H,OAAO,OAAO,CAAC,OAAO,EAAE,CAAC;IAC3B,CAAC;IAED,WAAW,CAAC,GAAW;QACrB,IAAI,CAAC,QAAQ,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;QAC1B,OAAO,OAAO,CAAC,OAAO,EAAE,CAAC;IAC3B,CAAC;IAES,UAAU;QAClB,IAAI,OAAO,GAAG,IAAI,CAAC,cAAc,CAAC,SAAS,CAA8C,OAAO,CAAC,CAAC;QAClG,IAAI,CAAC,OAAO,EAAE;YACZ,OAAO,GAAG;gBACR,GAAG,EAAE,IAAI;gBACT,OAAO,EAAE,IAAI,GAAG,IAAI;gBACpB,GAAG,EAAE,EAAE,GAAG,EAAE,GAAG,IAAI;aACpB,CAAC;SACH;QACD,OAAO,OAAuB,CAAC;IACjC,CAAC;IAES,WAAW;QACnB,MAAM,QAAQ,GAAG,IAAI,CAAC,UAAU,EAAE,CAAC;QACnC,OAAO,IAAI,oBAAa,CAAc;YACpC,GAAI,QAAgB;YACpB,WAAW,EAAE,KAAK;YAClB,eAAe,EAAE,CAAC,GAAQ,EAAE,GAAW,EAAE,EAAE,CAAC,IAAI,CAAC,eAAe,CAAC,GAAG,EAAE,GAAG,CAAC;YAC1E,OAAO,EAAE,CAAC,GAAQ,EAAE,GAAW,EAAE,EAAE,CAAC,IAAI,CAAC,kBAAkB,CAAC,GAAG,CAAC;SACjE,CAAC,CAAC;IACL,CAAC;IAES,eAAe,CAAC,KAAU,EAAE,GAAW;QAC/C,IAAI,MAAM,CAAC,QAAQ,CAAC,KAAK,CAAC,EAAE;YAC1B,OAAQ,KAAgB,CAAC,UAAU,CAAC;SACrC;QACD,OAAO,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,KAAK,CAAC,EAAE,OAAO,CAAC,CAAC,UAAU,CAAC;IAChE,CAAC;IAES,cAAc,CAAC,GAAW;QAClC,OAAO,CAAC,CAAC,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;IACpC,CAAC;IAES,eAAe,CAAC,GAAW,EAAE,GAAW;QAChD,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,GAAG,EAAE,GAAG,CAAC,CAAC;IAChC,CAAC;IAES,kBAAkB,CAAC,GAAW;QACtC,IAAI,CAAC,UAAU,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;IAC9B,CAAC;CACF,CAAA;AAhFY,4BAAQ;mBAAR,QAAQ;IAFpB,IAAA,uBAAU,GAAE;IACZ,IAAA,sBAAS,EAAC,iCAAyB,CAAC;;GACxB,QAAQ,CAgFpB"}

build/src/cache/options/CacheEntryOptions.d.ts

+export interface CacheEntryOptions {
+    /**
+     * 缓存类型
+     */
+    type: 'sliding' | 'absolute';
+    /**
+     * 过期时间(单位秒)
+     */
+    ttl?: number;
+}

build/src/cache/options/CacheEntryOptions.js

+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+//# sourceMappingURL=CacheEntryOptions.js.map

build/src/cache/options/CacheEntryOptions.js.map

+{"version":3,"file":"CacheEntryOptions.js","sourceRoot":"","sources":["../../../../src/cache/options/CacheEntryOptions.ts"],"names":[],"mappings":""}

build/src/cache/options/CacheOptions.d.ts

+export interface CacheOptions {
+}

build/src/cache/options/CacheOptions.js

+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+//# sourceMappingURL=CacheOptions.js.map

build/src/cache/options/CacheOptions.js.map

+{"version":3,"file":"CacheOptions.js","sourceRoot":"","sources":["../../../../src/cache/options/CacheOptions.ts"],"names":[],"mappings":""}

build/index.d.ts

@@ -26,2 +26,7 @@ import 'reflect-metadata';
 import { UserInfo, ICurrentUser, CURRENT_USER_INJECT_TOKEN } from './src/user/CurrentUser';
-export { Container, Singleton, Transient, Injectable, Inject, GetInjectInfo, ReplaceService, AllowMultiple, IsMultipleRegister, Abstract, IsAbstract, GetInjectToken, LOGGER_INJECT_TOKEN, ILogger, Logger, InitLogger, SC_INJECT_TOKEN, IServiceCollection, ServiceCollection, InitServiceCollection, InitServiceLoader, NewbilityError, UserFriendlyError, UserFriendlyErrorData, EVENT_BUS_INJECT_TOKEN, IEventData, IEventBus, EventBus, EVENT_HANDLER_METADATA, IEventHandler, EventKey, GetEventKey, IsEventHandler, EventHandler, GetMetadataKey, Metadata, DefineMetadata, GetMetadata, MODULE_INJECT_TOKEN, MODULE_PATH_METADATA_TOKEN, IAppModule, AppModule, StartModule, StopModule, RegisterModuleByPath, ModulePath, DependsOn, GetModulePath, GetModuleDepends, RegisterModule, IProgram, SETTING_INJECT_TOKEN, ISettingManager, SettingManager, InitSettingManager, IDisposable, IAsyncDisposable, UsingAsync, IRunnable, ArrayHelper, Guid, OsHelper, StreamHelper, CoreModule, IService, Service, IInterceptor, InterceptorBase, Interceptor, PromiseHelper, UserInfo, ICurrentUser, CURRENT_USER_INJECT_TOKEN, };
+import { Cache } from './src/cache/Cache';
+import { IMemoryCache, LRUCache, MEMORY_CACHE_INJECT_TOKEN } from './src/cache/memory/MemoryCache';
+import { IDistributedCache, DefaultDistributedCache, DISTRIBUTED_CACHE_INJECT_TOKEN } from './src/cache/distributed/DistributedCache';
+import { CacheEntryOptions } from './src/cache/options/CacheEntryOptions';
+import { CacheOptions } from './src/cache/options/CacheOptions';
+export { Container, Singleton, Transient, Injectable, Inject, GetInjectInfo, ReplaceService, AllowMultiple, IsMultipleRegister, Abstract, IsAbstract, GetInjectToken, LOGGER_INJECT_TOKEN, ILogger, Logger, InitLogger, SC_INJECT_TOKEN, IServiceCollection, ServiceCollection, InitServiceCollection, InitServiceLoader, NewbilityError, UserFriendlyError, UserFriendlyErrorData, EVENT_BUS_INJECT_TOKEN, IEventData, IEventBus, EventBus, EVENT_HANDLER_METADATA, IEventHandler, EventKey, GetEventKey, IsEventHandler, EventHandler, GetMetadataKey, Metadata, DefineMetadata, GetMetadata, MODULE_INJECT_TOKEN, MODULE_PATH_METADATA_TOKEN, IAppModule, AppModule, StartModule, StopModule, RegisterModuleByPath, ModulePath, DependsOn, GetModulePath, GetModuleDepends, RegisterModule, IProgram, SETTING_INJECT_TOKEN, ISettingManager, SettingManager, InitSettingManager, IDisposable, IAsyncDisposable, UsingAsync, IRunnable, ArrayHelper, Guid, OsHelper, StreamHelper, CoreModule, IService, Service, IInterceptor, InterceptorBase, Interceptor, PromiseHelper, UserInfo, ICurrentUser, CURRENT_USER_INJECT_TOKEN, Cache, CacheOptions, CacheEntryOptions, MEMORY_CACHE_INJECT_TOKEN, IMemoryCache, LRUCache, DISTRIBUTED_CACHE_INJECT_TOKEN, IDistributedCache, DefaultDistributedCache, };

build/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.OsHelper = exports.Guid = exports.ArrayHelper = exports.UsingAsync = exports.InitSettingManager = exports.SettingManager = exports.SETTING_INJECT_TOKEN = exports.RegisterModule = exports.GetModuleDepends = exports.GetModulePath = exports.DependsOn = exports.ModulePath = exports.RegisterModuleByPath = exports.StopModule = exports.StartModule = exports.AppModule = exports.MODULE_PATH_METADATA_TOKEN = exports.MODULE_INJECT_TOKEN = exports.GetMetadata = exports.DefineMetadata = exports.Metadata = exports.GetMetadataKey = exports.EventHandler = exports.IsEventHandler = exports.GetEventKey = exports.EventKey = exports.EVENT_HANDLER_METADATA = exports.EventBus = exports.EVENT_BUS_INJECT_TOKEN = exports.UserFriendlyError = exports.NewbilityError = exports.InitServiceLoader = exports.InitServiceCollection = exports.ServiceCollection = exports.SC_INJECT_TOKEN = exports.InitLogger = exports.Logger = exports.LOGGER_INJECT_TOKEN = exports.GetInjectToken = exports.IsAbstract = exports.Abstract = exports.IsMultipleRegister = exports.AllowMultiple = exports.ReplaceService = exports.GetInjectInfo = exports.Inject = exports.Injectable = exports.Transient = exports.Singleton = exports.Container = void 0;
-exports.CURRENT_USER_INJECT_TOKEN = exports.PromiseHelper = exports.Interceptor = exports.InterceptorBase = exports.Service = exports.CoreModule = exports.StreamHelper = void 0;
+exports.DefaultDistributedCache = exports.DISTRIBUTED_CACHE_INJECT_TOKEN = exports.LRUCache = exports.MEMORY_CACHE_INJECT_TOKEN = exports.Cache = exports.CURRENT_USER_INJECT_TOKEN = exports.PromiseHelper = exports.Interceptor = exports.InterceptorBase = exports.Service = exports.CoreModule = exports.StreamHelper = void 0;
 require("reflect-metadata");
@@ -85,2 +85,10 @@ const Dependency_1 = require("./src/di/Dependency");
 Object.defineProperty(exports, "CURRENT_USER_INJECT_TOKEN", { enumerable: true, get: function () { return CurrentUser_1.CURRENT_USER_INJECT_TOKEN; } });
+const Cache_1 = require("./src/cache/Cache");
+Object.defineProperty(exports, "Cache", { enumerable: true, get: function () { return Cache_1.Cache; } });
+const MemoryCache_1 = require("./src/cache/memory/MemoryCache");
+Object.defineProperty(exports, "LRUCache", { enumerable: true, get: function () { return MemoryCache_1.LRUCache; } });
+Object.defineProperty(exports, "MEMORY_CACHE_INJECT_TOKEN", { enumerable: true, get: function () { return MemoryCache_1.MEMORY_CACHE_INJECT_TOKEN; } });
+const DistributedCache_1 = require("./src/cache/distributed/DistributedCache");
+Object.defineProperty(exports, "DefaultDistributedCache", { enumerable: true, get: function () { return DistributedCache_1.DefaultDistributedCache; } });
+Object.defineProperty(exports, "DISTRIBUTED_CACHE_INJECT_TOKEN", { enumerable: true, get: function () { return DistributedCache_1.DISTRIBUTED_CACHE_INJECT_TOKEN; } });
 //# sourceMappingURL=index.js.map

build/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../index.ts"],"names":[],"mappings":";;;;AAAA,4BAA0B;AAC1B,oDAa6B;AA+C3B,yFA3DA,qBAAQ,OA2DA;AAFR,8FAxDA,0BAAa,OAwDA;AAPb,0FAhDA,sBAAS,OAgDA;AAKT,8FApDA,0BAAa,OAoDA;AAMb,+FAzDA,2BAAc,OAyDA;AAPd,uFAjDA,mBAAM,OAiDA;AADN,2FA/CA,uBAAU,OA+CA;AAOV,2FArDA,uBAAU,OAqDA;AAFV,mGAlDA,+BAAkB,OAkDA;AAFlB,+FA/CA,2BAAc,OA+CA;AALd,0FAzCA,sBAAS,OAyCA;AACT,0FAzCA,sBAAS,OAyCA;AAvCX,kEAA2H;AAqDzH,gGArDO,mCAAe,OAqDP;AAEf,kGAvD4C,qCAAiB,OAuD5C;AACjB,sGAxD+D,yCAAqB,OAwD/D;AAvDvB,+DAA4D;AAyD1D,+FAzDO,+BAAc,OAyDP;AAxDhB,qEAAyF;AAyDvF,kGAzDO,qCAAiB,OAyDP;AAxDnB,mDAA+F;AA6D7F,yFA7DO,mBAAQ,OA6DP;AAHR,uGA1DiB,iCAAsB,OA0DjB;AAzDxB,2DAAsI;AA6DpI,uGA7DO,qCAAsB,OA6DP;AAEtB,yFA/D8C,uBAAQ,OA+D9C;AACR,4FAhEwD,0BAAW,OAgExD;AACX,+FAjEqE,6BAAc,OAiErE;AACd,6FAlEqF,2BAAY,OAkErF;AAjEd,gDAAuF;AA4CrF,oGA5CO,4BAAmB,OA4CP;AAEnB,uFA9CqC,eAAM,OA8CrC;AACN,2FA/C6C,mBAAU,OA+C7C;AA9CZ,sDAAgG;AAmE9F,+FAnEO,yBAAc,OAmEP;AACd,4FApEuB,sBAAW,OAoEvB;AAHX,+FAjEoC,yBAAc,OAiEpC;AACd,yFAlEoD,mBAAQ,OAkEpD;AAjEV,0DAYoC;AA2DlC,0FArEA,qBAAS,OAqEA;AACT,4FArEA,uBAAW,OAqEA;AACX,2FArEA,sBAAU,OAqEA;AACV,qGArEA,gCAAoB,OAqEA;AACpB,2FArEA,sBAAU,OAqEA;AAEV,8FAtEA,yBAAa,OAsEA;AACb,iGAtEA,4BAAgB,OAsEA;AAChB,+FAtEA,0BAAc,OAsEA;AAXd,oGA1DA,+BAAmB,OA0DA;AACnB,2GA1DA,sCAA0B,OA0DA;AAvD5B,iEAAyH;AAmEvH,qGAnEO,qCAAoB,OAmEP;AAEpB,+FArE8C,+BAAc,OAqE9C;AACd,mGAtE8D,mCAAkB,OAsE9D;AArEpB,qDAAiF;AAwE/E,2FAxEsC,uBAAU,OAwEtC;AAvEZ,wDAAqD;AAyEnD,4FAzEO,yBAAW,OAyEP;AAxEb,0CAAuC;AAyErC,qFAzEO,WAAI,OAyEP;AAxEN,0DAAuD;AA0ErD,6FA1EO,2BAAY,OA0EP;AAzEd,0DAAuD;AAyDrD,0FAzDO,qBAAS,OAyDP;AAxDX,0DAA2D;AA8BzD,kGA9BO,iCAAiB,OA8BP;AA7BnB,iDAA8C;AAwE5C,2FAxEO,uBAAU,OAwEP;AAvEZ,kDAA+C;AAqE7C,yFArEO,mBAAQ,OAqEP;AAnEV,mDAA0D;AAuExD,wFAvEiB,iBAAO,OAuEjB;AAtET,+DAA2F;AAwEzF,gGAxEqB,6BAAe,OAwErB;AACf,4FAzEsC,yBAAW,OAyEtC;AAxEb,4DAAyD;AAyEvD,8FAzEO,6BAAa,OAyEP;AAxEf,wDAA2F;AA2EzF,0GA3E+B,uCAAyB,OA2E/B"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../index.ts"],"names":[],"mappings":";;;;AAAA,4BAA0B;AAC1B,oDAa6B;AAoD3B,yFAhEA,qBAAQ,OAgEA;AAFR,8FA7DA,0BAAa,OA6DA;AAPb,0FArDA,sBAAS,OAqDA;AAKT,8FAzDA,0BAAa,OAyDA;AAMb,+FA9DA,2BAAc,OA8DA;AAPd,uFAtDA,mBAAM,OAsDA;AADN,2FApDA,uBAAU,OAoDA;AAOV,2FA1DA,uBAAU,OA0DA;AAFV,mGAvDA,+BAAkB,OAuDA;AAFlB,+FApDA,2BAAc,OAoDA;AALd,0FA9CA,sBAAS,OA8CA;AACT,0FA9CA,sBAAS,OA8CA;AA5CX,kEAA2H;AA0DzH,gGA1DO,mCAAe,OA0DP;AAEf,kGA5D4C,qCAAiB,OA4D5C;AACjB,sGA7D+D,yCAAqB,OA6D/D;AA5DvB,+DAA4D;AA8D1D,+FA9DO,+BAAc,OA8DP;AA7DhB,qEAAyF;AA8DvF,kGA9DO,qCAAiB,OA8DP;AA7DnB,mDAA+F;AAkE7F,yFAlEO,mBAAQ,OAkEP;AAHR,uGA/DiB,iCAAsB,OA+DjB;AA9DxB,2DAAsI;AAkEpI,uGAlEO,qCAAsB,OAkEP;AAEtB,yFApE8C,uBAAQ,OAoE9C;AACR,4FArEwD,0BAAW,OAqExD;AACX,+FAtEqE,6BAAc,OAsErE;AACd,6FAvEqF,2BAAY,OAuErF;AAtEd,gDAAuF;AAiDrF,oGAjDO,4BAAmB,OAiDP;AAEnB,uFAnDqC,eAAM,OAmDrC;AACN,2FApD6C,mBAAU,OAoD7C;AAnDZ,sDAAgG;AAwE9F,+FAxEO,yBAAc,OAwEP;AACd,4FAzEuB,sBAAW,OAyEvB;AAHX,+FAtEoC,yBAAc,OAsEpC;AACd,yFAvEoD,mBAAQ,OAuEpD;AAtEV,0DAYoC;AAgElC,0FA1EA,qBAAS,OA0EA;AACT,4FA1EA,uBAAW,OA0EA;AACX,2FA1EA,sBAAU,OA0EA;AACV,qGA1EA,gCAAoB,OA0EA;AACpB,2FA1EA,sBAAU,OA0EA;AAEV,8FA3EA,yBAAa,OA2EA;AACb,iGA3EA,4BAAgB,OA2EA;AAChB,+FA3EA,0BAAc,OA2EA;AAXd,oGA/DA,+BAAmB,OA+DA;AACnB,2GA/DA,sCAA0B,OA+DA;AA5D5B,iEAAyH;AAwEvH,qGAxEO,qCAAoB,OAwEP;AAEpB,+FA1E8C,+BAAc,OA0E9C;AACd,mGA3E8D,mCAAkB,OA2E9D;AA1EpB,qDAAiF;AA6E/E,2FA7EsC,uBAAU,OA6EtC;AA5EZ,wDAAqD;AA8EnD,4FA9EO,yBAAW,OA8EP;AA7Eb,0CAAuC;AA8ErC,qFA9EO,WAAI,OA8EP;AA7EN,0DAAuD;AA+ErD,6FA/EO,2BAAY,OA+EP;AA9Ed,0DAAuD;AA8DrD,0FA9DO,qBAAS,OA8DP;AA7DX,0DAA2D;AAmCzD,kGAnCO,iCAAiB,OAmCP;AAlCnB,iDAA8C;AA6E5C,2FA7EO,uBAAU,OA6EP;AA5EZ,kDAA+C;AA0E7C,yFA1EO,mBAAQ,OA0EP;AAxEV,mDAA0D;AA4ExD,wFA5EiB,iBAAO,OA4EjB;AA3ET,+DAA2F;AA6EzF,gGA7EqB,6BAAe,OA6ErB;AACf,4FA9EsC,yBAAW,OA8EtC;AA7Eb,4DAAyD;AA8EvD,8FA9EO,6BAAa,OA8EP;AA7Ef,wDAA2F;AAgFzF,0GAhF+B,uCAAyB,OAgF/B;AA/E3B,6CAA0C;AAgFxC,sFAhFO,aAAK,OAgFP;AA/EP,gEAAmG;AAoFjG,yFApFqB,sBAAQ,OAoFrB;AAFR,0GAlF+B,uCAAyB,OAkF/B;AAjF3B,+EAAsI;AAsFpI,wGAtF0B,0CAAuB,OAsF1B;AAFvB,+GApFmD,iDAA8B,OAoFnD"}

package.json

 {
   "name": "@newbility/core",
-  "version": "0.2.49",
+  "version": "0.2.50",
   "main": "build/index.js",
@@ -21,2 +21,3 @@ "author": "jameshu",
     "log4js": "^6.6.1",
+    "lru-cache": "^10.1.0",
     "reflect-metadata": "^0.1.13",
@@ -23,0 +24,0 @@ "tsyringe": "^4.8.0",

No alert changes

Improved metrics

Total package byte prevSize

123554

17.23%

Number of package files

95

18.75%

Lines of code

1890

16.88%

Worsened metrics

Dependency count

6

20%

Dependency changes

• + Added

  lru-cache@^10.1.0

• + Added

  lru-cache@10.4.3
  (transitive)