/**
 * Telegram queue menu UI helpers
 * Zones: telegram ui, queue controls, menu composition
 * Owns queue-menu rendering, queue item callbacks, and queue-menu runtime adapters while core queue mechanics stay in queue
 */

import type { TelegramInlineKeyboardMarkup } from "./keyboard.ts";
import type { TelegramModelMenuState } from "./menu.ts";
import type { MenuModel } from "./model.ts";
import * as Queue from "./queue.ts";

// --- Queue Menu ---

const QUEUE_ITEM_PROMPT_HTML_LIMIT = 3600;
const QUEUE_ITEM_PROMPT_TRUNCATION_SUFFIX = "\n… [truncated]";
const EMPTY_QUEUE_REFRESH_TITLES = [
  "<b>⌛ Queue is still empty.</b>",
  "<b>🫙 Still nothing in queue.</b>",
  "<b>🍃 Queue remains empty.</b>",
  "<b>🕳 Nothing queued yet.</b>",
  "<b>🦗 Queue crickets continue.</b>",
  "<b>🌙 Queue is peacefully idle.</b>",
  "<b>🧘 Nothing waiting. Very zen.</b>",
  "<b>🪐 Queue orbit is clear.</b>",
  "<b>🧺 Basket is empty.</b>",
  "<b>🔭 No prompts on the horizon.</b>",
  "<b>🫧 Queue bubbles: none.</b>",
  "<b>🛸 No queued signals detected.</b>",
] as const;
type TelegramQueueMenuReplyMarkup = TelegramInlineKeyboardMarkup;
interface TelegramQueueMenuItem {
  chatId: number;
  replyToMessageId: number;
  queuePosition: number;
  isPriority: boolean;
  priorityEmoji?: string;
  reactionSuppressionEmoji?: string;
  hasAttachments: boolean;
  statusSummary: string;
  promptText: string;
}

function getTelegramQueueItemPromptText<Context>(
  item: Queue.TelegramQueueItem<Context>,
): string {
  if (item.kind !== "prompt") return item.statusSummary;
  return (
    item.content
      .filter((block) => block.type === "text")
      .map((block) => block.text)
      .join("\n")
      .trim() || item.statusSummary
  );
}

function toTelegramQueueMenuItems<Context>(
  items: readonly Queue.TelegramQueueItem<Context>[],
): TelegramQueueMenuItem[] {
  return items.map((item, index) => {
    return {
      chatId: item.chatId,
      replyToMessageId: item.replyToMessageId,
      queuePosition: index + 1,
      isPriority: item.queueLane === "priority",
      priorityEmoji: item.kind === "prompt" ? item.priorityEmoji : undefined,
      reactionSuppressionEmoji:
        item.kind === "prompt" ? item.reactionSuppressionEmoji : undefined,
      hasAttachments:
        item.kind === "prompt" && item.queuedAttachments.length > 0,
      statusSummary: item.statusSummary,
      promptText: getTelegramQueueItemPromptText(item),
    };
  });
}

function formatSkippedTelegramQueuePosition(position: number): string {
  return Array.from(String(position), (char) => `${char}\u0335`).join("");
}

function buildTelegramQueueMenuReplyMarkup(
  items: readonly TelegramQueueMenuItem[],
  emptyRefreshIndex = 0,
): TelegramQueueMenuReplyMarkup {
  const backRow = [{ text: "⬆️ Main menu", callback_data: "menu:back" }];
  const nextEmptyRefreshIndex =
    (emptyRefreshIndex + 1) % EMPTY_QUEUE_REFRESH_TITLES.length;
  const refreshData =
    items.length === 0
      ? `queue:refresh:${nextEmptyRefreshIndex}`
      : "queue:refresh";
  const refreshRow = [{ text: "🌀 Refresh", callback_data: refreshData }];
  if (items.length === 0) return { inline_keyboard: [backRow, refreshRow] };
  const rows = items.map((item) => {
    const prefix = item.reactionSuppressionEmoji
      ? `${item.reactionSuppressionEmoji} `
      : item.isPriority
        ? `${item.priorityEmoji ?? "⚡"} `
        : item.hasAttachments
          ? "📎 "
          : "";
    const position = item.reactionSuppressionEmoji
      ? formatSkippedTelegramQueuePosition(item.queuePosition)
      : String(item.queuePosition);
    const ordinalSeparator = item.reactionSuppressionEmoji ? "\u200A" : "";
    const label = `${position}${ordinalSeparator}. ${prefix}${item.statusSummary}`;
    return [
      {
        text: label,
        callback_data: `queue:pick:${item.chatId}:${item.replyToMessageId}`,
      },
    ];
  });
  return { inline_keyboard: [backRow, refreshRow, ...rows] };
}

