AdrianoDev
1b8ba0ef9c
Task 6.7: porting alpaca da services/mcp-alpaca a src/cerbero_mcp. client.py + leverage_cap.py copiati 1:1 (default cap 1 cash). tools.py: 17 tool senza ACL/Principal/audit. Router /mcp-alpaca con 18 route (env_info + 17 tool). Builder branch alpaca: paper=(env=="testnet"), api_key viene da settings.alpaca.api_key_id. Test client + leverage_cap migrati (15 test alpaca pass). Test builder con stub SDK alpaca-py. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
57 lines
1.5 KiB
Python
57 lines
1.5 KiB
Python
"""Leverage cap server-side per place_order.
|
|
|
|
Cap letto dal secret JSON via campo `max_leverage`. Default 1 (cash) se assente.
|
|
"""
|
|
from __future__ import annotations
|
|
|
|
from fastapi import HTTPException
|
|
|
|
|
|
def get_max_leverage(creds: dict) -> int:
|
|
"""Legge max_leverage dal secret. Default 1 se mancante."""
|
|
raw = creds.get("max_leverage", 1)
|
|
try:
|
|
value = int(raw)
|
|
except (TypeError, ValueError):
|
|
value = 1
|
|
return max(1, value)
|
|
|
|
|
|
def enforce_leverage(
|
|
requested: int | float | None,
|
|
*,
|
|
creds: dict,
|
|
exchange: str,
|
|
) -> int:
|
|
"""Verifica e applica leverage cap. Ritorna leverage applicabile.
|
|
|
|
Solleva HTTPException(403, LEVERAGE_CAP_EXCEEDED) se requested > cap.
|
|
Se requested is None, applica il cap come default.
|
|
"""
|
|
cap = get_max_leverage(creds)
|
|
if requested is None:
|
|
return cap
|
|
lev = int(requested)
|
|
if lev < 1:
|
|
raise HTTPException(
|
|
status_code=403,
|
|
detail={
|
|
"error": "LEVERAGE_CAP_EXCEEDED",
|
|
"exchange": exchange,
|
|
"requested": lev,
|
|
"max": cap,
|
|
"reason": "leverage must be >= 1",
|
|
},
|
|
)
|
|
if lev > cap:
|
|
raise HTTPException(
|
|
status_code=403,
|
|
detail={
|
|
"error": "LEVERAGE_CAP_EXCEEDED",
|
|
"exchange": exchange,
|
|
"requested": lev,
|
|
"max": cap,
|
|
},
|
|
)
|
|
return lev
|