Update app.py

app.py

@@ -1,7 +1,7 @@
 # -*- coding: utf-8 -*-
 """
 HUGGING FACE SPACE: BINANCE SPOT TRADING SIMULATOR
-Gradio Dashboard | No API Key Required | Rule-Based Virtual Execution
+✅ Fixed: Gradio Timer Compatible | No API Key | Rule-Based
 """
 import os, time, json, threading, logging, requests, pandas as pd
 from datetime import datetime, timezone
@@ -35,7 +35,8 @@ logging.basicConfig(level=logging.INFO, format="%(message)s")
 # ==========================================
 def load_state():
     if os.path.exists(STATE_FILE):
-        with open(STATE_FILE) as f: return json.load(f)
+        with open(STATE_FILE) as f: 
+            return json.load(f)
     return {
         "date": datetime.now(timezone.utc).strftime("%Y-%m-%d"),
         "balance": 1000.0, "trades": 0, "daily_pnl": 0.0,
@@ -43,7 +44,8 @@ def load_state():
     }
 
 def save_state(s):
-    with open(STATE_FILE, "w") as f: json.dump(s, f, indent=2)
+    with open(STATE_FILE, "w") as f: 
+        json.dump(s, f, indent=2)
 
 # ==========================================
 # PUBLIC BINANCE FETCHER (NO API KEY)
@@ -56,7 +58,8 @@ def fetch_klines(sym, interval="1h", limit=100):
         d = r.json()
         df = pd.DataFrame(d, columns=["ts","o","h","l","c","v"] + ["_"]*6)
         df["ts"] = pd.to_datetime(df["ts"], unit="ms")
-        for c in "o h l c v".split(): df[c] = df[c].astype(float)
+        for c in "o h l c v".split(): 
+            df[c] = df[c].astype(float)
         return df[["ts","o","h","l","c","v"]]
     except Exception as e:
         return pd.DataFrame()
@@ -65,11 +68,13 @@ def fetch_klines(sym, interval="1h", limit=100):
 # INDIKATOR & AI SCORE
 # ==========================================
 def add_ema(df, periods=[20, 50]):
-    for p in periods: df[f"ema_{p}"] = df["c"].ewm(span=p, adjust=False).mean()
+    for p in periods: 
+        df[f"ema_{p}"] = df["c"].ewm(span=p, adjust=False).mean()
     return df
 
 def calc_ai_score(df):
-    if len(df) < 50: return 0
+    if len(df) < 50: 
+        return 0
     trend = 30 if df["ema_20"].iloc[-1] > df["ema_50"].iloc[-1] else 0
     vol_ma = df["v"].rolling(20).mean().iloc[-1]
     vol_ratio = df["v"].iloc[-1] / max(vol_ma, 1e-9)
@@ -81,11 +86,13 @@ def calc_ai_score(df):
 # TELEGRAM ALERT
 # ==========================================
 def tg_send(txt):
-    if not CONFIG["TELEGRAM_TOKEN"] or not CONFIG["TELEGRAM_CHAT_ID"]: return
+    if not CONFIG["TELEGRAM_TOKEN"] or not CONFIG["TELEGRAM_CHAT_ID"]: 
+        return
     try:
         requests.post(f"https://api.telegram.org/bot{CONFIG['TELEGRAM_TOKEN']}/sendMessage",
                       json={"chat_id": CONFIG["TELEGRAM_CHAT_ID"], "text": txt, "parse_mode": "HTML"}, timeout=5)
-    except: pass
+    except: 
+        pass
 
 def tg_fmt(emoji, title, msg):
     return f"{emoji} <b>{title}</b>\n{msg}\n⏰ {datetime.now(timezone.utc).strftime('%H:%M UTC')}"
@@ -102,7 +109,8 @@ class SimEngine:
         self._thread = None
 
     def start(self):
-        if self._running: return "⚠️ Sudah berjalan"
+        if self._running: 
+            return "⚠️ Sudah berjalan"
         self._running = True
         self._stop.clear()
         self._thread = threading.Thread(target=self._loop, daemon=True)