function findTelegramQueueItem<Context>(
  items: readonly Queue.TelegramQueueItem<Context>[],
  chatId: number,
  replyToMessageId: number,
): Queue.TelegramQueueItem<Context> | undefined {
  return items.find((item) => {
    return item.chatId === chatId && item.replyToMessageId === replyToMessageId;
  });
}

function findTelegramQueueMenuItem(
  items: readonly TelegramQueueMenuItem[],
  chatId: number,
  replyToMessageId: number,
): TelegramQueueMenuItem | undefined {
  return items.find((item) => {
    return item.chatId === chatId && item.replyToMessageId === replyToMessageId;
  });
}

function escapeTelegramQueueMenuHtmlChar(char: string): string {
  if (char === "&") return "&amp;";
  if (char === "<") return "&lt;";
  if (char === ">") return "&gt;";
  return char;
}

function escapeTelegramQueueMenuHtml(text: string): string {
  return Array.from(text).map(escapeTelegramQueueMenuHtmlChar).join("");
}

function escapeTelegramQueueMenuHtmlPreview(text: string): string {
  const suffix = escapeTelegramQueueMenuHtml(
    QUEUE_ITEM_PROMPT_TRUNCATION_SUFFIX,
  );
  let escaped = "";
  let truncated = false;
  for (const char of text) {
    const next = escapeTelegramQueueMenuHtmlChar(char);
    if (
      escaped.length + next.length + suffix.length >
      QUEUE_ITEM_PROMPT_HTML_LIMIT
    ) {
      truncated = true;
      break;
    }
    escaped += next;
  }
  return truncated ? escaped + suffix : escaped;
}

function getTelegramQueueMenuItemText(item: TelegramQueueMenuItem): string {
  const badge = item.reactionSuppressionEmoji
    ? ` ${item.reactionSuppressionEmoji}`
    : item.isPriority
      ? ` ${item.priorityEmoji ?? "⚡"}`
      : "";
  const position = item.reactionSuppressionEmoji
    ? `<s>${item.queuePosition}</s>.`
    : `<b>${item.queuePosition}.</b>`;
  const heading = `${position}${badge}`;
  const preview = `<pre>${escapeTelegramQueueMenuHtmlPreview(item.promptText)}</pre>`;
  return `${heading}\n${preview}`;
}

function buildTelegramQueueItemSubmenuReplyMarkup(
  chatId: number,
  replyToMessageId: number,
  isPriority: boolean,
  isSkipped: boolean,
): TelegramQueueMenuReplyMarkup {
  return {
    inline_keyboard: [
      [{ text: "⬆️ Back", callback_data: "queue:list" }],
      [
        {
          text: isPriority ? "🟡 Priority" : "⚫️ Priority",
          callback_data: `queue:prio-set:${chatId}:${replyToMessageId}:priority`,
        },
        {
          text: isPriority ? "⚫️ Normal" : "🔵 Normal",
          callback_data: `queue:prio-set:${chatId}:${replyToMessageId}:normal`,
        },
      ],
      [
        {
          text: isSkipped ? "⚫️ Keep" : "🟢 Keep",
          callback_data: `queue:skip-set:${chatId}:${replyToMessageId}:keep`,
        },
        {
          text: isSkipped ? "🔴 Skip" : "⚫️ Skip",
          callback_data: `queue:skip-set:${chatId}:${replyToMessageId}:skip`,
        },
      ],
    ],
  };
}

interface TelegramQueueMenuCallbackDeps<Context = unknown> {
  getQueuedItems: () => TelegramQueueMenuItem[];
  findItem: (
    chatId: number,
    replyToMessageId: number,
  ) => TelegramQueueMenuItem | undefined;
  togglePriority: (chatId: number, replyToMessageId: number) => boolean;
  setPriority: (
    chatId: number,
    replyToMessageId: number,
    enabled: boolean,
  ) => boolean;
  setSkipped: (
    chatId: number,
    replyToMessageId: number,
    skipped: boolean,
  ) => boolean;
  updateQueueMessage: (
    chatId: number,
    messageId: number,
    text: string,
    replyMarkup: TelegramQueueMenuReplyMarkup,
  ) => Promise<number | undefined>;
  answerCallbackQuery: (
    callbackQueryId: string,
    text?: string,
  ) => Promise<void>;
  updateStatus: (ctx: Context) => void;
}

