fixed the Railway deployment failing

Author: emdevelopa

backend/src/lib/env-validation.js

@@ -4,7 +4,6 @@ function validateEnvironmentVariables() {
     'SUPABASE_SERVICE_ROLE_KEY',
     'STELLAR_NETWORK',
     'DATABASE_URL',
-    'REDIS_URL',
   ];
 
   const missing = required.filter(key => !process.env[key]);
@@ -52,8 +51,12 @@ function validateEnvironmentVariables() {
   }
 
   if (!process.env.RESEND_API_KEY) {
-  console.warn("⚠️  RESEND_API_KEY is not set — receipt emails will be disabled.");
-}
+    console.warn("⚠️  RESEND_API_KEY is not set — receipt emails will be disabled.");
+  }
+
+  if (!process.env.REDIS_URL) {
+    console.warn("⚠️  REDIS_URL is not set — running without Redis (fallback mode).");
+  }
 
   console.log('✅ Environment variables validated');
 }

backend/src/lib/redis.js

@@ -1,15 +1,35 @@
 import { createClient } from "redis";
 
 let redisClient;
+let redisErrorCount = 0;
+
+function getRedisConnectTimeoutMs(env = process.env) {
+  const raw = Number.parseInt(String(env.REDIS_CONNECT_TIMEOUT_MS || "4000"), 10);
+  if (!Number.isFinite(raw) || raw <= 0) return 4000;
+  return raw;
+}
 
 export function getRedisClient({
   redisUrl = process.env.REDIS_URL,
   clientFactory = createClient,
 } = {}) {
   if (!redisClient) {
-    redisClient = clientFactory({ url: redisUrl });
+    redisClient = clientFactory({
+      url: redisUrl,
+      socket: {
+        connectTimeout: getRedisConnectTimeoutMs(),
+        // Prevent endless reconnect loops when Redis URL is invalid/unreachable.
+        reconnectStrategy: () => false,
+      },
+    });
     redisClient.on("error", (err) => {
-      console.error("Redis client error:", err.message);
+      redisErrorCount += 1;
+      const suffix = err?.message ? ` ${err.message}` : "";
+      if (redisErrorCount <= 3) {
+        console.error("Redis client error:" + suffix);
+      } else if (redisErrorCount === 4) {
+        console.error("Redis client error: suppressing repeated logs");
+      }
     });
   }
   return redisClient;
@@ -18,7 +38,18 @@ export function getRedisClient({
 export async function connectRedisClient(options) {
   const client = getRedisClient(options);
   if (!client.isOpen) {
-    await client.connect();
+    const timeoutMs = getRedisConnectTimeoutMs();
+    const timeout = new Promise((_, reject) => {
+      setTimeout(() => reject(new Error(`Redis connection timed out after ${timeoutMs}ms`)), timeoutMs);
+    });
+    try {
+      await Promise.race([client.connect(), timeout]);
+    } catch (err) {
+      try {
+        client.disconnect();
+      } catch {}
+      throw err;
+    }
   }
   return client;
 }
@@ -91,4 +122,4 @@ export async function invalidatePaymentCache(client, id) {
   } catch (err) {
     console.error("Redis DEL error:", err.message);
   }
-}
+}

backend/src/server.js

@@ -17,11 +17,15 @@ const port = process.env.PORT || 4000;
 
 async function startServer() {
   let redisClient = null;
-  try {
-    redisClient = await connectRedisClient();
-    logger.info("redis connected");
-  } catch (err) {
-    logger.warn({ err }, "redis unavailable, continuing with in-memory fallbacks");
+  if (process.env.REDIS_URL) {
+    try {
+      redisClient = await connectRedisClient();
+      logger.info("redis connected");
+    } catch (err) {
+      logger.warn({ err }, "redis unavailable, continuing with in-memory fallbacks");
+    }
+  } else {
+    logger.warn("redis disabled (REDIS_URL not set), using in-memory fallbacks");
   }
 
   const { app, io } = await createApp({ redisClient });