Update app.py

app.py

@@ -65,8 +65,12 @@ ALIASES = {
     "timeframe": ["timeframe", "interval", "tf"],
     "exchange": ["exchange"],
     "limit": ["limit", "count", "n", "bars"],
+    "until": ["until", "end", "end_time", "endTime", "to", "before"],
 }
 
+TF_MS = {"1m": 60_000, "5m": 300_000, "15m": 900_000, "1h": 3_600_000,
+         "4h": 14_400_000, "1d": 86_400_000}
+
 
 # ----------------------------------------------------------------- MCP yardımcıları
 def build_args(tool, **wanted):
@@ -98,6 +102,46 @@ async def call_tool(session, tools, name, **wanted):
         return {"text": text}
 
 
+async def fetch_ohlcv(session, tools, symbol, timeframe, exchange, total):
+    """Borsa sayfa limiti (~1000) yüzünden geriye doğru sayfalayarak `total` muma kadar çeker.
+    Tool bitiş-zamanı parametresi desteklemiyorsa ilk sayfayla yetinir."""
+    tool = tools.get("get_ohlcv")
+    if tool is None:
+        return None
+    page = min(1000, total)
+    first = await call_tool(session, tools, "get_ohlcv", symbol=symbol,
+                            timeframe=timeframe, exchange=exchange, limit=page)
+    if first is None or (isinstance(first, dict) and "error" in first) or total <= page:
+        return first
+    props = (tool.inputSchema or {}).get("properties", {})
+    if not any(n in props for n in ALIASES["until"]):
+        return first  # sayfalama desteklenmiyor
+    try:
+        frames = [to_df(first)]
+    except Exception:
+        return first
+    got = len(frames[0])
+    epoch = pd.Timestamp("1970-01-01")
+    while got < total:
+        oldest = frames[-1]["ts"].iloc[0]
+        end_ms = int((oldest - epoch) // pd.Timedelta("1ms")) - 1
+        res = await call_tool(session, tools, "get_ohlcv", symbol=symbol, timeframe=timeframe,
+                              exchange=exchange, limit=page, until=end_ms)
+        if res is None or (isinstance(res, dict) and "error" in res):
+            break
+        try:
+            d = to_df(res)
+        except Exception:
+            break
+        d = d[d["ts"] < oldest]
+        if d.empty:
+            break
+        frames.append(d)
+        got += len(d)
+    out = pd.concat(frames[::-1]).drop_duplicates("ts").sort_values("ts").tail(total)
+    return out.to_dict("records")
+
+
 def to_df(payload) -> pd.DataFrame:
     rows = payload
     if isinstance(payload, dict):
@@ -326,8 +370,7 @@ async def run_async(symbol, timeframe, exchange, horizon, limit):
             await session.initialize()
             tools = {t.name: t for t in (await session.list_tools()).tools}
 
-            ohlcv = await call_tool(session, tools, "get_ohlcv", symbol=symbol,
-                                    timeframe=timeframe, exchange=exchange, limit=int(limit))
+            ohlcv = await fetch_ohlcv(session, tools, symbol, timeframe, exchange, int(limit))
             if ohlcv is None:
                 raise RuntimeError(f"get_ohlcv bulunamadı. Mevcut tool'lar: {list(tools)}")
             if isinstance(ohlcv, dict) and "error" in ohlcv:
@@ -402,7 +445,7 @@ with gr.Blocks(title="Tickscope Tahmin") as demo:
         timeframe = gr.Dropdown(["5m", "15m", "1h", "4h", "1d"], value="1h", label="Timeframe")
     with gr.Row():
         horizon = gr.Slider(1, 24, value=4, step=1, label="Tahmin ufku (bar)")
-        limit = gr.Slider(300, 1000, value=1000, step=100, label="Mum sayısı")
+        limit = gr.Slider(300, 20000, value=5000, step=100, label="Mum sayısı (1000 üstü sayfalanır)")
     btn = gr.Button("Tahmin et", variant="primary")
     out_md = gr.Markdown()
     out_plot = gr.Plot()