Fix TypeScript build errors

- Remove duplicate EscalationLevel export from regulatory.ts
- Add missing logger.ts and reports.ts files to audit package
- Fix treasury package type issues
- Clean dist folders and rebuild

packages/rules-engine/src/aml.d.ts

@@ -0,0 +1,42 @@
+/**
+ * AML (Anti-Money Laundering) and anti-structuring detection
+ */
+import type { Transaction, AMLCheckResult, SingleTransactionAMLResult, StructuringCheckResult, RuleResult } from '@brazil-swift-ops/types';
+/**
+ * Transaction history for structuring detection (in production, this would be a database)
+ */
+interface TransactionHistory {
+    transactionId: string;
+    amount: number;
+    currency: string;
+    usdEquivalent: number;
+    date: Date;
+    orderingCustomerTaxId?: string;
+    beneficiaryTaxId?: string;
+}
+declare class TransactionHistoryStore {
+    private history;
+    add(entry: TransactionHistory): void;
+    getByDateRange(startDate: Date, endDate: Date): TransactionHistory[];
+    getByCustomer(taxId: string, startDate: Date, endDate: Date): TransactionHistory[];
+    getAll(): TransactionHistory[];
+}
+export declare function getHistoryStore(): TransactionHistoryStore;
+/**
+ * Check single transaction AML threshold
+ */
+export declare function checkSingleTransactionAML(transaction: Transaction): SingleTransactionAMLResult;
+/**
+ * Check for structuring patterns (multiple small transactions that sum above threshold)
+ */
+export declare function checkStructuring(transaction: Transaction, historicalTransactions?: TransactionHistory[]): StructuringCheckResult | undefined;
+/**
+ * Perform complete AML check
+ */
+export declare function performAMLCheck(transaction: Transaction, historicalTransactions?: TransactionHistory[]): AMLCheckResult;
+/**
+ * Create rule result for AML check
+ */
+export declare function createAMLRuleResult(check: AMLCheckResult): RuleResult;
+export {};
+//# sourceMappingURL=aml.d.ts.map

packages/rules-engine/src/aml.d.ts.map

@@ -0,0 +1 @@
+{"version":3,"file":"aml.d.ts","sourceRoot":"","sources":["aml.ts"],"names":[],"mappings":"AAAA;;GAEG;AAEH,OAAO,KAAK,EACV,WAAW,EACX,cAAc,EACd,0BAA0B,EAC1B,sBAAsB,EACtB,UAAU,EAGX,MAAM,yBAAyB,CAAC;AAKjC;;GAEG;AACH,UAAU,kBAAkB;IAC1B,aAAa,EAAE,MAAM,CAAC;IACtB,MAAM,EAAE,MAAM,CAAC;IACf,QAAQ,EAAE,MAAM,CAAC;IACjB,aAAa,EAAE,MAAM,CAAC;IACtB,IAAI,EAAE,IAAI,CAAC;IACX,qBAAqB,CAAC,EAAE,MAAM,CAAC;IAC/B,gBAAgB,CAAC,EAAE,MAAM,CAAC;CAC3B;AAED,cAAM,uBAAuB;IAC3B,OAAO,CAAC,OAAO,CAA4B;IAE3C,GAAG,CAAC,KAAK,EAAE,kBAAkB,GAAG,IAAI;IAIpC,cAAc,CAAC,SAAS,EAAE,IAAI,EAAE,OAAO,EAAE,IAAI,GAAG,kBAAkB,EAAE;IAMpE,aAAa,CACX,KAAK,EAAE,MAAM,EACb,SAAS,EAAE,IAAI,EACf,OAAO,EAAE,IAAI,GACZ,kBAAkB,EAAE;IAUvB,MAAM,IAAI,kBAAkB,EAAE;CAG/B;AAID,wBAAgB,eAAe,IAAI,uBAAuB,CAEzD;AAED;;GAEG;AACH,wBAAgB,yBAAyB,CACvC,WAAW,EAAE,WAAW,GACvB,0BAA0B,CA6B5B;AAED;;GAEG;AACH,wBAAgB,gBAAgB,CAC9B,WAAW,EAAE,WAAW,EACxB,sBAAsB,CAAC,EAAE,kBAAkB,EAAE,GAC5C,sBAAsB,GAAG,SAAS,CAiEpC;AAED;;GAEG;AACH,wBAAgB,eAAe,CAC7B,WAAW,EAAE,WAAW,EACxB,sBAAsB,CAAC,EAAE,kBAAkB,EAAE,GAC5C,cAAc,CAyBhB;AAED;;GAEG;AACH,wBAAgB,mBAAmB,CAAC,KAAK,EAAE,cAAc,GAAG,UAAU,CAsBrE"}

packages/rules-engine/src/aml.js

