fixed the Railway deployment failing

Author: emdevelopa

backend/src/app.js

@@ -35,6 +35,7 @@ import { versionDeprecationMiddleware } from "./lib/version-deprecation.js";
 
 export async function createApp({ redisClient }) {
   const app = express();
+  const redisAvailable = Boolean(redisClient && redisClient.isOpen);
 
   const __filename = fileURLToPath(import.meta.url);
   const __dirname = path.dirname(__filename);
@@ -200,17 +201,17 @@ export async function createApp({ redisClient }) {
       services: {
         database: dbOk ? "ok" : "unavailable",
         horizon: horizonOk ? "ok" : "unavailable",
-        redis: "ok",
+        redis: redisAvailable ? "ok" : "unavailable",
       },
     });
   });
 
   const verifyPaymentRateLimit = createVerifyPaymentRateLimit({
-    store: createRedisRateLimitStore({ client: redisClient }),
+    store: redisAvailable ? createRedisRateLimitStore({ client: redisClient }) : undefined,
   });
 
   const merchantRegistrationRateLimit = createMerchantRegistrationRateLimit({
-    store: createRedisRateLimitStore({ client: redisClient }),
+    store: redisAvailable ? createRedisRateLimitStore({ client: redisClient }) : undefined,
   });
 
   // x402 pay-per-request on payment creation endpoints (custom middleware flow)

backend/src/lib/create-payment-rate-limit.js

@@ -1,5 +1,5 @@
 import { createHash } from "node:crypto";
-import rateLimit from "express-rate-limit";
+import rateLimit, { ipKeyGenerator } from "express-rate-limit";
 
 const DEFAULT_CREATE_PAYMENT_RATE_LIMIT_MAX = 50;
 const DEFAULT_CREATE_PAYMENT_RATE_LIMIT_WINDOW_MS = 60 * 1000;
@@ -44,7 +44,7 @@ export function getCreatePaymentRateLimitKey(req) {
     return `merchant:${req.merchant.id}`;
   }
 
-  return req.ip;
+  return ipKeyGenerator(req.ip);
 }
 
 export function getRetryAfterSeconds(resetTime, now = new Date(), windowMs = DEFAULT_CREATE_PAYMENT_RATE_LIMIT_WINDOW_MS) {

backend/src/server.js

@@ -16,7 +16,13 @@ validateEnvironmentVariables();
 const port = process.env.PORT || 4000;
 
 async function startServer() {
-  const redisClient = await connectRedisClient();
+  let redisClient = null;
+  try {
+    redisClient = await connectRedisClient();
+    logger.info("redis connected");
+  } catch (err) {
+    logger.warn({ err }, "redis unavailable, continuing with in-memory fallbacks");
+  }
 
   const { app, io } = await createApp({ redisClient });
 
@@ -34,7 +40,7 @@ async function startServer() {
 
     const results = await Promise.allSettled([
       probe("Database", () => pool.query("SELECT 1")),
-      probe("Redis", () => redisClient.ping()),
+      probe("Redis", () => (redisClient ? redisClient.ping() : Promise.reject(new Error("redis unavailable")))),
       probe("Horizon", () => isHorizonReachable())
     ]);