Power Your Agent with On-Chain Analytics

import requests
import time
from dataclasses import dataclass
from typing import Optional

# Purple Flea API configuration
BASE_URL = "https://purpleflea.com"
API_KEY  = "pf_live_your_key_here"

HEADERS = {
    "Authorization": f"Bearer {API_KEY}",
    "Content-Type": "application/json"
}

@dataclass
class OnChainSignal:
    token: str
    whale_accumulation_usd: float
    exchange_inflow_usd: float
    dex_volume_ratio: float   # current / 30d avg
    risk_score: int
    composite_score: float    # -1.0 (bearish) to +1.0 (bullish)


def fetch_on_chain_signal(token: str, chain: str = "ethereum") -> OnChainSignal:
    """Fetch composite on-chain signal for a token."""

    # Get token flow data
    flows = requests.get(
        f"{BASE_URL}/analytics/token-flows",
        params={"token": token, "chain": chain, "window": "24h"},
        headers=HEADERS
    ).json()

    # Get DEX volume (compare to 30d average)
    dex = requests.get(
        f"{BASE_URL}/analytics/dex-volume",
        params={"pair": f"{token}/USDC", "chain": chain, "anomaly": "true"},
        headers=HEADERS
    ).json()

    whale_net    = flows.get("whale_net_usd", 0)
    exch_inflow  = flows.get("exchange_inflow_usd", 0)
    vol_ratio    = dex.get("volume_vs_30d_avg", 1.0)

    # Build composite signal:
    # +whale_acc, -exchange_inflow, +dex_spike
    composite = 0.0
    if whale_net > 5_000_000:
        composite += 0.35
    if exch_inflow < 2_000_000:
        composite += 0.25
    if vol_ratio > 2.5:
        composite += 0.20
    if exch_inflow > 15_000_000:
        composite -= 0.40

    return OnChainSignal(
        token=token,
        whale_accumulation_usd=whale_net,
        exchange_inflow_usd=exch_inflow,
        dex_volume_ratio=vol_ratio,
        risk_score=0,
        composite_score=max(-1.0, min(1.0, composite))
    )


def execute_trade_if_signal_strong(signal: OnChainSignal, threshold: float = 0.5):
    """Open a perp position if signal is strong enough."""

    if signal.composite_score >= threshold:
        side = "long"
        notional = 1000   # USDC
    elif signal.composite_score <= -threshold:
        side = "short"
        notional = 1000
    else:
        print(f"Signal too weak ({signal.composite_score:.2f}), holding.")
        return None

    # Submit via Purple Flea Trading API
    order = requests.post(
        f"{BASE_URL}/trading/perps/open",
        json={
            "symbol": f"{signal.token}-PERP",
            "side": side,
            "notional_usdc": notional,
            "leverage": 3,
            "signal_source": "on-chain-analytics"
        },
        headers=HEADERS
    ).json()

    print(f"Opened {side} {signal.token} | "
          f"Score: {signal.composite_score:.2f} | "
          f"Order ID: {order.get('order_id')}")
    return order


# Main agent loop
WATCHLIST = ["ETH", "SOL", "BTC", "MATIC"]

if __name__ == "__main__":
    while True:
        for token in WATCHLIST:
            signal = fetch_on_chain_signal(token)
            print(f"{token}: composite={signal.composite_score:.2f}, "
                  f"whale={signal.whale_accumulation_usd/1e6:.1f}M, "
                  f"vol_ratio={signal.dex_volume_ratio:.1f}x")
            execute_trade_if_signal_strong(signal)
        time.sleep(3600)  # Re-evaluate every hour