82 lines
3.5 KiB
JavaScript
82 lines
3.5 KiB
JavaScript
|
|
const { Client } = require('pg');
|
|
const { Connection, PublicKey } = require('@solana/web3.js');
|
|
const { CryptoEngine } = require('./lib/crypto-engine');
|
|
|
|
async function simulateSync() {
|
|
const client = new Client({ connectionString: process.env.DATABASE_URL });
|
|
await client.connect();
|
|
|
|
const res = await client.query(`
|
|
SELECT * FROM transactions
|
|
WHERE source_ref_id IN ('TEST_ORDER_999', 'TEST_ORDER_1000')
|
|
`);
|
|
|
|
console.log(`Simulating sync for ${res.rows.length} transactions...`);
|
|
|
|
for (const tx of res.rows) {
|
|
console.log(`\n>> Processing TX: ${tx.id} (${tx.source_ref_id}) | Current Status: ${tx.status}`);
|
|
const metadata = tx.metadata || {};
|
|
const wallets = metadata.wallets || {};
|
|
|
|
console.log("Wallets in metadata:", Object.keys(wallets));
|
|
|
|
const scanningMatrix = [
|
|
{ network: 'SOLANA', tokens: ['SOL', 'USDT', 'USDC'] },
|
|
{ network: 'POLYGON', tokens: ['MATIC', 'USDT', 'USDC'] },
|
|
{ network: 'TRON', tokens: ['TRX', 'USDT', 'USDC'] }
|
|
];
|
|
|
|
for (const scan of scanningMatrix) {
|
|
const networkId = scan.network;
|
|
const walletConfig = wallets[networkId] || (networkId === 'POLYGON' ? wallets['EVM'] : null);
|
|
|
|
if (!walletConfig) {
|
|
console.log(`[${networkId}] Skiped: No wallet config found.`);
|
|
continue;
|
|
}
|
|
|
|
console.log(`[${networkId}] Found wallet config. Address: ${typeof walletConfig === 'string' ? walletConfig : walletConfig.address}`);
|
|
|
|
const cryptoEngine = new CryptoEngine(networkId);
|
|
|
|
for (const tokenSymbol of scan.tokens) {
|
|
console.log(` [${networkId}/${tokenSymbol}] Verifying...`);
|
|
|
|
let expectedCryptoAmount = tx.amount.toString();
|
|
try {
|
|
const coinIdMap = {
|
|
'SOL': 'solana', 'MATIC': 'matic-network', 'POLYGON': 'matic-network',
|
|
'USDC': 'usd-coin', 'USDT': 'tether', 'TRX': 'tron', 'BTC': 'bitcoin'
|
|
};
|
|
const coinId = coinIdMap[tokenSymbol] || 'solana';
|
|
const priceUrl = `https://api.coingecko.com/api/v3/simple/price?ids=${coinId}&vs_currencies=usd,try`;
|
|
const priceRes = await fetch(priceUrl);
|
|
const priceData = await priceRes.json();
|
|
const currencyKey = (tx.currency || 'TRY').toLowerCase();
|
|
const priceInCurrency = priceData[coinId][currencyKey] || priceData[coinId]['usd'];
|
|
|
|
if (priceInCurrency) {
|
|
const rawExpected = parseFloat(tx.amount) / priceInCurrency;
|
|
expectedCryptoAmount = (rawExpected * 0.98).toFixed(6);
|
|
console.log(` Expected Min: ${expectedCryptoAmount} ${tokenSymbol} (Price: ${priceInCurrency})`);
|
|
}
|
|
} catch (e) { console.log(" Price fetch failed."); }
|
|
|
|
const depositAddress = typeof walletConfig === 'string' ? walletConfig : walletConfig.address;
|
|
const verification = await cryptoEngine.verifyPayment(depositAddress, expectedCryptoAmount, tokenSymbol);
|
|
|
|
if (verification.success) {
|
|
console.log(` ✅ PAYMENT DETECTED!`);
|
|
} else {
|
|
console.log(` ❌ No payment found.`);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
await client.end();
|
|
}
|
|
|
|
simulateSync();
|