Update ai.py

ai.py

@@ -1,18 +1,18 @@
 import requests
 import time
 import pytz
-from news import get_news_about
+import json
 from datetime import datetime, timedelta
 from timeframe import fetch_financial_data
 
-
 def get_times():
     """Get current time in different financial centers"""
     # Define the time zones
     greenwich_tz = pytz.timezone('GMT')
     london_tz = pytz.timezone('Europe/London')
     newyork_tz = pytz.timezone('America/New_York')
-    dubai_tz = pytz.timezone('Asia/Dubai')
+    tokyo_tz = pytz.timezone('Asia/Tokyo')
+    sydney_tz = pytz.timezone('Australia/Sydney')
 
     # Get current UTC time
     utc_now = datetime.now(pytz.utc)
@@ -21,7 +21,8 @@ def get_times():
     greenwich_time = utc_now.astimezone(greenwich_tz)
     london_time = utc_now.astimezone(london_tz)
     newyork_time = utc_now.astimezone(newyork_tz)
-    dubai_time = utc_now.astimezone(dubai_tz)
+    tokyo_time = utc_now.astimezone(tokyo_tz)
+    sydney_time = utc_now.astimezone(sydney_tz)
 
     # Format the times
     time_format = "%Y-%m-%d %H:%M:%S %Z%z"
@@ -30,42 +31,13 @@ def get_times():
         "Greenwich": greenwich_time.strftime(time_format),
         "London": london_time.strftime(time_format),
         "New York": newyork_time.strftime(time_format),
-        "Dubai": dubai_time.strftime(time_format)
+        "Tokyo": tokyo_time.strftime(time_format),
+        "Sydney": sydney_time.strftime(time_format)
     }
 
     return times
 
-
-def capture_screenshot(url, browser_width=1280, browser_height=3000, full_page=True,
-                      device_scale_factor=1, format="png"):
-    """Capture a screenshot of a webpage using the Imagy API"""
-    api_endpoint = "https://gcp.imagy.app/screenshot/createscreenshot"
-
-    payload = {
-        "url": url,
-        "browserWidth": browser_width,
-        "browserHeight": browser_height,
-        "fullPage": full_page,
-        "deviceScaleFactor": device_scale_factor,
-        "format": format
-    }
-
-    headers = {
-        "Content-Type": "application/json",
-        "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/137.0.0.0 Safari/537.36"
-    }
-
-    try:
-        response = requests.post(api_endpoint, json=payload, headers=headers)
-        response.raise_for_status()
-        data = response.json()
-        return data.get("fileUrl")
-    except Exception as e:
-        print(f"Error capturing screenshot: {e}")
-        return None
-
-
-def chat_with_ai(chat_history, temperature=0.7):
+def chat_with_ai(chat_history, temperature=0.4):
     """Send chat history to AI and get response"""
     url = "https://corvo-ai-xx-ry.hf.space/chat"
 
@@ -96,223 +68,333 @@ def chat_with_ai(chat_history, temperature=0.7):
 
     return "عذراً، واجهت مشكلة في الاتصال. يرجى المحاولة مرة أخرى لاحقاً. 🙁"
 
+def fetch_pair_data(pair):
+    """
+    Fetch data for a pair in multiple timeframes with appropriate time ranges:
+    - 15m: 3 days of data
+    - 5m: 1 day of data
 
-def get_forex_data(pair, timeframes=["1d", "1h"]):
-    """Get forex data for a specific pair and timeframes"""
-    data = {}
+    Returns data for both timeframes or only what's available
+    """
+    now = datetime.now()
 
-    # Convert timeframes to Yahoo Finance format
-    timeframe_mapping = {
-        "1m": "1m",
-        "5m": "5m",
-        "15m": "15m",
-        "30m": "30m",
-        "1h": "60m",
-        "4h": "4h",
-        "1d": "1d"
-    }
+    # Determine if we need to add =X suffix
+    special_symbols = ["DX-Y.NYB", "GC=F", "^SPX", "WTI", "^TNX", "^FTSE"]
 
-    # List of special symbols that don't need =X suffix
-    special_symbols = ["DX-Y.NYB", "GC=F", "^SPX", "WTI", "^TNX" , "^FTSE"]
+    if pair in special_symbols:
+        symbol = pair  # Use symbol as is, without appending =X
+    else:
+        symbol = f"{pair}=X"  # Append =X for forex pairs
 
