Listings Detector - Multi-Source Token Listing Detection

Description

The Listings Detector is a comprehensive token listing detection system that monitors multiple centralized and decentralized exchanges to identify new token listings in real-time. It aggregates data from CEX announcements and DEX liquidity pools, applies intelligent deduplication, and delivers actionable insights via webhooks or dataset storage.

Features

• Multi-Source Coverage: Binance, KuCoin, MEXC (CEX) + DexScreener (DEX)
• Smart Deduplication: Multi-stage deduplication prevents duplicate listings
  • Basic deduplication (same symbol, same source)
  • Priority deduplication (prefer higher quality sources)
  • Cross-chain deduplication (identify same token across chains)
• Confidence Scoring: Each listing gets a confidence score (0-1)
• Liquidity Filtering: Filter DEX listings by minimum liquidity threshold
• Webhook Integration: Instant or batch delivery modes
• Quality Filtering: Automatic filtering of low-quality listings

Input Schema

interface ListingsDetectorInput {
    webhook_url?: string;           // Optional webhook delivery URL
    webhook_mode?: "instant" | "batch"; // Delivery mode (default: batch)
    min_liquidity?: number;         // Minimum liquidity for DEX listings (default: 5000)
    min_confidence?: number;        // Minimum confidence score (default: 0.1)
}

Output Schema

interface ListingsDetectorOutput {
    timestamp: string;
    listings: ListingItem[];
}

interface ListingItem {
    symbol: string;              // Token symbol (e.g., "BTC", "ETH")
    name?: string;               // Token name
    chain?: string;              // Blockchain (ethereum, bsc, solana, etc.)
    source: string;              // Source (binance, kucoin, mexc, dexscreener)
    listing_type: "cex" | "dex"; // Exchange type
    detected_at: number;         // Unix timestamp (ms)
    confidence: number;          // 0-1 confidence score

    // Optional metadata
    contract_address?: string;
    pair?: string;              // Trading pair (e.g., "BTC/USDT")
    liquidity_usd?: number;     // Liquidity (DEX only)
    price_usd?: number;         // Current price
    volume_24h?: number;        // 24h volume
}

Example Run

Input

{
    "webhook_url": "https://hooks.zapier.com/hooks/catch/123456/abcdef",
    "webhook_mode": "batch",
    "min_liquidity": 10000,
    "min_confidence": 0.5
}

Output

{
    "timestamp": "2025-12-29T12:00:00.000Z",
    "listings": [
        {
            "symbol": "NEWTOKEN",
            "name": "New Token Protocol",
            "chain": "ethereum",
            "source": "binance",
            "listing_type": "cex",
            "detected_at": 1735473600000,
            "confidence": 0.95,
            "pair": "NEWTOKEN/USDT",
            "price_usd": 0.00152,
            "volume_24h": 1250000
        },
        {
            "symbol": "DEXTOKEN",
            "name": "DEX Token",
            "chain": "bsc",
            "source": "dexscreener",
            "listing_type": "dex",
            "detected_at": 1735473500000,
            "confidence": 0.75,
            "contract_address": "0x1234567890abcdef...",
            "liquidity_usd": 15000,
            "price_usd": 0.000045
        }
    ]
}

Data Sources

Centralized Exchanges (CEX)

1. Binance: New listing announcements via API

   • High confidence (0.9-1.0)
   • Includes trading pairs, initial pricing

2. KuCoin: Trading pair announcements

   • Good confidence (0.8-0.9)
   • Fast detection

3. MEXC: New listings API

   • Moderate confidence (0.7-0.8)
   • Wide coverage including new tokens

Decentralized Exchanges (DEX)

4. DexScreener: Multi-chain DEX pool monitoring
   • Confidence based on liquidity (0.5-0.9)
   • Filters by minimum liquidity threshold
   • Covers Ethereum, BSC, Polygon, Solana, and more

Processing Pipeline

┌─────────────────────┐
│  Fetch from Sources │
│  (4 parallel calls) │
└──────────┬──────────┘
           │
           ▼
┌─────────────────────┐
│ Quality Filtering   │
│ - Age check (<24h)  │
│ - Minimum data      │
└──────────┬──────────┘
           │
           ▼
