Function decodeInteraction

packages/bot-telegram/src/interaction.ts:159–218

(raw: unknown)

 *   - A bare callback query object: `{ id, data, from, message }`
 */
export function decodeInteraction(raw: unknown): InteractionEvent | undefined {
  if (!raw || typeof raw !== "object") return undefined;

  const obj = raw as Record<string, unknown>;

  // Unwrap grammY update wrapper if present.
  const cq = (obj.callback_query ?? obj) as Record<string, unknown>;
  if (!cq || typeof cq !== "object") return undefined;

  // Must have callback data.
  if (!cq.data || typeof cq.data !== "string") return undefined;

  const message = cq.message as
    | {
        message_id: number;
        message_thread_id?: number;
        chat: { id: number | string; type: string; is_forum?: boolean };
        reply_to_message?: { message_id: number };
      }
    | undefined;

  if (!message) return undefined;

  const from = cq.from as
    | { id: number; first_name?: string; last_name?: string; username?: string }
    | undefined;

  // A callback_query's `message` is the BOT's message, so its `from` is the
  // bot. Derive the key from the CLICKING user's id (cq.from) so non-forum
  // group keys match the ingress key produced by the listener.
  const ck = deriveConversationKey(message, from?.id);
  const conversationKey = conversationKeyOf(ck);

  const replyTarget: ReplyTarget = {
    chatId: message.chat.id,
    // Only attach a forum thread id in forum supergroups. In non-forum chats
    // message_thread_id is the reply-thread id and Telegram rejects sends that
    // attach it ("message thread not found").
    messageThreadId: message.chat?.is_forum
      ? message.message_thread_id
      : undefined,
    conversationKey,
  };

  const messageRef: TelegramMessageRef = {
    id: `${message.chat.id}:${message.message_id}`,
    chatId: message.chat.id,
    messageId: message.message_id,
  };

  const user = from ? toPlatformUser(from) : undefined;

  return {
    id: cq.data as string,
    conversationKey,
    replyTarget,
    messageRef,
    user,