🗑️ Flag deprecated stream routes

Author: baptisteArno

apps/landing-page/src/routeTree.gen.ts

@@ -20,7 +20,7 @@ import { Route as LayoutSlugRouteImport } from './routes/_layout/$slug'
 import { Route as LayoutBlogIndexRouteImport } from './routes/_layout/blog/index'
 import { Route as LayoutBlogSlugRouteImport } from './routes/_layout/blog/$slug'
 import { ServerRoute as SitemapDotxmlServerRouteImport } from './routes/sitemap[.]xml'
-import { ServerRoute as ApiHealthzServerRouteImport } from './routes/api/healthz'
+import { ServerRoute as HealthzServerRouteImport } from './routes/healthz'
 
 const rootServerRouteImport = createServerRootRoute()
 
@@ -68,9 +68,9 @@ const SitemapDotxmlServerRoute = SitemapDotxmlServerRouteImport.update({
   path: '/sitemap.xml',
   getParentRoute: () => rootServerRouteImport,
 } as any)
-const ApiHealthzServerRoute = ApiHealthzServerRouteImport.update({
-  id: '/api/healthz',
-  path: '/api/healthz',
+const HealthzServerRoute = HealthzServerRouteImport.update({
+  id: '/healthz',
+  path: '/healthz',
   getParentRoute: () => rootServerRouteImport,
 } as any)
 
@@ -139,29 +139,29 @@ export interface RootRouteChildren {
   LayoutRoute: typeof LayoutRouteWithChildren
 }
 export interface FileServerRoutesByFullPath {
+  '/healthz': typeof HealthzServerRoute
   '/sitemap.xml': typeof SitemapDotxmlServerRoute
-  '/api/healthz': typeof ApiHealthzServerRoute
 }
 export interface FileServerRoutesByTo {
+  '/healthz': typeof HealthzServerRoute
   '/sitemap.xml': typeof SitemapDotxmlServerRoute
-  '/api/healthz': typeof ApiHealthzServerRoute
 }
 export interface FileServerRoutesById {
   __root__: typeof rootServerRouteImport
+  '/healthz': typeof HealthzServerRoute
   '/sitemap.xml': typeof SitemapDotxmlServerRoute
-  '/api/healthz': typeof ApiHealthzServerRoute
 }
 export interface FileServerRouteTypes {
   fileServerRoutesByFullPath: FileServerRoutesByFullPath
-  fullPaths: '/sitemap.xml' | '/api/healthz'
+  fullPaths: '/healthz' | '/sitemap.xml'
   fileServerRoutesByTo: FileServerRoutesByTo
-  to: '/sitemap.xml' | '/api/healthz'
-  id: '__root__' | '/sitemap.xml' | '/api/healthz'
+  to: '/healthz' | '/sitemap.xml'
+  id: '__root__' | '/healthz' | '/sitemap.xml'
   fileServerRoutesById: FileServerRoutesById
 }
 export interface RootServerRouteChildren {
+  HealthzServerRoute: typeof HealthzServerRoute
   SitemapDotxmlServerRoute: typeof SitemapDotxmlServerRoute
-  ApiHealthzServerRoute: typeof ApiHealthzServerRoute
 }
 
 declare module '@tanstack/react-router' {
@@ -233,11 +233,11 @@ declare module '@tanstack/react-start/server' {
       preLoaderRoute: typeof SitemapDotxmlServerRouteImport
       parentRoute: typeof rootServerRouteImport
     }
-    '/api/healthz': {
-      id: '/api/healthz'
-      path: '/api/healthz'
-      fullPath: '/api/healthz'
-      preLoaderRoute: typeof ApiHealthzServerRouteImport
+    '/healthz': {
+      id: '/healthz'
+      path: '/healthz'
+      fullPath: '/healthz'
+      preLoaderRoute: typeof HealthzServerRouteImport
       parentRoute: typeof rootServerRouteImport
     }
   }
@@ -272,8 +272,8 @@ export const routeTree = rootRouteImport
   ._addFileChildren(rootRouteChildren)
   ._addFileTypes<FileRouteTypes>()
 const rootServerRouteChildren: RootServerRouteChildren = {
+  HealthzServerRoute: HealthzServerRoute,
   SitemapDotxmlServerRoute: SitemapDotxmlServerRoute,
-  ApiHealthzServerRoute: ApiHealthzServerRoute,
 }
 export const serverRouteTree = rootServerRouteImport
   ._addFileChildren(rootServerRouteChildren)

…s/landing-page/src/routes/api/healthz.ts apps/landing-page/src/routes/healthz.tsapps/landing-page/src/routes/api/healthz.ts renamed to apps/landing-page/src/routes/healthz.ts apps/landing-page/src/routes/api/healthz.ts renamed to apps/landing-page/src/routes/healthz.ts

@@ -1,6 +1,6 @@
 import { createServerFileRoute } from "@tanstack/react-start/server";
 
-export const ServerRoute = createServerFileRoute("/api/healthz").methods({
+export const ServerRoute = createServerFileRoute("/healthz").methods({
   GET: async () => {
     return new Response(
       JSON.stringify({ status: "ok", timestamp: new Date().toISOString() }),

apps/landing-page/vercel.json

@@ -10,11 +10,6 @@
       "source": "/typebot-lib/v2",
       "destination": "https://unpkg.com/[email protected]/dist/index.umd.min.js",
       "permanent": true
-    },
-    {
-      "source": "/healthz",
-      "destination": "/api/healthz",
-      "permanent": true
     }
   ]
 }

apps/viewer/next.config.mjs

@@ -127,10 +127,6 @@ const nextConfig = {
             destination:
               "/api/v1/typebots/:typebotId/blocks/:blockId/storage/upload-url",
           },
-          {
-            source: "/healthz",
-            destination: "/api/health",
-          },
         ])
         .concat(
           process.env.NEXTAUTH_URL

apps/viewer/src/app/api/integrations/openai/streamer/route.ts

@@ -1,4 +1,5 @@
 import { connect } from "@planetscale/database";
+import * as Sentry from "@sentry/nextjs";
 import { isForgedBlockType } from "@typebot.io/blocks-core/helpers";
 import { IntegrationBlockType } from "@typebot.io/blocks-integrations/constants";
 import type { ChatCompletionOpenAIOptions } from "@typebot.io/blocks-integrations/openai/schema";
@@ -180,6 +181,9 @@ export async function POST(req: Request) {
         { status: 400, headers: responseHeaders },
       );
 
+    Sentry.setTag("typebotId", state.typebotsQueue[0].typebot.id);
+    Sentry.captureMessage("Is using /api/integrations/openai/streamer");
+
     return new StreamingTextResponse(stream, {
       headers: responseHeaders,
     });

apps/viewer/src/app/api/v1/sessions/[sessionId]/streamMessage/route.ts

@@ -1,3 +1,4 @@
+import * as Sentry from "@sentry/nextjs";
 import { getMessageStream } from "@typebot.io/bot-engine/apiHandlers/getMessageStream";
 import { StreamingTextResponse } from "@typebot.io/legacy/ai";
 import { NextResponse } from "next/server";
@@ -29,12 +30,16 @@ export async function POST(
   const { sessionId } = await params;
   const body = await req.text();
   const messages = body ? JSON.parse(body).messages : undefined;
-  const { stream, status, message } = await getMessageStream({
+  const { stream, status, message, typebotId } = await getMessageStream({
     sessionId,
     messages,
   });
   if (!stream)
     return NextResponse.json({ message }, { status, headers: responseHeaders });
+
+  Sentry.setTag("typebotId", typebotId);
+  Sentry.captureMessage("Is using /api/v1/sessions/[sessionId]/streamMessage");
+
   return new StreamingTextResponse(
     stream.pipeThrough(createStreamDataTransformer()),
     {

apps/viewer/src/app/healthz/route.ts

@@ -0,0 +1,8 @@
+export default function GET() {
+  return new Response(
+    JSON.stringify({ status: "ok", timestamp: new Date().toISOString() }),
+    {
+      headers: { "Content-Type": "application/json" },
+    },
+  );
+}