feat(mcp-bybit): leverage_cap + testnet resolver + environment_info

services/mcp-bybit/src/mcp_bybit/server.py

@@ -4,11 +4,14 @@ import os
 
 from fastapi import Depends, HTTPException
 from mcp_common.auth import Principal, TokenStore, require_principal
+from mcp_common.environment import EnvironmentInfo
 from mcp_common.mcp_bridge import mount_mcp_endpoint
 from mcp_common.server import build_app
 from pydantic import BaseModel
 
 from mcp_bybit.client import BybitClient
+from mcp_bybit.leverage_cap import enforce_leverage as _enforce_leverage
+from mcp_bybit.leverage_cap import get_max_leverage
 
 
 # --- Body models: reads ---
@@ -180,11 +183,39 @@ def _check(principal: Principal, *, core: bool = False, observer: bool = False)
         raise HTTPException(status_code=403, detail="forbidden")
 
 
-def create_app(*, client: BybitClient, token_store: TokenStore):
+def create_app(
+    *,
+    client: BybitClient,
+    token_store: TokenStore,
+    creds: dict | None = None,
+    env_info: "EnvironmentInfo | None" = None,
+):
+    creds = creds or {}
     app = build_app(name="mcp-bybit", version="0.1.0", token_store=token_store)
 
     # ── Reads ──────────────────────────────────────────────
 
+    @app.post("/tools/environment_info", tags=["reads"])
+    async def t_environment_info(principal: Principal = Depends(require_principal)):
+        _check(principal, core=True, observer=True)
+        if env_info is None:
+            return {
+                "exchange": "bybit",
+                "environment": "testnet" if client.testnet else "mainnet",
+                "source": "credentials",
+                "env_value": None,
+                "base_url": getattr(client, "base_url", None),
+                "max_leverage": get_max_leverage(creds),
+            }
+        return {
+            "exchange": env_info.exchange,
+            "environment": env_info.environment,
+            "source": env_info.source,
+            "env_value": env_info.env_value,
+            "base_url": env_info.base_url,
+            "max_leverage": get_max_leverage(creds),
+        }
+
     @app.post("/tools/get_ticker", tags=["reads"])
     async def t_get_ticker(body: TickerReq, principal: Principal = Depends(require_principal)):
         _check(principal, core=True, observer=True)
@@ -309,6 +340,7 @@ def create_app(*, client: BybitClient, token_store: TokenStore):
 
     @app.post("/tools/set_leverage", tags=["writes"])
     async def t_set_leverage(body: SetLeverageReq, principal: Principal = Depends(require_principal)):
+        _enforce_leverage(body.leverage, creds=creds, exchange="bybit")
         _check(principal, core=True)
         return await client.set_leverage(body.category, body.symbol, body.leverage)
 
@@ -332,6 +364,7 @@ def create_app(*, client: BybitClient, token_store: TokenStore):
         token_store=token_store,
         internal_base_url=f"http://localhost:{port}",
         tools=[
+            {"name": "environment_info", "description": "Ambiente operativo (testnet/mainnet), source, base_url, max_leverage cap."},
             {"name": "get_ticker", "description": "Ticker Bybit (spot/linear/inverse/option)."},
             {"name": "get_ticker_batch", "description": "Ticker per più simboli."},
             {"name": "get_orderbook", "description": "Orderbook profondità N."},