25211526966

Committed 01 May 2026 10:42AM UTC coverage: 90.981% (-0.2%) from 91.201%

Build # 25211526966

Build Type

Pull #46

github

Committed by

web-flow

Commit Message

Merge 7fedfe62d into 9d971c85b

Pull Request Pull Request #46: Bug fixes w18

Coverage Stats

2870 of 3390 branches covered (84.66%)

Branch coverage included in aggregate %.

890 of 1011 new or added lines in 53 files covered. (88.03%)

5 existing lines in 3 files now uncovered.

11697 of 12621 relevant lines covered (92.68%)

33.41 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

77.09

/frontend/src/components/chat/ThreadPanel.tsx

import { useEffect, useLayoutEffect, useMemo, useRef } from 'react';
import { MessageItem } from './MessageItem';
import { MessageInput, type MessageInputHandle } from './MessageInput';
import { MessageDropZone } from './MessageDropZone';
import { ThreadTypingIndicator } from './TypingIndicator';
import { Button } from '@/components/ui/button';
import { X } from 'lucide-react';
import { useAtBottomRef } from '@/hooks/useAtBottomRef';
import { useSendMessage, type SendMessageInput } from '@/hooks/useMessages';
import { useThreadMessages } from '@/hooks/useThreads';
import { useUsersBatch } from '@/hooks/useUsersBatch';
import { collectMessageUserIDs } from '@/lib/message-users';
import type { UserMapEntry } from './MessageList';

const ANCHOR_HIGHLIGHT_CLASSES = ['ring-1', 'ring-amber-400/50', 'rounded-md'];
const ANCHOR_HIGHLIGHT_MS = 2200;

interface ThreadPanelProps {
  channelId?: string;
  conversationId?: string;
  threadRootID: string;
  onClose: () => void;
  userMap: Record<string, UserMapEntry>;
  currentUserId?: string;
  // Deep-link target inside the thread — when set, the panel scrolls
  // to and highlights this reply instead of snapping to the bottom.
  // Used for search/threads-page links of the form
  // /channel/x?thread=root#msg-replyId.
  anchorMsgId?: string;
  // Per-navigation revision token; same role as in MessageList.
  anchorRevision?: string;
}

