1#!/usr/bin/env python3
2"""
3CoinGecko Exchanges Tools
4 
5Tools for fetching spot exchange data, tickers, and volume history.
6"""
7 
8import os
9from dotenv import load_dotenv
10import json
11import argparse
12from typing import Dict, Any, Optional
13 
14from core.http_client import proxied_get
15 
16# Load environment variables
17load_dotenv()
18 
19 
20def get_api_key() -> str:
21    """Get CoinGecko API key from environment."""
22    api_key = os.getenv("COINGECKO_API_KEY")
23    if not api_key:
24        raise ValueError("COINGECKO_API_KEY environment variable is required")
25    return api_key
26 
27 
28def get_exchanges(
29    per_page: int = 100,
30    page: int = 1
31) -> Dict[str, Any]:
32    """
33    Get all spot exchanges with volumes and trust scores.
34 
35    Args:
36        per_page: Results per page (max 250)
37        page: Page number
38 
39    Returns:
40        Dictionary with list of exchanges
41    """
42    api_key = get_api_key()
43 
44    url = "https://pro-api.coingecko.com/api/v3/exchanges"
45    headers = {"x-cg-pro-api-key": api_key}
46    params = {
47        "per_page": min(per_page, 250),
48        "page": page
49    }
50 
51    response = proxied_get(url, headers=headers, params=params, timeout=30)
52    response.raise_for_status()
53    data = response.json()
54 
55    exchanges = []
56    for exchange in data:
57        exchanges.append({
58            "id": exchange.get("id", ""),
59            "name": exchange.get("name", ""),
60            "year_established": exchange.get("year_established"),
61            "country": exchange.get("country"),
62            "description": exchange.get("description"),
63            "url": exchange.get("url"),
64            "image": exchange.get("image"),
65            "has_trading_incentive": exchange.get("has_trading_incentive"),
66            "trust_score": exchange.get("trust_score"),
67            "trust_score_rank": exchange.get("trust_score_rank"),
68            "trade_volume_24h_btc": exchange.get("trade_volume_24h_btc"),
69            "trade_volume_24h_btc_normalized": exchange.get("trade_volume_24h_btc_normalized")
70        })
71 
72    return {
73        "exchanges": exchanges,
74        "count": len(exchanges),
75        "page": page,
76        "per_page": per_page
77    }
78 
79 
80def get_exchange(exchange_id: str) -> Dict[str, Any]:
81    """
82    Get detailed exchange data including tickers and BTC volume.
83 
84    Args:
85        exchange_id: CoinGecko exchange id (e.g., binance, coinbase-exchange)
86 
87    Returns:
88        Dictionary with detailed exchange data
89    """
90    api_key = get_api_key()
91 
92    url = f"https://pro-api.coingecko.com/api/v3/exchanges/{exchange_id}"
93    headers = {"x-cg-pro-api-key": api_key}
94 
95    response = proxied_get(url, headers=headers, timeout=30)
96    response.raise_for_status()
97    data = response.json()
98 
99    result = {
100        "id": data.get("id", ""),
101        "name": data.get("name", ""),
102        "year_established": data.get("year_established"),
103        "country": data.get("country"),
104        "description": data.get("description"),
105        "url": data.get("url"),
106        "image": data.get("image"),
107        "facebook_url": data.get("facebook_url"),
108        "reddit_url": data.get("reddit_url"),
109        "telegram_url": data.get("telegram_url"),
110        "slack_url": data.get("slack_url"),
111        "other_url_1": data.get("other_url_1"),
112        "other_url_2": data.get("other_url_2"),
113        "twitter_handle": data.get("twitter_handle"),
114        "has_trading_incentive": data.get("has_trading_incentive"),
115        "centralized": data.get("centralized"),
116        "public_notice": data.get("public_notice"),
117        "alert_notice": data.get("alert_notice"),
118        "trust_score": data.get("trust_score"),
119        "trust_score_rank": data.get("trust_score_rank"),
120        "trade_volume_24h_btc": data.get("trade_volume_24h_btc"),
121        "trade_volume_24h_btc_normalized": data.get("trade_volume_24h_btc_normalized"),
122        "tickers_count": len(data.get("tickers", []))
123    }
124 
125    # Include sample tickers (first 10)
126    tickers = data.get("tickers", [])[:10]
127    result["sample_tickers"] = [
128        {
129            "base": t.get("base", ""),
130            "target": t.get("target", ""),
131            "last": t.get("last"),
132            "volume": t.get("volume"),
133            "trust_score": t.get("trust_score"),
134            "bid_ask_spread_percentage": t.get("bid_ask_spread_percentage")
135        }
136        for t in tickers
137    ]
138 
139    return result
140 
141 
142def get_exchange_tickers(
143    exchange_id: str,
144    coin_ids: Optional[str] = None,
145    include_exchange_logo: bool = False,
146    page: int = 1,
147    order: str = "volume_desc",
148    depth: bool = False
149) -> Dict[str, Any]:
150    """
151    Get all trading pairs on an exchange.
152 
153    Args:
154        exchange_id: CoinGecko exchange id
155        coin_ids: Comma-separated coin ids to filter
156        include_exchange_logo: Include exchange logo
157        page: Page number
158        order: Sort order (trust_score_desc, trust_score_asc, volume_desc, volume_asc)
159        depth: Include order book depth
160 
161    Returns:
162        Dictionary with exchange tickers
163    """
164    api_key = get_api_key()
165 
166    url = f"https://pro-api.coingecko.com/api/v3/exchanges/{exchange_id}/tickers"
167    headers = {"x-cg-pro-api-key": api_key}
168    params = {
169        "include_exchange_logo": str(include_exchange_logo).lower(),
170        "page": page,
171        "order": order,
172        "depth": str(depth).lower()
173    }
174    if coin_ids:
175        params["coin_ids"] = coin_ids
176 
177    response = proxied_get(url, headers=headers, params=params, timeout=30)
178    response.raise_for_status()
179    data = response.json()
180 
181    tickers = []
182    for ticker in data.get("tickers", []):
183        ticker_data = {
184            "base": ticker.get("base", ""),
185            "target": ticker.get("target", ""),
186            "coin_id": ticker.get("coin_id"),
187            "target_coin_id": ticker.get("target_coin_id"),
188            "last": ticker.get("last"),
189            "volume": ticker.get("volume"),
190            "converted_last": ticker.get("converted_last", {}),
191            "converted_volume": ticker.get("converted_volume", {}),
192            "trust_score": ticker.get("trust_score"),
193            "bid_ask_spread_percentage": ticker.get("bid_ask_spread_percentage"),
194            "timestamp": ticker.get("timestamp"),
195            "last_traded_at": ticker.get("last_traded_at"),
196            "last_fetch_at": ticker.get("last_fetch_at"),
197            "is_anomaly": ticker.get("is_anomaly"),
198            "is_stale": ticker.get("is_stale"),
199            "trade_url": ticker.get("trade_url")
200        }
201        if depth:
202            ticker_data["cost_to_move_up_usd"] = ticker.get("cost_to_move_up_usd")
203            ticker_data["cost_to_move_down_usd"] = ticker.get("cost_to_move_down_usd")
204        tickers.append(ticker_data)
205 
206    return {
207        "name": data.get("name", ""),
208        "tickers": tickers,
209        "count": len(tickers),
210        "page": page
211    }
212 
213 
214def get_exchange_volume_chart(
215    exchange_id: str,
216    days: int = 30
217) -> Dict[str, Any]:
218    """
219    Get historical volume chart for an exchange.
220 
221    Args:
222        exchange_id: CoinGecko exchange id
223        days: Number of days (1, 7, 14, 30, 90, 180, 365)
224 
225    Returns:
226        Dictionary with volume history data
227    """
228    api_key = get_api_key()
229 
230    url = f"https://pro-api.coingecko.com/api/v3/exchanges/{exchange_id}/volume_chart"
231    headers = {"x-cg-pro-api-key": api_key}
232    params = {"days": days}
233 
234    response = proxied_get(url, headers=headers, params=params, timeout=30)
235    response.raise_for_status()
236    data = response.json()
237 
238    # Data is array of [timestamp, volume_btc]
239    volume_data = []
240    for item in data:
241        if isinstance(item, list) and len(item) >= 2:
242            volume_data.append({
243                "timestamp": item[0],
244                "volume_btc": item[1]
245            })
246 
247    return {
248        "exchange_id": exchange_id,
249        "days": days,
250        "volume_history": volume_data,
251        "count": len(volume_data)
252    }
253 
254 
255def main():
256    """CLI interface for exchanges tools."""
257    parser = argparse.ArgumentParser(
258        description="CoinGecko Exchanges Tools",
259        formatter_class=argparse.RawDescriptionHelpFormatter
260    )
261 
262    subparsers = parser.add_subparsers(dest="command")
263 
264    # List command
265    list_parser = subparsers.add_parser("list", help="Get all exchanges")
266    list_parser.add_argument("--per-page", type=int, default=100)
267    list_parser.add_argument("--page", type=int, default=1)
268 
269    # Exchange command
270    exch_parser = subparsers.add_parser("get", help="Get exchange details")
271    exch_parser.add_argument("exchange_id", help="Exchange ID")
272 
273    # Tickers command
274    tickers_parser = subparsers.add_parser("tickers", help="Get exchange tickers")
275    tickers_parser.add_argument("exchange_id", help="Exchange ID")
276    tickers_parser.add_argument("--coins", help="Filter by coin ids")
277    tickers_parser.add_argument("--page", type=int, default=1)
278    tickers_parser.add_argument("--order", default="volume_desc")
279 
280    # Volume chart command
281    chart_parser = subparsers.add_parser("volume-chart", help="Get exchange volume history")
282    chart_parser.add_argument("exchange_id", help="Exchange ID")
283    chart_parser.add_argument("--days", type=int, default=30)
284 
285    args = parser.parse_args()
286 
287    try:
288        if args.command == "list":
289            result = get_exchanges(args.per_page, args.page)
290        elif args.command == "get":
291            result = get_exchange(args.exchange_id)
292        elif args.command == "tickers":
293            result = get_exchange_tickers(
294                exchange_id=args.exchange_id,
295                coin_ids=args.coins,
296                page=args.page,
297                order=args.order
298            )
299        elif args.command == "volume-chart":
300            result = get_exchange_volume_chart(args.exchange_id, args.days)
301        else:
302            parser.print_help()
303            return 0
304 
305        print(json.dumps(result, indent=2, ensure_ascii=False))
306        return 0
307 
308    except Exception as e:
309        print(json.dumps({"error": str(e)}, indent=2))
310        return 1
311 
312 
313if __name__ == "__main__":
314    exit(main())
315