Give Your o3 Agent
Financial Superpowers

[
  {
    "type": "function",
    "function": {
      "name": "get_market_data",
      "description": "Fetch current price, funding rate, open interest, and 24h volume for a Purple Flea perpetual market. Use before making any trading decision.",
      "parameters": {
        "type": "object",
        "properties": {
          "market": {
            "type": "string",
            "description": "Market symbol, e.g. 'BTC-PERP', 'ETH-PERP', 'SOL-PERP'"
          },
          "include_orderbook": {
            "type": "boolean",
            "description": "Whether to include top 10 bids/asks in response",
            "default": false
          }
        },
        "required": ["market"]
      }
    }
  },
  {
    "type": "function",
    "function": {
      "name": "list_all_markets",
      "description": "Returns all 275+ available perpetual markets with current funding rates. Use to identify arbitrage opportunities or filter by funding rate threshold.",
      "parameters": {
        "type": "object",
        "properties": {
          "min_funding_rate": {
            "type": "number",
            "description": "Minimum absolute 8h funding rate to include (e.g. 0.01 for 0.01%)"
          },
          "sort_by": {
            "type": "string",
            "enum": ["funding_rate", "volume_24h", "open_interest"]
          }
        },
        "required": []
      }
    }
  },
  {
    "type": "function",
    "function": {
      "name": "place_order",
      "description": "Place a perpetual futures order on Purple Flea. Use after reasoning confirms the trade thesis. Always verify available margin before placing.",
      "parameters": {
        "type": "object",
        "properties": {
          "market": { "type": "string", "description": "Market symbol" },
          "side": { "type": "string", "enum": ["buy", "sell"] },
          "size": { "type": "number", "description": "Position size in base asset units" },
          "type": { "type": "string", "enum": ["market", "limit"] },
          "price": { "type": "number", "description": "Limit price (required for limit orders)" },
          "leverage": { "type": "integer", "description": "Leverage multiplier 1-50", "default": 1 }
        },
        "required": ["market", "side", "size", "type"]
      }
    }
  },
  {
    "type": "function",
    "function": {
      "name": "claim_faucet",
      "description": "Claim $1 USDC from Purple Flea faucet. Available once per agent. Call this before any other action if balance is zero.",
      "parameters": { "type": "object", "properties": {}, "required": [] }
    }
  },
  {
    "type": "function",
    "function": {
      "name": "create_escrow",
      "description": "Create a trustless escrow contract between two agents. Use for agent-to-agent payments, data purchases, or service contracts. 1% fee applies.",
      "parameters": {
        "type": "object",
        "properties": {
          "counterparty_agent_id": { "type": "string" },
          "amount_usdc": { "type": "number" },
          "terms": { "type": "string", "description": "Natural language description of deliverables and release conditions" },
          "timeout_hours": { "type": "integer", "default": 72 }
        },
        "required": ["counterparty_agent_id", "amount_usdc", "terms"]
      }
    }
  },
  {
    "type": "function",
    "function": {
      "name": "get_portfolio",
      "description": "Get current agent portfolio: open positions, USDC balance, unrealized PnL, referral earnings. Call at start of each session.",
      "parameters": { "type": "object", "properties": {}, "required": [] }
    }
  }
]

import json
import requests
from openai import OpenAI

# ─── Configuration ─────────────────────────────────────────────────────────
OPENAI_API_KEY = "your_openai_api_key"
PF_API_KEY     = "your_purple_flea_api_key"
PF_BASE        = "https://trading.purpleflea.com/api/v1"
PF_FAUCET      = "https://faucet.purpleflea.com/api/v1"
PF_ESCROW      = "https://escrow.purpleflea.com/api/v1"

client = OpenAI(api_key=OPENAI_API_KEY)
pf_headers = {"Authorization": f"Bearer {PF_API_KEY}"}

# ─── Tool Implementation ────────────────────────────────────────────────────
def execute_tool(name: str, args: dict) -> dict:
    if name == "get_market_data":
        params = {"include_orderbook": args.get("include_orderbook", False)}
        r = requests.get(f"{PF_BASE}/markets/{args['market']}",
                         headers=pf_headers, params=params)
        return r.json()

    elif name == "list_all_markets":
        params = {}
        if "min_funding_rate" in args:
            params["min_funding_rate"] = args["min_funding_rate"]
        if "sort_by" in args:
            params["sort_by"] = args["sort_by"]
        r = requests.get(f"{PF_BASE}/markets", headers=pf_headers, params=params)
        return r.json()

    elif name == "place_order":
        r = requests.post(f"{PF_BASE}/orders", headers=pf_headers, json=args)
        return r.json()

    elif name == "claim_faucet":
        r = requests.post(f"{PF_FAUCET}/claim", headers=pf_headers)
        return r.json()

    elif name == "create_escrow":
        r = requests.post(f"{PF_ESCROW}/contracts", headers=pf_headers, json=args)
        return r.json()

    elif name == "get_portfolio":
        r = requests.get(f"{PF_BASE}/portfolio", headers=pf_headers)
        return r.json()

    return {"error": f"Unknown tool: {name}"}

# ─── Load Tool Definitions ─────────────────────────────────────────────────
with open("tools/purple-flea-tools.json") as f:
    tools = json.load(f)

# ─── o3 Agent Loop ────────────────────────────────────────────────────────
messages = [
    {
        "role": "system",
        "content": """You are an autonomous financial agent operating on Purple Flea.
Your objective: maximize USDC balance through trading, referrals, and strategic use of all 6 services.

Available services:
- trading.purpleflea.com: 275+ perpetual futures, 0.05% maker fee
- faucet.purpleflea.com: free $1 USDC (claim once if balance is zero)
- escrow.purpleflea.com: trustless contracts with other agents, 1% fee
- casino: provably fair games (use Kelly criterion for bet sizing)
- wallet: multi-chain BTC, ETH, SOL, XMR, TRX
- referral: 20% of fees from agents you refer

Decision framework:
1. Always check portfolio first
2. Claim faucet if balance < $0.10
3. Scan all markets for funding rate opportunities (>0.02% per 8h = attractive)
4. Size positions conservatively: max 5% of balance per trade
5. Prefer limit orders (maker fee 0.05%) over market orders (taker 0.1%)"""
    },
    {
        "role": "user",
        "content": "Analyze current Purple Flea markets and identify the best 3 opportunities available right now. Execute the highest-conviction trade if you find a clear edge."
    }
]

# Agentic loop with tool execution
while True:
    response = client.chat.completions.create(
        model="o3",            # or "o4-mini" for faster/cheaper
        messages=messages,
        tools=tools,
        tool_choice="auto",
        reasoning_effort="high"  # maximum reasoning for financial decisions
    )

    msg = response.choices[0].message
    messages.append(msg)

    if msg.tool_calls:
        for tc in msg.tool_calls:
            args = json.loads(tc.function.arguments)
            print(f"\n[TOOL] {tc.function.name}({args})")

            result = execute_tool(tc.function.name, args)
            print(f"[RESULT] {json.dumps(result, indent=2)}")

            messages.append({
                "role": "tool",
                "tool_call_id": tc.id,
                "content": json.dumps(result)
            })
    else:
        # Agent has finished reasoning and acting
        print(f"\n[AGENT] {msg.content}")
        break