async function handleTelegramQueueMenuCallback<Context>(
  callbackQueryId: string,
  data: string,
  replyChatId: number,
  replyMessageId: number,
  ctx: Context,
  deps: TelegramQueueMenuCallbackDeps<Context>,
): Promise<boolean> {
  if (!data.startsWith("queue:")) return false;
  if (data === "queue:noop") {
    await deps.answerCallbackQuery(callbackQueryId);
    return true;
  }
  if (data === "queue:list") {
    await updateTelegramQueueMenuList(
      callbackQueryId,
      replyChatId,
      replyMessageId,
      deps,
    );
    return true;
  }
  const refreshMatch = data.match(/^queue:refresh(?::(\d+))?$/);
  if (refreshMatch) {
    await updateTelegramQueueMenuList(
      callbackQueryId,
      replyChatId,
      replyMessageId,
      deps,
      undefined,
      refreshMatch[1] === undefined ? 0 : Number(refreshMatch[1]),
    );
    return true;
  }
  const pickMatch = data.match(/^queue:pick:(\d+):(\d+)$/);
  if (pickMatch) {
    await handleTelegramQueueMenuPick(
      callbackQueryId,
      replyChatId,
      replyMessageId,
      Number(pickMatch[1]),
      Number(pickMatch[2]),
      deps,
    );
    return true;
  }
  const prioSetMatch = data.match(
    /^queue:prio-set:(\d+):(\d+):(priority|normal)$/,
  );
  if (prioSetMatch) {
    await handleTelegramQueueMenuPrioritySet(
      callbackQueryId,
      replyChatId,
      replyMessageId,
      Number(prioSetMatch[1]),
      Number(prioSetMatch[2]),
      prioSetMatch[3] === "priority",
      ctx,
      deps,
    );
    return true;
  }
  const prioMatch = data.match(/^queue:prio:(\d+):(\d+)$/);
  if (prioMatch) {
    await handleTelegramQueueMenuPriority(
      callbackQueryId,
      replyChatId,
      replyMessageId,
      Number(prioMatch[1]),
      Number(prioMatch[2]),
      ctx,
      deps,
    );
    return true;
  }
  const skipSetMatch = data.match(
    /^queue:skip-set:(\d+):(\d+):(skip|keep)$/,
  );
  if (skipSetMatch) {
    await handleTelegramQueueMenuSkipSet(
      callbackQueryId,
      replyChatId,
      replyMessageId,
      Number(skipSetMatch[1]),
      Number(skipSetMatch[2]),
      skipSetMatch[3] === "skip",
      ctx,
      deps,
    );
    return true;
  }
  return false;
}

function getTelegramQueueMenuListText(
  items: readonly TelegramQueueMenuItem[],
  emptyRefreshIndex?: number,
): string {
  if (items.length > 0) return "<b>⏳ Queue:</b>";
  if (emptyRefreshIndex === undefined) return "<b>⌛ Queue is empty.</b>";
  return EMPTY_QUEUE_REFRESH_TITLES[
    emptyRefreshIndex % EMPTY_QUEUE_REFRESH_TITLES.length
  ];
}

async function updateTelegramQueueMenuList<Context>(
  callbackQueryId: string,
  replyChatId: number,
  replyMessageId: number,
  deps: TelegramQueueMenuCallbackDeps<Context>,
  notice?: string,
  emptyRefreshIndex?: number,
): Promise<void> {
  const items = deps.getQueuedItems();
  await deps.updateQueueMessage(
    replyChatId,
    replyMessageId,
    getTelegramQueueMenuListText(items, emptyRefreshIndex),
    buildTelegramQueueMenuReplyMarkup(items, emptyRefreshIndex),
  );
  await deps.answerCallbackQuery(callbackQueryId, notice);
}

