Merge pull request #101 from will-lp1/ai-sdk-v5

upgrade to ai sdk v5!!

Author: will-lp1

apps/saru/.env.example

@@ -8,3 +8,5 @@ BETTER_AUTH_SECRET=123456789
 TAVILY_API_KEY=...
 
 DISCORD_WEBHOOK_URL=https://discord.com/api/webhooks/1364565597974954014/U9epDQwldNhgeFPT6ZktqcR9pBbwuJLf2SgAkeRiE9nnVDfhPqMA_8LO7semIMalVOS1
+
+DB_LOG_QUERIES=true # To log drizzle queries

apps/saru/app/api/blog-chat/route.ts

@@ -28,7 +28,7 @@ export async function POST(request: Request) {
       async start(controller) {
         for await (const delta of fullStream) {
           if (delta.type === 'text-delta') {
-            controller.enqueue(new TextEncoder().encode(delta.textDelta));
+            controller.enqueue(new TextEncoder().encode(delta.text));
           }
         }
         controller.close();

apps/saru/app/api/chat/actions/chat.ts

@@ -1,6 +1,6 @@
 'use server';
 
-import { generateText, Message } from 'ai';
+import { generateText, UIMessage } from 'ai';
 import { cookies } from 'next/headers';
 
 import {
@@ -21,7 +21,7 @@ export async function saveChatModelAsCookie(model: string) {
 export async function generateTitleFromUserMessage({
   message,
 }: {
-  message: Message;
+  message: UIMessage;
 }) {
   const { text: title } = await generateText({
     model: myProvider.languageModel('title-model'),
@@ -37,12 +37,21 @@ export async function generateTitleFromUserMessage({
 }
 
 export async function deleteTrailingMessages({ id }: { id: string }) {
-  const message = await getMessageById({ id });
+  try {
+    const message = await getMessageById({ id });
 
-  if (message) {
-    await deleteMessagesByChatIdAfterTimestamp({
-      chatId: message.chatId,
-      timestamp: message.createdAt,
-    });
+    if (message) {
+      await deleteMessagesByChatIdAfterTimestamp({
+        chatId: message.chatId,
+        timestamp: message.createdAt,
+      });
+    } else {
+      console.warn(
+        '[Chat Actions] deleteTrailingMessages: message not found, skipping delete',
+        { id }
+      );
+    }
+  } catch (error) {
+    console.warn('Failed to delete trailing messages by ID, skipping:', error);
   }
-} 
+}