feat: ➕ use superjson instead of built-in json

Author: imxeno

package-lock.json

@@ -18,8 +18,8 @@
     "build": "rimraf dist && rimraf adapter && rimraf link && rimraf types && tsc -p tsconfig.build.json && shx mv dist/* . && rimraf dist"
   },
   "peerDependencies": {
-    "@trpc/client": "10.0.0-proxy-beta.18",
-    "@trpc/server": "10.0.0-proxy-beta.18"
+    "@trpc/client": "^10.0.0-proxy-beta.18",
+    "@trpc/server": "^10.0.0-proxy-beta.18"
   },
   "devDependencies": {
     "@trivago/prettier-plugin-sort-imports": "^3.3.0",

package.json

@@ -8,6 +8,7 @@ import {
 import type { OnErrorFunction } from '@trpc/server/dist/internals/types';
 import * as amqp from 'amqp-connection-manager';
 import type { ConsumeMessage } from 'amqplib';
+import { parse, stringify } from 'superjson';
 
 import { getErrorFromUnknown } from './errors';
 
@@ -41,7 +42,7 @@ export const createRMQHandler = <TRouter extends AnyRouter>(
         if (!correlationId || !replyTo) return;
         const res = await handleMessage(router, msg, onError);
         if (!res) return;
-        void channel.sendToQueue(replyTo as string, Buffer.from(JSON.stringify({ trpc: res })), {
+        void channel.sendToQueue(replyTo as string, Buffer.from(stringify({ trpc: res })), {
           correlationId: correlationId as string
         });
       });
@@ -59,7 +60,7 @@ async function handleMessage<TRouter extends AnyRouter>(
   const { transformer } = router._def._config;
 
   try {
-    const message = JSON.parse(msg.content.toString('utf-8'));
+    const message: any = parse(msg.content.toString('utf-8'));
     if (!('trpc' in message)) return;
     const { trpc } = message;
     if (!('id' in trpc) || trpc.id === null || trpc.id === undefined) return;

src/adapter/index.ts

@@ -4,6 +4,7 @@ import { observable } from '@trpc/server/observable';
 import * as amqp from 'amqp-connection-manager';
 import { randomUUID } from 'crypto';
 import EventEmitter from 'events';
+import { parse, stringify } from 'superjson';
 
 import type { TRPCRMQRequest, TRPCRMQResponse } from '../types';
 
@@ -31,7 +32,7 @@ export const rmqLink = <TRouter extends AnyRouter>(opts: TRPCRMQLinkOptions): TR
             if (!msg) return;
             responseEmitter.emit(
               msg.properties.correlationId as string,
-              JSON.parse(msg.content.toString('utf-8'))
+              parse(msg.content.toString('utf-8'))
             );
           },
           { noAck: true }
@@ -43,7 +44,7 @@ export const rmqLink = <TRouter extends AnyRouter>(opts: TRPCRMQLinkOptions): TR
       new Promise<any>(resolve => {
         const correlationId = randomUUID();
         responseEmitter.once(correlationId, resolve);
-        void channel.sendToQueue(queue, Buffer.from(JSON.stringify(message)), {
+        void channel.sendToQueue(queue, Buffer.from(stringify(message)), {
           correlationId,
           replyTo: REPLY_QUEUE
         });