frishi/threetwo-core-service
1
0
Fork 0
Code Issues 2 Pull Requests 2 Actions Packages Projects Releases Wiki Activity

🔧 Fixes

Browse Source
This commit is contained in:
Rishi Ghan
2024-05-15 21:27:38 -05:00
parent 66f9d63b44
commit 03f6623ed0
3 changed files with 111 additions and 68 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
config/redis.config.ts
View File

@@ -1,24 +1,11 @@
import { createClient } from "redis";
console.log(`REDIS_URI: ${process.env.REDIS_URI}`);
const redisURL = process.env.REDIS_URI;
if (!redisURL) throw new Error("REDIS_URI environment variable is not set.");
const createRedisClient = (url) => {
const client = createClient(url);
client.on("error", (err) => console.error("Redis Client Error", err));
client.on("connect", () => console.log("Connected to Redis:", url));
client.on("reconnecting", () => console.log("Reconnecting to Redis..."));
client.connect().catch((err) => console.error("Failed to connect to Redis:", err));
return client;
};
const pubClient = createRedisClient(redisURL);
const pubClient = createClient({
url: process.env.REDIS_URI || 'redis://localhost:6379'
});
(async () => {
await pubClient.connect();
})();
const subClient = pubClient.duplicate();
subClient.on("error", (err) => console.error("Redis Subscriber Client Error", err));
subClient.connect().catch((err) => console.error("Failed to connect Redis Subscriber:", err));
export { subClient, pubClient };