Create app.py

app.py

@@ -0,0 +1,184 @@
+import gradio as gr
+import time
+import threading
+import pandas as pd
+import plotly.graph_objects as go
+from datetime import datetime
+from r2 import R2Manager
+from llm import MarketBrain
+
+# تهيئة الكائنات
+r2 = R2Manager()
+brain = MarketBrain()
+
+# متغيرات عالمية للتحكم في البوت
+bot_active = False
+target_symbol = "ETH/USDT" # الافتراضي
+stop_event = threading.Event()
+
+def trading_loop():
+    """الحلقة الخلفية التي تعمل كل 15 دقيقة"""
+    global bot_active, target_symbol
+    
+    while not stop_event.is_set():
+        if bot_active:
+            print(f"--- Running Analysis for {target_symbol} at {datetime.now()} ---")
+            
+            # 1. جلب بيانات المحفظة
+            portfolio = r2.get_data()
+            current_pos = portfolio.get("active_position")
+            
+            # 2. استشارة الذكاء الاصطناعي
+            decision, _ = brain.analyze_and_decide(target_symbol, current_pos)
+            print(f"AI Decision: {decision}")
+            
+            current_price = brain.get_market_data(target_symbol)[0]['close']
+            
+            # 3. تنفيذ المنطق
+            # حالة الشراء (لا توجد صفقة + إشارة شراء + ثقة عالية)
+            if not current_pos and decision.get('action') == "BUY" and decision.get('confidence', 0) > 70:
+                # منطق التحجيم (10$ ثم 20$)
+                trade_size = 10.0
+                if portfolio['balance'] > 1050: # مثال بسيط لزيادة الحجم عند الربح
+                    trade_size = 20.0
+                
+                new_pos = {
+                    "symbol": target_symbol,
+                    "entry_price": current_price,
+                    "amount": trade_size / current_price,
+                    "cost": trade_size,
+                    "tp": decision.get('tp_target'),
+                    "sl": decision.get('sl_target'),
+                    "timestamp": str(datetime.now())
+                }
+                portfolio['active_position'] = new_pos
+                portfolio['balance'] -= trade_size
+                print(f"OPENED BUY POSITION: {new_pos}")
+                
+            # حالة البيع (يوجد صفقة + إشارة بيع أو ضرب الأهداف)
+            elif current_pos:
+                # التحقق من الأهداف المحددة مسبقاً (إدارة مخاطر صارمة)
+                hit_tp = current_price >= current_pos['tp'] if current_pos['tp'] else False
+                hit_sl = current_price <= current_pos['sl'] if current_pos['sl'] else False
+                ai_exit = decision.get('action') == "SELL"
+                
+                if hit_tp or hit_sl or ai_exit:
+                    revenue = current_pos['amount'] * current_price
+                    pnl = revenue - current_pos['cost']
+                    
+                    # تحديث السجلات
+                    portfolio['active_position'] = None
+                    portfolio['balance'] += revenue
+                    portfolio['stats']['total_pnl'] += pnl
+                    if pnl > 0:
+                        portfolio['stats']['wins'] += 1
+                    else:
+                        portfolio['stats']['losses'] += 1
+                        
+                    history_record = {
+                        "symbol": target_symbol,
+                        "entry": current_pos['entry_price'],
+                        "exit": current_price,
+                        "pnl": pnl,
+                        "reason": "TP" if hit_tp else ("SL" if hit_sl else "AI_DECISION"),
+                        "time": str(datetime.now())
+                    }
+                    portfolio['history'].append(history_record)
+                    print(f"CLOSED POSITION: {history_record}")
+
+            # 4. حفظ البيانات في Cloudflare R2
+            r2.save_data(portfolio)
+            
+        # الانتظار 15 دقيقة (900 ثانية)
+        time.sleep(900)
+
+# تشغيل الخيط الخلفي
+t = threading.Thread(target=trading_loop, daemon=True)
+t.start()
+
+# --- دوال الواجهة ---
+
+def start_bot(symbol):
+    global bot_active, target_symbol
+    target_symbol = symbol
+    bot_active = True
+    return f"Bot Started on {symbol}. Scanning every 15 mins..."
+
+def stop_bot():
+    global bot_active
+    bot_active = False
+    return "Bot Stopped."
+
+def get_dashboard_data():
+    portfolio = r2.get_data()
+    market_info, df = brain.get_market_data(target_symbol)
+    
+    # 1. الرسم البياني
+    fig = go.Figure(data=[go.Candlestick(
+        x=df['timestamp'],
+        open=df['open'], high=df['high'],
+        low=df['low'], close=df['close']
+    )])
+    fig.update_layout(title=f"{target_symbol} Live Chart", height=400)
+    
+    # 2. معلومات الصفقة الحالية
+    pos = portfolio.get('active_position')
+    pos_str = "No Active Position"
+    if pos:
+        pnl_pct = ((market_info['close'] - pos['entry_price']) / pos['entry_price']) * 100
+        pos_str = f"""
+        Symbol: {pos['symbol']}
+        Entry: {pos['entry_price']}
+        Current: {market_info['close']}
+        PnL: {pnl_pct:.2f}%
+        TP: {pos['tp']} | SL: {pos['sl']}
+        """
+    
+    # 3. السجلات
+    stats = f"""
+    Balance: ${portfolio['balance']:.2f}
+    Wins: {portfolio['stats']['wins']} | Losses: {portfolio['stats']['losses']}
+    Total PnL: ${portfolio['stats']['total_pnl']:.2f}
+    """
+    
+    history_df = pd.DataFrame(portfolio.get('history', []))
+    if not history_df.empty:
+        history_table = history_df[['time', 'symbol', 'pnl', 'reason']].tail(5).values.tolist()
+    else:
+        history_table = []
+
+    return fig, pos_str, stats, history_table
+
+# --- بناء واجهة Gradio ---
+
+with gr.Blocks(theme=gr.themes.Soft()) as demo:
+    gr.Markdown("# 🤖 GEM-Architect AI Trading Agent (Qwen-80B + OKX)")
+    
+    with gr.Row():
+        with gr.Column(scale=1):
+            symbol_input = gr.Textbox(value="BTC/USDT", label="Symbol to Trade")
+            start_btn = gr.Button("▶ Start Bot", variant="primary")
+            stop_btn = gr.Button("⏹ Stop Bot", variant="stop")
+            status_output = gr.Markdown("Status: Idle")
+        
+        with gr.Column(scale=2):
+            stats_display = gr.Markdown("### Wallet Stats")
+    
+    with gr.Row():
+        chart_output = gr.Plot(label="Price Chart")
+    
+    with gr.Row():
+        with gr.Column():
+            position_display = gr.Markdown("### Active Position")
+        with gr.Column():
+            history_display = gr.Dataframe(headers=["Time", "Symbol", "PnL", "Reason"], label="Recent Trade History")
+
+    # أحداث الأزرار
+    start_btn.click(start_bot, inputs=[symbol_input], outputs=[status_output])
+    stop_btn.click(stop_bot, outputs=[status_output])
+    
+    # تحديث الواجهة تلقائياً كل 30 ثانية للقراءة فقط
+    demo.load(get_dashboard_data, outputs=[chart_output, position_display, stats_display, history_display], every=30)
+
+if __name__ == "__main__":
+    demo.launch()