async function refreshStaleTelegramQueueMenuItem<Context>(
  callbackQueryId: string,
  replyChatId: number,
  replyMessageId: number,
  deps: TelegramQueueMenuCallbackDeps<Context>,
): Promise<void> {
  await updateTelegramQueueMenuList(
    callbackQueryId,
    replyChatId,
    replyMessageId,
    deps,
    "Item no longer in queue.",
  );
}

async function handleTelegramQueueMenuPick<Context>(
  callbackQueryId: string,
  replyChatId: number,
  replyMessageId: number,
  chatId: number,
  msgId: number,
  deps: TelegramQueueMenuCallbackDeps<Context>,
): Promise<void> {
  const item = deps.findItem(chatId, msgId);
  if (!item) {
    return refreshStaleTelegramQueueMenuItem(
      callbackQueryId,
      replyChatId,
      replyMessageId,
      deps,
    );
  }
  await deps.updateQueueMessage(
    replyChatId,
    replyMessageId,
    getTelegramQueueMenuItemText(item),
    buildTelegramQueueItemSubmenuReplyMarkup(
      chatId,
      msgId,
      item.isPriority,
      item.reactionSuppressionEmoji !== undefined,
    ),
  );
  await deps.answerCallbackQuery(callbackQueryId);
}

async function handleTelegramQueueMenuPriority<Context>(
  callbackQueryId: string,
  replyChatId: number,
  replyMessageId: number,
  chatId: number,
  msgId: number,
  ctx: Context,
  deps: TelegramQueueMenuCallbackDeps<Context>,
): Promise<void> {
  const item = deps.findItem(chatId, msgId);
  if (!item) {
    return refreshStaleTelegramQueueMenuItem(
      callbackQueryId,
      replyChatId,
      replyMessageId,
      deps,
    );
  }
  await updateTelegramQueueMenuPriority(
    callbackQueryId,
    replyChatId,
    replyMessageId,
    chatId,
    msgId,
    !item.isPriority,
    ctx,
    deps,
  );
}

async function handleTelegramQueueMenuPrioritySet<Context>(
  callbackQueryId: string,
  replyChatId: number,
  replyMessageId: number,
  chatId: number,
  msgId: number,
  enabled: boolean,
  ctx: Context,
  deps: TelegramQueueMenuCallbackDeps<Context>,
): Promise<void> {
  const item = deps.findItem(chatId, msgId);
  if (!item) {
    return refreshStaleTelegramQueueMenuItem(
      callbackQueryId,
      replyChatId,
      replyMessageId,
      deps,
    );
  }
  await updateTelegramQueueMenuPriority(
    callbackQueryId,
    replyChatId,
    replyMessageId,
    chatId,
    msgId,
    enabled,
    ctx,
    deps,
  );
}

async function updateTelegramQueueMenuPriority<Context>(
  callbackQueryId: string,
  replyChatId: number,
  replyMessageId: number,
  chatId: number,
  msgId: number,
  enabled: boolean,
  ctx: Context,
  deps: TelegramQueueMenuCallbackDeps<Context>,
): Promise<void> {
  deps.setPriority(chatId, msgId, enabled);
  deps.updateStatus(ctx);
  const updated = deps.findItem(chatId, msgId);
  if (!updated) {
    return refreshStaleTelegramQueueMenuItem(
      callbackQueryId,
      replyChatId,
      replyMessageId,
      deps,
    );
  }
  await deps.updateQueueMessage(
    replyChatId,
    replyMessageId,
    getTelegramQueueMenuItemText(updated),
    buildTelegramQueueItemSubmenuReplyMarkup(
      chatId,
      msgId,
      updated.isPriority,
      updated.reactionSuppressionEmoji !== undefined,
    ),
  );
  await deps.answerCallbackQuery(
    callbackQueryId,
    updated.isPriority ? "Prioritized." : "Normal priority.",
  );
}

