Wallet Transfers

const WebSocket = require("ws");

class WalletTransferMonitor {
  constructor(apiKey) {
    this.apiKey = apiKey;
    this.ws = null;
    this.transferCount = 0;
    this.walletGraph = {};
    this.volumeByToken = {};
  }

  connect() {
    this.ws = new WebSocket(
      `wss://api.nolimitnodes.com/socket?apikey=${this.apiKey}`
    );
    this.setupHandlers();
  }

  setupHandlers() {
    this.ws.on("open", () => {
      console.log("Connected to Wallet Transfers stream");
      this.subscribe();
    });

    this.ws.on("message", (data) => {
      const message = JSON.parse(data);
      if (message.method === "walletTransfersSubscribe") {
        this.processTransfer(message.result);
      } else {
        console.log("Info:", JSON.stringify(message));
      }
    });

    this.ws.on("error", (error) => {
      console.error("WebSocket error:", error.message);
    });

    this.ws.on("close", () => {
      console.log("Connection closed. Reconnecting in 5s...");
      setTimeout(() => this.connect(), 5000);
    });
  }

  subscribe(filters = {}) {
    this.ws.send(
      JSON.stringify({
        method: "dataSubscribe",
        params: {
          referenceId: "WALLET_TRANSFERS",
          streams: [
            {
              stream: "walletTransfersSubscribe",
              params: filters,
            },
          ],
        },
        id: 1,
      })
    );
  }

  processTransfer(tx) {
    this.transferCount++;
    const amount = tx.amount / Math.pow(10, tx.decimals);

    // Track volume by token
    if (!this.volumeByToken[tx.token]) {
      this.volumeByToken[tx.token] = { count: 0, totalAmount: 0 };
    }
    this.volumeByToken[tx.token].count++;
    this.volumeByToken[tx.token].totalAmount += amount;

    // Build wallet connection graph
    this.trackWalletConnection(tx.from, tx.to, tx.token, amount);

    console.log(`\n--- Transfer #${this.transferCount} ---`);
    console.log(`${tx.from.slice(0, 8)}... -> ${tx.to.slice(0, 8)}...`);
    console.log(`Amount: ${amount} ${tx.token === "Solana" ? "SOL" : tx.token.slice(0, 8) + "..."}`);
    console.log(`Block: ${tx.block_num} | Time: ${tx.block_time}`);
    console.log(`Tx: ${tx.transaction_signature.slice(0, 16)}...`);
  }

  trackWalletConnection(from, to, token, amount) {
    const key = `${from.slice(0, 8)}->${to.slice(0, 8)}`;
    if (!this.walletGraph[key]) {
      this.walletGraph[key] = { count: 0, tokens: {}, totalAmount: 0 };
    }
    this.walletGraph[key].count++;
    this.walletGraph[key].totalAmount += amount;

    if (!this.walletGraph[key].tokens[token]) {
      this.walletGraph[key].tokens[token] = 0;
    }
    this.walletGraph[key].tokens[token] += amount;
  }

  analyzeRelatedWallets(walletAddress) {
    const connections = Object.entries(this.walletGraph)
      .filter(([key]) => key.includes(walletAddress.slice(0, 8)))
      .sort((a, b) => b[1].count - a[1].count);

    console.log(`\nWallet connections for ${walletAddress.slice(0, 8)}...:`);
    connections.forEach(([key, data]) => {
      console.log(`  ${key}: ${data.count} transfers, total: ${data.totalAmount.toFixed(4)}`);
    });
    return connections;
  }
}

// Usage
const monitor = new WalletTransferMonitor("YOUR_API_KEY");
monitor.connect();