Receiving Payments

// Get both on-chain and off-chain addresses
const addresses = await wallet.getAddress()

// The off-chain Ark address for instant payments
console.log('Ark Address:', addresses.offchain)

// The on-chain Bitcoin address
console.log('Bitcoin Address:', addresses.onchain)

try {
  // Create an abort controller to manage the subscription lifecycle
  const abortController = new AbortController();
  
  // Subscribe to updates for your address
  const addresses = await wallet.getAddress();
  const subscription = arkProvider.subscribeForAddress(
    addresses.offchain,
    abortController.signal
  );
  
  // Process updates as they arrive
  for await (const update of subscription) {
    const vtxos = [...update.newVtxos, ...update.spentVtxos];
    if (vtxos.length === 0) {
      continue;
    }
    
    // Process the received VTXOs
    console.log('New VTXOs received:', update.newVtxos.length);
    console.log('VTXOs spent:', update.spentVtxos.length);
    
    // Process new payments
    await processNewVtxos(update.newVtxos);
  }
} catch (error) {
  console.error("Error processing address updates:", error);
}

// Example function to process new VTXOs
async function processNewVtxos(newVtxos) {
  // Update your application state
  for (const vtxo of newVtxos) {
    console.log(`Received payment of ${vtxo.amount} sats`);
    
    // You might want to store the VTXO in your database
    await storeVtxoInDatabase(vtxo);
    
    // Notify the user
    showNotification(`Received ${vtxo.amount} sats!`);
    
    // Update the UI
    await refreshBalanceDisplay();
  }
}

// Clean up the subscription when done
abortController.abort();