async function handleTelegramQueueMenuSkipSet<Context>(
  callbackQueryId: string,
  replyChatId: number,
  replyMessageId: number,
  chatId: number,
  msgId: number,
  skipped: boolean,
  ctx: Context,
  deps: TelegramQueueMenuCallbackDeps<Context>,
): Promise<void> {
  const item = deps.findItem(chatId, msgId);
  if (!item) {
    return refreshStaleTelegramQueueMenuItem(
      callbackQueryId,
      replyChatId,
      replyMessageId,
      deps,
    );
  }
  deps.setSkipped(chatId, msgId, skipped);
  deps.updateStatus(ctx);
  const updated = deps.findItem(chatId, msgId);
  if (!updated) {
    return refreshStaleTelegramQueueMenuItem(
      callbackQueryId,
      replyChatId,
      replyMessageId,
      deps,
    );
  }
  await deps.updateQueueMessage(
    replyChatId,
    replyMessageId,
    getTelegramQueueMenuItemText(updated),
    buildTelegramQueueItemSubmenuReplyMarkup(
      chatId,
      msgId,
      updated.isPriority,
      updated.reactionSuppressionEmoji !== undefined,
    ),
  );
  await deps.answerCallbackQuery(callbackQueryId);
}

interface TelegramQueueMenuCallbackQuery {
  id: string;
  data?: string;
  message?: { chat?: { id?: number }; message_id?: number };
}
interface TelegramQueueMenuRuntime<Context> {
  openQueueMenu: (
    chatId: number,
    replyToMessageId: number,
    ctx: Context,
  ) => Promise<void>;
  handleCallbackQuery: (
    query: TelegramQueueMenuCallbackQuery,
    ctx: Context,
  ) => Promise<boolean>;
}
export function createTelegramQueueMenuRuntime<
  Context,
  TModel extends MenuModel = MenuModel,
>(deps: {
  telegramQueueStore: Queue.TelegramQueueStateStore<Context>;
  queueMutationRuntime: Queue.TelegramQueueMutationController<Context>;
  sendInteractiveMessage: (
    chatId: number,
    text: string,
    mode: "html",
    replyMarkup: TelegramQueueMenuReplyMarkup,
  ) => Promise<number | undefined>;
  editInteractiveMessage: (
    chatId: number,
    messageId: number,
    text: string,
    mode: "html",
    replyMarkup: TelegramQueueMenuReplyMarkup,
  ) => Promise<void>;
  answerCallbackQuery: (
    callbackQueryId: string,
    text?: string,
  ) => Promise<void>;
  getModelMenuState: (
    chatId: number,
    ctx: Context,
  ) => Promise<TelegramModelMenuState<TModel>>;
  getStoredModelMenuState: (
    messageId: number | undefined,
    chatId?: number,
  ) => TelegramModelMenuState<TModel> | undefined;
  storeModelMenuState: (state: TelegramModelMenuState<TModel>) => void;
  updateStatusMessage: (
    state: TelegramModelMenuState<TModel>,
    ctx: Context,
  ) => Promise<void>;
  updateStatus: (ctx: Context) => void;
}): TelegramQueueMenuRuntime<Context> {
  const sendQueueMenuMessage = createQueueMenuSendMessageAdapter(
    deps.sendInteractiveMessage,
  );
  const editQueueMenuMessage = createQueueMenuEditMessageAdapter(
    deps.editInteractiveMessage,
  );
  return {
    openQueueMenu: createOpenQueueMenu<Context, TModel>({
      getQueuedItems: deps.telegramQueueStore.getQueuedItems,
      getModelMenuState: deps.getModelMenuState,
      storeModelMenuState: deps.storeModelMenuState,
      sendInteractiveMessage: sendQueueMenuMessage,
    }),
    handleCallbackQuery: createQueueMenuCallbackHandler<Context, TModel>({
      telegramQueueStore: deps.telegramQueueStore,
      queueMutationRuntime: deps.queueMutationRuntime,
      editInteractiveMessage: editQueueMenuMessage,
      getStoredModelMenuState: deps.getStoredModelMenuState,
      updateStatusMessage: deps.updateStatusMessage,
      answerCallbackQuery: deps.answerCallbackQuery,
      updateStatus: deps.updateStatus,
    }),
  };
}

function createOpenQueueMenu<
  Context,
  TModel extends MenuModel = MenuModel,
