diff --git a/src/main/debrid.ts b/src/main/debrid.ts index c898230..fddbd13 100644 --- a/src/main/debrid.ts +++ b/src/main/debrid.ts @@ -302,7 +302,7 @@ function getMegaDebridAbortMinRunMs(): number { } const megaDebridEmptyResponseStreaks = new Map(); -export const MEGA_DEBRID_EMPTY_STREAK_UNTIL_RESTART = 3; +export const MEGA_DEBRID_EMPTY_STREAK_UNTIL_RESTART = 10; let megaDebridRotationCursor = 0; let megaDebridStickyCount = 0; @@ -2254,7 +2254,7 @@ class MegaDebridClient { const streak = recordMegaDebridEmptyResponseStreak(cooldownKey); if (streak >= MEGA_DEBRID_EMPTY_STREAK_UNTIL_RESTART) { parkUntilRestart = true; - parkMessage = `Tageslimit erreicht (${streak}x kein Server/leere Antwort) — bis zum Tagesreset gesperrt`; + parkMessage = `Tageslimit erreicht (${streak}x leere Antwort in Folge) — bis zum Tagesreset gesperrt`; } } else { clearMegaDebridEmptyResponseStreak(cooldownKey); diff --git a/tests/debrid.test.ts b/tests/debrid.test.ts index 6a2495d..d922cd7 100644 --- a/tests/debrid.test.ts +++ b/tests/debrid.test.ts @@ -2140,7 +2140,7 @@ describe("debrid service", () => { it("escalates a Mega-Debrid account to 'until restart' after the empty-response streak threshold", () => { const key = `${getMegaDebridAccountId("user1")}:web`; - expect(MEGA_DEBRID_EMPTY_STREAK_UNTIL_RESTART).toBe(3); + expect(MEGA_DEBRID_EMPTY_STREAK_UNTIL_RESTART).toBe(10); expect(recordMegaDebridEmptyResponseStreak(key)).toBe(1); expect(recordMegaDebridEmptyResponseStreak(key)).toBe(2); expect(recordMegaDebridEmptyResponseStreak(key)).toBe(3); @@ -2265,8 +2265,9 @@ describe("debrid service", () => { globalThis.fetch = (async () => new Response("error", { status: 500 })) as typeof fetch; const key = `${getMegaDebridAccountId("user1")}:web`; - recordMegaDebridEmptyResponseStreak(key); - recordMegaDebridEmptyResponseStreak(key); + for (let i = 0; i < MEGA_DEBRID_EMPTY_STREAK_UNTIL_RESTART - 1; i += 1) { + recordMegaDebridEmptyResponseStreak(key); + } expect(getMegaDebridAccountCooldownState(key)?.untilRestart ?? false).toBe(false); const megaWeb = vi.fn(async () => null);