File size: 2,527 Bytes
c09f67c | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 | import { createLoggerWithContext } from "@midday/logger";
import { getSharedRedisClient } from "./shared-redis";
const logger = createLoggerWithContext("redis-cache");
export class RedisCache {
private prefix: string;
private defaultTTL: number;
constructor(prefix: string, defaultTTL: number = 30 * 60) {
this.prefix = prefix;
this.defaultTTL = defaultTTL;
}
// Get client lazily - allows picking up reconnected clients
private get redis() {
return getSharedRedisClient();
}
private parseValue<T>(value: string | null): T | undefined {
if (!value) return undefined;
try {
return JSON.parse(value) as T;
} catch {
// If parsing fails, return the raw string (for backwards compatibility)
return value as unknown as T;
}
}
private stringifyValue(value: unknown): string {
if (typeof value === "string") {
return value;
}
return JSON.stringify(value);
}
private getKey(key: string): string {
return `${this.prefix}:${key}`;
}
async get<T>(key: string): Promise<T | undefined> {
try {
const value = await this.redis.get(this.getKey(key));
return this.parseValue<T>(value);
} catch (error) {
logger.error(`Get error for ${this.prefix} cache`, {
key,
error: error instanceof Error ? error.message : String(error),
});
return undefined;
}
}
async set(key: string, value: unknown, ttlSeconds?: number): Promise<void> {
try {
const serializedValue = this.stringifyValue(value);
const redisKey = this.getKey(key);
const ttl = ttlSeconds ?? this.defaultTTL;
if (ttl > 0) {
await this.redis.send("SETEX", [
redisKey,
ttl.toString(),
serializedValue,
]);
} else {
await this.redis.set(redisKey, serializedValue);
}
} catch (error) {
logger.error(`Set error for ${this.prefix} cache`, {
key,
error: error instanceof Error ? error.message : String(error),
});
}
}
async delete(key: string): Promise<void> {
try {
await this.redis.del(this.getKey(key));
} catch (error) {
logger.error(`Delete error for ${this.prefix} cache`, {
key,
error: error instanceof Error ? error.message : String(error),
});
}
}
async healthCheck(): Promise<void> {
try {
await this.redis.send("PING", []);
} catch (error) {
throw new Error(`Redis health check failed: ${error}`);
}
}
}
|