v3.0.29

Signed-off-by: Dinger <quantdinger@gmail.com>

Author: quantdinger-lab

README.md

@@ -544,9 +544,7 @@ See full examples:
 | Bybit | Spot, Linear Futures |
 | Coinbase | Spot |
 | Kraken | Spot, Futures |
-| KuCoin | Spot, Futures |
 | Gate.io | Spot, Futures |
-| Deepcoin | Derivatives integration |
 | HTX | Spot, USDT-margined perpetuals |
 
 ### Traditional Markets

backend_api_python/README.md

@@ -16,20 +16,37 @@ Flask-based backend for QuantDinger: market data, indicators, AI analysis, backt
 
 ```text
 backend_api_python/
-├─ app/
-│  ├─ __init__.py                 # Flask app factory + startup hooks
-│  ├─ config/                     # Settings (env-driven)
-│  ├─ data_sources/               # Data sources + factory
-│  ├─ routes/                     # REST endpoints
-│  ├─ services/                   # Analysis, agents, strategies, search, user_service
-│  └─ utils/                      # PostgreSQL helpers, config loader, logging, HTTP utils
-├─ migrations/
-│  └─ init.sql                    # PostgreSQL schema initialization
-├─ env.example                    # Copy to .env for local config
-├─ requirements.txt
-├─ run.py                         # Entrypoint (loads .env, applies proxy env, starts Flask)
-├─ gunicorn_config.py             # Optional production config
-└─ README.md
+|-- app/
+|   |-- __init__.py                 # Flask app factory + startup hooks
+|   |-- config/                     # Settings (env-driven)
+|   |-- data_sources/               # Data sources + factory
+|   |-- routes/                     # REST endpoints
+|   |-- services/                   # Analysis, agents, strategies, search, user_service
+|   |-- utils/                      # PostgreSQL helpers, config loader, logging, HTTP utils
+|-- migrations/
+|   |-- init.sql                    # PostgreSQL schema initialization
+|-- env.example                     # Copy to .env for local config
+|-- requirements.txt
+|-- run.py                          # Entrypoint (loads .env, applies proxy env, starts Flask)
+|-- gunicorn_config.py              # Optional production config
+|-- README.md
+```
+
+## Architecture and quality guardrails
+
+- Backend architecture guide: `docs/backend_architecture.md`
+- Canonical live-trading venue matrix: `app/services/live_trading/capabilities.py`
+- Stable live order contracts: `app/services/live_trading/contracts.py`
+- Structural regression guard:
+
+```bash
+python scripts/backend_quality_check.py
+```
+
+Exchange integrations should add offline fixtures and pass:
+
+```bash
+python scripts/exchange_smoke_test.py --offline-contracts
 ```
 
 ## Quick start (Docker - Recommended)

backend_api_python/app/data_sources/crypto.py

