From d06a7a9bb689849b2b7beced2606ceb98513f4bb Mon Sep 17 00:00:00 2001
From: Fuwn <contact@fuwn.net>
Date: Wed, 15 Apr 2026 01:18:00 +0000
Subject: feat(cache): instant list revalidation from command palette and debug
 menu

Replaces one-shot boolean revalidateAnime with a counter store so
multiple components can subscribe without race conditions. Adds
revalidateManga store and reactive refresh blocks to DueAnimeList
and MangaListTemplate. Extracts shared invalidateListCaches function
used by both the command palette action and the debug settings button.
Renames palette item to "Refresh" and debug button to "Invalidate".
---
 src/lib/List/Anime/CleanAnimeList.svelte    |  2 +-
 src/lib/List/Anime/DueAnimeList.svelte      | 22 ++++++++++++++++++
 src/lib/List/Anime/UpcomingAnimeList.svelte | 36 ++++++++++++++++-------------
 3 files changed, 43 insertions(+), 17 deletions(-)

(limited to 'src/lib/List/Anime')

diff --git a/src/lib/List/Anime/CleanAnimeList.svelte b/src/lib/List/Anime/CleanAnimeList.svelte
index 808a8e5b..35a12314 100644
--- a/src/lib/List/Anime/CleanAnimeList.svelte
+++ b/src/lib/List/Anime/CleanAnimeList.svelte
@@ -193,7 +193,7 @@ onDestroy(() => clearAiringRefreshTimeout());
 
 const increment = (anime: Media, progress: number) => {
 	if (!dummy && pendingUpdate !== anime.id) {
-		$revalidateAnime = true;
+		$revalidateAnime = $revalidateAnime + 1;
 		lastUpdatedMedia = anime.id;
 		pendingUpdate = anime.id;
 
diff --git a/src/lib/List/Anime/DueAnimeList.svelte b/src/lib/List/Anime/DueAnimeList.svelte
index 2c707ffb..d2c47ebe 100644
--- a/src/lib/List/Anime/DueAnimeList.svelte
+++ b/src/lib/List/Anime/DueAnimeList.svelte
@@ -16,6 +16,7 @@ import {
 import { addNotification } from "$lib/Notification/store";
 import locale from "$stores/locale";
 import identity from "$stores/identity";
+import revalidateAnime from "$stores/revalidateAnime";
 
 export let user: AniListAuthorisation;
 let animeLists: Promise<Media[]>;
@@ -68,6 +69,27 @@ onMount(async () => {
 $: if (keyCacher && keyCacheMinutes !== $settings.cacheMinutes)
 	restartKeyCacher($settings.cacheMinutes);
 
+let lastAnimeRevalidation = 0;
+
+$: if ($revalidateAnime > lastAnimeRevalidation) {
+	lastAnimeRevalidation = $revalidateAnime;
+
+	startTime = performance.now();
+	endTime = -1;
+
+	animeLists = mediaListCollection(
+		user,
+		$identity,
+		Type.Anime,
+		$anime,
+		$lastPruneTimes.anime,
+		{
+			forcePrune: true,
+			addNotification,
+		},
+	);
+}
+
 onDestroy(() => {
 	if (keyCacher) clearInterval(keyCacher);
 });
diff --git a/src/lib/List/Anime/UpcomingAnimeList.svelte b/src/lib/List/Anime/UpcomingAnimeList.svelte
index d9b91122..ed47f22f 100644
--- a/src/lib/List/Anime/UpcomingAnimeList.svelte
+++ b/src/lib/List/Anime/UpcomingAnimeList.svelte
@@ -96,22 +96,26 @@ const cleanMedia = (
 	return upcomingAnime;
 };
 
-$: {
-	if ($revalidateAnime) {
-		$revalidateAnime = false;
-		$lastPruneTimes.anime = -1;
-		animeLists = mediaListCollection(
-			user,
-			$identity,
-			Type.Anime,
-			$anime,
-			$lastPruneTimes.anime,
-			{
-				addNotification,
-				notificationType: "Upcoming Episodes",
-			},
-		);
-	}
+let lastAnimeRevalidation = 0;
+
+$: if ($revalidateAnime > lastAnimeRevalidation) {
+	lastAnimeRevalidation = $revalidateAnime;
+
+	startTime = performance.now();
+	endTime = -1;
+
+	animeLists = mediaListCollection(
+		user,
+		$identity,
+		Type.Anime,
+		$anime,
+		$lastPruneTimes.anime,
+		{
+			forcePrune: true,
+			addNotification,
+			notificationType: "Upcoming Episodes",
+		},
+	);
 }
 </script>
 
-- 
cgit v1.2.3