Liquidity Pools

const WebSocket = require("ws");

class LiquidityPoolMonitor {
  constructor(apiKey) {
    this.apiKey = apiKey;
    this.ws = null;
    this.pools = {};
    this.ammStats = {};
  }

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

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

    this.ws.on("message", (data) => {
      const message = JSON.parse(data);
      if (message.method === "liquidityPoolsSubscribe") {
        this.processPoolEvent(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: "LIQUIDITY_POOLS",
          streams: [
            {
              stream: "liquidityPoolsSubscribe",
              params: filters,
            },
          ],
        },
        id: 1,
      })
    );
  }

  processPoolEvent(pool) {
    // Track pools by AMM
    if (!this.ammStats[pool.amm]) {
      this.ammStats[pool.amm] = { count: 0, pools: [] };
    }
    this.ammStats[pool.amm].count++;
    this.ammStats[pool.amm].pools.push(pool.pool);

    // Store pool data
    this.pools[pool.pool] = {
      amm: pool.amm,
      token1: pool.token1,
      token2: pool.token2,
      creator: pool.creator,
      block: pool.block_num,
      time: pool.block_time,
      type: pool.type,
    };

    const timestamp = new Date(pool.block_time * 1000).toISOString();
    console.log(`\n[${timestamp}] New Pool [${pool.amm}]`);
    console.log(`  Pool: ${pool.pool}`);
    console.log(`  Token1: ${pool.token1.slice(0, 12)}...`);
    console.log(`  Token2: ${pool.token2.slice(0, 12)}...`);
    console.log(`  Creator: ${pool.creator.slice(0, 12)}...`);
    console.log(`  Block: ${pool.block_num} | Program: ${pool.program_id}`);
    console.log(`  Type: ${pool.type}`);

    // Show AMM stats
    console.log(`  [${pool.amm} total pools: ${this.ammStats[pool.amm].count}]`);
  }
}

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