malice

<script lang="ts">

  import { onMount, tick } from 'svelte';

  import { fade, fly } from 'svelte/transition';

  import LoginPanel from './lib/LoginPanel.svelte';

  import MessageRow from './lib/MessageRow.svelte';

  import MentionsInbox from './lib/MentionsInbox.svelte';

  import HistoryRepairPanel from './lib/HistoryRepairPanel.svelte';

  import type { HistoryRepairPolicy, HistoryRepairReport } from './lib/repair-model';

  import MxcAvatar from './lib/MxcAvatar.svelte';

  import PinButton from './lib/PinButton.svelte';

  import ContextMenu, { type MenuItem } from './lib/ContextMenu.svelte';

  import StickerPicker from './lib/StickerPicker.svelte';

  import PackManager from './lib/PackManager.svelte';

  import PackCloneDialog from './lib/PackCloneDialog.svelte';

  import type { CloneSource } from './lib/pack-clone';

  import { allPacks, findSticker, reactionShortcode } from './lib/packs';

  import { disabledPackImages, loadPackPreferences } from './lib/pack-preferences';

  import { enabledPacks, enabledQuickReactions } from './lib/pack-preferences-model';

  import type { CommandRequest } from './lib/transport';

  import UserCard, { type UserAction } from './lib/UserCard.svelte';

  import { allowed, canRedact, groupMembers, isMuted, parsePowerLevels, type PowerLevels } from './lib/permissions';

  import { moveBefore, pinnedFirst, sortSpaces } from './lib/rail-order';

  import ImageLightbox from './lib/ImageLightbox.svelte';

  import { lightbox } from './lib/lightbox';

  import SecurityPanel from './lib/SecurityPanel.svelte';

  import {

    closeRoom,

    createRoom,

    getEncryption,

    getMembers,

    getProfile,

    getRooms,

    getSession,

    getSpaceChildren,

    historyRepair,

    continueHistoryRepair,

    cancelHistoryRepair,

    startRecentHistory,

    fillHistoryGap,

    joinRoom,

    leaveRoom,

    logout,

    markRead,

    openRoom,

    paginateRoom,

    reactToMessage,

    runCommand,

    sendMessage,

    uploadAttachment,

    uploadAvatar,

    uploadRoomAvatar,

    editMessage,

    mediaUrl

  } from './lib/api';

  import EmojiText from './lib/EmojiText.svelte';

  import { loadEmoji, type EmojiEntry } from './lib/emoji';

  import { completeShortcode, customEmotes, emoteQueryAt, rankEmotes, resolveEmotes, type EmoteCandidate, type EmoteQuery } from './lib/emotes';

  import { COMMAND_USAGE, commandQueryAt, isKnownCommand, matchCommands, parseCommand, splitTarget, unescapeCommand } from './lib/commands';

  import type { CommandName } from './lib/commands';

  import type { ParsedCommand } from './lib/commands';

  import {

    banners,

    blocked,

    connectEvents,

    connection,

    disconnectEvents,

    dismissBanner,

    encryption,

    membersByRoom,

    membersLoading,

    mentionsSnapshot,

    pushBanner,

    markTimelineOpened,

    imagePacks,

    historyRepairs,

    publishHistoryRepair,

    resetClientState,

    rooms,

    selectedRoomId,

    sessionUser,

    softLogout,

    timelines,

    pinnedTimelines,

    pinnedTimelineVersions,

    verification

  } from './lib/store';

  import { discardPending, pendingByRoom, queueSend, resetPending, retryPending } from './lib/pending';

  import type { PendingMessage } from './lib/pending';

  import { insideOpenFence } from './lib/markdown';

  import { TimelineViewport } from './lib/timeline-viewport';

  import ComposerText from './lib/ComposerText.svelte';

  import { markMentions } from './lib/composer-marks';

  import { mentionQueryAt, mentionsFromHtml, rankPeople, resolveMentions } from './lib/mentions';

  import type { Mention, MentionQuery } from './lib/mentions';

  import { loadQuickReactions, quickReactions, saveQuickReactions } from './lib/quick-reactions';

  import {

    linkPreviews,

    loadUrlPreviewSettings,

    requestLinkPreview,

    saveUrlPreviewSettings,

    urlPreviewSettings

  } from './lib/link-previews';

  import { notifyTyping, stopTyping } from './lib/typing';

  import { formatDay } from './lib/format';

  import {

    MEMBERS_WIDTH,

    SIDE_WIDTH,

    lastSpaceRooms,

    lineHeight,

    membersWidth,

    messageSpacing,

    navFolded,

    railFolded,

    sideWidth

  } from './lib/appearance';

  import SettingsPanel from './lib/SettingsPanel.svelte';

  import { packsForRoom, parseEncryptionState, parseOwnProfile, parseVerificationState, contentPreview, senderLabel } from './lib/types';

  import type { ImagePack, MemberSummary, OwnProfile, PackImage, Person, QuickReaction, ReplyReference, RoomSummary, SendState, TimelineEvent, TimelineItem } from './lib/types';

  let roomsLoading = false;

  let booted = false;

  let wasOnline = false;

  let search = '';

  let sidebarOpen = false;

  let membersOpen = false;

  let replyingTo: ReplyReference | null = null;

  let dialog: 'join' | 'create' | 'security' | 'settings' | 'packs' | null = null;

  let stickersOpen = false;

  let cloneSource: CloneSource | null = null;

  let joinTarget = '';

  let joinBusy = false;

  let createName = '';

  let createTopic = '';

  let createBusy = false;

  let leaveBusy = false;

  let paginateBusy = false;

  let fillingGaps: Record<string, string> = {};

  let historyAccount: string | null | undefined;

  $: if ($sessionUser !== historyAccount) {

    historyAccount = $sessionUser;

    fillingGaps = {};

  }

  let reacting = false;

  let composer = '';

  let drafts: Record<string, string> = {};

  let stickToBottom = true;

  let timelineEl: HTMLElement | null = null;

  let timelineViewport: TimelineViewport | null = null;

  let composerEl: HTMLTextAreaElement | null = null;

  let marksEl: HTMLDivElement | null = null;

  let composerComposing = false;

  $: composerMarks = markMentions(

    composer,

    ($selectedRoomId && pickedMentions[$selectedRoomId]) || [],

    resolveEmotes(composer, roomEmotes).map((e) => `:${e.shortcode}:`)

  );

  let fileInput: HTMLInputElement | null = null;

  let avatarInput: HTMLInputElement | null = null;

  let uploadBusy = false;

  let uploadName: string | null = null;

  interface StagedAttachment {

    id: number;

    file: File;

    previewUrl: string | null;

  }

  let staged: Record<string, StagedAttachment[]> = {};

  let editing: { roomId: string; eventId: string; original: string; stash: string } | null = null;

  /** Everyone picked from the finder per room; only those whose name is still in the text get linked on send. */

  let pickedMentions: Record<string, Mention[]> = {};

  let mentionQuery: MentionQuery | null = null;

  let mentionIndex = 0;

  let nextStagedId = 1;

  const WARM_ROOM_LIMIT = 8;

  /** Rooms left open after switching away so coming back is instant, least recently viewed first. */

  let warmRooms: string[] = [];

  let openReady: Record<string, boolean> = {};

  let openFailed: Record<string, string> = {};

  let membersFor: string | null = null;

  let lastReadKey = '';

  let readTimer: number | null = null;

  let profile: OwnProfile | null = null;

  let profileMxc: string | null = null;

  let selectedSpaceId: string | null = null;

  let mentionsOpen = false;

  let spaceChildIds: string[] | null = null;

  let spaceChildrenLoading = false;

  let spaceChildrenError: string | null = null;

  let avatarByUser: Record<string, string | null> = {};

  let restoringRoute = false;

  let repairPanels: Record<string, boolean> = {};

  let repairBusy: Record<string, boolean> = {};

  let repairCancelling: Record<string, boolean> = {};

  let repairErrors: Record<string, string | null> = {};

  let repairJumps: Record<string, { previous: HistoryRepairReport | null }> = {};

  let repairAccount: string | null | undefined;

  let repairEpoch = 0;

  $: if ($sessionUser !== repairAccount) {

    repairAccount = $sessionUser;

    repairEpoch++;

    repairPanels = {};

    repairBusy = {};

    repairCancelling = {};

    repairErrors = {};

    repairJumps = {};

  }

  $: currentRepair = $selectedRoomId ? $historyRepairs[$selectedRoomId] ?? null : null;

  $: currentRepairActive = !!($selectedRoomId && repairBusy[$selectedRoomId]) || repairActive(currentRepair);

  $: maybeJumpAfterRepair($selectedRoomId, currentRepair, repairJumps);

  $: settleRepairCancellation($historyRepairs, repairBusy);

  function repairActive(report: HistoryRepairReport | null | undefined): boolean {

    return report?.phase === 'FetchingRecent' || report?.phase === 'Bridging';

  }

  function settleRepairCancellation(reports: Record<string, HistoryRepairReport>, busy: Record<string, boolean>): void {

    for (const [roomId, report] of Object.entries(reports)) {

      if (repairCancelling[roomId] && !busy[roomId] && !repairActive(report)) {

        repairCancelling = { ...repairCancelling, [roomId]: false };

      }

    }

  }

  function maybeJumpAfterRepair(roomId: string | null, report: HistoryRepairReport | null, jumps: typeof repairJumps): void {

    if (!roomId || roomId !== $selectedRoomId || !report?.recent_available || !jumps[roomId] || report === jumps[roomId].previous) return;

    const next = { ...repairJumps };

    delete next[roomId];

    repairJumps = next;

    stickToBottom = true;

    const epoch = repairEpoch;

    void tick().then(() => {

      if (epoch === repairEpoch && $selectedRoomId === roomId) scrollToBottom();

    });

  }

  async function showHistoryRepair(roomId: string): Promise<void> {

    if ($selectedRoomId !== roomId) await selectRoom(roomId);

    if ($selectedRoomId === roomId) repairPanels = { ...repairPanels, [roomId]: true };

  }

  async function runHistoryRepair(roomId: string, action: 'start' | 'continue' | 'recent', policy: HistoryRepairPolicy | null = null): Promise<void> {

    if (!$sessionUser || repairBusy[roomId] || repairActive($historyRepairs[roomId]) || repairCancelling[roomId]) return;

    const account = $sessionUser;

    const epoch = repairEpoch;

    repairPanels = { ...repairPanels, [roomId]: true };

    repairBusy = { ...repairBusy, [roomId]: true };

    repairErrors = { ...repairErrors, [roomId]: null };

    if (action !== 'continue') repairJumps = { ...repairJumps, [roomId]: { previous: $historyRepairs[roomId] ?? null } };

    try {

      if (!openReady[roomId]) {

        await openRoom(roomId);

        if ($sessionUser !== account || epoch !== repairEpoch) return;

        openReady = { ...openReady, [roomId]: true };

        const failures = { ...openFailed };

        delete failures[roomId];

        openFailed = failures;

        touchWarmRoom(roomId);

      }

      if (repairCancelling[roomId]) return;

      const report = action === 'continue' ? await continueHistoryRepair(roomId)

        : action === 'recent' ? await startRecentHistory(roomId) : await historyRepair(roomId, policy);

      if ($sessionUser !== account || epoch !== repairEpoch) return;

      if (report.room_id !== roomId) throw new Error('History repair returned a different room');

      publishHistoryRepair(report, account);

      maybeJumpAfterRepair(roomId, report, repairJumps);

    } catch (cause) {

      if ($sessionUser === account && epoch === repairEpoch) {

        repairErrors = { ...repairErrors, [roomId]: cause instanceof Error ? cause.message : 'Could not repair history' };

      }

    } finally {

      if ($sessionUser === account && epoch === repairEpoch) {

        repairBusy = { ...repairBusy, [roomId]: false };

        repairCancelling = { ...repairCancelling, [roomId]: false };

        if (repairJumps[roomId]) {

          const next = { ...repairJumps };

          delete next[roomId];

          repairJumps = next;

        }

      }

    }

  }

  async function cancelRoomRepair(roomId: string): Promise<void> {

    if (!$sessionUser || repairCancelling[roomId]) return;

    const account = $sessionUser;

    const epoch = repairEpoch;

    repairCancelling = { ...repairCancelling, [roomId]: true };

    try {

      await cancelHistoryRepair(roomId);

      if ($sessionUser === account && epoch === repairEpoch && !repairBusy[roomId] && !repairActive($historyRepairs[roomId])) {

        repairCancelling = { ...repairCancelling, [roomId]: false };

      }

    } catch (cause) {

      if ($sessionUser === account && epoch === repairEpoch) {

        repairCancelling = { ...repairCancelling, [roomId]: false };

        repairErrors = { ...repairErrors, [roomId]: cause instanceof Error ? cause.message : 'Could not cancel history repair' };

      }

    }

  }

  function motionDuration(ms: number): number {

    return typeof window !== 'undefined' && window.matchMedia('(prefers-reduced-motion: reduce)').matches ? 0 : ms;

  }

  // account data is read from the local cache, which is empty on a fresh device until the first sync lands

  $: {

    const online = $connection === 'online';

    if (online && !wasOnline) {

      void loadQuickReactions();

      void loadPackPreferences();

      void loadUrlPreviewSettings();

    }

    wasOnline = online;

  }

  $: selectedRoom = $rooms.find((r) => r.room_id === $selectedRoomId) ?? null;

  $: roomPacks = enabledPacks(packsForRoom($imagePacks, $selectedRoomId, $rooms), $disabledPackImages);

  $: roomEmotes = customEmotes(roomPacks);

  $: usableQuickReactions = enabledQuickReactions($quickReactions, allPacks($imagePacks), $disabledPackImages);

  $: previewsAllowed = selectedRoom !== null && (!selectedRoom.encrypted || $urlPreviewSettings.encrypted_rooms);

  $: loadPreview = previewsAllowed && $selectedRoomId ? previewLoader($selectedRoomId) : null;

  $: spaceRooms = $rooms.filter((r) => r.space);

  $: spaceParents = parentSpaceMap(spaceRooms);

  $: railSpaces = spaceRooms.filter((s) => !spaceParents.has(s.room_id));

  let railOverride: string[] | null = null;

  $: if (railOverride && sortSpaces(railSpaces, null).map((s) => s.room_id).join() === railOverride.join()) railOverride = null;

  $: orderedRail = sortSpaces(railSpaces, railOverride);

  $: pinnedRail = orderedRail.filter((s) => s.favourite);

  $: otherRail = orderedRail.filter((s) => !s.favourite);

  $: railSelected = selectedSpaceId ? topSpaceOf(selectedSpaceId, spaceParents) : null;

  $: invites = $rooms.filter((r) => r.membership === 'Invited');

  $: query = search.trim().toLowerCase();

  $: selectedSpace = selectedSpaceId ? ($rooms.find((r) => r.room_id === selectedSpaceId) ?? null) : null;

  // While a space's children load (or fail), show no channels rather than the

  // full list — listing everything would falsely imply it belongs to the space.

  $: baseRooms = selectedSpaceId ? (spaceChildIds ? $rooms.filter((r) => spaceChildIds?.includes(r.room_id)) : []) : $rooms;

  $: visibleRooms = query

    ? baseRooms.filter(

        (r) =>

          r.name.toLowerCase().includes(query) || r.room_id.toLowerCase().includes(query)

      )

    : baseRooms;

  $: directRooms = pinnedFirst(visibleRooms.filter((r) => r.direct && !r.space && r.membership !== 'Invited'));

  $: groupRooms = pinnedFirst(visibleRooms.filter((r) => !r.direct && !r.space && r.membership !== 'Invited'));

  $: spaceList = pinnedFirst(visibleRooms.filter((r) => r.space && r.membership !== 'Invited'));

  $: channelRooms = baseRooms.filter((r) => !r.space && r.membership !== 'Invited');

  $: recoveryBanner = $encryption && ($encryption.recovery === 'Disabled' || $encryption.recovery === 'Incomplete') ? $encryption : null;

  $: verificationBanner = $verification && $verification.kind !== 'Done' ? $verification : null;

  $: items = $selectedRoomId ? ($timelines[$selectedRoomId] ?? []) : [];

  $: currentStaged = $selectedRoomId ? (staged[$selectedRoomId] ?? []) : [];

  $: members = $selectedRoomId ? ($membersByRoom[$selectedRoomId] ?? []) : [];

  $: memberGroups = groupMembers(members, roomLevels);

  $: people = peopleIn(items, members);

  $: mentionCandidates = mentionQuery ? rankPeople(Object.values(people), mentionQuery.query, $sessionUser ?? null) : [];

  $: if (mentionIndex >= mentionCandidates.length) mentionIndex = 0;

  $: hasStart = items.some((i) => i.kind === 'start');

  $: grouped = buildGroups(items);

  $: lastSentId = lastOwnSent(items);

  $: pendingItems = $selectedRoomId ? ($pendingByRoom[$selectedRoomId] ?? []) : [];

  $: lastRealOwn = lastSenderIsOwn(items);

  function lastSenderIsOwn(list: TimelineItem[]): boolean {

    for (let i = list.length - 1; i >= 0; i -= 1) {

      const it = list[i];

      if (it.kind === 'event') return it.event.sender.user_id === $sessionUser;

    }

    return false;

  }

  function pendingShowSender(index: number): boolean {

    return index === 0 ? !lastRealOwn : false;

  }

  function pendingToEvent(p: PendingMessage): TimelineEvent {

    const state: SendState = p.status === 'failed' ? { kind: 'Failed', will_retry: false } : { kind: 'Sending' };

    return {

      item_id: `pending-${p.id}`,

      event_id: null,

      transaction_id: p.id,

      sender: {

        user_id: $sessionUser ?? '',

        display_name: profile?.display_name ?? null,

        avatar: null,

        name_ambiguous: false

      },

      timestamp_ms: p.createdAt,

      own: true,

      send_state: state,

      content: {

        kind: 'Message',

        message: { kind: 'Text', body: p.body, geo_uri: null, formatted_body: p.formatted, edited: false, media: null, link_previews: [] }

      },

      reply_to: p.replyTo,

      thread_root: null,

      thread_summary: null,

      reactions: [],

      read_by: [],

      editable: false

    };

  }

  interface Group {

    key: string;

    item: TimelineItem;

    showSender: boolean;

  }

  function lastOwnSent(list: TimelineItem[]): string | null {

    for (let i = list.length - 1; i >= 0; i--) {

      const item = list[i];

      if (item.kind === 'event' && item.event.own && item.event.send_state.kind === 'Sent') return item.event.item_id;

    }

    return null;

  }

  function buildGroups(list: TimelineItem[]): Group[] {

    const out: Group[] = [];

    let prevSender: string | null = null;

    let prevTs = 0;

    list.forEach((item, index) => {

      let showSender = true;

      if (item.kind === 'event') {

        const e = item.event;

        showSender =

          prevSender !== e.sender.user_id || Math.abs(e.timestamp_ms - prevTs) > 5 * 60 * 1000;

        prevSender = e.sender.user_id;

        prevTs = e.timestamp_ms;

        out.push({ key: e.item_id || e.event_id || `m-${index}`, item, showSender });

      } else {

        prevSender = null;

        const key = item.kind === 'historyGap' ? `gap-${item.gap.id}` : `${item.kind}-${index}`;

        out.push({ key, item, showSender });

      }

    });

    return out;

  }

  function roomUnread(r: RoomSummary): number {

    return r.unread_messages + r.unread_mentions;

  }

  function recordRoute(spaceId: string | null, roomId: string | null, view?: string): void {

    if (restoringRoute) return;

    const url = new URL(window.location.href);

    url.searchParams.delete('space');

    url.searchParams.delete('room');

    url.searchParams.delete('view');

    if (view) url.searchParams.set('view', view);

    if (spaceId) url.searchParams.set('space', spaceId);

    if (roomId) url.searchParams.set('room', roomId);

    const next = `${url.pathname}${url.search}${url.hash}`;

    const current = `${window.location.pathname}${window.location.search}${window.location.hash}`;

    if (next !== current) window.history.pushState({ spaceId, roomId }, '', next);

  }

  async function restoreRoute(): Promise<void> {

    const url = new URL(window.location.href);

    const roomId = url.searchParams.get('room');

    const spaceId = url.searchParams.get('space');

    restoringRoute = true;

    try {

      if (url.searchParams.get('view') === 'mentions') {

        selectMentions();

      } else if (roomId && $rooms.some((room) => room.room_id === roomId && !room.space)) {

        selectedSpaceId = spaceId && $rooms.some((room) => room.room_id === spaceId && room.space) ? spaceId : null;

        spaceChildrenError = null;

        spaceChildIds = selectedSpaceId ? (await getSpaceChildren(selectedSpaceId)).room_ids ?? [] : null;

        await selectRoom(roomId);

      } else if (spaceId && $rooms.some((room) => room.room_id === spaceId && room.space)) {

        await selectSpace(spaceId);

      } else {

        await selectHome();

      }

    } catch (e) {

      pushBanner(e instanceof Error ? e.message : 'Could not restore navigation');

    } finally {

      restoringRoute = false;

    }

  }

  onMount(() => {

    const onPopState = () => void restoreRoute();

    window.addEventListener('popstate', onPopState);

    void boot();

    return () => {

      window.removeEventListener('popstate', onPopState);

      disconnectEvents();

      stopTyping();

      if (readTimer !== null) window.clearTimeout(readTimer);

    };

  });

  async function boot(): Promise<void> {

    try {

      const session = await getSession();

      blocked.set(session.blocked ?? false);

      sessionUser.set(session.user_id);

      if (session.user_id) {

        softLogout.set(null);

        await refreshRooms();

        await restoreRoute();

        connectEvents();

        void loadProfile();

        void loadEncryption();

        void loadQuickReactions();

        void loadPackPreferences();

        void loadUrlPreviewSettings();

      } else {

        softLogout.set(session.soft_logout ?? null);

      }

    } catch (e) {

      pushBanner(e instanceof Error ? `Session check failed: ${e.message}` : 'Session check failed');

      sessionUser.set(null);

    } finally {

      booted = true;

    }

  }

  async function refreshRooms(): Promise<void> {

    roomsLoading = true;

    try {

      const res = await getRooms();

      rooms.set(res.rooms);

      pruneSpaceFilter();

    } catch (e) {

      pushBanner(e instanceof Error ? e.message : 'Could not load rooms');

    } finally {

      roomsLoading = false;

    }

  }

  async function loadProfile(): Promise<void> {

    try {

      const raw = await getProfile();

      profile = parseOwnProfile(raw);

      profileMxc = profile.avatar_url;

    } catch {

      profile = null;

    }

  }

  async function loadEncryption(): Promise<void> {

    try {

      const res = await getEncryption();

      const state = parseEncryptionState(res.state);

      if (state) encryption.set(state);

      const verificationState = parseVerificationState(res.verification);

      if (verificationState) verification.set(verificationState);

    } catch {

      // Encryption status also arrives over SSE; a failed first fetch is not fatal.

    }

  }

  function afterLogin(userId: string): void {

    sessionUser.set(userId);

    softLogout.set(null);

    blocked.set(false);

    void refreshRooms();

    connectEvents();

    void loadProfile();

    void loadEncryption();

    void loadQuickReactions();

    void loadPackPreferences();

    void loadUrlPreviewSettings();

  }

  async function doLogout(): Promise<void> {

    stopTyping();

    try {

      await logout();

    } catch (e) {

      pushBanner(e instanceof Error ? e.message : 'Logout failed');

      return;

    }

    disconnectEvents();

    resetClientState();

    softLogout.set(null);

    blocked.set(false);

    sessionUser.set(null);

    lightbox.set(null);

    composer = '';

    drafts = {};

    dialog = null;

    cloneSource = null;

    membersOpen = false;

    sidebarOpen = false;

    profile = null;

    profileMxc = null;

    mentionsOpen = false;

    selectedSpaceId = null;

    spaceChildIds = null;

    spaceChildrenError = null;

    openReady = {};

    openFailed = {};

    warmRooms = [];

    pickedMentions = {};

    mentionQuery = null;

    clearAllStaged();

    avatarByUser = {};

    resetPending();

  }

  /** Joined spaces that sit inside another joined space, keyed to one such parent. Either side of the link counts. */

  function parentSpaceMap(spaces: RoomSummary[]): Map<string, string> {

    const ids = new Set(spaces.map((s) => s.room_id));

    const parents = new Map<string, string>();

    for (const space of spaces) {

      for (const child of space.children) {

        if (child !== space.room_id && ids.has(child) && !parents.has(child)) parents.set(child, space.room_id);

      }

    }

    for (const space of spaces) {

      const parent = space.parent_spaces.find((id) => id !== space.room_id && ids.has(id));

      if (parent && !parents.has(space.room_id)) parents.set(space.room_id, parent);

    }

    for (const id of [...parents.keys()]) {

      const seen = new Set<string>([id]);

      let at = parents.get(id);

      while (at && !seen.has(at)) {

        seen.add(at);

        at = parents.get(at);

      }

      if (at) parents.delete(id);

    }

    return parents;

  }

  function topSpaceOf(id: string, parents: Map<string, string>): string {

    let at = id;

    while (parents.has(at)) at = parents.get(at)!;

    return at;

  }

  function pruneSpaceFilter(): void {

    if (!selectedSpaceId) return;

    if (!$rooms.some((r) => r.room_id === selectedSpaceId)) {

      selectedSpaceId = null;

      spaceChildIds = null;

      spaceChildrenError = null;

    }

  }

  async function selectHome(): Promise<void> {

    mentionsOpen = false;

    selectedSpaceId = null;

    spaceChildIds = null;

    spaceChildrenError = null;

    if (window.innerWidth > 640) navFolded.set(false);

    sidebarOpen = true;

    recordRoute(null, null);

  }

  function selectMentions(): void {

    if ($selectedRoomId && composer.trim()) drafts[$selectedRoomId] = composer;

    stopTyping();

    selectedSpaceId = null;

    spaceChildIds = null;

    spaceChildrenError = null;

    spaceChildrenLoading = false;

    selectedRoomId.set(null);

    replyingTo = null;

    editing = null;

    mentionQuery = null;

    peeking = null;

    membersOpen = false;

    sidebarOpen = false;

    mentionsOpen = true;

    recordRoute(null, null, 'mentions');

  }

  function toggleChannelsPane(): void {

    if (window.innerWidth <= 640) sidebarOpen = !sidebarOpen;

    else navFolded.update((v) => !v);

  }

  async function selectSpace(spaceId: string): Promise<void> {

    mentionsOpen = false;

    if ($selectedRoomId && composer.trim()) drafts[$selectedRoomId] = composer;

    stopTyping();

    selectedSpaceId = spaceId;

    spaceChildIds = null;

    spaceChildrenError = null;

    spaceChildrenLoading = true;

    const last = $lastSpaceRooms[spaceId];

    const resume = last && $rooms.some((r) => r.room_id === last && !r.space) ? last : null;

    if (resume) {

      void selectRoom(resume);

    } else {

      selectedRoomId.set(null);

    }

    try {

      const res = await getSpaceChildren(spaceId);

      if (selectedSpaceId === spaceId) {

        spaceChildIds = res.room_ids ?? [];

        const firstChannel = spaceChildIds

          .map((id) => $rooms.find((room) => room.room_id === id))

          .find((room) => room && !room.space);

        if ((!resume || !spaceChildIds.includes(resume)) && firstChannel) {

          await selectRoom(firstChannel.room_id);

        }

      }

    } catch (e) {

      if (selectedSpaceId === spaceId) {

        spaceChildrenError = e instanceof Error ? e.message : 'Could not load rooms in this space';

        spaceChildIds = [];

      }

    } finally {

      if (selectedSpaceId === spaceId) spaceChildrenLoading = false;

    }

  }

  async function selectRoom(roomId: string, peek = false): Promise<void> {

    mentionsOpen = false;

    peeking = peek ? roomId : null;

    if ($selectedRoomId && composer.trim()) drafts[$selectedRoomId] = composer;

    if (roomId === $selectedRoomId && openReady[roomId]) {

      sidebarOpen = false;

      return;

    }

    stopTyping();

    const spaceId = selectedSpaceId;

    if (spaceId) lastSpaceRooms.update((all) => ({ ...all, [spaceId]: roomId }));

    selectedRoomId.set(roomId);

    recordRoute(selectedSpaceId, roomId);

    composer = drafts[roomId] ?? '';

    replyingTo = null;

    editing = null;

    mentionQuery = null;

    stickToBottom = true;

    lastReadKey = '';

    sidebarOpen = false;

    touchWarmRoom(roomId);

    if (openReady[roomId]) {

      if (membersOpen) void loadMembers(roomId);

      await tick();

      scrollToBottom();

      queueReadReceipt();

      composerEl?.focus();

      return;

    }

    if (openFailed[roomId]) {

      const nextFailed = { ...openFailed };

      delete nextFailed[roomId];

      openFailed = nextFailed;

    }

    try {

      markTimelineOpened(roomId);

      await openRoom(roomId);

      if (warmRooms.includes(roomId)) openReady = { ...openReady, [roomId]: true };

    } catch (e) {

      const message = e instanceof Error ? e.message : `Could not open room ${roomId}`;

      openFailed = { ...openFailed, [roomId]: message };

      pushBanner(message);

    }

    if (membersOpen) void loadMembers(roomId);

    await tick();

    scrollToBottom();

    queueReadReceipt();

    composerEl?.focus();

  }

  function touchWarmRoom(roomId: string): void {

    warmRooms = [...warmRooms.filter((id) => id !== roomId), roomId];

    while (warmRooms.length > WARM_ROOM_LIMIT) {

      const evicted = warmRooms[0];

      warmRooms = warmRooms.slice(1);

      forgetOpenRoom(evicted);

      closeRoom(evicted).catch(() => undefined);

    }

  }

  function forgetOpenRoom(roomId: string): void {

    warmRooms = warmRooms.filter((id) => id !== roomId);

    const nextReady = { ...openReady };

    delete nextReady[roomId];

    openReady = nextReady;

  }

  function scrollToBottom(): void {

    if (timelineViewport?.element === timelineEl) timelineViewport.scrollToBottom();

    else if (timelineEl) timelineEl.scrollTop = timelineEl.scrollHeight;

  }

  function noteUserScroll(): void {

    timelineViewport?.releaseScroll();

    if ($selectedRoomId && repairJumps[$selectedRoomId]) {

      const next = { ...repairJumps };

      delete next[$selectedRoomId];

      repairJumps = next;

    }

  }

  function syncComposer(node: HTMLTextAreaElement) {

    const sync = () => {

      if (!marksEl) return;

      marksEl.style.width = `${node.clientWidth}px`;

      marksEl.scrollTop = node.scrollTop;

      marksEl.scrollLeft = node.scrollLeft;

    };

    const observer = new ResizeObserver(sync);

    observer.observe(node);

    node.addEventListener('scroll', sync);

    return { destroy: () => {

      observer.disconnect();

      node.removeEventListener('scroll', sync);

    } };

  }

  function onTimelineKey(e: KeyboardEvent): void {

    if (['ArrowUp', 'ArrowDown', 'PageUp', 'PageDown', 'Home', 'End', ' '].includes(e.key)) noteUserScroll();

  }

  function onTimelineScroll(): void {

    if (!timelineEl) return;

    if (timelineViewport?.consumeScroll()) return;

    const gap = timelineEl.scrollHeight - timelineEl.scrollTop - timelineEl.clientHeight;

    stickToBottom = gap < 2;

    timelineViewport?.capture();

    if (timelineEl.scrollTop < 80 && !hasStart && !paginateBusy) void paginate();

  }

  function pinTimeline(node: HTMLElement) {

    const viewport = new TimelineViewport(node.parentElement!, $selectedRoomId);

    timelineViewport = viewport;

    const observer = new ResizeObserver(() => {

      if (timelineViewport !== viewport || viewport.roomId !== $selectedRoomId) return;

      if (stickToBottom) viewport.scrollToBottom(true);

      else viewport.restore();

    });

    observer.observe(node);

    if (node.parentElement) observer.observe(node.parentElement);

    return { destroy: () => {

      observer.disconnect();

      viewport.releaseScroll();

      if (timelineViewport === viewport) timelineViewport = null;

    } };

  }

  $: void trackTimeline($selectedRoomId, items);

  async function trackTimeline(roomId: string | null, list: TimelineItem[]): Promise<void> {

    if (!roomId || list.length === 0) return;

    if (roomId !== $selectedRoomId) return;

    await tick();

    if (roomId !== $selectedRoomId || timelineViewport?.roomId !== roomId) return;

    if (stickToBottom) timelineViewport.scrollToBottom(true);

    else timelineViewport.restore();

    queueReadReceipt();

  }

  function queueReadReceipt(): void {

    if (readTimer !== null) window.clearTimeout(readTimer);

    readTimer = window.setTimeout(() => {

      readTimer = null;

      void sendReadReceipt();

    }, 800);

  }

  async function sendReadReceipt(): Promise<void> {

    const roomId = $selectedRoomId;

    if (!roomId || roomId === peeking) return;

    const list = $timelines[roomId] ?? [];

    for (let i = list.length - 1; i >= 0; i -= 1) {

      const entry = list[i];

      if (entry.kind === 'event' && entry.event.event_id) {

        const key = `${roomId}:${entry.event.event_id}`;

        if (key === lastReadKey) return;

        lastReadKey = key;

        try {

          await markRead(roomId, entry.event.event_id);

        } catch {

          return;

        }

        return;

      }

    }

  }

  function send(): void {

    if (editing) {

      submitEdit();

      return;

    }

    const roomId = $selectedRoomId;

    const body = composer.trim();

    const attachments = roomId ? (staged[roomId] ?? []) : [];

    if (!roomId || (!body && attachments.length === 0)) return;

    if (!openReady[roomId]) {

      pushBanner('Still opening this room — sending is disabled until the room is ready.');

      return;

    }

    if (attachments.length > 0 && uploadBusy) return;

    const command = parseCommand(body);

    if (command && !isKnownCommand(command.name)) {

      pushBanner(`Unknown command /${command.name}`);

      return;

    }

    if (command && attachments.length > 0) {

      if (command.name !== 'roomavatar' && command.name !== 'globalavatar') {

        pushBanner(`/${command.name} doesn't take attachments`);

        return;

      }

      if (command.args || attachments.length !== 1 || !attachments[0].file.type.startsWith('image/')) {

        pushBanner(`/${command.name} takes a single attached image`);

        return;

      }

    }

    composer = '';

    if (roomId in drafts) delete drafts[roomId];

    stickToBottom = true;

    const reply = replyingTo;

    replyingTo = null;

    const text = unescapeCommand(body);

    const mentions = resolveMentions(text, pickedMentions[roomId] ?? []);

    pickedMentions = { ...pickedMentions, [roomId]: [] };

    mentionQuery = null;

    if (command) {

      const image = attachments[0] ?? null;

      if (image) {

        const { [roomId]: _used, ...rest } = staged;

        staged = rest;

      }

      void execute(roomId, command, reply, mentions, image?.file ?? null).finally(() => {

        if (image?.previewUrl) URL.revokeObjectURL(image.previewUrl);

      });

    } else if (attachments.length === 0) {

      queueSend(roomId, text, reply, mentions, resolveEmotes(text, roomEmotes));

    } else {

      const { [roomId]: _sent, ...rest } = staged;

      staged = rest;

      void sendAttachments(roomId, text, reply, mentions, attachments);

    }

    if (peeking === roomId) stopPeeking();

    composerEl?.focus();

  }

  function lastOwnEventId(): string | null {

    for (let i = items.length - 1; i >= 0; i -= 1) {

      const entry = items[i];

      if (entry.kind === 'event' && entry.event.own && entry.event.event_id && entry.event.content.kind !== 'Redacted') {

        return entry.event.event_id;

      }

    }

    return null;

  }

  async function execute(

    roomId: string,

    command: ParsedCommand,

    reply: ReplyReference | null,

    mentions: Mention[],

    image: File | null

  ): Promise<void> {

    const { name, args } = command;

    const target = () => {

      const found = splitTarget(args, Object.values(people));

      if ('error' in found) throw new Error(found.error);

      return found;

    };

    const required = (what: string) => {

      if (!args) throw new Error(`/${name} needs ${what}`);

      return args;

    };

    try {

      switch (name) {

        case 'me':

        case 'notice': {

          const said = required('something to say');

          await sendMessage(roomId, said, null, mentions, name === 'me' ? 'emote' : 'notice', resolveEmotes(said, roomEmotes));

          break;

        }

        case 'sticker': {

          const { pack, sticker } = findSticker(enabledPacks(packsForRoom($imagePacks, roomId, $rooms), $disabledPackImages), required('a sticker name'));

          await runCommand({ op: 'send_sticker', room_id: roomId, pack_id: pack.id, shortcode: sticker.shortcode });

          break;

        }

        case 'msg': {

          const { user_id, rest } = target();

          const res = (await runCommand({ op: 'direct', user_id })) as { room_id: string };

          await refreshRooms();

          await selectRoom(res.room_id);

          if (rest) queueSend(res.room_id, rest);

          break;

        }

        case 'join':

          await join(required('a room id or alias'));

          break;

        case 'leave':

          await leave();

          break;

        case 'invite':

          await runCommand({ op: 'invite', room_id: roomId, user_id: target().user_id });

          break;

        case 'disinvite':

        case 'kick':

        case 'ban':

        case 'unban': {

          const { user_id, rest } = target();

          const op = name === 'disinvite' ? 'kick' : name;

          await runCommand({ op, room_id: roomId, user_id, reason: rest || null });

          break;

        }

        case 'powerlevel': {

          const { user_id, rest } = target();

          const level = Number(rest);

          if (!rest || !Number.isInteger(level)) throw new Error('/powerlevel needs a whole number after the name');

          await runCommand({ op: 'set_power_level', room_id: roomId, user_id, level });

          break;

        }

        case 'mute':

        case 'unmute':

          await runCommand({ op: 'mute', room_id: roomId, user_id: target().user_id, muted: name === 'mute' });

          break;

        case 'ignore':

        case 'unignore':

          await runCommand({ op: name, user_id: target().user_id });

          break;

        case 'roomnick':

          await runCommand({ op: 'set_room_display_name', room_id: roomId, name: args || null });

          break;

        case 'roomavatar':

          if (image) {

            await uploadRoomAvatar(roomId, image);

          } else if (args && !args.startsWith('mxc://')) {

            throw new Error('/roomavatar takes an mxc:// link, an attached image, or nothing to drop the override');

          } else {

            await runCommand({ op: 'set_room_avatar', room_id: roomId, mxc: args || null });

          }

          break;

        case 'delete': {

          const eventId = reply?.event_id ?? lastOwnEventId();

          if (!eventId) throw new Error('Nothing of yours to delete here');

          await runCommand({ op: 'redact', room_id: roomId, event_id: eventId, reason: args || null });

          break;

        }

        case 'globalnick':

          await runCommand({ op: 'set_display_name', name: required('a name') });

          await loadProfile();

          break;

        case 'globalavatar':

          if (image) {

            await uploadAvatar(image);

            await loadProfile();

          } else if (!args) {

            avatarInput?.click();

          } else if (args.startsWith('mxc://')) {

            await runCommand({ op: 'set_avatar', mxc: args });

            await loadProfile();

          } else {

            throw new Error('/globalavatar takes an mxc:// link, or nothing to pick a file');

          }

          break;

      }

    } catch (e) {

      pushBanner(e instanceof Error ? e.message : `/${name} failed`);

    }

  }

  async function onAvatarChosen(): Promise<void> {

    const file = avatarInput?.files?.[0];

    if (avatarInput) avatarInput.value = '';

    if (!file) return;

    try {

      await uploadAvatar(file);

      await loadProfile();

    } catch (e) {

      pushBanner(e instanceof Error ? e.message : 'Avatar upload failed');

    }

  }

  async function sendAttachments(

    roomId: string,

    body: string,

    reply: ReplyReference | null,

    mentions: Mention[],

    attachments: StagedAttachment[]

  ): Promise<void> {

    let first = true;

    uploadBusy = true;

    try {

      for (const attachment of attachments) {

        uploadName = attachment.file.name || 'attachment';

        try {

          if (first) await uploadAttachment(roomId, attachment.file, body || null, reply?.event_id ?? null, mentions, resolveEmotes(body, roomEmotes));

          else await uploadAttachment(roomId, attachment.file);

          first = false;

        } catch (e) {

          pushBanner(e instanceof Error ? e.message : 'Upload failed');

        }

        if (attachment.previewUrl) URL.revokeObjectURL(attachment.previewUrl);

      }

    } finally {

      uploadBusy = false;

      uploadName = null;

    }

  }

  function stageFiles(files: File[]): void {

    const roomId = $selectedRoomId;

    if (!roomId || !openReady[roomId]) return;

    const accepted: StagedAttachment[] = [];

    for (const file of files) {

      if (file.size === 0 || file.size > 20 * 1024 * 1024) {

        pushBanner(`${file.name || 'File'} must be between 1 byte and 20 MiB.`);

        continue;

      }

      const previewUrl = file.type.startsWith('image/') ? URL.createObjectURL(file) : null;

      accepted.push({ id: nextStagedId++, file, previewUrl });

    }

    if (accepted.length === 0) return;

    staged = { ...staged, [roomId]: [...(staged[roomId] ?? []), ...accepted] };

    composerEl?.focus();

  }

  function unstage(roomId: string, id: number): void {

    const list = staged[roomId] ?? [];

    const removed = list.find((a) => a.id === id);

    if (removed?.previewUrl) URL.revokeObjectURL(removed.previewUrl);

    staged = { ...staged, [roomId]: list.filter((a) => a.id !== id) };

  }

  function clearAllStaged(): void {

    for (const list of Object.values(staged)) {

      for (const attachment of list) if (attachment.previewUrl) URL.revokeObjectURL(attachment.previewUrl);

    }

    staged = {};

  }

  function startEdit(eventId: string, body: string): void {

    const roomId = $selectedRoomId;

    if (!roomId) return;

    const stash = editing ? editing.stash : composer;

    editing = { roomId, eventId, original: body, stash };

    const entry = items.find((i) => i.kind === 'event' && i.event.event_id === eventId);

    if (entry?.kind === 'event' && entry.event.content.kind === 'Message') {

      const existing = mentionsFromHtml(entry.event.content.message.formatted_body);

      pickedMentions = { ...pickedMentions, [roomId]: [...(pickedMentions[roomId] ?? []), ...existing] };

    }

    composer = body;

    replyingTo = null;

    composerEl?.focus();

  }

  function cancelEdit(): void {

    if (!editing) return;

    composer = editing.stash;

    editing = null;

    composerEl?.focus();

  }

  function submitEdit(): void {

    if (!editing) return;

    const { roomId, eventId, original } = editing;

    const body = composer.trim();

    cancelEdit();

    if (!body || body === original.trim()) return;

    editMessage(roomId, eventId, body, resolveMentions(body, pickedMentions[roomId] ?? []), resolveEmotes(body, roomEmotes)).catch((e) => pushBanner(e instanceof Error ? e.message : 'Edit failed'));

  }

  function editLastOwn(): boolean {

    for (let i = items.length - 1; i >= 0; i -= 1) {

      const entry = items[i];

      if (entry.kind !== 'event' || !entry.event.own) continue;

      const ev = entry.event;

      if (!ev.editable || !ev.event_id || ev.content.kind !== 'Message' || ev.content.message.kind !== 'Text') return false;

      startEdit(ev.event_id, ev.content.message.body);

      return true;

    }

    return false;

  }

  function startReply(target: ReplyReference): void {

    if (editing) cancelEdit();

    replyingTo = target;

    composerEl?.focus();

  }

  let pinnedOpenFor: string | null = null;

  let pinnedCloseVersion = 0;

  let pinsExpanded = false;

  let pinPreview: TimelineEvent | null = null;

  let pinJumpBusy = false;

  $: syncPinned(selectedRoom?.room_id ?? null, (selectedRoom?.pinned_events.length ?? 0) > 0, $selectedRoomId ? $pinnedTimelineVersions[$selectedRoomId] ?? 0 : 0, currentRepairActive);

  function syncPinned(roomId: string | null, hasPins: boolean, version: number, repairing: boolean): void {

    const want = hasPins ? roomId : null;

    if (want === pinnedOpenFor && version === pinnedCloseVersion) return;

    if (want && repairing) return;

    if (pinnedOpenFor) runCommand({ op: 'close_pinned', room_id: pinnedOpenFor }).catch(() => undefined);

    pinnedOpenFor = want;

    pinnedCloseVersion = version;

    pinsExpanded = false;

    if (want) runCommand({ op: 'open_pinned', room_id: want }).catch(() => undefined);

  }

  $: pins = pinnedList(selectedRoom, $pinnedTimelines);

  function pinnedList(room: RoomSummary | null, all: Record<string, TimelineItem[]>): TimelineEvent[] {

    if (!room || !room.pinned_events.length) return [];

    const order = new Map(room.pinned_events.map((id, i) => [id, i]));

    return (all[room.room_id] ?? [])

      .flatMap((item) => (item.kind === 'event' && item.event.event_id && order.has(item.event.event_id) ? [item.event] : []))

      .sort((a, b) => (order.get(b.event_id!) ?? 0) - (order.get(a.event_id!) ?? 0));

  }

  function setPinned(eventId: string, pinned: boolean): void {

    const roomId = $selectedRoomId;

    if (!roomId) return;

    runCommand({ op: 'set_pinned', room_id: roomId, event_id: eventId, pinned }).catch((e) =>

      pushBanner(e instanceof Error ? e.message : 'Could not change the pin')

    );

  }

  async function jumpToPin(eventId: string): Promise<void> {

    const roomId = $selectedRoomId;

    if (!roomId || !eventId || pinJumpBusy) return;

    pinsExpanded = false;

    pinPreview = pins.find((event) => event.event_id === eventId) ?? null;

    pinJumpBusy = true;

    try {

      for (let attempt = 0; attempt < 24; attempt += 1) {

        if (($timelines[roomId] ?? []).some((item) => item.kind === 'event' && item.event.event_id === eventId)) {

          pinPreview = null;

          await tick();

          jumpTo(eventId);

          return;

        }

        await paginateRoom(roomId);

        await new Promise((resolve) => window.setTimeout(resolve, 180));

      }

      pushBanner('Could not load that pinned message');

    } catch (e) {

      pushBanner(e instanceof Error ? e.message : 'Could not load that pinned message');

    } finally {

      pinJumpBusy = false;

    }

  }

  function jumpTo(eventId: string): void {

    const el = timelineEl?.querySelector<HTMLElement>(`[data-event="${CSS.escape(eventId)}"]`);

    if (!el) {

      pushBanner('The original message is not loaded. Scroll up to load older messages.');

      return;

    }

    stickToBottom = false;

    timelineViewport?.releaseScroll();

    el.scrollIntoView({ block: 'center', behavior: 'smooth' });

    el.classList.remove('flash');

    void el.offsetWidth;

    el.classList.add('flash');

  }

  let typedText = '';

  let typedRoom: string | null = null;

  $: trackTypingInput(composer, $selectedRoomId, openReady);

  function trackTypingInput(text: string, roomId: string | null, ready: Record<string, boolean>): void {

    const edited = roomId === typedRoom && text !== typedText;

    typedText = text;

    typedRoom = roomId;

    if (!roomId || !ready[roomId] || !text.trim()) {

      stopTyping();

    } else if (edited && roomId !== peeking) {

      notifyTyping(roomId);

    }

  }

  $: void trackPending($selectedRoomId, pendingItems);

  async function trackPending(roomId: string | null, list: PendingMessage[]): Promise<void> {

    if (!roomId) return;

    if (roomId !== $selectedRoomId) return;

    await tick();

    if (roomId !== $selectedRoomId || timelineViewport?.roomId !== roomId) return;

    if (stickToBottom) timelineViewport.scrollToBottom(true);

    else timelineViewport.restore();

  }

  let commandQuery: string | null = null;

  let commandIndex = 0;

  $: commandCandidates = commandQuery === null ? [] : matchCommands(commandQuery);

  $: if (commandIndex >= commandCandidates.length) commandIndex = 0;

  async function pickCommand(name: CommandName): Promise<void> {

    if (!composerEl) return;

    const caret = composerEl.selectionStart ?? composer.length;

    const rest = composer.slice(caret).replace(/^\S*/, '');

    composer = `/${name}${rest.startsWith(' ') ? rest : ` ${rest}`}`;

    commandQuery = null;

    await tick();

    const at = name.length + 2;

    composerEl.focus();

    composerEl.setSelectionRange(at, at);

  }

  let emoteQuery: EmoteQuery | null = null;

  let emoteIndex = 0;

  let emojiList: EmojiEntry[] = [];

  $: emoteCandidates = emoteQuery ? rankEmotes(emoteQuery.query, roomEmotes, emojiList) : [];

  $: if (emoteIndex >= emoteCandidates.length) emoteIndex = 0;

  function ensureEmoji(): void {

    if (emojiList.length) return;

    loadEmoji()

      .then((groups) => (emojiList = groups.flatMap((g) => g.emojis)))

      .catch(() => undefined);

  }

  async function onComposerInput(): Promise<void> {

    if (composerEl && composer.includes(':')) {

      ensureEmoji();

      const done = completeShortcode(composerEl.value, composerEl.selectionStart ?? composerEl.value.length, emojiList);

      if (done) {

        composer = done.text;

        await tick();

        composerEl.setSelectionRange(done.caret, done.caret);

      }

    }

    updateMentionQuery();

  }

  async function pickEmote(candidate: EmoteCandidate): Promise<void> {

    if (!emoteQuery || !composerEl) return;

    const caret = composerEl.selectionStart ?? composer.length;

    const inserted = candidate.kind === 'emoji' ? candidate.emoji : `:${candidate.shortcode}: `;

    composer = composer.slice(0, emoteQuery.start) + inserted + composer.slice(caret);

    const at = emoteQuery.start + inserted.length;

    emoteQuery = null;

    await tick();

    composerEl.focus();

    composerEl.setSelectionRange(at, at);

  }

  function updateMentionQuery(): void {

    const roomId = $selectedRoomId;

    const nextEmote = composerEl ? emoteQueryAt(composerEl.value, composerEl.selectionStart ?? composerEl.value.length) : null;

    if (nextEmote?.start !== emoteQuery?.start) emoteIndex = 0;

    emoteQuery = nextEmote;

    const nextCommand = composerEl ? commandQueryAt(composerEl.value, composerEl.selectionStart ?? composerEl.value.length) : null;

    if (nextCommand !== commandQuery) commandIndex = 0;

    commandQuery = nextCommand;

    const next = composerEl && roomId ? mentionQueryAt(composerEl.value, composerEl.selectionStart ?? composerEl.value.length) : null;

    if (next && !mentionQuery && roomId && !$membersByRoom[roomId]) void loadMembers(roomId);

    if (next?.start !== mentionQuery?.start) mentionIndex = 0;

    mentionQuery = next;

  }

  async function pickMention(person: Person): Promise<void> {

    const roomId = $selectedRoomId;

    if (!mentionQuery || !roomId || !composerEl) return;

    const caret = composerEl.selectionStart ?? composer.length;

    const inserted = `${person.name} `;

    composer = composer.slice(0, mentionQuery.start) + inserted + composer.slice(caret);

    const at = mentionQuery.start + inserted.length;

    pickedMentions = {

      ...pickedMentions,

      [roomId]: [...(pickedMentions[roomId] ?? []), { user_id: person.user_id, text: person.name }]

    };

    mentionQuery = null;

    await tick();

    composerEl.focus();

    composerEl.setSelectionRange(at, at);

  }

  function onComposerKey(ev: KeyboardEvent): void {

    if (ev.isComposing || composerComposing) return;

    if (emoteQuery && emoteCandidates.length > 0) {

      if (ev.key === 'ArrowDown' || ev.key === 'ArrowUp') {

        ev.preventDefault();

        const step = ev.key === 'ArrowDown' ? 1 : -1;

        emoteIndex = (emoteIndex + step + emoteCandidates.length) % emoteCandidates.length;

        return;

      }

      if ((ev.key === 'Enter' && !ev.shiftKey) || ev.key === 'Tab') {

        ev.preventDefault();

        void pickEmote(emoteCandidates[emoteIndex]);

        return;

      }

      if (ev.key === 'Escape') {

        ev.stopPropagation();

        emoteQuery = null;

        return;

      }

    }

    if (commandQuery !== null && commandCandidates.length > 0) {

      if (ev.key === 'ArrowDown' || ev.key === 'ArrowUp') {

        ev.preventDefault();

        const step = ev.key === 'ArrowDown' ? 1 : -1;

        commandIndex = (commandIndex + step + commandCandidates.length) % commandCandidates.length;

        return;

      }

      const exact = commandCandidates.length === 1 && commandCandidates[0] === commandQuery;

      if (ev.key === 'Tab' || (ev.key === 'Enter' && !ev.shiftKey && !exact)) {

        ev.preventDefault();

        void pickCommand(commandCandidates[commandIndex]);

        return;

      }

      if (ev.key === 'Escape') {

        ev.stopPropagation();

        commandQuery = null;

        return;

      }

    }

    if (mentionQuery && mentionCandidates.length > 0) {

      if (ev.key === 'ArrowDown' || ev.key === 'ArrowUp') {

        ev.preventDefault();

        const step = ev.key === 'ArrowDown' ? 1 : -1;

        mentionIndex = (mentionIndex + step + mentionCandidates.length) % mentionCandidates.length;

        return;

      }

      if ((ev.key === 'Enter' && !ev.shiftKey) || ev.key === 'Tab') {

        ev.preventDefault();

        void pickMention(mentionCandidates[mentionIndex]);

        return;

      }

      if (ev.key === 'Escape') {

        ev.stopPropagation();

        mentionQuery = null;

        return;

      }

    }

    if (ev.key === 'Enter' && !ev.shiftKey && !insideOpenFence(composer, composerEl?.selectionStart ?? composer.length)) {

      ev.preventDefault();

      send();

    } else if (ev.key === 'Escape' && editing) {

      ev.stopPropagation();

      cancelEdit();

    } else if (ev.key === 'Escape' && replyingTo) {

      ev.stopPropagation();

      replyingTo = null;

    } else if (ev.key === 'ArrowUp' && !composer && !editing && editLastOwn()) {

      ev.preventDefault();

    }

  }

  function pickFiles(): void {

    const roomId = $selectedRoomId;

    if (!roomId || !openReady[roomId]) return;

    fileInput?.click();

  }

  function onFileChosen(): void {

    stageFiles(Array.from(fileInput?.files ?? []));

    if (fileInput) fileInput.value = '';

  }

  function onComposerPaste(ev: ClipboardEvent): void {

    const data = ev.clipboardData;

    // Office apps put a rendered image next to the copied text, so only take the image when there is no plain text.

    if (!data || data.types.includes('text/plain')) return;

    const images = Array.from(data.files).filter((f) => f.type.startsWith('image/'));

    if (images.length === 0) return;

    ev.preventDefault();

    stageFiles(images);

  }

  async function react(eventId: string, key: string, shortcode?: string): Promise<void> {

    const roomId = $selectedRoomId;

    if (!roomId || !eventId || reacting) return;

    reacting = true;

    try {

      await reactToMessage(roomId, eventId, key, reactionShortcode(key, shortcode, allPacks($imagePacks)));

    } catch (e) {

      pushBanner(e instanceof Error ? e.message : 'Reaction failed');

    } finally {

      reacting = false;

    }

  }

  function previewLoader(roomId: string): (url: string) => void {

    return (url) => requestLinkPreview(roomId, url);

  }

  async function changeEncryptedPreviews(enabled: boolean): Promise<void> {

    try {

      await saveUrlPreviewSettings({ encrypted_rooms: enabled });

    } catch (e) {

      pushBanner(e instanceof Error ? e.message : 'Could not save link preview setting');

    }

  }

  async function changeQuickReactions(list: QuickReaction[]): Promise<void> {

    try {

      await saveQuickReactions(list);

    } catch (e) {

      pushBanner(e instanceof Error ? e.message : 'Could not save quick reactions');

    }

  }

  async function paginate(): Promise<void> {

    const roomId = $selectedRoomId;

    if (!roomId || paginateBusy || currentRepairActive) return;

    paginateBusy = true;

    try {

      await paginateRoom(roomId);

    } catch (e) {

      pushBanner(e instanceof Error ? e.message : 'Loading older messages failed');

    } finally {

      paginateBusy = false;

    }

  }

  async function fillGap(gapId: string): Promise<void> {

    const roomId = $selectedRoomId;

    if (!roomId || fillingGaps[roomId]) return;

    fillingGaps = { ...fillingGaps, [roomId]: gapId };

    try {

      await fillHistoryGap(roomId, gapId);

    } catch (e) {

      pushBanner(e instanceof Error ? e.message : 'Loading the missing history failed');

    } finally {

      if (fillingGaps[roomId] === gapId) {

        const { [roomId]: _done, ...rest } = fillingGaps;

        fillingGaps = rest;

      }

    }

  }

  async function loadMembers(roomId: string): Promise<void> {

    if (membersFor === roomId && $membersLoading) return;

    membersFor = roomId;

    membersLoading.set(true);

    try {

      const res = await getMembers(roomId);

      membersByRoom.update((all) => ({ ...all, [roomId]: res.members }));

      avatarByUser = { ...avatarByUser, ...avatarMap(res.members) };

    } catch (e) {

      pushBanner(e instanceof Error ? e.message : 'Could not load members');

    } finally {

      if (membersFor === roomId) membersLoading.set(false);

    }

  }

  function avatarMap(list: MemberSummary[]): Record<string, string | null> {

    const next: Record<string, string | null> = {};

    for (const member of list) next[member.user_id] = member.avatar;

    return next;

  }

  function peopleIn(list: TimelineItem[], roster: MemberSummary[]): Record<string, Person> {

    const out: Record<string, Person> = {};

    for (const item of list) {

      if (item.kind !== 'event') continue;

      const s = item.event.sender;

      out[s.user_id] = { user_id: s.user_id, name: senderLabel(s), avatar: s.avatar };

    }

    for (const m of roster) out[m.user_id] = { user_id: m.user_id, name: m.name, avatar: m.avatar };

    return out;

  }

  function senderAvatarFor(userId: string): string | null {

    return avatarByUser[userId] ?? null;

  }

  function toggleMembers(): void {

    membersOpen = !membersOpen;

    if (membersOpen && $selectedRoomId) {

      void loadMembers($selectedRoomId);

      void loadLevels($selectedRoomId);

    }

  }

  async function join(target: string): Promise<void> {

    const room = target.trim();

    if (!room || joinBusy) return;

    joinBusy = true;

    try {

      const res = await joinRoom(room);

      joinTarget = '';

      dialog = null;

      await refreshRooms();

      await selectRoom(res.room_id);

    } catch (e) {

      pushBanner(e instanceof Error ? e.message : 'Join failed');

    } finally {

      joinBusy = false;

    }

  }