Function getFromCache

shared/fetch/fetch.ts:219–322

({
    key,
    fetchFunction: fetchFromSource,
    calledFrom,
    redisUrl,
    redisToken,
    shouldGetFromCache: shouldGetFromCacheOptions = true,
    shouldUpdateCache: shouldUpdateCacheOptions = true,
    shouldThrow = true,
    shouldCompress = false,
    cacheType = CacheType.REDIS
}: GetFromCacheOptions<T>)

 * @returns
 */
export async function getFromCache<T = any>({
    key,
    fetchFunction: fetchFromSource,
    calledFrom,
    redisUrl,
    redisToken,
    shouldGetFromCache: shouldGetFromCacheOptions = true,
    shouldUpdateCache: shouldUpdateCacheOptions = true,
    shouldThrow = true,
    shouldCompress = false,
    cacheType = CacheType.REDIS
}: GetFromCacheOptions<T>) {
    const startAt = new Date()
    let inMemory = false
    initRedis(redisUrl, redisToken)
    const calledFromLog = calledFrom ? `(↪️  ${calledFrom})` : ''

    const cacheIsDisabled = process.env.DISABLE_CACHE === 'true'
    const shouldGetFromCache = !cacheIsDisabled && shouldGetFromCacheOptions
    const shouldUpdateCache = !cacheIsDisabled && shouldUpdateCacheOptions

    if (cacheIsDisabled && shouldGetFromCache === true) {
        console.warn(
            'Cache is turned off in env settings, ignoring shouldGetFromCache = true option'
        )
    }
    if (cacheIsDisabled && shouldUpdateCache === true) {
        console.warn(
            'Cache is turned off in env settings, ignoring shouldUpdateCache = true option'
        )
    }

    async function fetchAndProcess<T>(source: SourceType) {
        const data = await fetchFromSource()
        return processFetchData<T>(data, source, key)
    }

    let resultPromise: Promise<FetchPayload<T>>

    try {
        // 1. we have the a promise that resolve to the data in memory => return that
        if (shouldGetFromCache && memoryCache.has(key)) {
            console.debug(`🟢 [${key}] in-memory cache hit ${calledFromLog}`)
            inMemory = true
            resultPromise = memoryCache.get<Promise<FetchPayload<T>>>(key)!
        } else {
            // 2. store a promise that will first look in Redis, then in the main db
            if (shouldGetFromCache) {
                resultPromise = getFromCacheOrSource<T>({
                    key,
                    fetchFromSource,
                    calledFromLog,
                    shouldUpdateCache,
                    shouldCompress
                })
            } else {
                console.debug(
                    `🟡 [${key}] Redis cache disabled, fetching from source ${calledFromLog}`