weixin-plugin-test/weixin-plugin/weixin/messaging/process-message.ts

import type { WeixinMessage } from "../api/types.js";
import { MessageItemType } from "../api/types.js";
import type { WeixinInboundMediaOpts } from "./inbound.js";

export type ProcessMessageDeps = {
  accountId: string;
  baseUrl: string;
  cdnBaseUrl: string;
  token?: string;
  typingTicket?: string;
  log: (msg: string) => void;
  errLog: (m: string) => void;
};

function extractTextBody(itemList?: import("../api/types.js").MessageItem[]): string {
  if (!itemList?.length) return "";
  for (const item of itemList) {
    if (item.type === MessageItemType.TEXT && item.text_item?.text != null) {
      return String(item.text_item.text);
    }
  }
  return "";
}

export async function processOneMessage(
  full: WeixinMessage,
  deps: ProcessMessageDeps,
): Promise<void> {
  const textBody = extractTextBody(full.item_list);
  const fromUserId = full.from_user_id ?? "";

  deps.log(`[weixin] inbound message from=${fromUserId} bodyLen=${textBody.length}`);
}