Розробка системи sanctions screening

Розробка системи sanctions screening

Sanctions screening — перевірка клієнтів та контрагентів проти офіційних санкційних списків. Для крипто-бізнесу це двохрівнева задача: скринінг особистості клієнта (OFAC SDN, EU sanctions, UN) та скринінг крипто адрес (OFAC SDN Crypto Addresses, Chainalysis Sanctioned).

Джерела санкційних даних

OFAC SDN List (США): найважливіший. Оновлюється кілька разів на тиждень. XML формат включає крипто адреси з 2018 року (Tornado Cash, OFAC designates). Доступний безплатно: https://www.treasury.gov/ofac/downloads/SDN_advanced.xml.

EU Consolidated Sanctions: https://webgate.ec.europa.eu/fsd/fsf. Охоплює всі EU санкції.

UN Security Council: https://scsanctions.un.org/.

UK OFSI: Post-Brexit UK sanctions список.

ComplyAdvantage / Refinitiv: комерційні провайдери які агрегують всі списки + enrichment.

Парсинг OFAC SDN для крипто адрес

import { parseStringPromise } from "xml2js";
import axios from "axios";

interface SanctionedCryptoAddress {
  address: string;
  currency: string; // XBT, ETH, USDT, та ін.
  entityName: string;
  programTags: string[];
}

async function fetchOFACCryptoAddresses(): Promise<SanctionedCryptoAddress[]> {
  const response = await axios.get(
    "https://www.treasury.gov/ofac/downloads/SDN_advanced.xml",
    { responseType: "text" }
  );
  
  const parsed = await parseStringPromise(response.data);
  const sdnEntries = parsed.sdnList.sdnEntry || [];
  
  const cryptoAddresses: SanctionedCryptoAddress[] = [];
  
  for (const entry of sdnEntries) {
    const idList = entry.idList?.[0]?.id || [];
    
    for (const id of idList) {
      const idType = id.idType?.[0];
      
      // OFAC використовує "Digital Currency Address - ETH", "Digital Currency Address - XBT" та ін.
      if (idType?.includes("Digital Currency Address")) {
        const currency = idType.split(" - ")[1];
        cryptoAddresses.push({
          address: id.idNumber?.[0]?.toLowerCase(),
          currency,
          entityName: `${entry.lastName?.[0]} ${entry.firstName?.[0] || ""}`.trim(),
          programTags: (entry.programList?.[0]?.program || []),
        });
      }
    }
  }
  
  return cryptoAddresses;
}

Система скринінгу

class SanctionsScreeningService {
  private nameIndex: Map<string, SanctionedPerson[]>;
  private cryptoAddressSet: Set<string>;
  private lastUpdated: Date;
  
  // Оновлення з усіх джерел
  async updateLists(): Promise<void> {
    const [ofacAddresses, ofacPersons, euSanctions] = await Promise.all([
      fetchOFACCryptoAddresses(),
      fetchOFACPersons(),
      fetchEUSanctions(),
    ]);
    
    // Перебудова індексів
    this.cryptoAddressSet = new Set(ofacAddresses.map(a => a.address.toLowerCase()));
    
    // Fuzzy name index для скринінгу персон
    this.nameIndex = buildNameIndex([...ofacPersons, ...euSanctions]);
    
    this.lastUpdated = new Date();
    await this.cache.set("sanctions_last_updated", this.lastUpdated);
  }
  
  // Скринінг крипто адреси (точне збігання)
  screenAddress(address: string): AddressScreenResult {
    const normalized = address.toLowerCase();
    if (this.cryptoAddressSet.has(normalized)) {
      return { isSanctioned: true, matchType: "EXACT" };
    }
    return { isSanctioned: false };
  }
  
  // Скринінг особистих даних (fuzzy matching)
  screenPerson(name: string, dob?: string, country?: string): PersonScreenResult {
    const candidates = this.nameIndex.get(normalizeNameKey(name)) || [];
    
    for (const candidate of candidates) {
      const score = calculateMatchScore(name, dob, country, candidate);
      
      if (score >= 95) {
        return { isSanctioned: true, matchType: "STRONG", matchScore: score, entity: candidate };
      }
      if (score >= 75) {
        return { isSanctioned: false, isPotentialMatch: true, matchScore: score, entity: candidate };
      }
    }
    
    return { isSanctioned: false };
  }
}

Fuzzy Matching для імен

Імена перекладаються між алфавітами, змінюються (девичья фамилія), пишуться з помилками. Точне збігання рядків дає false negatives:

import Fuse from "fuse.js";
import { transliterate } from "transliteration";

function calculateMatchScore(
  inputName: string,
  inputDob: string | undefined,
  inputCountry: string | undefined,
  candidate: SanctionedPerson
): number {
  // Транслітерація (Іванов → Ivanov)
  const normalizedInput = transliterate(inputName.toLowerCase());
  const normalizedCandidate = transliterate(candidate.name.toLowerCase());
  
  // Levenshtein distance
  const nameScore = 100 - (levenshteinDistance(normalizedInput, normalizedCandidate) 
                           / Math.max(normalizedInput.length, normalizedCandidate.length)) * 100;
  
  let totalScore = nameScore;
  
  // Якщо DOB збігається — підвищуємо впевненість
  if (inputDob && candidate.dob) {
    if (inputDob === candidate.dob) totalScore = Math.min(100, totalScore + 20);
    else totalScore = Math.max(0, totalScore - 10);
  }
  
  // Якщо країна збігається — невеличкий бонус
  if (inputCountry && candidate.countries?.includes(inputCountry)) {
    totalScore = Math.min(100, totalScore + 5);
  }
  
  return totalScore;
}

Безперервний моніторинг

Санкційні списки оновлюються неочікувано (екстрені designations). Потрібен cron job для синхронізації:

// Оновлення кожні 2 години
@Cron("0 */2 * * *")
async syncSanctionsList() {
  await this.sanctionsService.updateLists();
  
  // Re-screen активних клієнтів при крупних оновленнях
  const updateSize = await this.detectSignificantUpdate();
  if (updateSize > 10) {
    await this.rescreenActiveCustomers();
  }
}

Системасанкційного скринінгу з OFAC/EU parsing, fuzzy name matching та безперервним моніторингом — 2-3 тижні.