@@ -0,0 +1,152 @@
+/**
+ * AML (Anti-Money Laundering) and anti-structuring detection
+ */
+import { getDefaultConverter } from '@brazil-swift-ops/utils';
+import { calculateRollingWindow, filterDatesInWindow } from '@brazil-swift-ops/utils';
+import { getConfig } from './config';
+class TransactionHistoryStore {
+    history = [];
+    add(entry) {
+        this.history.push(entry);
+    }
+    getByDateRange(startDate, endDate) {
+        return this.history.filter((entry) => entry.date >= startDate && entry.date <= endDate);
+    }
+    getByCustomer(taxId, startDate, endDate) {
+        return this.history.filter((entry) => (entry.orderingCustomerTaxId === taxId ||
+            entry.beneficiaryTaxId === taxId) &&
+            entry.date >= startDate &&
+            entry.date <= endDate);
+    }
+    getAll() {
+        return [...this.history];
+    }
+}
+const historyStore = new TransactionHistoryStore();
+export function getHistoryStore() {
+    return historyStore;
+}
+/**
+ * Check single transaction AML threshold
+ */
+export function checkSingleTransactionAML(transaction) {
+    const config = getConfig();
+    const converter = getDefaultConverter();
+    const usdEquivalent = converter.getUSDEquivalent(transaction.amount, transaction.currency);
+    const threshold = config.aml.singleTransactionThreshold;
+    const requiresEnhancedReview = usdEquivalent >= threshold;
+    let riskLevel;
+    if (usdEquivalent >= threshold) {
+        riskLevel = 'High';
+    }
+    else if (usdEquivalent >= threshold * 0.5) {
+        riskLevel = 'Medium';
+    }
+    else {
+        riskLevel = 'Low';
+    }
+    return {
+        passed: true, // AML check doesn't fail, it flags for review
+        transactionAmount: transaction.amount,
+        usdEquivalent,
+        threshold,
+        requiresEnhancedReview,
+        riskLevel,
+    };
+}
+/**
+ * Check for structuring patterns (multiple small transactions that sum above threshold)
+ */
+export function checkStructuring(transaction, historicalTransactions) {
+    const config = getConfig();
+    const converter = getDefaultConverter();
+    // Calculate rolling window
+    const window = calculateRollingWindow(transaction.createdAt || new Date(), config.aml.structuringWindowDays);
+    // Get historical transactions if not provided
+    if (!historicalTransactions) {
+        const customerTaxId = transaction.orderingCustomerTaxId || transaction.beneficiary?.taxId;
+        if (customerTaxId) {
+            historicalTransactions = historyStore.getByCustomer(customerTaxId, window.startDate, window.endDate);
+        }
+        else {
+            historicalTransactions = historyStore.getByDateRange(window.startDate, window.endDate);
+        }
+    }
+    // Filter to transactions in window
+    const windowTransactions = historicalTransactions.filter((t) => filterDatesInWindow([t.date], window).length > 0);
+    // Calculate totals
+    const totalAmount = windowTransactions.reduce((sum, t) => sum + t.amount, transaction.amount);
+    const totalUsdEquivalent = windowTransactions.reduce((sum, t) => sum + t.usdEquivalent, converter.getUSDEquivalent(transaction.amount, transaction.currency));
+    const individualAmounts = [
+        ...windowTransactions.map((t) => t.usdEquivalent),
+        converter.getUSDEquivalent(transaction.amount, transaction.currency),
+    ];
+    // Check if structuring detected
+    const threshold = config.aml.structuringThreshold;
+    const detected = totalUsdEquivalent >= threshold &&
+        individualAmounts.every((amt) => amt < threshold);
+    return {
+        detected,
+        windowDays: window.days,
+        transactionCount: windowTransactions.length + 1,
+        totalAmount,
+        totalUsdEquivalent,
+        individualAmounts,
+        rationale: detected
+            ? `Structuring detected: ${windowTransactions.length + 1} transactions totaling ${totalUsdEquivalent.toFixed(2)} USD over ${window.days} days, each below ${threshold} USD threshold.`
+            : `No structuring pattern detected. Total: ${totalUsdEquivalent.toFixed(2)} USD over ${window.days} days.`,
+    };
+}
+/**
+ * Perform complete AML check
+ */
+export function performAMLCheck(transaction, historicalTransactions) {
+    const singleCheck = checkSingleTransactionAML(transaction);
+    const structuringCheck = checkStructuring(transaction, historicalTransactions);
+    // Determine overall risk level
+    let overallRiskLevel;
+    if (singleCheck.riskLevel === 'High' || structuringCheck?.detected) {
+        overallRiskLevel = 'High';
+    }
+    else if (singleCheck.riskLevel === 'Medium') {
+        overallRiskLevel = 'Medium';
+    }
+    else {
+        overallRiskLevel = 'Low';
+    }
+    const passed = overallRiskLevel !== 'High';
+    return {
+        passed,
+        singleTransactionCheck: singleCheck,
+        structuringCheck,
+        overallRiskLevel,
+        rationale: passed
+            ? `AML check passed. Risk level: ${overallRiskLevel}.`
+            : `AML check flagged for review. Risk level: ${overallRiskLevel}. ${structuringCheck?.detected ? 'Structuring pattern detected.' : ''}`,
+    };
+}
+/**
+ * Create rule result for AML check
+ */
+export function createAMLRuleResult(check) {
+    const severity = check.overallRiskLevel === 'High'
+        ? 'Critical'
+        : check.overallRiskLevel === 'Medium'
+            ? 'Warning'
+            : 'Info';
+    const decision = check.passed ? 'Allow' : 'Escalate';
+    return {
+        ruleId: 'aml-check',
+        ruleName: 'AML & Anti-Structuring Check',
+        passed: check.passed,
+        severity,
+        decision,
+        rationale: check.rationale,
+        details: {
+            overallRiskLevel: check.overallRiskLevel,
+            singleTransactionCheck: check.singleTransactionCheck,
+            structuringCheck: check.structuringCheck,
+        },
+    };
+}
+//# sourceMappingURL=aml.js.map

