The Complete Production SOP: How to Deploy and Run Socket.IO Real-Time Rooms, Namespaces & Binary Streams in Autonomous AI Agents

---
name: "socket-io-rooms-binary-events"
description: "Build bi-directional, resilient event-driven WebSocket applications using Socket.IO."
triggers:
  - "create socket.io room"
  - "broadcast to room socket.io"
  - "redis adapter socket.io cluster"
permissions:
  fs_read: true
  fs_write: "workspace"
  shell_exec: false
  net_access: false
---

import { createServer } from 'node:http';
import { Server, Socket } from 'socket.io';
import { createAdapter } from '@socket.io/redis-adapter';
import Redis from 'ioredis';

export async function initSocketServer(port = 3001) {
  const httpServer = createServer();
  const pubClient = new Redis(process.env.REDIS_URL || 'redis://127.0.0.1:6379');
  const subClient = pubClient.duplicate();

  const io = new Server(httpServer, {
    adapter: createAdapter(pubClient, subClient),
    cors: { origin: process.env.ALLOWED_ORIGINS?.split(',') || '*' },
    maxHttpBufferSize: 1e7 // 10MB limit for binary streams
  });

  const mediaNamespace = io.of('/media');
  mediaNamespace.on('connection', (socket: Socket) => {
    socket.on('join_room', (roomId: string) => {
      socket.join(`room_${roomId}`);
    });

    socket.on('binary_chunk', (data: Buffer, ack: (status: string) => void) => {
      if (!Buffer.isBuffer(data)) return ack('ERR_INVALID_TYPE');
      socket.broadcast.emit('chunk_received', data);
      ack('OK');
    });
  });

  return { httpServer, io };
}

# Execute via Cursor Composer or Claude Code CLI
claude code --prompt "create socket.io room for voice sessions using redis adapter socket.io cluster"

import { io as Client } from 'socket.io-client';
import { initSocketServer } from '../src/realtime/socketServer';

describe('Socket.IO Room & Binary Streaming', () => {
  let server: any, clientSocket: any;

  beforeAll(async () => {
    const instance = await initSocketServer(3099);
    server = instance.httpServer;
    await new Promise((res) => server.listen(3099, res));
    clientSocket = Client('http://localhost:3099/media');
    await new Promise((res) => clientSocket.on('connect', res));
  });

  afterAll(() => {
    clientSocket.disconnect();
    server.close();
  });

  test('emits and receives raw buffer binary events', (done) => {
    const payload = Buffer.from([0xDE, 0xAD, 0xBE, 0xEF]);
    clientSocket.emit('binary_chunk', payload, (response: string) => {
      expect(response).toBe('OK');
      done();
    });
  });
});