DexPaprika DEX API TypeScript SDK -- On‑chain Liquidity & Swap Data Client

import { DexPaprikaClient } from '@dexpaprika/sdk';

async function main() {
  // Initialize client
  const client = new DexPaprikaClient();
  
  // Get Ethereum network details
  const networks = await client.networks.list();
  const ethereum = networks.find(n => n.id === 'ethereum');
  console.log(`Found ${ethereum.name} with ${ethereum.dexes_count} DEXes`);
  
  // Get WETH token details
  const weth = await client.tokens.getDetails(
    'ethereum',
    '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2'
  );
  console.log(`${weth.name} price: $${weth.price_usd}`);
  
  // Find WETH/USDC pools
  const pools = await client.tokens.getPools(
    'ethereum',
    '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2', // WETH
    {
      limit: 5,
      sort: 'desc',
      orderBy: 'volume_usd',
      pairWith: '0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48' // USDC
    }
  );
  
  // Show top pools
  console.log('Top WETH/USDC pools:');
  pools.data.forEach(pool => {
    console.log(`${pool.dex.name}: $${pool.volume_usd_24h.toLocaleString()} 24h volume`);
  });
}

main().catch(console.error);

import { DexPaprikaClient, parseError } from '@dexpaprika/sdk';

// Basic error handling
try {
  const client = new DexPaprikaClient();
  const token = await client.tokens.getDetails('ethereum', '0xinvalidaddress');
} catch (error) {
  // Using the helper to extract the most relevant error message
  console.error('Error:', parseError(error));
  
  // Or handle specific error cases manually
  if (error.response?.status === 404) {
    console.error('Resource not found');
  } else if (error.response?.status === 429) {
    console.error('Rate limit exceeded');
  }
}

// The SDK automatically retries on these status codes: 
// 408 (Request Timeout), 429 (Too Many Requests), 
// 500, 502, 503, 504 (Server Errors)

// Custom retry configuration
const client = new DexPaprikaClient('https://api.dexpaprika.com', {}, {
  retry: {
    maxRetries: 3,
    delaySequenceMs: [200, 500, 1000],
    retryableStatuses: [429, 500, 503]
  }
});

import { DexPaprikaClient, Cache } from '@dexpaprika/sdk';

// The SDK includes built-in caching by default
// This example shows how to configure it

// Configure caching with custom settings
const client = new DexPaprikaClient('https://api.dexpaprika.com', {}, {
  cache: {
    ttl: 60 * 1000, // 1 minute cache TTL (default is 5 minutes)
    maxSize: 100,   // Store up to 100 responses (default is 1000)
    enabled: true   // Enable caching (enabled by default)
  }
});

// Demonstration of cache behavior
async function demonstrateCaching() {
  console.time('First call');
  await client.networks.list(); // Makes an API request
  console.timeEnd('First call');
  
  console.time('Second call');
  await client.networks.list(); // Returns cached result
  console.timeEnd('Second call');
  
  // You can also manage the cache manually
  client.clearCache();                // Clear all cached data
  console.log(client.cacheSize);      // Get current cache size
  client.setCacheEnabled(false);      // Disable caching
}

// Using the Cache class directly
const manualCache = new Cache({ 
  ttl: 30 * 1000,  // 30 second TTL
  maxSize: 50      // Store maximum 50 items
});

manualCache.set('myKey', { data: 'example data' });
const data = manualCache.get('myKey');
manualCache.delete('myKey');
manualCache.clear();

import { DexPaprikaClient } from '@dexpaprika/sdk';

async function fetchAllPools(networkId) {
  const client = new DexPaprikaClient();
  const allPools = [];
  let page = 0;
  const limit = 50;
  let hasMore = true;
  
  while (hasMore) {
    const response = await client.pools.listByNetwork(
      networkId, 
      {
        page,
        limit,
        sort: 'desc',
        orderBy: 'volume_usd'
      }
    );
    
    allPools.push(...response.data);
    
    // Check if there are more pages
    hasMore = response.data.length === limit;
    page++;
    
    // Adding a small delay to avoid hitting rate limits
    await new Promise(resolve => setTimeout(resolve, 100));
  }
  
  console.log(`Fetched a total of ${allPools.length} pools on ${networkId}`);
  return allPools;
}

// Usage example
fetchAllPools('ethereum').catch(console.error);

import { DexPaprikaClient } from '@dexpaprika/sdk';
import axios from 'axios';

// Create a custom axios instance
const axiosInstance = axios.create({
  timeout: 60000, // 60 second timeout
  headers: {
    'User-Agent': 'MyApp/1.0 DexPaprikaSDK'
  }
});

// Create client with custom configuration
const client = new DexPaprikaClient(
  'https://api.dexpaprika.com', // Base URL (optional)
  axiosInstance,                // Custom axios instance (optional)
  {
    // Retry configuration (optional)
    retry: {
      maxRetries: 5,
      delaySequenceMs: [100, 500, 1000, 2000, 5000],
      retryableStatuses: [429, 500, 502, 503, 504]
    },
    
    // Cache configuration (optional)
    cache: {
      ttl: 10 * 60 * 1000, // 10 minutes TTL
      maxSize: 500,        // Store up to 500 responses
      enabled: true        // Enable caching
    }
  }
);

// Usage example
async function fetchWithCustomClient() {
  try {
    const networks = await client.networks.list();
    console.log(`Fetched ${networks.length} networks with custom client`);
  } catch (err) {
    console.error('Error:', err);
  }
}