Update app.py

app.py

@@ -68,6 +68,10 @@ ALIASES = {
     "until": ["until", "end", "end_time", "endTime", "to", "before"],
 }
 
+EXTRA_TOOLS = ["detect_divergence", "detect_patterns", "analyze_structure",
+               "find_support_resistance", "detect_cross", "get_orderbook",
+               "get_ticker", "get_recent_trades", "server_status"]
+
 TF_MS = {"1m": 60_000, "5m": 300_000, "15m": 900_000, "1h": 3_600_000,
          "4h": 14_400_000, "1d": 86_400_000}
 
@@ -176,9 +180,19 @@ def make_features(df: pd.DataFrame):
     lr = np.log(c).diff()
 
     # Getiri / momentum (çok ölçekli)
-    for n in (1, 2, 3, 6, 12, 24, 48):
+    for n in (1, 2, 3, 6, 12, 24, 48, 96, 192):
         f[f"ret{n}"] = c.pct_change(n)
 
+    # Çoklu zaman dilimi (lookahead'siz yuvarlanan pencereler): ~4x ve ~16x üst TF benzeri
+    dd = c.diff()
+    for k in (4, 16):
+        up_k = dd.clip(lower=0).ewm(alpha=1 / (14 * k), adjust=False).mean()
+        dn_k = (-dd.clip(upper=0)).ewm(alpha=1 / (14 * k), adjust=False).mean()
+        f[f"rsi_htf{k}"] = 100 - 100 / (1 + up_k / (dn_k + 1e-12))
+        f[f"ema_dist_htf{k}"] = c / c.ewm(span=20 * k, adjust=False).mean() - 1
+        f[f"chan_pos{k}"] = (c - l.rolling(20 * k).min()) / (h.rolling(20 * k).max() - l.rolling(20 * k).min() + 1e-12)
+        f[f"vol_htf{k}"] = lr.rolling(20 * k).std()
+
     # Volatilite rejimi
     for n in (6, 24, 96):
         f[f"vol{n}"] = lr.rolling(n).std()
@@ -381,7 +395,19 @@ async def run_async(symbol, timeframe, exchange, horizon, limit):
                                    timeframe=timeframe, exchange=exchange)
             ind = await call_tool(session, tools, "compute_indicators", symbol=symbol,
                                   timeframe=timeframe, exchange=exchange)
-    return ohlcv, deep, ind
+
+            # Tickscope'un diğer tüm analiz/piyasa araçları (canlı bağlam; şema uyuşmazsa hata olarak kaydedilir)
+            extra = {}
+            for name in EXTRA_TOOLS:
+                if name not in tools:
+                    continue
+                try:
+                    extra[name] = await call_tool(session, tools, name, symbol=symbol,
+                                                  timeframe=timeframe, exchange=exchange)
+                except Exception as e:  # noqa: BLE001
+                    extra[name] = {"error": _root(e)}
+            extra["_available_tools"] = list(tools)
+    return ohlcv, deep, ind, extra
 
 
 def _root(e):
@@ -393,7 +419,7 @@ def _root(e):
 
 def run(symbol, timeframe, exchange, horizon, limit):
     try:
-        ohlcv, deep, ind = asyncio.run(run_async(symbol, timeframe, exchange, horizon, limit))
+        ohlcv, deep, ind, extra = asyncio.run(run_async(symbol, timeframe, exchange, horizon, limit))
         df = to_df(ohlcv)
         res = predict(df, int(horizon))
     except BaseException as e:  # noqa: BLE001
@@ -432,7 +458,7 @@ def run(symbol, timeframe, exchange, horizon, limit):
                                           arrayminus=[res["center"] - res["low"]])))
     fig.update_layout(height=450, xaxis_rangeslider_visible=False, margin=dict(l=10, r=10, t=30, b=10))
 
-    raw = json.dumps({"deep_analyze": deep, "compute_indicators": ind},
+    raw = json.dumps({"deep_analyze": deep, "compute_indicators": ind, **extra},
                      indent=2, ensure_ascii=False, default=str)
     return md, fig, raw