DMleadgen
46d973904b
Next.js website for Rocky Mountain Vending company featuring: - Product catalog with Stripe integration - Service areas and parts pages - Admin dashboard with Clerk authentication - SEO optimized pages with JSON-LD structured data Co-authored-by: Cursor <cursoragent@cursor.com>
1 line
No EOL
10 KiB
Text
1 line
No EOL
10 KiB
Text
{"version":3,"sources":["../../src/server/revalidation-utils.ts"],"sourcesContent":["import type { WorkStore } from './app-render/work-async-storage.external'\nimport type { IncrementalCache } from './lib/incremental-cache'\nimport { getCacheHandlers } from './use-cache/handlers'\n\n/** Run a callback, and execute any *new* revalidations added during its runtime. */\nexport async function withExecuteRevalidates<T>(\n store: WorkStore | undefined,\n callback: () => Promise<T>\n): Promise<T> {\n if (!store) {\n return callback()\n }\n // If we executed any revalidates during the request, then we don't want to execute them again.\n // save the state so we can check if anything changed after we're done running callbacks.\n const savedRevalidationState = cloneRevalidationState(store)\n try {\n return await callback()\n } finally {\n // Check if we have any new revalidates, and if so, wait until they are all resolved.\n const newRevalidates = diffRevalidationState(\n savedRevalidationState,\n cloneRevalidationState(store)\n )\n await executeRevalidates(store, newRevalidates)\n }\n}\n\ntype RevalidationState = Required<\n Pick<\n WorkStore,\n 'pendingRevalidatedTags' | 'pendingRevalidates' | 'pendingRevalidateWrites'\n >\n>\n\nfunction cloneRevalidationState(store: WorkStore): RevalidationState {\n return {\n pendingRevalidatedTags: store.pendingRevalidatedTags\n ? [...store.pendingRevalidatedTags]\n : [],\n pendingRevalidates: { ...store.pendingRevalidates },\n pendingRevalidateWrites: store.pendingRevalidateWrites\n ? [...store.pendingRevalidateWrites]\n : [],\n }\n}\n\nfunction diffRevalidationState(\n prev: RevalidationState,\n curr: RevalidationState\n): RevalidationState {\n const prevTagsWithProfile = new Set(\n prev.pendingRevalidatedTags.map((item) => {\n const profileKey =\n typeof item.profile === 'object'\n ? JSON.stringify(item.profile)\n : item.profile || ''\n return `${item.tag}:${profileKey}`\n })\n )\n const prevRevalidateWrites = new Set(prev.pendingRevalidateWrites)\n return {\n pendingRevalidatedTags: curr.pendingRevalidatedTags.filter((item) => {\n const profileKey =\n typeof item.profile === 'object'\n ? JSON.stringify(item.profile)\n : item.profile || ''\n return !prevTagsWithProfile.has(`${item.tag}:${profileKey}`)\n }),\n pendingRevalidates: Object.fromEntries(\n Object.entries(curr.pendingRevalidates).filter(\n ([key]) => !(key in prev.pendingRevalidates)\n )\n ),\n pendingRevalidateWrites: curr.pendingRevalidateWrites.filter(\n (promise) => !prevRevalidateWrites.has(promise)\n ),\n }\n}\n\nasync function revalidateTags(\n tagsWithProfile: Array<{\n tag: string\n profile?: string | { expire?: number }\n }>,\n incrementalCache: IncrementalCache | undefined,\n workStore?: WorkStore\n): Promise<void> {\n if (tagsWithProfile.length === 0) {\n return\n }\n\n const handlers = getCacheHandlers()\n const promises: Promise<void>[] = []\n\n // Group tags by profile for batch processing\n const tagsByProfile = new Map<\n | string\n | { stale?: number; revalidate?: number; expire?: number }\n | undefined,\n string[]\n >()\n\n for (const item of tagsWithProfile) {\n const profile = item.profile\n // Find existing profile by comparing values\n let existingKey = undefined\n for (const [key] of tagsByProfile) {\n if (\n typeof key === 'string' &&\n typeof profile === 'string' &&\n key === profile\n ) {\n existingKey = key\n break\n }\n if (\n typeof key === 'object' &&\n typeof profile === 'object' &&\n JSON.stringify(key) === JSON.stringify(profile)\n ) {\n existingKey = key\n break\n }\n if (key === profile) {\n existingKey = key\n break\n }\n }\n\n const profileKey = existingKey || profile\n if (!tagsByProfile.has(profileKey)) {\n tagsByProfile.set(profileKey, [])\n }\n tagsByProfile.get(profileKey)!.push(item.tag)\n }\n\n // Process each profile group\n for (const [profile, tagsForProfile] of tagsByProfile) {\n // Look up the cache profile from workStore if available\n let durations: { expire?: number } | undefined\n\n if (profile) {\n let cacheLife:\n | { stale?: number; revalidate?: number; expire?: number }\n | undefined\n\n if (typeof profile === 'object') {\n // Profile is already a cacheLife configuration object\n cacheLife = profile\n } else if (typeof profile === 'string') {\n // Profile is a string key, look it up in workStore\n cacheLife = workStore?.cacheLifeProfiles?.[profile]\n\n if (!cacheLife) {\n throw new Error(\n `Invalid profile provided \"${profile}\" must be configured under cacheLife in next.config or be \"max\"`\n )\n }\n }\n\n if (cacheLife) {\n durations = {\n expire: cacheLife.expire,\n }\n }\n }\n // If profile is not found and not 'max', durations will be undefined\n // which will trigger immediate expiration in the cache handler\n\n for (const handler of handlers || []) {\n if (profile) {\n promises.push(handler.updateTags?.(tagsForProfile, durations))\n } else {\n promises.push(handler.updateTags?.(tagsForProfile))\n }\n }\n\n if (incrementalCache) {\n promises.push(incrementalCache.revalidateTag(tagsForProfile, durations))\n }\n }\n\n await Promise.all(promises)\n}\n\nexport async function executeRevalidates(\n workStore: WorkStore,\n state?: RevalidationState\n) {\n const pendingRevalidatedTags =\n state?.pendingRevalidatedTags ?? workStore.pendingRevalidatedTags ?? []\n\n const pendingRevalidates =\n state?.pendingRevalidates ?? workStore.pendingRevalidates ?? {}\n\n const pendingRevalidateWrites =\n state?.pendingRevalidateWrites ?? workStore.pendingRevalidateWrites ?? []\n\n return Promise.all([\n revalidateTags(\n pendingRevalidatedTags,\n workStore.incrementalCache,\n workStore\n ),\n ...Object.values(pendingRevalidates),\n ...pendingRevalidateWrites,\n ])\n}\n"],"names":["executeRevalidates","withExecuteRevalidates","store","callback","savedRevalidationState","cloneRevalidationState","newRevalidates","diffRevalidationState","pendingRevalidatedTags","pendingRevalidates","pendingRevalidateWrites","prev","curr","prevTagsWithProfile","Set","map","item","profileKey","profile","JSON","stringify","tag","prevRevalidateWrites","filter","has","Object","fromEntries","entries","key","promise","revalidateTags","tagsWithProfile","incrementalCache","workStore","length","handlers","getCacheHandlers","promises","tagsByProfile","Map","existingKey","undefined","set","get","push","tagsForProfile","durations","cacheLife","cacheLifeProfiles","Error","expire","handler","updateTags","revalidateTag","Promise","all","state","values"],"mappings":";;;;;;;;;;;;;;;IAyLsBA,kBAAkB;eAAlBA;;IApLAC,sBAAsB;eAAtBA;;;0BAHW;AAG1B,eAAeA,uBACpBC,KAA4B,EAC5BC,QAA0B;IAE1B,IAAI,CAACD,OAAO;QACV,OAAOC;IACT;IACA,+FAA+F;IAC/F,yFAAyF;IACzF,MAAMC,yBAAyBC,uBAAuBH;IACtD,IAAI;QACF,OAAO,MAAMC;IACf,SAAU;QACR,qFAAqF;QACrF,MAAMG,iBAAiBC,sBACrBH,wBACAC,uBAAuBH;QAEzB,MAAMF,mBAAmBE,OAAOI;IAClC;AACF;AASA,SAASD,uBAAuBH,KAAgB;IAC9C,OAAO;QACLM,wBAAwBN,MAAMM,sBAAsB,GAChD;eAAIN,MAAMM,sBAAsB;SAAC,GACjC,EAAE;QACNC,oBAAoB;YAAE,GAAGP,MAAMO,kBAAkB;QAAC;QAClDC,yBAAyBR,MAAMQ,uBAAuB,GAClD;eAAIR,MAAMQ,uBAAuB;SAAC,GAClC,EAAE;IACR;AACF;AAEA,SAASH,sBACPI,IAAuB,EACvBC,IAAuB;IAEvB,MAAMC,sBAAsB,IAAIC,IAC9BH,KAAKH,sBAAsB,CAACO,GAAG,CAAC,CAACC;QAC/B,MAAMC,aACJ,OAAOD,KAAKE,OAAO,KAAK,WACpBC,KAAKC,SAAS,CAACJ,KAAKE,OAAO,IAC3BF,KAAKE,OAAO,IAAI;QACtB,OAAO,GAAGF,KAAKK,GAAG,CAAC,CAAC,EAAEJ,YAAY;IACpC;IAEF,MAAMK,uBAAuB,IAAIR,IAAIH,KAAKD,uBAAuB;IACjE,OAAO;QACLF,wBAAwBI,KAAKJ,sBAAsB,CAACe,MAAM,CAAC,CAACP;YAC1D,MAAMC,aACJ,OAAOD,KAAKE,OAAO,KAAK,WACpBC,KAAKC,SAAS,CAACJ,KAAKE,OAAO,IAC3BF,KAAKE,OAAO,IAAI;YACtB,OAAO,CAACL,oBAAoBW,GAAG,CAAC,GAAGR,KAAKK,GAAG,CAAC,CAAC,EAAEJ,YAAY;QAC7D;QACAR,oBAAoBgB,OAAOC,WAAW,CACpCD,OAAOE,OAAO,CAACf,KAAKH,kBAAkB,EAAEc,MAAM,CAC5C,CAAC,CAACK,IAAI,GAAK,CAAEA,CAAAA,OAAOjB,KAAKF,kBAAkB,AAAD;QAG9CC,yBAAyBE,KAAKF,uBAAuB,CAACa,MAAM,CAC1D,CAACM,UAAY,CAACP,qBAAqBE,GAAG,CAACK;IAE3C;AACF;AAEA,eAAeC,eACbC,eAGE,EACFC,gBAA8C,EAC9CC,SAAqB;IAErB,IAAIF,gBAAgBG,MAAM,KAAK,GAAG;QAChC;IACF;IAEA,MAAMC,WAAWC,IAAAA,0BAAgB;IACjC,MAAMC,WAA4B,EAAE;IAEpC,6CAA6C;IAC7C,MAAMC,gBAAgB,IAAIC;IAO1B,KAAK,MAAMvB,QAAQe,gBAAiB;QAClC,MAAMb,UAAUF,KAAKE,OAAO;QAC5B,4CAA4C;QAC5C,IAAIsB,cAAcC;QAClB,KAAK,MAAM,CAACb,IAAI,IAAIU,cAAe;YACjC,IACE,OAAOV,QAAQ,YACf,OAAOV,YAAY,YACnBU,QAAQV,SACR;gBACAsB,cAAcZ;gBACd;YACF;YACA,IACE,OAAOA,QAAQ,YACf,OAAOV,YAAY,YACnBC,KAAKC,SAAS,CAACQ,SAAST,KAAKC,SAAS,CAACF,UACvC;gBACAsB,cAAcZ;gBACd;YACF;YACA,IAAIA,QAAQV,SAAS;gBACnBsB,cAAcZ;gBACd;YACF;QACF;QAEA,MAAMX,aAAauB,eAAetB;QAClC,IAAI,CAACoB,cAAcd,GAAG,CAACP,aAAa;YAClCqB,cAAcI,GAAG,CAACzB,YAAY,EAAE;QAClC;QACAqB,cAAcK,GAAG,CAAC1B,YAAa2B,IAAI,CAAC5B,KAAKK,GAAG;IAC9C;IAEA,6BAA6B;IAC7B,KAAK,MAAM,CAACH,SAAS2B,eAAe,IAAIP,cAAe;QACrD,wDAAwD;QACxD,IAAIQ;QAEJ,IAAI5B,SAAS;YACX,IAAI6B;YAIJ,IAAI,OAAO7B,YAAY,UAAU;gBAC/B,sDAAsD;gBACtD6B,YAAY7B;YACd,OAAO,IAAI,OAAOA,YAAY,UAAU;oBAE1Be;gBADZ,mDAAmD;gBACnDc,YAAYd,8BAAAA,+BAAAA,UAAWe,iBAAiB,qBAA5Bf,4BAA8B,CAACf,QAAQ;gBAEnD,IAAI,CAAC6B,WAAW;oBACd,MAAM,qBAEL,CAFK,IAAIE,MACR,CAAC,0BAA0B,EAAE/B,QAAQ,+DAA+D,CAAC,GADjG,qBAAA;+BAAA;oCAAA;sCAAA;oBAEN;gBACF;YACF;YAEA,IAAI6B,WAAW;gBACbD,YAAY;oBACVI,QAAQH,UAAUG,MAAM;gBAC1B;YACF;QACF;QACA,qEAAqE;QACrE,+DAA+D;QAE/D,KAAK,MAAMC,WAAWhB,YAAY,EAAE,CAAE;YACpC,IAAIjB,SAAS;gBACXmB,SAASO,IAAI,CAACO,QAAQC,UAAU,oBAAlBD,QAAQC,UAAU,MAAlBD,SAAqBN,gBAAgBC;YACrD,OAAO;gBACLT,SAASO,IAAI,CAACO,QAAQC,UAAU,oBAAlBD,QAAQC,UAAU,MAAlBD,SAAqBN;YACrC;QACF;QAEA,IAAIb,kBAAkB;YACpBK,SAASO,IAAI,CAACZ,iBAAiBqB,aAAa,CAACR,gBAAgBC;QAC/D;IACF;IAEA,MAAMQ,QAAQC,GAAG,CAAClB;AACpB;AAEO,eAAerC,mBACpBiC,SAAoB,EACpBuB,KAAyB;IAEzB,MAAMhD,yBACJgD,CAAAA,yBAAAA,MAAOhD,sBAAsB,KAAIyB,UAAUzB,sBAAsB,IAAI,EAAE;IAEzE,MAAMC,qBACJ+C,CAAAA,yBAAAA,MAAO/C,kBAAkB,KAAIwB,UAAUxB,kBAAkB,IAAI,CAAC;IAEhE,MAAMC,0BACJ8C,CAAAA,yBAAAA,MAAO9C,uBAAuB,KAAIuB,UAAUvB,uBAAuB,IAAI,EAAE;IAE3E,OAAO4C,QAAQC,GAAG,CAAC;QACjBzB,eACEtB,wBACAyB,UAAUD,gBAAgB,EAC1BC;WAECR,OAAOgC,MAAM,CAAChD;WACdC;KACJ;AACH","ignoreList":[0]} |