DexPaprika DEX API PHP SDK: on-chain liquidity and swap data client

<?php

require_once __DIR__ . '/vendor/autoload.php';

use DexPaprika\Client;
use DexPaprika\Exception\DexPaprikaApiException;

const WETH = '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2';
const USDC = '0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48';

function main() {
    try {
        $client = new Client();

        // Networks come back as a plain list of ['id' => ..., 'display_name' => ...]
        $networks = $client->networks->getNetworks();
        foreach ($networks as $network) {
            if ($network['id'] === 'ethereum') {
                echo "{$network['display_name']} is one of " . count($networks) . " networks\n";
            }
        }

        // Price lives under summary
        $weth = $client->tokens->getTokenDetails('ethereum', WETH);
        echo "{$weth['name']} price: $" . number_format($weth['summary']['price_usd'], 2) . "\n";

        // Pools for a token are served by pool search. Rows sit under results,
        // sorted by volume_usd_24h. There is no pair filter, so match the second
        // token client-side.
        $pools = $client->tokens->getTokenPools('ethereum', WETH, [
            'limit' => 20,
            'orderBy' => 'volume_usd_24h',
            'sort' => 'desc',
        ]);

        echo "Top WETH/USDC pools:\n";
        $shown = 0;
        foreach ($pools['results'] as $pool) {
            $ids = array_column($pool['tokens'], 'id');
            if (in_array(USDC, $ids, true) && $shown < 5) {
                echo "{$pool['dex_name']}: $" . number_format($pool['volume_usd_24h'], 2) . " 24h volume\n";
                $shown++;
            }
        }
    } catch (DexPaprikaApiException $e) {
        echo "API Error: {$e->getMessage()}\n";
    }
}

main();

<?php

require_once __DIR__ . '/vendor/autoload.php';

use DexPaprika\Client;
use DexPaprika\Exception\DexPaprikaApiException;
use DexPaprika\Exception\NotFoundException;
use DexPaprika\Exception\RateLimitException;
use DexPaprika\Exception\ServerException;
use DexPaprika\Exception\NetworkException;

// Basic error handling
try {
    $client = new Client();
    $token = $client->tokens->getTokenDetails('ethereum', '0xinvalidaddress');
} catch (NotFoundException $e) {
    echo "Token not found: {$e->getMessage()}\n";
} catch (RateLimitException $e) {
    echo "Rate limit exceeded: {$e->getMessage()}\n";
} catch (ServerException $e) {
    echo "Server error occurred: {$e->getMessage()}\n";
} catch (NetworkException $e) {
    echo "Network error: {$e->getMessage()}\n";
} catch (DexPaprikaApiException $e) {
    echo "API error: {$e->getMessage()} (Code: {$e->getCode()})\n";
} catch (Exception $e) {
    echo "General error: {$e->getMessage()}\n";
}

// The SDK automatically retries 429 (Too Many Requests), any 5xx
// (server errors) and connection failures

// Custom retry configuration
use DexPaprika\Config;

$config = new Config();
$config->setMaxRetries(4);  // Number of retry attempts (default: 5)
$config->setRetryDelays([100, 500, 1000, 5000]);  // Delay in milliseconds

$client = new Client(null, null, false, $config);

// All API requests will now use these retry settings
try {
    $networks = $client->networks->getNetworks();
} catch (Exception $e) {
    echo "Failed after multiple retries: {$e->getMessage()}\n";
}

<?php

require_once __DIR__ . '/vendor/autoload.php';

use DexPaprika\Client;
use DexPaprika\Cache\FilesystemCache;

// The SDK includes built-in caching capabilities
// Demonstration of cache behavior

// Create a client with default cache (1 hour TTL)
$client = new Client();
$client->setupCache();

// First call - hits the API
$startTime = microtime(true);
$networks = $client->networks->getNetworks();
$firstCallTime = microtime(true) - $startTime;
echo "First call (API): " . count($networks) . " networks, took {$firstCallTime} s\n";

// Second call - served from cache (much faster)
$startTime = microtime(true);
$networks = $client->networks->getNetworks();
$secondCallTime = microtime(true) - $startTime;
echo "Second call (cached): " . count($networks) . " networks, took {$secondCallTime} s\n";
echo "Cache speedup: " . ($firstCallTime / $secondCallTime) . "x\n";

