onAdd: publicProcedure.subscription(() => {
    // return an `observable` with a callback which is triggered immediately
    return observable<Review>(emit => {
      const onAdd = (data: Review) => {
        // emit data to client
        emit.next(data)
      }
      // trigger `onAdd()` when `add` is triggered in our event emitter
      ee.on('add', onAdd)
      // unsubscribe function when client disconnects or stops subscribing
      return () => {
        ee.off('add', onAdd)
      }
    })
  }),
  createReview: authedProcedure
    .input(v => {
      const schema = z.object({
       ...
      })
      const result = schema.safeParse(v)
      if (!result.success) {
        throw result.error
      }
      return result.data
    })
    .mutation(async ({ input, ctx }) => {
      const session = await getServerAuthSession()

      // Create the review record
      const review = await db.review.create({
        data: {
          ....
        },
     
      })
      ee.emit('add', review)
      return review
    }),

onAdd: publicProcedure.subscription(() => {
    // return an `observable` with a callback which is triggered immediately
    return observable<Review>(emit => {
      const onAdd = (data: Review) => {
        // emit data to client
        emit.next(data)
      }
      // trigger `onAdd()` when `add` is triggered in our event emitter
      ee.on('add', onAdd)
      // unsubscribe function when client disconnects or stops subscribing
      return () => {
        ee.off('add', onAdd)
      }
    })
  }),
  createReview: authedProcedure
    .input(v => {
      const schema = z.object({
       ...
      })
      const result = schema.safeParse(v)
      if (!result.success) {
        throw result.error
      }
      return result.data
    })
    .mutation(async ({ input, ctx }) => {
      const session = await getServerAuthSession()

      // Create the review record
      const review = await db.review.create({
        data: {
          ....
        },
     
      })
      ee.emit('add', review)
      return review
    }),

import ws from 'ws'
import { applyWSSHandler } from '@trpc/server/adapters/ws'
import { appRouter } from './routers/_app'
import { createContext, createTRPCContext } from './context'

const wss = new ws.Server({
  port: 3001
})

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

wss.on('connection', () => {
  console.log(`Got a connection ${wss.clients.size}`)
  wss.once('close', () => {
    console.log(`Closed connection ${wss.clients.size}`)
  })
})

console.log(`wss server start at ws://localhost:3001`)

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

import ws from 'ws'
import { applyWSSHandler } from '@trpc/server/adapters/ws'
import { appRouter } from './routers/_app'
import { createContext, createTRPCContext } from './context'

const wss = new ws.Server({
  port: 3001
})

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

wss.on('connection', () => {
  console.log(`Got a connection ${wss.clients.size}`)
  wss.once('close', () => {
    console.log(`Closed connection ${wss.clients.size}`)
  })
})

console.log(`wss server start at ws://localhost:3001`)

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

"dev": "run-p dev:*",
    "dev:next": "next dev",
    "dev:wss": "cross-env PORT=3001 nodemon --watch src --ext .ts,.tsx,js,jsx --signal SIGTERM --exec \"ts-node --project tsconfig.server.json src/server/wsServer.ts\"",

"dev": "run-p dev:*",
    "dev:next": "next dev",
    "dev:wss": "cross-env PORT=3001 nodemon --watch src --ext .ts,.tsx,js,jsx --signal SIGTERM --exec \"ts-node --project tsconfig.server.json src/server/wsServer.ts\"",

export const trpc = createTRPCNext<AppRouter>({
  /**
   * @link https://trpc.io/docs/v11/ssr
   */
  // ssr: true,
  // ssrPrepass,
  ssr: false,
  config({ ctx }) {
    /**
     * If you want to use SSR, you need to use the server's full URL
     * @link https://trpc.io/docs/v11/ssr
     */

    return {
      /**
       * @link https://trpc.io/docs/v11/client/links
       */
      links: [
        // adds pretty logs to your console in development and logs errors in production
        loggerLink({
          enabled: opts =>
            (process.env.NODE_ENV === 'development' && typeof window !== 'undefined') ||
            (opts.direction === 'down' && opts.result instanceof Error)
        }),
        splitLink({
          condition: op => {
            return op.type === 'subscription'
          },
          true: wsLink({
            client: createWSClient({
              url: 'ws://localhost:3001'
            })
          }),
          false: httpBatchLink({
            transformer: superjson,
            url: `http://localhost:3000/api/trpc`
          })
        })
      ],
      /**
       * @link https://tanstack.com/query/v5/docs/reference/QueryClient
       */
      queryClientConfig: { defaultOptions: { queries: { staleTime: 60 } } }
    }
  },
  /**
   * @link https://trpc.io/docs/v11/data-transformers
   */
  transformer: superjson
})

export const trpc = createTRPCNext<AppRouter>({
  /**
   * @link https://trpc.io/docs/v11/ssr
   */
  // ssr: true,
  // ssrPrepass,
  ssr: false,
  config({ ctx }) {
    /**
     * If you want to use SSR, you need to use the server's full URL
     * @link https://trpc.io/docs/v11/ssr
     */

    return {
      /**
       * @link https://trpc.io/docs/v11/client/links
       */
      links: [
        // adds pretty logs to your console in development and logs errors in production
        loggerLink({
          enabled: opts =>
            (process.env.NODE_ENV === 'development' && typeof window !== 'undefined') ||
            (opts.direction === 'down' && opts.result instanceof Error)
        }),
        splitLink({
          condition: op => {
            return op.type === 'subscription'
          },
          true: wsLink({
            client: createWSClient({
              url: 'ws://localhost:3001'
            })
          }),
          false: httpBatchLink({
            transformer: superjson,
            url: `http://localhost:3000/api/trpc`
          })
        })
      ],
      /**
       * @link https://tanstack.com/query/v5/docs/reference/QueryClient
       */
      queryClientConfig: { defaultOptions: { queries: { staleTime: 60 } } }
    }
  },
  /**
   * @link https://trpc.io/docs/v11/data-transformers
   */
  transformer: superjson
})