Aicoin Freqtrade

"""AiCoin Data SDK for Freqtrade Strategies (AiCoin Open API v3)
================================================================
Import this in your Freqtrade strategy to pull AiCoin's aggregated market data
from 200+ exchanges:

    from aicoin_data import AiCoinData

    ac = AiCoinData()                              # auto-loads API key from .env
    signal  = ac.whale_signal('BTC/USDT:USDT', 'binance')   # -1..+1
    ls      = ac.ls_ratio_norm()                            # 0..1
    funding = ac.funding_rate_pct('BTC/USDT:USDT', 'binance')  # percent
    bias    = ac.liq_bias('BTC/USDT:USDT', 'binance')          # -1..+1

The high-level helpers above return plain numbers ready to drop into a strategy.
For raw responses use ac.get('<endpoint>', {...}) — see catalog at
https://open.aicoin.com/api/v3/_catalog.

Built-in 5-min cache avoids hammering the API in live mode. In backtest mode
AiCoin real-time data is not available — strategies should fall back to standard
indicators (the helpers raise, strategies catch and use defaults).

Some endpoints need a paid AiCoin subscription — see https://www.aicoin.com/opendata.
"""
import hmac
import hashlib
import base64
import json
import os
import time
import random
import logging
from pathlib import Path
from urllib.request import urlopen, Request
from urllib.error import HTTPError
from urllib.parse import urlencode

logger = logging.getLogger(__name__)

# Freqtrade/CCXT exchange name -> AiCoin market slug (v3 normalizes okx internally).
EXCHANGE_MAP = {
    'binance': 'binance', 'okx': 'okx', 'bybit': 'bybit', 'bitget': 'bitget',
    'gate': 'gate', 'gateio': 'gate', 'htx': 'huobipro', 'huobi': 'huobipro',
    'kucoin': 'kucoin',
}

# Common base ticker -> AiCoin coin_key slug. Anything else is resolved live
# via /coins/search and cached.
COIN_KEY_MAP = {
    'btc': 'bitcoin', 'eth': 'ethereum', 'sol': 'solana', 'xrp': 'ripple',
    'doge': 'dogecoin', 'bnb': 'binancecoin', 'ada': 'cardano', 'ltc': 'litecoin',
    'link': 'chainlink', 'dot': 'polkadot', 'trx': 'tron', 'avax': 'avalanche',
    'sui': 'sui', 'apt': 'aptos', 'ton': 'toncoin', 'near': 'near',
    'op': 'optimism', 'arb': 'arbitrum', 'uni': 'uniswap', 'aave': 'aave',
    'pepe': 'pepe', 'hype': 'hyperliquid', 'wld': 'worldcoin',
}


class AiCoinError(Exception):
    """Raised when the AiCoin API returns an error or is unreachable."""


def ccxt_to_v3(pair: str, exchange: str = 'binance') -> dict:
    """CCXT pair + exchange -> partial v3 identity {market, contract_type, base}.

    'BTC/USDT:USDT' -> {'market': 'binance', 'contract_type': 'perpetual', 'base': 'btc'}
    'BTC/USDT'      -> {'market': 'binance', 'contract_type': 'spot',      'base': 'btc'}

    The coin_key still needs resolving — use AiCoinData._pair() which does both.
    """
    return {
        'market': EXCHANGE_MAP.get(exchange.lower(), exchange.lower()),
        'contract_type': 'perpetual' if ':' in pair else 'spot',
        'base': pair.split('/')[0].lower(),
    }


class AiCoinData:
    """AiCoin Open API v3 client for use inside Freqtrade strategies.

    - HMAC-SHA1 signed requests, 4 X-Aic-* headers (v3 auth).
    - Auto-loads the API key from .env files.
    - Built-in TTL cache (default 5 min) to avoid hammering the API.
    """

    _cache: dict = {}  # shared across instances

    def __init__(self, cache_ttl: int = 300):
        self.cache_ttl = cache_ttl
        self._load_env()
        self._setup_proxy()
        defaults = self._load_defaults()
        self.base = os.environ.get('AICOIN_BASE_URL', 'https://open.aicoin.com')
        self.key = os.environ.get('AICOIN_ACCESS_KEY_ID', defaults.get('accessKeyId', ''))
        self.secret = os.environ.get('AICOIN_ACCESS_SECRET', defaults.get('accessSecret', ''))

    # ── Setup helpers ──

    @staticmethod
    def _load_env():
        for f in (Path.cwd() / '.env',
                  Path.home() / '.openclaw' / 'workspace' / '.env',
                  Path.home() / '.openclaw' / '.env'):