"dev:wss": "cross-env PORT=3005 tsx watch src/server/wss.ts --tsconfig tsconfig.server.json",

"dev:wss": "cross-env PORT=3005 tsx watch src/server/wss.ts --tsconfig tsconfig.server.json",

pnpm dev:wss

pnpm dev:wss

pnpm dev

pnpm dev

import { createWSClient, wsLink } from "@trpc/client";
import { createTRPCNext } from "@trpc/next";

const wssLink = wsLink<AppRouter>({
    client: createWSClient({
      url: "ws://localhost:3005",
      onOpen: () => console.info("ws con established"),
      onClose: () => console.info("ws con closed"),
    }),
  });

export const api = createTRPCNext<AppRouter>({
  config({ ctx: _ctx }) {
    return {
      // ...
      links: [
        // ...
        wssLink
      ],
    };
  },

import { createWSClient, wsLink } from "@trpc/client";
import { createTRPCNext } from "@trpc/next";

const wssLink = wsLink<AppRouter>({
    client: createWSClient({
      url: "ws://localhost:3005",
      onOpen: () => console.info("ws con established"),
      onClose: () => console.info("ws con closed"),
    }),
  });

export const api = createTRPCNext<AppRouter>({
  config({ ctx: _ctx }) {
    return {
      // ...
      links: [
        // ...
        wssLink
      ],
    };
  },

import {WebSocketServer} from "ws"
import { applyWSSHandler } from "@trpc/server/adapters/ws"
import {appRouter} from "src/server/api/root"
import { createTRPCContext } from "src/server/api/trpc"

const wss = new WebSocketServer({
    port: 3005
})

const handler = applyWSSHandler({
    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment, @typescript-eslint/no-explicit-any
    wss, router: appRouter, createContext: createTRPCContext as any
})

wss.on("connection", (ws) => {
    const fakeClientId = Math.floor(Math.random() * 1000)
    console.info(`client_connected ${fakeClientId}`)
    ws.once("close", () => {
        console.info(`cliend_close ${fakeClientId}`)
    })
})


console.info("wss enabled")

process.on('SIGTERM', () => {
    console.log('SIGTERM');
    handler.broadcastReconnectNotification();
    wss.close();
  });

import {WebSocketServer} from "ws"
import { applyWSSHandler } from "@trpc/server/adapters/ws"
import {appRouter} from "src/server/api/root"
import { createTRPCContext } from "src/server/api/trpc"

const wss = new WebSocketServer({
    port: 3005
})

const handler = applyWSSHandler({
    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment, @typescript-eslint/no-explicit-any
    wss, router: appRouter, createContext: createTRPCContext as any
})

wss.on("connection", (ws) => {
    const fakeClientId = Math.floor(Math.random() * 1000)
    console.info(`client_connected ${fakeClientId}`)
    ws.once("close", () => {
        console.info(`cliend_close ${fakeClientId}`)
    })
})


console.info("wss enabled")

process.on('SIGTERM', () => {
    console.log('SIGTERM');
    handler.broadcastReconnectNotification();
    wss.close();
  });