@@ -123,9 +131,12 @@ class SimEngine:
 
     def _can_trade(self):
         with self._lock:
-            if self.state["trades"] >= CONFIG["MAX_DAILY_TRADES"]: return False, "Max 2 trade/hari"
-            if self.state["daily_pnl"] <= CONFIG["DAILY_LOSS_LIMIT"]: return False, "Daily Loss Limit -3%"
-            if self.state["daily_pnl"] >= CONFIG["DAILY_PROFIT_LOCK"]: return False, "Profit Lock +5%"
+            if self.state["trades"] >= CONFIG["MAX_DAILY_TRADES"]: 
+                return False, "Max 2 trade/hari"
+            if self.state["daily_pnl"] <= CONFIG["DAILY_LOSS_LIMIT"]: 
+                return False, "Daily Loss Limit -3%"
+            if self.state["daily_pnl"] >= CONFIG["DAILY_PROFIT_LOCK"]: 
+                return False, "Profit Lock +5%"
             return True, "OK"
 
     def _check_positions(self):
@@ -133,10 +144,12 @@ class SimEngine:
             for p in self.state["positions"][:]:
                 sym = p["symbol"]
                 df = fetch_klines(sym, CONFIG["INTERVAL"], limit=1)
-                if df.empty: continue
+                if df.empty: 
+                    continue
                 price = df["c"].iloc[-1]
                 pnl = (price - p["entry"]) / p["entry"]
-                if price > p["trail_h"]: p["trail_h"] = price
+                if price > p["trail_h"]: 
+                    p["trail_h"] = price
 
                 if pnl >= CONFIG["TP1"] and not p["tp1"]:
                     p["tp1"] = True
@@ -148,7 +161,6 @@ class SimEngine:
                     tg_send(tg_fmt("💰", f"TP2 {sym}", f"+5% | 30% closed | Virtual"))
 
                 trail_sl = p["trail_h"] * (1 - CONFIG["TRAIL_PCT"])
-                exit_price = price
                 if price <= max(trail_sl, p["sl"]):
                     close_share = CONFIG["TP3_SHARE"] if p["tp2"] else 1.0
                     pnl_real = pnl * close_share
@@ -174,18 +186,22 @@ class SimEngine:
                 self._reset_daily()
                 ok, reason = self._can_trade()
                 if not ok:
-                    time.sleep(60); continue
+                    time.sleep(60)
+                    continue
 
                 # BTC Filter
                 btc = add_ema(fetch_klines("BTCUSDT", CONFIG["INTERVAL"]))
                 if btc.empty or btc["ema_20"].iloc[-1] <= btc["ema_50"].iloc[-1]:
-                    time.sleep(60); continue
+                    time.sleep(60)
+                    continue
 
                 # Scan Watchlist
                 for sym in CONFIG["WATCHLIST"]:
-                    if sym == "BTCUSDT" or self._stop.is_set(): continue
+                    if sym == "BTCUSDT" or self._stop.is_set(): 
+                        continue
                     df = add_ema(fetch_klines(sym, CONFIG["INTERVAL"]))
-                    if df.empty: continue
+                    if df.empty: 
+                        continue
                     score = calc_ai_score(df)
                     vol_ma = df["v"].rolling(20).mean().iloc[-1]
                     vol_r = df["v"].iloc[-1] / max(vol_ma, 1e-9)
@@ -219,16 +235,17 @@ class SimEngine:
         ts = datetime.now().strftime("%H:%M:%S")
         with self._lock:
             self.state["logs"].append(f"[{ts}] {msg}")
-            if len(self.state["logs"]) > 150: self.state["logs"] = self.state["logs"][-50:]
+            if len(self.state["logs"]) > 150: 
+                self.state["logs"] = self.state["logs"][-50:]
 
     def get_state(self):
         with self._lock:
-            return json.loads(json.dumps(self.state))  # Deep copy
+            return json.loads(json.dumps(self.state))
 
 engine = SimEngine()
 
 # ==========================================
-# GRADIO DASHBOARD
+# GRADIO DASHBOARD (FIXED)
 # ==========================================
 def ui_update():
     s = engine.get_state()
