reasoning.tsx 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173
  1. 'use client';
  2. import { useControllableState } from '@radix-ui/react-use-controllable-state';
  3. import { Collapsible, CollapsibleContent, CollapsibleTrigger } from '@/components/ui/collapsible';
  4. import { cn } from '@/lib/utils';
  5. import { BrainIcon, ChevronDownIcon } from 'lucide-react';
  6. import type { ComponentProps, ReactNode } from 'react';
  7. import { createContext, memo, useContext, useEffect, useState } from 'react';
  8. import { Streamdown } from 'streamdown';
  9. import { Shimmer } from './shimmer';
  10. type ReasoningContextValue = {
  11. isStreaming: boolean;
  12. isOpen: boolean;
  13. setIsOpen: (open: boolean) => void;
  14. duration: number | undefined;
  15. };
  16. const ReasoningContext = createContext<ReasoningContextValue | null>(null);
  17. export const useReasoning = () => {
  18. const context = useContext(ReasoningContext);
  19. if (!context) {
  20. throw new Error('Reasoning components must be used within Reasoning');
  21. }
  22. return context;
  23. };
  24. export type ReasoningProps = ComponentProps<typeof Collapsible> & {
  25. isStreaming?: boolean;
  26. open?: boolean;
  27. defaultOpen?: boolean;
  28. onOpenChange?: (open: boolean) => void;
  29. duration?: number;
  30. };
  31. const AUTO_CLOSE_DELAY = 1000;
  32. const MS_IN_S = 1000;
  33. export const Reasoning = memo(
  34. ({
  35. className,
  36. isStreaming = false,
  37. open,
  38. defaultOpen = true,
  39. onOpenChange,
  40. duration: durationProp,
  41. children,
  42. ...props
  43. }: ReasoningProps) => {
  44. const [isOpen, setIsOpen] = useControllableState({
  45. prop: open,
  46. defaultProp: defaultOpen,
  47. onChange: onOpenChange,
  48. });
  49. const [duration, setDuration] = useControllableState({
  50. prop: durationProp,
  51. defaultProp: undefined,
  52. });
  53. const [hasAutoClosed, setHasAutoClosed] = useState(false);
  54. const [startTime, setStartTime] = useState<number | null>(null);
  55. // Track duration when streaming starts and ends
  56. useEffect(() => {
  57. if (isStreaming) {
  58. if (startTime === null) {
  59. // eslint-disable-next-line react-hooks/set-state-in-effect -- Tracking streaming duration requires effect
  60. setStartTime(Date.now());
  61. }
  62. } else if (startTime !== null) {
  63. setDuration(Math.ceil((Date.now() - startTime) / MS_IN_S));
  64. setStartTime(null);
  65. }
  66. }, [isStreaming, startTime, setDuration]);
  67. // Auto-open when streaming starts, auto-close when streaming ends (once only)
  68. useEffect(() => {
  69. if (defaultOpen && !isStreaming && isOpen && !hasAutoClosed) {
  70. // Add a small delay before closing to allow user to see the content
  71. const timer = setTimeout(() => {
  72. setIsOpen(false);
  73. setHasAutoClosed(true);
  74. }, AUTO_CLOSE_DELAY);
  75. return () => clearTimeout(timer);
  76. }
  77. }, [isStreaming, isOpen, defaultOpen, setIsOpen, hasAutoClosed]);
  78. const handleOpenChange = (newOpen: boolean) => {
  79. setIsOpen(newOpen);
  80. };
  81. return (
  82. <ReasoningContext.Provider value={{ isStreaming, isOpen, setIsOpen, duration }}>
  83. <Collapsible
  84. className={cn('not-prose mb-4', className)}
  85. onOpenChange={handleOpenChange}
  86. open={isOpen}
  87. {...props}
  88. >
  89. {children}
  90. </Collapsible>
  91. </ReasoningContext.Provider>
  92. );
  93. },
  94. );
  95. export type ReasoningTriggerProps = ComponentProps<typeof CollapsibleTrigger> & {
  96. getThinkingMessage?: (isStreaming: boolean, duration?: number) => ReactNode;
  97. };
  98. const defaultGetThinkingMessage = (isStreaming: boolean, duration?: number) => {
  99. if (isStreaming || duration === 0) {
  100. return <Shimmer duration={1}>Thinking...</Shimmer>;
  101. }
  102. if (duration === undefined) {
  103. return <p>Thought for a few seconds</p>;
  104. }
  105. return <p>Thought for {duration} seconds</p>;
  106. };
  107. export const ReasoningTrigger = memo(
  108. ({
  109. className,
  110. children,
  111. getThinkingMessage = defaultGetThinkingMessage,
  112. ...props
  113. }: ReasoningTriggerProps) => {
  114. const { isStreaming, isOpen, duration } = useReasoning();
  115. return (
  116. <CollapsibleTrigger
  117. className={cn(
  118. 'flex w-full items-center gap-2 text-muted-foreground text-sm transition-colors hover:text-foreground',
  119. className,
  120. )}
  121. {...props}
  122. >
  123. {children ?? (
  124. <>
  125. <BrainIcon className="size-4" />
  126. {getThinkingMessage(isStreaming, duration)}
  127. <ChevronDownIcon
  128. className={cn('size-4 transition-transform', isOpen ? 'rotate-180' : 'rotate-0')}
  129. />
  130. </>
  131. )}
  132. </CollapsibleTrigger>
  133. );
  134. },
  135. );
  136. export type ReasoningContentProps = ComponentProps<typeof CollapsibleContent> & {
  137. children: string;
  138. };
  139. export const ReasoningContent = memo(({ className, children, ...props }: ReasoningContentProps) => (
  140. <CollapsibleContent
  141. className={cn(
  142. 'mt-4 text-sm',
  143. 'data-[state=closed]:fade-out-0 data-[state=closed]:slide-out-to-top-2 data-[state=open]:slide-in-from-top-2 text-muted-foreground outline-none data-[state=closed]:animate-out data-[state=open]:animate-in',
  144. className,
  145. )}
  146. {...props}
  147. >
  148. <Streamdown>{children}</Streamdown>
  149. </CollapsibleContent>
  150. ));
  151. Reasoning.displayName = 'Reasoning';
  152. ReasoningTrigger.displayName = 'ReasoningTrigger';
  153. ReasoningContent.displayName = 'ReasoningContent';