packages/rules-engine/src/aml.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"aml.js","sourceRoot":"","sources":["aml.ts"],"names":[],"mappings":"AAAA;;GAEG;AAWH,OAAO,EAAE,mBAAmB,EAAE,MAAM,yBAAyB,CAAC;AAC9D,OAAO,EAAE,sBAAsB,EAAE,mBAAmB,EAAE,MAAM,yBAAyB,CAAC;AACtF,OAAO,EAAE,SAAS,EAAE,MAAM,UAAU,CAAC;AAerC,MAAM,uBAAuB;IACnB,OAAO,GAAyB,EAAE,CAAC;IAE3C,GAAG,CAAC,KAAyB;QAC3B,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;IAC3B,CAAC;IAED,cAAc,CAAC,SAAe,EAAE,OAAa;QAC3C,OAAO,IAAI,CAAC,OAAO,CAAC,MAAM,CACxB,CAAC,KAAK,EAAE,EAAE,CAAC,KAAK,CAAC,IAAI,IAAI,SAAS,IAAI,KAAK,CAAC,IAAI,IAAI,OAAO,CAC5D,CAAC;IACJ,CAAC;IAED,aAAa,CACX,KAAa,EACb,SAAe,EACf,OAAa;QAEb,OAAO,IAAI,CAAC,OAAO,CAAC,MAAM,CACxB,CAAC,KAAK,EAAE,EAAE,CACR,CAAC,KAAK,CAAC,qBAAqB,KAAK,KAAK;YACpC,KAAK,CAAC,gBAAgB,KAAK,KAAK,CAAC;YACnC,KAAK,CAAC,IAAI,IAAI,SAAS;YACvB,KAAK,CAAC,IAAI,IAAI,OAAO,CACxB,CAAC;IACJ,CAAC;IAED,MAAM;QACJ,OAAO,CAAC,GAAG,IAAI,CAAC,OAAO,CAAC,CAAC;IAC3B,CAAC;CACF;AAED,MAAM,YAAY,GAAG,IAAI,uBAAuB,EAAE,CAAC;AAEnD,MAAM,UAAU,eAAe;IAC7B,OAAO,YAAY,CAAC;AACtB,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,yBAAyB,CACvC,WAAwB;IAExB,MAAM,MAAM,GAAG,SAAS,EAAE,CAAC;IAC3B,MAAM,SAAS,GAAG,mBAAmB,EAAE,CAAC;IAExC,MAAM,aAAa,GAAG,SAAS,CAAC,gBAAgB,CAC9C,WAAW,CAAC,MAAM,EAClB,WAAW,CAAC,QAAQ,CACrB,CAAC;IAEF,MAAM,SAAS,GAAG,MAAM,CAAC,GAAG,CAAC,0BAA0B,CAAC;IACxD,MAAM,sBAAsB,GAAG,aAAa,IAAI,SAAS,CAAC;IAE1D,IAAI,SAAoC,CAAC;IACzC,IAAI,aAAa,IAAI,SAAS,EAAE,CAAC;QAC/B,SAAS,GAAG,MAAM,CAAC;IACrB,CAAC;SAAM,IAAI,aAAa,IAAI,SAAS,GAAG,GAAG,EAAE,CAAC;QAC5C,SAAS,GAAG,QAAQ,CAAC;IACvB,CAAC;SAAM,CAAC;QACN,SAAS,GAAG,KAAK,CAAC;IACpB,CAAC;IAED,OAAO;QACL,MAAM,EAAE,IAAI,EAAE,8CAA8C;QAC5D,iBAAiB,EAAE,WAAW,CAAC,MAAM;QACrC,aAAa;QACb,SAAS;QACT,sBAAsB;QACtB,SAAS;KACV,CAAC;AACJ,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,gBAAgB,CAC9B,WAAwB,EACxB,sBAA6C;IAE7C,MAAM,MAAM,GAAG,SAAS,EAAE,CAAC;IAC3B,MAAM,SAAS,GAAG,mBAAmB,EAAE,CAAC;IAExC,2BAA2B;IAC3B,MAAM,MAAM,GAAG,sBAAsB,CACnC,WAAW,CAAC,SAAS,IAAI,IAAI,IAAI,EAAE,EACnC,MAAM,CAAC,GAAG,CAAC,qBAAqB,CACjC,CAAC;IAEF,8CAA8C;IAC9C,IAAI,CAAC,sBAAsB,EAAE,CAAC;QAC5B,MAAM,aAAa,GACjB,WAAW,CAAC,qBAAqB,IAAI,WAAW,CAAC,WAAW,EAAE,KAAK,CAAC;QACtE,IAAI,aAAa,EAAE,CAAC;YAClB,sBAAsB,GAAG,YAAY,CAAC,aAAa,CACjD,aAAa,EACb,MAAM,CAAC,SAAS,EAChB,MAAM,CAAC,OAAO,CACf,CAAC;QACJ,CAAC;aAAM,CAAC;YACN,sBAAsB,GAAG,YAAY,CAAC,cAAc,CAClD,MAAM,CAAC,SAAS,EAChB,MAAM,CAAC,OAAO,CACf,CAAC;QACJ,CAAC;IACH,CAAC;IAED,mCAAmC;IACnC,MAAM,kBAAkB,GAAG,sBAAsB,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE,EAAE,CAC7D,mBAAmB,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,EAAE,MAAM,CAAC,CAAC,MAAM,GAAG,CAAC,CACjD,CAAC;IAEF,mBAAmB;IACnB,MAAM,WAAW,GAAG,kBAAkB,CAAC,MAAM,CAC3C,CAAC,GAAG,EAAE,CAAC,EAAE,EAAE,CAAC,GAAG,GAAG,CAAC,CAAC,MAAM,EAC1B,WAAW,CAAC,MAAM,CACnB,CAAC;IACF,MAAM,kBAAkB,GAAG,kBAAkB,CAAC,MAAM,CAClD,CAAC,GAAG,EAAE,CAAC,EAAE,EAAE,CAAC,GAAG,GAAG,CAAC,CAAC,aAAa,EACjC,SAAS,CAAC,gBAAgB,CAAC,WAAW,CAAC,MAAM,EAAE,WAAW,CAAC,QAAQ,CAAC,CACrE,CAAC;IAEF,MAAM,iBAAiB,GAAG;QACxB,GAAG,kBAAkB,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,aAAa,CAAC;QACjD,SAAS,CAAC,gBAAgB,CAAC,WAAW,CAAC,MAAM,EAAE,WAAW,CAAC,QAAQ,CAAC;KACrE,CAAC;IAEF,gCAAgC;IAChC,MAAM,SAAS,GAAG,MAAM,CAAC,GAAG,CAAC,oBAAoB,CAAC;IAClD,MAAM,QAAQ,GACZ,kBAAkB,IAAI,SAAS;QAC/B,iBAAiB,CAAC,KAAK,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,GAAG,GAAG,SAAS,CAAC,CAAC;IAEpD,OAAO;QACL,QAAQ;QACR,UAAU,EAAE,MAAM,CAAC,IAAI;QACvB,gBAAgB,EAAE,kBAAkB,CAAC,MAAM,GAAG,CAAC;QAC/C,WAAW;QACX,kBAAkB;QAClB,iBAAiB;QACjB,SAAS,EAAE,QAAQ;YACjB,CAAC,CAAC,yBAAyB,kBAAkB,CAAC,MAAM,GAAG,CAAC,0BAA0B,kBAAkB,CAAC,OAAO,CAAC,CAAC,CAAC,aAAa,MAAM,CAAC,IAAI,qBAAqB,SAAS,iBAAiB;YACtL,CAAC,CAAC,2CAA2C,kBAAkB,CAAC,OAAO,CAAC,CAAC,CAAC,aAAa,MAAM,CAAC,IAAI,QAAQ;KAC7G,CAAC;AACJ,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,eAAe,CAC7B,WAAwB,EACxB,sBAA6C;IAE7C,MAAM,WAAW,GAAG,yBAAyB,CAAC,WAAW,CAAC,CAAC;IAC3D,MAAM,gBAAgB,GAAG,gBAAgB,CAAC,WAAW,EAAE,sBAAsB,CAAC,CAAC;IAE/E,+BAA+B;IAC/B,IAAI,gBAA2C,CAAC;IAChD,IAAI,WAAW,CAAC,SAAS,KAAK,MAAM,IAAI,gBAAgB,EAAE,QAAQ,EAAE,CAAC;QACnE,gBAAgB,GAAG,MAAM,CAAC;IAC5B,CAAC;SAAM,IAAI,WAAW,CAAC,SAAS,KAAK,QAAQ,EAAE,CAAC;QAC9C,gBAAgB,GAAG,QAAQ,CAAC;IAC9B,CAAC;SAAM,CAAC;QACN,gBAAgB,GAAG,KAAK,CAAC;IAC3B,CAAC;IAED,MAAM,MAAM,GAAG,gBAAgB,KAAK,MAAM,CAAC;IAE3C,OAAO;QACL,MAAM;QACN,sBAAsB,EAAE,WAAW;QACnC,gBAAgB;QAChB,gBAAgB;QAChB,SAAS,EAAE,MAAM;YACf,CAAC,CAAC,iCAAiC,gBAAgB,GAAG;YACtD,CAAC,CAAC,6CAA6C,gBAAgB,KAAK,gBAAgB,EAAE,QAAQ,CAAC,CAAC,CAAC,+BAA+B,CAAC,CAAC,CAAC,EAAE,EAAE;KAC1I,CAAC;AACJ,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,mBAAmB,CAAC,KAAqB;IACvD,MAAM,QAAQ,GACZ,KAAK,CAAC,gBAAgB,KAAK,MAAM;QAC/B,CAAC,CAAC,UAAU;QACZ,CAAC,CAAC,KAAK,CAAC,gBAAgB,KAAK,QAAQ;YACrC,CAAC,CAAC,SAAS;YACX,CAAC,CAAC,MAAM,CAAC;IACb,MAAM,QAAQ,GAAiB,KAAK,CAAC,MAAM,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,UAAU,CAAC;IAEnE,OAAO;QACL,MAAM,EAAE,WAAW;QACnB,QAAQ,EAAE,8BAA8B;QACxC,MAAM,EAAE,KAAK,CAAC,MAAM;QACpB,QAAQ;QACR,QAAQ;QACR,SAAS,EAAE,KAAK,CAAC,SAAS;QAC1B,OAAO,EAAE;YACP,gBAAgB,EAAE,KAAK,CAAC,gBAAgB;YACxC,sBAAsB,EAAE,KAAK,CAAC,sBAAsB;YACpD,gBAAgB,EAAE,KAAK,CAAC,gBAAgB;SACzC;KACF,CAAC;AACJ,CAAC"}

