How to use this module with Websockets & subscriptions ?

[michael-dm]

[gustawdaniel]

seems to be unimplemented

[wobsoriano]

You can do this now, just follow this doc from tRPC docs and use a Nitro plugin for the WS server:

import { applyWSSHandler } from '@trpc/server/adapters/ws';
import WebSocket, { WebSocketServer as WSWebSocketServer } from 'ws';
import { appRouter } from '~/server/api/trpc/[trpc]';

export default defineNitroPlugin((nitro) => {
  const WebSocketServer = WebSocket.Server || WSWebSocketServer;
  const wss = new WebSocketServer({
    port: 3002,
  });

  const handler = applyWSSHandler({ wss, router: appRouter });

  wss.on('connection', (ws) => {
    console.log(`➕➕ Connection (${wss.clients.size})`);
    ws.once('close', () => {
      console.log(`➖➖ Connection (${wss.clients.size})`);
    });
  });
  
  console.log('✅ WebSocket Server listening on ws://localhost:3002');

  nitro.hooks.hookOnce('close', async () => {
    handler.broadcastReconnectNotification();
    wss.close();
  })
})

Here's a basic example - https://github.com/wobsoriano/trpc-nuxt-subscriptions-demo

[Q16solver]

@wobsoriano This doesn't seem to work in production with https://domain.com:3002 not connecting

[lewebsimple]

Is it possible to re-use the same port for the WS server ?