add redis adapter

ansible/roles/poc-board-collaboration-server/templates/deployment.yml.j2

@@ -52,6 +52,8 @@ spec:
         envFrom:
         - configMapRef:
             name: poc-board-collaboration-server-configmap
+        - secretRef:
+            name: api-secret
         resources:
           limits:
             cpu: {{ POC_BOARD_COLLABORATION_SERVER__CPU_LIMITS|default("1000m", true) }}

package.json

@@ -25,6 +25,8 @@
     "@nestjs/platform-express": "^10.0.0",
     "@nestjs/platform-socket.io": "^10.3.3",
     "@nestjs/websockets": "^10.3.3",
+    "@socket.io/redis-adapter": "^8.3.0",
+    "redis": "^4.6.13",
     "reflect-metadata": "^0.2.0",
     "rxjs": "^7.8.1",
     "socket.io": "^4.7.4",

src/main.ts

@@ -1,11 +1,17 @@
 import { NestFactory } from '@nestjs/core';
 import { AppModule } from './app.module';
+import { RedisIoAdapter } from './socket/socket/redis-adapter';
 
 async function bootstrap() {
   const app = await NestFactory.create(AppModule, {
     cors: true,
   });
   app.setGlobalPrefix('bc-6683-poc-board-collaboration');
+
+  const redisIoAdapter = new RedisIoAdapter(app);
+  await redisIoAdapter.connectToRedis();
+
+  app.useWebSocketAdapter(redisIoAdapter);
   await app.listen(3000); // TODO: use env variable
 }
 bootstrap();

src/socket/socket/redis-adapter.ts

@@ -0,0 +1,28 @@
+import { IoAdapter } from '@nestjs/platform-socket.io';
+import { ServerOptions } from 'socket.io';
+import { createAdapter } from '@socket.io/redis-adapter';
+import { createClient } from 'redis';
+
+export class RedisIoAdapter extends IoAdapter {
+  private adapterConstructor: ReturnType<typeof createAdapter>;
+
+  async connectToRedis(): Promise<void> {
+	if (process.env.REDIS_URI) {
+		console.log('found a secret redis uri')
+	} else {
+		console.log('did not find a secret redis uri')
+	}
+    const pubClient = createClient({ url: process.env.REDIS_URI || `redis://localhost:6379` });
+    const subClient = pubClient.duplicate();
+
+    await Promise.all([pubClient.connect(), subClient.connect()]);
+
+    this.adapterConstructor = createAdapter(pubClient, subClient);
+  }
+
+  createIOServer(port: number, options?: ServerOptions): any {
+    const server = super.createIOServer(port, options);
+    server.adapter(this.adapterConstructor);
+    return server;
+  }
+}