packages/rules-engine/src/fx-contract.d.ts

@@ -0,0 +1,13 @@
+import type { Transaction, FXContract, FXContractCheckResult, RuleResult } from '@brazil-swift-ops/types';
+declare class FXContractStore {
+    private contracts;
+    add(contract: FXContract): void;
+    get(contractId: string): FXContract | undefined;
+    getAll(): FXContract[];
+    updateRemainingAmount(contractId: string, usedAmount: number): void;
+}
+export declare function getContractStore(): FXContractStore;
+export declare function validateFXContract(transaction: Transaction, contract?: FXContract): FXContractCheckResult;
+export declare function createFXContractRuleResult(check: FXContractCheckResult): RuleResult;
+export {};
+//# sourceMappingURL=fx-contract.d.ts.map

packages/rules-engine/src/fx-contract.d.ts.map

@@ -0,0 +1 @@
+{"version":3,"file":"fx-contract.d.ts","sourceRoot":"","sources":["fx-contract.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EACV,WAAW,EACX,UAAU,EACV,qBAAqB,EACrB,UAAU,EAGX,MAAM,yBAAyB,CAAC;AAGjC,cAAM,eAAe;IACnB,OAAO,CAAC,SAAS,CAAsC;IAEvD,GAAG,CAAC,QAAQ,EAAE,UAAU,GAAG,IAAI;IAI/B,GAAG,CAAC,UAAU,EAAE,MAAM,GAAG,UAAU,GAAG,SAAS;IAI/C,MAAM,IAAI,UAAU,EAAE;IAItB,qBAAqB,CAAC,UAAU,EAAE,MAAM,EAAE,UAAU,EAAE,MAAM,GAAG,IAAI;CAWpE;AAID,wBAAgB,gBAAgB,IAAI,eAAe,CAElD;AAED,wBAAgB,kBAAkB,CAChC,WAAW,EAAE,WAAW,EACxB,QAAQ,CAAC,EAAE,UAAU,GACpB,qBAAqB,CAmFvB;AAED,wBAAgB,0BAA0B,CACxC,KAAK,EAAE,qBAAqB,GAC3B,UAAU,CAsBZ"}

packages/rules-engine/src/fx-contract.js

@@ -0,0 +1,127 @@
+import { isEffectiveDate } from '@brazil-swift-ops/utils';
+class FXContractStore {
+    contracts = new Map();
+    add(contract) {
+        this.contracts.set(contract.contractId, contract);
+    }
+    get(contractId) {
+        return this.contracts.get(contractId);
+    }
+    getAll() {
+        return Array.from(this.contracts.values());
+    }
+    updateRemainingAmount(contractId, usedAmount) {
+        const contract = this.contracts.get(contractId);
+        if (contract) {
+            contract.usedAmount += usedAmount;
+            contract.remainingAmount = contract.amount - contract.usedAmount;
+            contract.updatedAt = new Date();
+            if (contract.remainingAmount <= 0) {
+                contract.status = 'exhausted';
+            }
+        }
+    }
+}
+const contractStore = new FXContractStore();
+export function getContractStore() {
+    return contractStore;
+}
+export function validateFXContract(transaction, contract) {
+    if (!transaction.fxContractId) {
+        return {
+            passed: false,
+            contractExists: false,
+            contractType: undefined,
+            contractAmount: 0,
+            contractRemainingAmount: 0,
+            transactionAmount: transaction.amount,
+            amountWithinLimit: false,
+            rationale: 'FX contract ID is required for cross-border transactions.',
+        };
+    }
+    if (!contract) {
+        contract = contractStore.get(transaction.fxContractId);
+    }
+    if (!contract) {
+        return {
+            passed: false,
+            fxContractId: transaction.fxContractId,
+            contractExists: false,
+            contractType: undefined,
+            contractAmount: 0,
+            contractRemainingAmount: 0,
+            transactionAmount: transaction.amount,
+            amountWithinLimit: false,
+            rationale: `FX contract ${transaction.fxContractId} not found.`,
+        };
+    }
+    const now = new Date();
+    const contractActive = contract.status === 'active' &&
+        isEffectiveDate(now, contract.effectiveDate, contract.expiryDate);
+    if (!contractActive) {
+        return {
+            passed: false,
+            fxContractId: contract.contractId,
+            contractExists: true,
+            contractActive: false,
+            contractType: contract.type,
+            contractAmount: contract.amount,
+            contractRemainingAmount: contract.remainingAmount,
+            transactionAmount: transaction.amount,
+            amountWithinLimit: false,
+            rationale: `FX contract ${contract.contractId} is not active (status: ${contract.status}).`,
+        };
+    }
+    if (contract.type !== transaction.direction) {
+        return {
+            passed: false,
+            fxContractId: contract.contractId,
+            contractExists: true,
+            contractActive: false,
+            contractType: contract.type,
+            contractAmount: contract.amount,
+            contractRemainingAmount: contract.remainingAmount,
+            transactionAmount: transaction.amount,
+            amountWithinLimit: false,
+            rationale: `FX contract type (${contract.type}) does not match transaction direction (${transaction.direction}).`,
+        };
+    }
+    const amountWithinLimit = transaction.amount <= contract.remainingAmount;
+    return {
+        passed: amountWithinLimit && contractActive,
+        fxContractId: contract.contractId,
+        contractExists: true,
+        contractActive,
+        contractType: contract.type,
+        contractAmount: contract.amount,
+        contractRemainingAmount: contract.remainingAmount,
+        transactionAmount: transaction.amount,
+        amountWithinLimit,
+        rationale: amountWithinLimit
+            ? `Transaction amount (${transaction.amount} ${transaction.currency}) is within FX contract limit (${contract.remainingAmount} ${contract.currency} remaining).`
+            : `Transaction amount (${transaction.amount} ${transaction.currency}) exceeds FX contract remaining amount (${contract.remainingAmount} ${contract.currency}).`,
+    };
+}
+export function createFXContractRuleResult(check) {
+    const severity = check.passed ? 'Info' : 'Critical';
+    const decision = check.passed ? 'Allow' : 'Hold';
+    return {
+        ruleId: 'fx-contract-check',
+        ruleName: 'FX Contract Validation',
+        passed: check.passed,
+        severity,
+        decision,
+        rationale: check.rationale,
+        details: {
+            fxContractId: check.fxContractId,
+            contractExists: check.contractExists,
+            contractActive: check.contractActive,
+            contractType: check.contractType,
+            contractAmount: check.contractAmount,
+            contractRemainingAmount: check.contractRemainingAmount,
+            transactionAmount: check.transactionAmount,
+            amountWithinLimit: check.amountWithinLimit,
+        },
+    };
+}
+//# sourceMappingURL=fx-contract.js.map

packages/rules-engine/src/fx-contract.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"fx-contract.js","sourceRoot":"","sources":["fx-contract.ts"],"names":[],"mappings":"AAQA,OAAO,EAAE,eAAe,EAAE,MAAM,yBAAyB,CAAC;AAE1D,MAAM,eAAe;IACX,SAAS,GAA4B,IAAI,GAAG,EAAE,CAAC;IAEvD,GAAG,CAAC,QAAoB;QACtB,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,QAAQ,CAAC,UAAU,EAAE,QAAQ,CAAC,CAAC;IACpD,CAAC;IAED,GAAG,CAAC,UAAkB;QACpB,OAAO,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC;IACxC,CAAC;IAED,MAAM;QACJ,OAAO,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,MAAM,EAAE,CAAC,CAAC;IAC7C,CAAC;IAED,qBAAqB,CAAC,UAAkB,EAAE,UAAkB;QAC1D,MAAM,QAAQ,GAAG,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC;QAChD,IAAI,QAAQ,EAAE,CAAC;YACb,QAAQ,CAAC,UAAU,IAAI,UAAU,CAAC;YAClC,QAAQ,CAAC,eAAe,GAAG,QAAQ,CAAC,MAAM,GAAG,QAAQ,CAAC,UAAU,CAAC;YACjE,QAAQ,CAAC,SAAS,GAAG,IAAI,IAAI,EAAE,CAAC;YAChC,IAAI,QAAQ,CAAC,eAAe,IAAI,CAAC,EAAE,CAAC;gBAClC,QAAQ,CAAC,MAAM,GAAG,WAAW,CAAC;YAChC,CAAC;QACH,CAAC;IACH,CAAC;CACF;AAED,MAAM,aAAa,GAAG,IAAI,eAAe,EAAE,CAAC;AAE5C,MAAM,UAAU,gBAAgB;IAC9B,OAAO,aAAa,CAAC;AACvB,CAAC;AAED,MAAM,UAAU,kBAAkB,CAChC,WAAwB,EACxB,QAAqB;IAErB,IAAI,CAAC,WAAW,CAAC,YAAY,EAAE,CAAC;QAC9B,OAAO;YACL,MAAM,EAAE,KAAK;YACb,cAAc,EAAE,KAAK;YACrB,YAAY,EAAE,SAAS;YACvB,cAAc,EAAE,CAAC;YACjB,uBAAuB,EAAE,CAAC;YAC1B,iBAAiB,EAAE,WAAW,CAAC,MAAM;YACrC,iBAAiB,EAAE,KAAK;YACxB,SAAS,EAAE,2DAA2D;SACvE,CAAC;IACJ,CAAC;IAED,IAAI,CAAC,QAAQ,EAAE,CAAC;QACd,QAAQ,GAAG,aAAa,CAAC,GAAG,CAAC,WAAW,CAAC,YAAY,CAAC,CAAC;IACzD,CAAC;IAED,IAAI,CAAC,QAAQ,EAAE,CAAC;QACd,OAAO;YACL,MAAM,EAAE,KAAK;YACb,YAAY,EAAE,WAAW,CAAC,YAAY;YACtC,cAAc,EAAE,KAAK;YACrB,YAAY,EAAE,SAAS;YACvB,cAAc,EAAE,CAAC;YACjB,uBAAuB,EAAE,CAAC;YAC1B,iBAAiB,EAAE,WAAW,CAAC,MAAM;YACrC,iBAAiB,EAAE,KAAK;YACxB,SAAS,EAAE,eAAe,WAAW,CAAC,YAAY,aAAa;SAChE,CAAC;IACJ,CAAC;IAED,MAAM,GAAG,GAAG,IAAI,IAAI,EAAE,CAAC;IACvB,MAAM,cAAc,GAClB,QAAQ,CAAC,MAAM,KAAK,QAAQ;QAC5B,eAAe,CAAC,GAAG,EAAE,QAAQ,CAAC,aAAa,EAAE,QAAQ,CAAC,UAAU,CAAC,CAAC;IAEpE,IAAI,CAAC,cAAc,EAAE,CAAC;QACpB,OAAO;YACL,MAAM,EAAE,KAAK;YACb,YAAY,EAAE,QAAQ,CAAC,UAAU;YACjC,cAAc,EAAE,IAAI;YACpB,cAAc,EAAE,KAAK;YACrB,YAAY,EAAE,QAAQ,CAAC,IAAI;YAC3B,cAAc,EAAE,QAAQ,CAAC,MAAM;YAC/B,uBAAuB,EAAE,QAAQ,CAAC,eAAe;YACjD,iBAAiB,EAAE,WAAW,CAAC,MAAM;YACrC,iBAAiB,EAAE,KAAK;YACxB,SAAS,EAAE,eAAe,QAAQ,CAAC,UAAU,2BAA2B,QAAQ,CAAC,MAAM,IAAI;SAC5F,CAAC;IACJ,CAAC;IAED,IAAI,QAAQ,CAAC,IAAI,KAAK,WAAW,CAAC,SAAS,EAAE,CAAC;QAC5C,OAAO;YACL,MAAM,EAAE,KAAK;YACb,YAAY,EAAE,QAAQ,CAAC,UAAU;YACjC,cAAc,EAAE,IAAI;YACpB,cAAc,EAAE,KAAK;YACrB,YAAY,EAAE,QAAQ,CAAC,IAAI;YAC3B,cAAc,EAAE,QAAQ,CAAC,MAAM;YAC/B,uBAAuB,EAAE,QAAQ,CAAC,eAAe;YACjD,iBAAiB,EAAE,WAAW,CAAC,MAAM;YACrC,iBAAiB,EAAE,KAAK;YACxB,SAAS,EAAE,qBAAqB,QAAQ,CAAC,IAAI,2CAA2C,WAAW,CAAC,SAAS,IAAI;SAClH,CAAC;IACJ,CAAC;IAED,MAAM,iBAAiB,GAAG,WAAW,CAAC,MAAM,IAAI,QAAQ,CAAC,eAAe,CAAC;IAEzE,OAAO;QACL,MAAM,EAAE,iBAAiB,IAAI,cAAc;QAC3C,YAAY,EAAE,QAAQ,CAAC,UAAU;QACjC,cAAc,EAAE,IAAI;QACpB,cAAc;QACd,YAAY,EAAE,QAAQ,CAAC,IAAI;QAC3B,cAAc,EAAE,QAAQ,CAAC,MAAM;QAC/B,uBAAuB,EAAE,QAAQ,CAAC,eAAe;QACjD,iBAAiB,EAAE,WAAW,CAAC,MAAM;QACrC,iBAAiB;QACjB,SAAS,EAAE,iBAAiB;YAC1B,CAAC,CAAC,uBAAuB,WAAW,CAAC,MAAM,IAAI,WAAW,CAAC,QAAQ,kCAAkC,QAAQ,CAAC,eAAe,IAAI,QAAQ,CAAC,QAAQ,cAAc;YAChK,CAAC,CAAC,uBAAuB,WAAW,CAAC,MAAM,IAAI,WAAW,CAAC,QAAQ,2CAA2C,QAAQ,CAAC,eAAe,IAAI,QAAQ,CAAC,QAAQ,IAAI;KAClK,CAAC;AACJ,CAAC;AAED,MAAM,UAAU,0BAA0B,CACxC,KAA4B;IAE5B,MAAM,QAAQ,GAAiB,KAAK,CAAC,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,UAAU,CAAC;IAClE,MAAM,QAAQ,GAAiB,KAAK,CAAC,MAAM,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,MAAM,CAAC;IAE/D,OAAO;QACL,MAAM,EAAE,mBAAmB;QAC3B,QAAQ,EAAE,wBAAwB;QAClC,MAAM,EAAE,KAAK,CAAC,MAAM;QACpB,QAAQ;QACR,QAAQ;QACR,SAAS,EAAE,KAAK,CAAC,SAAS;QAC1B,OAAO,EAAE;YACP,YAAY,EAAE,KAAK,CAAC,YAAY;YAChC,cAAc,EAAE,KAAK,CAAC,cAAc;YACpC,cAAc,EAAE,KAAK,CAAC,cAAc;YACpC,YAAY,EAAE,KAAK,CAAC,YAAY;YAChC,cAAc,EAAE,KAAK,CAAC,cAAc;YACpC,uBAAuB,EAAE,KAAK,CAAC,uBAAuB;YACtD,iBAAiB,EAAE,KAAK,CAAC,iBAAiB;YAC1C,iBAAiB,EAAE,KAAK,CAAC,iBAAiB;SAC3C;KACF,CAAC;AACJ,CAAC"}