export function ThreadPanel({
  channelId,
  conversationId,
  threadRootID,
  onClose,
  userMap,
  currentUserId,
  anchorMsgId,
  anchorRevision,
}: ThreadPanelProps) {
  const { data, isLoading } = useThreadMessages({ channelId, conversationId, threadRootID });

  // Authors + reactors of thread messages may not be in the parent
  // userMap (which was built from the channel page, not the thread).
  // Fetch any missing IDs so reaction tooltips don't show "Unknown".
  const missingUserIDs = useMemo(() => {
    const ids = collectMessageUserIDs(data ?? []);
    return ids.filter((id) => !userMap[id]);
  }, [data, userMap]);
  const { data: extras } = useUsersBatch(missingUserIDs);
  const mergedUserMap = useMemo(() => {
    if (!extras || extras.length === 0) return userMap;
    const m: Record<string, UserMapEntry> = { ...userMap };
    for (const u of extras) {
      m[u.id] = { displayName: u.displayName || 'Unknown', avatarURL: u.avatarURL };
    }
    return m;
  }, [userMap, extras]);
  // Adapter for MessageItem — its userMap prop is the .get-style lookup
  // ThreadActionBar / reaction tooltip both consume.
  const userLookup = useMemo(
    () => ({ get: (id: string) => mergedUserMap[id] }),
    [mergedUserMap],
  );

  const send = useSendMessage({ channelId, conversationId });
  const inputRef = useRef<MessageInputHandle>(null);
  const scrollRef = useRef<HTMLDivElement>(null);
  // Inner messages container — observed by the ResizeObservers below
  // (NOT scroller.lastElementChild, which can be a fixed-height
  // sentinel and would never report real content shifts).
  const innerRef = useRef<HTMLDivElement>(null);
  const wasAtBottomRef = useAtBottomRef(scrollRef);

  // userHasScrolledRef is shared with the anchor effect below. Once
  // the user takes control of the scroll, the bottom-stick RO can
  // engage even in deep-link mode — but until then it stays a no-op
  // so an anchor that landed near the bottom doesn't get yanked by
  // settling avatars / attachments.
  const userHasScrolledRef = useRef(false);
  // Snap to the bottom on open, follow new replies while at the
  // bottom, and keep re-pinning while async content settles. The
  // ResizeObserver lives for the duration of the open thread (gated
  // by wasAtBottomRef so it doesn't yank a reader who has scrolled
  // up). Re-arms when the user opens a different thread.
  const stickyDoneRef = useRef(false);
  const prevLenRef = useRef(0);
  const stickyROrRef = useRef<ResizeObserver | null>(null);
  useLayoutEffect(() => {
    stickyDoneRef.current = false;
    prevLenRef.current = 0;
    if (stickyROrRef.current) {
      stickyROrRef.current.disconnect();
      stickyROrRef.current = null;
    }
  }, [threadRootID, anchorMsgId]);
  useLayoutEffect(() => {
    const len = data?.length ?? 0;
    if (len === 0) return;
    const el = scrollRef.current;
    if (!el) return;
    const stick = () => {
      el.scrollTop = el.scrollHeight;
      wasAtBottomRef.current = true;
    };

    if (!stickyDoneRef.current) {
      // Initial open. Skip the snap-to-newest if a deep-link anchor
      // is set — the anchor effect below controls position. The RO
      // is still installed so live-following resumes if/when the
      // user reaches the bottom themselves.
      if (!anchorMsgId) {
        stick();
      }
      stickyDoneRef.current = true;
      prevLenRef.current = len;
      if (typeof ResizeObserver !== 'undefined') {
        const inner = innerRef.current;
        if (inner) {
          // See MessageList: in deep-link mode (anchor set) we never
          // auto-stick — the reader went to a specific reply and
          // didn't opt into live-tail follow. In live-tail mode we
          // follow growth while the reader is at the bottom.
          let lastHeight = el.scrollHeight;
          const ro = new ResizeObserver(() => {
            const height = el.scrollHeight;
            const grew = height > lastHeight + 0.5;
            lastHeight = height;
            if (anchorMsgId) return;
            if (!grew) return;
            if (wasAtBottomRef.current) stick();
          });
          ro.observe(inner);
          stickyROrRef.current = ro;
        }
      }
      return;
    }

    // New reply on a thread already open — follow only if the user
    // hasn't scrolled away. Compute the distance synchronously
    // rather than reading wasAtBottomRef so a programmatic
    // scrollTop set (with no accompanying scroll event) is handled
    // correctly.
    if (len > prevLenRef.current) {
      const distanceFromBottom = el.scrollHeight - el.scrollTop - el.clientHeight;
      if (distanceFromBottom < 120) stick();
    }
    prevLenRef.current = len;
  }, [data?.length, wasAtBottomRef, anchorMsgId]);

  // Deep-link landing inside the thread panel: scroll the matching
  // reply into view + highlight, exactly once per (threadRootID,
  // anchor). Mirrors MessageList's anchor logic, including a short-
  // lived follow-anchor RO so async reply content (avatars, attachments)
  // settling above the anchor doesn't push it off-screen. See
  // MessageList.tsx for the StrictMode/page-fetch invariants this
  // shape preserves.
  const anchorAppliedRef = useRef<string | null>(null);
  const followDeadlineRef = useRef<number>(0);
  useLayoutEffect(() => {
    if (!anchorMsgId) {
      anchorAppliedRef.current = null;
      userHasScrolledRef.current = false;
      followDeadlineRef.current = 0;
      return;
    }
    if ((data?.length ?? 0) === 0) return;
    const scroller = scrollRef.current;
    if (!scroller) return;
    const el = document.getElementById(`msg-${anchorMsgId}`);
    if (!el) return;

    const dedupKey = anchorRevision ? `${anchorMsgId}@${anchorRevision}` : anchorMsgId;
    if (anchorAppliedRef.current !== dedupKey) {
      el.scrollIntoView({ block: 'center' });
      anchorAppliedRef.current = dedupKey;
      wasAtBottomRef.current = false;
      userHasScrolledRef.current = false;
      followDeadlineRef.current = Date.now() + 1500;
    }

    if (userHasScrolledRef.current) return;
    if (Date.now() >= followDeadlineRef.current) return;
    if (typeof ResizeObserver === 'undefined') return;
    const inner = innerRef.current;
    if (!inner) return;
    let expectedScrollTop = scroller.scrollTop;
    const stopFollowing = () => {
      ro.disconnect();
      scroller.removeEventListener('scroll', onScroll);
      window.clearTimeout(timeoutId);
    };
    const onScroll = () => {
      if (Math.abs(scroller.scrollTop - expectedScrollTop) > 5) {
        userHasScrolledRef.current = true;
        stopFollowing();
      }
    };
    const ro = new ResizeObserver(() => {
      el.scrollIntoView({ block: 'center' });
      expectedScrollTop = scroller.scrollTop;
    });
    ro.observe(inner);
    scroller.addEventListener('scroll', onScroll, { passive: true });
    const remaining = Math.max(0, followDeadlineRef.current - Date.now());
    const timeoutId = window.setTimeout(stopFollowing, remaining);
    return stopFollowing;
  }, [anchorMsgId, anchorRevision, data?.length, wasAtBottomRef]);

  // Cosmetic highlight ring on the in-thread anchor.
  const repliesHaveLoaded = (data?.length ?? 0) > 0;
  useEffect(() => {
    if (!anchorMsgId || !repliesHaveLoaded) return;
    const el = document.getElementById(`msg-${anchorMsgId}`);
    if (!el) return;
    el.classList.add(...ANCHOR_HIGHLIGHT_CLASSES);
    const t = window.setTimeout(() => {
      el.classList.remove(...ANCHOR_HIGHLIGHT_CLASSES);
    }, ANCHOR_HIGHLIGHT_MS);
    return () => {
      window.clearTimeout(t);
      el.classList.remove(...ANCHOR_HIGHLIGHT_CLASSES);
    };
  }, [anchorMsgId, anchorRevision, repliesHaveLoaded]);
  useEffect(
    () => () => {
      if (stickyROrRef.current) {
        stickyROrRef.current.disconnect();
        stickyROrRef.current = null;
      }
    },
    [],
  );

  // Backup for the bottom-stick RO: late-loading <img> elements
  // (avatars, attachments, unfurl thumbs) finish at unpredictable
  // moments. Listening for delegated load events on the inner
  // container is the most reliable signal that "this image just
  // grew its box" — gated by wasAtBottomRef and skipped in deep-link
  // mode. Mirrors MessageList; see that file for the full rationale.
  useEffect(() => {
    const el = scrollRef.current;
    const inner = innerRef.current;
    if (!el || !inner) return;
    if (anchorMsgId) return;
    const onLoad = (e: Event) => {
      const target = e.target as HTMLElement | null;
      if (!target || target.tagName !== 'IMG') return;
      if (!wasAtBottomRef.current) return;
      el.scrollTop = el.scrollHeight;
    };
    inner.addEventListener('load', onLoad, true);
    return () => inner.removeEventListener('load', onLoad, true);
  }, [anchorMsgId, wasAtBottomRef]);

  function handleReply(input: SendMessageInput) {
    send.mutate({ ...input, parentMessageID: threadRootID });
  }

  return (
    <aside className="w-[28rem] border-l flex flex-col" aria-label="Thread">
      <div className="flex items-center justify-between border-b px-4 py-3">
        <h2 className="text-sm font-semibold">Thread</h2>
        <Button
          variant="ghost"
          size="icon"
          className="h-7 w-7"
          onClick={onClose}
          aria-label="Close thread"
        >
          <X className="h-4 w-4" />
        </Button>
      </div>
      <MessageDropZone onFiles={(files) => void inputRef.current?.uploadFiles(files)}>
        <div ref={scrollRef} className="flex-1 overflow-y-auto">
          <div ref={innerRef} className="p-2 space-y-2">
            {isLoading && (
              <p className="text-xs text-muted-foreground p-2">Loading replies...</p>
            )}
            {data?.length === 0 && (
              <p className="text-xs text-muted-foreground p-2">No replies yet. Start the thread!</p>
            )}
            {data?.map((msg) => {
              const u = mergedUserMap[msg.authorID];
              return (
                <MessageItem
                  key={msg.id}
                  message={msg}
                  authorName={u?.displayName ?? 'Unknown'}
                  authorAvatarURL={u?.avatarURL}
                  authorOnline={u?.online}
                  isOwn={msg.authorID === currentUserId}
                  channelId={channelId}
                  conversationId={conversationId}
                  currentUserId={currentUserId}
                  userMap={userLookup}
                  inThread
                />
              );
            })}
          </div>
        </div>
        <ThreadTypingIndicator
          parentID={channelId ?? conversationId}
          threadRootID={threadRootID}
          userMap={mergedUserMap}
        />
        <MessageInput
          ref={inputRef}
          onSend={handleReply}
          disabled={send.isPending}
          placeholder="Reply..."
          focusKey={threadRootID}
          typingParentID={channelId ?? conversationId}
          typingParentType={channelId ? 'channel' : 'conversation'}
          typingThreadRootID={threadRootID}
        />
      </MessageDropZone>
    </aside>
  );
}

