Pump.fun Real-Time Trade Monitor - Real-time Solana Meme Token Tracking

An Apify actor that monitors and records meme token and new token transactions on the Solana blockchain in real-time from the Pump.fun platform. Don't miss new opportunities, track market movements instantly!

Overview

This tool monitors and records Solana-based token transactions on the Pump.fun platform in real-time. It is ideal for traders, analysts, and developers to track current transaction data and market movements.

🔗 Related Actors

Pump.fun Token Scraper & Monitor

A powerful Apify actor that monitors and analyzes Solana (SOL) tokens on the Pump.fun platform in real-time. Track market capitalization, new token listings, trading volume, and King of the Hill tokens with comprehensive monitoring features. Don't miss opportunities in the Solana ecosystem!

🚀 Key Features:

• Real-Time Token Monitoring: Track instant token movements and market changes
• Advanced Sorting Options:
  • Latest Trading Activity
  • New Token Listings
  • Market Cap Rankings
  • King of the Hill Tokens
  • Community Engagement
• Customizable Filtering:
  • NSFW Content Filter
  • Flexible Monitoring Duration
• Automated Data Collection and Analysis

🔍 Click for Detailed Information and Usage Guide

Key Features

• Real-Time Transaction Monitoring: Instant tracking of token buy/sell transactions
• Dual Operating Modes:
  • Normal Mode: Fixed monitoring duration with data export to dataset
  • Standby Mode: Continuous HTTP API server for real-time data access
• Detailed Data Collection:
  • Transaction Details (Buy/Sell, Amount, Price)
  • Token Information (Name, Symbol, Description)
  • Market Data (Market Cap, Reserves)
  • Social Media Links
  • Creator Information
• Standby API Features:
  • Real-time HTTP endpoints
  • Server-Sent Events (SSE) for push-based real-time data
  • Connection management (up to 1000 concurrent connections)
  • Automatic reconnection and error handling
  • Advanced health monitoring and disconnect detection
• Customizable Settings:
  • Flexible Monitoring Duration (Normal Mode)
• Automated Data Collection: All data automatically stored in Apify dataset (Normal Mode)

Usage

Normal Mode

1. Run the actor in the Apify console
2. Provide the following input parameters:
   • monitoringDuration: Monitoring duration (minutes, 0=unlimited)

Example Input

{
  "monitoringDuration": 3
}

Standby Mode

When the actor runs in Standby mode, it operates as a continuous HTTP API server providing real-time access to trade data.

Available Endpoints

• GET / or GET /health - Health check endpoint
• GET /events - Server-Sent Events stream for all configured tokens
• GET /tokens - Get current global tokens that server is monitoring
• POST /tokens - Update global tokens (subscribe/unsubscribe/set actions)

Real-Time Streaming via Server-Sent Events

The standby mode provides real-time trade streaming via Server-Sent Events (SSE). Connect once and receive live data as it happens.

Benefits over polling:

• ✅ Real-time: Trades delivered instantly as they happen
• ✅ Efficient: No constant HTTP requests needed
• ✅ Filtered: Receive only the tokens you care about
• ✅ Scalable: Handles thousands of concurrent connections
• ✅ Simple: Just a single URL with token filtering

Basic Usage:

# First, set tokens on the server (admin only)
curl -X POST https://muhammetakkurtt--pump-fun-trade-monitor.apify.actor/tokens \
     -H "Authorization: Bearer your_apify_token" \
     -H "Content-Type: application/json" \
     -d '{
       "action": "set",
       "tokens": ["8hMpgQGzin64DpoVqeFFyaHmZYzFTVVFHLLHzAo9pump", "9iAnother1Token2Address3Here4567890pump"]
     }'

# Then, any client can stream all configured tokens
curl -N https://muhammetakkurtt--pump-fun-trade-monitor.apify.actor/events \
     -H "Authorization: Bearer your_apify_token"

Server Token Management

The server maintains a global token list that all clients receive. You can manage this list dynamically:

# Get current global tokens
curl https://muhammetakkurtt--pump-fun-trade-monitor.apify.actor/tokens \
     -H "Authorization: Bearer your_apify_token"

# Add new tokens to monitoring (subscribe)
curl -X POST https://muhammetakkurtt--pump-fun-trade-monitor.apify.actor/tokens \
     -H "Authorization: Bearer your_apify_token" \
     -H "Content-Type: application/json" \
     -d '{
       "action": "subscribe",
       "tokens": ["8hMpgQGzin64DpoVqeFFyaHmZYzFTVVFHLLHzAo9pump", "NewTokenAddress123"]
     }'

# Remove tokens from monitoring (unsubscribe)
curl -X POST https://muhammetakkurtt--pump-fun-trade-monitor.apify.actor/tokens \
     -H "Authorization: Bearer your_apify_token" \
     -H "Content-Type: application/json" \
     -d '{
       "action": "unsubscribe",
       "tokens": ["OldTokenToRemove"]
     }'

