Tracking

import MoneiSDK from 'monei-sdk';

const monei = new MoneiSDK({
  apiKey: process.env.MONEI_API_KEY,
});

// Track order by reference
const order = await monei.offrampLedger.trackOrder('OFFRAMP-ABC123XYZ');

console.log('Order Status:');
console.log('=============');
console.log('Reference:', order.reference);
console.log('Status:', order.status);
console.log('Amount:', order.amount, order.token);
console.log('Fiat Amount:', order.fiatAmount, order.fiatCurrency);
console.log('Exchange Rate:', order.exchangeRate);

console.log('\nDeposit Details:');
console.log('Address:', order.onChain.depositAddress);
console.log('Network:', order.onChain.network);
console.log('Expected:', order.onChain.expectedAmount, order.token);
console.log('Received:', order.onChain.receivedAmount || 'Pending');

console.log('\nBank Details:');
console.log('Bank:', order.bankDetails.bankName);
console.log('Account:', order.bankDetails.accountNumber);
console.log('Account Name:', order.bankDetails.accountName);

console.log('\nTimestamps:');
console.log('Created:', new Date(order.createdAt).toLocaleString());
console.log('Expires:', new Date(order.expiresAt).toLocaleString());
if (order.completedAt) {
  console.log('Completed:', new Date(order.completedAt).toLocaleString());
}

// Poll for status updates
async function monitorOrder(reference) {
  console.log('Monitoring order:', reference);
  console.log('================\n');
  
  let lastStatus = null;
  let attempts = 0;
  const maxAttempts = 60; // 30 minutes (every 30s)
  
  while (attempts < maxAttempts) {
    try {
      const order = await monei.offrampLedger.trackOrder(reference);
      
      // Check if status changed
      if (order.status !== lastStatus) {
        lastStatus = order.status;
        const timestamp = new Date().toLocaleTimeString();
        
        console.log(`[${timestamp}] Status: ${order.status}`);
        
        // Display relevant info based on status
        switch (order.status) {
          case 'awaiting_deposit':
            console.log(`  → Send ${order.onChain.expectedAmount} ${order.token} to:`);
            console.log(`  → ${order.onChain.depositAddress}`);
            break;
            
          case 'deposit_received':
            console.log(`  → Received ${order.onChain.receivedAmount} ${order.token}`);
            console.log(`  → TX: ${order.onChain.transactionHash}`);
            break;
            
          case 'processing':
            console.log(`  → Converting ${order.amount} ${order.token} to ${order.fiatCurrency}`);
            break;
            
          case 'fiat_sent':
            console.log(`  → ₦${order.fiatAmount.toLocaleString()} sent to ${order.bankDetails.bankName}`);
            break;
            
          case 'completed':
            console.log(`  → ✓ Transaction completed!`);
            console.log(`  → Check your bank account`);
            return order;
            
          case 'failed':
            console.log(`  → ✗ Transaction failed`);
            console.log(`  → Contact support with reference: ${reference}`);
            return order;
            
          case 'expired':
            console.log(`  → ✗ Order expired - no deposit received`);
            return order;
        }
        
        console.log('');
      }
      
      // Break if terminal state
      if (['completed', 'failed', 'expired', 'refunded'].includes(order.status)) {
        break;
      }
      
    } catch (error) {
      console.error('Error checking status:', error.message);
    }
    
    // Wait 30 seconds before next check
    await new Promise(resolve => setTimeout(resolve, 30000));
    attempts++;
  }
  
  console.log('Monitoring stopped');
}

// Start monitoring
await monitorOrder('OFFRAMP-ABC123XYZ');

// Get all offramp transactions
const transactions = await monei.offrampLedger.getTransactions({
  page: 1,
  limit: 20,
});

console.log(`Total Offramp Transactions: ${transactions.pagination.total}\n`);

transactions.transactions.forEach(tx => {
  console.log('Reference:', tx.reference);
  console.log('Status:', tx.status);
  console.log('Amount:', tx.amount, tx.currency);
  console.log('Fiat:', tx.metadata.fiatAmount, tx.metadata.fiatCurrency);
  console.log('Rate:', tx.metadata.exchangeRate);
  console.log('Bank:', tx.metadata.bankName);
  console.log('Date:', new Date(tx.createdAt).toLocaleString());
  console.log('---');
});

app.post('/webhooks/monei', (req, res) => {
  const event = req.body;
  
  // Verify webhook signature
  const signature = req.headers['x-monei-signature'];
  if (!verifySignature(event, signature)) {
    return res.status(401).send('Invalid signature');
  }
  
  // Handle offramp events
  switch (event.type) {
    case 'offramp.deposit_received':
      console.log('Crypto deposit confirmed');
      console.log('Reference:', event.data.reference);
      console.log('Amount:', event.data.amount);
      // Notify user: "Crypto received, converting to fiat"
      break;
      
    case 'offramp.processing':
      console.log('Converting to fiat');
      // Notify user: "Converting your crypto..."
      break;
      
    case 'offramp.fiat_sent':
      console.log('Fiat sent to bank');
      console.log('Fiat Amount:', event.data.fiatAmount);
      console.log('Bank:', event.data.bankName);
      // Notify user: "₦X sent to your account"
      break;
      
    case 'offramp.completed':
      console.log('Transaction completed!');
      // Notify user: "Transaction complete!"
      break;
      
    case 'offramp.failed':
      console.log('Transaction failed');
      console.log('Reason:', event.data.failureReason);
      // Notify user of failure
      break;
  }
  
  res.status(200).send('OK');
});