shishantbiswas/aniwatch-api
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: add quitConnection method; update variable names, function defs & logic

Browse Source
This commit is contained in:
Ritesh Ghosh
2025-05-25 22:47:09 +05:30
parent 013196bd3d
commit 1017371432
1 changed files with 29 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/config/cache.ts
+29 -20
View File
@@ -5,15 +5,17 @@ export class AniwatchAPICache {
private static instance: AniwatchAPICache | null = null; private static instance: AniwatchAPICache | null = null;
private client: Redis | null; private client: Redis | null;
public isOptional: boolean = true; public enabled: boolean = false;
static DEFAULT_CACHE_EXPIRY_SECONDS = 60 as const; static enabled = false;
static CACHE_EXPIRY_HEADER_NAME = "X-ANIWATCH-CACHE-EXPIRY" as const; // 5 mins, 5 * 60
static DEFAULT_CACHE_EXPIRY_SECONDS = 300 as const;
static CACHE_EXPIRY_HEADER_NAME = "Aniwatch-Cache-Expiry" as const;
constructor() { constructor() {
const redisConnURL = env.ANIWATCH_API_REDIS_CONN_URL; const redisConnURL = env.ANIWATCH_API_REDIS_CONN_URL;
this.isOptional = !Boolean(redisConnURL); this.enabled = AniwatchAPICache.enabled = Boolean(redisConnURL);
this.client = this.isOptional ? null : new Redis(String(redisConnURL)); this.client = this.enabled ? new Redis(String(redisConnURL)) : null;
} }
static getInstance() { static getInstance() {
@@ -23,27 +25,17 @@ export class AniwatchAPICache {
return AniwatchAPICache.instance; return AniwatchAPICache.instance;
} }
// set(key: string | Buffer, value: string | Buffer | number) {
// if (this.isOptional) return;
// return this.client?.set(key, value);
// }
// get(key: string | Buffer) {
// if (this.isOptional) return;
// return this.client?.get(key);
// }
/** /**
* @param expirySeconds set to 60 by default * @param expirySeconds set to 300 (5 mins) by default
*/ */
async getOrSet<T>( async getOrSet<T>(
dataGetter: () => Promise<T>, dataGetter: () => Promise<T>,
key: string | Buffer, key: string,
expirySeconds: number = AniwatchAPICache.DEFAULT_CACHE_EXPIRY_SECONDS expirySeconds: number = AniwatchAPICache.DEFAULT_CACHE_EXPIRY_SECONDS
) { ) {
const cachedData = this.isOptional const cachedData = this.enabled
? null ? (await this.client?.get?.(key)) || null
: (await this.client?.get?.(key)) || null; : null;
let data = JSON.parse(String(cachedData)) as T; let data = JSON.parse(String(cachedData)) as T;
if (!data) { if (!data) {
@@ -57,6 +49,23 @@ export class AniwatchAPICache {
} }
return data; return data;
} }
closeConnection() {
this.client
?.quit()
?.then(() => {
this.client = null;
AniwatchAPICache.instance = null;
console.info(
"aniwatch-api redis connection closed and cache instance reset"
);
})
.catch((err) => {
console.error(
`aniwatch-api error while closing redis connection: ${err}`
);
});
}
} }
export const cache = AniwatchAPICache.getInstance(); export const cache = AniwatchAPICache.getInstance();