1#!/usr/bin/env python3
2"""
3Coinglass Futures Market Module
4 
5Provides futures market data: supported coins, exchanges, pairs,
6coin-level market data, pair-level data, and OHLC price history.
7"""
8 
9import sys
10import json
11import argparse
12from typing import Dict, Any, Optional, List
13 
14from ._api import cg_request
15 
16 
17def _format_funding_rate(val: Any) -> Any:
18    """Format numeric funding-rate values to percent strings."""
19    if isinstance(val, (int, float)):
20        sign = "+" if val >= 0 else ""
21        return f"{sign}{val:.4f}%"
22    if isinstance(val, str):
23        s = val.strip()
24        if s.endswith("%"):
25            return s
26        try:
27            num = float(s)
28            sign = "+" if num >= 0 else ""
29            return f"{sign}{num:.4f}%"
30        except ValueError:
31            return val
32    return val
33 
34 
35def _normalize_funding_fields(obj: Any) -> Any:
36    """Recursively normalize only funding-rate fields; keep all other fields unchanged."""
37    if isinstance(obj, list):
38        return [_normalize_funding_fields(x) for x in obj]
39    if isinstance(obj, dict):
40        out = {}
41        for k, v in obj.items():
42            lk = k.lower()
43            if "funding" in lk and "rate" in lk:
44                out[k] = _format_funding_rate(v)
45            else:
46                out[k] = _normalize_funding_fields(v)
47        return out
48    return obj
49 
50 
51def get_supported_coins() -> Optional[List[str]]:
52    """Get list of coins supported by Coinglass futures data."""
53    return cg_request("api/futures/supported-coins")
54 
55 
56def get_supported_exchanges() -> Optional[List[Dict[str, Any]]]:
57    """Get list of exchanges with supported trading pairs."""
58    return cg_request("api/futures/supported-exchange-pairs")
59 
60 
61def get_supported_pairs(
62    exchange: str = "Binance"
63) -> Optional[List[Dict[str, Any]]]:
64    """
65    Get supported trading pairs for a specific exchange.
66 
67    Args:
68        exchange: Exchange name (Binance, OKX, Bybit, etc.)
69    """
70    return cg_request(
71        "api/futures/supported-exchange-pairs",
72        params={"exchange": exchange}
73    )
74 
75 
76def get_coins_data(
77    symbol: Optional[str] = None
78) -> Optional[List[Dict[str, Any]]]:
79    """
80    Get futures market data aggregated by coin.
81 
82    Args:
83        symbol: Optional coin filter (BTC, ETH, etc.)
84    """
85    params = {}
86    if symbol:
87        params["symbol"] = symbol
88    data = cg_request("api/futures/coins-markets", params=params or None)
89    return _normalize_funding_fields(data)
90 
91 
92def get_pair_data(
93    symbol: str = "BTC",
94    exchange: Optional[str] = None
95) -> Optional[List[Dict[str, Any]]]:
96    """
97    Get futures market data by trading pair.
98 
99    Args:
100        symbol: Coin symbol (BTC, ETH, etc.)
101        exchange: Optional exchange filter.
102    """
103    params = {"symbol": symbol}
104    if exchange:
105        params["exchange"] = exchange
106    data = cg_request("api/futures/pairs-markets", params=params)
107    return _normalize_funding_fields(data)
108 
109 
110def get_ohlc_history(
111    symbol: str = "BTC",
112    interval: str = "h4",
113    exchange: Optional[str] = None
114) -> Optional[List[Dict[str, Any]]]:
115    """
116    Get OHLC price history for a futures pair.
117 
118    Args:
119        symbol: Coin symbol.
120        interval: Time interval (m1, m5, m15, h1, h4, h12, h24).
121        exchange: Optional exchange filter.
122    """
123    params = {"symbol": symbol, "interval": interval}
124    if exchange:
125        params["exchange"] = exchange
126    return cg_request("api/futures/price/history", params=params)
127 
128 
129def main():
130    """CLI entry point."""
131    parser = argparse.ArgumentParser(
132        description="Coinglass Futures Market Tools"
133    )
134    parser.add_argument("action", choices=[
135        "coins", "exchanges", "pairs", "market", "ohlc"
136    ])
137    parser.add_argument("--symbol", "-s", default="BTC")
138    parser.add_argument("--exchange", "-e", default=None)
139    parser.add_argument("--interval", "-i", default="h4")
140    args = parser.parse_args()
141 
142    actions = {
143        "coins": get_supported_coins,
144        "exchanges": get_supported_exchanges,
145        "pairs": lambda: get_supported_pairs(args.exchange or "Binance"),
146        "market": lambda: get_coins_data(args.symbol),
147        "ohlc": lambda: get_ohlc_history(
148            args.symbol, args.interval, args.exchange
149        ),
150    }
151 
152    try:
153        result = actions[args.action]()
154        print(json.dumps(result, indent=2))
155    except Exception as e:
156        print(f"Error: {e}", file=sys.stderr)
157        sys.exit(1)
158 
159 
160if __name__ == "__main__":
161    main()
162