微信 ClawBot：首个官方个人号 Bot API 协议拆解与实战

git clone https://github.com/x1ah/wechat-ilink-demo.git
cd wechat-ilink-demo
npm install
node bot.mjs

const ILINK_BASE = "https://ilinkai.weixin.qq.com";

async function login() {
  // 1. 获取二维码
  const qrRes = await fetch(
    `${ILINK_BASE}/ilink/bot/get_bot_qrcode?bot_type=3`,
    { headers: makeHeaders() }
  );
  const qrData = await qrRes.json();

  // ⚠️ 注意：用 qrcode_img_content（微信可识别的 URL）
  //         不是 qrcode（那只是轮询用的 key）
  const qrcodeUrl = qrData.qrcode_img_content;
  const qrcodeKey = qrData.qrcode;

  // 终端显示二维码，手机微信扫描
  qrterm.generate(qrcodeUrl, { small: true });

  // 2. 轮询扫码状态
  while (true) {
    await sleep(2000);
    const statusRes = await fetch(
      `${ILINK_BASE}/ilink/bot/get_qrcode_status?qrcode=${qrcodeKey}`,
      { headers: makeHeaders() }
    );
    const statusData = await statusRes.json();
    if (statusData.bot_token) {
      // 登录成功！保存 token 供后续使用
      return {
        bot_token: statusData.bot_token,
        baseurl: statusData.baseurl || ILINK_BASE,
      };
    }
  }
}

async function pollLoop(tokenData, onMessage) {
  let cursor = "";
  while (true) {
    try {
      const data = await apiPost(
        tokenData.baseurl,
        "ilink/bot/getupdates",
        { get_updates_buf: cursor, base_info: { channel_version: "1.0.2" } },
        tokenData.bot_token,
        40_000 // 客户端超时留余量
      );

      // 更新游标
      if (data.get_updates_buf) cursor = data.get_updates_buf;

      // ⚠️ 注意：消息列表在 msgs 字段
      for (const msg of (data.msgs || [])) {
        if (msg.message_type === 2) continue; // 跳过 bot 自己的消息
        // ⚠️ 文本内容在 item_list[].text_item.text
        const text = msg.item_list
          ?.filter(i => i.type === 1 && i.text_item)
          .map(i => i.text_item.text)
          .join("");
        await onMessage(msg, text);
      }
    } catch (err) {
      if (err.name === "AbortError") continue; // 长轮询超时，正常
      await sleep(3000);
    }
  }
}

// 发送文本消息
async function sendText(baseUrl, token, to, contextToken, text) {
  // ⚠️ 注意：外层需要 msg 包裹 + client_id + base_info
  //         响应是空对象 {} 即表示成功
  return apiPost(baseUrl, "ilink/bot/sendmessage", {
    msg: {
      from_user_id: "",
      to_user_id: to,
      client_id: `demo-${crypto.randomUUID()}`,
      message_type: 2,    // BOT 发送
      message_state: 2,    // FINISH（完整消息）
      context_token: contextToken,
      item_list: [{ type: 1, text_item: { text } }],
    },
    base_info: { channel_version: "1.0.2" },
  }, token);
}

// typing 状态（需要先获取 typing_ticket）
async function sendTyping(baseUrl, token, userId, contextToken) {
  // ⚠️ 注意：不能直接发 typing，需要先 getConfig 拿 ticket
  const config = await apiPost(baseUrl, "ilink/bot/getconfig", {
    ilink_user_id: userId,
    context_token: contextToken,
    base_info: { channel_version: "1.0.2" },
  }, token);

  if (config.typing_ticket) {
    await apiPost(baseUrl, "ilink/bot/sendtyping", {
      ilink_user_id: userId,
      typing_ticket: config.typing_ticket,
      status: 1, // 1=typing, 2=cancel
      base_info: { channel_version: "1.0.2" },
    }, token);
  }
}