CodeCow/stack
1
0
Fork 0
mirror of https://github.com/stack-auth/stack.git synced 2026-06-13 21:01:21 +08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Fix cache error for static pages

Browse Source
This commit is contained in:
Konstantin Wohlwend 2025-01-07 10:11:13 -08:00
parent 334b6a4c73
commit 02fa7f7dfa
1 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
packages/stack-shared/src/utils/caches.tsx
View File

@ -87,6 +87,7 @@ class AsyncValueCache<T> {
private readonly _rateLimitOptions: Omit<RateLimitOptions, "batchCalls">;
private _subscriptionsCount = 0;
private _unsubscribers: (() => void)[] = [];
private _mostRecentRefreshPromiseIndex = 0;
constructor(
fetcher: () => Promise<T>,
@ -180,17 +181,8 @@ class AsyncValueCache<T> {
runAsynchronously(this.getOrWait("read-write"));
if (this._subscriptionsCount++ === 0 && this._options.onSubscribe) {
let mostRecentRefreshPromiseIndex = 0;
const unsubscribe = this._options.onSubscribe(() => {
const currentRefreshPromiseIndex = mostRecentRefreshPromiseIndex++;
runAsynchronously(async () => {
// wait a few seconds; if anything changes during that time, we don't want to refresh
// else we do unnecessary requests if we unsubscribe and then subscribe again immediately
await wait(5000);
if (this._subscriptionsCount === 0 && currentRefreshPromiseIndex === mostRecentRefreshPromiseIndex) {
this.invalidate();
}
});
runAsynchronously(this.refresh());
});
this._unsubscribers.push(unsubscribe);
}
@ -202,6 +194,16 @@ class AsyncValueCache<T> {
hasUnsubscribed = true;
storeObj.unsubscribe();
if (--this._subscriptionsCount === 0) {
const currentRefreshPromiseIndex = ++this._mostRecentRefreshPromiseIndex;
runAsynchronously(async () => {
// wait a few seconds; if anything changes during that time, we don't want to refresh
// else we do unnecessary requests if we unsubscribe and then subscribe again immediately
await wait(5000);
if (this._subscriptionsCount === 0 && currentRefreshPromiseIndex === this._mostRecentRefreshPromiseIndex) {
this.invalidate();
}
});
for (const unsubscribe of this._unsubscribers) {
unsubscribe();
}