"use client";
import { RemoveScroll } from "react-remove-scroll";
import {
type ComponentProps,
createContext,
type SyntheticEvent,
use,
useEffect,
useMemo,
useRef,
useState,
} from "react";
import { Loader2, SearchIcon, Send, X } from "lucide-react";
import { cn } from "@/lib/utils";
import { buttonVariants } from "fumadocs-ui/components/ui/button";
import Link from "fumadocs-core/link";
import { Markdown } from "./markdown";
import { Presence } from "@radix-ui/react-presence";
import { betterFetch } from "@better-fetch/fetch";
const Context = createContext<{
open: boolean;
setOpen: (open: boolean) => void;
messages: Array<{ id: string; role: "user" | "assistant"; content: string }>;
isLoading: boolean;
sendMessage: (text: string) => void;
clearMessages: () => void;
} | null>(null);
function useChatContext() {
return use(Context)!;
}
function SearchAIActions() {
const { messages, isLoading, clearMessages } = useChatContext();
if (messages.length === 0) return null;
return (
<>
>
);
}
function SearchAIInput(props: ComponentProps<"form">) {
const { sendMessage, isLoading } = useChatContext();
const [input, setInput] = useState("");
const onStart = (e?: SyntheticEvent) => {
e?.preventDefault();
if (input.trim()) {
sendMessage(input.trim());
setInput("");
}
};
useEffect(() => {
if (isLoading) document.getElementById("nd-ai-input")?.focus();
}, [isLoading]);
return (
);
}
function List(props: Omit, "dir">) {
const containerRef = useRef(null);
useEffect(() => {
if (!containerRef.current) return;
function callback() {
const container = containerRef.current;
if (!container) return;
container.scrollTo({
top: container.scrollHeight,
behavior: "instant",
});
}
const observer = new ResizeObserver(callback);
callback();
const element = containerRef.current?.firstElementChild;
if (element) {
observer.observe(element);
}
return () => {
observer.disconnect();
};
}, []);
return (
{props.children}
);
}
function Input(props: ComponentProps<"textarea">) {
const ref = useRef(null);
const shared = cn("col-start-1 row-start-1", props.className);
return (
{`${props.value?.toString() ?? ""}\n`}
);
}
const roleName: Record = {
user: "you",
assistant: "better-auth bot",
};
function Message({
message,
...props
}: {
message: {
id: string;
role: "user" | "assistant";
content: string;
references?: Array<{ link: string; title: string; icon?: string }>;
isStreaming?: boolean;
};
} & ComponentProps<"div">) {
return (
{message.isStreaming && (
)}
{message.references &&
message.references.length > 0 &&
!message.isStreaming && (
References:
{message.references.map((ref, i) => (
{ref.icon && (

{
e.currentTarget.style.display = "none";
}}
/>
)}
{ref.title}
))}
)}
);
}
export function AISearchTrigger() {
if (process.env.NEXT_PUBLIC_ENABLE_AI_CHAT !== "true") {
return null;
}
const [open, setOpen] = useState(false);
const [messages, setMessages] = useState<
Array<{
id: string;
role: "user" | "assistant";
content: string;
references?: Array<{ link: string; title: string; icon?: string }>;
isStreaming?: boolean;
}>
>([]);
const [isLoading, setIsLoading] = useState(false);
const [input, setInput] = useState("");
const [sessionId, setSessionId] = useState("");
const [questionCount, setQuestionCount] = useState(0);
const streamText = (
messageId: string,
fullText: string,
references?: Array<{ link: string; title: string; icon?: string }>,
) => {
const words = fullText.split(" ");
let currentText = "";
let wordIndex = 0;
const streamInterval = setInterval(() => {
if (wordIndex < words.length) {
currentText += (wordIndex > 0 ? " " : "") + words[wordIndex];
wordIndex++;
setMessages((prev) =>
prev.map((msg) =>
msg.id === messageId
? {
...msg,
content: currentText,
isStreaming: false,
}
: msg,
),
);
} else {
setMessages((prev) =>
prev.map((msg) =>
msg.id === messageId
? { ...msg, isStreaming: false, references }
: msg,
),
);
clearInterval(streamInterval);
}
}, 30);
return () => clearInterval(streamInterval);
};
const sendMessage = async (text: string) => {
if (!text.trim()) return;
const userMessage = {
id: Date.now().toString(),
role: "user" as const,
content: text,
};
setMessages((prev) => [...prev, userMessage]);
setIsLoading(true);
setQuestionCount((prev) => prev + 1);
const messageId = (Date.now() + 1).toString();
const assistantMessage = {
id: messageId,
role: "assistant" as const,
content: "",
isStreaming: true,
};
setMessages((prev) => [...prev, assistantMessage]);
try {
const currentQuestionNumber = questionCount + 1;
const isFirstQuestion = currentQuestionNumber === 1;
const isSecondQuestion = currentQuestionNumber === 2;
if (!isFirstQuestion) {
const requestBody: any = {
question: text,
stream: false,
fetch_existing: true,
};
if (!isSecondQuestion && sessionId) {
requestBody.session_id = sessionId;
}
const { data, error } = await betterFetch<{
content?: string;
answer?: string;
response?: string;
session_id?: string;
references?: Array<{ link: string; title: string; icon?: string }>;
error?: string;
}>("/api/ai-chat", {
method: "POST",
headers: {
"Content-Type": "application/json",
},
body: JSON.stringify(requestBody),
});
if (error) {
console.error("API Error Response:", error);
throw new Error(`HTTP ${error.status}: ${error.message}`);
}
let responseContent = "";
if (data.content) {
responseContent = data.content;
} else if (data.answer) {
responseContent = data.answer;
} else if (data.response) {
responseContent = data.response;
} else if (data.error) {
responseContent = data.error;
} else {
responseContent = "No response received";
}
const filteredReferences = data.references?.filter(
(ref) => !ref.link.includes("github.com"),
);
streamText(messageId, responseContent, filteredReferences);
if (isSecondQuestion && data.session_id) {
setSessionId(data.session_id);
}
} else {
const streamRequestBody = {
question: text,
stream: true,
external_user_id: "floating-ai-user",
};
const streamResponse = await fetch("/api/ai-chat", {
method: "POST",
headers: {
"Content-Type": "application/json",
},
body: JSON.stringify(streamRequestBody),
});
if (!streamResponse.ok) {
throw new Error(`HTTP error! status: ${streamResponse.status}`);
}
const reader = streamResponse.body?.getReader();
const decoder = new TextDecoder();
let accumulatedContent = "";
if (reader) {
while (true) {
const { done, value } = await reader.read();
if (done) break;
const chunk = decoder.decode(value, { stream: true });
accumulatedContent += chunk;
setMessages((prev) =>
prev.map((msg) =>
msg.id === messageId
? { ...msg, content: accumulatedContent, isStreaming: true }
: msg,
),
);
}
}
setMessages((prev) =>
prev.map((msg) =>
msg.id === messageId ? { ...msg, isStreaming: false } : msg,
),
);
const fetchReferencesBody = {
question: text,
stream: false,
fetch_existing: true,
external_user_id: "floating-ai-user",
};
const { data: referencesData } = await betterFetch<{
references?: Array<{ link: string; title: string; icon?: string }>;
session_id?: string;
}>("/api/ai-chat", {
method: "POST",
headers: {
"Content-Type": "application/json",
},
body: JSON.stringify(fetchReferencesBody),
});
if (
referencesData?.references &&
referencesData.references.length > 0
) {
const filteredReferences = referencesData.references.filter(
(ref) => !ref.link.includes("github.com"),
);
if (filteredReferences.length > 0) {
setMessages((prev) =>
prev.map((msg) =>
msg.id === messageId
? { ...msg, references: filteredReferences }
: msg,
),
);
}
}
}
} catch (error) {
console.error("Error sending message:", error);
setMessages((prev) => {
const filtered = prev.filter((msg) => msg.id !== messageId);
return [
...filtered,
{
id: messageId,
role: "assistant" as const,
content:
"Sorry, there was an error processing your request. Please try again.",
},
];
});
} finally {
setIsLoading(false);
}
};
const clearMessages = () => {
setMessages([]);
setSessionId("");
setQuestionCount(0);
};
const onKeyPress = (e: KeyboardEvent) => {
if (e.key === "Escape" && open) {
setOpen(false);
e.preventDefault();
}
if (e.key === "/" && (e.metaKey || e.ctrlKey) && !open) {
setOpen(true);
e.preventDefault();
}
};
const onKeyPressRef = useRef(onKeyPress);
onKeyPressRef.current = onKeyPress;
useEffect(() => {
const listener = (e: KeyboardEvent) => onKeyPressRef.current(e);
window.addEventListener("keydown", listener);
return () => window.removeEventListener("keydown", listener);
}, []);
return (
({
messages,
isLoading,
sendMessage,
clearMessages,
open,
setOpen,
}),
[messages, isLoading, open],
)}
>
{
if (e.target === e.currentTarget) {
setOpen(false);
e.preventDefault();
}
}}
>
{messages.map((item) => (
))}
{isLoading && (
AI is thinking...
)}
);
}