Send desktop detail text directly

Author: plutoless

docs/architecture/communication-brain.md

@@ -19,7 +19,8 @@ It does not own:
 
 Core communication policy:
 
-- typed voice/text runtime input follows the v1 path: utterance -> structured Draft -> Dispatch Plan -> Dispatch Gate -> Task
+- typed voice/ASR runtime input follows the v1 path: utterance -> structured Draft -> Dispatch Plan -> Dispatch Gate -> Task
+- desktop Bro Detail typed input in push-to-talk mode is a direct targeted Communication Brain message to the selected Bro, not a Draft preparation/confirmation surface
 - the dispatch gate is deterministic and is the final authority for starting execution
 - the default execution mode for draft-created work is read-only/proposal-first; code modification and side effects require explicit confirmation
 - free-form utterance meaning is produced by the Communication Brain interaction-classifier boundary, not by runtime transcript keyword checks

docs/guides/frontend-workbench.md

@@ -90,6 +90,9 @@ Current behavior:
 - Bro Detail draft input uses a separate connector-managed Agora STT path: the
   page first prepares a fresh Agora-safe channel and browser RTC token, then
   starts the ASR bot after the browser joins RTC with the microphone disabled
+- Desktop Bro Detail typed input in push-to-talk mode bypasses the Draft card:
+  submitting the composer sends a targeted session message directly to the
+  selected Bro instead of calling draft ASR or draft Send endpoints
 - Bro Detail does not use the shell `session_id` as the Agora channel name;
   each page start receives a unique channel from the connector to avoid channel
   conflicts

docs/memories.md

@@ -237,3 +237,4 @@ Short log of important design decisions and changes for Newbro.
 - Limited the active Newbro UI to artboarded Home, Bro Detail, mobile, onboarding, create/connect, and offline states; standalone Bros, Nodes, Settings, and custom fallback product screens are removed or rendered blank.
 - Changed first-run Bro setup so Home issues a user-owned executor-node command first and creates/binds the Bro persona only after that node records its first successful connection.
 - Made connected-node persona creation idempotent per user and executor node so repeated first-run completion requests return the existing Bro instead of creating duplicates.
+- Changed desktop Bro Detail typed input in push-to-talk mode to send a targeted Communication Brain message directly to the selected Bro instead of preparing a Draft and requiring a separate Send confirmation.

docs/protocol/draft-to-execute.md

@@ -1,6 +1,9 @@
 # Draft-to-Execute Protocol
 
-`newbro v1` uses a quiet, voice/text-driven draft-to-execute workflow.
+`newbro v1` uses a quiet, voice/ASR-driven draft-to-execute workflow.
+Desktop Bro Detail typed input in push-to-talk mode is the exception: it sends a
+targeted Communication Brain message directly to the selected Bro instead of
+preparing a Draft that needs a separate Send confirmation.
 
 The stable contract is:
 

src/newbro/ui/src/ArtboardShell.tsx

