Update app.py

app.py

@@ -3,116 +3,125 @@ import time
 import gradio as gr
 from datetime import datetime
 import pytz
+import requests
+from groq import Groq
 from quotexpy import Quotex
 from quotexpy.utils.candles_period import CandlesPeriod
 from quotexpy.utils.account_type import AccountType
 
-# Initialize state and trade recommendations
+# Initialize
 state = []
 trade_recommendations = []
 client = Quotex(email="your_email@example.com", password="your_password", headless=True)
+groq_client = Groq(api_key="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")
 
-def analyze_candle_pattern(candles):
-    """Analyze candle patterns and return a recommendation."""
-    if not candles or len(candles) < 3:
-        return "Waiting for more data..."
+def get_ai_recommendation(market_data):
+    """Get AI-powered recommendation using Groq API"""
+    try:
+        prompt = f"""
+        Analyze the latest candlestick patterns and market data:
+        
+        {market_data}
 
-    latest_candle = max(candles.values(), key=lambda x: x["time"])
-    prev_candle = sorted(candles.values(), key=lambda x: x["time"])[-2]
+        Provide:
+        1. Trading Signal (BUY/SELL/HOLD)
+        2. Confidence (High/Medium/Low)
+        3. RSI Level
+        4. Key Price Levels
+        """
+        
+        chat_completion = groq_client.chat.completions.create(
+            messages=[{"role": "user", "content": prompt}],
+            model="mixtral-8x7b-32768",
+            temperature=0.3,
+            max_tokens=150
+        )
+        return chat_completion.choices[0].message.content
+    except Exception as e:
+        return f"AI analysis failed: {e}"
 
-    # Basic bullish/bearish detection
-    if latest_candle["close"] > latest_candle["open"] and latest_candle["close"] > prev_candle["close"]:
-        return "🔥 STRONG UPTREND - BUY Signal (Bullish Candle + Higher Close)"
-    elif latest_candle["close"] < latest_candle["open"] and latest_candle["close"] < prev_candle["close"]:
-        return "📉 STRONG DOWNTREND - SELL Signal (Bearish Candle + Lower Close)"
-    elif latest_candle["close"] > latest_candle["open"]:
-        return "🟢 Mild Bullish - Consider BUY"
+def analyze_candles(candles):
+    """AI + Technical Analysis"""
+    if not candles or len(candles) < 3:
+        return "Waiting for more data..."
+    
+    # Technical analysis
+    last_close = candles[max(candles.keys())]["close"]
+    prev_close = candles[sorted(candles.keys())[-2]]["close"]
+    
+    if last_close > prev_close * 1.005:  # Strong bullish
+        tech_signal = "🔥 STRONG UPTREND - BUY"
+    elif last_close < prev_close * 0.995:  # Strong bearish
+        tech_signal = "📉 STRONG DOWNTREND - SELL"
     else:
-        return "🔴 Mild Bearish - Consider SELL"
+        tech_signal = "🟡 WEAK TREND - HOLD"
+    
+    # AI Input
+    market_data = f"""
+    Latest Candle: 
+    - Open: {last_candle["open"]}
+    - Close: {last_candle["close"]}
+    - High: {last_candle["high"]}
+    - Low: {last_candle["low"]}
+    - Volume: {last_candle["vol"]}  
+    """
+    ai_signal = get_ai_recommendation(market_data)
+
+    return f"""\n
+    📊 **TECHNICAL ANALYSIS:**  
+    {tech_signal}  
+    🤖 **AI RECOMMENDATION:**  
+    {ai_signal}"""
 
 def background_worker(pair: str, timeframe: str):
     try:
-        if not client.connect():
-            print("[ERROR] Failed to connect to Quotex")
-            return
-
-        client.change_account(AccountType.PRACTICE)
-
-        period_map = {
-            "5s": CandlesPeriod.SEC_5,
-            "15s": CandlesPeriod.SEC_15,
-            "1m": CandlesPeriod.ONE_MINUTE,
-            "5m": CandlesPeriod.FIVE_MINUTES,
-        }
-        period = period_map[timeframe]
-        client.start_candles_stream(pair, 10, period)
-        
+        client.start_candles_stream(pair, 10, period_map[timeframe])
         while True:
             candles = client.get_realtime_candles(pair)
             if candles:
-                latest_ts = max(candles.keys())
-                candle_data = candles[latest_ts]
-                direction = "↑ (Bullish)" if candle_data["close"] > candle_data["open"] else "↓ (Bearish)"
-                timestamp = datetime.fromtimestamp(latest_ts / 1000).strftime("%H:%M:%S")
-                
-                entry = f"{timestamp} | {direction} | Close: {candle_data['close']:.5f}"
-                state.append(entry)
-                
-                # Generate new recommendation every 5 candles
-                if len(state) % 5 == 0:
-                    recommendation = analyze_candle_pattern(candles)
-                    trade_recommendations.append(f"⏱️ {timestamp} | {recommendation}")
-                
-                if len(state) > 100:
-                    state.pop(0)
-            time.sleep(1)
+                analysis = analyze_candles(candles)
+                trade_recommendations.append(analysis)
+            time.sleep(5)  # Refresh every 5 sec
     except Exception as e:
-        print(f"[ERROR] Worker crashed: {e}")
+        print(f"❌ Worker error: {e}")
 
 def start(pair, timeframe):
-    global state, trade_recommendations
     state.clear()
     trade_recommendations.clear()
-    threading.Thread(target=background_worker, args=(pair, timeframe), daemon=True).start()
-    return "✅ Bot is now analyzing market data..."
-
-def get_latest_candles():
-    """Display last 5 candles."""
-    return "\n".join(state[-5:][::-1]) or "No data yet."
-
-def get_latest_recommendations():
-    """Display last 3 trade recommendations."""
-    return "\n".join(trade_recommendations[-3:][::-1]) or "Waiting for recommendations..."
+    threading.Thread(
+        target=background_worker,
+        args=(pair, timeframe),
+        daemon=True
+    ).start()
+    return "🔄 Analyzing market..."
 
-with gr.Blocks(title="Quotex Trading Bot") as demo:
-    gr.Markdown("## 📊 Quotex Trading Bot")
+with gr.Blocks() as demo:
+    gr.Markdown("## 🤖 AI Trading Assistant")
+    gr.Markdown("### Real-time Candle Analysis")
     
     with gr.Row():
-        pair = gr.Dropdown(["EURUSD", "USDJPY", "BTCUSD"], label="Select Currency Pair")
-        timeframe = gr.Dropdown(["5s", "15s", "1m", "5m"], label="Select Timeframe")
-        start_btn = gr.Button("Start Bot")
-        refresh_btn = gr.Button("Refresh Data")
+        pair = gr.Dropdown(choices=["EURUSD", "USDJPY", "BTCUSD"], label="Pair")
+        timeframe = gr.Dropdown(choices=["5s", "15s", "1m", "5m"], label="Timeframe")
+        start_btn = gr.Button("Start AI Analysis")
     
-    status = gr.Textbox(label="Status")
-    gr.Markdown("### 🕯️ Latest Candles")
-    candle_output = gr.Textbox(label="Market Data")
-    gr.Markdown("### 🤖 Trade Recommendations")
-    recommendation_output = gr.Textbox(label="AI Recommendations")
+    gr.Markdown("---")
+    
+    with gr.Column():
+        gr.Markdown("### 📜 Last 10 Candles")
+        candle_output = gr.Textbox()
+        
+        gr.Markdown("### 🗃️ Trading Signals")
+        ai_output = gr.Textbox(label="AI + Technical Signals")
 
     start_btn.click(
-        fn=start,
+        start,
         inputs=[pair, timeframe],
-        outputs=status
+        outputs=[candle_output, ai_output]
     )
-    
-    refresh_btn.click(
-        fn=get_latest_candles,
-        outputs=candle_output
-    )
-    
-    refresh_btn.click(
-        fn=get_latest_recommendations,
-        outputs=recommendation_output
+    demo.load(
+        get_latest_recommendations,
+        outputs=ai_output,
+        every=5  # Refresh signals every 5 seconds
     )
 
 if __name__ == "__main__":