pipeUIMessageStreamToResponse({
response: response,
stream: await handleChatStream({
mastra,
agentId: request.params.agentId as string,
params: {
...request.body,
threadId, // Include threadId in response metadata
messages,
requestContext,
},
}),
});
pipeUIMessageStreamToResponse({
response: response,
stream: await handleChatStream({
mastra,
agentId: request.params.agentId as string,
params: {
...request.body,
threadId, // Include threadId in response metadata
messages,
requestContext,
},
}),
});