M
MastraAI•4d ago
sheerazz

toAISdkFormat and stream export issues (AI SDK v5)

getting an issue in vitest ever since i added import { toAISdkFormat } from '@mastra/ai-sdk';. The Error is SyntaxError: The requested module '@mastra/core/stream' does not provide an export named 'DefaultGeneratedFile' as anyone ran into this? my implementation is below: 
  const result1 = await agent1.streamVNext(finalMessages, {
    runtimeContext,
    stopWhen: stepCountIs(100),
  });

  const stream = createUIMessageStream({
    execute: async ({ writer }) => {
      for await (const part of toAISdkFormat(result1, { from: 'agent' })!) {
        writer.write(part);
      }
    },
    generateId: generateUUID,
    onFinish: async ({ messages: finished }) => {
      await saveMessages({
        messages: finished
          .filter((m) => m.role !== 'user')
          .map((m) => ({
            id: isUuidV4(m.id) ? m.id : generateUUID(),
            role: m.role,
            parts: m.parts as ChatMessagePart[],
            createdAt: new Date(),
            attachments: [],
            chatId,
          })),
      });
    },
    onError: () => 'Oops, an error occurred!',
  });

  // Set headers and return SSE stream (Express.js adaptation)
  res.writeHead(200, {
    'Content-Type': 'text/event-stream',
    'Cache-Control': 'no-cache',
    Connection: 'keep-alive',
    'Access-Control-Allow-Origin': '*',
  });

  const sseStream = stream.pipeThrough(new JsonToSseTransformStream());
  const reader = sseStream.getReader();
  const result1 = await agent1.streamVNext(finalMessages, {
    runtimeContext,
    stopWhen: stepCountIs(100),
  });

  const stream = createUIMessageStream({
    execute: async ({ writer }) => {
      for await (const part of toAISdkFormat(result1, { from: 'agent' })!) {
        writer.write(part);
      }
    },
    generateId: generateUUID,
    onFinish: async ({ messages: finished }) => {
      await saveMessages({
        messages: finished
          .filter((m) => m.role !== 'user')
          .map((m) => ({
            id: isUuidV4(m.id) ? m.id : generateUUID(),
            role: m.role,
            parts: m.parts as ChatMessagePart[],
            createdAt: new Date(),
            attachments: [],
            chatId,
          })),
      });
    },
    onError: () => 'Oops, an error occurred!',
  });

  // Set headers and return SSE stream (Express.js adaptation)
  res.writeHead(200, {
    'Content-Type': 'text/event-stream',
    'Cache-Control': 'no-cache',
    Connection: 'keep-alive',
    'Access-Control-Allow-Origin': '*',
  });

  const sseStream = stream.pipeThrough(new JsonToSseTransformStream());
  const reader = sseStream.getReader();
2 Replies
Mastra Triager
Mastra Triager•4d ago
📝 Created GitHub issue: https://github.com/mastra-ai/mastra/issues/8957
GitHub
[DISCORD:1428495709023502346] toAISdkFormat and stream export issue...
This issue was created from Discord post: https://discord.com/channels/1309558646228779139/1428495709023502346 getting an issue in vitest ever since i added import { toAISdkFormat } from '@mast...
Abhi Aiyer
Abhi Aiyer•3d ago
I believe you are in a different core version than the @mastra/ai-sdk. streamVNext is now stream in later versions. I don't think we have accurate peer deps because our ai-sdk package is quite new Try upgrading and seeing if you have the issue

Did you find this page helpful?