fix: invalidate home cache when updating read progress

- Add cache tags support to BaseApiService
- Tag home data with 'home-data' tag in HomeService
- Use revalidateTag('home-data', 'max') after read progress updates
- With 'max' profile: serve stale while fetching fresh in background
This commit is contained in:
2026-02-28 10:16:12 +01:00
parent 7523ec06e1
commit ecce0a9738
3 changed files with 39 additions and 18 deletions

View File

@@ -1,11 +1,14 @@
import type { NextRequest } from "next/server"; import type { NextRequest } from "next/server";
import { NextResponse } from "next/server"; import { NextResponse } from "next/server";
import { revalidateTag } from "next/cache";
import { BookService } from "@/lib/services/book.service"; import { BookService } from "@/lib/services/book.service";
import { ERROR_CODES } from "@/constants/errorCodes"; import { ERROR_CODES } from "@/constants/errorCodes";
import { getErrorMessage } from "@/utils/errors"; import { getErrorMessage } from "@/utils/errors";
import { AppError } from "@/utils/errors"; import { AppError } from "@/utils/errors";
import logger from "@/lib/logger"; import logger from "@/lib/logger";
const HOME_CACHE_TAG = "home-data";
export async function PATCH( export async function PATCH(
request: NextRequest, request: NextRequest,
{ params }: { params: Promise<{ bookId: string }> } { params }: { params: Promise<{ bookId: string }> }
@@ -60,6 +63,9 @@ export async function PATCH(
await BookService.updateReadProgress(bookId, page, completed); await BookService.updateReadProgress(bookId, page, completed);
// Invalider le cache de la home via le tag
revalidateTag(HOME_CACHE_TAG, "max");
return NextResponse.json({ message: "📖 Progression mise à jour avec succès" }); return NextResponse.json({ message: "📖 Progression mise à jour avec succès" });
} catch (error) { } catch (error) {
logger.error({ err: error }, "Erreur lors de la mise à jour de la progression:"); logger.error({ err: error }, "Erreur lors de la mise à jour de la progression:");
@@ -97,6 +103,9 @@ export async function DELETE(
await BookService.deleteReadProgress(bookId); await BookService.deleteReadProgress(bookId);
// Invalider le cache de la home via le tag
revalidateTag(HOME_CACHE_TAG, "max");
return NextResponse.json({ message: "🗑️ Progression supprimée avec succès" }); return NextResponse.json({ message: "🗑️ Progression supprimée avec succès" });
} catch (error) { } catch (error) {
logger.error({ err: error }, "Erreur lors de la suppression de la progression:"); logger.error({ err: error }, "Erreur lors de la suppression de la progression:");

View File

@@ -10,6 +10,8 @@ interface KomgaRequestInit extends RequestInit {
noJson?: boolean; noJson?: boolean;
/** Next.js cache duration in seconds. Use false to disable cache, number for TTL */ /** Next.js cache duration in seconds. Use false to disable cache, number for TTL */
revalidate?: number | false; revalidate?: number | false;
/** Cache tags for targeted invalidation */
tags?: string[];
} }
interface KomgaUrlBuilder { interface KomgaUrlBuilder {
@@ -137,10 +139,12 @@ export abstract class BaseApiService {
connectTimeout: timeoutMs, connectTimeout: timeoutMs,
bodyTimeout: timeoutMs, bodyTimeout: timeoutMs,
headersTimeout: timeoutMs, headersTimeout: timeoutMs,
// Next.js cache // Next.js cache with tags support
next: options.revalidate !== undefined next: options.tags
? { revalidate: options.revalidate } ? { tags: options.tags }
: undefined, : options.revalidate !== undefined
? { revalidate: options.revalidate }
: undefined,
}); });
} catch (fetchError: any) { } catch (fetchError: any) {
// Gestion spécifique des erreurs DNS // Gestion spécifique des erreurs DNS
@@ -158,10 +162,12 @@ export abstract class BaseApiService {
// Force IPv4 si IPv6 pose problème // Force IPv4 si IPv6 pose problème
// @ts-ignore // @ts-ignore
family: 4, family: 4,
// Next.js cache // Next.js cache with tags support
next: options.revalidate !== undefined next: options.tags
? { revalidate: options.revalidate } ? { tags: options.tags }
: undefined, : options.revalidate !== undefined
? { revalidate: options.revalidate }
: undefined,
}); });
} else if (fetchError?.cause?.code === "UND_ERR_CONNECT_TIMEOUT") { } else if (fetchError?.cause?.code === "UND_ERR_CONNECT_TIMEOUT") {
// Retry automatique sur timeout de connexion (cold start) // Retry automatique sur timeout de connexion (cold start)
@@ -175,10 +181,12 @@ export abstract class BaseApiService {
connectTimeout: timeoutMs, connectTimeout: timeoutMs,
bodyTimeout: timeoutMs, bodyTimeout: timeoutMs,
headersTimeout: timeoutMs, headersTimeout: timeoutMs,
// Next.js cache // Next.js cache with tags support
next: options.revalidate !== undefined next: options.tags
? { revalidate: options.revalidate } ? { tags: options.tags }
: undefined, : options.revalidate !== undefined
? { revalidate: options.revalidate }
: undefined,
}); });
} else { } else {
throw fetchError; throw fetchError;

View File

@@ -7,8 +7,12 @@ import { AppError } from "../../utils/errors";
export type { HomeData }; export type { HomeData };
// Cache tag pour invalidation ciblée
const HOME_CACHE_TAG = "home-data";
export class HomeService extends BaseApiService { export class HomeService extends BaseApiService {
private static readonly CACHE_TTL = 120; // 2 minutes private static readonly CACHE_TTL = 120; // 2 minutes fallback
private static readonly CACHE_TAG = HOME_CACHE_TAG;
static async getHomeData(): Promise<HomeData> { static async getHomeData(): Promise<HomeData> {
try { try {
@@ -25,7 +29,7 @@ export class HomeService extends BaseApiService {
}, },
}, },
{}, {},
{ revalidate: this.CACHE_TTL } { revalidate: this.CACHE_TTL, tags: [this.CACHE_TAG] }
), ),
this.fetchFromApi<LibraryResponse<KomgaBook>>( this.fetchFromApi<LibraryResponse<KomgaBook>>(
{ {
@@ -39,7 +43,7 @@ export class HomeService extends BaseApiService {
}, },
}, },
{}, {},
{ revalidate: this.CACHE_TTL } { revalidate: this.CACHE_TTL, tags: [this.CACHE_TAG] }
), ),
this.fetchFromApi<LibraryResponse<KomgaBook>>( this.fetchFromApi<LibraryResponse<KomgaBook>>(
{ {
@@ -51,7 +55,7 @@ export class HomeService extends BaseApiService {
}, },
}, },
{}, {},
{ revalidate: this.CACHE_TTL } { revalidate: this.CACHE_TTL, tags: [this.CACHE_TAG] }
), ),
this.fetchFromApi<LibraryResponse<KomgaBook>>( this.fetchFromApi<LibraryResponse<KomgaBook>>(
{ {
@@ -63,7 +67,7 @@ export class HomeService extends BaseApiService {
}, },
}, },
{}, {},
{ revalidate: this.CACHE_TTL } { revalidate: this.CACHE_TTL, tags: [this.CACHE_TAG] }
), ),
this.fetchFromApi<LibraryResponse<KomgaSeries>>( this.fetchFromApi<LibraryResponse<KomgaSeries>>(
{ {
@@ -75,7 +79,7 @@ export class HomeService extends BaseApiService {
}, },
}, },
{}, {},
{ revalidate: this.CACHE_TTL } { revalidate: this.CACHE_TTL, tags: [this.CACHE_TAG] }
), ),
]); ]);