1#!/usr/bin/env python3
2"""
3Coinglass Liquidations Module
4 
5Provides liquidation data across exchanges: individual liquidations
6and aggregated (long/short) liquidation summaries.
7"""
8 
9import sys
10import json
11import argparse
12from typing import Dict, Any, Optional
13 
14from ._api import cg_request
15 
16 
17def get_liquidations(
18    symbol: str = "BTC",
19    time_type: str = "h24"
20) -> Optional[Dict[str, Any]]:
21    """
22    Get liquidation data across exchanges.
23 
24    Args:
25        symbol: Coin symbol (BTC, ETH, SOL, etc.)
26        time_type: Time window (h1, h4, h12, h24).
27 
28    Returns:
29        Dict with liquidation data: long/short amounts, counts.
30 
31    Raises:
32        CoinglassError: On API failure.
33    """
34    # Map h-format to API format
35    range_map = {"h1": "1h", "h4": "4h", "h12": "12h", "h24": "24h"}
36    v4_range = range_map.get(time_type, time_type)
37    params = {"symbol": symbol.upper(), "range": v4_range}
38    return cg_request(
39        "api/futures/liquidation/exchange-list", params=params
40    )
41 
42 
43def get_liquidation_aggregated(
44    symbol: str = "BTC",
45    time_type: str = "h24"
46) -> Optional[Dict[str, Any]]:
47    """
48    Get aggregated liquidation summary (total longs vs shorts).
49 
50    Args:
51        symbol: Coin symbol.
52        interval: Time interval.
53 
54    Returns:
55        Dict with total long/short liquidations and ratio.
56    """
57    data = get_liquidations(symbol, time_type)
58    if not data:
59        return None
60 
61    # Aggregate across exchanges
62    entries = data if isinstance(data, list) else [data]
63    total_long = 0
64    total_short = 0
65    for entry in entries:
66        total_long += entry.get("longLiquidationUsd", 0) or 0
67        total_short += entry.get("shortLiquidationUsd", 0) or 0
68 
69    total = total_long + total_short
70    return {
71        "symbol": symbol.upper(),
72        "interval": time_type,
73        "total_long_usd": total_long,
74        "total_short_usd": total_short,
75        "total_usd": total,
76        "long_ratio": total_long / total if total else 0,
77        "short_ratio": total_short / total if total else 0,
78        "dominant": "long" if total_long > total_short else "short",
79    }
80 
81 
82def main():
83    """CLI entry point."""
84    parser = argparse.ArgumentParser(
85        description="Coinglass Liquidation Tools"
86    )
87    parser.add_argument("--symbol", "-s", default="BTC")
88    parser.add_argument("--interval", "-i", default="h4")
89    parser.add_argument("--exchange", "-e", default=None)
90    parser.add_argument("--aggregated", "-a", action="store_true",
91                        help="Show aggregated summary")
92    args = parser.parse_args()
93 
94    try:
95        if args.aggregated:
96            result = get_liquidation_aggregated(
97                args.symbol, args.interval
98            )
99        else:
100            result = get_liquidations(
101                args.symbol, args.interval
102            )
103 
104        if result:
105            print(json.dumps(result, indent=2))
106        else:
107            print("No data found", file=sys.stderr)
108    except Exception as e:
109        print(f"Error: {e}", file=sys.stderr)
110        sys.exit(1)
111 
112 
113if __name__ == "__main__":
114    main()
115