Function isMyMessageByIdentity

dme/dme.ts:311–341

(
  message: any,
  myId: bigint,
  sendAsTypedKeySet: Set<string>,
  sendAsRawIdSet: Set<string>
)

): boolean {
  if (message.senderId?.toString?.() === myId.toString()) {
    return true;
  }
  if (message.out === true) {
    return true;
  }
  const identityCandidates = [message.fromId, message.senderId];
  for (const candidate of identityCandidates) {
    const typedKey = peerToTypedKey(candidate);
    if (typedKey && sendAsTypedKeySet.has(typedKey)) {
      return true;
    }

    const rawId = getPeerRawId(candidate);
    if (rawId) {
      if (
        sendAsRawIdSet.has(rawId) ||
        sendAsRawIdSet.has(normalizeIdToken(rawId))
      ) {
        return true;
      }
    }
  }
  return false;
}

/**
 * 增强的消息搜索函数 - 带容错机制
 */
async function searchMyMessagesOptimized(
  client: TelegramClient,
  chatEntity: any,
  myId: bigint,
  userRequestedCount: number
): Promise<Api.Message[]> {