mirror of
https://github.com/multica-ai/multica.git
synced 2026-07-29 06:28:23 +02:00
A complete UX upgrade for chat sending → receiving → recovering.
* StatusPill replaces the orphan spinner — stage-aware copy
("Reading files · 12s", "Searching the web · 14s", "Typing · 24s"),
shimmer text, monotonic timer, derived effective status, > 60s
warning tone, > 5min cancel button.
* WS writethrough on task:queued / task:dispatch / task:cancelled so
pendingTask cache stays in sync with the daemon state machine without
invalidate-refetch latency. broadcastTaskDispatch now includes
chat_session_id when the task is for a chat session — the existing
payload only carried it on the generic task: events, leaving the pill
stuck at "Queued" until completion.
* Failure fallback — FailTask writes a chat_message tagged with
failure_reason (mirrors the issue path's system comment, gated on
retried==nil). Front-end renders an inline note ("Connection failed",
with a Show details collapsible) instead of the previous black hole.
* Elapsed timing — chat_message.elapsed_ms persists task.completed_at -
task.created_at on success/failure rows. UI shows "Replied in 38s" /
"Failed after 12s" beneath assistant bubbles. Format helper shared
between StatusPill and the persisted caption so the live timer and
final reading never disagree.
* Optimistic burst rebalanced — pendingTask seed + created_at moved
before the HTTP roundtrip so the pill appears the instant the user
hits send; handleStop is fire-and-forget so cancel feels immediate
(server confirmation arrives via task:cancelled WS).
* Presence integration — chat avatars use ActorAvatar (status dot +
hover card); OfflineBanner above the input on offline/unstable;
SessionDropdown shows per-row in-flight/unread pip plus a
cross-session aggregate pip on the closed trigger.
* Editor blur on send so the caret stops competing with the StatusPill
/ streaming reply for the user's attention.
* Chat panel isOpen now persists globally; defaults to OPEN for new
users (storage key absence) so the feature is discoverable. Existing
users' prior choice is respected.
* DB: migrations 062 (failure_reason) + 063 (elapsed_ms), both
ADD COLUMN NULL — fast, non-blocking, backwards compatible.
* WS: task:failed chat path now invalidates chatKeys.messages — fixes
a pre-existing bug where the failure bubble required a page refresh
to appear.
Co-authored-by: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
133 lines
5.0 KiB
TypeScript
133 lines
5.0 KiB
TypeScript
"use client";
|
|
|
|
import type { ReactNode } from "react";
|
|
import { useRef, useState } from "react";
|
|
import { ContentEditor, type ContentEditorRef } from "../../editor";
|
|
import { SubmitButton } from "@multica/ui/components/common/submit-button";
|
|
import { useChatStore, DRAFT_NEW_SESSION } from "@multica/core/chat";
|
|
import { createLogger } from "@multica/core/logger";
|
|
|
|
const logger = createLogger("chat.ui");
|
|
|
|
interface ChatInputProps {
|
|
onSend: (content: string) => void;
|
|
onStop?: () => void;
|
|
isRunning?: boolean;
|
|
disabled?: boolean;
|
|
/** Name of the currently selected agent, used in the placeholder. */
|
|
agentName?: string;
|
|
/** Rendered at the bottom-left of the input bar — typically the agent picker. */
|
|
leftAdornment?: ReactNode;
|
|
/** Rendered just before the submit button — used for context-anchor action. */
|
|
rightAdornment?: ReactNode;
|
|
/** Rendered inside the rounded container, above the editor — attached
|
|
* context cards, drafts, etc. */
|
|
topSlot?: ReactNode;
|
|
}
|
|
|
|
export function ChatInput({
|
|
onSend,
|
|
onStop,
|
|
isRunning,
|
|
disabled,
|
|
agentName,
|
|
leftAdornment,
|
|
rightAdornment,
|
|
topSlot,
|
|
}: ChatInputProps) {
|
|
const editorRef = useRef<ContentEditorRef>(null);
|
|
const activeSessionId = useChatStore((s) => s.activeSessionId);
|
|
const selectedAgentId = useChatStore((s) => s.selectedAgentId);
|
|
// Scope the new-chat draft by agent:
|
|
// 1. Switching agents while composing a brand-new chat gives each
|
|
// agent its own draft (no cross-agent leakage).
|
|
// 2. Tiptap's Placeholder extension is only applied at mount; this
|
|
// key changes on agent switch so the editor remounts and the
|
|
// `Tell {agent} what to do…` placeholder refreshes.
|
|
const draftKey =
|
|
activeSessionId ?? `${DRAFT_NEW_SESSION}:${selectedAgentId ?? ""}`;
|
|
// Select a primitive — empty-string fallback keeps referential stability.
|
|
const inputDraft = useChatStore((s) => s.inputDrafts[draftKey] ?? "");
|
|
const setInputDraft = useChatStore((s) => s.setInputDraft);
|
|
const clearInputDraft = useChatStore((s) => s.clearInputDraft);
|
|
const [isEmpty, setIsEmpty] = useState(!inputDraft.trim());
|
|
|
|
const handleSend = () => {
|
|
const content = editorRef.current?.getMarkdown()?.replace(/(\n\s*)+$/, "").trim();
|
|
if (!content || isRunning || disabled) {
|
|
logger.debug("input.send skipped", {
|
|
emptyContent: !content,
|
|
isRunning,
|
|
disabled,
|
|
});
|
|
return;
|
|
}
|
|
// Capture draft key BEFORE onSend — creating a new session mutates
|
|
// activeSessionId synchronously, so reading it after onSend would point
|
|
// at the new session and leave the old draft orphaned.
|
|
const keyAtSend = draftKey;
|
|
logger.info("input.send", { contentLength: content.length, draftKey: keyAtSend });
|
|
onSend(content);
|
|
editorRef.current?.clearContent();
|
|
// Drop focus so the caret doesn't keep blinking under the StatusPill /
|
|
// streaming reply that's about to take over the user's attention. The
|
|
// input is also `disabled` once isRunning flips, and a focused-but-
|
|
// disabled editor reads as a stale cursor. We deliberately don't auto-
|
|
// refocus on completion — that would interrupt the user if they're
|
|
// selecting text from the assistant reply; one click to refocus is
|
|
// a fair price for not stealing focus mid-action.
|
|
editorRef.current?.blur();
|
|
clearInputDraft(keyAtSend);
|
|
setIsEmpty(true);
|
|
};
|
|
|
|
const placeholder = disabled
|
|
? "This session is archived"
|
|
: agentName
|
|
? `Tell ${agentName} what to do…`
|
|
: "Tell me what to do…";
|
|
|
|
return (
|
|
<div className="px-5 pb-3 pt-0">
|
|
<div className="relative mx-auto flex min-h-16 max-h-40 w-full max-w-4xl flex-col rounded-lg bg-card pb-9 border-1 border-border transition-colors focus-within:border-brand">
|
|
{topSlot}
|
|
<div className="flex-1 min-h-0 overflow-y-auto px-3 py-2">
|
|
<ContentEditor
|
|
// Remount the editor when the active session changes so its
|
|
// uncontrolled defaultValue picks up the new session's draft.
|
|
key={draftKey}
|
|
ref={editorRef}
|
|
defaultValue={inputDraft}
|
|
placeholder={placeholder}
|
|
onUpdate={(md) => {
|
|
setIsEmpty(!md.trim());
|
|
setInputDraft(draftKey, md);
|
|
}}
|
|
onSubmit={handleSend}
|
|
debounceMs={100}
|
|
// Chat is short-form — the floating formatting toolbar is
|
|
// more distraction than feature here.
|
|
showBubbleMenu={false}
|
|
// Enter sends; Shift-Enter inserts a hard break.
|
|
submitOnEnter
|
|
/>
|
|
</div>
|
|
{leftAdornment && (
|
|
<div className="absolute bottom-1.5 left-2 flex items-center">
|
|
{leftAdornment}
|
|
</div>
|
|
)}
|
|
<div className="absolute bottom-1 right-1.5 flex items-center gap-2">
|
|
{rightAdornment}
|
|
<SubmitButton
|
|
onClick={handleSend}
|
|
disabled={isEmpty || !!disabled}
|
|
running={isRunning}
|
|
onStop={onStop}
|
|
/>
|
|
</div>
|
|
</div>
|
|
</div>
|
|
);
|
|
}
|