fix(cache): respect AniList media list recache windows

1 files changed, 48 insertions, 0 deletions

diff --git a/src/lib/Data/AniList/cacheHydration.ts b/src/lib/Data/AniList/cacheHydration.ts
new file mode 100644
index 00000000..434d2a82
--- /dev/null
+++ b/src/lib/Data/AniList/cacheHydration.ts
@@ -0,0 +1,48 @@
+import { browser } from "$app/environment";
+import anime from "$stores/anime";
+import lastPruneTimes from "$stores/lastPruneTimes";
+import manga from "$stores/manga";
+import localforage from "localforage";
+
+type MediaCacheKind = "anime" | "manga";
+
+interface StoredLastPruneTimes {
+	anime: number;
+	chapters: number;
+	manga: number;
+}
+
+const hydration = new Map<MediaCacheKind, Promise<void>>();
+
+const isStoredLastPruneTimes = (
+	value: unknown,
+): value is StoredLastPruneTimes =>
+	typeof value === "object" &&
+	value !== null &&
+	typeof (value as StoredLastPruneTimes).anime === "number" &&
+	typeof (value as StoredLastPruneTimes).chapters === "number" &&
+	typeof (value as StoredLastPruneTimes).manga === "number";
+
+export const hydrateMediaListCache = (kind: MediaCacheKind) => {
+	if (!browser) return Promise.resolve();
+
+	const existing = hydration.get(kind);
+
+	if (existing) return existing;
+
+	const promise = (async () => {
+		const [cache, pruneTimes] = await Promise.all([
+			localforage.getItem<string>(kind),
+			localforage.getItem<StoredLastPruneTimes>("lastPruneTimes"),
+		]);
+
+		if (typeof cache === "string" && cache.length)
+			(kind === "anime" ? anime : manga).set(cache);
+
+		if (isStoredLastPruneTimes(pruneTimes)) lastPruneTimes.set(pruneTimes);
+	})();
+
+	hydration.set(kind, promise);
+
+	return promise;
+};