openclaw/extensions/imessage/src/monitor/parse-notification.ts

import { isRecord } from "openclaw/plugin-sdk/string-coerce-runtime";
import { stripImessageLengthPrefixedUtf8Text } from "./strip-imsg-length-prefixed-text.js";
import type { IMessagePayload } from "./types.js";

function isOptionalString(value: unknown): value is string | null | undefined {
  return value === undefined || value === null || typeof value === "string";
}

function isOptionalStringOrNumber(value: unknown): value is string | number | null | undefined {
  return (
    value === undefined || value === null || typeof value === "string" || typeof value === "number"
  );
}

function isOptionalNumber(value: unknown): value is number | null | undefined {
  return value === undefined || value === null || typeof value === "number";
}

function isOptionalBoolean(value: unknown): value is boolean | null | undefined {
  return value === undefined || value === null || typeof value === "boolean";
}

function isOptionalStringArray(value: unknown): value is string[] | null | undefined {
  return (
    value === undefined ||
    value === null ||
    (Array.isArray(value) && value.every((entry) => typeof entry === "string"))
  );
}

function isOptionalAttachments(value: unknown): value is IMessagePayload["attachments"] {
  if (value === undefined || value === null) {
    return true;
  }
  if (!Array.isArray(value)) {
    return false;
  }
  return value.every((attachment) => {
    if (!isRecord(attachment)) {
      return false;
    }
    return (
      isOptionalString(attachment.original_path) &&
      isOptionalString(attachment.mime_type) &&
      isOptionalBoolean(attachment.missing) &&
      isOptionalString(attachment.transfer_name) &&
      isOptionalString(attachment.uti)
    );
  });
}

export function parseIMessageNotification(raw: unknown): IMessagePayload | null {
  if (!isRecord(raw)) {
    return null;
  }
  const maybeMessage = raw.message;
  if (!isRecord(maybeMessage)) {
    return null;
  }

  const message: IMessagePayload = maybeMessage;
  if (
    !isOptionalNumber(message.id) ||
    !isOptionalString(message.guid) ||
    !isOptionalNumber(message.chat_id) ||
    !isOptionalString(message.sender) ||
    !isOptionalString(message.destination_caller_id) ||
    !isOptionalBoolean(message.is_from_me) ||
    !isOptionalString(message.text) ||
    !isOptionalStringOrNumber(message.reply_to_id) ||
    !isOptionalString(message.reply_to_text) ||
    !isOptionalString(message.reply_to_sender) ||
    !isOptionalString(message.created_at) ||
    !isOptionalBoolean(message.is_reaction) ||
    !isOptionalBoolean(message.is_tapback) ||
    !isOptionalString(message.associated_message_guid) ||
    !isOptionalNumber(message.associated_message_type) ||
    !isOptionalString(message.reaction_type) ||
    !isOptionalString(message.reaction_emoji) ||
    !isOptionalBoolean(message.is_reaction_add) ||
    !isOptionalString(message.reacted_to_guid) ||
    !isOptionalAttachments(message.attachments) ||
    !isOptionalString(message.chat_identifier) ||
    !isOptionalString(message.chat_guid) ||
    !isOptionalString(message.chat_name) ||
    !isOptionalStringArray(message.participants) ||
    !isOptionalBoolean(message.is_group)
  ) {
    return null;
  }

  return {
    ...message,
    text:
      typeof message.text === "string"
        ? stripImessageLengthPrefixedUtf8Text(message.text)
        : message.text,
    reply_to_text:
      typeof message.reply_to_text === "string"
        ? stripImessageLengthPrefixedUtf8Text(message.reply_to_text)
        : message.reply_to_text,
  };
}