-    for tf in timeframes:
-        if tf in timeframe_mapping:
-            yahoo_tf = timeframe_mapping[tf]
+    print(f"Fetching data for {symbol}...")
 
-            # Check if the pair is in the special symbols list
-            if pair in special_symbols:
-                yahoo_symbol = pair  # Use symbol as is, without appending =X
-            else:
-                # Append =X to make it a proper Yahoo Finance forex symbol
-                yahoo_symbol = f"{pair}=X"
-
-            print(f"Fetching {yahoo_symbol} data for {tf} timeframe...")
-
-            # Set appropriate start date based on timeframe
-            if tf == "1d":
-                # For daily timeframe, get 7 days of data
-                start_date = datetime.now() - timedelta(days=7)
-            elif tf == "1h":
-                # For hourly timeframe, get 3 days of data
-                start_date = datetime.now() - timedelta(days=3)
-            else:
-                # Default fallback (shouldn't be needed with the current implementation)
-                start_date = datetime.now() - timedelta(days=5)
-
-            # Use the fetch_financial_data function from timeframe.py
-            result = fetch_financial_data(
-                symbol=yahoo_symbol,
-                start_date=start_date,
-                interval=yahoo_tf
-            )
+    timeframes = {}
 
-            if result['success']:
-                data[tf] = {
-                    'dataframe': result['data'],
-                    'stats': result['stats'],
-                    'table': result['table'],
-                    'meta_info': result['meta_info']
-                }
-                print(f"Successfully fetched {tf} data for {pair}")
-            else:
-                print(f"Failed to fetch {tf} data for {pair}: {result['message']}")
-                data[tf] = None
+    # Fetch 15-minute data (3 days)
+    try:
+        fifteen_min_start = now - timedelta(days=3)
+        fifteen_min_data = fetch_financial_data(
+            symbol=symbol,
+            start_date=fifteen_min_start,
+            end_date=now,
+            interval="15m"
+        )
+
+        if fifteen_min_data['success']:
+            timeframes["15m"] = fifteen_min_data
         else:
-            print(f"Unsupported timeframe: {tf}")
+            print(f"⚠️ Failed to fetch 15m data for {pair}: {fifteen_min_data['message']}")
+    except Exception as e:
+        print(f"⚠️ Error fetching 15m data for {pair}: {str(e)}")
 
-    return data
+    # Wait between requests to avoid rate limiting
+    time.sleep(1)
 
+    # Fetch 5-minute data (1 day)
+    try:
+        five_min_start = now - timedelta(days=1)
+        five_min_data = fetch_financial_data(
+            symbol=symbol,
+            start_date=five_min_start,
+            end_date=now,
+            interval="5m"
+        )
+
+        if five_min_data['success']:
+            timeframes["5m"] = five_min_data
+        else:
+            print(f"⚠️ Failed to fetch 5m data for {pair}: {five_min_data['message']}")
+            # Try 1-hour data as fallback if 5m fails
+            try:
+                hour_start = now - timedelta(days=7)  # Get a week of hourly data
+                hour_data = fetch_financial_data(
+                    symbol=symbol,
+                    start_date=hour_start,
+                    end_date=now,
+                    interval="60m"
+                )
+
+                if hour_data['success']:
+                    timeframes["1h"] = hour_data
+                    print(f"✅ Successfully fetched fallback 1h data for {pair}")
+            except Exception as e:
+                print(f"⚠️ Error fetching fallback 1h data for {pair}: {str(e)}")
+    except Exception as e:
+        print(f"⚠️ Error fetching 5m data for {pair}: {str(e)}")
+        # Try 1-hour data as fallback
+        try:
+            hour_start = now - timedelta(days=7)  # Get a week of hourly data
+            hour_data = fetch_financial_data(
+                symbol=symbol,
+                start_date=hour_start,
+                end_date=now,
+                interval="60m"
+            )
 
