feat: add Redis as cache (#5)

.env.example

@@ -1,2 +1,3 @@
 PROXY_URL=wss://your-proxy.com
-RELAYS=wss://relay1.com,wss://relay2.com,wss://relay.com
+RELAYS=wss://relay1.com,wss://relay2.com,wss://relay.com
+REDIS=redis://user:password@localhost:6379

package.json

@@ -24,6 +24,7 @@
     "@fastify/sensible": "^5.0.0",
     "@fastify/view": "^7.4.1",
     "@fastify/websocket": "^7.1.2",
+    "@keyv/redis": "^2.5.5",
     "ejs": "^3.1.8",
     "fastify": "^4.0.0",
     "fastify-cli": "^5.7.1",

src/services/WebSocketPool.ts

@@ -1,6 +1,6 @@
 import EventEmitter from "events";
 import WebSocket from "ws";
-import { getRelays } from "./env";
+import { getRedis, getRelays } from "./env";
 import Keyv from "keyv";
 import crypto from "crypto";
 import { EventType, parseEvent } from "./Event";
@@ -20,7 +20,10 @@ class WebSocketPool extends EventEmitter {
         this.maxAttempts = maxAttempts;
         this.resetTimeout = resetTimeout;
         this.sockets = {};
-        this.cache = new Keyv();
+        const redis = getRedis()
+        console.log(redis)
+        this.cache = redis !== null ? new Keyv(redis) : new Keyv();
+
 
         this.connectAll();
     }

src/services/env.ts

@@ -1,5 +1,6 @@
 let proxyUrl = "";
 let relays: string[] = [];
+let redis: string | null = null;
 
 export function validateEnv() {
     if (!process.env.PROXY_URL) {
@@ -18,6 +19,10 @@ export function validateEnv() {
         console.error("A problem occured while parsing relays");
         process.exit(1);
     }
+
+    if (process.env.REDIS) {
+        redis = process.env.REDIS
+    }
 }
 
 export function getRelays() {
@@ -26,4 +31,8 @@ export function getRelays() {
 
 export function getProxyUrl() {
     return proxyUrl;
+}
+
+export function getRedis() {
+    return redis;
 }