Something went wrong. Try again.
This repository has no description
Something went wrong. Try again.
22 kB · 669 lines
TSX
at next
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670import { createTeleportCommands, formatHandle, formatHandleWithAt, handleSlashCommand, teleportErrorIdentifier, type LivestreamStore, type TeleportErrorData,} from "@streamplace/core";import { Extension } from "@tiptap/core";import MentionBase from "@tiptap/extension-mention";import Placeholder from "@tiptap/extension-placeholder";import { PluginKey } from "@tiptap/pm/state";import { EditorContent, ReactRenderer, useEditor } from "@tiptap/react";import StarterKit from "@tiptap/starter-kit";import { exitSuggestion, Suggestion } from "@tiptap/suggestion";import type { SkinTone } from "frimousse";import { Reply, Smile, X } from "lucide-react";import { useCallback, useMemo, useRef, useState } from "react";import { flushSync } from "react-dom";import { useTranslation } from "react-i18next";import type { ChatMessageViewHydrated } from "streamplace";import { useStore } from "zustand";import { useChatSend } from "../../hooks/use-chat-send";import { skinToneIndex, useSkinTone } from "../../hooks/use-skin-tone";import { getEmojiData, getSkinNative, searchEmojis, useEmojiData, type Emoji, type EmojiData,} from "../../lib/emoji-data";import { useSession } from "../../lib/session";import { useStore as useAppStore } from "../../lib/store";import { Button } from "../ui/button";import { EmojiList } from "./emoji-list";import { EmojiPicker } from "./emoji-picker";import { MentionList, type MentionItem } from "./mention-list";import { TeleportDialog } from "./teleport-dialog";
const MAX_LENGTH = 300;
// Two distinct plugin keys so the mention and emoji suggestion plugins can// coexist and be queried independently from `handleKeyDown` and elsewhere.const MentionPluginKey = new PluginKey("streamplace-mention");const EmojiPluginKey = new PluginKey("streamplace-emoji");
// Extend the default Mention node to store our custom attributes (color, avatar,// did, handle, displayName) so they survive serialization inside the editor.const Mention = MentionBase.extend({ addAttributes() { return { ...this.parent?.(), did: { default: null }, handle: { default: null }, displayName: { default: null }, avatar: { default: null }, color: { default: null }, }; },});
// Module-level refs so the suggestion items functions read from fresh data// without recreating the editor (or the suggestion plugin) on every render.let mentionDataRef: { allItems: MentionItem[] } = { allItems: [] };let emojiDataRef: { data: EmojiData | null } = { data: null };
function getMentionSuggestions( chat: ChatMessageViewHydrated[], authors: { [key: string]: ChatMessageViewHydrated["chatProfile"] },): MentionItem[] { const seen = new Set<string>(); const items: MentionItem[] = []; for (const msg of chat) { const did = msg.author.did; if (seen.has(did)) continue; seen.add(did); if (!msg.author.handle || formatHandle(msg.author) === did) continue; const profile = authors[did]; items.push({ did, handle: msg.author.handle || "", displayName: msg.author.displayName || "", avatar: msg.author.avatar || null, color: profile?.color || null, }); } return items;}
function createMentionSuggestion() { return { pluginKey: MentionPluginKey, char: "@", items: ({ query }: { query: string }) => { const q = query.toLowerCase(); return mentionDataRef.allItems.filter( (item) => formatHandle(item).toLowerCase().includes(q) || item.displayName.toLowerCase().includes(q), ); }, render: () => { let component: ReactRenderer<any> | null = null; let popup: HTMLDivElement | null = null;
return { onStart: (props: any) => { component = new ReactRenderer(MentionList, { props: { items: props.items, command: (item: MentionItem) => { props.command({ id: formatHandle(item), label: formatHandleWithAt(item), did: item.did, handle: item.handle, displayName: item.displayName, avatar: item.avatar, color: item.color, }); }, }, editor: props.editor, });
if (!props.clientRect) return;
popup = document.createElement("div"); popup.style.position = "absolute"; popup.style.zIndex = "50"; // Match the editor's width so the suggestion list spans the // full chat input column instead of a narrow 220px column. popup.style.width = `${props.editor.view.dom.offsetWidth}px`; popup.appendChild(component.element); document.body.appendChild(popup);
const rect = props.clientRect(); if (rect) { popup.style.left = `${rect.left}px`; popup.style.bottom = `${window.innerHeight - rect.top + 4}px`; } }, onUpdate: (props: any) => { component?.updateProps({ items: props.items, command: (item: MentionItem) => { props.command({ id: formatHandle(item), label: formatHandleWithAt(item), did: item.did, handle: item.handle, displayName: item.displayName, avatar: item.avatar, color: item.color, }); }, });
if (!props.clientRect) return;
const rect = props.clientRect(); if (rect && popup) { popup.style.left = `${rect.left}px`; popup.style.bottom = `${window.innerHeight - rect.top + 4}px`; popup.style.width = `${props.editor.view.dom.offsetWidth}px`; } }, onKeyDown: (props: any) => { if (props.event.key === "Escape") { destroy(); return true; } return component?.ref?.onKeyDown?.(props) ?? false; }, onExit: () => { destroy(); }, };
function destroy() { // internally, we updated external html els flushSync(() => component?.destroy()); popup?.remove(); component = null; popup = null; } }, };}
// Suggestion popup factoryinterface PopupProps<T> { items: T[]; command: (item: T) => void; clientRect?: (() => DOMRect | null) | null; editor: any;}
interface PopupRenderHandlers<T> { onStart: (props: PopupProps<T>) => void; onUpdate: (props: PopupProps<T>) => void; onKeyDown: (props: { event: KeyboardEvent }) => boolean; onExit: () => void;}
function createBodyPopup<T>( ListComponent: React.ComponentType<any>, buildCommand: (props: PopupProps<T>) => (item: T) => void,) { return (): PopupRenderHandlers<T> => { let component: ReactRenderer<any> | null = null; let popup: HTMLDivElement | null = null;
return { onStart(props) { component = new ReactRenderer(ListComponent, { props: { items: props.items, command: buildCommand(props), }, editor: props.editor, }); if (!props.clientRect) return;
popup = document.createElement("div"); popup.style.position = "absolute"; popup.style.zIndex = "50"; popup.style.width = `${props.editor.view.dom.offsetWidth}px`; popup.appendChild(component.element); document.body.appendChild(popup);
const rect = props.clientRect(); if (rect) { popup.style.left = `${rect.left}px`; popup.style.bottom = `${window.innerHeight - rect.top + 4}px`; } }, onUpdate(props) { component?.updateProps({ items: props.items, command: buildCommand(props), }); if (!props.clientRect) return; const rect = props.clientRect(); if (rect && popup) { popup.style.left = `${rect.left}px`; popup.style.bottom = `${window.innerHeight - rect.top + 4}px`; popup.style.width = `${props.editor.view.dom.offsetWidth}px`; } }, onKeyDown(props) { if (props.event.key === "Escape") { flushSync(() => component?.destroy()); popup?.remove(); component = null; popup = null; return true; } return component?.ref?.onKeyDown?.(props) ?? false; }, onExit() { flushSync(() => component?.destroy()); popup?.remove(); component = null; popup = null; }, }; };}
interface EmojiSuggestionProps { getSkinTone: () => SkinTone;}
function createEmojiSuggestion({ getSkinTone }: EmojiSuggestionProps) { return { pluginKey: EmojiPluginKey, char: ":", // Should show after this many characters shouldShow: ({ query }: { query: string }) => query.length >= 3, items: ({ query }: { query: string }) => { const data = emojiDataRef.data; if (data) return searchEmojis(data, query); return getEmojiData().then((d) => { emojiDataRef.data = d; return searchEmojis(d, query); }); }, command: ({ editor, range, props }: any) => { const native = getSkinNative(props, skinToneIndex(getSkinTone())); editor .chain() .focus() .deleteRange(range) .insertContent(native + " ") .run(); }, render: createBodyPopup<Emoji>( EmojiList, (props) => (item) => props.command(item), ), };}
export function ChatInput({ store, onTeleportCreated,}: { store: LivestreamStore; onTeleportCreated?: (uri: string, targetDID: string) => void;}) { const { t } = useTranslation("common"); const { state, pdsAgent, did } = useSession(); const isAuthed = state.status === "authenticated"; const send = useChatSend(store); const replyToMessage = useStore(store, (s) => s.replyToMessage); const chat = useStore(store, (s) => s.chat); const authors = useStore(store, (s) => s.authors); const [error, setError] = useState<string | null>(null); const [sending, setSending] = useState(false); const [emojiOpen, setEmojiOpen] = useState(false); const [skinTone, setSkinTone] = useSkinTone(); const [teleportOpen, setTeleportOpen] = useState(false); const commands = useMemo(() => { if (!pdsAgent || !did) return []; return createTeleportCommands( pdsAgent, did, () => { const livestream = store.getState().livestream; return livestream && !livestream.record.endedAt ? { uri: livestream.uri, cid: livestream.cid, streamerDid: livestream.author.did, } : null; }, (uri, targetDID) => { store.getState().setActiveTeleportUri(uri); onTeleportCreated?.(uri, targetDID); }, () => setTeleportOpen(true), ); }, [did, pdsAgent, store, onTeleportCreated]);
// Keep module-level refs fresh so the suggestion items functions always // have up-to-date data without recreating the editor. mentionDataRef.allItems = getMentionSuggestions(chat, authors); const emojiData = useEmojiData(); emojiDataRef.data = emojiData;
// skinToneRef lets the suggestion command (a closure created once) read // the latest skin tone value without recreating the suggestion plugin. const skinToneRef = useRef(skinTone); skinToneRef.current = skinTone;
const mentionConfig = useMemo(() => createMentionSuggestion(), []); const emojiConfig = useMemo( () => createEmojiSuggestion({ getSkinTone: () => skinToneRef.current }), [], );
// Store onSubmit in a ref so editorProps can access it without depending on // sending state (which would recreate the editor on every send). const onSubmitRef = useRef<() => void>(() => {});
// Ref to the smile trigger button; passed to the picker so it can // position itself relative to it (the picker portals to document.body // to escape the chat sidebar's overflow-hidden wrapper). const smileButtonRef = useRef<HTMLButtonElement>(null);
const editor = useEditor( { extensions: [ StarterKit.configure({ heading: false, bold: false, italic: false, strike: false, code: false, blockquote: false, bulletList: false, orderedList: false, codeBlock: false, horizontalRule: false, hardBreak: false, }), Placeholder.configure({ placeholder: t("chat-send-message"), }), Mention.configure({ HTMLAttributes: { class: "mention", }, suggestion: mentionConfig, renderText({ node }) { return node.attrs.label ?? `@${node.attrs.id}`; }, renderHTML({ node }) { const id = node.attrs.id as string; const label = (node.attrs.label as string) ?? `@${id}`; const color = node.attrs.color as { red: number; green: number; blue: number; } | null; const colorStr = color ? `rgb(${color.red}, ${color.green}, ${color.blue})` : undefined; return [ "span", { "data-type": "mention", "data-id": id, "data-label": label, class: "mention", style: colorStr ? `color: ${colorStr}` : undefined, }, label, ]; }, }), // The emoji suggestion plugin lives on a thin extension that just // registers the ProseMirror plugin. We insert the native character // as plain text (no custom node needed) and rely on ProseMirror's // text handling for cursor/backspace behavior. Extension.create({ name: "emoji-suggestion", addProseMirrorPlugins() { return [ Suggestion({ editor: this.editor, ...emojiConfig, }), ]; }, }), ], editorProps: { attributes: { // ProseMirror's default CSS adds white-space: pre-wrap and // word-wrap: break-word, but that stylesheet isn't imported // here, so we add the equivalents via Tailwind to keep long // input from overflowing horizontally instead of wrapping. class: "min-h-[36px] max-h-[120px] min-w-0 overflow-y-auto whitespace-pre-wrap break-words px-3 py-2 text-sm outline-none", }, handleKeyDown: (view, event) => { if (event.key === "Enter" && !event.shiftKey) { const mentionActive = MentionPluginKey.getState(view.state)?.active; const emojiActive = EmojiPluginKey.getState(view.state)?.active; // use decoration as final check for active suggestions const suggestionVisible = Boolean( view.dom.querySelector("[data-decoration-id]") ?? view.dom.querySelector(".suggestion"), ); if (mentionActive || emojiActive || suggestionVisible) return false; onSubmitRef.current(); return true; } // Escape dismisses whichever popup is open (whichever the user // most recently engaged with), even when the suggestion plugin // is still processing. if (event.key === "Escape") { const mentionActive = MentionPluginKey.getState(view.state)?.active; const emojiActive = EmojiPluginKey.getState(view.state)?.active; if (mentionActive) { exitSuggestion(view, MentionPluginKey); return true; } if (emojiActive) { exitSuggestion(view, EmojiPluginKey); return true; } } return false; }, }, onUpdate: () => { setError(null); }, }, [], );
const onSubmit = useCallback(async () => { if (!editor || sending) return; const text = editor.getText().trim(); if (!text) return;
setError(null); setSending(true); try { if (text.startsWith("/")) { const result = await handleSlashCommand(text, commands); if (result.handled) { if (result.error) { setError( result.errorData ? t( teleportErrorIdentifier(result.errorData), result.errorData.params, ) : result.error, ); return; } editor.commands.clearContent(); store.setState((s) => ({ ...s, replyToMessage: null })); return; } } await send(text); editor.commands.clearContent(); } catch (error) { console.error("Failed to send chat message:", error); setError(t("chat-failed-send")); } finally { setSending(false); } }, [editor, sending, send, store, commands, t]);
const submitTeleport = useCallback( async ( handle: string, countdownSeconds: number, ): Promise<TeleportErrorData | undefined> => { const result = await handleSlashCommand( `/teleport ${handle} ${countdownSeconds}`, commands, ); if (!result.handled || result.error) { return result.errorData ?? { type: "teleport", code: "create" }; } return undefined; }, [commands], );
// Keep the ref fresh so editorProps.handleKeyDown can call the latest onSubmit. onSubmitRef.current = () => onSubmit();
const handleEmojiSelect = useCallback( ( emoji: { type: "standard"; native: string } | { type: "custom"; name: string }, ) => { if (editor) { const text = emoji.type === "standard" ? emoji.native : `:${emoji.name}: `; editor.chain().focus().insertContent(text).run(); } setEmojiOpen(false); }, [editor], );
if (!isAuthed) { return ( <div className="py-2 text-center text-sm text-(--color-fg-muted)"> <Button type="button" variant="muted" onClick={() => useAppStore.getState().openLoginModal()} className="text-lg font-medium text-(--color-accent) hover:underline" > {t("chat-log-in-to")} </Button> </div> ); }
const textLength = editor?.getText().length ?? 0;
return ( <div> {replyToMessage && ( <div className="mb-1 flex items-center gap-2 rounded border border-(--color-border) bg-(--color-bg-overlay) px-2 py-1 text-xs"> <Reply className="h-3 w-3 shrink-0 text-(--color-fg-muted)" /> <span className="min-w-0 flex-1 truncate text-(--color-fg-muted)"> <span className="font-medium"> {t("chat-replying-to", { handle: formatHandle(replyToMessage.author), })} </span> {" · "} {replyToMessage.record.text} </span> <Button type="button" onClick={() => store.setState((s) => ({ ...s, replyToMessage: null })) } variant="ghost" size="icon-touch" aria-label={t("close")} className="-mr-1 shrink-0 text-(--color-fg-muted) hover:text-(--color-fg)" > <X className="h-3 w-3" /> </Button> </div> )}
<form onSubmit={(e) => { e.preventDefault(); onSubmit(); }} className="flex items-end gap-2" > <div className="relative min-w-0 flex-1 rounded-lg border border-(--color-border) bg-(--color-bg) focus-within:border-(--color-accent)"> {editor && <EditorContent editor={editor} />}
{textLength > 200 && ( <span className={`pointer-events-none absolute top-1/2 right-2 -translate-y-1/2 text-[10px] tabular-nums ${textLength >= MAX_LENGTH ? "text-(--color-danger)" : "text-(--color-fg-subtle)"}`} > {MAX_LENGTH - textLength} </span> )} </div>
<Button ref={smileButtonRef} type="button" variant="ghost" size="icon" className="h-9 w-9 shrink-0" aria-label={t("chat-insert-emoji")} onClick={() => setEmojiOpen((o) => !o)} > <Smile className="h-4 w-4" /> </Button>
<Button type="submit" size="lg" disabled={sending || textLength === 0}> {sending ? "..." : t("chat-send-button")} </Button> </form>
{emojiOpen && ( <EmojiPicker isOpen={emojiOpen} onClose={() => setEmojiOpen(false)} onSelect={handleEmojiSelect} skinTone={skinTone} onSkinToneChange={setSkinTone} anchorRef={smileButtonRef} /> )}
{teleportOpen && ( <TeleportDialog open={teleportOpen} onOpenChange={setTeleportOpen} onSubmit={submitTeleport} /> )}
{error && ( <div className="mt-1 text-xs text-(--color-danger)" role="alert"> {error} </div> )} </div> );}