Pump.fun Trade Monitor

# 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 json { "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: bash # 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: bash # 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 bash # 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: bash curl -H "Authorization: Bearer your_apify_token" \ https://muhammetakkurtt--pump-fun-trade-monitor.apify.actor/events Or for health check: bash curl -H "Authorization: Bearer your_apify_token" \ https://muhammetakkurtt--pump-fun-trade-monitor.apify.actor/health #### API Response Examples Health Check Response: json { "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): json { "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: json // 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 json { "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