>(deps: {
  getQueuedItems: () => Queue.TelegramQueueItem<Context>[];
  getModelMenuState: (
    chatId: number,
    ctx: Context,
  ) => Promise<TelegramModelMenuState<TModel>>;
  storeModelMenuState: (state: TelegramModelMenuState<TModel>) => void;
  sendInteractiveMessage: (
    chatId: number,
    replyToMessageId: number,
    text: string,
    replyMarkup: TelegramQueueMenuReplyMarkup,
  ) => Promise<number | undefined>;
}) {
  return async (
    chatId: number,
    replyToMessageId: number,
    ctx: Context,
  ): Promise<void> => {
    const state = await deps.getModelMenuState(chatId, ctx);
    const menuItems = toTelegramQueueMenuItems(deps.getQueuedItems());
    const text = getTelegramQueueMenuListText(menuItems);
    const messageId = await deps.sendInteractiveMessage(
      chatId,
      replyToMessageId,
      text,
      buildTelegramQueueMenuReplyMarkup(menuItems),
    );
    if (messageId === undefined) return;
    state.messageId = messageId;
    state.mode = "queue";
    deps.storeModelMenuState(state);
  };
}

function createQueueMenuCallbackHandler<
  Context,
  TModel extends MenuModel = MenuModel,
>(deps: {
  telegramQueueStore: Queue.TelegramQueueStateStore<Context>;
  queueMutationRuntime: Queue.TelegramQueueMutationController<Context>;
  editInteractiveMessage: (
    chatId: number,
    messageId: number,
    text: string,
    replyMarkup: TelegramQueueMenuReplyMarkup,
  ) => Promise<number | undefined>;
  getStoredModelMenuState: (
    messageId: number | undefined,
    chatId?: number,
  ) => TelegramModelMenuState<TModel> | undefined;
  updateStatusMessage: (
    state: TelegramModelMenuState<TModel>,
    ctx: Context,
  ) => Promise<void>;
  answerCallbackQuery: (
    callbackQueryId: string,
    text?: string,
  ) => Promise<void>;
  updateStatus: (ctx: Context) => void;
}) {
  return async (
    query: TelegramQueueMenuCallbackQuery,
    ctx: Context,
  ): Promise<boolean> => {
    const data = query.data;
    const chatId = query.message?.chat?.id;
    const messageId = query.message?.message_id;
    if (!data || typeof chatId !== "number" || typeof messageId !== "number")
      return false;
    if (data === "menu:queue" || data === "status:queue") {
      const state = deps.getStoredModelMenuState(messageId, chatId);
      if (!state) {
        await deps.answerCallbackQuery(
          query.id,
          "Interactive message expired.",
        );
        return true;
      }
      const menuItems = toTelegramQueueMenuItems(
        deps.telegramQueueStore.getQueuedItems(),
      );
      await deps.editInteractiveMessage(
        chatId,
        messageId,
        getTelegramQueueMenuListText(menuItems),
        buildTelegramQueueMenuReplyMarkup(menuItems),
      );
      state.mode = "queue";
      await deps.answerCallbackQuery(query.id);
      return true;
    }
    if (!data.startsWith("queue:")) return false;
    const getQueueSnapshot = () => {
      return deps.telegramQueueStore.getQueuedItems();
    };
    const toMenuItems = () => {
      return toTelegramQueueMenuItems(getQueueSnapshot());
    };
    const findItem = (cId: number, rId: number) => {
      return findTelegramQueueMenuItem(toMenuItems(), cId, rId);
    };
    return handleTelegramQueueMenuCallback(
      query.id,
      data,
      chatId,
      messageId,
      ctx,
      {
        getQueuedItems: toMenuItems,
        findItem,
        togglePriority: (cId, rId) => {
          return toggleQueuedTelegramPromptPriority(cId, rId, ctx, {
            getQueueSnapshot,
            queueMutationRuntime: deps.queueMutationRuntime,
          });
        },
        setPriority: (cId, rId, enabled) => {
          return setQueuedTelegramPromptPriority(cId, rId, enabled, ctx, {
            getQueueSnapshot,
            queueMutationRuntime: deps.queueMutationRuntime,
          });
        },
        setSkipped: (cId, rId, skipped) => {
          return setQueuedTelegramPromptSkipped(cId, rId, skipped, ctx, {
            getQueueSnapshot,
            queueMutationRuntime: deps.queueMutationRuntime,
          });
        },
        updateQueueMessage: deps.editInteractiveMessage,
        answerCallbackQuery: deps.answerCallbackQuery,
        updateStatus: deps.updateStatus,
      },
    );
  };
}

