Feat/websocket monitoring + coingecko find routes

scripts/test-auto-subscription.sh

@@ -0,0 +1,64 @@
+#!/bin/bash
+
+# Test auto-subscription to Solana wallets on Gateway startup
+# This script verifies that wallets in conf/wallets/solana are automatically monitored
+
+echo "╔════════════════════════════════════════════════════════════╗"
+echo "║  Testing Auto-Subscription to Solana Wallets              ║"
+echo "╚════════════════════════════════════════════════════════════╝"
+echo ""
+
+# Check if conf/wallets/solana exists and has wallets
+if [ ! -d "conf/wallets/solana" ]; then
+    echo "❌ Directory conf/wallets/solana does not exist"
+    echo "   No wallets to auto-subscribe"
+    exit 1
+fi
+
+WALLET_COUNT=$(find conf/wallets/solana -name "*.json" -not -name "hardware-wallets.json" 2>/dev/null | wc -l | tr -d ' ')
+
+if [ "$WALLET_COUNT" -eq 0 ]; then
+    echo "⚠️  No Solana wallets found in conf/wallets/solana"
+    echo "   Auto-subscription will be skipped on startup"
+    echo ""
+    echo "To add a wallet, use:"
+    echo "  curl -X POST http://localhost:15888/wallet/add \\"
+    echo "    -H \"Content-Type: application/json\" \\"
+    echo "    -d '{\"chain\":\"solana\",\"privateKey\":\"YOUR_PRIVATE_KEY\"}'"
+    exit 0
+fi
+
+echo "✅ Found $WALLET_COUNT Solana wallet(s):"
+echo ""
+
+# List wallet addresses
+for wallet_file in conf/wallets/solana/*.json; do
+    if [[ "$wallet_file" != *"hardware-wallets.json" ]]; then
+        wallet_address=$(basename "$wallet_file" .json)
+        echo "  📔 $wallet_address"
+    fi
+done
+
+echo ""
+echo "─────────────────────────────────────────────────────────────"
+echo ""
+echo "Starting Gateway with auto-subscription enabled..."
+echo ""
+echo "Expected log output:"
+echo "  1. ✅ Helius WebSocket monitor successfully initialized"
+echo "  2. Auto-subscribing to N Solana wallet(s)..."
+echo "  3. [ADDRESS...] Initial balance: X.XXXX SOL, Y token(s)"
+echo "  4. Subscribed to wallet balance updates for ADDRESS..."
+echo "  5. ✅ Auto-subscribed to N/N Solana wallet(s)"
+echo ""
+echo "When a transaction occurs on any wallet, you'll see:"
+echo "  [ADDRESS...] Balance update at slot XXXXXX:"
+echo "    SOL: X.XXXX, Tokens: Y"
+echo ""
+echo "─────────────────────────────────────────────────────────────"
+echo ""
+echo "Press Ctrl+C to stop Gateway when ready..."
+echo ""
+
+# Start Gateway in dev mode
+GATEWAY_PASSPHRASE=a START_SERVER=true DEV=true pnpm start

scripts/test-sse-stream.sh

@@ -0,0 +1,49 @@
+#!/bin/bash
+
+# Test Server-Sent Events streaming for WebSocket monitoring
+# This script demonstrates how to consume real-time pool updates
+
+echo "╔════════════════════════════════════════════════════════════╗"
+echo "║  Testing Phase 3: Pool Monitoring via SSE                 ║"
+echo "╚════════════════════════════════════════════════════════════╝"
+echo ""
+
+# Check if server is running
+if ! curl -s http://localhost:15888/chains 2>&1 | grep -q "solana"; then
+    echo "❌ Gateway server is not running on port 15888"
+    echo "   Start it with: GATEWAY_PASSPHRASE=a START_SERVER=true DEV=true pnpm start"
+    exit 1
+fi
+
+echo "✅ Gateway server detected"
+echo ""
+
+# Pool address - SOL-USDC Meteora DLMM pool
+POOL_ADDRESS="5E4sYT75xoHs41wWv7cUKzbe8kUE6wZVB3QjhKBp3jAH"
+
+echo "Connecting to pool monitoring stream..."
+echo "Pool: $POOL_ADDRESS"
+echo ""
+echo "Stream will show real-time pool updates as they occur."
+echo "Press Ctrl+C to stop."
+echo ""
+echo "─────────────────────────────────────────────────────────────"
+echo ""
+
+# Stream pool updates
+curl -N "http://localhost:15888/connectors/meteora/clmm/pool-info-stream?network=mainnet-beta&poolAddress=$POOL_ADDRESS" 2>/dev/null | while IFS= read -r line; do
+    # Skip empty lines and keepalive comments
+    if [[ "$line" =~ ^data:\ (.*)$ ]]; then
+        data="${BASH_REMATCH[1]}"
+
+        # Pretty print JSON with color if jq is available
+        if command -v jq &> /dev/null; then
+            echo "$data" | jq -C '.'
+        else
+            echo "$data" | python3 -m json.tool
+        fi
+
+        echo "─────────────────────────────────────────────────────────────"
+        echo ""
+    fi
+done

scripts/test-websocket-monitoring.ts

@@ -0,0 +1,162 @@
+/**
+ * Test script for WebSocket monitoring features
+ * Tests Phase 2 (wallet balance monitoring) and Phase 3 (pool monitoring)
+ *
+ * Usage:
+ *   GATEWAY_PASSPHRASE=a START_SERVER=true DEV=true node dist/scripts/test-websocket-monitoring.js
+ */
+
+import { Solana } from '../chains/solana/solana';
+import { Meteora } from '../connectors/meteora/meteora';
+import { logger } from '../services/logger';
+
+async function testWalletBalanceMonitoring() {
+  console.log('\n=== Testing Phase 2: Wallet Balance Monitoring ===\n');
+
+  try {
+    const solana = await Solana.getInstance('mainnet-beta');
+    const heliusService = solana.getHeliusService();
+
+    if (!heliusService?.isWebSocketConnected()) {
+      console.log('❌ WebSocket not available');
+      console.log('   Enable useWebSocketRPC in conf/rpc/helius.yml and configure Helius API key');
+      return;
+    }
+
+    // Example wallet - replace with your wallet address
+    const walletAddress = 'vines1vzrYbzLMRdu58ou5XTby4qAqVRLmqo36NKPTg'; // Random example wallet
+
+    console.log(`Subscribing to wallet: ${walletAddress}`);
+    console.log('Waiting for balance updates...\n');
+
+    const subscriptionId = await solana.subscribeToWalletBalance(walletAddress, (balances) => {
+      console.log(`[Wallet Update] Slot: ${balances.slot}`);
+      console.log(`  SOL Balance: ${balances.sol.toFixed(4)} SOL`);
+      console.log(`  Token Count: ${balances.tokens.length}`);
+
+      if (balances.tokens.length > 0) {
+        console.log('  Tokens:');
+        balances.tokens.slice(0, 5).forEach(token => {
+          console.log(`    - ${token.symbol}: ${token.balance.toFixed(4)} (${token.address.slice(0, 8)}...)`);
+        });
+        if (balances.tokens.length > 5) {
+          console.log(`    ... and ${balances.tokens.length - 5} more tokens`);
+        }
+      }
+      console.log('');
+    });
+
+    console.log(`✅ Subscribed (ID: ${subscriptionId})`);
+    console.log('   Balance updates will be logged in real-time');
+    console.log('   Press Ctrl+C to stop\n');
+
+    // Keep running for 2 minutes
+    await new Promise(resolve => setTimeout(resolve, 120000));
+
+    // Cleanup
+    const helius = solana.getHeliusService();
+    if (helius) {
+      await helius.unsubscribeFromAccount(subscriptionId);
+      console.log('Unsubscribed from wallet monitoring');
+    }
+
+  } catch (error: any) {
+    console.error('Error testing wallet monitoring:', error.message);
+  }
+}
+
+async function testPoolMonitoring() {
+  console.log('\n=== Testing Phase 3: Pool Monitoring ===\n');
+
+  try {
+    const meteora = await Meteora.getInstance('mainnet-beta');
+    const solana = await Solana.getInstance('mainnet-beta');
+    const heliusService = solana.getHeliusService();
+
+    if (!heliusService?.isWebSocketConnected()) {
+      console.log('❌ WebSocket not available');
+      console.log('   Enable useWebSocketRPC in conf/rpc/helius.yml and configure Helius API key');
+      return;
+    }
+
+    // Example SOL-USDC pool - replace with any Meteora pool address
+    const poolAddress = '5E4sYT75xoHs41wWv7cUKzbe8kUE6wZVB3QjhKBp3jAH'; // SOL-USDC pool
+
+    console.log(`Subscribing to pool: ${poolAddress}`);
+    console.log('Waiting for pool updates...\n');
+
+    const subscriptionId = await meteora.subscribeToPoolUpdates(poolAddress, (poolInfo) => {
+      console.log(`[Pool Update] Slot: ${poolInfo.slot}`);
+      console.log(`  Active Bin ID: ${poolInfo.activeBinId}`);
+      console.log(`  Price: ${poolInfo.price.toFixed(6)}`);
+      console.log(`  Base Reserve: ${poolInfo.baseTokenAmount.toFixed(4)}`);
+      console.log(`  Quote Reserve: ${poolInfo.quoteTokenAmount.toFixed(4)}`);
+      console.log(`  Fee: ${poolInfo.feePct.toFixed(4)}%`);
+      console.log(`  Bin Step: ${poolInfo.binStep}`);
+      console.log('');
+    });
+
+    console.log(`✅ Subscribed (ID: ${subscriptionId})`);
+    console.log('   Pool updates will be logged in real-time');
+    console.log('   Press Ctrl+C to stop\n');
+
+    // Keep running for 2 minutes
+    await new Promise(resolve => setTimeout(resolve, 120000));
+
+    // Cleanup
+    await meteora.unsubscribeFromPool(subscriptionId);
+    console.log('Unsubscribed from pool monitoring');
+
+  } catch (error: any) {
+    console.error('Error testing pool monitoring:', error.message);
+  }
+}
+
+async function testServerSentEvents() {
+  console.log('\n=== Testing Server-Sent Events (SSE) ===\n');
+  console.log('To test SSE streaming, use curl in another terminal:\n');
+  console.log('Example wallet balance streaming:');
+  console.log('  curl -X POST http://localhost:15888/chains/solana/subscribe-balances \\');
+  console.log('    -H "Content-Type: application/json" \\');
+  console.log('    -d \'{"network": "mainnet-beta", "address": "YOUR_WALLET_ADDRESS"}\'\n');
+
+  console.log('Example pool info streaming:');
+  console.log('  curl "http://localhost:15888/connectors/meteora/clmm/pool-info-stream?network=mainnet-beta&poolAddress=5E4sYT75xoHs41wWv7cUKzbe8kUE6wZVB3QjhKBp3jAH"\n');
+
+  console.log('The stream will continuously output JSON events as they occur.\n');
+}
+
+async function main() {
+  console.log('╔════════════════════════════════════════════════════════════╗');
+  console.log('║  WebSocket Monitoring Test Suite                          ║');
+  console.log('║  Phase 2: Wallet Balance Monitoring                       ║');
+  console.log('║  Phase 3: Pool State Monitoring                           ║');
+  console.log('╚════════════════════════════════════════════════════════════╝');
+
+  const args = process.argv.slice(2);
+  const testType = args[0] || 'all';
+
+  if (testType === 'wallet' || testType === 'all') {
+    await testWalletBalanceMonitoring();
+  }
+
+  if (testType === 'pool' || testType === 'all') {
+    await testPoolMonitoring();
+  }
+
+  if (testType === 'sse') {
+    testServerSentEvents();
+    // Keep running to allow SSE testing
+    console.log('Server running... Press Ctrl+C to stop');
+    await new Promise(() => {}); // Run forever
+  }
+
+  console.log('\n✅ Tests complete');
+  process.exit(0);
+}
+
+// Run tests
+main().catch((error) => {
+  console.error('Fatal error:', error);
+  process.exit(1);
+});