introduce caching

This commit is contained in:
ld3zian 2025-02-02 14:45:38 -07:00
parent 3c76e395ab
commit 07d245e94d
2 changed files with 35 additions and 2 deletions

View file

@ -1,4 +1,5 @@
import type { Comic, Genre, ComicType } from './types'; import type { Comic, Genre, ComicType } from './types';
import { getRedisClient } from './db';
const languageMap = { const languageMap = {
"en": "English", "en": "English",
@ -256,9 +257,27 @@ export async function getChaptersForSlugs(
): Promise<ChapterDetail[]> { ): Promise<ChapterDetail[]> {
console.log(`Fetching chapters for slugs:`, slugs, `in language: ${lang}`); console.log(`Fetching chapters for slugs:`, slugs, `in language: ${lang}`);
const chapters: ChapterDetail[] = []; const chapters: ChapterDetail[] = [];
const redis = await getRedisClient();
// Cache results for 1 hour (3600 seconds)
const CACHE_TTL = 60 * 60;
for (const slug of slugs) { for (const slug of slugs) {
console.log(`Processing slug: ${slug}`); console.log(`Processing slug: ${slug}`);
const cacheKey = `chapters:${slug}:${lang}`;
try {
// Try to get cached chapters
const cachedChapters = await redis.get(cacheKey);
if (cachedChapters) {
console.log(`Using cached chapters for ${slug}`);
chapters.push(...JSON.parse(cachedChapters));
continue;
}
} catch (error) {
console.error('Redis cache read error:', error);
}
const comicDetail = await getComicBySlug(slug); const comicDetail = await getComicBySlug(slug);
if (!comicDetail) { if (!comicDetail) {
@ -284,6 +303,19 @@ export async function getChaptersForSlugs(
if (comicChapters.length > 0) { if (comicChapters.length > 0) {
chapters.push(...comicChapters); chapters.push(...comicChapters);
// Cache the results
try {
await redis.set(
cacheKey,
JSON.stringify(comicChapters),
'EX',
CACHE_TTL
);
console.log(`Cached chapters for ${slug}`);
} catch (error) {
console.error('Redis cache write error:', error);
}
} }
} }

View file

@ -5,6 +5,7 @@ const REDIS_URL = import.meta.env.REDIS_URL || process.env.REDIS_URL;
let redis: Redis | null = null; let redis: Redis | null = null;
let redisRetryCount = 0; let redisRetryCount = 0;
const MAX_RETRIES = 3; const MAX_RETRIES = 3;
const DEFAULT_CACHE_TTL = 60 * 60 * 24 * 30; // 30 days
try { try {
console.log('Environment check:', { console.log('Environment check:', {
@ -60,7 +61,7 @@ try {
} }
} }
async function getRedisClient(): Promise<Redis> { export async function getRedisClient(): Promise<Redis> {
if (redis?.status === 'ready') return redis; if (redis?.status === 'ready') return redis;
if (redisRetryCount >= MAX_RETRIES) { if (redisRetryCount >= MAX_RETRIES) {
@ -109,7 +110,7 @@ export async function storeFeedMapping(feedId: string, slugs: string[], lang: st
feedId, feedId,
JSON.stringify(mapping), JSON.stringify(mapping),
'EX', 'EX',
60 * 60 * 24 * 30 // 30 days in seconds DEFAULT_CACHE_TTL // Use the constant here
); );
} catch (error) { } catch (error) {
console.error('Error storing feed mapping:', error); console.error('Error storing feed mapping:', error);