Getting Started with GmGnAPI

pip install gmgnapi

# Install with optional dependencies
pip install gmgnapi[all]

# Or install specific optional dependencies
pip install gmgnapi[pandas,analysis]

import asyncio
from gmgnapi import GmGnClient

async def main():
    # Create client instance
    async with GmGnClient() as client:
        # Subscribe to new liquidity pools
        await client.subscribe_new_pools(chain="sol")
        
        # Define event handler
        @client.on_new_pool
        async def handle_new_pool(pool_data):
            print(f"🆕 New pool detected!")
            for pool in pool_data.pools:
                if pool.bti:  # Base token info available
                    print(f"  Token: {pool.bti.s} ({pool.bti.n})")
                    print(f"  Market Cap: ${pool.bti.mc:,.2f}")
                    print(f"  Exchange: {pool.ex}")
                    print("-" * 40)
        
        # Start listening for messages
        print("🔥 Starting GMGN data stream...")
        await client.listen()

# Run the async function
if __name__ == "__main__":
    asyncio.run(main())

# Set environment variable
export GMGN_ACCESS_TOKEN="your_access_token_here"

# Client will automatically use the environment variable
async with GmGnClient() as client:
    await client.subscribe_wallet_trades()  # Requires auth

async with GmGnClient(access_token="your_token") as client:
    await client.subscribe_wallet_trades()

# config.json
{
    "access_token": "your_access_token_here",
    "default_chain": "sol"
}

# In your code
import json
with open('config.json') as f:
    config = json.load(f)

async with GmGnClient(access_token=config['access_token']) as client:
    # Your code here

async def multi_subscription_example():
    async with GmGnClient() as client:
        # Subscribe to multiple data streams
        await client.subscribe_new_pools(chain="sol")
        await client.subscribe_token_updates(tokens=["EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v"])
        
        # Handle different event types
        @client.on_new_pool
        async def handle_pools(data):
            print(f"📊 New pool: {len(data.pools)} pools")
        
        @client.on_token_update
        async def handle_updates(data):
            print(f"💰 Token update: ${data.price_usd}")
        
        @client.on_error
        async def handle_error(error):
            print(f"❌ Error: {error}")
        
        await client.listen()

# Solana (default)
await client.subscribe_new_pools(chain="sol")

# Ethereum
await client.subscribe_new_pools(chain="eth")

# Binance Smart Chain
await client.subscribe_new_pools(chain="bsc")

# Polygon
await client.subscribe_new_pools(chain="polygon")

import logging
from gmgnapi import GmGnClient, GmGnAPIError

# Set up logging
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__)

async def robust_client_example():
    try:
        async with GmGnClient() as client:
            # Error event handler
            @client.on_error
            async def handle_error(error):
                logger.error(f"WebSocket error: {error}")
                # Custom error handling logic here
            
            # Connection event handlers
            @client.on_connect
            async def handle_connect():
                logger.info("✅ Connected to GMGN WebSocket")
            
            @client.on_disconnect
            async def handle_disconnect():
                logger.warning("⚠️ Disconnected from GMGN WebSocket")
            
            @client.on_reconnect
            async def handle_reconnect():
                logger.info("🔄 Reconnected to GMGN WebSocket")
            
            await client.subscribe_new_pools()
            await client.listen()
            
    except GmGnAPIError as e:
        logger.error(f"GMGN API Error: {e}")
    except Exception as e:
        logger.error(f"Unexpected error: {e}")
        raise