{"version":3,"sources":["../../../src/server/resume-data-cache/cache-store.ts"],"sourcesContent":["import {\n  arrayBufferToString,\n  stringToUint8Array,\n} from '../app-render/encryption-utils'\nimport type { CacheEntry } from '../lib/cache-handlers/types'\nimport type { CachedFetchValue } from '../response-cache/types'\nimport { DYNAMIC_EXPIRE } from '../use-cache/constants'\n\n/**\n * A generic cache store type that provides a subset of Map functionality\n */\ntype CacheStore<T> = Pick<\n  Map<string, T>,\n  'entries' | 'keys' | 'size' | 'get' | 'set'\n>\n\n/**\n * A cache store specifically for fetch cache values\n */\nexport type FetchCacheStore = CacheStore<CachedFetchValue>\n\n/**\n * A cache store for encrypted bound args of inline server functions.\n */\nexport type EncryptedBoundArgsCacheStore = CacheStore<string>\n\n/**\n * An in-memory-only cache store for decrypted bound args of inline server\n * functions.\n */\nexport type DecryptedBoundArgsCacheStore = CacheStore<string>\n\n/**\n * Serialized format for \"use cache\" entries\n */\nexport interface UseCacheCacheStoreSerialized {\n  value: string\n  tags: string[]\n  stale: number\n  timestamp: number\n  expire: number\n  revalidate: number\n}\n\n/**\n * A cache store specifically for \"use cache\" values that stores promises of\n * cache entries.\n */\nexport type UseCacheCacheStore = CacheStore<Promise<CacheEntry>>\n\n/**\n * Parses serialized cache entries into a UseCacheCacheStore\n * @param entries - The serialized entries to parse\n * @returns A new UseCacheCacheStore containing the parsed entries\n */\nexport function parseUseCacheCacheStore(\n  entries: Iterable<[string, UseCacheCacheStoreSerialized]>\n): UseCacheCacheStore {\n  const store = new Map<string, Promise<CacheEntry>>()\n\n  for (const [\n    key,\n    { value, tags, stale, timestamp, expire, revalidate },\n  ] of entries) {\n    store.set(\n      key,\n      Promise.resolve({\n        // Create a ReadableStream from the Uint8Array\n        value: new ReadableStream<Uint8Array>({\n          start(controller) {\n            // Enqueue the Uint8Array to the stream\n            controller.enqueue(stringToUint8Array(atob(value)))\n\n            // Close the stream\n            controller.close()\n          },\n        }),\n        tags,\n        stale,\n        timestamp,\n        expire,\n        revalidate,\n      })\n    )\n  }\n\n  return store\n}\n\n/**\n * Serializes UseCacheCacheStore entries into an array of key-value pairs\n * @param entries - The store entries to stringify\n * @returns A promise that resolves to an array of key-value pairs with serialized values\n */\nexport async function serializeUseCacheCacheStore(\n  entries: IterableIterator<[string, Promise<CacheEntry>]>,\n  isCacheComponentsEnabled: boolean\n): Promise<Array<[string, UseCacheCacheStoreSerialized] | null>> {\n  return Promise.all(\n    Array.from(entries).map(([key, value]) => {\n      return value\n        .then(async (entry) => {\n          if (\n            isCacheComponentsEnabled &&\n            (entry.revalidate === 0 || entry.expire < DYNAMIC_EXPIRE)\n          ) {\n            // The entry was omitted from the prerender result, and subsequently\n            // does not need to be included in the serialized RDC.\n            return null\n          }\n\n          const [left, right] = entry.value.tee()\n          entry.value = right\n\n          let binaryString: string = ''\n\n          // We want to encode the value as a string, but we aren't sure if the\n          // value is a a stream of UTF-8 bytes or not, so let's just encode it\n          // as a string using base64.\n          for await (const chunk of left) {\n            binaryString += arrayBufferToString(chunk)\n          }\n\n          return [\n            key,\n            {\n              // Encode the value as a base64 string.\n              value: btoa(binaryString),\n              tags: entry.tags,\n              stale: entry.stale,\n              timestamp: entry.timestamp,\n              expire: entry.expire,\n              revalidate: entry.revalidate,\n            },\n          ] satisfies [string, UseCacheCacheStoreSerialized]\n        })\n        .catch(() => {\n          // Any failed cache writes should be ignored as to not discard the\n          // entire cache.\n          return null\n        })\n    })\n  )\n}\n"],"names":["parseUseCacheCacheStore","serializeUseCacheCacheStore","entries","store","Map","key","value","tags","stale","timestamp","expire","revalidate","set","Promise","resolve","ReadableStream","start","controller","enqueue","stringToUint8Array","atob","close","isCacheComponentsEnabled","all","Array","from","map","then","entry","DYNAMIC_EXPIRE","left","right","tee","binaryString","chunk","arrayBufferToString","btoa","catch"],"mappings":";;;;;;;;;;;;;;;IAuDgBA,uBAAuB;eAAvBA;;IAuCMC,2BAA2B;eAA3BA;;;iCA3Ff;2BAGwB;AAiDxB,SAASD,wBACdE,OAAyD;IAEzD,MAAMC,QAAQ,IAAIC;IAElB,KAAK,MAAM,CACTC,KACA,EAAEC,KAAK,EAAEC,IAAI,EAAEC,KAAK,EAAEC,SAAS,EAAEC,MAAM,EAAEC,UAAU,EAAE,CACtD,IAAIT,QAAS;QACZC,MAAMS,GAAG,CACPP,KACAQ,QAAQC,OAAO,CAAC;YACd,8CAA8C;YAC9CR,OAAO,IAAIS,eAA2B;gBACpCC,OAAMC,UAAU;oBACd,uCAAuC;oBACvCA,WAAWC,OAAO,CAACC,IAAAA,mCAAkB,EAACC,KAAKd;oBAE3C,mBAAmB;oBACnBW,WAAWI,KAAK;gBAClB;YACF;YACAd;YACAC;YACAC;YACAC;YACAC;QACF;IAEJ;IAEA,OAAOR;AACT;AAOO,eAAeF,4BACpBC,OAAwD,EACxDoB,wBAAiC;IAEjC,OAAOT,QAAQU,GAAG,CAChBC,MAAMC,IAAI,CAACvB,SAASwB,GAAG,CAAC,CAAC,CAACrB,KAAKC,MAAM;QACnC,OAAOA,MACJqB,IAAI,CAAC,OAAOC;YACX,IACEN,4BACCM,CAAAA,MAAMjB,UAAU,KAAK,KAAKiB,MAAMlB,MAAM,GAAGmB,yBAAc,AAAD,GACvD;gBACA,oEAAoE;gBACpE,sDAAsD;gBACtD,OAAO;YACT;YAEA,MAAM,CAACC,MAAMC,MAAM,GAAGH,MAAMtB,KAAK,CAAC0B,GAAG;YACrCJ,MAAMtB,KAAK,GAAGyB;YAEd,IAAIE,eAAuB;YAE3B,qEAAqE;YACrE,qEAAqE;YACrE,4BAA4B;YAC5B,WAAW,MAAMC,SAASJ,KAAM;gBAC9BG,gBAAgBE,IAAAA,oCAAmB,EAACD;YACtC;YAEA,OAAO;gBACL7B;gBACA;oBACE,uCAAuC;oBACvCC,OAAO8B,KAAKH;oBACZ1B,MAAMqB,MAAMrB,IAAI;oBAChBC,OAAOoB,MAAMpB,KAAK;oBAClBC,WAAWmB,MAAMnB,SAAS;oBAC1BC,QAAQkB,MAAMlB,MAAM;oBACpBC,YAAYiB,MAAMjB,UAAU;gBAC9B;aACD;QACH,GACC0B,KAAK,CAAC;YACL,kEAAkE;YAClE,gBAAgB;YAChB,OAAO;QACT;IACJ;AAEJ","ignoreList":[0]}