// You can skip the cache when you need fresh data
$client->getConfig()->setCacheEnabled(false);
$freshNetworks = $client->networks->getNetworks();
$client->getConfig()->setCacheEnabled(true);

// Custom cache configuration
$cache = new FilesystemCache('/path/to/custom/cache');
$client->setupCache($cache, 300);  // 5 minutes TTL

// Clear the entire cache
$client->getConfig()->getCache()->clear();

<?php

require_once __DIR__ . '/vendor/autoload.php';

use DexPaprika\Client;

function fetchAllPools($networkId, $maxPages = 10) {
    $client = new Client();
    $allPools = [];
    $limit = 50;
    $cursor = null;
    
    // Every page is one request against your allowance, so cap the walk
    for ($page = 0; $page < $maxPages; $page++) {
        $options = [
            'limit' => $limit,
            'sort' => 'desc',
            'orderBy' => 'volume_usd_24h'
        ];
        if ($cursor !== null) {
            $options['cursor'] = $cursor;
        }
        
        $response = $client->pools->getNetworkPools($networkId, $options);
        
        $allPools = array_merge($allPools, $response['results']);
        
        // The search endpoint is cursor-paginated, not page-numbered
        if (empty($response['has_next_page']) || empty($response['next_cursor'])) {
            break;
        }
        $cursor = $response['next_cursor'];
        
        // Pause between pages to stay under your per-minute limit:
        // https://docs.dexpaprika.com/knowledge-base/rate-limits
        sleep(4);
    }
    
    echo "Fetched a total of " . count($allPools) . " pools on {$networkId}\n";
    return $allPools;
}

// Alternative approach using built-in paginator
function fetchAllPoolsWithPaginator($networkId) {
    $client = new Client();
    $allPools = [];
    
    // Create a paginator for network pools. Arguments are keyed by the
    // method's parameter names; whatever is left becomes the options array.
    $paginator = $client->createPaginator(
        $client->pools,
        'getNetworkPools',
        [
            'networkId' => $networkId,
            'limit' => 50,
            'orderBy' => 'volume_usd_24h',
            'sort' => 'desc'
        ]
    );
    
    // Paginator is not Traversable and has no setMaxPages(), so walk it explicitly.
    $page = 0;
    while ($paginator->hasNextPage() && $page < 10) {
        $response = $paginator->getNextPage();
        $allPools = array_merge($allPools, $response['results']);
        echo "Processed page {$page}, got " . count($response['results']) . " pools\n";
        $page++;
    }
    
    echo "Fetched a total of " . count($allPools) . " pools on {$networkId}\n";
    return $allPools;
}

// Usage example
$ethereumPools = fetchAllPools('ethereum');
// or
$ethereumPools = fetchAllPoolsWithPaginator('ethereum');

<?php

require_once __DIR__ . '/vendor/autoload.php';

use DexPaprika\Client;

$client = new Client();

// Pass 'asObject' => true to get an object instead of an array
$pool = $client->pools->getPoolDetails(
    'ethereum',
    '0x88e6a0c2ddd26feeb64f039a2c41296fcb3f5640',  // USDC/WETH Uniswap v3 pool
    ['asObject' => true]
);

// Access pool properties as object properties
echo "Pool: {$pool->tokens[0]->symbol}/{$pool->tokens[1]->symbol}\n";
echo "Price: \${$pool->last_price_usd}\n";

// Time windows are keyed '24h', '6h', '1h', '30m', '15m' and '5m', so use
// the brace syntax to read them
echo "Volume (24h): \${$pool->{'24h'}->volume_usd}\n";
echo "Transactions (24h): {$pool->{'24h'}->txns}\n";
echo "1h price change: {$pool->{'1h'}->last_price_usd_change}%\n";
echo "24h price change: {$pool->{'24h'}->last_price_usd_change}%\n";

// Calls without the option keep returning arrays
$networks = $client->networks->getNetworks();

$token = $client->tokens->getTokenDetails(
    'ethereum',
    '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2',
    ['asObject' => true]
);
echo "{$token->name} price: \${$token->summary->price_usd}\n";