(null);
- const { urlSessionId, setUrlSessionId } = useCopilotSessionId();
- const setIsStreaming = useCopilotStore((s) => s.setIsStreaming);
- const isCreating = useCopilotStore((s) => s.isCreatingSession);
- const setIsCreating = useCopilotStore((s) => s.setIsCreatingSession);
+ const {
+ sessionId,
+ setSessionId,
+ hydratedMessages,
+ isLoadingSession,
+ createSession,
+ isCreatingSession,
+ } = useChatSession();
- const greetingName = getGreetingName(user);
- const quickActions = getQuickActions();
+ const breakpoint = useBreakpoint();
+ const isMobile =
+ breakpoint === "base" || breakpoint === "sm" || breakpoint === "md";
- const hasSession = Boolean(urlSessionId);
- const initialPrompt = urlSessionId
- ? getInitialPrompt(urlSessionId)
- : undefined;
+ const transport = useMemo(
+ () =>
+ sessionId
+ ? new DefaultChatTransport({
+ api: `/api/chat/sessions/${sessionId}/stream`,
+ prepareSendMessagesRequest: ({ messages }) => {
+ const last = messages[messages.length - 1];
+ return {
+ body: {
+ message: (
+ last.parts?.map((p) => (p.type === "text" ? p.text : "")) ??
+ []
+ ).join(""),
+ is_user_message: last.role === "user",
+ context: null,
+ },
+ };
+ },
+ })
+ : null,
+ [sessionId],
+ );
+
+ const { messages, sendMessage, stop, status, error, setMessages } = useChat({
+ id: sessionId ?? undefined,
+ transport: transport ?? undefined,
+ });
+
+ // Abort the stream if the backend doesn't start sending data within 12s.
+ const stopRef = useRef(stop);
+ stopRef.current = stop;
+ useEffect(() => {
+ if (status !== "submitted") return;
+
+ const timer = setTimeout(() => {
+ stopRef.current();
+ toast({
+ title: "Stream timed out",
+ description: "The server took too long to respond. Please try again.",
+ variant: "destructive",
+ });
+ }, STREAM_START_TIMEOUT_MS);
+
+ return () => clearTimeout(timer);
+ }, [status]);
useEffect(() => {
- if (isLoggedIn) completeStep("VISIT_COPILOT");
- }, [completeStep, isLoggedIn]);
+ if (!hydratedMessages || hydratedMessages.length === 0) return;
+ setMessages((prev) => {
+ if (prev.length >= hydratedMessages.length) return prev;
+ return hydratedMessages;
+ });
+ }, [hydratedMessages, setMessages]);
- async function startChatWithPrompt(prompt: string) {
- if (!prompt?.trim()) return;
- if (isCreating) return;
+ // Poll session endpoint when a long-running tool (create_agent, edit_agent)
+ // is in progress. When the backend completes, the session data will contain
+ // the final tool output — this hook detects the change and updates messages.
+ useLongRunningToolPolling(sessionId, messages, setMessages);
- const trimmedPrompt = prompt.trim();
- setIsCreating(true);
+ // Clear messages when session is null
+ useEffect(() => {
+ if (!sessionId) setMessages([]);
+ }, [sessionId, setMessages]);
- try {
- const sessionResponse = await postV2CreateSession({
- body: JSON.stringify({}),
- });
+ useEffect(() => {
+ if (!sessionId || !pendingMessage) return;
+ const msg = pendingMessage;
+ setPendingMessage(null);
+ sendMessage({ text: msg });
+ }, [sessionId, pendingMessage, sendMessage]);
- if (sessionResponse.status !== 200 || !sessionResponse.data?.id) {
- throw new Error("Failed to create session");
- }
+ async function onSend(message: string) {
+ const trimmed = message.trim();
+ if (!trimmed) return;
- const sessionId = sessionResponse.data.id;
- setInitialPrompt(sessionId, trimmedPrompt);
-
- await queryClient.invalidateQueries({
- queryKey: getGetV2ListSessionsQueryKey(),
- });
-
- await setUrlSessionId(sessionId, { shallow: true });
- } catch (error) {
- console.error("[CopilotPage] Failed to start chat:", error);
- toast({ title: "Failed to start chat", variant: "destructive" });
- Sentry.captureException(error);
- } finally {
- setIsCreating(false);
+ if (sessionId) {
+ sendMessage({ text: trimmed });
+ return;
}
+
+ setPendingMessage(trimmed);
+ await createSession();
}
- function handleQuickAction(action: string) {
- startChatWithPrompt(action);
+ const { data: sessionsResponse, isLoading: isLoadingSessions } =
+ useGetV2ListSessions(
+ { limit: 50 },
+ { query: { enabled: !isUserLoading && isLoggedIn } },
+ );
+
+ const sessions =
+ sessionsResponse?.status === 200 ? sessionsResponse.data.sessions : [];
+
+ function handleOpenDrawer() {
+ setIsDrawerOpen(true);
}
- function handleSessionNotFound() {
- router.replace("/copilot");
+ function handleCloseDrawer() {
+ setIsDrawerOpen(false);
}
- function handleStreamingChange(isStreamingValue: boolean) {
- setIsStreaming(isStreamingValue);
+ function handleDrawerOpenChange(open: boolean) {
+ setIsDrawerOpen(open);
+ }
+
+ function handleSelectSession(id: string) {
+ setSessionId(id);
+ if (isMobile) setIsDrawerOpen(false);
+ }
+
+ function handleNewChat() {
+ setSessionId(null);
+ if (isMobile) setIsDrawerOpen(false);
}
return {
- state: {
- greetingName,
- quickActions,
- isLoading: isUserLoading,
- hasSession,
- initialPrompt,
- },
- handlers: {
- handleQuickAction,
- startChatWithPrompt,
- handleSessionNotFound,
- handleStreamingChange,
- },
+ sessionId,
+ messages,
+ status,
+ error,
+ stop,
+ isLoadingSession,
+ isCreatingSession,
+ isUserLoading,
+ isLoggedIn,
+ createSession,
+ onSend,
+ // Mobile drawer
+ isMobile,
+ isDrawerOpen,
+ sessions,
+ isLoadingSessions,
+ handleOpenDrawer,
+ handleCloseDrawer,
+ handleDrawerOpenChange,
+ handleSelectSession,
+ handleNewChat,
};
}
-
-function getInitialPrompt(sessionId: string): string | undefined {
- try {
- const prompts = JSON.parse(
- sessionStorage.get(SessionKey.CHAT_INITIAL_PROMPTS) || "{}",
- );
- return prompts[sessionId];
- } catch {
- return undefined;
- }
-}
-
-function setInitialPrompt(sessionId: string, prompt: string): void {
- try {
- const prompts = JSON.parse(
- sessionStorage.get(SessionKey.CHAT_INITIAL_PROMPTS) || "{}",
- );
- prompts[sessionId] = prompt;
- sessionStorage.set(
- SessionKey.CHAT_INITIAL_PROMPTS,
- JSON.stringify(prompts),
- );
- } catch {
- // Ignore storage errors
- }
-}
diff --git a/autogpt_platform/frontend/src/app/(platform)/copilot/useCopilotSessionId.ts b/autogpt_platform/frontend/src/app/(platform)/copilot/useCopilotSessionId.ts
deleted file mode 100644
index 87f9b7d3ae..0000000000
--- a/autogpt_platform/frontend/src/app/(platform)/copilot/useCopilotSessionId.ts
+++ /dev/null
@@ -1,10 +0,0 @@
-import { parseAsString, useQueryState } from "nuqs";
-
-export function useCopilotSessionId() {
- const [urlSessionId, setUrlSessionId] = useQueryState(
- "sessionId",
- parseAsString,
- );
-
- return { urlSessionId, setUrlSessionId };
-}
diff --git a/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/NewAgentLibraryView/components/selected-views/RunDetailHeader/RunDetailHeader.tsx b/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/NewAgentLibraryView/components/selected-views/RunDetailHeader/RunDetailHeader.tsx
index 3d04234bb3..4e98c70de5 100644
--- a/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/NewAgentLibraryView/components/selected-views/RunDetailHeader/RunDetailHeader.tsx
+++ b/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/NewAgentLibraryView/components/selected-views/RunDetailHeader/RunDetailHeader.tsx
@@ -2,7 +2,7 @@ import { GraphExecution } from "@/app/api/__generated__/models/graphExecution";
import { LibraryAgent } from "@/app/api/__generated__/models/libraryAgent";
import { Text } from "@/components/atoms/Text/Text";
import { ClockClockwiseIcon } from "@phosphor-icons/react";
-import moment from "moment";
+import { formatDistanceToNow, formatDistanceStrict } from "date-fns";
import { AGENT_LIBRARY_SECTION_PADDING_X } from "../../../helpers";
import { RunStatusBadge } from "../SelectedRunView/components/RunStatusBadge";
@@ -43,7 +43,10 @@ export function RunDetailHeader({ agent, run, scheduleRecurrence }: Props) {
{run ? (
- Started {moment(run.started_at).fromNow()}
+ Started{" "}
+ {run.started_at
+ ? formatDistanceToNow(run.started_at, { addSuffix: true })
+ : "—"}
|
@@ -62,7 +65,7 @@ export function RunDetailHeader({ agent, run, scheduleRecurrence }: Props) {
|
Duration:{" "}
- {moment.duration(run.stats.duration, "seconds").humanize()}
+ {formatDistanceStrict(0, run.stats.duration * 1000)}
)}
diff --git a/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/NewAgentLibraryView/components/sidebar/SidebarRunsList/components/ScheduleListItem.tsx b/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/NewAgentLibraryView/components/sidebar/SidebarRunsList/components/ScheduleListItem.tsx
index a389fb4fc8..1ad40fcef4 100644
--- a/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/NewAgentLibraryView/components/sidebar/SidebarRunsList/components/ScheduleListItem.tsx
+++ b/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/NewAgentLibraryView/components/sidebar/SidebarRunsList/components/ScheduleListItem.tsx
@@ -3,7 +3,7 @@
import { GraphExecutionJobInfo } from "@/app/api/__generated__/models/graphExecutionJobInfo";
import { LibraryAgent } from "@/app/api/__generated__/models/libraryAgent";
import { ClockClockwiseIcon } from "@phosphor-icons/react";
-import moment from "moment";
+import { formatDistanceToNow } from "date-fns";
import { IconWrapper } from "./IconWrapper";
import { ScheduleActionsDropdown } from "./ScheduleActionsDropdown";
import { SidebarItemCard } from "./SidebarItemCard";
@@ -26,7 +26,9 @@ export function ScheduleListItem({
return (
}
title={template.name}
- description={moment(template.updated_at).fromNow()}
+ description={formatDistanceToNow(template.updated_at, {
+ addSuffix: true,
+ })}
onClick={onClick}
selected={selected}
actions={
diff --git a/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/NewAgentLibraryView/components/sidebar/SidebarRunsList/components/TriggerListItem.tsx b/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/NewAgentLibraryView/components/sidebar/SidebarRunsList/components/TriggerListItem.tsx
index 4c399e640a..c7b0473a9b 100644
--- a/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/NewAgentLibraryView/components/sidebar/SidebarRunsList/components/TriggerListItem.tsx
+++ b/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/NewAgentLibraryView/components/sidebar/SidebarRunsList/components/TriggerListItem.tsx
@@ -3,7 +3,7 @@
import { LibraryAgent } from "@/app/api/__generated__/models/libraryAgent";
import { LibraryAgentPreset } from "@/app/api/__generated__/models/libraryAgentPreset";
import { LightningIcon } from "@phosphor-icons/react";
-import moment from "moment";
+import { formatDistanceToNow } from "date-fns";
import { IconWrapper } from "./IconWrapper";
import { SidebarItemCard } from "./SidebarItemCard";
import { TriggerActionsDropdown } from "./TriggerActionsDropdown";
@@ -31,7 +31,7 @@ export function TriggerListItem({
}
title={trigger.name}
- description={moment(trigger.updated_at).fromNow()}
+ description={formatDistanceToNow(trigger.updated_at, { addSuffix: true })}
onClick={onClick}
selected={selected}
actions={
diff --git a/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/OldAgentLibraryView/components/agent-run-details-view.tsx b/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/OldAgentLibraryView/components/agent-run-details-view.tsx
index f51c44c243..eb5224c958 100644
--- a/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/OldAgentLibraryView/components/agent-run-details-view.tsx
+++ b/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/OldAgentLibraryView/components/agent-run-details-view.tsx
@@ -1,5 +1,5 @@
"use client";
-import moment from "moment";
+import { format, formatDistanceToNow, formatDistanceStrict } from "date-fns";
import React, { useCallback, useMemo, useEffect } from "react";
import {
@@ -90,13 +90,15 @@ export function AgentRunDetailsView({
},
{
label: "Started",
- value: `${moment(run.started_at).fromNow()}, ${moment(run.started_at).format("HH:mm")}`,
+ value: run.started_at
+ ? `${formatDistanceToNow(run.started_at, { addSuffix: true })}, ${format(run.started_at, "HH:mm")}`
+ : "—",
},
...(run.stats
? [
{
label: "Duration",
- value: moment.duration(run.stats.duration, "seconds").humanize(),
+ value: formatDistanceStrict(0, run.stats.duration * 1000),
},
{ label: "Steps", value: run.stats.node_exec_count },
{ label: "Cost", value: formatCredits(run.stats.cost) },
diff --git a/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/OldAgentLibraryView/components/agent-run-summary-card.tsx b/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/OldAgentLibraryView/components/agent-run-summary-card.tsx
index 423495878b..6f7d7865bc 100644
--- a/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/OldAgentLibraryView/components/agent-run-summary-card.tsx
+++ b/autogpt_platform/frontend/src/app/(platform)/library/agents/[id]/components/OldAgentLibraryView/components/agent-run-summary-card.tsx
@@ -1,5 +1,5 @@
import React from "react";
-import moment from "moment";
+import { formatDistanceToNow, isPast } from "date-fns";
import { cn } from "@/lib/utils";
@@ -118,10 +118,10 @@ export function AgentRunSummaryCard({
{timestamp && (
- {moment(timestamp).isBefore() ? "Ran" : "Runs in"}{" "}
- {moment(timestamp).fromNow()}
+ {isPast(timestamp) ? "Ran" : "Runs in"}{" "}
+ {formatDistanceToNow(timestamp, { addSuffix: true })}
)}
diff --git a/autogpt_platform/frontend/src/app/(platform)/library/components/LibrarySearchBar/useLibrarySearchbar.tsx b/autogpt_platform/frontend/src/app/(platform)/library/components/LibrarySearchBar/useLibrarySearchbar.tsx
index 74b8e9874c..efeb654ed5 100644
--- a/autogpt_platform/frontend/src/app/(platform)/library/components/LibrarySearchBar/useLibrarySearchbar.tsx
+++ b/autogpt_platform/frontend/src/app/(platform)/library/components/LibrarySearchBar/useLibrarySearchbar.tsx
@@ -1,4 +1,4 @@
-import { debounce } from "lodash";
+import debounce from "lodash/debounce";
import { useCallback, useEffect } from "react";
interface Props {
diff --git a/autogpt_platform/frontend/src/app/(platform)/monitoring/components/AgentFlowList.tsx b/autogpt_platform/frontend/src/app/(platform)/monitoring/components/AgentFlowList.tsx
index badba61bf1..a306275f10 100644
--- a/autogpt_platform/frontend/src/app/(platform)/monitoring/components/AgentFlowList.tsx
+++ b/autogpt_platform/frontend/src/app/(platform)/monitoring/components/AgentFlowList.tsx
@@ -30,7 +30,7 @@ import {
TableHeader,
TableRow,
} from "@/components/__legacy__/ui/table";
-import moment from "moment/moment";
+import { formatDistanceToNow } from "date-fns";
import { DialogTitle } from "@/components/__legacy__/ui/dialog";
import { AgentImportForm } from "./AgentImportForm";
@@ -161,8 +161,12 @@ export const AgentFlowList = ({
(!lastRun ? (
) : (
-
- {moment(lastRun.started_at).fromNow()}
+
+ {lastRun.started_at
+ ? formatDistanceToNow(lastRun.started_at, {
+ addSuffix: true,
+ })
+ : "—"}
))}
diff --git a/autogpt_platform/frontend/src/app/(platform)/monitoring/components/FlowRunInfo.tsx b/autogpt_platform/frontend/src/app/(platform)/monitoring/components/FlowRunInfo.tsx
index e619c2fd3d..0fdf39e8d9 100644
--- a/autogpt_platform/frontend/src/app/(platform)/monitoring/components/FlowRunInfo.tsx
+++ b/autogpt_platform/frontend/src/app/(platform)/monitoring/components/FlowRunInfo.tsx
@@ -10,7 +10,7 @@ import Link from "next/link";
import { Button, buttonVariants } from "@/components/__legacy__/ui/button";
import { IconSquare } from "@/components/__legacy__/ui/icons";
import { ExitIcon, Pencil2Icon } from "@radix-ui/react-icons";
-import moment from "moment/moment";
+import { format } from "date-fns";
import { FlowRunStatusBadge } from "@/app/(platform)/monitoring/components/FlowRunStatusBadge";
import { useBackendAPI } from "@/lib/autogpt-server-api/context";
import RunnerOutputUI, {
@@ -111,11 +111,15 @@ export const FlowRunInfo: React.FC<
Started:{" "}
- {moment(execution.started_at).format("YYYY-MM-DD HH:mm:ss")}
+ {execution.started_at
+ ? format(execution.started_at, "yyyy-MM-dd HH:mm:ss")
+ : "—"}
Finished:{" "}
- {moment(execution.ended_at).format("YYYY-MM-DD HH:mm:ss")}
+ {execution.ended_at
+ ? format(execution.ended_at, "yyyy-MM-dd HH:mm:ss")
+ : "—"}
{execution.stats && (
diff --git a/autogpt_platform/frontend/src/app/(platform)/monitoring/components/FlowRunsList.tsx b/autogpt_platform/frontend/src/app/(platform)/monitoring/components/FlowRunsList.tsx
index a99d9309b5..c4a2a40447 100644
--- a/autogpt_platform/frontend/src/app/(platform)/monitoring/components/FlowRunsList.tsx
+++ b/autogpt_platform/frontend/src/app/(platform)/monitoring/components/FlowRunsList.tsx
@@ -14,7 +14,7 @@ import {
TableHeader,
TableRow,
} from "@/components/__legacy__/ui/table";
-import moment from "moment/moment";
+import { format } from "date-fns";
import { FlowRunStatusBadge } from "@/app/(platform)/monitoring/components/FlowRunStatusBadge";
import { TextRenderer } from "../../../../components/__legacy__/ui/render";
@@ -59,7 +59,9 @@ export const FlowRunsList: React.FC<{
/>
- {moment(execution.started_at).format("HH:mm")}
+ {execution.started_at
+ ? format(execution.started_at, "HH:mm")
+ : "—"}
{
- const now = moment();
- const time = moment(unixTime);
- return now.diff(time, "hours") < 24
- ? time.format("HH:mm")
- : time.format("YYYY-MM-DD HH:mm");
+ const now = new Date();
+ const time = new Date(unixTime);
+ return differenceInHours(now, time) < 24
+ ? format(time, "HH:mm")
+ : format(time, "yyyy-MM-dd HH:mm");
}}
name="Time"
scale="time"
@@ -79,7 +79,9 @@ export const FlowRunsTimeline = ({
Started:{" "}
- {moment(data.started_at).format("YYYY-MM-DD HH:mm:ss")}
+ {data.started_at
+ ? format(data.started_at, "yyyy-MM-dd HH:mm:ss")
+ : "—"}
{data.stats && (
diff --git a/autogpt_platform/frontend/src/app/api/chat/sessions/[sessionId]/stream/route.ts b/autogpt_platform/frontend/src/app/api/chat/sessions/[sessionId]/stream/route.ts
index d63eed0ca2..bd27c77963 100644
--- a/autogpt_platform/frontend/src/app/api/chat/sessions/[sessionId]/stream/route.ts
+++ b/autogpt_platform/frontend/src/app/api/chat/sessions/[sessionId]/stream/route.ts
@@ -1,11 +1,8 @@
import { environment } from "@/services/environment";
import { getServerAuthToken } from "@/lib/autogpt-server-api/helpers";
import { NextRequest } from "next/server";
+import { normalizeSSEStream, SSE_HEADERS } from "../../../sse-helpers";
-/**
- * SSE Proxy for chat streaming.
- * Supports POST with context (page content + URL) in the request body.
- */
export async function POST(
request: NextRequest,
{ params }: { params: Promise<{ sessionId: string }> },
@@ -23,17 +20,14 @@ export async function POST(
);
}
- // Get auth token from server-side session
const token = await getServerAuthToken();
- // Build backend URL
const backendUrl = environment.getAGPTServerBaseUrl();
const streamUrl = new URL(
`/api/chat/sessions/${sessionId}/stream`,
backendUrl,
);
- // Forward request to backend with auth header
const headers: Record = {
"Content-Type": "application/json",
Accept: "text/event-stream",
@@ -63,14 +57,15 @@ export async function POST(
});
}
- // Return the SSE stream directly
- return new Response(response.body, {
- headers: {
- "Content-Type": "text/event-stream",
- "Cache-Control": "no-cache, no-transform",
- Connection: "keep-alive",
- "X-Accel-Buffering": "no",
- },
+ if (!response.body) {
+ return new Response(
+ JSON.stringify({ error: "Empty response from chat service" }),
+ { status: 502, headers: { "Content-Type": "application/json" } },
+ );
+ }
+
+ return new Response(normalizeSSEStream(response.body), {
+ headers: SSE_HEADERS,
});
} catch (error) {
console.error("SSE proxy error:", error);
@@ -87,40 +82,21 @@ export async function POST(
}
}
-/**
- * Legacy GET endpoint for backward compatibility
- */
export async function GET(
- request: NextRequest,
+ _request: NextRequest,
{ params }: { params: Promise<{ sessionId: string }> },
) {
const { sessionId } = await params;
- const searchParams = request.nextUrl.searchParams;
- const message = searchParams.get("message");
- const isUserMessage = searchParams.get("is_user_message");
-
- if (!message) {
- return new Response("Missing message parameter", { status: 400 });
- }
try {
- // Get auth token from server-side session
const token = await getServerAuthToken();
- // Build backend URL
const backendUrl = environment.getAGPTServerBaseUrl();
const streamUrl = new URL(
`/api/chat/sessions/${sessionId}/stream`,
backendUrl,
);
- streamUrl.searchParams.set("message", message);
- // Pass is_user_message parameter if provided
- if (isUserMessage !== null) {
- streamUrl.searchParams.set("is_user_message", isUserMessage);
- }
-
- // Forward request to backend with auth header
const headers: Record = {
Accept: "text/event-stream",
"Cache-Control": "no-cache",
@@ -136,6 +112,10 @@ export async function GET(
headers,
});
+ if (response.status === 204) {
+ return new Response(null, { status: 204 });
+ }
+
if (!response.ok) {
const error = await response.text();
return new Response(error, {
@@ -144,17 +124,18 @@ export async function GET(
});
}
- // Return the SSE stream directly
- return new Response(response.body, {
+ if (!response.body) {
+ return new Response(null, { status: 204 });
+ }
+
+ return new Response(normalizeSSEStream(response.body), {
headers: {
- "Content-Type": "text/event-stream",
- "Cache-Control": "no-cache, no-transform",
- Connection: "keep-alive",
- "X-Accel-Buffering": "no",
+ ...SSE_HEADERS,
+ "x-vercel-ai-ui-message-stream": "v1",
},
});
} catch (error) {
- console.error("SSE proxy error:", error);
+ console.error("Resume stream proxy error:", error);
return new Response(
JSON.stringify({
error: "Failed to connect to chat service",
diff --git a/autogpt_platform/frontend/src/app/api/chat/sse-helpers.ts b/autogpt_platform/frontend/src/app/api/chat/sse-helpers.ts
new file mode 100644
index 0000000000..a5c76cf872
--- /dev/null
+++ b/autogpt_platform/frontend/src/app/api/chat/sse-helpers.ts
@@ -0,0 +1,72 @@
+export const SSE_HEADERS = {
+ "Content-Type": "text/event-stream",
+ "Cache-Control": "no-cache, no-transform",
+ Connection: "keep-alive",
+ "X-Accel-Buffering": "no",
+} as const;
+
+export function normalizeSSEStream(
+ input: ReadableStream,
+): ReadableStream {
+ const decoder = new TextDecoder();
+ const encoder = new TextEncoder();
+ let buffer = "";
+
+ return input.pipeThrough(
+ new TransformStream({
+ transform(chunk, controller) {
+ buffer += decoder.decode(chunk, { stream: true });
+
+ const parts = buffer.split("\n\n");
+ buffer = parts.pop() ?? "";
+
+ for (const part of parts) {
+ const normalized = normalizeSSEEvent(part);
+ controller.enqueue(encoder.encode(normalized + "\n\n"));
+ }
+ },
+ flush(controller) {
+ if (buffer.trim()) {
+ const normalized = normalizeSSEEvent(buffer);
+ controller.enqueue(encoder.encode(normalized + "\n\n"));
+ }
+ },
+ }),
+ );
+}
+
+function normalizeSSEEvent(event: string): string {
+ const lines = event.split("\n");
+ const dataLines: string[] = [];
+ const otherLines: string[] = [];
+
+ for (const line of lines) {
+ if (line.startsWith("data: ")) {
+ dataLines.push(line.slice(6));
+ } else {
+ otherLines.push(line);
+ }
+ }
+
+ if (dataLines.length === 0) return event;
+
+ const dataStr = dataLines.join("\n");
+ try {
+ const parsed = JSON.parse(dataStr) as Record;
+ if (parsed.type === "error") {
+ const normalized = {
+ type: "error",
+ errorText:
+ typeof parsed.errorText === "string"
+ ? parsed.errorText
+ : "An unexpected error occurred",
+ };
+ const newData = `data: ${JSON.stringify(normalized)}`;
+ return [...otherLines.filter((l) => l.length > 0), newData].join("\n");
+ }
+ } catch {
+ // Not valid JSON — pass through as-is
+ }
+
+ return event;
+}
diff --git a/autogpt_platform/frontend/src/app/api/chat/tasks/[taskId]/stream/route.ts b/autogpt_platform/frontend/src/app/api/chat/tasks/[taskId]/stream/route.ts
index 336786bfdb..238fdebb06 100644
--- a/autogpt_platform/frontend/src/app/api/chat/tasks/[taskId]/stream/route.ts
+++ b/autogpt_platform/frontend/src/app/api/chat/tasks/[taskId]/stream/route.ts
@@ -1,20 +1,8 @@
import { environment } from "@/services/environment";
import { getServerAuthToken } from "@/lib/autogpt-server-api/helpers";
import { NextRequest } from "next/server";
+import { normalizeSSEStream, SSE_HEADERS } from "../../../sse-helpers";
-/**
- * SSE Proxy for task stream reconnection.
- *
- * This endpoint allows clients to reconnect to an ongoing or recently completed
- * background task's stream. It replays missed messages from Redis Streams and
- * subscribes to live updates if the task is still running.
- *
- * Client contract:
- * 1. When receiving an operation_started event, store the task_id
- * 2. To reconnect: GET /api/chat/tasks/{taskId}/stream?last_message_id={idx}
- * 3. Messages are replayed from the last_message_id position
- * 4. Stream ends when "finish" event is received
- */
export async function GET(
request: NextRequest,
{ params }: { params: Promise<{ taskId: string }> },
@@ -24,15 +12,12 @@ export async function GET(
const lastMessageId = searchParams.get("last_message_id") || "0-0";
try {
- // Get auth token from server-side session
const token = await getServerAuthToken();
- // Build backend URL
const backendUrl = environment.getAGPTServerBaseUrl();
const streamUrl = new URL(`/api/chat/tasks/${taskId}/stream`, backendUrl);
streamUrl.searchParams.set("last_message_id", lastMessageId);
- // Forward request to backend with auth header
const headers: Record = {
Accept: "text/event-stream",
"Cache-Control": "no-cache",
@@ -56,14 +41,12 @@ export async function GET(
});
}
- // Return the SSE stream directly
- return new Response(response.body, {
- headers: {
- "Content-Type": "text/event-stream",
- "Cache-Control": "no-cache, no-transform",
- Connection: "keep-alive",
- "X-Accel-Buffering": "no",
- },
+ if (!response.body) {
+ return new Response(null, { status: 204 });
+ }
+
+ return new Response(normalizeSSEStream(response.body), {
+ headers: SSE_HEADERS,
});
} catch (error) {
console.error("Task stream proxy error:", error);
diff --git a/autogpt_platform/frontend/src/app/api/openapi.json b/autogpt_platform/frontend/src/app/api/openapi.json
index ccf5ad3e34..5d2cb83f7c 100644
--- a/autogpt_platform/frontend/src/app/api/openapi.json
+++ b/autogpt_platform/frontend/src/app/api/openapi.json
@@ -1018,6 +1018,58 @@
}
}
},
+ "/api/chat/schema/tool-responses": {
+ "get": {
+ "tags": ["v2", "chat", "chat"],
+ "summary": "[Dummy] Tool response type export for codegen",
+ "description": "This endpoint is not meant to be called. It exists solely to expose tool response models in the OpenAPI schema for frontend codegen.",
+ "operationId": "getV2[dummy] tool response type export for codegen",
+ "responses": {
+ "200": {
+ "description": "Successful Response",
+ "content": {
+ "application/json": {
+ "schema": {
+ "anyOf": [
+ { "$ref": "#/components/schemas/AgentsFoundResponse" },
+ { "$ref": "#/components/schemas/NoResultsResponse" },
+ { "$ref": "#/components/schemas/AgentDetailsResponse" },
+ {
+ "$ref": "#/components/schemas/SetupRequirementsResponse"
+ },
+ { "$ref": "#/components/schemas/ExecutionStartedResponse" },
+ { "$ref": "#/components/schemas/NeedLoginResponse" },
+ { "$ref": "#/components/schemas/ErrorResponse" },
+ {
+ "$ref": "#/components/schemas/InputValidationErrorResponse"
+ },
+ { "$ref": "#/components/schemas/AgentOutputResponse" },
+ {
+ "$ref": "#/components/schemas/UnderstandingUpdatedResponse"
+ },
+ { "$ref": "#/components/schemas/AgentPreviewResponse" },
+ { "$ref": "#/components/schemas/AgentSavedResponse" },
+ {
+ "$ref": "#/components/schemas/ClarificationNeededResponse"
+ },
+ { "$ref": "#/components/schemas/BlockListResponse" },
+ { "$ref": "#/components/schemas/BlockOutputResponse" },
+ { "$ref": "#/components/schemas/DocSearchResultsResponse" },
+ { "$ref": "#/components/schemas/DocPageResponse" },
+ { "$ref": "#/components/schemas/OperationStartedResponse" },
+ { "$ref": "#/components/schemas/OperationPendingResponse" },
+ {
+ "$ref": "#/components/schemas/OperationInProgressResponse"
+ }
+ ],
+ "title": "Response Getv2[Dummy] Tool Response Type Export For Codegen"
+ }
+ }
+ }
+ }
+ }
+ }
+ },
"/api/chat/sessions": {
"get": {
"tags": ["v2", "chat", "chat"],
@@ -1182,9 +1234,9 @@
"/api/chat/sessions/{session_id}/stream": {
"get": {
"tags": ["v2", "chat", "chat"],
- "summary": "Stream Chat Get",
- "description": "Stream chat responses for a session (GET - legacy endpoint).\n\nStreams the AI/completion responses in real time over Server-Sent Events (SSE), including:\n - Text fragments as they are generated\n - Tool call UI elements (if invoked)\n - Tool execution results\n\nArgs:\n session_id: The chat session identifier to associate with the streamed messages.\n message: The user's new message to process.\n user_id: Optional authenticated user ID.\n is_user_message: Whether the message is a user message.\nReturns:\n StreamingResponse: SSE-formatted response chunks.",
- "operationId": "getV2StreamChatGet",
+ "summary": "Resume Session Stream",
+ "description": "Resume an active stream for a session.\n\nCalled by the AI SDK's ``useChat(resume: true)`` on page load.\nChecks for an active (in-progress) task on the session and either replays\nthe full SSE stream or returns 204 No Content if nothing is running.\n\nArgs:\n session_id: The chat session identifier.\n user_id: Optional authenticated user ID.\n\nReturns:\n StreamingResponse (SSE) when an active stream exists,\n or 204 No Content when there is nothing to resume.",
+ "operationId": "getV2ResumeSessionStream",
"security": [{ "HTTPBearerJWT": [] }],
"parameters": [
{
@@ -1192,27 +1244,6 @@
"in": "path",
"required": true,
"schema": { "type": "string", "title": "Session Id" }
- },
- {
- "name": "message",
- "in": "query",
- "required": true,
- "schema": {
- "type": "string",
- "minLength": 1,
- "maxLength": 10000,
- "title": "Message"
- }
- },
- {
- "name": "is_user_message",
- "in": "query",
- "required": false,
- "schema": {
- "type": "boolean",
- "default": true,
- "title": "Is User Message"
- }
}
],
"responses": {
@@ -6358,6 +6389,75 @@
"required": ["new_balance", "transaction_key"],
"title": "AddUserCreditsResponse"
},
+ "AgentDetails": {
+ "properties": {
+ "id": { "type": "string", "title": "Id" },
+ "name": { "type": "string", "title": "Name" },
+ "description": { "type": "string", "title": "Description" },
+ "in_library": {
+ "type": "boolean",
+ "title": "In Library",
+ "default": false
+ },
+ "inputs": {
+ "additionalProperties": true,
+ "type": "object",
+ "title": "Inputs",
+ "default": {}
+ },
+ "credentials": {
+ "items": { "$ref": "#/components/schemas/CredentialsMetaInput" },
+ "type": "array",
+ "title": "Credentials",
+ "default": []
+ },
+ "execution_options": {
+ "$ref": "#/components/schemas/ExecutionOptions"
+ },
+ "trigger_info": {
+ "anyOf": [
+ { "additionalProperties": true, "type": "object" },
+ { "type": "null" }
+ ],
+ "title": "Trigger Info"
+ }
+ },
+ "type": "object",
+ "required": ["id", "name", "description"],
+ "title": "AgentDetails",
+ "description": "Detailed agent information."
+ },
+ "AgentDetailsResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "agent_details"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "agent": { "$ref": "#/components/schemas/AgentDetails" },
+ "user_authenticated": {
+ "type": "boolean",
+ "title": "User Authenticated",
+ "default": false
+ },
+ "graph_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Graph Id"
+ },
+ "graph_version": {
+ "anyOf": [{ "type": "integer" }, { "type": "null" }],
+ "title": "Graph Version"
+ }
+ },
+ "type": "object",
+ "required": ["message", "agent"],
+ "title": "AgentDetailsResponse",
+ "description": "Response for get_details action."
+ },
"AgentExecutionStatus": {
"type": "string",
"enum": [
@@ -6371,6 +6471,224 @@
],
"title": "AgentExecutionStatus"
},
+ "AgentInfo": {
+ "properties": {
+ "id": { "type": "string", "title": "Id" },
+ "name": { "type": "string", "title": "Name" },
+ "description": { "type": "string", "title": "Description" },
+ "source": {
+ "type": "string",
+ "title": "Source",
+ "description": "marketplace or library"
+ },
+ "in_library": {
+ "type": "boolean",
+ "title": "In Library",
+ "default": false
+ },
+ "creator": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Creator"
+ },
+ "category": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Category"
+ },
+ "rating": {
+ "anyOf": [{ "type": "number" }, { "type": "null" }],
+ "title": "Rating"
+ },
+ "runs": {
+ "anyOf": [{ "type": "integer" }, { "type": "null" }],
+ "title": "Runs"
+ },
+ "is_featured": {
+ "anyOf": [{ "type": "boolean" }, { "type": "null" }],
+ "title": "Is Featured"
+ },
+ "status": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Status"
+ },
+ "can_access_graph": {
+ "anyOf": [{ "type": "boolean" }, { "type": "null" }],
+ "title": "Can Access Graph"
+ },
+ "has_external_trigger": {
+ "anyOf": [{ "type": "boolean" }, { "type": "null" }],
+ "title": "Has External Trigger"
+ },
+ "new_output": {
+ "anyOf": [{ "type": "boolean" }, { "type": "null" }],
+ "title": "New Output"
+ },
+ "graph_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Graph Id"
+ },
+ "inputs": {
+ "anyOf": [
+ { "additionalProperties": true, "type": "object" },
+ { "type": "null" }
+ ],
+ "title": "Inputs",
+ "description": "Input schema for the agent, including field names, types, and defaults"
+ }
+ },
+ "type": "object",
+ "required": ["id", "name", "description", "source"],
+ "title": "AgentInfo",
+ "description": "Information about an agent."
+ },
+ "AgentOutputResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "agent_output"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "agent_name": { "type": "string", "title": "Agent Name" },
+ "agent_id": { "type": "string", "title": "Agent Id" },
+ "library_agent_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Library Agent Id"
+ },
+ "library_agent_link": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Library Agent Link"
+ },
+ "execution": {
+ "anyOf": [
+ { "$ref": "#/components/schemas/ExecutionOutputInfo" },
+ { "type": "null" }
+ ]
+ },
+ "available_executions": {
+ "anyOf": [
+ {
+ "items": { "additionalProperties": true, "type": "object" },
+ "type": "array"
+ },
+ { "type": "null" }
+ ],
+ "title": "Available Executions"
+ },
+ "total_executions": {
+ "type": "integer",
+ "title": "Total Executions",
+ "default": 0
+ }
+ },
+ "type": "object",
+ "required": ["message", "agent_name", "agent_id"],
+ "title": "AgentOutputResponse",
+ "description": "Response for agent_output tool."
+ },
+ "AgentPreviewResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "agent_preview"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "agent_json": {
+ "additionalProperties": true,
+ "type": "object",
+ "title": "Agent Json"
+ },
+ "agent_name": { "type": "string", "title": "Agent Name" },
+ "description": { "type": "string", "title": "Description" },
+ "node_count": { "type": "integer", "title": "Node Count" },
+ "link_count": {
+ "type": "integer",
+ "title": "Link Count",
+ "default": 0
+ }
+ },
+ "type": "object",
+ "required": [
+ "message",
+ "agent_json",
+ "agent_name",
+ "description",
+ "node_count"
+ ],
+ "title": "AgentPreviewResponse",
+ "description": "Response for previewing a generated agent before saving."
+ },
+ "AgentSavedResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "agent_saved"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "agent_id": { "type": "string", "title": "Agent Id" },
+ "agent_name": { "type": "string", "title": "Agent Name" },
+ "library_agent_id": { "type": "string", "title": "Library Agent Id" },
+ "library_agent_link": {
+ "type": "string",
+ "title": "Library Agent Link"
+ },
+ "agent_page_link": { "type": "string", "title": "Agent Page Link" }
+ },
+ "type": "object",
+ "required": [
+ "message",
+ "agent_id",
+ "agent_name",
+ "library_agent_id",
+ "library_agent_link",
+ "agent_page_link"
+ ],
+ "title": "AgentSavedResponse",
+ "description": "Response when an agent is saved to the library."
+ },
+ "AgentsFoundResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "agents_found"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "title": {
+ "type": "string",
+ "title": "Title",
+ "default": "Available Agents"
+ },
+ "agents": {
+ "items": { "$ref": "#/components/schemas/AgentInfo" },
+ "type": "array",
+ "title": "Agents"
+ },
+ "count": { "type": "integer", "title": "Count" },
+ "name": {
+ "type": "string",
+ "title": "Name",
+ "default": "agents_found"
+ }
+ },
+ "type": "object",
+ "required": ["message", "agents", "count"],
+ "title": "AgentsFoundResponse",
+ "description": "Response for find_agent tool."
+ },
"ApiResponse": {
"properties": {
"answer": { "type": "string", "title": "Answer" },
@@ -6691,6 +7009,120 @@
],
"title": "BlockInfo"
},
+ "BlockInfoSummary": {
+ "properties": {
+ "id": { "type": "string", "title": "Id" },
+ "name": { "type": "string", "title": "Name" },
+ "description": { "type": "string", "title": "Description" },
+ "categories": {
+ "items": { "type": "string" },
+ "type": "array",
+ "title": "Categories"
+ },
+ "input_schema": {
+ "additionalProperties": true,
+ "type": "object",
+ "title": "Input Schema"
+ },
+ "output_schema": {
+ "additionalProperties": true,
+ "type": "object",
+ "title": "Output Schema"
+ },
+ "required_inputs": {
+ "items": { "$ref": "#/components/schemas/BlockInputFieldInfo" },
+ "type": "array",
+ "title": "Required Inputs",
+ "description": "List of required input fields for this block"
+ }
+ },
+ "type": "object",
+ "required": [
+ "id",
+ "name",
+ "description",
+ "categories",
+ "input_schema",
+ "output_schema"
+ ],
+ "title": "BlockInfoSummary",
+ "description": "Summary of a block for search results."
+ },
+ "BlockInputFieldInfo": {
+ "properties": {
+ "name": { "type": "string", "title": "Name" },
+ "type": { "type": "string", "title": "Type" },
+ "description": {
+ "type": "string",
+ "title": "Description",
+ "default": ""
+ },
+ "required": {
+ "type": "boolean",
+ "title": "Required",
+ "default": false
+ },
+ "default": { "anyOf": [{}, { "type": "null" }], "title": "Default" }
+ },
+ "type": "object",
+ "required": ["name", "type"],
+ "title": "BlockInputFieldInfo",
+ "description": "Information about a block input field."
+ },
+ "BlockListResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "block_list"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "blocks": {
+ "items": { "$ref": "#/components/schemas/BlockInfoSummary" },
+ "type": "array",
+ "title": "Blocks"
+ },
+ "count": { "type": "integer", "title": "Count" },
+ "query": { "type": "string", "title": "Query" },
+ "usage_hint": {
+ "type": "string",
+ "title": "Usage Hint",
+ "default": "To execute a block, call run_block with block_id set to the block's 'id' field and input_data containing the required fields from input_schema."
+ }
+ },
+ "type": "object",
+ "required": ["message", "blocks", "count", "query"],
+ "title": "BlockListResponse",
+ "description": "Response for find_block tool."
+ },
+ "BlockOutputResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "block_output"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "block_id": { "type": "string", "title": "Block Id" },
+ "block_name": { "type": "string", "title": "Block Name" },
+ "outputs": {
+ "additionalProperties": { "items": {}, "type": "array" },
+ "type": "object",
+ "title": "Outputs"
+ },
+ "success": { "type": "boolean", "title": "Success", "default": true }
+ },
+ "type": "object",
+ "required": ["message", "block_id", "block_name", "outputs"],
+ "title": "BlockOutputResponse",
+ "description": "Response for run_block tool."
+ },
"BlockResponse": {
"properties": {
"blocks": {
@@ -6937,6 +7369,42 @@
"required": ["query", "conversation_history", "message_id"],
"title": "ChatRequest"
},
+ "ClarificationNeededResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "clarification_needed"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "questions": {
+ "items": { "$ref": "#/components/schemas/ClarifyingQuestion" },
+ "type": "array",
+ "title": "Questions"
+ }
+ },
+ "type": "object",
+ "required": ["message"],
+ "title": "ClarificationNeededResponse",
+ "description": "Response when the LLM needs more information from the user."
+ },
+ "ClarifyingQuestion": {
+ "properties": {
+ "question": { "type": "string", "title": "Question" },
+ "keyword": { "type": "string", "title": "Keyword" },
+ "example": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Example"
+ }
+ },
+ "type": "object",
+ "required": ["question", "keyword"],
+ "title": "ClarifyingQuestion",
+ "description": "A question that needs user clarification."
+ },
"CountResponse": {
"properties": {
"all_blocks": { "type": "integer", "title": "All Blocks" },
@@ -7195,6 +7663,71 @@
"required": ["version_counts"],
"title": "DeleteGraphResponse"
},
+ "DocPageResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "doc_page"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "title": { "type": "string", "title": "Title" },
+ "path": { "type": "string", "title": "Path" },
+ "content": { "type": "string", "title": "Content" },
+ "doc_url": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Doc Url"
+ }
+ },
+ "type": "object",
+ "required": ["message", "title", "path", "content"],
+ "title": "DocPageResponse",
+ "description": "Response for get_doc_page tool."
+ },
+ "DocSearchResult": {
+ "properties": {
+ "title": { "type": "string", "title": "Title" },
+ "path": { "type": "string", "title": "Path" },
+ "section": { "type": "string", "title": "Section" },
+ "snippet": { "type": "string", "title": "Snippet" },
+ "score": { "type": "number", "title": "Score" },
+ "doc_url": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Doc Url"
+ }
+ },
+ "type": "object",
+ "required": ["title", "path", "section", "snippet", "score"],
+ "title": "DocSearchResult",
+ "description": "A single documentation search result."
+ },
+ "DocSearchResultsResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "doc_search_results"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "results": {
+ "items": { "$ref": "#/components/schemas/DocSearchResult" },
+ "type": "array",
+ "title": "Results"
+ },
+ "count": { "type": "integer", "title": "Count" },
+ "query": { "type": "string", "title": "Query" }
+ },
+ "type": "object",
+ "required": ["message", "results", "count", "query"],
+ "title": "DocSearchResultsResponse",
+ "description": "Response for search_docs tool."
+ },
"Document": {
"properties": {
"url": { "type": "string", "title": "Url" },
@@ -7204,6 +7737,34 @@
"required": ["url", "relevance_score"],
"title": "Document"
},
+ "ErrorResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "error"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "error": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Error"
+ },
+ "details": {
+ "anyOf": [
+ { "additionalProperties": true, "type": "object" },
+ { "type": "null" }
+ ],
+ "title": "Details"
+ }
+ },
+ "type": "object",
+ "required": ["message"],
+ "title": "ErrorResponse",
+ "description": "Response for errors."
+ },
"ExecutionAnalyticsConfig": {
"properties": {
"available_models": {
@@ -7380,6 +7941,85 @@
],
"title": "ExecutionAnalyticsResult"
},
+ "ExecutionOptions": {
+ "properties": {
+ "manual": { "type": "boolean", "title": "Manual", "default": true },
+ "scheduled": {
+ "type": "boolean",
+ "title": "Scheduled",
+ "default": true
+ },
+ "webhook": { "type": "boolean", "title": "Webhook", "default": false }
+ },
+ "type": "object",
+ "title": "ExecutionOptions",
+ "description": "Available execution options for an agent."
+ },
+ "ExecutionOutputInfo": {
+ "properties": {
+ "execution_id": { "type": "string", "title": "Execution Id" },
+ "status": { "type": "string", "title": "Status" },
+ "started_at": {
+ "anyOf": [
+ { "type": "string", "format": "date-time" },
+ { "type": "null" }
+ ],
+ "title": "Started At"
+ },
+ "ended_at": {
+ "anyOf": [
+ { "type": "string", "format": "date-time" },
+ { "type": "null" }
+ ],
+ "title": "Ended At"
+ },
+ "outputs": {
+ "additionalProperties": { "items": {}, "type": "array" },
+ "type": "object",
+ "title": "Outputs"
+ },
+ "inputs_summary": {
+ "anyOf": [
+ { "additionalProperties": true, "type": "object" },
+ { "type": "null" }
+ ],
+ "title": "Inputs Summary"
+ }
+ },
+ "type": "object",
+ "required": ["execution_id", "status", "outputs"],
+ "title": "ExecutionOutputInfo",
+ "description": "Summary of a single execution's outputs."
+ },
+ "ExecutionStartedResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "execution_started"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "execution_id": { "type": "string", "title": "Execution Id" },
+ "graph_id": { "type": "string", "title": "Graph Id" },
+ "graph_name": { "type": "string", "title": "Graph Name" },
+ "library_agent_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Library Agent Id"
+ },
+ "library_agent_link": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Library Agent Link"
+ },
+ "status": { "type": "string", "title": "Status", "default": "QUEUED" }
+ },
+ "type": "object",
+ "required": ["message", "execution_id", "graph_id", "graph_name"],
+ "title": "ExecutionStartedResponse",
+ "description": "Response for run/schedule actions."
+ },
"Graph": {
"properties": {
"id": { "type": "string", "title": "Id" },
@@ -8131,6 +8771,43 @@
"required": ["provider", "host"],
"title": "HostScopedCredentials"
},
+ "InputValidationErrorResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "input_validation_error"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "unrecognized_fields": {
+ "items": { "type": "string" },
+ "type": "array",
+ "title": "Unrecognized Fields",
+ "description": "List of input field names that were not recognized"
+ },
+ "inputs": {
+ "additionalProperties": true,
+ "type": "object",
+ "title": "Inputs",
+ "description": "The agent's valid input schema for reference"
+ },
+ "graph_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Graph Id"
+ },
+ "graph_version": {
+ "anyOf": [{ "type": "integer" }, { "type": "null" }],
+ "title": "Graph Version"
+ }
+ },
+ "type": "object",
+ "required": ["message", "unrecognized_fields", "inputs"],
+ "title": "InputValidationErrorResponse",
+ "description": "Response when run_agent receives unknown input fields."
+ },
"LibraryAgent": {
"properties": {
"id": { "type": "string", "title": "Id" },
@@ -8649,6 +9326,54 @@
"required": ["agents", "pagination"],
"title": "MyAgentsResponse"
},
+ "NeedLoginResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "need_login"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "agent_info": {
+ "anyOf": [
+ { "additionalProperties": true, "type": "object" },
+ { "type": "null" }
+ ],
+ "title": "Agent Info"
+ }
+ },
+ "type": "object",
+ "required": ["message"],
+ "title": "NeedLoginResponse",
+ "description": "Response when login is needed."
+ },
+ "NoResultsResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "no_results"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "suggestions": {
+ "items": { "type": "string" },
+ "type": "array",
+ "title": "Suggestions",
+ "default": []
+ },
+ "name": { "type": "string", "title": "Name", "default": "no_results" }
+ },
+ "type": "object",
+ "required": ["message"],
+ "title": "NoResultsResponse",
+ "description": "Response when no agents found."
+ },
"Node": {
"properties": {
"id": { "type": "string", "title": "Id" },
@@ -8773,12 +9498,6 @@
"webhook_id": {
"anyOf": [{ "type": "string" }, { "type": "null" }],
"title": "Webhook Id"
- },
- "webhook": {
- "anyOf": [
- { "$ref": "#/components/schemas/Webhook" },
- { "type": "null" }
- ]
}
},
"type": "object",
@@ -9058,6 +9777,66 @@
"title": "OperationCompleteRequest",
"description": "Request model for external completion webhook."
},
+ "OperationInProgressResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "operation_in_progress"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "tool_call_id": { "type": "string", "title": "Tool Call Id" }
+ },
+ "type": "object",
+ "required": ["message", "tool_call_id"],
+ "title": "OperationInProgressResponse",
+ "description": "Response when an operation is already in progress.\n\nReturned for idempotency when the same tool_call_id is requested again\nwhile the background task is still running."
+ },
+ "OperationPendingResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "operation_pending"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "operation_id": { "type": "string", "title": "Operation Id" },
+ "tool_name": { "type": "string", "title": "Tool Name" }
+ },
+ "type": "object",
+ "required": ["message", "operation_id", "tool_name"],
+ "title": "OperationPendingResponse",
+ "description": "Response stored in chat history while a long-running operation is executing.\n\nThis is persisted to the database so users see a pending state when they\nrefresh before the operation completes."
+ },
+ "OperationStartedResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "operation_started"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "operation_id": { "type": "string", "title": "Operation Id" },
+ "tool_name": { "type": "string", "title": "Tool Name" },
+ "task_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Task Id"
+ }
+ },
+ "type": "object",
+ "required": ["message", "operation_id", "tool_name"],
+ "title": "OperationStartedResponse",
+ "description": "Response when a long-running operation has been started in the background.\n\nThis is returned immediately to the client while the operation continues\nto execute. The user can close the tab and check back later.\n\nThe task_id can be used to reconnect to the SSE stream via\nGET /chat/tasks/{task_id}/stream?last_idx=0"
+ },
"Pagination": {
"properties": {
"total_items": {
@@ -9689,6 +10468,38 @@
"required": ["credit_amount"],
"title": "RequestTopUp"
},
+ "ResponseType": {
+ "type": "string",
+ "enum": [
+ "agents_found",
+ "agent_details",
+ "setup_requirements",
+ "execution_started",
+ "need_login",
+ "error",
+ "no_results",
+ "agent_output",
+ "understanding_updated",
+ "agent_preview",
+ "agent_saved",
+ "clarification_needed",
+ "block_list",
+ "block_output",
+ "doc_search_results",
+ "doc_page",
+ "workspace_file_list",
+ "workspace_file_content",
+ "workspace_file_metadata",
+ "workspace_file_written",
+ "workspace_file_deleted",
+ "operation_started",
+ "operation_pending",
+ "operation_in_progress",
+ "input_validation_error"
+ ],
+ "title": "ResponseType",
+ "description": "Types of tool responses."
+ },
"ReviewItem": {
"properties": {
"node_exec_id": {
@@ -9952,6 +10763,48 @@
"required": ["active_graph_version"],
"title": "SetGraphActiveVersion"
},
+ "SetupInfo": {
+ "properties": {
+ "agent_id": { "type": "string", "title": "Agent Id" },
+ "agent_name": { "type": "string", "title": "Agent Name" },
+ "requirements": {
+ "additionalProperties": { "items": {}, "type": "array" },
+ "type": "object",
+ "title": "Requirements"
+ },
+ "user_readiness": { "$ref": "#/components/schemas/UserReadiness" }
+ },
+ "type": "object",
+ "required": ["agent_id", "agent_name"],
+ "title": "SetupInfo",
+ "description": "Complete setup information."
+ },
+ "SetupRequirementsResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "setup_requirements"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "setup_info": { "$ref": "#/components/schemas/SetupInfo" },
+ "graph_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Graph Id"
+ },
+ "graph_version": {
+ "anyOf": [{ "type": "integer" }, { "type": "null" }],
+ "title": "Graph Version"
+ }
+ },
+ "type": "object",
+ "required": ["message", "setup_info"],
+ "title": "SetupRequirementsResponse",
+ "description": "Response for validate action."
+ },
"ShareRequest": {
"properties": {},
"type": "object",
@@ -11348,6 +12201,33 @@
"required": ["name", "graph_id", "graph_version", "trigger_config"],
"title": "TriggeredPresetSetupRequest"
},
+ "UnderstandingUpdatedResponse": {
+ "properties": {
+ "type": {
+ "$ref": "#/components/schemas/ResponseType",
+ "default": "understanding_updated"
+ },
+ "message": { "type": "string", "title": "Message" },
+ "session_id": {
+ "anyOf": [{ "type": "string" }, { "type": "null" }],
+ "title": "Session Id"
+ },
+ "updated_fields": {
+ "items": { "type": "string" },
+ "type": "array",
+ "title": "Updated Fields"
+ },
+ "current_understanding": {
+ "additionalProperties": true,
+ "type": "object",
+ "title": "Current Understanding"
+ }
+ },
+ "type": "object",
+ "required": ["message"],
+ "title": "UnderstandingUpdatedResponse",
+ "description": "Response for add_understanding tool."
+ },
"UnifiedSearchResponse": {
"properties": {
"results": {
@@ -12226,6 +13106,29 @@
"required": ["provider", "username", "password"],
"title": "UserPasswordCredentials"
},
+ "UserReadiness": {
+ "properties": {
+ "has_all_credentials": {
+ "type": "boolean",
+ "title": "Has All Credentials",
+ "default": false
+ },
+ "missing_credentials": {
+ "additionalProperties": true,
+ "type": "object",
+ "title": "Missing Credentials",
+ "default": {}
+ },
+ "ready_to_run": {
+ "type": "boolean",
+ "title": "Ready To Run",
+ "default": false
+ }
+ },
+ "type": "object",
+ "title": "UserReadiness",
+ "description": "User readiness status."
+ },
"UserTransaction": {
"properties": {
"transaction_key": {
diff --git a/autogpt_platform/frontend/src/app/globals.css b/autogpt_platform/frontend/src/app/globals.css
index 1f782f753b..dd1d17cde7 100644
--- a/autogpt_platform/frontend/src/app/globals.css
+++ b/autogpt_platform/frontend/src/app/globals.css
@@ -1,6 +1,7 @@
@tailwind base;
@tailwind components;
@tailwind utilities;
+@source "../node_modules/streamdown/dist/*.js";
@layer base {
:root {
@@ -29,6 +30,14 @@
--chart-3: 197 37% 24%;
--chart-4: 43 74% 66%;
--chart-5: 27 87% 67%;
+ --sidebar-background: 0 0% 98%;
+ --sidebar-foreground: 240 5.3% 26.1%;
+ --sidebar-primary: 240 5.9% 10%;
+ --sidebar-primary-foreground: 0 0% 98%;
+ --sidebar-accent: 240 4.8% 95.9%;
+ --sidebar-accent-foreground: 240 5.9% 10%;
+ --sidebar-border: 220 13% 91%;
+ --sidebar-ring: 217.2 91.2% 59.8%;
}
.dark {
@@ -56,6 +65,14 @@
--chart-3: 30 80% 55%;
--chart-4: 280 65% 60%;
--chart-5: 340 75% 55%;
+ --sidebar-background: 240 5.9% 10%;
+ --sidebar-foreground: 240 4.8% 95.9%;
+ --sidebar-primary: 224.3 76.3% 48%;
+ --sidebar-primary-foreground: 0 0% 100%;
+ --sidebar-accent: 240 3.7% 15.9%;
+ --sidebar-accent-foreground: 240 4.8% 95.9%;
+ --sidebar-border: 240 3.7% 15.9%;
+ --sidebar-ring: 217.2 91.2% 59.8%;
}
* {
diff --git a/autogpt_platform/frontend/src/components/ai-elements/conversation.tsx b/autogpt_platform/frontend/src/components/ai-elements/conversation.tsx
new file mode 100644
index 0000000000..92e940c715
--- /dev/null
+++ b/autogpt_platform/frontend/src/components/ai-elements/conversation.tsx
@@ -0,0 +1,109 @@
+"use client";
+
+import { Button } from "@/components/ui/button";
+import { scrollbarStyles } from "@/components/styles/scrollbars";
+import { cn } from "@/lib/utils";
+import { ArrowDownIcon } from "lucide-react";
+import type { ComponentProps } from "react";
+import { useCallback } from "react";
+import { StickToBottom, useStickToBottomContext } from "use-stick-to-bottom";
+
+export type ConversationProps = ComponentProps;
+
+export const Conversation = ({ className, ...props }: ConversationProps) => (
+
+);
+
+export type ConversationContentProps = ComponentProps<
+ typeof StickToBottom.Content
+>;
+
+export const ConversationContent = ({
+ className,
+ ...props
+}: ConversationContentProps) => (
+
+);
+
+export type ConversationEmptyStateProps = ComponentProps<"div"> & {
+ title?: string;
+ description?: string;
+ icon?: React.ReactNode;
+};
+
+export const ConversationEmptyState = ({
+ className,
+ title = "No messages yet",
+ description = "Start a conversation to see messages here",
+ icon,
+ children,
+ ...props
+}: ConversationEmptyStateProps) => (
+
+ {children ?? (
+ <>
+ {icon && (
+
{icon}
+ )}
+
+
{title}
+ {description && (
+
+ {description}
+
+ )}
+
+
+ )}
+
+ {children}
+
+);
+
+export type MessageActionsProps = ComponentProps<"div">;
+
+export const MessageActions = ({
+ className,
+ children,
+ ...props
+}: MessageActionsProps) => (
+
+ {children}
+
+);
+
+export type MessageActionProps = ComponentProps & {
+ tooltip?: string;
+ label?: string;
+};
+
+export const MessageAction = ({
+ tooltip,
+ children,
+ label,
+ variant = "ghost",
+ size = "icon-sm",
+ ...props
+}: MessageActionProps) => {
+ const button = (
+
+ );
+
+ if (tooltip) {
+ return (
+
+
+ {button}
+
+ {tooltip}
+
+
+
+ );
+ }
+
+ return button;
+};
+
+interface MessageBranchContextType {
+ currentBranch: number;
+ totalBranches: number;
+ goToPrevious: () => void;
+ goToNext: () => void;
+ branches: ReactElement[];
+ setBranches: (branches: ReactElement[]) => void;
+}
+
+const MessageBranchContext = createContext(
+ null,
+);
+
+const useMessageBranch = () => {
+ const context = useContext(MessageBranchContext);
+
+ if (!context) {
+ throw new Error("MessageBranch components must be used within");
+ }
+
+ return context;
+};
+
+export type MessageBranchProps = HTMLAttributes & {
+ defaultBranch?: number;
+ onBranchChange?: (branchIndex: number) => void;
+};
+
+export const MessageBranch = ({
+ defaultBranch = 0,
+ onBranchChange,
+ className,
+ ...props
+}: MessageBranchProps) => {
+ const [currentBranch, setCurrentBranch] = useState(defaultBranch);
+ const [branches, setBranches] = useState([]);
+
+ const handleBranchChange = (newBranch: number) => {
+ setCurrentBranch(newBranch);
+ onBranchChange?.(newBranch);
+ };
+
+ const goToPrevious = () => {
+ const newBranch =
+ currentBranch > 0 ? currentBranch - 1 : branches.length - 1;
+ handleBranchChange(newBranch);
+ };
+
+ const goToNext = () => {
+ const newBranch =
+ currentBranch < branches.length - 1 ? currentBranch + 1 : 0;
+ handleBranchChange(newBranch);
+ };
+
+ const contextValue: MessageBranchContextType = {
+ currentBranch,
+ totalBranches: branches.length,
+ goToPrevious,
+ goToNext,
+ branches,
+ setBranches,
+ };
+
+ return (
+
+ div]:pb-0", className)}
+ {...props}
+ />
+
+ );
+};
+
+export type MessageBranchContentProps = HTMLAttributes
;
+
+export const MessageBranchContent = ({
+ children,
+ ...props
+}: MessageBranchContentProps) => {
+ const { currentBranch, setBranches, branches } = useMessageBranch();
+ const childrenArray = Array.isArray(children) ? children : [children];
+
+ // Use useEffect to update branches when they change
+ useEffect(() => {
+ if (branches.length !== childrenArray.length) {
+ setBranches(childrenArray);
+ }
+ }, [childrenArray, branches, setBranches]);
+
+ return childrenArray.map((branch, index) => (
+ div]:pb-0",
+ index === currentBranch ? "block" : "hidden",
+ )}
+ key={branch.key}
+ {...props}
+ >
+ {branch}
+
+ ));
+};
+
+export type MessageBranchSelectorProps = HTMLAttributes & {
+ from: UIMessage["role"];
+};
+
+export const MessageBranchSelector = ({
+ className,
+ from: _from,
+ ...props
+}: MessageBranchSelectorProps) => {
+ const { totalBranches } = useMessageBranch();
+
+ // Don't render if there's only one branch
+ if (totalBranches <= 1) {
+ return null;
+ }
+
+ return (
+ *:not(:first-child)]:rounded-l-md [&>*:not(:last-child)]:rounded-r-md",
+ className,
+ )}
+ orientation="horizontal"
+ {...props}
+ />
+ );
+};
+
+export type MessageBranchPreviousProps = ComponentProps;
+
+export const MessageBranchPrevious = ({
+ children,
+ ...props
+}: MessageBranchPreviousProps) => {
+ const { goToPrevious, totalBranches } = useMessageBranch();
+
+ return (
+
+ );
+};
+
+export type MessageBranchNextProps = ComponentProps;
+
+export const MessageBranchNext = ({
+ children,
+ ...props
+}: MessageBranchNextProps) => {
+ const { goToNext, totalBranches } = useMessageBranch();
+
+ return (
+
+ );
+};
+
+export type MessageBranchPageProps = HTMLAttributes;
+
+export const MessageBranchPage = ({
+ className,
+ ...props
+}: MessageBranchPageProps) => {
+ const { currentBranch, totalBranches } = useMessageBranch();
+
+ return (
+
+ {currentBranch + 1} of {totalBranches}
+
+ );
+};
+
+export type MessageResponseProps = ComponentProps;
+
+export const MessageResponse = memo(
+ ({ className, ...props }: MessageResponseProps) => (
+ *:first-child]:mt-0 [&>*:last-child]:mb-0 [&_pre]:!bg-white",
+ className,
+ )}
+ plugins={{ code, mermaid, math, cjk }}
+ {...props}
+ />
+ ),
+ (prevProps, nextProps) => prevProps.children === nextProps.children,
+);
+
+MessageResponse.displayName = "MessageResponse";
+
+export type MessageToolbarProps = ComponentProps<"div">;
+
+export const MessageToolbar = ({
+ className,
+ children,
+ ...props
+}: MessageToolbarProps) => (
+
+ {children}
+
+);
diff --git a/autogpt_platform/frontend/src/components/atoms/OverflowText/OverflowText.tsx b/autogpt_platform/frontend/src/components/atoms/OverflowText/OverflowText.tsx
index efc345f79c..b118cc5aa0 100644
--- a/autogpt_platform/frontend/src/components/atoms/OverflowText/OverflowText.tsx
+++ b/autogpt_platform/frontend/src/components/atoms/OverflowText/OverflowText.tsx
@@ -77,7 +77,7 @@ export function OverflowText(props: Props) {
"block min-w-0 overflow-hidden text-ellipsis whitespace-nowrap",
)}
>
-
+
{value}
diff --git a/autogpt_platform/frontend/src/components/atoms/Text/Text.tsx b/autogpt_platform/frontend/src/components/atoms/Text/Text.tsx
index 8bae184e5b..86c39b6436 100644
--- a/autogpt_platform/frontend/src/components/atoms/Text/Text.tsx
+++ b/autogpt_platform/frontend/src/components/atoms/Text/Text.tsx
@@ -1,4 +1,5 @@
import React from "react";
+import { cn } from "@/lib/utils";
import { As, Variant, variantElementMap, variants } from "./helpers";
type CustomProps = {
@@ -22,7 +23,7 @@ export function Text({
}: TextProps) {
const variantClasses = variants[size || variant] || variants.body;
const Element = outerAs || variantElementMap[variant];
- const combinedClassName = `${variantClasses} ${className}`.trim();
+ const combinedClassName = cn(variantClasses, className);
return React.createElement(
Element,
diff --git a/autogpt_platform/frontend/src/components/contextual/Chat/Chat.tsx b/autogpt_platform/frontend/src/components/contextual/Chat/Chat.tsx
deleted file mode 100644
index da454150bf..0000000000
--- a/autogpt_platform/frontend/src/components/contextual/Chat/Chat.tsx
+++ /dev/null
@@ -1,114 +0,0 @@
-"use client";
-
-import { useCopilotSessionId } from "@/app/(platform)/copilot/useCopilotSessionId";
-import { LoadingSpinner } from "@/components/atoms/LoadingSpinner/LoadingSpinner";
-import { Text } from "@/components/atoms/Text/Text";
-import { cn } from "@/lib/utils";
-import { useEffect, useRef } from "react";
-import { ChatContainer } from "./components/ChatContainer/ChatContainer";
-import { ChatErrorState } from "./components/ChatErrorState/ChatErrorState";
-import { useChat } from "./useChat";
-
-export interface ChatProps {
- className?: string;
- initialPrompt?: string;
- onSessionNotFound?: () => void;
- onStreamingChange?: (isStreaming: boolean) => void;
-}
-
-export function Chat({
- className,
- initialPrompt,
- onSessionNotFound,
- onStreamingChange,
-}: ChatProps) {
- const { urlSessionId } = useCopilotSessionId();
- const hasHandledNotFoundRef = useRef(false);
- const {
- session,
- messages,
- isLoading,
- isCreating,
- error,
- isSessionNotFound,
- sessionId,
- createSession,
- showLoader,
- startPollingForOperation,
- } = useChat({ urlSessionId });
-
- // Extract active stream info for reconnection
- const activeStream = (
- session as {
- active_stream?: {
- task_id: string;
- last_message_id: string;
- operation_id: string;
- tool_name: string;
- };
- }
- )?.active_stream;
-
- useEffect(() => {
- if (!onSessionNotFound) return;
- if (!urlSessionId) return;
- if (!isSessionNotFound || isLoading || isCreating) return;
- if (hasHandledNotFoundRef.current) return;
- hasHandledNotFoundRef.current = true;
- onSessionNotFound();
- }, [
- onSessionNotFound,
- urlSessionId,
- isSessionNotFound,
- isLoading,
- isCreating,
- ]);
-
- const shouldShowLoader = showLoader && (isLoading || isCreating);
-
- return (
-
- {/* Main Content */}
-
- {/* Loading State */}
- {shouldShowLoader && (
-
-
-
-
- Loading your chat...
-
-
-
-
- {children}
-
- );
-}
diff --git a/autogpt_platform/frontend/src/components/contextual/Chat/components/AgentCarouselMessage/AgentCarouselMessage.tsx b/autogpt_platform/frontend/src/components/contextual/Chat/components/AgentCarouselMessage/AgentCarouselMessage.tsx
deleted file mode 100644
index 582b24de5e..0000000000
--- a/autogpt_platform/frontend/src/components/contextual/Chat/components/AgentCarouselMessage/AgentCarouselMessage.tsx
+++ /dev/null
@@ -1,119 +0,0 @@
-import { Button } from "@/components/atoms/Button/Button";
-import { Card } from "@/components/atoms/Card/Card";
-import { Text } from "@/components/atoms/Text/Text";
-import { cn } from "@/lib/utils";
-import { ArrowRight, List, Robot } from "@phosphor-icons/react";
-import Image from "next/image";
-
-export interface Agent {
- id: string;
- name: string;
- description: string;
- version?: number;
- image_url?: string;
-}
-
-export interface AgentCarouselMessageProps {
- agents: Agent[];
- totalCount?: number;
- onSelectAgent?: (agentId: string) => void;
- className?: string;
-}
-
-export function AgentCarouselMessage({
- agents,
- totalCount,
- onSelectAgent,
- className,
-}: AgentCarouselMessageProps) {
- const displayCount = totalCount ?? agents.length;
-
- return (
-
- {/* Header */}
-
-
-
-
-
-
- Found {displayCount} {displayCount === 1 ? "Agent" : "Agents"}
-
-
- Select an agent to view details or run it
-
-
-
-
- {/* Agent Cards */}
-
- {agents.map((agent) => (
-
-
-
- {agent.image_url ? (
-
- ) : (
-
-
-
- )}
-
-
-
-
- {agent.name}
-
- {agent.version && (
-
- v{agent.version}
-
- )}
-
-
- {agent.description}
-
- {onSelectAgent && (
-
- )}
-
-
- ))}
-
-
- {totalCount && totalCount > agents.length && (
-
- Showing {agents.length} of {totalCount} results
-
- )}
-
-
-
-
-
-
- {agentName ? `Configure ${agentName}` : "Agent Configuration"}
-
-
- {message}
-
-
- {inputFields.length > 0 && (
-
- {inputFields.map(([key, inputSubSchema]) => (
- setInputValue(key, value)}
- />
- ))}
-
- )}
-
- {credentialFields.length > 0 && (
-
- {credentialFields.map(([key, schema]) => {
- const requiredCredentials = new Set(
- (credentialsSchemaObj.required as string[]) || [],
- );
- return (
-
- setCredentialsValue(key, value)
- }
- siblingInputs={mergedInputValues}
- isOptional={!requiredCredentials.has(key)}
- />
- );
- })}
-
- )}
-
-
-
- {onCancel && (
-
- )}
-
-
-
-
-
-
-
-
-
-
- Authentication Required
-
-
- Sign in to set up and manage agents
-
-
-
-
-
-
{message}
- {agentInfo && (
-
-
- Ready to set up:{" "}
- {agentInfo.name}
-
-
- Type:{" "}
- {agentInfo.trigger_type}
-
-
- )}
-
-
-
-
-
-
-
-
- Your chat session will be preserved after signing in
-
-
-
-
-
- The Autogpt AI model is not available in your region or your
- connection is blocking it. Please try again with a different
- connection.
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- Credentials Required
-
-
- {message}
-
-
-
-
- {credentials.map((cred, index) => {
- const schema = createSchemaFromCredentialInfo(cred);
- const isSelected = !!selectedCredentials[cred.provider];
-
- return (
-
-
- {isSelected ? (
-
- ) : (
-
- )}
-
- {cred.providerName}
-
-
-
-
- handleCredentialSelect(cred.provider, credMeta)
- }
- />
-
- );
- })}
-
-
-
-
-
-
-
-
- );
-}
diff --git a/autogpt_platform/frontend/src/components/contextual/Chat/components/ChatLoader/ChatLoader.tsx b/autogpt_platform/frontend/src/components/contextual/Chat/components/ChatLoader/ChatLoader.tsx
deleted file mode 100644
index 76cee8dbae..0000000000
--- a/autogpt_platform/frontend/src/components/contextual/Chat/components/ChatLoader/ChatLoader.tsx
+++ /dev/null
@@ -1,7 +0,0 @@
-export function ChatLoader() {
- return (
-
- );
-}
diff --git a/autogpt_platform/frontend/src/components/contextual/Chat/components/ChatLoadingState/ChatLoadingState.tsx b/autogpt_platform/frontend/src/components/contextual/Chat/components/ChatLoadingState/ChatLoadingState.tsx
deleted file mode 100644
index c0cdb33c50..0000000000
--- a/autogpt_platform/frontend/src/components/contextual/Chat/components/ChatLoadingState/ChatLoadingState.tsx
+++ /dev/null
@@ -1,19 +0,0 @@
-import { LoadingSpinner } from "@/components/atoms/LoadingSpinner/LoadingSpinner";
-import { cn } from "@/lib/utils";
-
-export interface ChatLoadingStateProps {
- message?: string;
- className?: string;
-}
-
-export function ChatLoadingState({ className }: ChatLoadingStateProps) {
- return (
-
- );
-}
diff --git a/autogpt_platform/frontend/src/components/contextual/Chat/components/ChatMessage/ChatMessage.tsx b/autogpt_platform/frontend/src/components/contextual/Chat/components/ChatMessage/ChatMessage.tsx
deleted file mode 100644
index 44dae40eb4..0000000000
--- a/autogpt_platform/frontend/src/components/contextual/Chat/components/ChatMessage/ChatMessage.tsx
+++ /dev/null
@@ -1,448 +0,0 @@
-"use client";
-
-import { Button } from "@/components/atoms/Button/Button";
-import { useSupabase } from "@/lib/supabase/hooks/useSupabase";
-import { cn } from "@/lib/utils";
-import {
- ArrowsClockwiseIcon,
- CheckCircleIcon,
- CheckIcon,
-} from "@phosphor-icons/react";
-import { useRouter } from "next/navigation";
-import { useCallback, useState } from "react";
-import { AgentCarouselMessage } from "../AgentCarouselMessage/AgentCarouselMessage";
-import { AIChatBubble } from "../AIChatBubble/AIChatBubble";
-import { AuthPromptWidget } from "../AuthPromptWidget/AuthPromptWidget";
-import { ChatCredentialsSetup } from "../ChatCredentialsSetup/ChatCredentialsSetup";
-import { ClarificationQuestionsWidget } from "../ClarificationQuestionsWidget/ClarificationQuestionsWidget";
-import { ExecutionStartedMessage } from "../ExecutionStartedMessage/ExecutionStartedMessage";
-import { PendingOperationWidget } from "../PendingOperationWidget/PendingOperationWidget";
-import { MarkdownContent } from "../MarkdownContent/MarkdownContent";
-import { NoResultsMessage } from "../NoResultsMessage/NoResultsMessage";
-import { ToolCallMessage } from "../ToolCallMessage/ToolCallMessage";
-import { ToolResponseMessage } from "../ToolResponseMessage/ToolResponseMessage";
-import { UserChatBubble } from "../UserChatBubble/UserChatBubble";
-import { useChatMessage, type ChatMessageData } from "./useChatMessage";
-
-function stripInternalReasoning(content: string): string {
- const cleaned = content.replace(
- /[\s\S]*?<\/internal_reasoning>/gi,
- "",
- );
- return cleaned.replace(/\n{3,}/g, "\n\n").trim();
-}
-
-function getDisplayContent(message: ChatMessageData, isUser: boolean): string {
- if (message.type !== "message") return "";
- if (isUser) return message.content;
- return stripInternalReasoning(message.content);
-}
-
-export interface ChatMessageProps {
- message: ChatMessageData;
- messages?: ChatMessageData[];
- index?: number;
- isStreaming?: boolean;
- className?: string;
- onDismissLogin?: () => void;
- onDismissCredentials?: () => void;
- onSendMessage?: (content: string, isUserMessage?: boolean) => void;
- agentOutput?: ChatMessageData;
- isFinalMessage?: boolean;
-}
-
-export function ChatMessage({
- message,
- messages = [],
- index = -1,
- isStreaming = false,
- className,
- onDismissCredentials,
- onSendMessage,
- agentOutput,
- isFinalMessage = true,
-}: ChatMessageProps) {
- const { user } = useSupabase();
- const router = useRouter();
- const [copied, setCopied] = useState(false);
- const {
- isUser,
- isToolCall,
- isToolResponse,
- isLoginNeeded,
- isCredentialsNeeded,
- isClarificationNeeded,
- isOperationStarted,
- isOperationPending,
- isOperationInProgress,
- } = useChatMessage(message);
- const displayContent = getDisplayContent(message, isUser);
-
- const handleAllCredentialsComplete = useCallback(
- function handleAllCredentialsComplete() {
- // Send a user message that explicitly asks to retry the setup
- // This ensures the LLM calls get_required_setup_info again and proceeds with execution
- if (onSendMessage) {
- onSendMessage(
- "I've configured the required credentials. Please check if everything is ready and proceed with setting up the agent.",
- );
- }
- // Optionally dismiss the credentials prompt
- if (onDismissCredentials) {
- onDismissCredentials();
- }
- },
- [onSendMessage, onDismissCredentials],
- );
-
- function handleCancelCredentials() {
- // Dismiss the credentials prompt
- if (onDismissCredentials) {
- onDismissCredentials();
- }
- }
-
- const handleCopy = useCallback(
- async function handleCopy() {
- if (message.type !== "message") return;
- if (!displayContent) return;
-
- try {
- await navigator.clipboard.writeText(displayContent);
- setCopied(true);
- setTimeout(() => setCopied(false), 2000);
- } catch (error) {
- console.error("Failed to copy:", error);
- }
- },
- [displayContent, message],
- );
-
- const handleTryAgain = useCallback(() => {
- if (message.type !== "message" || !onSendMessage) return;
- onSendMessage(message.content, message.role === "user");
- }, [message, onSendMessage]);
-
- const handleViewExecution = useCallback(() => {
- if (message.type === "execution_started" && message.libraryAgentLink) {
- router.push(message.libraryAgentLink);
- }
- }, [message, router]);
-
- // Render credentials needed messages
- if (isCredentialsNeeded && message.type === "credentials_needed") {
- return (
-
- );
- }
-
- if (isClarificationNeeded && message.type === "clarification_needed") {
- const hasUserReplyAfter =
- index >= 0 &&
- messages
- .slice(index + 1)
- .some((m) => m.type === "message" && m.role === "user");
-
- const handleClarificationAnswers = (answers: Record) => {
- if (onSendMessage) {
- // Iterate over questions (preserves original order) instead of answers
- const contextMessage = message.questions
- .map((q) => {
- const answer = answers[q.keyword] || "";
- return `> ${q.question}\n\n${answer}`;
- })
- .join("\n\n");
-
- onSendMessage(
- `**Here are my answers:**\n\n${contextMessage}\n\nPlease proceed with creating the agent.`,
- );
- }
- };
-
- return (
-
- );
- }
-
- // Render login needed messages
- if (isLoginNeeded && message.type === "login_needed") {
- // If user is already logged in, show success message instead of auth prompt
- if (user) {
- return (
-
-
-
-
-
-
-
-
-
- Successfully Authenticated
-
-
- You're now signed in and ready to continue
-
-
-
-
-
-
-
-
- );
- }
-
- // Render no_results messages - use dedicated component, not ToolResponseMessage
- if (message.type === "no_results") {
- return (
-
-
-
- );
- }
-
- // Render agent_carousel messages - use dedicated component, not ToolResponseMessage
- if (message.type === "agent_carousel") {
- return (
-
- );
- }
-
- // Render execution_started messages - use dedicated component, not ToolResponseMessage
- if (message.type === "execution_started") {
- return (
-
-
-
- );
- }
-
- // Render operation_started messages (long-running background operations)
- if (isOperationStarted && message.type === "operation_started") {
- return (
-
- );
- }
-
- // Render operation_pending messages (operations in progress when refreshing)
- if (isOperationPending && message.type === "operation_pending") {
- return (
-
- );
- }
-
- // Render operation_in_progress messages (duplicate request while operation running)
- if (isOperationInProgress && message.type === "operation_in_progress") {
- return (
-
- );
- }
-
- // Render tool response messages (but skip agent_output if it's being rendered inside assistant message)
- if (isToolResponse && message.type === "tool_response") {
- return (
-
-
-
- );
- }
-
- // Render regular chat messages
- if (message.type === "message") {
- return (
-
-
-
- {isUser ? (
-
-
-
- ) : (
-
-
- {agentOutput && agentOutput.type === "tool_response" && (
-
-
-
- )}
-
- )}
-
- {isUser && onSendMessage && (
-
- )}
- {!isUser && isFinalMessage && !isStreaming && (
-
- )}
-
-
-
-
- {/* Icon & Header */}
-
-
-
-
-
-
- Execution Started
-
-
- {message}
-
-
-
-
- {/* Details */}
-
-
- {agentName && (
-
-
- Agent:
-
-
- {agentName}
-
-
- )}
-
-
- Execution ID:
-
-
- {executionId.slice(0, 16)}...
-
-
-
-
-
- {/* Action Buttons */}
- {onViewExecution && (
-
- )}
-
-
-
-
- Your agent is now running. You can monitor its progress in the monitor
- page.
-
-
-