-def analyze_forex_group(group, description, relationships):
-    """Main function to analyze a group of forex pairs with their relationships"""
-    print(f"Analyzing forex group: {', '.join(group)}")
+            if hour_data['success']:
+                timeframes["1h"] = hour_data
+                print(f"✅ Successfully fetched fallback 1h data for {pair}")
+        except Exception as e:
+            print(f"⚠️ Error fetching fallback 1h data for {pair}: {str(e)}")
+
+    return timeframes
+
+def analyze_forex_pairs(pairs, description, deals=""):
+    """Main function to analyze a list of forex pairs"""
+    print(f"Analyzing forex pairs: {', '.join(pairs)}")
 
     # Step 1: Get current times in financial centers
     market_times = get_times()
     times_text = "\n".join([f"{k}: {v}" for k, v in market_times.items()])
 
-    # Step 2: Capture FinViz forex performance chart
-    finviz_url = "https://finviz.com/forex.ashx"
-    print("📸 Capturing Forex Performance Chart...")
-    performance_screenshot = capture_screenshot(finviz_url)
-    if performance_screenshot:
-        print(f"✅ Forex Performance Chart captured: {performance_screenshot}")
-    else:
-        print("❌ Failed to capture Forex Performance Chart")
+    # Step 2: Fetch data for all pairs
+    pairs_data = {}
+    for pair in pairs:
+        print(f"📊 Fetching data for {pair}...")
+        pairs_data[pair] = fetch_pair_data(pair)
+        time.sleep(1)  # Small delay between requests
 
-    # Prepare system prompt with market times, group context and relationships
-    system_prompt = f"""You are a Principal Forex Analyst specializing in technical analysis and correlation-based trading.
-Your task is to analyze the entire forex group: {', '.join(group)} and identify the strongest trading opportunities within this correlated group.
+    # Prepare system prompt with market times and group context
+    system_prompt = f"""
+You are a Senior Forex Analyst and Precision Entry Strategist specializing in intraday relationship-driven technical analysis.
 
-🕒 Current Market Times:
+📆 **Current Market Times**:
 {times_text}
 
-📌 Group Context: {description}
+🕐 **All analysis is based on Greenwich Mean Time (GMT)** to ensure accurate tracking of session overlaps.
+
+📊 **Session Times (GMT):**
+
+| ⏰ **التوقيت (GMT)** | 💥 **الجلسات المتداخلة** | 🌐 **العملات المستفيدة**                | 📝 **ملاحظات**                              |
+| ------------------- | ------------------------ | --------------------------------------- | ------------------------------------------- |
+| **00:00 – 02:00**   | **سيدني + طوكيو**        | AUD, NZD, JPY                           | بداية حركة آسيا – دعم للتقنيات المبكرة      |
+| **01:00 – 03:00**   | **ويلينغتون + طوكيو**    | NZD, JPY                                | نشاط خفيف – مفيد لتداول NZDJPY              |
+| **01:00 – 04:00**   | **سنغافورة + طوكيو**     | JPY, AUD, NZD                           | حجم تداول متوسط – بداية سيولة للسوق الآسيوي |
+| **06:00 – 08:00**   | **فرانكفورت + طوكيو**    | EUR, JPY                                | بداية الزخم الأوروبي – تحركات مبكرة         |
+| **07:00 – 09:00**   | **لندن + طوكيو**         | GBP, JPY, EUR, USD, AUD, NZD            | ⚡ سيولة عالية جدًا – ممتاز للسكالبينج       |
+| **07:00 – 10:00**   | **زيورخ + لندن**         | CHF, EUR, GBP                           | جلسة أوروبا الكاملة – نشاط مؤسسات           |
+| **08:00 – 09:00**   | **لندن + سنغافورة**      | GBP, SGD, JPY                           | بعض الفرص على GBPJPY / GBPSGD               |
+| **12:00 – 16:00**   | **لندن + نيويورك**       | ✅ USD, GBP, EUR, CHF, XAU, المؤشرات     | أقوى فترة في اليوم – تدفقات مؤسسات          |
+| **13:00 – 15:00**   | **نيويورك + فرانكفورت**  | USD, EUR                                | نشاط البيانات الاقتصادية الأمريكية          |
+| **13:00 – 16:00**   | **نيويورك + زيورخ**      | USD, CHF                                | مفيد لتداول USDCHF – حركات واضحة            |
+| **14:00 – 17:00**   | **نيويورك + شيكاغو**     | USD, الذهب (XAU), النفط (WTI), المؤشرات | العقود الأمريكية تبدأ بالحركة القوية        |
+| **22:00 – 00:00**   | **نيويورك + سيدني**      | USD, AUD, XAU                           | هدوء نسبي – مناسب لتحليل ما قبل الآسيوية    |
+
+
 