packages/rules-engine/src/index.d.ts

@@ -0,0 +1,13 @@
+/**
+ * @brazil-swift-ops/rules-engine
+ *
+ * Brazil regulatory rules engine for cross-border payments
+ */
+export * from './config';
+export * from './threshold';
+export * from './documentation';
+export * from './fx-contract';
+export * from './iof';
+export * from './aml';
+export * from './orchestrator';
+//# sourceMappingURL=index.d.ts.map

packages/rules-engine/src/index.d.ts.map

@@ -0,0 +1 @@
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["index.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAEH,cAAc,UAAU,CAAC;AACzB,cAAc,aAAa,CAAC;AAC5B,cAAc,iBAAiB,CAAC;AAChC,cAAc,eAAe,CAAC;AAC9B,cAAc,OAAO,CAAC;AACtB,cAAc,OAAO,CAAC;AACtB,cAAc,gBAAgB,CAAC"}

packages/rules-engine/src/index.js

@@ -0,0 +1,13 @@
+/**
+ * @brazil-swift-ops/rules-engine
+ *
+ * Brazil regulatory rules engine for cross-border payments
+ */
+export * from './config';
+export * from './threshold';
+export * from './documentation';
+export * from './fx-contract';
+export * from './iof';
+export * from './aml';
+export * from './orchestrator';
+//# sourceMappingURL=index.js.map

