Julien Froidefond
e6fe5ac27f
All checks were successful
Deploy with Docker Compose / deploy (push) Successful in 1m36s
645 lines
24 KiB
JavaScript
645 lines
24 KiB
JavaScript
// StripStream Service Worker - Version 2
|
|
// Architecture: static + image caching, resilient offline navigation fallback
|
|
|
|
const VERSION = "v2.16";
|
|
const STATIC_CACHE = `stripstream-static-${VERSION}`;
|
|
const PAGES_CACHE = `stripstream-pages-${VERSION}`; // Navigation documents + RSC payloads
|
|
const API_CACHE = `stripstream-api-${VERSION}`;
|
|
const IMAGES_CACHE = `stripstream-images-${VERSION}`;
|
|
const BOOKS_CACHE = "stripstream-books"; // Never version this - managed by DownloadManager
|
|
|
|
const OFFLINE_PAGE = "/offline.html";
|
|
const OPTIONAL_PRECACHE_ASSETS = ["/manifest.json"];
|
|
|
|
// Cache size limits
|
|
const IMAGES_CACHE_MAX_ENTRIES = 500;
|
|
|
|
// ============================================================================
|
|
// Utility Functions - Request Detection
|
|
// ============================================================================
|
|
|
|
function isNextStaticResource(url) {
|
|
return url.includes("/_next/static/");
|
|
}
|
|
|
|
function isNextRSCRequest(request) {
|
|
const url = new URL(request.url);
|
|
return url.searchParams.has("_rsc") || request.headers.get("RSC") === "1";
|
|
}
|
|
|
|
function isImageRequest(url) {
|
|
return url.includes("/api/komga/images/");
|
|
}
|
|
|
|
function isBookPageRequest(url) {
|
|
// Book pages: /api/komga/images/books/{id}/pages/{num} or /api/komga/books/{id}/pages/{num}
|
|
// These are handled by manual download (DownloadManager) - don't cache via SWR
|
|
return (
|
|
(url.includes("/api/komga/images/books/") || url.includes("/api/komga/books/")) &&
|
|
url.includes("/pages/")
|
|
);
|
|
}
|
|
|
|
function shouldCacheResponse(response, options = {}) {
|
|
if (!response || !response.ok) return false;
|
|
|
|
if (options.allowPrivateNoStore) {
|
|
return true;
|
|
}
|
|
|
|
const cacheControl = response.headers.get("Cache-Control") || "";
|
|
return !/no-store|private/i.test(cacheControl);
|
|
}
|
|
|
|
async function getOfflineFallbackResponse() {
|
|
// Prefer dedicated offline page to avoid route mismatches
|
|
const staticCache = await caches.open(STATIC_CACHE);
|
|
const offlinePage = await staticCache.match(OFFLINE_PAGE);
|
|
if (offlinePage) {
|
|
return offlinePage;
|
|
}
|
|
|
|
// If offline page is unavailable, fallback to root app shell
|
|
const pagesCache = await caches.open(PAGES_CACHE);
|
|
const rootPage = await pagesCache.match("/");
|
|
if (rootPage && isHtmlResponse(rootPage)) {
|
|
return rootPage;
|
|
}
|
|
|
|
// Fallback to any cached HTML app shell page before static offline page
|
|
const keys = await pagesCache.keys();
|
|
const pageKey = [...keys].reverse().find((request) => {
|
|
const key = getVisitablePageKey(request.url);
|
|
return key !== null;
|
|
});
|
|
|
|
if (pageKey) {
|
|
const appShellPage = await pagesCache.match(pageKey);
|
|
if (appShellPage && isHtmlResponse(appShellPage)) {
|
|
return appShellPage;
|
|
}
|
|
}
|
|
|
|
return createInlineOfflineResponse();
|
|
}
|
|
|
|
function getVisitablePageKey(rawUrl) {
|
|
try {
|
|
const url = new URL(rawUrl);
|
|
|
|
if (url.origin !== self.location.origin) {
|
|
return null;
|
|
}
|
|
|
|
if (url.pathname.startsWith("/api/") || url.pathname.startsWith("/_next/")) {
|
|
return null;
|
|
}
|
|
|
|
url.searchParams.delete("_rsc");
|
|
url.searchParams.delete("__sw_rsc");
|
|
const search = url.searchParams.toString();
|
|
return `${url.pathname}${search ? `?${search}` : ""}`;
|
|
} catch {
|
|
return null;
|
|
}
|
|
}
|
|
|
|
function isHtmlResponse(response) {
|
|
if (!response) return false;
|
|
const contentType = response.headers.get("content-type") || "";
|
|
return contentType.includes("text/html");
|
|
}
|
|
|
|
function createInlineOfflineResponse() {
|
|
return new Response(
|
|
`<!doctype html><html lang="fr"><head><meta charset="UTF-8" /><meta name="viewport" content="width=device-width, initial-scale=1.0" /><title>Hors ligne - StripStream</title><style>:root{--bg:#060b16;--panel:rgba(15,23,42,.72);--panel-strong:rgba(15,23,42,.9);--line:rgba(99,102,241,.28);--text:#e2e8f0;--muted:#94a3b8;--primary:#4f46e5;--primary-2:#06b6d4}*{box-sizing:border-box}body{margin:0;padding:0;font-family:"Segoe UI","SF Pro Text",-apple-system,BlinkMacSystemFont,sans-serif;background:radial-gradient(78% 45% at 0% 0%,rgba(79,70,229,.28),transparent 60%),radial-gradient(52% 35% at 100% 8%,rgba(6,182,212,.22),transparent 65%),radial-gradient(40% 26% at 54% 100%,rgba(236,72,153,.17),transparent 72%),var(--bg);color:var(--text);min-height:100vh}.header{position:sticky;top:0;z-index:20;height:64px;border-bottom:1px solid var(--line);background:rgba(6,11,22,.75);backdrop-filter:blur(10px)}.header-inner{height:100%;display:flex;align-items:center;justify-content:space-between;gap:1rem;padding:0 1rem}.brand{display:flex;align-items:center;gap:.75rem}.menu-btn{width:2.25rem;height:2.25rem;border-radius:999px;border:1px solid rgba(148,163,184,.35);background:rgba(15,23,42,.6);color:var(--text);font-size:1rem}.brand-title{font-size:1.05rem;font-weight:800;letter-spacing:.12em;text-transform:uppercase;background:linear-gradient(90deg,var(--primary),var(--primary-2),#d946ef);-webkit-background-clip:text;background-clip:text;color:transparent}.brand-subtitle{font-size:.6rem;text-transform:uppercase;letter-spacing:.25em;color:rgba(226,232,240,.75);margin-top:.2rem}.pill{display:inline-flex;align-items:center;border-radius:999px;border:1px solid rgba(148,163,184,.35);background:rgba(15,23,42,.62);color:var(--muted);padding:.45rem .7rem;font-size:.78rem}.layout{display:grid;grid-template-columns:280px minmax(0,1fr);min-height:calc(100vh - 64px)}.sidebar{border-right:1px solid var(--line);background:var(--panel);backdrop-filter:blur(10px);padding:1rem}.section{border:1px solid rgba(148,163,184,.25);background:rgba(15,23,42,.4);border-radius:.9rem;padding:.7rem;margin-bottom:.8rem}.section h2{margin:.25rem .45rem .6rem;font-size:.67rem;letter-spacing:.2em;text-transform:uppercase;color:rgba(148,163,184,.95)}.nav-link{appearance:none;width:100%;border:1px solid transparent;border-radius:.65rem;background:transparent;color:var(--text);text-align:left;padding:.62rem .78rem;margin:.14rem 0;font-size:.93rem}.nav-link.active{border-color:rgba(79,70,229,.45);background:rgba(79,70,229,.16)}.main{display:flex;align-items:center;justify-content:center;padding:1.5rem}.card{width:min(720px,100%);border:1px solid rgba(148,163,184,.3);border-radius:1.2rem;background:var(--panel-strong);box-shadow:0 25px 60px -35px rgba(2,6,23,.92);padding:1.5rem}.status{display:inline-flex;align-items:center;gap:.45rem;color:#fecaca;background:rgba(127,29,29,.3);border:1px solid rgba(248,113,113,.35);border-radius:999px;padding:.35rem .7rem;font-size:.82rem;margin-bottom:1rem}h1{margin:0 0 .7rem;font-size:clamp(1.35rem,2.4vw,1.95rem);line-height:1.24}p{margin:0;color:var(--muted);line-height:1.6}.actions{display:flex;gap:.7rem;margin-top:1.35rem}.btn{appearance:none;border:1px solid transparent;border-radius:.65rem;padding:.7rem 1rem;font-size:.9rem;cursor:pointer}.btn-primary{background:var(--primary);color:#fff}.btn-secondary{background:rgba(15,23,42,.45);border-color:rgba(148,163,184,.35);color:var(--text)}.hint{margin-top:1rem;font-size:.82rem;color:rgba(148,163,184,.95)}@media (max-width:900px){.layout{grid-template-columns:1fr}.sidebar{display:none}.main{min-height:calc(100vh - 64px);padding:1rem}.actions{flex-direction:column}}</style></head><body><header class="header"><div class="header-inner"><div class="brand"><button class="menu-btn" type="button" aria-label="Menu">☰</button><div><div class="brand-title">STRIPSTREAM</div><div class="brand-subtitle">comic reader</div></div></div><span class="pill">Mode hors ligne</span></div></header><div class="layout"><aside class="sidebar"><div class="section"><h2>Navigation</h2><button class="nav-link active" type="button">Accueil</button><button class="nav-link" type="button">Telechargements</button></div><div class="section"><h2>Compte</h2><button class="nav-link" type="button">Mon compte</button><button class="nav-link" type="button">Preferences</button></div></aside><main class="main"><div class="card"><div class="status">● Hors ligne</div><h1>Cette page n'est pas encore disponible hors ligne.</h1><p>Tu peux continuer a naviguer sur les pages deja consultees. Cette route sera disponible hors ligne apres une visite en ligne.</p><div class="actions"><button class="btn btn-secondary" onclick="window.history.back()">Retour</button><button class="btn btn-primary" onclick="window.location.reload()">Reessayer</button></div><div class="hint">Astuce: visite d'abord Accueil, Bibliotheques, Series et pages de lecture quand tu es en ligne.</div></div></main></div><script>window.addEventListener("online",()=>{window.location.reload()})</script></body></html>`,
|
|
{
|
|
headers: {
|
|
"Content-Type": "text/html; charset=utf-8",
|
|
"Cache-Control": "no-store",
|
|
},
|
|
}
|
|
);
|
|
}
|
|
|
|
function countVisitablePages(requests) {
|
|
const uniquePages = new Set();
|
|
|
|
requests.forEach((request) => {
|
|
const key = getVisitablePageKey(request.url);
|
|
if (key) {
|
|
uniquePages.add(key);
|
|
}
|
|
});
|
|
|
|
return uniquePages.size;
|
|
}
|
|
|
|
// ============================================================================
|
|
// Client Communication
|
|
// ============================================================================
|
|
|
|
async function notifyClients(message) {
|
|
const clients = await self.clients.matchAll({ type: "window" });
|
|
clients.forEach((client) => {
|
|
client.postMessage(message);
|
|
});
|
|
}
|
|
|
|
// ============================================================================
|
|
// Cache Management
|
|
// ============================================================================
|
|
|
|
async function getCacheSize(cacheName) {
|
|
const cache = await caches.open(cacheName);
|
|
const keys = await cache.keys();
|
|
let totalSize = 0;
|
|
|
|
for (const request of keys) {
|
|
const response = await cache.match(request);
|
|
if (response) {
|
|
const blob = await response.clone().blob();
|
|
totalSize += blob.size;
|
|
}
|
|
}
|
|
|
|
return totalSize;
|
|
}
|
|
|
|
async function trimCache(cacheName, maxEntries) {
|
|
const cache = await caches.open(cacheName);
|
|
const keys = await cache.keys();
|
|
|
|
if (keys.length > maxEntries) {
|
|
// Remove oldest entries (FIFO)
|
|
const toDelete = keys.slice(0, keys.length - maxEntries);
|
|
await Promise.all(toDelete.map((key) => cache.delete(key)));
|
|
// eslint-disable-next-line no-console
|
|
console.log(`[SW] Trimmed ${toDelete.length} entries from ${cacheName}`);
|
|
}
|
|
}
|
|
|
|
// ============================================================================
|
|
// Cache Strategies
|
|
// ============================================================================
|
|
|
|
/**
|
|
* Cache-First: Serve from cache, fallback to network
|
|
* Used for: Next.js static resources (immutable)
|
|
*/
|
|
async function cacheFirstStrategy(request, cacheName, options = {}) {
|
|
const cache = await caches.open(cacheName);
|
|
const cached = await cache.match(request, options);
|
|
|
|
if (cached) {
|
|
return cached;
|
|
}
|
|
|
|
try {
|
|
const response = await fetch(request);
|
|
if (shouldCacheResponse(response, options)) {
|
|
cache.put(request, response.clone());
|
|
}
|
|
return response;
|
|
} catch (error) {
|
|
// Network failed - try cache without ignoreSearch as fallback
|
|
if (options.ignoreSearch) {
|
|
const fallback = await cache.match(request, { ignoreSearch: false });
|
|
if (fallback) return fallback;
|
|
}
|
|
throw error;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Stale-While-Revalidate: Serve from cache immediately, update in background
|
|
* Used for: RSC payloads, images
|
|
* Respects Cache-Control: no-cache to force network-first (for refresh buttons)
|
|
*/
|
|
async function staleWhileRevalidateStrategy(request, cacheName, options = {}) {
|
|
const cache = await caches.open(cacheName);
|
|
const cacheKey = options.cacheKey ? options.cacheKey(request) : request;
|
|
|
|
// Check if client requested no-cache (refresh button, router.refresh(), etc.)
|
|
// 1. Check Cache-Control header
|
|
const cacheControl = request.headers.get("Cache-Control");
|
|
const noCacheHeader =
|
|
cacheControl && (cacheControl.includes("no-cache") || cacheControl.includes("no-store"));
|
|
// 2. Check request.cache mode (used by Next.js router.refresh())
|
|
const noCacheMode =
|
|
request.cache === "no-cache" || request.cache === "no-store" || request.cache === "reload";
|
|
const noCache = noCacheHeader || noCacheMode;
|
|
|
|
// If no-cache, skip cached response and go network-first
|
|
const cached = noCache ? null : await cache.match(cacheKey);
|
|
|
|
// Start network request (don't await)
|
|
const fetchPromise = fetch(request)
|
|
.then(async (response) => {
|
|
if (shouldCacheResponse(response, options)) {
|
|
// Clone response for cache
|
|
const responseToCache = response.clone();
|
|
|
|
// Check if content changed (for notification)
|
|
if (cached && options.notifyOnChange) {
|
|
try {
|
|
const cachedResponse = await cache.match(cacheKey);
|
|
if (cachedResponse) {
|
|
// For JSON APIs, compare content
|
|
if (options.isJson) {
|
|
const oldText = await cachedResponse.text();
|
|
const newText = await response.clone().text();
|
|
if (oldText !== newText) {
|
|
notifyClients({
|
|
type: "CACHE_UPDATED",
|
|
url: request.url,
|
|
timestamp: Date.now(),
|
|
});
|
|
}
|
|
}
|
|
}
|
|
} catch {
|
|
// Ignore comparison errors
|
|
}
|
|
}
|
|
|
|
// Update cache
|
|
await cache.put(cacheKey, responseToCache);
|
|
|
|
// Trim cache if needed (for images)
|
|
if (options.maxEntries) {
|
|
trimCache(cacheName, options.maxEntries);
|
|
}
|
|
}
|
|
return response;
|
|
})
|
|
.catch((error) => {
|
|
// eslint-disable-next-line no-console
|
|
console.log("[SW] Network request failed:", request.url, error.message);
|
|
return null;
|
|
});
|
|
|
|
// Return cached version immediately if available
|
|
if (cached) {
|
|
return cached;
|
|
}
|
|
|
|
// Otherwise wait for network
|
|
const response = await fetchPromise;
|
|
if (response) {
|
|
return response;
|
|
}
|
|
|
|
if (options.fallbackToOffline) {
|
|
// For RSC/data requests, return an HTML fallback to avoid hard failures offline
|
|
const fallbackResponse = await getOfflineFallbackResponse();
|
|
if (fallbackResponse) {
|
|
return fallbackResponse;
|
|
}
|
|
}
|
|
|
|
throw new Error("Network failed and no cache available");
|
|
}
|
|
|
|
/**
|
|
* Navigation Network-First: prefer fresh content from network
|
|
* Falls back to cached page, then offline fallback when network fails
|
|
* Used for: Page navigations
|
|
*/
|
|
async function navigationNetworkFirstStrategy(request, cacheName) {
|
|
const cache = await caches.open(cacheName);
|
|
|
|
try {
|
|
const networkResponse = await fetch(request);
|
|
if (shouldCacheResponse(networkResponse, { allowPrivateNoStore: true })) {
|
|
await cache.put(request, networkResponse.clone());
|
|
}
|
|
return networkResponse;
|
|
} catch {
|
|
const cached = await cache.match(request);
|
|
if (cached && isHtmlResponse(cached)) {
|
|
return cached;
|
|
}
|
|
|
|
const fallbackResponse = await getOfflineFallbackResponse();
|
|
if (fallbackResponse) {
|
|
return fallbackResponse;
|
|
}
|
|
|
|
throw new Error("Offline and no cached page available");
|
|
}
|
|
}
|
|
|
|
// ============================================================================
|
|
// Service Worker Lifecycle
|
|
// ============================================================================
|
|
|
|
self.addEventListener("install", (event) => {
|
|
// eslint-disable-next-line no-console
|
|
console.log("[SW] Installing version", VERSION);
|
|
|
|
event.waitUntil(
|
|
(async () => {
|
|
const cache = await caches.open(STATIC_CACHE);
|
|
try {
|
|
await cache.add(OFFLINE_PAGE);
|
|
await Promise.allSettled(OPTIONAL_PRECACHE_ASSETS.map((asset) => cache.add(asset)));
|
|
// eslint-disable-next-line no-console
|
|
console.log("[SW] Precached assets");
|
|
} catch (error) {
|
|
console.error("[SW] Precache failed:", error);
|
|
}
|
|
await self.skipWaiting();
|
|
})()
|
|
);
|
|
});
|
|
|
|
self.addEventListener("activate", (event) => {
|
|
// eslint-disable-next-line no-console
|
|
console.log("[SW] Activating version", VERSION);
|
|
|
|
event.waitUntil(
|
|
(async () => {
|
|
// Clean up old caches, but preserve BOOKS_CACHE
|
|
const cacheNames = await caches.keys();
|
|
const currentCaches = [STATIC_CACHE, PAGES_CACHE, API_CACHE, IMAGES_CACHE, BOOKS_CACHE];
|
|
|
|
const cachesToDelete = cacheNames.filter(
|
|
(name) => name.startsWith("stripstream-") && !currentCaches.includes(name)
|
|
);
|
|
|
|
await Promise.all(cachesToDelete.map((name) => caches.delete(name)));
|
|
|
|
if (cachesToDelete.length > 0) {
|
|
// eslint-disable-next-line no-console
|
|
console.log("[SW] Deleted old caches:", cachesToDelete);
|
|
}
|
|
|
|
await self.clients.claim();
|
|
// eslint-disable-next-line no-console
|
|
console.log("[SW] Activated and claimed clients");
|
|
|
|
// Notify clients that SW is ready
|
|
notifyClients({ type: "SW_ACTIVATED", version: VERSION });
|
|
})()
|
|
);
|
|
});
|
|
|
|
// ============================================================================
|
|
// Message Handler - Client Communication
|
|
// ============================================================================
|
|
|
|
self.addEventListener("message", async (event) => {
|
|
const { type, payload } = event.data || {};
|
|
|
|
switch (type) {
|
|
case "GET_CACHE_STATS": {
|
|
try {
|
|
const [staticSize, pagesSize, apiSize, imagesSize, booksSize] = await Promise.all([
|
|
getCacheSize(STATIC_CACHE),
|
|
getCacheSize(PAGES_CACHE),
|
|
getCacheSize(API_CACHE),
|
|
getCacheSize(IMAGES_CACHE),
|
|
getCacheSize(BOOKS_CACHE),
|
|
]);
|
|
|
|
const staticCache = await caches.open(STATIC_CACHE);
|
|
const pagesCache = await caches.open(PAGES_CACHE);
|
|
const apiCache = await caches.open(API_CACHE);
|
|
const imagesCache = await caches.open(IMAGES_CACHE);
|
|
const booksCache = await caches.open(BOOKS_CACHE);
|
|
|
|
const [staticKeys, pagesKeys, apiKeys, imagesKeys, booksKeys] = await Promise.all([
|
|
staticCache.keys(),
|
|
pagesCache.keys(),
|
|
apiCache.keys(),
|
|
imagesCache.keys(),
|
|
booksCache.keys(),
|
|
]);
|
|
|
|
const visitablePages = countVisitablePages(pagesKeys);
|
|
|
|
event.source.postMessage({
|
|
type: "CACHE_STATS",
|
|
payload: {
|
|
static: { size: staticSize, entries: staticKeys.length },
|
|
pages: { size: pagesSize, entries: pagesKeys.length },
|
|
api: { size: apiSize, entries: apiKeys.length },
|
|
images: { size: imagesSize, entries: imagesKeys.length },
|
|
books: { size: booksSize, entries: booksKeys.length },
|
|
total: staticSize + pagesSize + apiSize + imagesSize + booksSize,
|
|
visitablePages,
|
|
},
|
|
});
|
|
} catch (error) {
|
|
event.source.postMessage({
|
|
type: "CACHE_STATS_ERROR",
|
|
payload: { error: error.message },
|
|
});
|
|
}
|
|
break;
|
|
}
|
|
|
|
case "CLEAR_CACHE": {
|
|
try {
|
|
const cacheType = payload?.cacheType || "all";
|
|
const cachesToClear = [];
|
|
|
|
if (cacheType === "all" || cacheType === "static") {
|
|
cachesToClear.push(STATIC_CACHE);
|
|
}
|
|
if (cacheType === "all" || cacheType === "pages") {
|
|
cachesToClear.push(PAGES_CACHE);
|
|
}
|
|
if (cacheType === "all" || cacheType === "api") {
|
|
cachesToClear.push(API_CACHE);
|
|
}
|
|
if (cacheType === "all" || cacheType === "images") {
|
|
cachesToClear.push(IMAGES_CACHE);
|
|
}
|
|
// Note: BOOKS_CACHE is not cleared by default, only explicitly
|
|
|
|
await Promise.all(
|
|
cachesToClear.map(async (cacheName) => {
|
|
const cache = await caches.open(cacheName);
|
|
const keys = await cache.keys();
|
|
await Promise.all(keys.map((key) => cache.delete(key)));
|
|
})
|
|
);
|
|
|
|
event.source.postMessage({
|
|
type: "CACHE_CLEARED",
|
|
payload: { caches: cachesToClear },
|
|
});
|
|
} catch (error) {
|
|
event.source.postMessage({
|
|
type: "CACHE_CLEAR_ERROR",
|
|
payload: { error: error.message },
|
|
});
|
|
}
|
|
break;
|
|
}
|
|
|
|
case "SKIP_WAITING": {
|
|
self.skipWaiting();
|
|
break;
|
|
}
|
|
|
|
case "GET_VERSION": {
|
|
event.source.postMessage({
|
|
type: "SW_VERSION",
|
|
payload: { version: VERSION },
|
|
});
|
|
break;
|
|
}
|
|
|
|
case "GET_CACHE_ENTRIES": {
|
|
try {
|
|
const cacheType = payload?.cacheType;
|
|
let cacheName;
|
|
|
|
switch (cacheType) {
|
|
case "static":
|
|
cacheName = STATIC_CACHE;
|
|
break;
|
|
case "pages":
|
|
cacheName = PAGES_CACHE;
|
|
break;
|
|
case "api":
|
|
cacheName = API_CACHE;
|
|
break;
|
|
case "images":
|
|
cacheName = IMAGES_CACHE;
|
|
break;
|
|
case "books":
|
|
cacheName = BOOKS_CACHE;
|
|
break;
|
|
default:
|
|
throw new Error("Invalid cache type");
|
|
}
|
|
|
|
const cache = await caches.open(cacheName);
|
|
const keys = await cache.keys();
|
|
|
|
const entries = await Promise.all(
|
|
keys.map(async (request) => {
|
|
const response = await cache.match(request);
|
|
let size = 0;
|
|
if (response) {
|
|
const blob = await response.clone().blob();
|
|
size = blob.size;
|
|
}
|
|
return {
|
|
url: request.url,
|
|
size,
|
|
};
|
|
})
|
|
);
|
|
|
|
// Sort by size descending
|
|
entries.sort((a, b) => b.size - a.size);
|
|
|
|
event.source.postMessage({
|
|
type: "CACHE_ENTRIES",
|
|
payload: { cacheType, entries },
|
|
});
|
|
} catch (error) {
|
|
event.source.postMessage({
|
|
type: "CACHE_ENTRIES_ERROR",
|
|
payload: { error: error.message },
|
|
});
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
});
|
|
|
|
// ============================================================================
|
|
// Fetch Handler - Request Routing
|
|
// ============================================================================
|
|
|
|
self.addEventListener("fetch", (event) => {
|
|
const { request } = event;
|
|
const { method } = request;
|
|
const url = new URL(request.url);
|
|
|
|
// Only handle GET requests
|
|
if (method !== "GET") {
|
|
return;
|
|
}
|
|
|
|
// Only handle same-origin HTTP(S) requests
|
|
if (url.origin !== self.location.origin) {
|
|
return;
|
|
}
|
|
|
|
if (url.protocol !== "http:" && url.protocol !== "https:") {
|
|
return;
|
|
}
|
|
|
|
// Route 1: Book pages (handled by DownloadManager) - Check manual cache only, no SWR
|
|
if (isBookPageRequest(url.href)) {
|
|
event.respondWith(
|
|
(async () => {
|
|
// Check the manual books cache
|
|
const booksCache = await caches.open(BOOKS_CACHE);
|
|
const cached = await booksCache.match(request);
|
|
if (cached) {
|
|
return cached;
|
|
}
|
|
|
|
// Not in cache - fetch from network without caching
|
|
// Book pages are large and should only be cached via manual download
|
|
return fetch(request);
|
|
})()
|
|
);
|
|
return;
|
|
}
|
|
|
|
// Route 2: Next.js RSC payloads → SWR in PAGES_CACHE
|
|
if (isNextRSCRequest(request)) {
|
|
event.respondWith(
|
|
staleWhileRevalidateStrategy(request, PAGES_CACHE, {
|
|
allowPrivateNoStore: true,
|
|
cacheKey: (incomingRequest) => {
|
|
const normalized = new URL(incomingRequest.url);
|
|
normalized.searchParams.delete("_rsc");
|
|
normalized.searchParams.set("__sw_rsc", "1");
|
|
return normalized.toString();
|
|
},
|
|
})
|
|
);
|
|
return;
|
|
}
|
|
|
|
// Route 3: Next.js static resources → Cache-First with ignoreSearch
|
|
if (isNextStaticResource(url.href)) {
|
|
event.respondWith(
|
|
cacheFirstStrategy(request, STATIC_CACHE, {
|
|
ignoreSearch: true,
|
|
allowPrivateNoStore: true,
|
|
})
|
|
);
|
|
return;
|
|
}
|
|
|
|
// Route 4: Image requests (thumbnails, covers) → SWR with cache size management
|
|
// Note: Book pages are excluded (Route 1) and only use manual download cache
|
|
if (isImageRequest(url.href)) {
|
|
event.respondWith(
|
|
staleWhileRevalidateStrategy(request, IMAGES_CACHE, {
|
|
maxEntries: IMAGES_CACHE_MAX_ENTRIES,
|
|
})
|
|
);
|
|
return;
|
|
}
|
|
|
|
// Route 5: Navigation → Network-First with cache/offline fallback
|
|
if (request.mode === "navigate") {
|
|
event.respondWith(navigationNetworkFirstStrategy(request, PAGES_CACHE));
|
|
return;
|
|
}
|
|
|
|
// Route 6: Everything else → Network only (no caching)
|
|
});
|