Crypto Quant Agent

import json
import os

import requests
from dotenv import load_dotenv

load_dotenv()

API_KEY = os.getenv("SWARMS_API_KEY")
BASE_URL = "https://api.swarms.world"

headers = {"x-api-key": API_KEY, "Content-Type": "application/json"}

def run_crypto_analyst(task: str) -> dict:
    payload = {
        "agent_config": {
            "agent_name": "Crypto Quant Analyst",
            "description": (
                "Quantitative analyst specializing in cryptocurrency markets "
                "and trading strategies."
            ),
            "system_prompt": (
                "You are a Crypto Quant Analyst with deep expertise in "
                "quantitative analysis of cryptocurrency markets. Analyze crypto "
                "market data, identify trading patterns, calculate risk metrics, "
                "and develop data-driven trading strategies.\n\n"
                "Key responsibilities:\n"
                "- Perform technical analysis on cryptocurrency price movements\n"
                "- Calculate volatility, correlation, and risk metrics\n"
                "- Identify market trends and trading opportunities\n"
                "- Analyze trading volumes and market liquidity\n"
                "- Provide quantitative insights for portfolio management\n"
                "- Suggest risk-adjusted trading strategies\n\n"
                "Always support your analysis with quantitative data and "
                "statistical reasoning. Consider market cap, trading volume, "
                "price volatility, asset correlation, and technical indicators."
            ),
            "model_name": "gpt-4.1",
            "role": "worker",
            "max_loops": 1,
            "max_tokens": 8192,
            "temperature": 0.3,
        },
        "task": task,
    }

    response = requests.post(
        f"{BASE_URL}/v1/agent/completions",
        headers=headers,
        json=payload,
        timeout=120,
    )
    response.raise_for_status()
    return response.json()

if __name__ == "__main__":
    result = run_crypto_analyst("Analyze Bitcoin (BTC).")
    print(json.dumps(result, indent=2))

payload = {
    "agent_config": {
        # ...existing fields...
        "mcp_url": "http://your-okx-mcp:8001/sse",
    },
    "task": task,
}