WebSocket Integration

Real-time WebSocket feed for token price updates, trade activities, and more.

🧭 Supported Methods

Currently, CoinVera WebSocket supports the following subscription methods:

• subscribePrice: Subscribe to real-time price updates for tokens

• subscribeTrade: Subscribe to live trade activity data

• subscribeNewpair: Subscribe to stream new tokens & pools live

---

🌐 WebSocket Endpoint

wss://api.coinvera.io

---

🛠️ Required Parameters

Each subscription request must include the following parameters:

Parameter	Type	Description
apiKey	string	Your CoinVera API key
method	string	One of: subscribePrice, subscribeTrade
tokens	array	One or more token addresses or wallet addresses (based on your plan limits)

---

💻 Code Example

const WebSocket = require('ws');

const apiKey = ''; // Your CoinVera API Key
if (!apiKey) {
  console.error('Missing API key');
  process.exit(1);
}

// WebSocket endpoint
const WS_URL = 'wss://api.coinvera.io'; // Normal usage

// Create WebSocket client
const ws = new WebSocket(WS_URL);

let pingInterval;

// Subscribe to trade updates once the connection is open
ws.on('open', () => {
  console.log('WebSocket connection opened. Subscribing to trades...');

  const payload = {
    apiKey,
    method: 'subscribeTrade',
    tokens: [''], // Comment or remove for methods: subscribeNewpair
  };

  ws.send(JSON.stringify(payload));
  console.log('Subscribe request sent:', payload);

  // Start sending PING to keep connection alive every 10 seconds
  pingInterval = setInterval(() => {
    if (ws.readyState === WebSocket.OPEN) {
      ws.ping();
    }
  }, 10000);
});

// Handle incoming messages
ws.on('message', (data) => {
  try {
    const message = JSON.parse(data);
    console.log('Received:', message);
  } catch (err) {
    console.error('Error parsing message:', err);
  }
});

// Handle errors
ws.on('error', (err) => {
  console.error('WebSocket error:', err);
});

// Handle connection close
ws.on('close', (code, reason) => {
  console.log(`WebSocket closed: ${code} - ${reason}`);
  if (pingInterval) clearInterval(pingInterval);
});

---

📤 Sample Response: subscribePrice

{
  ca: '3VCkk4EVWQjCP8usuVK9ArfSmViFAcNcTMPivFJPpump',
  dex: 'PumpFun',
  priceInSol: '0.000000028020233436191693',
  priceInUsd: '0.000004195937910602868'
}

---

📤 Sample Response: subscribeTrade

{
  signature: '5MZFwRDa6Q9ErRetB8RvaUjepNM9RodDG1ZSfMLunSq36NcB38FhR5mBsQFvmTWjzkG8xztMnKmFXVy3eQS6fyv3',
  signer: '58FqLVkDz8Zkg5fRAinwrAnu6a2dK1TJkDg8NG6pRimE',
  dexs: [ 'Pump.fun' ],
  ca: '3VCkk4EVWQjCP8usuVK9ArfSmViFAcNcTMPivFJPpump',
  trade: 'buy',
  priceInSol: 2.801561469095688e-8,
  solAmount: -0.004950495,
  tokenAmount: 176704.85029899998,
  TokenDelta: [
    {
      mint: '3VCkk4EVWQjCP8usuVK9ArfSmViFAcNcTMPivFJPpump',
      amount: 176704.85029899998
    }
  ]
}

📤 Sample Response: subscribeNewpair

{
  dex: 'Meteora DlmmV2',
  signature: '5ZX2iDtPMvsGGt6uLHF2ZivcqoyPgGxHLqe1tkRADSwGHc6L5Df6vUNuetP137V6shqRY6qTrNQdfmDWsMqycjEp',
  creator: '7Loze72RNfp2t2PUtw43ajtCNeyvzeVWLpmWm8v8Ss5m',
  pool: 'kp8a7jXmCG3QNx3WssGpJGpGpaVCkFimj7ocMsB1H3Z',
  token0: 'y7DdeCMbukNQShsGbybQmsxgVANi4nhCy7m4WZSLuCb',
  token1: 'So11111111111111111111111111111111111111112'
}

---

🔁 Connection Keep-Alive

To maintain your WebSocket session, periodically send ping messages to avoid disconnection.