openclaw/src/test-utils/imessage-test-plugin.ts

import { normalizeIMessageHandle } from "../channels/plugins/normalize/imessage.js";
import type { ChannelOutboundAdapter, ChannelPlugin } from "../channels/plugins/types.js";
import { resolveOutboundSendDep } from "../infra/outbound/send-deps.js";
import { collectStatusIssuesFromLastError } from "../plugin-sdk/status-helpers.js";

const defaultIMessageOutbound: ChannelOutboundAdapter = {
  deliveryMode: "direct",
  sendText: async ({ to, text, accountId, replyToId, deps, cfg }) => {
    const sendIMessage = resolveOutboundSendDep<
      (
        target: string,
        content: string,
        opts?: Record<string, unknown>,
      ) => Promise<{ messageId: string }>
    >(deps, "imessage");
    const result = await sendIMessage?.(to, text, {
      config: cfg,
      accountId: accountId ?? undefined,
      replyToId: replyToId ?? undefined,
    });
    return { channel: "imessage", messageId: result?.messageId ?? "imessage-test-stub" };
  },
  sendMedia: async ({ to, text, mediaUrl, accountId, replyToId, deps, cfg, mediaLocalRoots }) => {
    const sendIMessage = resolveOutboundSendDep<
      (
        target: string,
        content: string,
        opts?: Record<string, unknown>,
      ) => Promise<{ messageId: string }>
    >(deps, "imessage");
    const result = await sendIMessage?.(to, text, {
      config: cfg,
      mediaUrl,
      accountId: accountId ?? undefined,
      replyToId: replyToId ?? undefined,
      mediaLocalRoots,
    });
    return { channel: "imessage", messageId: result?.messageId ?? "imessage-test-stub" };
  },
};

export const createIMessageTestPlugin = (params?: {
  outbound?: ChannelOutboundAdapter;
}): ChannelPlugin => ({
  id: "imessage",
  meta: {
    id: "imessage",
    label: "iMessage",
    selectionLabel: "iMessage (imsg)",
    docsPath: "/channels/imessage",
    blurb: "iMessage test stub.",
    aliases: ["imsg"],
  },
  capabilities: { chatTypes: ["direct", "group"], media: true },
  config: {
    listAccountIds: () => [],
    resolveAccount: () => ({}),
  },
  status: {
    collectStatusIssues: (accounts) => collectStatusIssuesFromLastError("imessage", accounts),
  },
  outbound: params?.outbound ?? defaultIMessageOutbound,
  messaging: {
    targetResolver: {
      looksLikeId: (raw) => {
        const trimmed = raw.trim();
        if (!trimmed) {
          return false;
        }
        if (/^(imessage:|sms:|auto:|chat_id:|chat_guid:|chat_identifier:)/i.test(trimmed)) {
          return true;
        }
        if (trimmed.includes("@")) {
          return true;
        }
        return /^\+?\d{3,}$/.test(trimmed);
      },
      hint: "<handle|chat_id:ID>",
    },
    normalizeTarget: (raw) => normalizeIMessageHandle(raw),
  },
});