1	import { useEffect, useLayoutEffect, useMemo, useRef } from 'react';
2	import { MessageItem } from './MessageItem';
3	import { MessageInput, type MessageInputHandle } from './MessageInput';
4	import { MessageDropZone } from './MessageDropZone';
5	import { ThreadTypingIndicator } from './TypingIndicator';
6	import { Button } from '@/components/ui/button';
7	import { X } from 'lucide-react';
8	import { useAtBottomRef } from '@/hooks/useAtBottomRef';
9	import { useSendMessage, type SendMessageInput } from '@/hooks/useMessages';
10	import { useThreadMessages } from '@/hooks/useThreads';
11	import { useUsersBatch } from '@/hooks/useUsersBatch';
12	import { collectMessageUserIDs } from '@/lib/message-users';
13	import type { UserMapEntry } from './MessageList';
14
15	const ANCHOR_HIGHLIGHT_CLASSES = ['ring-1', 'ring-amber-400/50', 'rounded-md'];	14✔
16	const ANCHOR_HIGHLIGHT_MS = 2200;	14✔
17
18	interface ThreadPanelProps {
19	channelId?: string;
20	conversationId?: string;
21	threadRootID: string;
22	onClose: () => void;
23	userMap: Record<string, UserMapEntry>;
24	currentUserId?: string;
25	// Deep-link target inside the thread — when set, the panel scrolls
26	// to and highlights this reply instead of snapping to the bottom.
27	// Used for search/threads-page links of the form
28	// /channel/x?thread=root#msg-replyId.
29	anchorMsgId?: string;
30	// Per-navigation revision token; same role as in MessageList.
31	anchorRevision?: string;
32	}
33
34	export function ThreadPanel({
35	channelId,
36	conversationId,
37	threadRootID,
38	onClose,
39	userMap,
40	currentUserId,
41	anchorMsgId,
42	anchorRevision,
43	}: ThreadPanelProps) {
44	const { data, isLoading } = useThreadMessages({ channelId, conversationId, threadRootID });	26✔
45
46	// Authors + reactors of thread messages may not be in the parent
47	// userMap (which was built from the channel page, not the thread).
48	// Fetch any missing IDs so reaction tooltips don't show "Unknown".
49	const missingUserIDs = useMemo(() => {	26✔
50	const ids = collectMessageUserIDs(data ?? []);	26✔
51	return ids.filter((id) => !userMap[id]);	26✔
52	}, [data, userMap]);
53	const { data: extras } = useUsersBatch(missingUserIDs);	26✔
54	const mergedUserMap = useMemo(() => {	26✔
55	if (!extras \|\| extras.length === 0) return userMap;	19!
56	const m: Record<string, UserMapEntry> = { ...userMap };	×
57	for (const u of extras) {	×
58	m[u.id] = { displayName: u.displayName \|\| 'Unknown', avatarURL: u.avatarURL };	×
59	}
60	return m;	×
61	}, [userMap, extras]);
62	// Adapter for MessageItem — its userMap prop is the .get-style lookup
63	// ThreadActionBar / reaction tooltip both consume.
64	const userLookup = useMemo(	26✔
65	() => ({ get: (id: string) => mergedUserMap[id] }),	19✔
66	[mergedUserMap],
67	);
68
69	const send = useSendMessage({ channelId, conversationId });	26✔
70	const inputRef = useRef<MessageInputHandle>(null);	26✔
71	const scrollRef = useRef<HTMLDivElement>(null);	26✔
72	// Inner messages container — observed by the ResizeObservers below
73	// (NOT scroller.lastElementChild, which can be a fixed-height
74	// sentinel and would never report real content shifts).
75	const innerRef = useRef<HTMLDivElement>(null);	26✔
76	const wasAtBottomRef = useAtBottomRef(scrollRef);	26✔
77
78	// userHasScrolledRef is shared with the anchor effect below. Once
79	// the user takes control of the scroll, the bottom-stick RO can
80	// engage even in deep-link mode — but until then it stays a no-op
81	// so an anchor that landed near the bottom doesn't get yanked by
82	// settling avatars / attachments.
83	const userHasScrolledRef = useRef(false);	26✔
84	// Snap to the bottom on open, follow new replies while at the
85	// bottom, and keep re-pinning while async content settles. The
86	// ResizeObserver lives for the duration of the open thread (gated
87	// by wasAtBottomRef so it doesn't yank a reader who has scrolled
88	// up). Re-arms when the user opens a different thread.
89	const stickyDoneRef = useRef(false);	26✔
90	const prevLenRef = useRef(0);	26✔
91	const stickyROrRef = useRef<ResizeObserver \| null>(null);	26✔
92	useLayoutEffect(() => {	26✔
93	stickyDoneRef.current = false;	17✔
94	prevLenRef.current = 0;	17✔
95	if (stickyROrRef.current) {	17✔
96	stickyROrRef.current.disconnect();	1✔
97	stickyROrRef.current = null;	1✔
98	}
99	}, [threadRootID, anchorMsgId]);
100	useLayoutEffect(() => {	26✔
101	const len = data?.length ?? 0;	26✔
102	if (len === 0) return;	26✔
103	const el = scrollRef.current;	11✔
104	if (!el) return;	11!
105	const stick = () => {	11✔
106	el.scrollTop = el.scrollHeight;	8✔
107	wasAtBottomRef.current = true;	8✔
108	};
109
110	if (!stickyDoneRef.current) {	11✔
111	// Initial open. Skip the snap-to-newest if a deep-link anchor
112	// is set — the anchor effect below controls position. The RO
113	// is still installed so live-following resumes if/when the
114	// user reaches the bottom themselves.
115	if (!anchorMsgId) {	9✔
116	stick();	7✔
117	}
118	stickyDoneRef.current = true;	9✔
119	prevLenRef.current = len;	9✔
120	if (typeof ResizeObserver !== 'undefined') {	9!
121	const inner = innerRef.current;	9✔
122	if (inner) {	9!
123	// See MessageList: in deep-link mode (anchor set) we never
124	// auto-stick — the reader went to a specific reply and
125	// didn't opt into live-tail follow. In live-tail mode we
126	// follow growth while the reader is at the bottom.
127	let lastHeight = el.scrollHeight;	9✔
128	const ro = new ResizeObserver(() => {	9✔
129	const height = el.scrollHeight;	×
130	const grew = height > lastHeight + 0.5;	×
131	lastHeight = height;	×
132	if (anchorMsgId) return;	×
133	if (!grew) return;	×
134	if (wasAtBottomRef.current) stick();	×
135	});
136	ro.observe(inner);	9✔
137	stickyROrRef.current = ro;	9✔
138	}
139	}
140	return;	9✔
141	}
142
143	// New reply on a thread already open — follow only if the user
144	// hasn't scrolled away. Compute the distance synchronously
145	// rather than reading wasAtBottomRef so a programmatic
146	// scrollTop set (with no accompanying scroll event) is handled
147	// correctly.
148	if (len > prevLenRef.current) {	2!
149	const distanceFromBottom = el.scrollHeight - el.scrollTop - el.clientHeight;	2✔
150	if (distanceFromBottom < 120) stick();	2✔
151	}
152	prevLenRef.current = len;	2✔
153	}, [data?.length, wasAtBottomRef, anchorMsgId]);
154
155	// Deep-link landing inside the thread panel: scroll the matching
156	// reply into view + highlight, exactly once per (threadRootID,
157	// anchor). Mirrors MessageList's anchor logic, including a short-
158	// lived follow-anchor RO so async reply content (avatars, attachments)
159	// settling above the anchor doesn't push it off-screen. See
160	// MessageList.tsx for the StrictMode/page-fetch invariants this
161	// shape preserves.
162	const anchorAppliedRef = useRef<string \| null>(null);	26✔
163	const followDeadlineRef = useRef<number>(0);	26✔
164	useLayoutEffect(() => {	26✔
165	if (!anchorMsgId) {	26✔
166	anchorAppliedRef.current = null;	22✔
167	userHasScrolledRef.current = false;	22✔
168	followDeadlineRef.current = 0;	22✔
169	return;	22✔
170	}
171	if ((data?.length ?? 0) === 0) return;	4✔
172	const scroller = scrollRef.current;	2✔
173	if (!scroller) return;	2!
174	const el = document.getElementById(`msg-${anchorMsgId}`);	2✔
175	if (!el) return;	2!
176
177	const dedupKey = anchorRevision ? `${anchorMsgId}@${anchorRevision}` : anchorMsgId;	2!
178	if (anchorAppliedRef.current !== dedupKey) {	26✔
179	el.scrollIntoView({ block: 'center' });	2✔
180	anchorAppliedRef.current = dedupKey;	2✔
181	wasAtBottomRef.current = false;	2✔
182	userHasScrolledRef.current = false;	2✔
183	followDeadlineRef.current = Date.now() + 1500;	2✔
184	}
185
186	if (userHasScrolledRef.current) return;	2!
187	if (Date.now() >= followDeadlineRef.current) return;	2!
188	if (typeof ResizeObserver === 'undefined') return;	2!
189	const inner = innerRef.current;	2✔
190	if (!inner) return;	2!
191	let expectedScrollTop = scroller.scrollTop;	2✔
192	const stopFollowing = () => {	2✔
193	ro.disconnect();	2✔
194	scroller.removeEventListener('scroll', onScroll);	2✔
195	window.clearTimeout(timeoutId);	2✔
196	};
197	const onScroll = () => {	2✔
198	if (Math.abs(scroller.scrollTop - expectedScrollTop) > 5) {	×
199	userHasScrolledRef.current = true;	×
200	stopFollowing();	×
201	}
202	};
203	const ro = new ResizeObserver(() => {	2✔
204	el.scrollIntoView({ block: 'center' });	×
205	expectedScrollTop = scroller.scrollTop;	×
206	});
207	ro.observe(inner);	2✔
208	scroller.addEventListener('scroll', onScroll, { passive: true });	2✔
209	const remaining = Math.max(0, followDeadlineRef.current - Date.now());	2✔
210	const timeoutId = window.setTimeout(stopFollowing, remaining);	2✔
211	return stopFollowing;	2✔
212	}, [anchorMsgId, anchorRevision, data?.length, wasAtBottomRef]);
213
214	// Cosmetic highlight ring on the in-thread anchor.
215	const repliesHaveLoaded = (data?.length ?? 0) > 0;	26✔
216	useEffect(() => {	26✔
217	if (!anchorMsgId \|\| !repliesHaveLoaded) return;	20✔
218	const el = document.getElementById(`msg-${anchorMsgId}`);	2✔
219	if (!el) return;	2!
220	el.classList.add(...ANCHOR_HIGHLIGHT_CLASSES);	2✔
221	const t = window.setTimeout(() => {	2✔
222	el.classList.remove(...ANCHOR_HIGHLIGHT_CLASSES);	×
223	}, ANCHOR_HIGHLIGHT_MS);
224	return () => {	2✔
225	window.clearTimeout(t);	2✔
226	el.classList.remove(...ANCHOR_HIGHLIGHT_CLASSES);	2✔
227	};
228	}, [anchorMsgId, anchorRevision, repliesHaveLoaded]);
229	useEffect(	26✔
230	() => () => {
231	if (stickyROrRef.current) {	16✔
232	stickyROrRef.current.disconnect();	8✔
233	stickyROrRef.current = null;	8✔
234	}
235	},
236	[],
237	);
238
239	// Backup for the bottom-stick RO: late-loading <img> elements
240	// (avatars, attachments, unfurl thumbs) finish at unpredictable
241	// moments. Listening for delegated load events on the inner
242	// container is the most reliable signal that "this image just
243	// grew its box" — gated by wasAtBottomRef and skipped in deep-link
244	// mode. Mirrors MessageList; see that file for the full rationale.
245	useEffect(() => {	26✔
246	const el = scrollRef.current;	16✔
247	const inner = innerRef.current;	16✔
248	if (!el \|\| !inner) return;	16!
249	if (anchorMsgId) return;	16✔
250	const onLoad = (e: Event) => {	14✔
NEW 251	const target = e.target as HTMLElement \| null;	×
NEW 252	if (!target \|\| target.tagName !== 'IMG') return;	×
NEW 253	if (!wasAtBottomRef.current) return;	×
NEW 254	el.scrollTop = el.scrollHeight;	×
255	};
256	inner.addEventListener('load', onLoad, true);	14✔
257	return () => inner.removeEventListener('load', onLoad, true);	14✔
258	}, [anchorMsgId, wasAtBottomRef]);
259
260	function handleReply(input: SendMessageInput) {
261	send.mutate({ ...input, parentMessageID: threadRootID });	1✔
262	}
263
264	return (	26✔
265	<aside className="w-[28rem] border-l flex flex-col" aria-label="Thread">
266	<div className="flex items-center justify-between border-b px-4 py-3">
267	<h2 className="text-sm font-semibold">Thread</h2>
268	<Button
269	variant="ghost"
270	size="icon"
271	className="h-7 w-7"
272	onClick={onClose}
273	aria-label="Close thread"
274	>
275	<X className="h-4 w-4" />
276	</Button>
277	</div>
278	<MessageDropZone onFiles={(files) => void inputRef.current?.uploadFiles(files)}>	×
279	<div ref={scrollRef} className="flex-1 overflow-y-auto">
280	<div ref={innerRef} className="p-2 space-y-2">
281	{isLoading && (	36✔
282	<p className="text-xs text-muted-foreground p-2">Loading replies...</p>
283	)}
284	{data?.length === 0 && (	31✔
285	<p className="text-xs text-muted-foreground p-2">No replies yet. Start the thread!</p>
286	)}
287	{data?.map((msg) => {
288	const u = mergedUserMap[msg.authorID];	20✔
289	return (	20✔
290	<MessageItem
291	key={msg.id}
292	message={msg}
293	authorName={u?.displayName ?? 'Unknown'}	32✔
294	authorAvatarURL={u?.avatarURL}
295	authorOnline={u?.online}
296	isOwn={msg.authorID === currentUserId}
297	channelId={channelId}
298	conversationId={conversationId}
299	currentUserId={currentUserId}
300	userMap={userLookup}
301	inThread
302	/>
303	);
304	})}
305	</div>
306	</div>
307	<ThreadTypingIndicator
308	parentID={channelId ?? conversationId}	28✔
309	threadRootID={threadRootID}
310	userMap={mergedUserMap}
311	/>
312	<MessageInput
313	ref={inputRef}
314	onSend={handleReply}
315	disabled={send.isPending}
316	placeholder="Reply..."
317	focusKey={threadRootID}
318	typingParentID={channelId ?? conversationId}	28✔
319	typingParentType={channelId ? 'channel' : 'conversation'}	26✔
320	typingThreadRootID={threadRootID}
321	/>
322	</MessageDropZone>
323	</aside>
324	);
325	}

DigitalTolk / ex / 25211526966

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous