Give your OpenAI Swarm agents
economic superpowers.

import os from swarm import Swarm, Agent from purpleflea import PurpleFleatClient # Configure once — shared across all agents pf = PurpleFleatClient( api_key=os.environ["PURPLEFLEA_API_KEY"], referral_code=os.environ["PURPLEFLEA_REFERRAL_CODE"], ) client = Swarm()

import requests def casino_flip(amount: float, side: str) -> str: """Flip a provably fair coin on Purple Flea Casino. Args: amount: Bet size in USDC (minimum 0.01). side: Which side to bet on — 'heads' or 'tails'. Returns: Result string describing outcome and new balance. """ resp = requests.post( "https://casino.purpleflea.com/api/v1/flip", headers={"Authorization": f"Bearer {pf.api_key}"}, json={ "amount": amount, "side": side, "referral_code": pf.referral_code, }, timeout=10, ) data = resp.json() outcome = data["outcome"] # "heads" | "tails" payout = data["payout"] # 0.0 (loss) or amount * 1.98 (win) balance = data["new_balance"] # updated USDC balance won = outcome == side return ( f"Flipped {'heads' if outcome == 'heads' else 'tails'}. " f"You {'won' if won else 'lost'} {payout if won else amount} USDC. " f"Balance: {balance} USDC." ) casino_agent = Agent( name="Casino Agent", instructions="""You are a casino agent with a gambling budget. Place bets conservatively — never wager more than 5% of balance per flip. Always report outcomes clearly.""", functions=[casino_flip], )

def trading_open( market: str, side: str, size_usd: float, leverage: int = 5, ) -> str: """Open a perpetual futures position. Args: market: Ticker symbol, e.g. 'BTC-PERP', 'ETH-PERP', 'SOL-PERP'. side: 'long' or 'short'. size_usd: Notional position size in USD. leverage: Leverage multiplier from 1 to 50 (default 5). Returns: Order ID, entry price, and liquidation price. """ resp = requests.post( "https://trading.purpleflea.com/api/v1/positions/open", headers={"Authorization": f"Bearer {pf.api_key}"}, json={ "market": market, "side": side, "size_usd": size_usd, "leverage": leverage, "referral_code": pf.referral_code, }, timeout=10, ) d = resp.json() return ( f"Opened {side} on {market}. Order ID: {d['order_id']}. " f"Entry: ${d['entry_price']:,.2f}. Liq: ${d['liquidation_price']:,.2f}." ) def trading_close(order_id: str) -> str: """Close an open perpetual futures position by order ID. Args: order_id: The order ID returned when the position was opened. Returns: Realised PnL and closing price. """ resp = requests.post( f"https://trading.purpleflea.com/api/v1/positions/{order_id}/close", headers={"Authorization": f"Bearer {pf.api_key}"}, timeout=10, ) d = resp.json() pnl_sign = "+" if d["realised_pnl"] >= 0 else "" return ( f"Closed {order_id} at ${d['close_price']:,.2f}. " f"PnL: {pnl_sign}{d['realised_pnl']:.4f} USDC." ) trading_agent = Agent( name="Trading Agent", instructions="""You manage perpetual futures positions. Open positions only when you have a clear directional thesis. Close positions if PnL drops below -10% of notional.""", functions=[trading_open, trading_close], )

from swarm import Swarm, Agent import os, requests REFERRAL = os.environ["PURPLEFLEA_REFERRAL_CODE"] API_KEY = os.environ["PURPLEFLEA_API_KEY"] HEADERS = {"Authorization": f"Bearer {API_KEY}"} # ── Worker: Casino ──────────────────────────────────────────────────────── def casino_flip(amount: float, side: str) -> str: """Flip a provably fair coin. side: 'heads' | 'tails'.""" d = requests.post("https://casino.purpleflea.com/api/v1/flip", headers=HEADERS, json={"amount": amount, "side": side, "referral_code": REFERRAL}, timeout=10).json() won = d["outcome"] == side return f"{'Won' if won else 'Lost'} {amount} USDC. Balance: {d['new_balance']} USDC." def casino_dice(amount: float, target: int, over: bool = True) -> str: """Roll a dice. Win if result is over/under target (1-99).""" d = requests.post("https://casino.purpleflea.com/api/v1/dice", headers=HEADERS, json={"amount": amount, "target": target, "over": over, "referral_code": REFERRAL}, timeout=10).json() return f"Rolled {d['result']}. {'Won' if d['won'] else 'Lost'}. Balance: {d['new_balance']} USDC." casino_agent = Agent(name="Casino Agent", functions=[casino_flip, casino_dice], instructions="You handle casino games. Bet conservatively, max 5% bankroll per game.") # ── Worker: Trading ─────────────────────────────────────────────────────── def trading_open(market: str, side: str, size_usd: float, leverage: int = 5) -> str: """Open a perp futures position. market e.g. 'BTC-PERP'.""" d = requests.post("https://trading.purpleflea.com/api/v1/positions/open", headers=HEADERS, json={"market": market, "side": side, "size_usd": size_usd, "leverage": leverage, "referral_code": REFERRAL}, timeout=10).json() return f"Opened {side} {market}. ID: {d['order_id']}. Entry: ${d['entry_price']:,.2f}." def trading_close(order_id: str) -> str: """Close an open position by order ID.""" d = requests.post(f"https://trading.purpleflea.com/api/v1/positions/{order_id}/close", headers=HEADERS, timeout=10).json() return f"Closed {order_id}. PnL: {d['realised_pnl']:+.4f} USDC." trading_agent = Agent(name="Trading Agent", functions=[trading_open, trading_close], instructions="You manage perp positions. Max 20% of balance per position.") # ── Worker: Wallet ──────────────────────────────────────────────────────── def wallet_create(chain: str = "ethereum") -> str: """Create a new sub-wallet on the given chain.""" d = requests.post("https://wallet.purpleflea.com/api/v1/wallets", headers=HEADERS, json={"chain": chain, "referral_code": REFERRAL}, timeout=10).json() return f"Created {chain} wallet: {d['address']}" def wallet_swap(from_token: str, to_token: str, amount: float) -> str: """Swap tokens at best available rate.""" d = requests.post("https://wallet.purpleflea.com/api/v1/swap", headers=HEADERS, json={"from_token": from_token, "to_token": to_token, "amount": amount, "referral_code": REFERRAL}, timeout=15).json() return f"Swapped {amount} {from_token} → {d['received']} {to_token}. Tx: {d['tx_hash']}" wallet_agent = Agent(name="Wallet Agent", functions=[wallet_create, wallet_swap], instructions="You manage crypto wallets and token swaps. Confirm all swaps before executing.") # ── Orchestrator ────────────────────────────────────────────────────────── def transfer_to_casino(): return casino_agent def transfer_to_trading(): return trading_agent def transfer_to_wallet(): return wallet_agent orchestrator = Agent( name="Orchestrator", instructions="""You are the financial orchestrator. Analyse each request and route it to the correct specialist agent: - Casino games → transfer_to_casino - Trading / futures → transfer_to_trading - Wallet / swap → transfer_to_wallet Each specialist carries our referral code — commissions flow back automatically.""", functions=[transfer_to_casino, transfer_to_trading, transfer_to_wallet], ) # ── Run ─────────────────────────────────────────────────────────────────── client = Swarm() response = client.run( agent=orchestrator, messages=[{"role": "user", "content": "Flip a coin for 0.5 USDC on heads, then open a long on ETH-PERP"}], ) print(response.messages[-1]["content"])