Method setupRedisAdapter

server/modules/socketManager.js:102–179

()

  }

  async setupRedisAdapter() {
    try {
      const redisConfig = getRedisOptions();

      // Check if Redis is configured (host is set)
      if (!redisConfig.host) {
        console.log("Redis not configured, using in-memory adapter"); // eslint-disable-line
        return;
      }

      // Create Redis clients for pub/sub with proper error handling
      this.pubClient = new Redis({
        ...redisConfig,
        lazyConnect: true, // Don't connect immediately, we'll connect explicitly
        maxRetriesPerRequest: null, // Required for adapter
        enableReadyCheck: true,
        retryStrategy(times) {
          const delay = Math.min(times * 50, 2000);
          return delay;
        },
      });

      this.subClient = this.pubClient.duplicate();

      // Set up error handlers before connecting
      this.pubClient.on("error", (err) => {
        console.error("Socket.IO Redis Pub Client Error:", err.message); // eslint-disable-line
      });

      this.subClient.on("error", (err) => {
        console.error("Socket.IO Redis Sub Client Error:", err.message); // eslint-disable-line
      });

      // Set up reconnection handlers
      this.pubClient.on("reconnecting", () => {
        console.log("Socket.IO Redis Pub Client reconnecting..."); // eslint-disable-line
      });

      this.subClient.on("reconnecting", () => {
        console.log("Socket.IO Redis Sub Client reconnecting..."); // eslint-disable-line
      });

      // Set up ready handlers
      this.pubClient.on("ready", () => {
        console.log("Socket.IO Redis Pub Client ready"); // eslint-disable-line
      });

      this.subClient.on("ready", () => {
        console.log("Socket.IO Redis Sub Client ready"); // eslint-disable-line
      });

      // Connect both clients and wait for them to be ready
      await Promise.all([
        this.pubClient.connect(),
        this.subClient.connect()
      ]);

      // Use Redis adapter for cross-process communication with recommended options