perf(cache): add 15s cache to broker market state and 2s cache to price query

capital_client.py

@@ -250,9 +250,23 @@ def get_capital_candles(asset='GOLD', interval='5m', max_bars=80, price_mode='bi
     return None
 
 
+_MARKET_PRICE_CACHE = {}
+_MARKET_PRICE_CACHE_TS = {}
+_BROKER_STATE_CACHE = {}
+_BROKER_STATE_CACHE_TS = {}
+_price_cache_lock = threading.RLock()
+
 def get_capital_market_price(asset='GOLD'):
-    """Returns real-time bid, ask, spread, and broker marketStatus from Capital.com Live"""
+    """
+    Fetches real-time market price and snapshot directly from Capital.com.
+    Protected by a 2.0s server-paced cache to eliminate redundant network roundtrips.
+    """
     asset_u = asset.upper()
+    now_t = time.time()
+    with _price_cache_lock:
+        if asset_u in _MARKET_PRICE_CACHE and (now_t - _MARKET_PRICE_CACHE_TS.get(asset_u, 0)) < 2.0:
+            return dict(_MARKET_PRICE_CACHE[asset_u])
+
     epic = EPICS.get(asset_u)
     if not epic:
         return None
@@ -281,7 +295,7 @@ def get_capital_market_price(asset='GOLD'):
             mid = (bid + ask) / 2.0
             m_status = str(snap.get('marketStatus', 'TRADEABLE')).upper()
 
-            return {
+            res_dict = {
                 'bid':           round(bid, prec),
                 'ask':           round(ask, prec),
                 'mid':           round(mid, prec),
@@ -293,6 +307,10 @@ def get_capital_market_price(asset='GOLD'):
                 'market_status': m_status,
                 'is_tradeable':  m_status == 'TRADEABLE'
             }
+            with _price_cache_lock:
+                _MARKET_PRICE_CACHE[asset_u] = res_dict
+                _MARKET_PRICE_CACHE_TS[asset_u] = now_t
+            return res_dict
     except Exception as e:
         err_str = str(e)
         if '401' in err_str or '403' in err_str:
@@ -314,7 +332,7 @@ def get_capital_market_price(asset='GOLD'):
                         ask = float(snap.get('offer', snap.get('ask', 0)))
                         mid = (bid + ask) / 2.0
                         m_status = str(snap.get('marketStatus', 'TRADEABLE')).upper()
-                        return {
+                        res_dict = {
                             'bid':           round(bid, prec),
                             'ask':           round(ask, prec),
                             'mid':           round(mid, prec),
@@ -326,30 +344,53 @@ def get_capital_market_price(asset='GOLD'):
                             'market_status': m_status,
                             'is_tradeable':  m_status == 'TRADEABLE'
                         }
+                        with _price_cache_lock:
+                            _MARKET_PRICE_CACHE[asset_u] = res_dict
+                            _MARKET_PRICE_CACHE_TS[asset_u] = now_t
+                        return res_dict
                 except Exception:
                     pass
+        with _price_cache_lock:
+            if asset_u in _MARKET_PRICE_CACHE:
+                return dict(_MARKET_PRICE_CACHE[asset_u])
         return None
 
 
 def get_broker_market_state(asset='GOLD'):
     """
     Authoritative Broker Truth Sensor
+    Protected by 15.0s cache to avoid redundant network calls.
     Returns dict: {'is_open': bool, 'market_status': str, 'status_title': str}
     """
-    p = get_capital_market_price(asset)
+    asset_u = asset.upper()
+    now_t = time.time()
+    with _price_cache_lock:
+        if asset_u in _BROKER_STATE_CACHE and (now_t - _BROKER_STATE_CACHE_TS.get(asset_u, 0)) < 15.0:
+            return dict(_BROKER_STATE_CACHE[asset_u])
+
+    p = get_capital_market_price(asset_u)
     if p and p.get('market_status'):
         status = p['market_status']
         is_open = (status == 'TRADEABLE')
-        return {
+        res = {
             'is_open': is_open,
             'market_status': status,
             'status_title': 'MARKET OPEN' if is_open else 'BROKER MARKET CLOSED'
         }
-    return {
+        with _price_cache_lock:
+            _BROKER_STATE_CACHE[asset_u] = res
+            _BROKER_STATE_CACHE_TS[asset_u] = now_t
+        return res
+
+    fallback = {
         'is_open': True,
         'market_status': 'UNKNOWN',
         'status_title': 'SESSION ACTIVE'
     }
+    with _price_cache_lock:
+        if asset_u in _BROKER_STATE_CACHE:
+            return dict(_BROKER_STATE_CACHE[asset_u])
+    return fallback
 
 
 # ---- Direct test ----