Combine Moralis Data with
Purple Flea Financial Execution

# NFT Trader: Moralis NFT floor price monitoring + Purple Flea escrow settlement
# Monitors a collection; when floor dips, creates an escrow offer to the seller.

import os, requests, time

MORALIS_KEY  = os.environ["MORALIS_API_KEY"]
PF_KEY       = os.environ["PURPLE_FLEA_API_KEY"]
AGENT_ID     = os.environ["PURPLE_FLEA_AGENT_ID"]
PF_WALLET_EP = "https://wallet.purpleflea.com/api/v1"
PF_ESCROW_EP = "https://escrow.purpleflea.com/api/v1"
PF_HDR       = {"X-API-Key": PF_KEY, "Content-Type": "application/json"}

# Target NFT collection: Bored Ape Yacht Club
NFT_CONTRACT = "0xBC4CA0EdA7647A8aB7C2061c2E118A18a936f13D"
CHAIN        = "eth"
MAX_BID_USD  = 5000.0   # max we'll pay
FLOOR_TARGET = 0.90    # bid if floor is 90% of 7-day average or lower

floor_history = []

def get_nft_floor(contract: str, chain: str) -> float:
    """Fetch current floor price in USD via Moralis NFT API."""
    url = f"https://deep-index.moralis.io/api/v2.2/nft/{contract}/stats"
    r = requests.get(
        url,
        headers={"X-API-Key": MORALIS_KEY},
        params={"chain": chain},
        timeout=5,
    )
    r.raise_for_status()
    data = r.json()
    return float(data["floor_price_usd"])

def get_wallet_balance() -> float:
    """Check available USDC balance in Purple Flea Wallet."""
    r = requests.get(
        f"{PF_WALLET_EP}/balance/{AGENT_ID}",
        headers={"X-API-Key": PF_KEY},
        timeout=5,
    )
    r.raise_for_status()
    return r.json().get("usdc", 0.0)

def create_escrow_offer(seller_agent_id: str, amount_usd: float) -> dict:
    """
    Create an escrow contract offer.
    Funds are held by Purple Flea until seller delivers the NFT token ID.
    """
    r = requests.post(
        f"{PF_ESCROW_EP}/create",
        headers=PF_HDR,
        json={
            "buyer_agent_id": AGENT_ID,
            "seller_agent_id": seller_agent_id,
            "amount_usd": amount_usd,
            "description": f"NFT purchase: BAYC {NFT_CONTRACT[:8]}...",
            "timeout_hours": 24,
        },
        timeout=5,
    )
    r.raise_for_status()
    return r.json()

def run_nft_agent():
    print("NFT Trader Agent started. Monitoring BAYC floor via Moralis...")

    while True:
        try:
            floor = get_nft_floor(NFT_CONTRACT, CHAIN)
            floor_history.append(floor)
            print(f"Floor: ${floor:,.0f} | samples: {len(floor_history)}")

            if len(floor_history) >= 7:
                avg_7d = sum(floor_history[-7:]) / 7
                ratio  = floor / avg_7d
                print(f"7-day avg: ${avg_7d:,.0f} | floor/avg ratio: {ratio:.3f}")

                if ratio <= FLOOR_TARGET:
                    balance = get_wallet_balance()
                    bid_usd = min(floor * 1.02, MAX_BID_USD)

                    if balance >= bid_usd:
                        print(f"Floor dip detected! Bidding ${bid_usd:,.0f} via Purple Flea Escrow")
                        # In production, source seller_agent_id from a peer discovery API
                        escrow = create_escrow_offer(
                            seller_agent_id="seller-agent-xyz",
                            amount_usd=bid_usd,
                        )
                        print(f"Escrow created: {escrow.get('escrow_id')}")
                    else:
                        print(f"Insufficient balance (${balance:.2f}) for bid (${bid_usd:.2f})")

        except Exception as e:
            print(f"ERROR: {e}")

        time.sleep(3600)  # check every hour

if __name__ == "__main__":
    run_nft_agent()