-🔗 Relationship Analysis:
-{relationships}
+🔁 Important Session Overlaps (High Liquidity):
 
-Your analysis must include the following:
+⏱️ Tokyo + Sydney: from 00:00 to 07:00  
+⏱️ Tokyo + London: from 07:00 to  09:00  
+⏱️ London + New York (most critical): from 12:00 to 16:00  
 
-1. Current market hours and which financial centers are active now.
-2. Comprehensive group analysis showing how these correlated pairs are moving together or if there are any notable divergences.
-3. Individual analysis of each pair in the group.
-4. Key support and resistance zones for each pair.
-5. How the described relationships are reflected in the current price action.
-6. Which pairs in the group show the strongest technical patterns.
-7. Volatility and liquidity conditions across the group.
-8. Impact of upcoming news events (if any) on the group dynamics.
-9. Potential for 40 to 70 pip price movement in any of the pairs.
+🚨🚨🚨 **EXTREMELY IMPORTANT RULE (DO NOT IGNORE):**  
+⛔ ONLY send a signal if the current time is BETWEEN the start and end of one of the defined session overlap periods (inclusive). That means every minute from the start time to the end time is valid.
+⛔ This is NOT optional — it is a **mandatory condition**.  
+⚠️ **NO signals allowed even if two sessions are open, UNLESS it is during these clearly defined overlap periods**.  
+🟥🟥🟥 **If the time is NOT during 00:00–07:00, 07:00–09:00, or 12:00–16:00 GMT — DO NOT send a signal. Period.**
+
+ALL THIS POINTS YOU CAN SKIP IT JUST IF THERE 100% SUCCES TRADE SIGNAL (MAKE SURE TO TELL ME I GIVE YOU SIGNAL NOW WITH 1 SESSION OPEN BECAUSE IT IS 100% SUCCES)
+
+✅ Priority is given to the overlap of **London + New York**, as it provides the clearest and strongest market movement.
+
+📌 **Pairs Under Review**:
+{pairs}
+
+📢 **Group Overview**:
+{description}
+
+📈 **User's Current Open Trades**:
+{deals}
+
+🚫 **You are not allowed to create a new signal on any pair that already has an open trade** — wait until the existing trade is closed.
 
 ---
 
-Your response **must** follow this exact structure:
+🎯 **Your Objective**
+You must analyze the available timeframe data to determine whether there is a clean technical setup supporting a potential **40 to 70 pip move** with minimal drawdown.
 
-<Group Analysis>
-Analyze the group as a whole, focusing on how the pairs interact according to their known correlations. Identify whether the correlations are still holding or if there are any notable divergences.
-</Group Analysis>
+Your analysis must always be based on **inter-pair and inter-asset relationships** — never analyze a single pair in isolation.
 
-<Individual Pair Analysis>
-Provide a concise technical analysis for each pair in the group:
+📉 Analysis should consider recent market conditions and price action from the timeframes available.
 
-PAIR1:
-- Current price action and technical structure
-- Key levels and patterns
-- Trend strength
-- Potential targets
+---
 
-PAIR2:
-- Current price action and technical structure
-- Key levels and patterns
-- Trend strength
-- Potential targets
+📊 **Entry Criteria**
+
+✅ **Confirmation Candle**
+- Must be one of the following (visible on the chart):
+  • Bullish/Bearish Engulfing
+  • Marubozu
+  • Pin Bar
+- The pattern must be clearly visible on the available charts
+❗ If no confirmation candle appears from this list, **do not send a signal** — wait for one to appear.
+
+🔁 **Market Trend Direction**
+- A clear short-term trend must be present on the available charts
+- It must align with directional bias based on group correlation
+
+📈 **Technical Filters**
+- ADX must be ≥ 20
+- RSI:
+  • Buy setups: between 45–70
+  • Sell setups: between 30–55
+- Volume: Preferably above average
+- Candle Quality:
+  • The last 3 candles must NOT be choppy, wick-heavy, or weak
+- Momentum Exhaustion Filter:
+  • Avoid entry if the last 5 candles moved more than 100 pips in total
+
+📍 **Support/Resistance Zone Proximity**
+- Entry must occur near or in reaction to a clearly defined zone
+- Price must be within 20 pips of the zone
+
+📰 **News Filter**
+- Avoid entry 30 minutes before or after any high-impact news event
+
+💼 **Risk-to-Reward Management**
+- Minimum R:R = 2.0
+- Target profit must be between 40 and 70 pips
 