┌─────────────────────┐
│  Deduplication      │
│  - Basic (symbol)   │
│  - Priority (source)│
│  - Cross-chain      │
└──────────┬──────────┘
           │
           ▼
┌─────────────────────┐
│ Confidence Filter   │
│ (>= min_confidence) │
└──────────┬──────────┘
           │
           ▼
┌─────────────────────┐
│ Output & Webhook    │
└─────────────────────┘

Configuration

Environment variables (optional):

• BINANCE_API_KEY: Binance API credentials (if needed)
• KUCOIN_API_KEY: KuCoin API credentials
• MEXC_API_KEY: MEXC API credentials
• MIN_LIQUIDITY_DEFAULT: Default minimum liquidity (default: 5000)

Confidence Scoring

Listings are scored based on source reliability and data quality:

Source	Base Confidence	Factors
Binance	0.95	Official announcements
KuCoin	0.85	Verified trading pairs
MEXC	0.75	Wide coverage
DexScreener	0.5-0.9	Based on liquidity level

DEX Confidence Formula:

• < $5k liquidity: 0.5
• $5k-$50k: 0.6
• $50k-$500k: 0.75

• $500k: 0.9

Deduplication Strategy

1. Basic Deduplication

• Same symbol + same source → keep most recent

2. Priority Deduplication

• Same symbol, different sources → keep highest confidence

3. Cross-Chain Deduplication

• Identifies wrapped/bridged tokens across chains
• Example: USDC on Ethereum vs USDC on BSC

Pricing

• Free Tier: Up to 50 listings detected per run
• Standard: $0.02 per listing detected
• Premium: $0.01 per listing (bulk pricing for >5,000/month)
• Enterprise: Custom pricing with dedicated monitoring

Use Cases

• Trading Bots: Early detection for first-mover advantage
• Portfolio Tracking: Monitor new investment opportunities
• Market Research: Analyze listing trends and patterns
• Risk Management: Track token debuts across exchanges
• Arbitrage Detection: Find pricing discrepancies on new listings

Webhooks

Instant Mode

Delivers each listing immediately as detected:

{
    "mode": "instant",
    "listing": { /* ListingItem */ }
}

Batch Mode (default)

Delivers all listings in one payload:

{
    "mode": "batch",
    "total_listings": 15,
    "listings": [ /* ListingItem[] */ ]
}

Technical Features

• Parallel Processing: All sources fetched simultaneously
• Error Resilience: Source failures don't stop other sources
• Detailed Statistics: Complete processing breakdown
• Production Ready: Handles edge cases and failures gracefully

Statistics Output

The actor stores processing statistics in Apify Key-Value Store:

{
    "sources": {
        "binance": 5,
        "kucoin": 3,
        "mexc": 7,
        "dexscreener": 12
    },
    "processing": {
        "total_raw": 27,
        "after_processing": 22,
        "after_deduplication": 15,
        "final_output": 12
    },
    "confidence": {
        "min_threshold": 0.5,
        "average": 0.78
    },
    "webhook": {
        "enabled": true,
        "mode": "batch",
        "delivered": true
    }
}

API Integration

The actor integrates seamlessly with:

• Zapier: Automated workflows on new listings
• Make (Integromat): Complex automation scenarios
• Discord/Slack: Real-time notifications
• Trading Platforms: Automated trading strategies

Best Practices

1. Set appropriate min_liquidity: Filter noise from DEX pools
2. Use batch mode for efficiency: Unless immediate notification needed
3. Monitor confidence scores: Adjust min_confidence based on your risk tolerance
4. Check statistics: Understand processing efficiency
5. Validate webhooks: Ensure HTTPS and proper endpoint

Limitations

• CEX detection depends on exchange APIs (may have rate limits)
• DEX detection is liquidity-based (very new tokens may be missed)
• Maximum 24-hour lookback for listings
• Deduplication is heuristic-based (edge cases possible)

Future Enhancements

• Social sentiment integration
• Smart contract verification checks
• Historical listing database
• Predictive listing detection
• More exchange coverage (Coinbase, Crypto.com, OKX)