import { RequestContext } from '../api'; /** * @description * This service is used to cache arbitrary data relative to an ongoing request. * It does this by using a WeakMap bound to the current RequestContext, so the cached * data is available for the duration of the request. Once the request completes, the * cached data will be automatically garbage-collected. * * This is useful for caching data which is expensive to compute and which is needed * multiple times during the handling of a single request. * * @docsCategory cache */ export class RequestContextCacheService { private caches = new WeakMap>(); /** * @description * Set a value in the RequestContext cache. */ set(ctx: RequestContext, key: any, val: T): void { this.getContextCache(ctx).set(key, val); } /** * @description * Get a value from the RequestContext cache. If the value is not found, the `getDefault` * function will be called to get the value, which will then be cached and returned. */ get(ctx: RequestContext, key: any): T | undefined; get(ctx: RequestContext, key: any, getDefault?: () => T): T; get(ctx: RequestContext, key: any, getDefault?: () => T): T | Promise | undefined { const ctxCache = this.getContextCache(ctx); const result = ctxCache.get(key); if (result) { return result; } if (getDefault) { const defaultResultOrPromise = getDefault(); ctxCache.set(key, defaultResultOrPromise); return defaultResultOrPromise; } else { return; } } private getContextCache(ctx: RequestContext): Map { let ctxCache = this.caches.get(ctx); if (!ctxCache) { ctxCache = new Map(); this.caches.set(ctx, ctxCache); } return ctxCache; } private isPromise(input: T | Promise): input is Promise { return typeof (input as any).then === 'function'; } }