Track Solana liquidity additions and removals

GET /trades/{token}?events=all
GET /trades/{token}/{pool}?events=liquidity
GET /trades/{token}/by-wallet/{wallet}?events=all&enrich=identity
GET /trades/{token}/{pool}/{wallet}?events=liquidity&sortDirection=ASC

import { Client } from '@solana-tracker/data-api';

const client = new Client({ apiKey: 'YOUR_API_KEY' });
const token = '6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN';
const filters = {
  events: 'all',
  enrich: 'identity',
  limit: 100,
  sortDirection: 'DESC',
} as const;

const page = await client.getTokenTradeHistory(token, filters);
for (const event of page.trades) {
  if (event.type === 'add_liquidity' || event.type === 'remove_liquidity') {
    console.log(event.type, event.pool, event.tokens, event.identity);
  } else if (event.type === 'buy' || event.type === 'sell') {
    console.log(event.type, event.amount, event.volume);
  }
}

if (page.hasNextPage && page.nextCursor != null) {
  const nextPage = await client.getTokenTradeHistory(token, {
    ...filters,
    cursor: page.nextCursor,
  });
  console.log(nextPage.trades);
}

if (page.hasNextPage && page.nextCursor !== null) {
  url.searchParams.set("cursor", String(page.nextCursor));
  const nextResponse = await fetch(url, {
    headers: { "x-api-key": "YOUR_API_KEY" },
  });
  if (!nextResponse.ok) throw new Error(`Request failed: ${nextResponse.status}`);
  const nextPage = await nextResponse.json();
  console.log(nextPage.trades);
}

const token = "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN";
const room = `liquidity:${token}`;
const ws = new WebSocket("wss://datastream.solanatracker.io/YOUR_API_KEY");

ws.onopen = () => {
  ws.send(JSON.stringify({ type: "join", room }));
};

ws.onmessage = ({ data }) => {
  const message = JSON.parse(data);
  if (message.type === "ping") {
    ws.send(JSON.stringify({ type: "pong" }));
    return;
  }
  if (message.type === "error") {
    console.error("Datastream error", message);
    return;
  }
  if (message.type !== "message" || message.room !== room) return;

  for (const event of message.data) {
    const action = event.type === "add_liquidity" ? "Added" : "Removed";
    for (const token of event.tokens) {
      console.log(`${action} ${token.amount} of ${token.address}`, event.pool);
    }
  }
};

// To unsubscribe while keeping the connection open:
// ws.send(JSON.stringify({ type: "leave", room }));

import { Datastream } from '@solana-tracker/data-api';

const stream = new Datastream({
  wsUrl: 'wss://datastream.solanatracker.io/YOUR_API_KEY',
});
stream.on('error', console.error);
await stream.connect();

const sub = stream.subscribe.liquidity
  .token('6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN', { enriched: true })
  .on((event) => {
    console.log(event.type, event.pool, event.tokens, event.identity);
  });

// sub.unsubscribe();
// stream.disconnect();

{ "type": "join", "room": "liquidity:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN:enriched" }

{
  "tx": "TRANSACTION_SIGNATURE",
  "type": "add_liquidity",
  "program": "pumpfun-amm",
  "programId": "pAMMBay6oceH9fJKBRHGP5D4bD4sWpmSwMn52FMfXEA",
  "instruction": "deposit",
  "pool": "POOL_ADDRESS",
  "wallet": "LIQUIDITY_PROVIDER_ADDRESS",
  "time": 1789722000000,
  "slot": 370000000,
  "amountBasis": "transfer",
  "tokens": [
    {
      "address": "TOKEN_MINT",
      "amount": "123.000001",
      "amountRaw": "123000001",
      "decimals": 6
    },
    {
      "address": "So11111111111111111111111111111111111111112",
      "amount": "9.000000001",
      "amountRaw": "9000000001",
      "decimals": 9
    }
  ]
}