-(Continue for the rest of the pairs in the group following the same format)
-</Individual Pair Analysis>
+---
+
+🧠 **Mandatory Output Format (Strict):**
 
-<Best Opportunities>
-Identify one or two pairs from the group that represent the strongest technical setups with a potential 40–70 pip movement. Explain why these opportunities stand out compared to other pairs in the group and how the correlation context strengthens this case.
-</Best Opportunities>
+```xml
+<Session>
+put herr is there any session openinig ?
+</Session>
+<MarketContext>
+Explain the current inter-pair relationships, such as EURUSD vs DXY or USDJPY vs US10Y. Mention any macro market flow if present.
+</MarketContext>
+
+<Analysis>
+Use the available chart data to assess candle structure, market behavior, confirmation pattern, volume, RSI, etc.
+Be precise and professional. Only highlight clean low-risk entry points.
+</Analysis>
 
 <Prediction>
-For each identified opportunity, clearly state:
-- The expected direction (bullish/bearish)
-- Specific price targets for the 40–70 pip move
-- Key levels that confirm or invalidate the prediction
-- Estimated timeframe for the move to develop
+State the expected direction (bullish or bearish), and whether a 40–70 pip move is likely within the next 1–3 hours based on current correlations and technicals.
 </Prediction>
 
-<Trading Strategy>
-Provide a strategic plan for trading the identified opportunities, including:
-- Entry zones
-- Stop loss considerations
-- Take profit targets
-- Risk management approach
-- How to use other pairs in the group as confirmation tools
-</Trading Strategy>
-
-<Correlation Warning>
-Highlight any potential risks or considerations when trading multiple pairs from the same correlated group.
-</Correlation Warning>
-
-<Forward>
-For the strongest one or two setups identified, indicate that they must be forwarded to the Deep Analyst specialized in the 15-minute timeframe for precise entry analysis. Explain:
-- Why this setup requires more detailed analysis on the 15-minute timeframe
-- What patterns, breakouts, or pullbacks the analyst should look for on the lower timeframe
-- Critical price zones for optimal entry with minimal risk
-- How the correlation with other pairs can be used to time entries precisely
-- The analyst should also consider what is happening on both the 1-hour and 1-day timeframes for each pair to understand the full context and optimize entry timing.
-</Forward>
-
-Always make sure to close tags properly (e.g., </Forward>)
-
-📌 Forwarding to the 15-minute timeframe analyst is crucial for:
-- Finding precise entry points with minimal risk
-- Identifying intraday patterns supporting the 1-hour analysis
-- Timing entries during pullbacks or breakout confirmations
-- Improving risk-to-reward ratio through tighter stop placement
-
-⚠️ This is **not** financial advice — only professional chart analysis for potential price movements.
-"""
-
-
-    # Build chat history with system prompt
+<Advice>
+Advise the trader to wait, monitor, or prepare for entry. Only suggest action if the structure is clean, the volume confirms, and the signal is valid.
+</Advice>
+
+<Invalidation>
+Clearly define what would invalidate the setup, such as a structural break, volume drop, or correlation failure.
+</Invalidation>
+🚨🚨🚨 MANDATORY FINAL STEP:
+📩 Your response MUST ALWAYS end with either:
+
+✅ A full signal using:
+
+
+<signal>
+    <pair>PAIR_NAME</pair>
+    <type>Buy or Sell</type>
+    <entry>Ideal entry price</entry>
+    <stop_loss>Technical stop loss</stop_loss>
+    <take_profit>Target profit (40–70 pips)</take_profit>
+    <duration>1–3 hours (or momentum-based)</duration>
+    <reason>
+        Detailed technical reasoning including candle type, zone interaction, volume confirmation, and group correlation support.
+    </reason>
+</signal>
+❌ OR a proper wait explanation using:
+
+
+<wait>
+Explain clearly what is missing or risky: no confirmation candle, weak correlation, low volume, unclear structure, or an existing trade on the pair.
+Also include if the current time is outside the required session overlap.
+</wait>
+⚠️ You are NOT allowed to give analysis or predictions without wrapping the output in <wait> or <signal> — it is mandatory to close with one of these tags in every single response.
+    # Build chat history with system prompt"""
+
+    
     chat_history = [
         {"role": "system", "content": system_prompt}
     ]
 
-    # Add Forex Performance screenshot
-    if performance_screenshot:
-        chat_history.append({
-            "role": "user",
-            "type": "multipart",
-            "content": [
-                {"type": "image", "url": performance_screenshot},
-                {"type": "text", "text": "Current Forex Relative Performance USD chart from FinViz"}
-            ]
-        })
-
-    # Get forex data for each pair and add to chat history
-    for pair in group:
-        timeframe_data = get_forex_data(pair, ["1d", "1h"])
-
-        # Add 1-day timeframe data
-        if timeframe_data.get("1d"):
+    # Add data for each pair as separate user messages for each timeframe
+    for pair, timeframes_data in pairs_data.items():
+        pair_data_added = False
+
+        # Add data for each available timeframe
+        for timeframe in ["15m", "5m", "1h"]:
+            if timeframe in timeframes_data and timeframes_data[timeframe]['success']:
+                chat_history.append({
+                    "role": "user",
+                    "content": f"**{pair} - {timeframe} Timeframe**\n\n{timeframes_data[timeframe]['table']}\n\n**Statistics:**\n{timeframes_data[timeframe]['stats']}\n\n**Meta Info:**\n{timeframes_data[timeframe]['meta_info']}"
+                })
+                pair_data_added = True
+
+        # If no data was added for this pair, inform the AI
+        if not pair_data_added:
             chat_history.append({
                 "role": "user",
-                "content": f"**{pair} - Daily (1D) Timeframe Data**\n\n{timeframe_data['1d']['table']}\n\n**Stats:**\n{timeframe_data['1d']['stats']}\n\n**Meta Info:**\n{timeframe_data['1d']['meta_info']}"
-            })
-
-        # Add 1-hour timeframe data
-        if timeframe_data.get("1h"):
-            chat_history.append({
-                "role": "user",
-                "content": f"**{pair} - Hourly (1H) Timeframe Data**\n\n{timeframe_data['1h']['table']}\n\n**Stats:**\n{timeframe_data['1h']['stats']}\n\n**Meta Info:**\n{timeframe_data['1h']['meta_info']}"
+                "content": f"**{pair} - No data available**\nUnable to fetch reliable data for this pair at the moment. Please analyze the other pairs in the group and mention that data for {pair} is currently unavailable."
             })
 
     # Get AI analysis
-    analysis = chat_with_ai(chat_history)
-    print(analysis)
-    print("Analysis complete!")
+    print("Sending data to AI for analysis...")
+    try:
+        analysis = chat_with_ai(chat_history)
+        print(analysis)
+        print("Analysis complete!")
+        return analysis
+    except Exception as e:
+        error_msg = f"Error during AI analysis: {str(e)}"
+        print(error_msg)
+
+        # If the payload is too large, try simplifying it
+        if len(str(chat_history)) > 10000000000:  # If chat history is very large
+            print("Chat history is too large. Simplifying data...")
+            simplified_chat_history = [
+                {"role": "system", "content": system_prompt}
+            ]
 
-    return analysis
+            for pair, timeframes_data in pairs_data.items():
+                if "15m" in timeframes_data and timeframes_data["15m"]["success"]:
+                    # Only include table without stats and meta info
+                    simplified_chat_history.append({
+                        "role": "user",
+                        "content": f"**{pair} - 15m Timeframe**\n\n{timeframes_data['15m']['table']}"
+                    })
+                elif "1h" in timeframes_data and timeframes_data["1h"]["success"]:
+                    # Fall back to hourly data if 15m isn't available
+                    simplified_chat_history.append({
+                        "role": "user",
+                        "content": f"**{pair} - 1h Timeframe**\n\n{timeframes_data['1h']['table']}"
+                    })
+
+            try:
+                print("Retrying with simplified data...")
+                analysis = chat_with_ai(simplified_chat_history)
+                
+                print("Analysis with simplified data complete!")
+                return analysis
+            except Exception as e2:
+                return f"Error during analysis even with simplified data: {str(e2)}\n\nPlease try again later with fewer pairs or a shorter timeframe."
+
+        return error_msg