Разработка системы блокировки подозрительных адресов

Разработка системы блокировки подозрительных адресов

Система блокировки подозрительных адресов — первый рубеж AML защиты. Её задача: предотвратить взаимодействие с известными bad actors до того, как транзакция попадёт в протокол или на биржу. Для DeFi протоколов это также снижает regulatory риски в юрисдикциях где регуляторы начинают обращать внимание на on-chain compliance.

Архитектура blocklist системы

On-chain blocklist (для смарт-контрактов)

contract AddressBlocklist {
    // Управление через multisig или governance
    address public admin;
    
    mapping(address => bool) public blocked;
    mapping(address => string) public blockReasons;
    
    event AddressBlocked(address indexed addr, string reason);
    event AddressUnblocked(address indexed addr);
    
    function blockAddress(address addr, string calldata reason) external onlyAdmin {
        blocked[addr] = true;
        blockReasons[addr] = reason;
        emit AddressBlocked(addr, reason);
    }
    
    function blockBatch(address[] calldata addrs, string calldata reason) external onlyAdmin {
        for (uint i = 0; i < addrs.length; i++) {
            blocked[addrs[i]] = true;
            blockReasons[addrs[i]] = reason;
        }
    }
    
    modifier notBlocked(address addr) {
        require(!blocked[addr], string.concat("Address blocked: ", blockReasons[addr]));
        _;
    }
}

// Использование в протоколе
contract Protocol is AddressBlocklist {
    function deposit(uint256 amount) external notBlocked(msg.sender) {
        // логика депозита
    }
}

Off-chain blocklist (для бирж и сервисов)

Для высоконагруженных систем — Redis Bloom Filter для быстрой проверки принадлежности адреса к blocklist:

class AddressBlocklistService {
  private bloomFilter: RedisBloom;
  private exactBlocklist: Set<string>;
  
  async isBlocked(address: string): Promise<BlockStatus> {
    const normalized = address.toLowerCase();
    
    // Bloom filter: false позитивы возможны, false негативы — нет
    if (!await this.bloomFilter.exists(normalized)) {
      return { blocked: false }; // быстрый ответ: точно не в blocklist
    }
    
    // Exact check для подтверждения (bloom filter мог дать false positive)
    const exactMatch = await this.db.findBlockedAddress(normalized);
    if (!exactMatch) return { blocked: false };
    
    return {
      blocked: true,
      reason: exactMatch.reason,
      source: exactMatch.source,
      addedAt: exactMatch.addedAt,
    };
  }
  
  async updateFromSanctionsList(): Promise<void> {
    // OFAC SDN список (обновляется несколько раз в неделю)
    const ofacAddresses = await fetchOFACCryptoAddresses();
    
    // Chainalysis Sanctioned Addresses список
    const chainalysisAddresses = await this.chainalysis.getSanctionedAddresses();
    
    const allNew = [...ofacAddresses, ...chainalysisAddresses];
    
    for (const addr of allNew) {
      await this.bloomFilter.add(addr.address.toLowerCase());
      await this.db.upsertBlockedAddress({
        address: addr.address.toLowerCase(),
        reason: addr.reason,
        source: addr.source,
      });
    }
  }
}

Источники blocklist данных

OFAC SDN список содержит crypto адреса — их нужно парсить из XML файла (SDN_Advanced.xml). Chainalysis и Elliptic предоставляют более широкие списки через API.

Автоматическое обновление

// Cron: каждый час проверяем обновления OFAC
@Cron("0 * * * *")
async syncOFACList() {
  const etag = await this.cache.get("ofac_etag");
  
  const response = await fetch("https://www.treasury.gov/ofac/downloads/SDN_advanced.xml", {
    headers: etag ? { "If-None-Match": etag } : {},
  });
  
  if (response.status === 304) return; // не изменился
  
  const xml = await response.text();
  const addresses = parseOFACCryptoAddresses(xml);
  
  await this.blocklist.updateAddresses(addresses, "OFAC");
  await this.cache.set("ofac_etag", response.headers.get("ETag"));
  
  this.logger.log(`OFAC sync: ${addresses.length} crypto addresses`);
}

Система блокировки подозрительных адресов с on-chain и off-chain компонентами, автоматическим обновлением из OFAC и Chainalysis — 2-3 недели разработки.