@@ -240,22 +257,59 @@ def ui_update():
             f"Daily PnL: {s['daily_pnl']:.2%}", 
             pos, logs)
 
-with gr.Blocks(title="Binance Spot Simulator") as demo:
+def refresh_logs():
+    """Fungsi khusus untuk timer refresh log saja"""
+    s = engine.get_state()
+    return "\n".join(s["logs"][-20:])
+
+with gr.Blocks(title="Binance Spot Simulator", css=".footer {text-align: center; margin-top: 20px;}") as demo:
     gr.Markdown("# 📊 System Trading + Profit Management (SIMULATOR)")
     gr.Markdown("*✅ Tanpa API Key | ✅ Data Publik Binance | ✅ Semua Rule Aktif | ✅ Telegram Ready*")
+    
     with gr.Row():
-        btn_start = gr.Button("▶ START SIMULATOR", variant="primary")
-        btn_stop = gr.Button("⏹ STOP")
+        btn_start = gr.Button("▶ START SIMULATOR", variant="primary", scale=1)
+        btn_stop = gr.Button("⏹ STOP", variant="stop", scale=1)
+        btn_reset = gr.Button("🔄 RESET STATE", variant="secondary", scale=1)
+    
     with gr.Row():
         bal = gr.Textbox(label="💰 Balance", value="Balance: $1000.00", interactive=False)
         trades = gr.Textbox(label="📈 Trades Hari Ini", value="Trades: 0/2", interactive=False)
         pnl = gr.Textbox(label="📊 Daily PnL", value="Daily PnL: 0.00%", interactive=False)
-    pos_table = gr.Dataframe(headers=["Pair", "Entry", "Qty", "SL", "Status"], value=[], interactive=False, label="📍 Open Positions")
-    log_box = gr.Textbox(label="📝 System Log", value="", lines=10, interactive=False)
+    
+    pos_table = gr.Dataframe(
+        headers=["Pair", "Entry", "Qty", "SL", "Status"], 
+        value=[], 
+        interactive=False, 
+        label="📍 Open Positions",
+        wrap=True
+    )
+    
+    log_box = gr.Textbox(label="📝 System Log", value="", lines=10, interactive=False, max_lines=20)
+    
+    gr.Markdown('<div class="footer">🔐 Mode: SIMULATOR (Virtual Trading) | Data: Binance Public API</div>', elem_classes="footer")
 
-    btn_start.click(lambda: engine.start(), outputs=None)
-    btn_stop.click(lambda: engine.stop(), outputs=None)
-    demo.load(ui_update, inputs=None, outputs=[bal, trades, pnl, pos_table, log_box], every=5)
+    # Event handlers
+    btn_start.click(lambda: engine.start(), inputs=None, outputs=None)
+    btn_stop.click(lambda: engine.stop(), inputs=None, outputs=None)
+    
+    def do_reset():
+        engine.state = {
+            "date": datetime.now(timezone.utc).strftime("%Y-%m-%d"),
+            "balance": 1000.0, "trades": 0, "daily_pnl": 0.0,
+            "positions": [], "logs": ["🔄 State di-reset"]
+        }
+        save_state(engine.state)
+        return "Balance: $1000.00", "Trades: 0/2", "Daily PnL: 0.00%", [], "🔄 State di-reset"
+    
+    btn_reset.click(do_reset, inputs=None, outputs=[bal, trades, pnl, pos_table, log_box])
+    
+    # ✅ FIXED: Gunakan gr.Timer untuk auto-refresh (Gradio 4.x compatible)
+    timer = gr.Timer(value=5)  # Refresh setiap 5 detik
+    timer.tick(ui_update, inputs=None, outputs=[bal, trades, pnl, pos_table, log_box])
+    
+    # Refresh log lebih sering agar real-time
+    log_timer = gr.Timer(value=2)
+    log_timer.tick(refresh_logs, inputs=None, outputs=log_box)
 
 if __name__ == "__main__":
-    demo.launch(server_name="0.0.0.0", server_port=7860)
+    demo.launch(server_name="0.0.0.0", server_port=int(os.getenv("PORT", "7860")))