@@ -899,32 +899,14 @@ function DesktopComposerBar({
 }) {
   const shell = useNewbroShell();
   const [draft, setDraft] = useState("");
-  const draftText = shell.draftSession?.current_draft?.text ?? draft;
   const connected = shell.voiceSession.phase === "connected";
   const loading = shell.voiceSession.phase === "loading";
 
   function submitText(event: FormEvent<HTMLFormElement>) {
     event.preventDefault();
     const text = draft.trim();
     if (!text || disabled) return;
-    shell.sendMessage(text);
-    shell.submitDraftAsrTurn({ raw_text: text, assigned_bro_id: bro.id });
-    setDraft("");
-  }
-
-  async function sendCurrentDraft() {
-    if (!shell.activeShellSessionId || disabled) return;
-    await sendDraft(shell.activeShellSessionId, {
-      draft_session_id: shell.draftSession?.id,
-      draft_revision_id: shell.draftSession?.current_revision_id ?? undefined,
-    });
-    await shell.refreshShellSession();
-  }
-
-  async function clearCurrentDraft() {
-    if (!shell.activeShellSessionId) return;
-    await clearDraft(shell.activeShellSessionId, { draft_session_id: shell.draftSession?.id });
-    await shell.refreshShellSession();
+    shell.sendMessage(text, bro.id);
     setDraft("");
   }
 
@@ -943,7 +925,7 @@ function DesktopComposerBar({
         </div>
         <span className="dt-cmp-hint">
           <kbd className="dt-kbd">space</kbd>
-          {disabled ? "node required before sending" : "push to talk anywhere"}
+          {disabled ? "node required before sending" : "type sends directly"}
         </span>
       </div>
       <div className="dt-cmp-bar">
@@ -956,7 +938,7 @@ function DesktopComposerBar({
           placeholder={disabled ? "Reconnect the node before sending" : `Type to ${bro.name}...`}
           disabled={disabled}
         />
-        <button type="button" className="dt-cmp-mode nb-detail-clear" onClick={() => { void clearCurrentDraft(); }} disabled={!draftText}>
+        <button type="button" className="dt-cmp-mode nb-detail-clear" onClick={() => setDraft("")} disabled={!draft}>
           Clear
         </button>
         <button
@@ -970,15 +952,13 @@ function DesktopComposerBar({
           <Mic size={18} aria-hidden="true" />
         </button>
         <button
-          type="button"
+          type="submit"
           className="dt-cmp-send"
           aria-label="Send message"
-          disabled={disabled || !draftText}
-          onClick={() => { void sendCurrentDraft(); }}
+          disabled={disabled || !draft.trim()}
         >
           <SendHorizontal size={16} strokeWidth={2.2} />
         </button>
-        <button type="submit" className="sr-only">Send message</button>
       </div>
     </form>
   );

src/newbro/ui/src/NewbroShell.tsx

@@ -500,11 +500,11 @@ function useNewbroShellState() {
     setShellWarning(null);
   });
 
-  const sendMessage = useCallback((text: string): boolean => {
+  const sendMessage = useCallback((text: string, targetPersonaId?: string | null): boolean => {
     const socket = socketRef.current;
     if (!socket || socket.readyState !== WebSocket.OPEN) return false;
     const requestId = `msg-${Date.now()}-${Math.random().toString(36).slice(2, 8)}`;
-    sendSocketMessage(socket, requestId, text);
+    sendSocketMessage(socket, requestId, text, targetPersonaId);
     return true;
   }, []);
 

src/newbro/ui/src/__tests__/App.test.tsx

@@ -347,6 +347,24 @@ describe("Newbro artboard shell", () => {
     await waitFor(() => expect(clientMock.setVoiceTarget).toHaveBeenCalledWith("session-existing", "forge"));
   });
 
+  it("sends desktop typed Bro detail input directly to the targeted Bro", async () => {
+    window.history.replaceState({}, "", "/bros/forge?sid=session-existing");
+
+    render(<RouterProvider router={getRouter()} />);
+
+    expect(await screen.findByRole("heading", { name: "Forge" })).toBeInTheDocument();
+    fireEvent.change(screen.getByLabelText("Message"), {
+      target: { value: "Run the desktop direct send path" },
+    });
+    fireEvent.click(screen.getByRole("button", { name: "Send message" }));
+
+    await waitFor(() => expect(clientMock.sendSocketMessage).toHaveBeenCalled());
+    expect(clientMock.sendSocketMessage.mock.calls.at(-1)?.[2]).toBe("Run the desktop direct send path");
+    expect(clientMock.sendSocketMessage.mock.calls.at(-1)?.[3]).toBe("forge");
+    expect(clientMock.sendSocketDraftAsrTurn).not.toHaveBeenCalled();
+    expect(clientMock.sendDraft).not.toHaveBeenCalled();
+  });
+
   it("uses the artboarded offline detail state and blocks talk/send for disconnected usable nodes", async () => {
     const offlineNode = usableExecutorNode({
       connected_executors: [],

src/newbro/ui/src/lib/session-client.test.ts

@@ -147,6 +147,20 @@ describe("session-client transport base URL handling", () => {
     expect(revealed.token).toBe("token-1");
   });
 
+  it("includes the target persona on websocket messages when provided", async () => {
+    const client = await import("./session-client");
+    const socket = { send: vi.fn() } as unknown as WebSocket;
+
+    client.sendSocketMessage(socket, "req-1", "Run this", "forge");
+
+    expect(socket.send).toHaveBeenCalledWith(JSON.stringify({
+      type: "send_message",
+      request_id: "req-1",
+      text: "Run this",
+      target_persona_id: "forge",
+    }));
+  });
+
   it("submits task commands to the session commands endpoint", async () => {
     const fetchMock = vi.fn(async () =>
       okJsonResponse({

src/newbro/ui/src/lib/session-client.ts

@@ -284,12 +284,13 @@ export function openSessionStream(
   return openSocket<SessionStreamEvent>(`${API_PREFIX}/sessions/${sessionId}/stream`, handlers);
 }
 
-export function sendSocketMessage(socket: WebSocket, requestId: string, text: string) {
+export function sendSocketMessage(socket: WebSocket, requestId: string, text: string, targetPersonaId?: string | null) {
   socket.send(
     JSON.stringify({
       type: "send_message",
       request_id: requestId,
       text,
+      ...(targetPersonaId ? { target_persona_id: targetPersonaId } : {}),
     }),
   );
 }