packages/rules-engine/src/index.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"index.js","sourceRoot":"","sources":["index.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAEH,cAAc,UAAU,CAAC;AACzB,cAAc,aAAa,CAAC;AAC5B,cAAc,iBAAiB,CAAC;AAChC,cAAc,eAAe,CAAC;AAC9B,cAAc,OAAO,CAAC;AACtB,cAAc,OAAO,CAAC;AACtB,cAAc,gBAAgB,CAAC"}

packages/rules-engine/src/iof.d.ts

@@ -0,0 +1,4 @@
+import type { Transaction, IOFCalculationResult, RuleResult } from '@brazil-swift-ops/types';
+export declare function calculateIOF(transaction: Transaction): IOFCalculationResult;
+export declare function createIOFRuleResult(calculation: IOFCalculationResult): RuleResult;
+//# sourceMappingURL=iof.d.ts.map

packages/rules-engine/src/iof.d.ts.map

@@ -0,0 +1 @@
+{"version":3,"file":"iof.d.ts","sourceRoot":"","sources":["iof.ts"],"names":[],"mappings":"AACA,OAAO,KAAK,EACV,WAAW,EACX,oBAAoB,EACpB,UAAU,EACX,MAAM,yBAAyB,CAAC;AAIjC,wBAAgB,YAAY,CAAC,WAAW,EAAE,WAAW,GAAG,oBAAoB,CAuC3E;AAED,wBAAgB,mBAAmB,CACjC,WAAW,EAAE,oBAAoB,GAChC,UAAU,CAoBZ"}

packages/rules-engine/src/iof.js

@@ -0,0 +1,55 @@
+import Decimal from 'decimal.js';
+import { getDefaultConverter } from '@brazil-swift-ops/utils';
+import { getConfig } from './config';
+export function calculateIOF(transaction) {
+    const config = getConfig();
+    const converter = getDefaultConverter();
+    const brlAmount = converter.convert(transaction.amount, transaction.currency, 'BRL');
+    const iofRate = transaction.direction === 'inbound'
+        ? config.iof.inboundRate
+        : config.iof.outboundRate;
+    const brlDecimal = new Decimal(brlAmount);
+    const rateDecimal = new Decimal(iofRate);
+    const iofDecimal = brlDecimal.mul(rateDecimal);
+    const iofAmount = iofDecimal.toNumber();
+    let netAmount;
+    if (transaction.direction === 'inbound') {
+        netAmount = brlAmount - iofAmount;
+    }
+    else {
+        netAmount = brlAmount + iofAmount;
+    }
+    return {
+        direction: transaction.direction,
+        transactionAmount: transaction.amount,
+        currency: transaction.currency,
+        brlAmount,
+        iofRate,
+        iofAmount,
+        netAmount,
+        effectiveDate: config.iof.effectiveDate,
+        rateVersion: config.iof.rateVersion,
+    };
+}
+export function createIOFRuleResult(calculation) {
+    return {
+        ruleId: 'iof-calculation',
+        ruleName: 'IOF Tax Calculation',
+        passed: true,
+        severity: 'Info',
+        decision: 'Allow',
+        rationale: `IOF calculated: ${calculation.iofAmount.toFixed(2)} BRL (${(calculation.iofRate * 100).toFixed(2)}% rate) for ${calculation.direction} transaction. Net amount: ${calculation.netAmount.toFixed(2)} BRL.`,
+        details: {
+            direction: calculation.direction,
+            transactionAmount: calculation.transactionAmount,
+            currency: calculation.currency,
+            brlAmount: calculation.brlAmount,
+            iofRate: calculation.iofRate,
+            iofAmount: calculation.iofAmount,
+            netAmount: calculation.netAmount,
+            effectiveDate: calculation.effectiveDate,
+            rateVersion: calculation.rateVersion,
+        },
+    };
+}
+//# sourceMappingURL=iof.js.map