# Replace all tokens (set)
curl -X POST https://muhammetakkurtt--pump-fun-trade-monitor.apify.actor/tokens \
     -H "Authorization: Bearer your_apify_token" \
     -H "Content-Type: application/json" \
     -d '{
       "action": "set",
       "tokens": ["TokenA", "TokenB", "TokenC"]
     }'

All connected SSE clients will automatically receive:

• Trade updates for newly added tokens
• No more trades for removed tokens
• Real-time notifications about token list changes

Example API Usage

# Health check
curl https://muhammetakkurtt--pump-fun-trade-monitor.apify.actor/health

# Real-time streaming for all configured tokens
curl -N -H "Authorization: Bearer your_apify_token" \
     "https://muhammetakkurtt--pump-fun-trade-monitor.apify.actor/events"

Authentication

Include your Apify token in the Authorization header:

curl -H "Authorization: Bearer your_apify_token" \
     https://muhammetakkurtt--pump-fun-trade-monitor.apify.actor/events

Or for health check:

curl -H "Authorization: Bearer your_apify_token" \
     https://muhammetakkurtt--pump-fun-trade-monitor.apify.actor/health

API Response Examples

Health Check Response:

{
  "status": "ok",
  "message": "Pump.fun Trade Monitor is running",
  "timestamp": "2025-02-05T22:44:22.000Z"
}

Server-Sent Events (SSE) Stream:

event: connected
data: {"message":"Connected to Pump.fun Trade Monitor","connection_id":"conn_1643849162000","filtering":2,"tokens":["8hMpgQGzin64DpoVqeFFyaHmZYzFTVVFHLLHzAo9pump","9iAnother1Token2Address3Here4567890pump"]}

event: status
data: {"connections":5,"timestamp":"2025-02-05T22:44:22.000Z"}

event: filter_info
data: {"message":"Server monitoring 2 tokens. Only trades for these tokens will be sent.","tokens":2}

event: trade
data: {"trade_details":{"signature":"abc123...","mint_address":"8hMpgQGzin64DpoVqeFFyaHmZYzFTVVFHLLHzAo9pump",...},"token_details":{...}}

event: tokens_updated
data: {"tokens_updated":true,"action":"subscribe","tokens":["NewToken123"],"total_tokens":3,"timestamp":"2025-02-05T22:44:52.000Z"}

event: ping
data: {"timestamp":"2025-02-05T22:44:52.000Z","connections":5}

Error Response (Unknown Endpoint):

{
  "error": "Endpoint not found", 
  "message": "Available endpoints: /health, /events, /tokens",
  "endpoints": {
    "/health": "Health check",
    "/events": "Real-time Server-Sent Events stream for all configured tokens",
    "/tokens": "GET/POST - Manage global tokens for all clients"
  },
  "timestamp": "2025-02-05T22:44:22.000Z"
}

Token Management Response Examples:

// GET /tokens - Current tokens
{
  "tokens": ["8hMpgQGzin64DpoVqeFFyaHmZYzFTVVFHLLHzAo9pump", "TokenB"],
  "count": 2,
  "timestamp": "2025-02-05T22:44:22.000Z"
}

// POST /tokens - Subscribe/Unsubscribe/Set
{
  "success": true,
  "action": "subscribe",
  "requested_tokens": ["NewToken123"],
  "current_tokens": ["8hMpgQGzin64DpoVqeFFyaHmZYzFTVVFHLLHzAo9pump", "TokenB", "NewToken123"],
  "total_tokens": 3,
  "timestamp": "2025-02-05T22:44:22.000Z"
}

Output

Normal Mode

The collected data is saved to the Apify dataset.

Standby Mode

Data is available via HTTP API endpoints with the following response formats:

Trade Data Structure

Both modes provide the same trade data structure with the following fields:

Transaction Details (trade_details)

• signature: Transaction signature
• sol_amount: SOL amount
• token_amount: Token amount
• is_buy: Buy/Sell status
• user: User address
• timestamp_utc: Transaction date (UTC)
• mint_address: Token mint address
• virtual_sol_reserves: Virtual SOL reserves
• virtual_token_reserves: Virtual token reserves
• slot: Solana slot number
• transaction_index: Transaction index

Token Details (token_details)

• name: Token name
• symbol: Token symbol
• description: Token description
• total_supply: Total supply
• market_cap_sol: Market cap (SOL)
• market_cap_usd: Market cap (USD)

Media (media)

• image_uri: Token logo URL
• video_uri: Video URL
• metadata_uri: Metadata URL

Social Links (social_links)

• website: Website address
• twitter: Twitter account
• telegram: Telegram channel

Bonding Curve (bonding_curve)

• bonding_curve: Bonding curve address
• associated_bonding_curve: Associated bonding curve