function getQueueMenuReactionDisposition<Context>(
  item: Queue.TelegramQueueItem<Context>,
  priority: boolean,
  skipped: boolean,
): Queue.TelegramQueueReactionDisposition {
  if (priority && skipped) {
    return {
      kind: "priority-suppressed",
      priorityEmoji:
        item.kind === "prompt" ? item.priorityEmoji ?? "⚡" : "⚡",
      suppressionEmoji:
        item.kind === "prompt"
          ? item.reactionSuppressionEmoji ?? "👎"
          : "👎",
    };
  }
  if (priority) {
    return {
      kind: "priority",
      emoji: item.kind === "prompt" ? item.priorityEmoji ?? "⚡" : "⚡",
    };
  }
  if (skipped) {
    return {
      kind: "suppressed",
      emoji:
        item.kind === "prompt"
          ? item.reactionSuppressionEmoji ?? "👎"
          : "👎",
    };
  }
  return { kind: "default" };
}

function toggleQueuedTelegramPromptPriority<Context>(
  chatId: number,
  replyToMessageId: number,
  ctx: Context,
  deps: {
    getQueueSnapshot: () => Queue.TelegramQueueItem<Context>[];
    queueMutationRuntime: Queue.TelegramQueueMutationController<Context>;
  },
): boolean {
  const item = findTelegramQueueItem(
    deps.getQueueSnapshot(),
    chatId,
    replyToMessageId,
  );
  if (!item) return false;
  deps.queueMutationRuntime.applyReactionByMessageId(
    replyToMessageId,
    getQueueMenuReactionDisposition(
      item,
      item.queueLane !== "priority",
      item.kind === "prompt" &&
        item.reactionSuppressionEmoji !== undefined,
    ),
    ctx,
  );
  return true;
}

function setQueuedTelegramPromptPriority<Context>(
  chatId: number,
  replyToMessageId: number,
  enabled: boolean,
  ctx: Context,
  deps: {
    getQueueSnapshot: () => Queue.TelegramQueueItem<Context>[];
    queueMutationRuntime: Queue.TelegramQueueMutationController<Context>;
  },
): boolean {
  const item = findTelegramQueueItem(
    deps.getQueueSnapshot(),
    chatId,
    replyToMessageId,
  );
  if (!item) return false;
  deps.queueMutationRuntime.applyReactionByMessageId(
    replyToMessageId,
    getQueueMenuReactionDisposition(
      item,
      enabled,
      item.kind === "prompt" &&
        item.reactionSuppressionEmoji !== undefined,
    ),
    ctx,
  );
  return true;
}

function setQueuedTelegramPromptSkipped<Context>(
  chatId: number,
  replyToMessageId: number,
  skipped: boolean,
  ctx: Context,
  deps: {
    getQueueSnapshot: () => Queue.TelegramQueueItem<Context>[];
    queueMutationRuntime: Queue.TelegramQueueMutationController<Context>;
  },
): boolean {
  const item = findTelegramQueueItem(
    deps.getQueueSnapshot(),
    chatId,
    replyToMessageId,
  );
  if (!item || item.kind !== "prompt") return false;
  deps.queueMutationRuntime.applyReactionByMessageId(
    replyToMessageId,
    getQueueMenuReactionDisposition(
      item,
      item.queueLane === "priority",
      skipped,
    ),
    ctx,
  );
  return true;
}

function createQueueMenuSendMessageAdapter(
  sendInteractiveMessage: (
    chatId: number,
    text: string,
    mode: "html",
    replyMarkup: TelegramQueueMenuReplyMarkup,
  ) => Promise<number | undefined>,
) {
  return (
    chatId: number,
    _replyToMessageId: number,
    text: string,
    replyMarkup: TelegramQueueMenuReplyMarkup,
  ): Promise<number | undefined> => {
    return sendInteractiveMessage(chatId, text, "html", replyMarkup);
  };
}

function createQueueMenuEditMessageAdapter(
  editInteractiveMessage: (
    chatId: number,
    messageId: number,
    text: string,
    mode: "html",
    replyMarkup: TelegramQueueMenuReplyMarkup,
  ) => Promise<void>,
) {
  return (
    chatId: number,
    messageId: number,
    text: string,
    replyMarkup: TelegramQueueMenuReplyMarkup,
  ): Promise<number | undefined> => {
    return editInteractiveMessage(
      chatId,
      messageId,
      text,
      "html",
      replyMarkup,
    ).then(() => {
      return undefined as number | undefined;
    });
  };
}