Revert "Implement useStream (#488)"

This reverts commit 76e9328.

Author: hinthornw

.github/workflows/eval.yml

@@ -1,6 +1,12 @@
 name: Eval
 
 on:
+  push:
+    branches:
+      - master
+  pull_request:
+    branches:
+      - master
   workflow_dispatch:
 
 concurrency:

frontend/app/components/ChatLangChain.tsx

@@ -8,7 +8,7 @@ import {
 } from "@assistant-ui/react";
 import { v4 as uuidv4 } from "uuid";
 import { useExternalMessageConverter } from "@assistant-ui/react";
-import type { Message } from "@langchain/langgraph-sdk";
+import { BaseMessage, HumanMessage } from "@langchain/core/messages";
 import { useToast } from "../hooks/use-toast";
 import {
   convertToOpenAIFormat,
@@ -25,7 +25,7 @@ function ChatLangChainComponent(): React.ReactElement {
   const { toast } = useToast();
   const { threadsData, userData, graphData } = useGraphContext();
   const { userId } = userData;
-  const { getUserThreads, getThreadById } = threadsData;
+  const { getUserThreads, createThread, getThreadById } = threadsData;
   const { messages, setMessages, streamMessage, switchSelectedThread } =
     graphData;
   const [isRunning, setIsRunning] = useState(false);
@@ -73,16 +73,29 @@ function ChatLangChainComponent(): React.ReactElement {
 
     setIsRunning(true);
 
+    let currentThreadId = threadId;
+    if (!currentThreadId) {
+      const thread = await createThread(userId);
+      if (!thread) {
+        toast({
+          title: "Error",
+          description: "Thread creation failed.",
+        });
+        return;
+      }
+      setThreadId(thread.thread_id);
+      currentThreadId = thread.thread_id;
+    }
+
     try {
-      const humanMessage: Message = {
-        type: "human",
+      const humanMessage = new HumanMessage({
         content: message.content[0].text,
         id: uuidv4(),
-      };
+      });
 
       setMessages((prevMessages) => [...prevMessages, humanMessage]);
 
-      await streamMessage(threadId ?? undefined, {
+      await streamMessage(currentThreadId, {
         messages: [convertToOpenAIFormat(humanMessage)],
       });
     } finally {
@@ -92,9 +105,9 @@ function ChatLangChainComponent(): React.ReactElement {
     }
   }
 
-  const threadMessages = useExternalMessageConverter<Message>({
+  const threadMessages = useExternalMessageConverter<BaseMessage>({
     callback: convertLangchainMessages,
-    messages,
+    messages: messages,
     isRunning,
   });
 

frontend/app/components/SelectModel.tsx

@@ -11,7 +11,7 @@ import {
 
 const modelOptionsAndLabels: Partial<Record<ModelOptions, string>> = {
   "anthropic/claude-3-5-haiku-20241022": "Claude 3.5 Haiku",
-  "openai/gpt-5-mini": "GPT 5 Mini",
+  "openai/gpt-4.1-mini": "GPT 4.1 Mini",
   "google_genai/gemini-2.0-flash": "Gemini 2.0 Flash",
 };
 

frontend/app/components/chat-interface/chat-composer.tsx

@@ -4,12 +4,12 @@ import { ComposerPrimitive, ThreadPrimitive } from "@assistant-ui/react";
 import { type FC } from "react";
 
 import { SendHorizontalIcon } from "lucide-react";
-import type { Message } from "@langchain/langgraph-sdk";
+import { BaseMessage } from "@langchain/core/messages";
 import { TooltipIconButton } from "../ui/assistant-ui/tooltip-icon-button";
 import { cn } from "@/app/utils/cn";
 
 export interface ChatComposerProps {
-  messages: Message[];
+  messages: BaseMessage[];
   submitDisabled: boolean;
 }
 

frontend/app/components/thread-history/utils.ts

@@ -10,7 +10,7 @@ export function convertThreadActualToThreadProps(
   const values = thread.values as Record<string, any> | undefined;
   return {
     id: thread.thread_id,
-    label: values?.messages?.[0]?.content || "Untitled",
+    label: values?.messages?.[0].content || "Untitled",
     createdAt: new Date(thread.created_at),
     onClick: () => {
       return switchSelectedThread(thread);