'use client'; import { useControllableState } from '@radix-ui/react-use-controllable-state'; import { Collapsible, CollapsibleContent, CollapsibleTrigger } from '@/components/ui/collapsible'; import { cn } from '@/lib/utils'; import { BrainIcon, ChevronDownIcon } from 'lucide-react'; import type { ComponentProps, ReactNode } from 'react'; import { createContext, memo, useContext, useEffect, useState } from 'react'; import { Streamdown } from 'streamdown'; import { Shimmer } from './shimmer'; type ReasoningContextValue = { isStreaming: boolean; isOpen: boolean; setIsOpen: (open: boolean) => void; duration: number | undefined; }; const ReasoningContext = createContext(null); export const useReasoning = () => { const context = useContext(ReasoningContext); if (!context) { throw new Error('Reasoning components must be used within Reasoning'); } return context; }; export type ReasoningProps = ComponentProps & { isStreaming?: boolean; open?: boolean; defaultOpen?: boolean; onOpenChange?: (open: boolean) => void; duration?: number; }; const AUTO_CLOSE_DELAY = 1000; const MS_IN_S = 1000; export const Reasoning = memo( ({ className, isStreaming = false, open, defaultOpen = true, onOpenChange, duration: durationProp, children, ...props }: ReasoningProps) => { const [isOpen, setIsOpen] = useControllableState({ prop: open, defaultProp: defaultOpen, onChange: onOpenChange, }); const [duration, setDuration] = useControllableState({ prop: durationProp, defaultProp: undefined, }); const [hasAutoClosed, setHasAutoClosed] = useState(false); const [startTime, setStartTime] = useState(null); // Track duration when streaming starts and ends useEffect(() => { if (isStreaming) { if (startTime === null) { // eslint-disable-next-line react-hooks/set-state-in-effect -- Tracking streaming duration requires effect setStartTime(Date.now()); } } else if (startTime !== null) { setDuration(Math.ceil((Date.now() - startTime) / MS_IN_S)); setStartTime(null); } }, [isStreaming, startTime, setDuration]); // Auto-open when streaming starts, auto-close when streaming ends (once only) useEffect(() => { if (defaultOpen && !isStreaming && isOpen && !hasAutoClosed) { // Add a small delay before closing to allow user to see the content const timer = setTimeout(() => { setIsOpen(false); setHasAutoClosed(true); }, AUTO_CLOSE_DELAY); return () => clearTimeout(timer); } }, [isStreaming, isOpen, defaultOpen, setIsOpen, hasAutoClosed]); const handleOpenChange = (newOpen: boolean) => { setIsOpen(newOpen); }; return ( {children} ); }, ); export type ReasoningTriggerProps = ComponentProps & { getThinkingMessage?: (isStreaming: boolean, duration?: number) => ReactNode; }; const defaultGetThinkingMessage = (isStreaming: boolean, duration?: number) => { if (isStreaming || duration === 0) { return Thinking...; } if (duration === undefined) { return

Thought for a few seconds

; } return

Thought for {duration} seconds

; }; export const ReasoningTrigger = memo( ({ className, children, getThinkingMessage = defaultGetThinkingMessage, ...props }: ReasoningTriggerProps) => { const { isStreaming, isOpen, duration } = useReasoning(); return ( {children ?? ( <> {getThinkingMessage(isStreaming, duration)} )} ); }, ); export type ReasoningContentProps = ComponentProps & { children: string; }; export const ReasoningContent = memo(({ className, children, ...props }: ReasoningContentProps) => ( {children} )); Reasoning.displayName = 'Reasoning'; ReasoningTrigger.displayName = 'ReasoningTrigger'; ReasoningContent.displayName = 'ReasoningContent';