Update app.py

app.py

@@ -288,6 +288,49 @@ async def fetch_deriv_features(symbol, exchange, timeframe, df):
     return m.drop(columns=["ts"]).add_prefix("dv_"), d2, extra
 
 
+# compute_indicators'ın `indicators` parametresi ZORUNLUDUR ("rsi:14", "macd:12,26,9" biçiminde spec listesi).
+# 73 göstergenin adlarını bilmediğimiz için geniş bir aday listesi denenir; geçersiz adlar atlanır.
+IND_NAMES = [
+    "sma", "ema", "wma", "hma", "vwma", "dema", "tema", "zlema", "kama", "alma", "rma", "smma", "lsma", "vwap",
+    "bb", "bbands", "bollinger", "bbw", "bbp", "kc", "keltner", "donchian", "dc", "envelope", "ichimoku",
+    "supertrend", "psar", "sar", "rsi", "stochrsi", "stoch", "macd", "ppo", "roc", "mom", "momentum", "cci",
+    "willr", "williams", "ao", "awesome", "ac", "uo", "tsi", "trix", "cmo", "dpo", "kst", "coppock", "fisher",
+    "rvi", "mfi", "obv", "cmf", "ad", "adl", "eom", "fi", "force", "vpt", "nvi", "pvi", "kvo", "atr", "natr",
+    "tr", "stdev", "hv", "ulcer", "chop", "massindex", "adx", "dmi", "aroon", "vortex", "wavetrend", "wt",
+    "squeeze", "ttm", "heikinashi", "ha", "pivot", "zigzag", "linreg", "zscore", "cog", "bop", "qstick",
+    "pgo", "smi", "stc", "er", "efi",
+]
+
+
+async def fetch_indicators(session, tools, symbol, timeframe, exchange, limit):
+    """Önce hepsini tek çağrıda dener; geçersiz ad yüzünden hata olursa her göstergeyi ayrı çağırıp çalışanları toplar."""
+    if "compute_indicators" not in tools:
+        return None
+    kw = dict(symbol=symbol, timeframe=timeframe, exchange=exchange, limit=limit, include_series=True)
+    out = {"by_indicator": {}, "failed": [], "mode": None}
+    try:
+        res = await call_tool(session, tools, "compute_indicators", indicators=IND_NAMES, **kw)
+    except Exception:  # noqa: BLE001
+        res = None
+    if isinstance(res, dict) and "error" not in res and extract_series(res, 0):
+        out["by_indicator"]["batch"] = res
+        out["mode"] = "batch"
+        return out
+    out["mode"] = "single"
+    out["batch_error"] = _strip_series(res) if isinstance(res, dict) else None
+    for name in IND_NAMES:
+        try:
+            r = await call_tool(session, tools, "compute_indicators", indicators=[name], **kw)
+        except Exception:  # noqa: BLE001
+            out["failed"].append(name)
+            continue
+        if r is None or (isinstance(r, dict) and "error" in r):
+            out["failed"].append(name)
+            continue
+        out["by_indicator"][name] = r
+    return out
+
+
 def _numeric_list(o, min_len):
     return (isinstance(o, list) and len(o) >= min_len and
             all(x is None or (isinstance(x, (int, float)) and not isinstance(x, bool)) for x in o[:50]))
@@ -698,9 +741,7 @@ async def run_async(symbol, timeframe, exchange, horizon, limit):
             # Tickscope'un kendi analizleri (opsiyonel, hata verirse atla)
             deep = await call_tool(session, tools, "deep_analyze", symbol=symbol,
                                    timeframe=timeframe, exchange=exchange)
-            ind = await call_tool(session, tools, "compute_indicators", symbol=symbol,
-                                  timeframe=timeframe, exchange=exchange,
-                                  limit=int(limit), include_series=True)
+            ind = await fetch_indicators(session, tools, symbol, timeframe, exchange, int(limit))
 
             # Tickscope'un diğer tüm analiz/piyasa araçları (canlı bağlam; şema uyuşmazsa hata olarak kaydedilir)
             extra = {}
@@ -713,6 +754,14 @@ async def run_async(symbol, timeframe, exchange, horizon, limit):
                 except Exception as e:  # noqa: BLE001
                     extra[name] = {"error": _root(e)}
             extra["_available_tools"] = list(tools)
+            ci = tools.get("compute_indicators")
+            if ci is not None:   # gerçek gösterge adlarını görebilmek için araç açıklaması
+                extra["_compute_indicators_description"] = (getattr(ci, "description", "") or "")[:4000]
+            if isinstance(ind, dict):
+                ser = extract_series(ind, 0)
+                extra["_ts_diag"] = {"mod": ind.get("mode"), "seri_sayisi": len(ser),
+                                     "seri_uzunluklari": sorted({len(v) for v in ser.values()})[:10],
+                                     "calismayan_adlar": ind.get("failed")}
     return ohlcv, deep, ind, extra