packages/rules-engine/src/iof.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"iof.js","sourceRoot":"","sources":["iof.ts"],"names":[],"mappings":"AAAA,OAAO,OAAO,MAAM,YAAY,CAAC;AAMjC,OAAO,EAAE,mBAAmB,EAAE,MAAM,yBAAyB,CAAC;AAC9D,OAAO,EAAE,SAAS,EAAE,MAAM,UAAU,CAAC;AAErC,MAAM,UAAU,YAAY,CAAC,WAAwB;IACnD,MAAM,MAAM,GAAG,SAAS,EAAE,CAAC;IAC3B,MAAM,SAAS,GAAG,mBAAmB,EAAE,CAAC;IAExC,MAAM,SAAS,GAAG,SAAS,CAAC,OAAO,CACjC,WAAW,CAAC,MAAM,EAClB,WAAW,CAAC,QAAQ,EACpB,KAAK,CACN,CAAC;IAEF,MAAM,OAAO,GACX,WAAW,CAAC,SAAS,KAAK,SAAS;QACjC,CAAC,CAAC,MAAM,CAAC,GAAG,CAAC,WAAW;QACxB,CAAC,CAAC,MAAM,CAAC,GAAG,CAAC,YAAY,CAAC;IAE9B,MAAM,UAAU,GAAG,IAAI,OAAO,CAAC,SAAS,CAAC,CAAC;IAC1C,MAAM,WAAW,GAAG,IAAI,OAAO,CAAC,OAAO,CAAC,CAAC;IACzC,MAAM,UAAU,GAAG,UAAU,CAAC,GAAG,CAAC,WAAW,CAAC,CAAC;IAE/C,MAAM,SAAS,GAAG,UAAU,CAAC,QAAQ,EAAE,CAAC;IAExC,IAAI,SAAiB,CAAC;IACtB,IAAI,WAAW,CAAC,SAAS,KAAK,SAAS,EAAE,CAAC;QACxC,SAAS,GAAG,SAAS,GAAG,SAAS,CAAC;IACpC,CAAC;SAAM,CAAC;QACN,SAAS,GAAG,SAAS,GAAG,SAAS,CAAC;IACpC,CAAC;IAED,OAAO;QACL,SAAS,EAAE,WAAW,CAAC,SAAS;QAChC,iBAAiB,EAAE,WAAW,CAAC,MAAM;QACrC,QAAQ,EAAE,WAAW,CAAC,QAAQ;QAC9B,SAAS;QACT,OAAO;QACP,SAAS;QACT,SAAS;QACT,aAAa,EAAE,MAAM,CAAC,GAAG,CAAC,aAAa;QACvC,WAAW,EAAE,MAAM,CAAC,GAAG,CAAC,WAAW;KACpC,CAAC;AACJ,CAAC;AAED,MAAM,UAAU,mBAAmB,CACjC,WAAiC;IAEjC,OAAO;QACL,MAAM,EAAE,iBAAiB;QACzB,QAAQ,EAAE,qBAAqB;QAC/B,MAAM,EAAE,IAAI;QACZ,QAAQ,EAAE,MAAM;QAChB,QAAQ,EAAE,OAAO;QACjB,SAAS,EAAE,mBAAmB,WAAW,CAAC,SAAS,CAAC,OAAO,CAAC,CAAC,CAAC,SAAS,CAAC,WAAW,CAAC,OAAO,GAAG,GAAG,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,eAAe,WAAW,CAAC,SAAS,6BAA6B,WAAW,CAAC,SAAS,CAAC,OAAO,CAAC,CAAC,CAAC,OAAO;QACrN,OAAO,EAAE;YACP,SAAS,EAAE,WAAW,CAAC,SAAS;YAChC,iBAAiB,EAAE,WAAW,CAAC,iBAAiB;YAChD,QAAQ,EAAE,WAAW,CAAC,QAAQ;YAC9B,SAAS,EAAE,WAAW,CAAC,SAAS;YAChC,OAAO,EAAE,WAAW,CAAC,OAAO;YAC5B,SAAS,EAAE,WAAW,CAAC,SAAS;YAChC,SAAS,EAAE,WAAW,CAAC,SAAS;YAChC,aAAa,EAAE,WAAW,CAAC,aAAa;YACxC,WAAW,EAAE,WAAW,CAAC,WAAW;SACrC;KACF,CAAC;AACJ,CAAC"}

packages/rules-engine/src/orchestrator.d.ts

@@ -0,0 +1,13 @@
+/**
+ * Rules engine orchestrator - coordinates all regulatory rule evaluations
+ */
+import type { Transaction, BrazilRegulatoryResult } from '@brazil-swift-ops/types';
+/**
+ * Evaluate all Brazil regulatory rules for a transaction
+ */
+export declare function evaluateTransaction(transaction: Transaction): BrazilRegulatoryResult;
+/**
+ * Evaluate a batch of transactions
+ */
+export declare function evaluateBatch(transactions: Transaction[]): BrazilRegulatoryResult[];
+//# sourceMappingURL=orchestrator.d.ts.map

packages/rules-engine/src/orchestrator.d.ts.map

@@ -0,0 +1 @@
+{"version":3,"file":"orchestrator.d.ts","sourceRoot":"","sources":["orchestrator.ts"],"names":[],"mappings":"AAAA;;GAEG;AAEH,OAAO,KAAK,EACV,WAAW,EACX,sBAAsB,EAGvB,MAAM,yBAAyB,CAAC;AAmBjC;;GAEG;AACH,wBAAgB,mBAAmB,CACjC,WAAW,EAAE,WAAW,GACvB,sBAAsB,CAoDxB;AAED;;GAEG;AACH,wBAAgB,aAAa,CAC3B,YAAY,EAAE,WAAW,EAAE,GAC1B,sBAAsB,EAAE,CAE1B"}

packages/rules-engine/src/orchestrator.js