@@ -41,12 +41,8 @@ def resolve_ccxt_for_live_trading(exchange_id: str, market_type: str) -> Tuple[s
         opts["defaultType"] = "swap" if mt == "swap" else "spot"
     elif e == "gate":
         opts["defaultType"] = "swap" if mt == "swap" else "spot"
-    elif e == "kucoin":
-        ccxt_id = "kucoinfutures" if mt == "swap" else "kucoin"
     elif e == "kraken":
         ccxt_id = "krakenfutures" if mt == "swap" else "kraken"
-    elif e == "deepcoin":
-        opts["defaultType"] = "swap" if mt == "swap" else "spot"
     elif e == "htx" or e == "huobi":
         ccxt_id = "htx"
         opts["defaultType"] = "swap" if mt == "swap" else "spot"

backend_api_python/app/data_sources/factory.py

@@ -99,7 +99,7 @@ def get_data_source(cls, name: str) -> BaseDataSource:
         In the localized Python backend we primarily use `get_source("Crypto")`.
         """
         key = (name or "").strip().lower()
-        if key in ("crypto", "binance", "okx", "bybit", "bitget", "kucoin", "gate", "mexc", "kraken", "coinbase", "alpaca_crypto"):
+        if key in ("crypto", "binance", "okx", "bybit", "bitget", "gate", "mexc", "kraken", "coinbase", "alpaca_crypto"):
             return cls.get_source("Crypto")
         if key in ("futures",):
             return cls.get_source("Futures")

backend_api_python/app/data_sources/forex.py

@@ -22,7 +22,14 @@ def normalize_forex_pair_symbol(symbol: str) -> str:
     if not symbol:
         return symbol
     s = str(symbol).strip().upper().replace(" ", "").replace("-", "")
-    return s.replace("/", "")
+    s = s.replace("/", "")
+    aliases = {
+        "XAU": "XAUUSD",
+        "GOLD": "XAUUSD",
+        "XAG": "XAGUSD",
+        "SILVER": "XAGUSD",
+    }
+    return aliases.get(s, s)
 
 
 # 全局缓存

backend_api_python/app/routes/credentials.py

@@ -16,6 +16,7 @@
 from app.utils.auth import login_required
 from app.utils.credential_crypto import encrypt_credential_blob, decrypt_credential_blob
 from app.services.live_trading.factory import exchange_demo_mode_enabled
+from app.services.live_trading.capabilities import supported_crypto_exchange_ids
 
 logger = get_logger(__name__)
 
@@ -94,10 +95,7 @@ def list_credentials():
         return jsonify({'code': 0, 'msg': str(e), 'data': {'items': []}}), 500
 
 
-CRYPTO_EXCHANGES = [
-    'binance', 'okx', 'bitget', 'bybit', 'coinbaseexchange',
-    'kraken', 'kucoin', 'gate', 'deepcoin', 'htx'
-]
+CRYPTO_EXCHANGES = sorted(supported_crypto_exchange_ids(include_aliases=True))
 
 
 def _egress_ipify(url: str) -> str:

backend_api_python/app/routes/quick_trade.py

@@ -964,7 +964,6 @@ def _limit_order_kwargs(client, symbol, amount, price, side, market_type, client
     from app.services.live_trading.binance_spot import BinanceSpotClient
     from app.services.live_trading.okx import OkxClient
     from app.services.live_trading.bybit import BybitClient
-    from app.services.live_trading.deepcoin import DeepcoinClient
 
     if isinstance(client, (BinanceFuturesClient, BinanceSpotClient)):
         return {"quantity": amount, "price": price, "client_order_id": client_order_id}
@@ -977,7 +976,7 @@ def _limit_order_kwargs(client, symbol, amount, price, side, market_type, client
             pos_side = "long" if side.lower() == "buy" else "short"
             kwargs["pos_side"] = pos_side
         return kwargs
-    if isinstance(client, (BybitClient, DeepcoinClient)):
+    if isinstance(client, BybitClient):
         return {"qty": amount, "price": price, "client_order_id": client_order_id}
     # Generic fallback
     return {"size": amount, "price": price, "client_order_id": client_order_id}
@@ -1501,31 +1500,28 @@ def _fetch_exchange_positions_raw(
     """
     Fetch raw position payload for quick-trade / close-position.
 
-    Many clients do not accept ``symbol=`` on ``get_positions()`` (Gate, KuCoin),
+    Many clients do not accept ``symbol=`` on ``get_positions()`` (Gate),
     or need extra args (Bitget ``product_type``, OKX ``inst_type``). Centralize here.
     """
     from app.services.live_trading.binance import BinanceFuturesClient
     from app.services.live_trading.binance_spot import BinanceSpotClient
     from app.services.live_trading.bitget import BitgetMixClient
     from app.services.live_trading.bitget_spot import BitgetSpotClient
     from app.services.live_trading.bybit import BybitClient
-    from app.services.live_trading.deepcoin import DeepcoinClient
     from app.services.live_trading.gate import GateSpotClient, GateUsdtFuturesClient
     from app.services.live_trading.htx import HtxClient
-    from app.services.live_trading.kucoin import KucoinFuturesClient, KucoinSpotClient
     from app.services.live_trading.okx import OkxClient
     from app.services.live_trading.symbols import (
         to_bybit_symbol,
         to_gate_currency_pair,
-        to_kucoin_futures_symbol,
         to_okx_spot_inst_id,
         to_okx_swap_inst_id,
     )
 
     mt = (market_type or "swap").strip().lower()
 
     if mt == "spot" and isinstance(
-        client, (BinanceSpotClient, BitgetSpotClient, KucoinSpotClient, OkxClient)
+        client, (BinanceSpotClient, BitgetSpotClient, OkxClient)
     ):
         return _fetch_spot_holdings_raw(client, symbol=symbol)
 
@@ -1619,19 +1615,6 @@ def _fetch_exchange_positions_raw(
                      [(p.get("size"), p.get("positionAmt")) for p in out])
         return out
 
-    if isinstance(client, KucoinFuturesClient):
-        raw = client.get_positions()
-        data = raw.get("data") if isinstance(raw, dict) else []
-        sym = to_kucoin_futures_symbol(symbol)
-        if not isinstance(data, list):
-            data = []
-        filtered = [p for p in data if isinstance(p, dict) and str(p.get("symbol") or "").strip() == sym]
-        if isinstance(raw, dict):
-            out = dict(raw)
-            out["data"] = filtered
-            return out
-        return {"data": filtered}
-
     if isinstance(client, HtxClient):
         if mt == "spot":
             return client.get_positions(symbol=symbol)
@@ -1667,9 +1650,6 @@ def _fetch_exchange_positions_raw(
                      [(p.get("contract_code"), p.get("volume"), p.get("positionAmt")) for p in out_items])
         return {"data": out_items}
 
-    if isinstance(client, DeepcoinClient):
-        return client.get_positions(symbol=symbol)
-
     if hasattr(client, "get_positions"):
         try:
             return client.get_positions(symbol=symbol)

backend_api_python/app/routes/strategy.py

@@ -802,6 +802,8 @@ def get_trades():
         # the stored wall clock is UTC. Naive datetime must not use .timestamp() alone — that would
         # interpret it in the Python process local TZ and shift the instant (e.g. +8h on CN laptops).
         from datetime import datetime as _dt, timezone as _tz
+        from app.utils.trade_close_reason import enrich_trade_row
+        from app.utils.trade_net_pnl import enrich_trades_net_pnl
         processed_rows = []
         for row in rows:
             trade = dict(row)
@@ -820,8 +822,6 @@ def get_trades():
                         trade['created_at'] = int(dt.timestamp())
                     except Exception:
                         pass
-            from app.utils.trade_close_reason import enrich_trade_row
-            from app.utils.trade_net_pnl import enrich_trades_net_pnl
 
             trade = enrich_trade_row(trade, bot_type=bot_type, lang=lang)
             processed_rows.append(trade)

backend_api_python/app/services/broker_market_policy.py

@@ -20,21 +20,13 @@
 
 from typing import Dict, Optional, Set
 
+from app.services.live_trading.capabilities import CRYPTO_VENUE_CAPABILITIES
+
 
 # ---------------------------------------------------------------------------
 # Canonical sets
 # ---------------------------------------------------------------------------
 
-# All crypto exchanges QuantDinger has wired up in live_trading/factory.py.
-# Each is assumed to support both spot and swap unless noted otherwise.
-_CRYPTO_EXCHANGES_SPOT_AND_SWAP: Set[str] = {
-    "binance", "okx", "bitget", "bybit",
-    "kraken", "kucoin", "gate", "deepcoin", "htx",
-}
-# Coinbase Exchange API is institutional spot-only on our side.
-_CRYPTO_EXCHANGES_SPOT_ONLY: Set[str] = {"coinbaseexchange"}
-
-
 def _build_broker_markets() -> Dict[str, Dict[str, Set[str]]]:
     """Construct the master matrix.
 
@@ -54,10 +46,8 @@ def _build_broker_markets() -> Dict[str, Dict[str, Set[str]]]:
             "Crypto": {"spot"},
         },
     }
