feat(channels): add WeChat/Weixin channel support

- Add WeixinAdapter with accounts, api, login, monitor, send modules
- Add channel configure command for interactive setup
- Update TelegramAdapter for consistency

Co-authored-by: Qwen-Coder <qwen-coder@alibabacloud.com>

packages/channels/weixin/src/api.ts

@@ -0,0 +1,128 @@
+/**
+ * HTTP API wrapper for WeChat iLink Bot API.
+ */
+
+import type {
+  GetUpdatesReq,
+  GetUpdatesResp,
+  SendMessageReq,
+  GetConfigResp,
+  SendTypingReq,
+  SendTypingResp,
+  BaseInfo,
+} from './types.js';
+
+const CHANNEL_VERSION = '0.1.0';
+
+function baseInfo(): BaseInfo {
+  return { channel_version: CHANNEL_VERSION };
+}
+
+function randomUin(): string {
+  const buf = new Uint8Array(4);
+  crypto.getRandomValues(buf);
+  return btoa(String.fromCharCode(...buf));
+}
+
+function buildHeaders(token?: string): Record<string, string> {
+  const headers: Record<string, string> = {
+    'Content-Type': 'application/json',
+    'X-WECHAT-UIN': randomUin(),
+  };
+  if (token) {
+    headers['AuthorizationType'] = 'ilink_bot_token';
+    headers['Authorization'] = `Bearer ${token}`;
+  }
+  return headers;
+}
+
+async function post<T>(
+  baseUrl: string,
+  path: string,
+  body: unknown,
+  token?: string,
+  timeoutMs = 40000,
+  signal?: AbortSignal,
+): Promise<T> {
+  const controller = new AbortController();
+  const timeout = setTimeout(() => controller.abort(), timeoutMs);
+
+  if (signal) {
+    signal.addEventListener('abort', () => controller.abort(), { once: true });
+  }
+
+  try {
+    const resp = await fetch(`${baseUrl}${path}`, {
+      method: 'POST',
+      headers: buildHeaders(token),
+      body: JSON.stringify(body),
+      signal: controller.signal,
+    });
+    if (!resp.ok) {
+      throw new Error(`HTTP ${resp.status}: ${resp.statusText}`);
+    }
+    return (await resp.json()) as T;
+  } finally {
+    clearTimeout(timeout);
+  }
+}
+
+export async function getUpdates(
+  baseUrl: string,
+  token: string,
+  getUpdatesBuf: string,
+  timeoutMs = 40000,
+  signal?: AbortSignal,
+): Promise<GetUpdatesResp> {
+  const body: GetUpdatesReq = {
+    get_updates_buf: getUpdatesBuf,
+    base_info: baseInfo(),
+  };
+  try {
+    return await post<GetUpdatesResp>(
+      baseUrl,
+      '/ilink/bot/getupdates',
+      body,
+      token,
+      timeoutMs,
+      signal,
+    );
+  } catch (err: unknown) {
+    if (err instanceof Error && err.name === 'AbortError') {
+      return { ret: 0, msgs: [], get_updates_buf: getUpdatesBuf };
+    }
+    throw err;
+  }
+}
+
+export async function sendMessage(
+  baseUrl: string,
+  token: string,
+  msg: SendMessageReq['msg'],
+): Promise<void> {
+  const body: SendMessageReq = { msg, base_info: baseInfo() };
+  await post(baseUrl, '/ilink/bot/sendmessage', body, token);
+}
+
+export async function getConfig(
+  baseUrl: string,
+  token: string,
+  userId: string,
+  contextToken?: string,
+): Promise<GetConfigResp> {
+  const body = {
+    ilink_user_id: userId,
+    context_token: contextToken,
+    base_info: baseInfo(),
+  };
+  return post<GetConfigResp>(baseUrl, '/ilink/bot/getconfig', body, token);
+}
+
+export async function sendTyping(
+  baseUrl: string,
+  token: string,
+  req: Omit<SendTypingReq, 'base_info'>,
+): Promise<SendTypingResp> {
+  const body: SendTypingReq = { ...req, base_info: baseInfo() };
+  return post<SendTypingResp>(baseUrl, '/ilink/bot/sendtyping', body, token);
+}