Function ChatInterface

ui/src/components/chat/ChatInterface.tsx:53–1111

({ selectedAgentName, selectedNamespace, selectedSession, sessionId, shareToken }: ChatInterfaceProps)

}

export default function ChatInterface({ selectedAgentName, selectedNamespace, selectedSession, sessionId, shareToken }: ChatInterfaceProps) {
  const runInSandbox = useChatRunInSandbox();
  const substrateSandbox = useChatSubstrateSandbox();
  const router = useRouter();
  const containerRef = useRef<HTMLDivElement>(null);
  const [currentInputMessage, setCurrentInputMessage] = useState("");

  const [chatStatus, setChatStatus] = useState<ChatStatus>("ready");

  const [session, setSession] = useState<Session | null>(selectedSession || null);
  const [shareReadOnly, setShareReadOnly] = useState<boolean>(false);
  const [storedMessages, setStoredMessages] = useState<Message[]>([]);
  const [streamingMessages, setStreamingMessages] = useState<Message[]>([]);
  const [streamingContent, setStreamingContent] = useState<string>("");
  const [isStreaming, setIsStreaming] = useState<boolean>(false);
  const abortControllerRef = useRef<AbortController | null>(null);
  const isFirstAssistantChunkRef = useRef(true);
  const [isLoading, setIsLoading] = useState<boolean>(false);
  const [sessionNotFound, setSessionNotFound] = useState<boolean>(false);
  const isCreatingSessionRef = useRef<boolean>(false);
  const [isFirstMessage, setIsFirstMessage] = useState<boolean>(!sessionId);
  const [sessionStats, setSessionStats] = useState<TokenStats>({ total: 0, prompt: 0, completion: 0 });
  // Mutable ref so pendingTurnStats survives re-renders between A2A stream events
  const pendingTurnStatsRef = useRef<TokenStats | undefined>(undefined);
  const [pendingDecisions, setPendingDecisions] = useState<Record<string, ToolDecision>>({});
  const pendingDecisionsRef = useRef<Record<string, ToolDecision>>({});
  /** Per-tool rejection reasons collected as the user rejects individual tools. */
  const pendingRejectionReasonsRef = useRef<Record<string, string>>({});
  // Stream inactivity timeout (ms), configurable via Helm (ui.streamTimeoutSeconds).
  const streamTimeoutMsRef = useRef<number>(DEFAULT_STREAM_TIMEOUT_MS);

  useEffect(() => {
    let cancelled = false;
    getUiRuntimeConfig()
      .then((config) => {
        if (!cancelled) streamTimeoutMsRef.current = config.streamTimeoutMs;
      })
      .catch(() => {
        /* keep default on failure */
      });
    return () => {
      cancelled = true;
    };
  }, []);

  const {
    isListening,
    isSupported: isVoiceSupported,
    startListening,
    stopListening,
    error: voiceError,
  } = useSpeechRecognition({
    onResult(transcriptText) {
      setCurrentInputMessage(transcriptText);
    },
    onError(msg) {
      toast.error(msg);
    },