Creator Details (creator_details)

• creator: Creator address
• creator_username: Creator username
• creator_profile_image: Creator profile image
• created_timestamp_utc: Creation date (UTC)

Market Details (market_details)

• raydium_pool: Raydium pool address
• complete: Completion status
• reply_count: Reply count
• last_reply_utc: Last reply date (UTC)
• nsfw: Adult content status
• market_id: Market ID
• inverted: Inverted status
• is_currently_live: Activity status
• king_of_hill_timestamp_utc: King of Hill date (UTC)

User Profile (user_profile)

• username: Username
• profile_image: Profile image

Example Output

{
  "bonding_curve": {
      "associated_bonding_curve": "5B7tNXtEwY8yjhSyJSq8d67r7mypSiTnv3mr4JUiaNRS",
      "bonding_curve": "ENgzXwDFzDZQ6moVKSnsDtAGAEWqnVkfFhAv6gRdyu4J"
  },
  "creator_details": {
      "created_timestamp_utc": "2025-02-05 20:28:36 UTC",
      "creator": "G1vvmzKfYxbdKn4haFWjN4CAH25T5EnZvzJwbtFqmjbD",
      "creator_profile_image": null,
      "creator_username": null
  },
  "market_details": {
      "complete": false,
      "inverted": null,
      "is_currently_live": false,
      "king_of_hill_timestamp_utc": "",
      "last_reply_utc": "2025-02-05 22:42:36 UTC",
      "market_id": null,
      "nsfw": false,
      "raydium_pool": null,
      "reply_count": 219
  },
  "media": {
      "image_uri": "https://ipfs.io/ipfs/QmRSC2jzyhHwzyvRED1dsZ2YTyMDZRyX1gUuea9affxsaC",
      "metadata_uri": "https://ipfs.io/ipfs/QmWUm2QUUsQ37P7UaqN62qhGW9f8x6UJAkvuvTTrNm88Pu",
      "video_uri": null
  },
  "social_links": {
      "telegram": "https://t.me/challange100to10k",
      "twitter": "",
      "website": "https://t.me/challange100to10k"
  },
  "token_details": {
      "description": "Simple challenge 100$ to 10k who's is brave enough ?  Please comment in token chat ",
      "market_cap_sol": 88.402048153,
      "market_cap_usd": 17468.244715032797,
      "name": "Challenge 100 to 10k ",
      "symbol": "Challenge ",
      "total_supply": 1000000000000000
  },
  "trade_details": {
      "is_buy": false,
      "mint_address": "ARQBXz2KtB7BWPsixxsywcMrCsnCaHvAqL2uERKEpump",
      "signature": "29VLB6kfoivRvtCGVra92xZqFvu1Z5xkB7TuiDBomqwxfwBaZYHkrmeqk7Bc3vmymNmrZ3y7oaqefYfnR29nodto",
      "slot": 318729017,
      "sol_amount": 0.011999999,
      "timestamp_utc": "2025-02-05 22:44:22 UTC",
      "token_amount": 135773992578,
      "transaction_index": 2,
      "user": "9khpvG2ZLPokAnuHZ9QTdppZ3oBkdpFpacJrCFMnJi9R",
      "virtual_sol_reserves": 53332746727,
      "virtual_token_reserves": 603569154101850
  },
  "user_profile": {
      "profile_image": "https://pump.mypinata.cloud/ipfs/QmVt2hgvL5vTQfUN58cFPiuXGYXycTuB9EF55rGGefqDFs?img-width=128&img-dpr=2&img-onerror=redirect",
      "username": "bump12319"
  }
}

This example output shows the structured data of a single cryptocurrency. The actual output will be a list of similar objects for all processed cryptocurrencies.

Notes

Normal Mode

• If the monitoring duration is set to 0, monitoring is done indefinitely
• The collected data is stored in Apify's default data store
• Actor stops after the specified monitoring duration

Standby Mode

• The actor runs continuously as a real-time streaming server
• Real-time SSE streaming - no polling needed
• No data is exported to dataset in standby mode
• Returns JSON error response for unknown endpoints
• Authentication via Bearer token (recommended) or query parameter
• Token Filtering System: Server maintains global token list, manageable via /tokens endpoint
• Dynamic Updates: Add/remove tokens without restarting - all clients get updates instantly
• Connection Management: Supports up to 1000 concurrent connections with automatic cleanup

Performance & Limitations

• Memory Usage: Optimized for real-time streaming with minimal memory footprint
• Scalability: Supports up to 1000 concurrent SSE connections with automatic cleanup
• Data Retention: Standby mode provides real-time streaming only (no persistent storage)
• Real-time Performance: Sub-second trade delivery via efficient broadcasting
• Connection Management: Automatic removal of inactive connections to maintain performance

Support & Examples

For help with implementation, Python client examples, or technical support, you can reach out on Discord: @muhammetakkurtt