Merge pull request #2 from langchain-ai/brace/new-thread

feat: Allow for creating new threads
This commit is contained in:
David Duong
2025-03-04 14:05:47 +01:00
committed by GitHub
6 changed files with 122 additions and 25 deletions

View File

@@ -36,9 +36,11 @@
"react": "^19.0.0", "react": "^19.0.0",
"react-dom": "^19.0.0", "react-dom": "^19.0.0",
"react-markdown": "^10.0.1", "react-markdown": "^10.0.1",
"react-router-dom": "^6.17.0",
"remark-gfm": "^4.0.1", "remark-gfm": "^4.0.1",
"tailwind-merge": "^3.0.2", "tailwind-merge": "^3.0.2",
"tailwindcss-animate": "^1.0.7", "tailwindcss-animate": "^1.0.7",
"use-query-params": "^2.2.1",
"uuid": "^11.0.5", "uuid": "^11.0.5",
"zod": "^3.24.2" "zod": "^3.24.2"
}, },

78
pnpm-lock.yaml generated
View File

@@ -84,6 +84,9 @@ importers:
react-markdown: react-markdown:
specifier: ^10.0.1 specifier: ^10.0.1
version: 10.0.1(@types/react@19.0.10)(react@19.0.0) version: 10.0.1(@types/react@19.0.10)(react@19.0.0)
react-router-dom:
specifier: ^6.17.0
version: 6.30.0(react-dom@19.0.0(react@19.0.0))(react@19.0.0)
remark-gfm: remark-gfm:
specifier: ^4.0.1 specifier: ^4.0.1
version: 4.0.1 version: 4.0.1
@@ -93,6 +96,9 @@ importers:
tailwindcss-animate: tailwindcss-animate:
specifier: ^1.0.7 specifier: ^1.0.7
version: 1.0.7(tailwindcss@4.0.9) version: 1.0.7(tailwindcss@4.0.9)
use-query-params:
specifier: ^2.2.1
version: 2.2.1(react-dom@19.0.0(react@19.0.0))(react-router-dom@6.30.0(react-dom@19.0.0(react@19.0.0))(react@19.0.0))(react@19.0.0)
uuid: uuid:
specifier: ^11.0.5 specifier: ^11.0.5
version: 11.1.0 version: 11.1.0
@@ -1420,6 +1426,13 @@ packages:
integrity: sha512-A9+lCBZoaMJlVKcRBz2YByCG+Cp2t6nAnMnNba+XiWxnj6r4JUFqfsgwocMBZU9LPtdxC6wB56ySYpc7LQIoJg==, integrity: sha512-A9+lCBZoaMJlVKcRBz2YByCG+Cp2t6nAnMnNba+XiWxnj6r4JUFqfsgwocMBZU9LPtdxC6wB56ySYpc7LQIoJg==,
} }
"@remix-run/router@1.23.0":
resolution:
{
integrity: sha512-O3rHJzAQKamUz1fvE0Qaw0xSFqsA/yafi2iqeE0pvdFtCO1viYx8QL6f3Ln/aCCTLxs68SLf0KPM9eSeM8yBnA==,
}
engines: { node: ">=14.0.0" }
"@rollup/rollup-android-arm-eabi@4.34.8": "@rollup/rollup-android-arm-eabi@4.34.8":
resolution: resolution:
{ {
@@ -4193,6 +4206,25 @@ packages:
"@types/react": "@types/react":
optional: true optional: true
react-router-dom@6.30.0:
resolution:
{
integrity: sha512-x30B78HV5tFk8ex0ITwzC9TTZMua4jGyA9IUlH1JLQYQTFyxr/ZxwOJq7evg1JX1qGVUcvhsmQSKdPncQrjTgA==,
}
engines: { node: ">=14.0.0" }
peerDependencies:
react: ">=16.8"
react-dom: ">=16.8"
react-router@6.30.0:
resolution:
{
integrity: sha512-D3X8FyH9nBcTSHGdEKurK7r8OYE1kKFn3d/CF+CoxbSHkxU7o37+Uh7eAHRXr6k2tSExXYO++07PeXJtA/dEhQ==,
}
engines: { node: ">=14.0.0" }
peerDependencies:
react: ">=16.8"
react-style-singleton@2.2.3: react-style-singleton@2.2.3:
resolution: resolution:
{ {
@@ -4361,6 +4393,12 @@ packages:
engines: { node: ">=10" } engines: { node: ">=10" }
hasBin: true hasBin: true
serialize-query-params@2.0.2:
resolution:
{
integrity: sha512-1chMo1dST4pFA9RDXAtF0Rbjaut4is7bzFbI1Z26IuMub68pNCILku85aYmeFhvnY//BXUPUhoRMjYcsT93J/Q==,
}
shebang-command@2.0.0: shebang-command@2.0.0:
resolution: resolution:
{ {
@@ -4746,6 +4784,22 @@ packages:
"@types/react": "@types/react":
optional: true optional: true
use-query-params@2.2.1:
resolution:
{
integrity: sha512-i6alcyLB8w9i3ZK3caNftdb+UnbfBRNPDnc89CNQWkGRmDrm/gfydHvMBfVsQJRq3NoHOM2dt/ceBWG2397v1Q==,
}
peerDependencies:
"@reach/router": ^1.2.1
react: ">=16.8.0"
react-dom: ">=16.8.0"
react-router-dom: ">=5"
peerDependenciesMeta:
"@reach/router":
optional: true
react-router-dom:
optional: true
use-sidecar@1.1.3: use-sidecar@1.1.3:
resolution: resolution:
{ {
@@ -5797,6 +5851,8 @@ snapshots:
"@radix-ui/rect@1.1.0": {} "@radix-ui/rect@1.1.0": {}
"@remix-run/router@1.23.0": {}
"@rollup/rollup-android-arm-eabi@4.34.8": "@rollup/rollup-android-arm-eabi@4.34.8":
optional: true optional: true
@@ -7583,6 +7639,18 @@ snapshots:
optionalDependencies: optionalDependencies:
"@types/react": 19.0.10 "@types/react": 19.0.10
react-router-dom@6.30.0(react-dom@19.0.0(react@19.0.0))(react@19.0.0):
dependencies:
"@remix-run/router": 1.23.0
react: 19.0.0
react-dom: 19.0.0(react@19.0.0)
react-router: 6.30.0(react@19.0.0)
react-router@6.30.0(react@19.0.0):
dependencies:
"@remix-run/router": 1.23.0
react: 19.0.0
react-style-singleton@2.2.3(@types/react@19.0.10)(react@19.0.0): react-style-singleton@2.2.3(@types/react@19.0.10)(react@19.0.0):
dependencies: dependencies:
get-nonce: 1.0.1 get-nonce: 1.0.1
@@ -7701,6 +7769,8 @@ snapshots:
semver@7.7.1: {} semver@7.7.1: {}
serialize-query-params@2.0.2: {}
shebang-command@2.0.0: shebang-command@2.0.0:
dependencies: dependencies:
shebang-regex: 3.0.0 shebang-regex: 3.0.0
@@ -7911,6 +7981,14 @@ snapshots:
optionalDependencies: optionalDependencies:
"@types/react": 19.0.10 "@types/react": 19.0.10
use-query-params@2.2.1(react-dom@19.0.0(react@19.0.0))(react-router-dom@6.30.0(react-dom@19.0.0(react@19.0.0))(react@19.0.0))(react@19.0.0):
dependencies:
react: 19.0.0
react-dom: 19.0.0(react@19.0.0)
serialize-query-params: 2.0.2
optionalDependencies:
react-router-dom: 6.30.0(react-dom@19.0.0(react@19.0.0))(react@19.0.0)
use-sidecar@1.1.3(@types/react@19.0.10)(react@19.0.0): use-sidecar@1.1.3(@types/react@19.0.10)(react@19.0.0):
dependencies: dependencies:
detect-node-es: 1.1.0 detect-node-es: 1.1.0

File diff suppressed because one or more lines are too long

View File

@@ -13,23 +13,9 @@ import {
ensureToolCallsHaveResponses, ensureToolCallsHaveResponses,
} from "@/lib/ensure-tool-responses"; } from "@/lib/ensure-tool-responses";
import { LangGraphLogoSVG } from "../icons/langgraph"; import { LangGraphLogoSVG } from "../icons/langgraph";
import { TooltipIconButton } from "./tooltip-icon-button";
// const dummyMessages = [ import { SquarePen } from "lucide-react";
// { type: "human", content: "Hi! What can you do?" }, import { StringParam, useQueryParam } from "use-query-params";
// {
// type: "ai",
// content: `Hello! I can assist you with a variety of tasks, including:
// 1. **Answering Questions**: I can provide information on a wide range of topics, from science and history to technology and culture.
// 2. **Writing Assistance**: I can help you draft emails, essays, reports, and creative writing pieces.
// 3. **Learning Support**: I can explain concepts, help with homework, and provide study tips.
// 4. **Language Help**: I can assist with translations, grammar, and vocabulary in multiple languages.
// 5. **Recommendations**: I can suggest books, movies, recipes, and more based on your interests.
// 6. **General Advice**: I can offer tips on various subjects, including productivity, wellness, and personal development.
// If you have something specific in mind, feel free to ask!`,
// },
// ];
function Title({ className }: { className?: string }) { function Title({ className }: { className?: string }) {
return ( return (
@@ -40,11 +26,26 @@ function Title({ className }: { className?: string }) {
); );
} }
function NewThread() {
const [_, setThreadId] = useQueryParam("threadId", StringParam);
return (
<TooltipIconButton
size="lg"
className="p-4"
tooltip="New thread"
variant="ghost"
onClick={() => setThreadId(null)}
>
<SquarePen className="size-5" />
</TooltipIconButton>
);
}
export function Thread() { export function Thread() {
const [input, setInput] = useState(""); const [input, setInput] = useState("");
const [firstTokenReceived, setFirstTokenReceived] = useState(false); const [firstTokenReceived, setFirstTokenReceived] = useState(false);
const stream = useStreamContext(); const stream = useStreamContext();
// const messages = [...dummyMessages, ...stream.messages];
const messages = stream.messages; const messages = stream.messages;
const isLoading = stream.isLoading; const isLoading = stream.isLoading;
const prevMessageLength = useRef(0); const prevMessageLength = useRef(0);
@@ -105,7 +106,8 @@ export function Thread() {
</div> </div>
)} )}
{chatStarted && ( {chatStarted && (
<div className="hidden md:flex absolute top-4 right-4"> <div className="hidden md:flex items-center gap-3 absolute top-4 right-4">
<NewThread />
<Title /> <Title />
</div> </div>
)} )}

View File

@@ -2,9 +2,16 @@ import { createRoot } from "react-dom/client";
import "./index.css"; import "./index.css";
import App from "./App.tsx"; import App from "./App.tsx";
import { StreamProvider } from "./providers/Stream.tsx"; import { StreamProvider } from "./providers/Stream.tsx";
import { QueryParamProvider } from "use-query-params";
import { ReactRouter6Adapter } from "use-query-params/adapters/react-router-6";
import { BrowserRouter } from "react-router-dom";
createRoot(document.getElementById("root")!).render( createRoot(document.getElementById("root")!).render(
<BrowserRouter>
<QueryParamProvider adapter={ReactRouter6Adapter}>
<StreamProvider> <StreamProvider>
<App /> <App />
</StreamProvider>, </StreamProvider>
</QueryParamProvider>
</BrowserRouter>,
); );

View File

@@ -1,10 +1,11 @@
import React, { createContext, useContext, ReactNode } from "react"; import React, { createContext, useContext, ReactNode } from "react";
import { useStream } from "@langchain/langgraph-sdk/react"; import { useStream } from "@langchain/langgraph-sdk/react";
import type { Message } from "@langchain/langgraph-sdk"; import { type Message } from "@langchain/langgraph-sdk";
import type { import type {
UIMessage, UIMessage,
RemoveUIMessage, RemoveUIMessage,
} from "@langchain/langgraph-sdk/react-ui/types"; } from "@langchain/langgraph-sdk/react-ui/types";
import { useQueryParam, StringParam } from "use-query-params";
const useTypedStream = useStream< const useTypedStream = useStream<
{ messages: Message[]; ui: UIMessage[] }, { messages: Message[]; ui: UIMessage[] },
@@ -23,11 +24,18 @@ const StreamContext = createContext<StreamContextType | undefined>(undefined);
export const StreamProvider: React.FC<{ children: ReactNode }> = ({ export const StreamProvider: React.FC<{ children: ReactNode }> = ({
children, children,
}) => { }) => {
const [threadId, setThreadId] = useQueryParam("threadId", StringParam);
const streamValue = useTypedStream({ const streamValue = useTypedStream({
apiUrl: "http://localhost:2024", apiUrl: "http://localhost:2024",
assistantId: "agent", assistantId: "agent",
threadId: threadId ?? null,
onThreadId: setThreadId,
}); });
console.log("threadId", threadId);
console.log("streamValue", streamValue.values);
return ( return (
<StreamContext.Provider value={streamValue}> <StreamContext.Provider value={streamValue}>
{children} {children}