Spaces:
Running
Running
File size: 3,022 Bytes
979bf48 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 | "use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
0 && (module.exports = {
parseUseCacheCacheStore: null,
serializeUseCacheCacheStore: null
});
function _export(target, all) {
for(var name in all)Object.defineProperty(target, name, {
enumerable: true,
get: all[name]
});
}
_export(exports, {
parseUseCacheCacheStore: function() {
return parseUseCacheCacheStore;
},
serializeUseCacheCacheStore: function() {
return serializeUseCacheCacheStore;
}
});
const _encryptionutils = require("../app-render/encryption-utils");
const _constants = require("../use-cache/constants");
function parseUseCacheCacheStore(entries) {
const store = new Map();
for (const [key, { value, tags, stale, timestamp, expire, revalidate }] of entries){
store.set(key, Promise.resolve({
// Create a ReadableStream from the Uint8Array
value: new ReadableStream({
start (controller) {
// Enqueue the Uint8Array to the stream
controller.enqueue((0, _encryptionutils.stringToUint8Array)(atob(value)));
// Close the stream
controller.close();
}
}),
tags,
stale,
timestamp,
expire,
revalidate
}));
}
return store;
}
async function serializeUseCacheCacheStore(entries, isCacheComponentsEnabled) {
return Promise.all(Array.from(entries).map(([key, value])=>{
return value.then(async (entry)=>{
if (isCacheComponentsEnabled && (entry.revalidate === 0 || entry.expire < _constants.DYNAMIC_EXPIRE)) {
// The entry was omitted from the prerender result, and subsequently
// does not need to be included in the serialized RDC.
return null;
}
const [left, right] = entry.value.tee();
entry.value = right;
let binaryString = '';
// We want to encode the value as a string, but we aren't sure if the
// value is a a stream of UTF-8 bytes or not, so let's just encode it
// as a string using base64.
for await (const chunk of left){
binaryString += (0, _encryptionutils.arrayBufferToString)(chunk);
}
return [
key,
{
// Encode the value as a base64 string.
value: btoa(binaryString),
tags: entry.tags,
stale: entry.stale,
timestamp: entry.timestamp,
expire: entry.expire,
revalidate: entry.revalidate
}
];
}).catch(()=>{
// Any failed cache writes should be ignored as to not discard the
// entire cache.
return null;
});
}));
}
//# sourceMappingURL=cache-store.js.map |