Refine useAIChat sendMessage contract

Author: IzumiSy

packages/core/src/ai/use-ai-chat.test.tsx

@@ -50,7 +50,7 @@ describe("useAIChat", () => {
 
     const { result } = renderHook(() => useAIChat({ client, model: "gpt-5-mini" }));
 
-    let sendPromise: Promise<void> | undefined;
+    let sendPromise: Promise<boolean> | undefined;
     await act(async () => {
       sendPromise = result.current.sendMessage("Hi");
     });
@@ -71,7 +71,7 @@ describe("useAIChat", () => {
 
     releaseSecondChunk();
     await act(async () => {
-      await sendPromise;
+      await expect(sendPromise).resolves.toBe(true);
     });
 
     await waitFor(() => {
@@ -102,7 +102,7 @@ describe("useAIChat", () => {
 
     const { result } = renderHook(() => useAIChat({ client, model: "gpt-5-mini" }));
 
-    let sendPromise: Promise<void> | undefined;
+    let sendPromise: Promise<boolean> | undefined;
     await act(async () => {
       sendPromise = result.current.sendMessage("Hi");
     });
@@ -118,7 +118,7 @@ describe("useAIChat", () => {
     releaseSecondChunk();
 
     await act(async () => {
-      await sendPromise;
+      await expect(sendPromise).resolves.toBe(false);
     });
 
     await waitFor(() => {
@@ -145,7 +145,7 @@ describe("useAIChat", () => {
     const { result } = renderHook(() => useAIChat({ client, model: "gpt-5-mini" }));
 
     await act(async () => {
-      await result.current.sendMessage("Hi");
+      await expect(result.current.sendMessage("Hi")).resolves.toBe(false);
     });
 
     await waitFor(() => {
@@ -157,7 +157,7 @@ describe("useAIChat", () => {
     shouldFail = false;
 
     await act(async () => {
-      await result.current.sendMessage("Retry");
+      await expect(result.current.sendMessage("Retry")).resolves.toBe(true);
     });
 
     await waitFor(() => {
@@ -187,7 +187,7 @@ describe("useAIChat", () => {
     const { result } = renderHook(() => useAIChat({ client, model: "gpt-5-mini" }));
 
     await act(async () => {
-      await result.current.sendMessage("   ");
+      await expect(result.current.sendMessage("   ")).resolves.toBe(false);
     });
 
     expect(client.chatCompletionStream).not.toHaveBeenCalled();
@@ -197,7 +197,7 @@ describe("useAIChat", () => {
     });
 
     await act(async () => {
-      await result.current.sendMessage("Second");
+      await expect(result.current.sendMessage("Second")).resolves.toBe(false);
     });
 
     expect(client.chatCompletionStream).toHaveBeenCalledTimes(1);

packages/core/src/ai/use-ai-chat.ts

@@ -13,7 +13,11 @@ export function useAIChat(config: { client: AIGatewayClient; model: string }): {
   messages: AIChatMessage[];
   status: AIChatStatus;
   error?: Error;
-  sendMessage: (message: { text: string } | string) => Promise<void>;
+  /**
+   * Returns true when the message is sent and the stream finishes successfully.
+   * Returns false when the call is ignored, aborted, or the request fails.
+   */
+  sendMessage: (message: string) => Promise<boolean>;
   stop: () => void;
 } {
   const [messages, setMessages] = useState<AIChatMessage[]>([]);
@@ -41,14 +45,14 @@ export function useAIChat(config: { client: AIGatewayClient; model: string }): {
   }, []);
 
   const sendMessage = useCallback(
-    async (message: { text: string } | string) => {
+    async (message: string) => {
       if (abortControllerRef.current) {
-        return;
+        return false;
       }
 
-      const text = (typeof message === "string" ? message : message.text).trim();
+      const text = message.trim();
       if (!text) {
-        return;
+        return false;
       }
 
       const userMessage: AIChatMessage = {
@@ -102,14 +106,16 @@ export function useAIChat(config: { client: AIGatewayClient; model: string }): {
         }
 
         setStatus("ready");
+        return true;
       } catch (caughtError) {
         if (isAbortError(caughtError)) {
           setStatus("ready");
-          return;
+          return false;
         }
 
         setError(toError(caughtError));
         setStatus("error");
+        return false;
       } finally {
         abortControllerRef.current = null;
       }