@@ -0,0 +1,68 @@
+/**
+ * Rules engine orchestrator - coordinates all regulatory rule evaluations
+ */
+import { getConfig } from './config';
+import { evaluateThreshold, createThresholdRuleResult } from './threshold';
+import { validateDocumentation, createDocumentationRuleResult, } from './documentation';
+import { validateFXContract, createFXContractRuleResult, getContractStore, } from './fx-contract';
+import { calculateIOF, createIOFRuleResult } from './iof';
+import { performAMLCheck, createAMLRuleResult, } from './aml';
+/**
+ * Evaluate all Brazil regulatory rules for a transaction
+ */
+export function evaluateTransaction(transaction) {
+    const config = getConfig();
+    const timestamp = new Date();
+    // Run all rule checks
+    const thresholdCheck = evaluateThreshold(transaction);
+    const documentationCheck = validateDocumentation(transaction);
+    const fxContract = getContractStore().get(transaction.fxContractId || '');
+    const fxContractCheck = validateFXContract(transaction, fxContract);
+    const iofCalculation = calculateIOF(transaction);
+    const amlCheck = performAMLCheck(transaction);
+    // Create rule results
+    const rules = [
+        createThresholdRuleResult(thresholdCheck),
+        createDocumentationRuleResult(documentationCheck),
+        createFXContractRuleResult(fxContractCheck),
+        createIOFRuleResult(iofCalculation),
+        createAMLRuleResult(amlCheck),
+    ];
+    // Determine overall decision and severity
+    const criticalRules = rules.filter((r) => r.severity === 'Critical' && !r.passed);
+    const warningRules = rules.filter((r) => r.severity === 'Warning' && !r.passed);
+    let overallDecision;
+    let overallSeverity;
+    if (criticalRules.length > 0) {
+        overallDecision = 'Hold';
+        overallSeverity = 'Critical';
+    }
+    else if (warningRules.length > 0) {
+        overallDecision = 'Escalate';
+        overallSeverity = 'Warning';
+    }
+    else {
+        overallDecision = 'Allow';
+        overallSeverity = 'Info';
+    }
+    return {
+        transactionId: transaction.id,
+        timestamp,
+        ruleSetVersion: config.ruleSetVersion,
+        overallDecision,
+        overallSeverity,
+        rules,
+        thresholdCheck,
+        documentationCheck,
+        fxContractCheck,
+        iofCalculation,
+        amlCheck,
+    };
+}
+/**
+ * Evaluate a batch of transactions
+ */
+export function evaluateBatch(transactions) {
+    return transactions.map((txn) => evaluateTransaction(txn));
+}
+//# sourceMappingURL=orchestrator.js.map

packages/rules-engine/src/orchestrator.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"orchestrator.js","sourceRoot":"","sources":["orchestrator.ts"],"names":[],"mappings":"AAAA;;GAEG;AAQH,OAAO,EAAE,SAAS,EAAE,MAAM,UAAU,CAAC;AACrC,OAAO,EAAE,iBAAiB,EAAE,yBAAyB,EAAE,MAAM,aAAa,CAAC;AAC3E,OAAO,EACL,qBAAqB,EACrB,6BAA6B,GAC9B,MAAM,iBAAiB,CAAC;AACzB,OAAO,EACL,kBAAkB,EAClB,0BAA0B,EAC1B,gBAAgB,GACjB,MAAM,eAAe,CAAC;AACvB,OAAO,EAAE,YAAY,EAAE,mBAAmB,EAAE,MAAM,OAAO,CAAC;AAC1D,OAAO,EACL,eAAe,EACf,mBAAmB,GAEpB,MAAM,OAAO,CAAC;AAEf;;GAEG;AACH,MAAM,UAAU,mBAAmB,CACjC,WAAwB;IAExB,MAAM,MAAM,GAAG,SAAS,EAAE,CAAC;IAC3B,MAAM,SAAS,GAAG,IAAI,IAAI,EAAE,CAAC;IAE7B,sBAAsB;IACtB,MAAM,cAAc,GAAG,iBAAiB,CAAC,WAAW,CAAC,CAAC;IACtD,MAAM,kBAAkB,GAAG,qBAAqB,CAAC,WAAW,CAAC,CAAC;IAC9D,MAAM,UAAU,GAAG,gBAAgB,EAAE,CAAC,GAAG,CAAC,WAAW,CAAC,YAAY,IAAI,EAAE,CAAC,CAAC;IAC1E,MAAM,eAAe,GAAG,kBAAkB,CAAC,WAAW,EAAE,UAAU,CAAC,CAAC;IACpE,MAAM,cAAc,GAAG,YAAY,CAAC,WAAW,CAAC,CAAC;IACjD,MAAM,QAAQ,GAAG,eAAe,CAAC,WAAW,CAAC,CAAC;IAE9C,sBAAsB;IACtB,MAAM,KAAK,GAAG;QACZ,yBAAyB,CAAC,cAAc,CAAC;QACzC,6BAA6B,CAAC,kBAAkB,CAAC;QACjD,0BAA0B,CAAC,eAAe,CAAC;QAC3C,mBAAmB,CAAC,cAAc,CAAC;QACnC,mBAAmB,CAAC,QAAQ,CAAC;KAC9B,CAAC;IAEF,0CAA0C;IAC1C,MAAM,aAAa,GAAG,KAAK,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,QAAQ,KAAK,UAAU,IAAI,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC;IAClF,MAAM,YAAY,GAAG,KAAK,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,QAAQ,KAAK,SAAS,IAAI,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC;IAEhF,IAAI,eAA6B,CAAC;IAClC,IAAI,eAA6B,CAAC;IAElC,IAAI,aAAa,CAAC,MAAM,GAAG,CAAC,EAAE,CAAC;QAC7B,eAAe,GAAG,MAAM,CAAC;QACzB,eAAe,GAAG,UAAU,CAAC;IAC/B,CAAC;SAAM,IAAI,YAAY,CAAC,MAAM,GAAG,CAAC,EAAE,CAAC;QACnC,eAAe,GAAG,UAAU,CAAC;QAC7B,eAAe,GAAG,SAAS,CAAC;IAC9B,CAAC;SAAM,CAAC;QACN,eAAe,GAAG,OAAO,CAAC;QAC1B,eAAe,GAAG,MAAM,CAAC;IAC3B,CAAC;IAED,OAAO;QACL,aAAa,EAAE,WAAW,CAAC,EAAE;QAC7B,SAAS;QACT,cAAc,EAAE,MAAM,CAAC,cAAc;QACrC,eAAe;QACf,eAAe;QACf,KAAK;QACL,cAAc;QACd,kBAAkB;QAClB,eAAe;QACf,cAAc;QACd,QAAQ;KACT,CAAC;AACJ,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,aAAa,CAC3B,YAA2B;IAE3B,OAAO,YAAY,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAC,CAAC;AAC7D,CAAC"}