qak2019
/
cents
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: back off conversion status polling

This commit is contained in:
openclaw 2026-07-25 01:03:20 +08:00
parent add83528d2
commit ffc8fb0eee
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
apps/web/src/stores/entries.ts
View File

@ -10,12 +10,22 @@ let syncPromise: Promise<void> | null = null;
let syncTriggersStarted = false; let syncTriggersStarted = false;
let conversionPollTimer: number | null = null; let conversionPollTimer: number | null = null;
let conversionPollAttempts = 0; let conversionPollAttempts = 0;
let conversionPollDeadline = 0;
const conversionPollEntryIds = new Set<string>(); const conversionPollEntryIds = new Set<string>();
function scheduleConversionPoll(entryIds: string[], resetAttempts = true) { function scheduleConversionPoll(entryIds: string[], resetAttempts = true) {
for (const entryId of entryIds) conversionPollEntryIds.add(entryId); for (const entryId of entryIds) conversionPollEntryIds.add(entryId);
if (conversionPollTimer !== null || typeof window === "undefined") return; if (conversionPollTimer !== null || typeof window === "undefined") return;
if (resetAttempts) conversionPollAttempts = 0; if (resetAttempts) {
conversionPollAttempts = 0;
conversionPollDeadline = Date.now() + 60_000;
}
const remainingMs = conversionPollDeadline - Date.now();
if (remainingMs <= 0) {
conversionPollEntryIds.clear();
return;
}
const delayMs = Math.min(1_500 * 2 ** conversionPollAttempts, remainingMs);
const poll = async () => { const poll = async () => {
conversionPollTimer = null; conversionPollTimer = null;
const store = useEntryStore(); const store = useEntryStore();
@ -25,11 +35,11 @@ function scheduleConversionPoll(entryIds: string[], resetAttempts = true) {
store.entries.some((entry) => entry.id === entryId && entry.conversionStatus === "pending"), store.entries.some((entry) => entry.id === entryId && entry.conversionStatus === "pending"),
); );
conversionPollEntryIds.clear(); conversionPollEntryIds.clear();
if (!remaining.length || conversionPollAttempts >= 6) return; if (!remaining.length || Date.now() >= conversionPollDeadline) return;
conversionPollAttempts += 1; conversionPollAttempts += 1;
scheduleConversionPoll(remaining, false); scheduleConversionPoll(remaining, false);
}; };
conversionPollTimer = window.setTimeout(() => void poll(), 1_500); conversionPollTimer = window.setTimeout(() => void poll(), delayMs);
} }
export const useEntryStore = defineStore("entries", { export const useEntryStore = defineStore("entries", {