1#!/usr/bin/env python3
2"""
3Coinglass ETF Module (Non-Bitcoin)
4 
5Provides ETF data for Ethereum, Solana, XRP, and HK listings.
6"""
7 
8import sys
9import json
10import argparse
11from typing import Dict, Any, Optional, List
12 
13from ._api import cg_request
14 
15 
16def get_eth_etf_flows() -> Optional[List[Dict[str, Any]]]:
17    """Get Ethereum ETF flow history (inflows/outflows)."""
18    return cg_request("api/etf/ethereum/flow-history")
19 
20 
21def get_eth_etf_list() -> Optional[List[Dict[str, Any]]]:
22    """Get list of all Ethereum ETFs with details."""
23    return cg_request("api/etf/ethereum/list")
24 
25 
26def get_eth_etf_premium_discount() -> Optional[List[Dict[str, Any]]]:
27    """Get Ethereum ETF premium/discount history."""
28    return cg_request("api/etf/ethereum/premium-discount/history")
29 
30 
31def get_sol_etf_flows() -> Optional[List[Dict[str, Any]]]:
32    """Get Solana ETF flow history."""
33    return cg_request("api/etf/solana/flow-history")
34 
35 
36def get_sol_etf_list() -> Optional[List[Dict[str, Any]]]:
37    """Get list of all Solana ETFs."""
38    return cg_request("api/etf/solana/list")
39 
40 
41def get_xrp_etf_flows() -> Optional[List[Dict[str, Any]]]:
42    """Get XRP ETF flow history."""
43    return cg_request("api/etf/xrp/flow-history")
44 
45 
46def get_xrp_etf_list() -> Optional[List[Dict[str, Any]]]:
47    """Get list of all XRP ETFs."""
48    return cg_request("api/etf/xrp/list")
49 
50 
51def get_hk_eth_etf_flows() -> Optional[List[Dict[str, Any]]]:
52    """Get Hong Kong Ethereum ETF flows."""
53    return cg_request("api/hk-etf/ethereum/flow-history")
54 
55 
56def main():
57    """CLI entry point."""
58    parser = argparse.ArgumentParser(description="Coinglass ETF Tools")
59    parser.add_argument("action", choices=[
60        "eth-flows", "eth-list", "sol-flows", "xrp-flows"
61    ])
62    parser.add_argument("--json", "-j", action="store_true")
63    args = parser.parse_args()
64 
65    actions = {
66        "eth-flows": get_eth_etf_flows,
67        "eth-list": get_eth_etf_list,
68        "sol-flows": get_sol_etf_flows,
69        "xrp-flows": get_xrp_etf_flows,
70    }
71 
72    try:
73        result = actions[args.action]()
74        print(json.dumps(result, indent=2))
75    except Exception as e:
76        print(f"Error: {e}", file=sys.stderr)
77        sys.exit(1)
78 
79 
80if __name__ == "__main__":
81    main()
82