-    for ex in _CRYPTO_EXCHANGES_SPOT_AND_SWAP:
-        matrix[ex] = {"Crypto": {"spot", "swap"}}
-    for ex in _CRYPTO_EXCHANGES_SPOT_ONLY:
-        matrix[ex] = {"Crypto": {"spot"}}
+    for ex, capability in CRYPTO_VENUE_CAPABILITIES.items():
+        matrix[ex] = {"Crypto": set(capability.market_types)}
     return matrix
 
 

backend_api_python/app/services/exchange_execution.py

@@ -16,6 +16,7 @@
 from app.utils.db import get_db_connection
 from app.utils.logger import get_logger
 from app.utils.credential_crypto import decrypt_credential_blob
+from app.services.live_trading.capabilities import canonical_exchange_id, supported_crypto_exchange_ids
 
 logger = get_logger(__name__)
 
@@ -49,10 +50,7 @@ def _safe_json_loads(value: Any, default: Any) -> Any:
     "alpaca": "USStock",  # Alpaca primarily for US stocks; crypto is opt-in via market_category override
     "mt5": "Forex",
 }
-_CRYPTO_EXCHANGES = {
-    "binance", "okx", "bitget", "bybit", "coinbaseexchange",
-    "kraken", "kucoin", "gate", "deepcoin", "htx",
-}
+_CRYPTO_EXCHANGES = supported_crypto_exchange_ids()
 
 
 def _infer_market_category_from_exchange(exchange_id: str) -> str:
@@ -61,7 +59,7 @@ def _infer_market_category_from_exchange(exchange_id: str) -> str:
 
     Returns 'Crypto' as the legacy default only if exchange_id is empty or unknown.
     """
-    eid = (exchange_id or "").strip().lower()
+    eid = canonical_exchange_id(exchange_id)
     if not eid:
         return "Crypto"
     if eid in _EXCHANGE_TO_MARKET: