fix: tRPC on alpha

Author: jherr

frameworks/react-cra/examples/tanchat/assets/src/routes/api.messages.ts

@@ -1,24 +1,21 @@
-import { createAPIFileRoute } from "@tanstack/react-start/api";
-import { getEvent } from "vinxi/http";
+import { transports } from '@/utils/demo.sse'
 
-import { transports } from "@/utils/demo.sse";
-
-export const APIRoute = createAPIFileRoute("/api/messages")({
+export const ServerRoute = createServerFileRoute('/api/messages').methods({
   // @ts-ignore
-  POST: async ({ request, params }) => {
-    const body = await request.json();
-    const url = new URL(request.url);
-    const sessionId = url.searchParams.get("sessionId") as string;
-    const transport = transports[sessionId];
+  POST: async ({ request }) => {
+    const body = await request.json()
+    const url = new URL(request.url)
+    const sessionId = url.searchParams.get('sessionId') as string
+    const transport = transports[sessionId]
     if (transport) {
       try {
-        getEvent().node.res.statusCode = 200;
-        await transport.handleMessage(body);
+        await transport.handleMessage(body)
+        return new Response(null, { status: 200 })
       } catch (error) {
-        getEvent().node.res.send("Error handling message");
+        return new Response(null, { status: 500 })
       }
     } else {
-      getEvent().node.res.send("No transport found for sessionId");
+      return new Response(null, { status: 404 })
     }
   },
-});
+})

frameworks/react-cra/examples/tanchat/assets/src/routes/api.sse.ts

@@ -1,23 +1,40 @@
-import { createAPIFileRoute } from '@tanstack/react-start/api'
-import { getEvent } from 'vinxi/http'
 import { SSEServerTransport } from '@modelcontextprotocol/sdk/server/sse.js'
 
 import { transports, server } from '@/utils/demo.sse'
 
-export const APIRoute = createAPIFileRoute('/api/sse')({
+export const ServerRoute = createServerFileRoute('/api/sse').methods({
   // @ts-ignore
   GET: async ({}) => {
-    const transport = new SSEServerTransport(
-      '/api/messages',
-      getEvent().node.res,
-    )
+    let body = ''
+    let headers: Record<string, string> = {}
+    let statusCode = 200
+    const resp = {
+      on: (event: string, callback: () => void) => {
+        if (event === 'close') {
+          callback()
+        }
+      },
+      writeHead: (statusCode: number, headers: Record<string, string>) => {
+        headers = headers
+        statusCode = statusCode
+      },
+      write: (data: string) => {
+        body += data + '\n'
+      },
+    }
+    const transport = new SSEServerTransport('/api/messages', resp as any)
     transports[transport.sessionId] = transport
     transport.onerror = (error) => {
       console.error(error)
     }
-    getEvent().node.res.on('close', () => {
+    resp.on('close', () => {
       delete transports[transport.sessionId]
     })
     await server.connect(transport)
+    const response = new Response(body, {
+      status: statusCode,
+      headers: headers,
+    })
+    return response
   },
 })

frameworks/react-cra/examples/tanchat/assets/src/utils/demo.sse.ts

@@ -1,31 +1,29 @@
-import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
-import { SSEServerTransport } from "@modelcontextprotocol/sdk/server/sse.js";
-import { getWebRequest } from "vinxi/http";
+import { McpServer } from '@modelcontextprotocol/sdk/server/mcp.js'
+import { SSEServerTransport } from '@modelcontextprotocol/sdk/server/sse.js'
 
-import guitars from "@/data/example-guitars";
+import guitars from '@/data/example-guitars'
 
 export const server = new McpServer({
-  name: "guitar-server",
-  version: "1.0.0",
-});
-export const transports: { [sessionId: string]: SSEServerTransport } = {};
+  name: 'guitar-server',
+  version: '1.0.0',
+})
+export const transports: { [sessionId: string]: SSEServerTransport } = {}
 
-server.tool("getGuitars", {}, async ({}) => {
-  const port = new URL(getWebRequest().url).port;
+server.tool('getGuitars', {}, async ({}) => {
   return {
     content: [
       {
-        type: "text",
+        type: 'text',
         text: JSON.stringify(
           guitars.map((guitar) => ({
             id: guitar.id,
             name: guitar.name,
             description: guitar.description,
             price: guitar.price,
-            image: `http://localhost:${port}${guitar.image}`,
-          }))
+            image: `http://localhost:3000${guitar.image}`,
+          })),
         ),
       },
     ],
-  };
-});
+  }
+})

packages/cta-engine/src/create-app.ts

@@ -233,7 +233,7 @@ Use the following commands to start your app:
       getPackageManagerScriptCommand(options.packageManager, ['dev']),
     )}
 
-Please read the README.md for information on testing, styling, adding routes, etc.${errorStatement}`,
+Please check the README.md for information on testing, styling, adding routes, etc.${errorStatement}`,
   )
 }