diff --git a/apps/viewer/src/app/api/v1/sessions/[sessionId]/streamMessage/route.ts b/apps/viewer/src/app/api/v1/sessions/[sessionId]/streamMessage/route.ts
index 47f8edf85..12b1dff50 100644
--- a/apps/viewer/src/app/api/v1/sessions/[sessionId]/streamMessage/route.ts
+++ b/apps/viewer/src/app/api/v1/sessions/[sessionId]/streamMessage/route.ts
@@ -26,8 +26,8 @@ export async function POST(
   req: Request,
   { params }: { params: { sessionId: string } }
 ) {
-  const messages =
-    typeof req.body === 'string' ? JSON.parse(req.body) : req.body
+  const body = await req.text()
+  const messages = body ? JSON.parse(body).messages : undefined
   const { stream, status, message } = await getMessageStream({
     sessionId: params.sessionId,
     messages,
diff --git a/apps/viewer/src/app/api/v2/sessions/[sessionId]/streamMessage/route.ts b/apps/viewer/src/app/api/v2/sessions/[sessionId]/streamMessage/route.ts
index ce2c18f62..804360648 100644
--- a/apps/viewer/src/app/api/v2/sessions/[sessionId]/streamMessage/route.ts
+++ b/apps/viewer/src/app/api/v2/sessions/[sessionId]/streamMessage/route.ts
@@ -26,8 +26,8 @@ export async function POST(
   req: Request,
   { params }: { params: { sessionId: string } }
 ) {
-  const messages =
-    typeof req.body === 'string' ? JSON.parse(req.body) : req.body
+  const body = await req.text()
+  const messages = body ? JSON.parse(body).messages : undefined
   const { stream, status, message } = await getMessageStream({
     sessionId: params.sessionId,
     messages,