Upload 4 files

ai_api.py

@@ -0,0 +1,45 @@
+import requests
+import json
+import time
+
+def thinking_animation():
+    """
+    دالة بسيطة للاستخدام أثناء الانتظار (ليست ضرورية).
+    """
+    for _ in range(3):
+        print(".", end="", flush=True)
+        time.sleep(0.5)
+
+def call_o1_ai_api(formatted_chat_history):
+    """
+    يُرسِل المحادثة الحالية إلى واجهة الذكاء الاصطناعي o1
+    ويعيد الرد مع تحديث المحادثة.
+    """
+    url = "https://corvo-ai-xx-gpt-5.hf.space/chat"
+    headers = {"Content-Type": "application/json"}
+    payload = {
+        "chat_history": formatted_chat_history
+    }
+    max_retries = 5
+    retry_delay = 10
+    timeout = 600
+
+    for attempt in range(max_retries):
+        try:
+            print("AI THINKING", end="", flush=True)
+            thinking_animation()
+            response = requests.post(url, headers=headers, data=json.dumps(payload), timeout=timeout)
+            response.raise_for_status()
+            assistant_response = response.json().get("assistant_response", "No response received.")
+            # Append the assistant response to chat history
+            formatted_chat_history.append({"role": "assistant", "content": assistant_response})
+            return assistant_response, formatted_chat_history
+        except requests.exceptions.Timeout:
+            print(f"Timeout on attempt {attempt + 1}, retrying...")
+            time.sleep(retry_delay)
+        except Exception as e:
+            print(f"Error on attempt {attempt + 1}: {e}, retrying...")
+            time.sleep(retry_delay)
+
+    return "Error processing request. Please try again.", formatted_chat_history
+

db_news.py

@@ -0,0 +1,125 @@
+import requests
+from bs4 import BeautifulSoup
+import json
+
+TOKEN = "_device_id=0038e28d4f7d4f9baf8f76b6b9fb8980; GHCC=Required:1-Analytics:1-SocialMedia:1-Advertising:1; MicrosoftApplicationsTelemetryDeviceId=c58113b4-9acb-4ba8-b9f2-4217bdef379a; MSFPC=GUID=79b87b010d464a8783fbf43e19eccddf&HASH=79b8&LV=202408&V=4&LU=1723654762596; _octo=GH1.1.1517954811.1753352111; cpu_bucket=lg; preferred_color_mode=dark; tz=Africa%2FTripoli; ai_session=v+6N2XPmhlxugZWyisQ+ZD|1753646990500|1753646990500; saved_user_sessions=155741452%3ASnvRnrrf0nAjVGrTz3q28Oda2y6wCt6rCADoDwrCx2M6pORt; user_session=SnvRnrrf0nAjVGrTz3q28Oda2y6wCt6rCADoDwrCx2M6pORt; __Host-user_session_same_site=SnvRnrrf0nAjVGrTz3q28Oda2y6wCt6rCADoDwrCx2M6pORt; tz=Africa%2FTripoli; color_mode=%7B%22color_mode%22%3A%22auto%22%2C%22light_theme%22%3A%7B%22name%22%3A%22light%22%2C%22color_mode%22%3A%22light%22%7D%2C%22dark_theme%22%3A%7B%22name%22%3A%22dark%22%2C%22color_mode%22%3A%22dark%22%7D%7D; logged_in=yes; dotcom_user=omarnuwrar; _gh_sess=7FzMK5K8ffnmyyh5LKKv%2FOXiqZJR4qLXxTdaV66E844ZCPq5qw%2FClaVmXHNfu8oc61N461wsjEr7d8vhEwrs0N0X7ITUed9Zj01RnwHGT8mMRUn6oYSv94LpIh2FwmotPwp8jkSQkZ%2BotdEpdYtp3ZoJZKfiZOcpHBtT7g2VwIPgoW2Qx5RpnKNdI3Hq31C6IIPaSzAqqny7O7c6L8nWv1nfx%2FAbF4UFSo7UfW%2F9JLUYF5lVJ2kXdYoesKOL7c2KItGDTaZCwjYr9cHKlHWD4E9wLo22GjFveVKxrEz5dgIrNdAj8WxWXuY5Ou4eYmxaBn2ovIhvnFz8%2F6qLURX81YxLLZbymGERA3MaRzDDzY3yE76U8y8lLPve0Duqc0lr34R3XUiMKE5A3%2FNPQ273e36yNlLsgBGDyuYIEcsQ84XLq2IQygBxX4y%2B6WSPwXAgOku6MiEP8Ro9ihF6scOhbJRrVCPp0toSY3RmJToUy6XRmBF2B0oyJstKbqLPfmZI8p%2B2bQo8DBKARHWWUzTJdjF%2BfgZtm%2Flb3qijcKT5I6SPU%2BiLMH%2Fl2GwHw73d1OFGUNy4tdLT5SO5vCFrf1GIiV7qUhhQdA21dXsAeQ4qoF5LHiGftyhOUBHto3ZZB%2FJ87uqACflXOfbbTCQCAYNa2u4o8I9iKQp9r2ripVxqQF1oyVu12FSIN%2BS%2Fd4Rm%2FN7E1tOw3tcVgYcsFEcbsOViUZBXXmo1Qfd9H%2B4IGnbv3hZe%2FPeJqb33SxWeQpamEWhLjVJL2hMCbZ8v79azeUL93QzkLXuryStKTXOdoyrbD2n93V36z5Sxhzi9Ku6OxVK1PCZW0R7JiYtQOWoeMAMd4oe3Bqrxyc%2BdAdb0sW3L%2FOD8J2nbvJ5gGA%3D%3D--Ngvrt5zzlDZazWNi--k%2F8wjhX57aMmLOJc8i6L7w%3D%3D"
+# Step 1: Fetch the authenticity_token and commitOid from the GitHub edit page
+def fetch_authenticity_token_and_commit_oid():
+    url = "https://github.com/omarnuwrar/Trading/edit/main/news.json"
+
+    headers = {
+        "cookie": TOKEN,
+        "if-none-match": 'W/"2ff86bd1792cfee5ed79ee070b3b46de"',
+        "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36",
+        "x-github-target": "dotcom",
+        "x-react-router": "json",
+        "x-requested-with": "XMLHttpRequest",
+    }
+
+    response = requests.get(url, headers=headers)
+
+    if response.status_code == 200:
+        soup = BeautifulSoup(response.text, 'html.parser')
+        script_tag = soup.find("script", {"type": "application/json", "data-target": "react-app.embeddedData"})
+
+        if script_tag:
+            try:
+                json_data = json.loads(script_tag.string.strip())
+                authenticity_token = json_data["payload"]["csrf_tokens"]["/omarnuwrar/Trading/tree-save/main/news.json"]["post"]
+                commit_oid = json_data["payload"]["webCommitInfo"]["commitOid"]
+                return authenticity_token, commit_oid
+            except (KeyError, json.JSONDecodeError) as e:
+                print(f"Error: Failed to extract data. Details: {str(e)}")
+                return None, None
+        else:
+            print("Error: Could not find the required <script> tag.")
+            return None, None
+    else:
+        print(f"Error: Failed to fetch the page. Status code: {response.status_code}")
+        return None, None
+
+# Step 2: Send the POST request to update the news.json file
+def update_user_json_file(authenticity_token, commit_oid, new_content):
+    url = "https://github.com/omarnuwrar/Trading/tree-save/main/news.json"
+
+    headers = {
+        "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36",
+        "x-requested-with": "XMLHttpRequest",
+        "github-verified-fetch": "true",
+        "content-type": "application/x-www-form-urlencoded",
+        "cookie": TOKEN,
+    }
+
+    payload = {
+        "message": "Update news.json",
+        "placeholder_message": "Update news.json",
+        "description": "",
+        "commit-choice": "direct",
+        "target_branch": "main",
+        "quick_pull": "",
+        "guidance_task": "",
+        "commit": commit_oid,
+        "same_repo": "1",
+        "pr": "",
+        "content_changed": "true",
+        "filename": "news.json",
+        "new_filename": "news.json",
+        "value": new_content,
+        "authenticity_token": authenticity_token,
+    }
+
+    response = requests.post(url, headers=headers, data=payload)
+
+    if response.status_code == 200:
+        return {"success": True, "message": "news.json has been updated!"}
+    else:
+        return {"success": False, "message": f"Request failed with status code {response.status_code}", "details": response.text}
+
+
+
+# Function to fetch and extract the JSON data
+def fetch_json_from_github():
+    # URL of the GitHub page
+    url = "https://github.com/omarnuwrar/Trading/blob/main/news.json"
+    
+    # Custom headers
+    headers = {
+        "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36",
+        "Cookie": TOKEN
+    }
+
+    try:
+        # Fetch the HTML content of the page
+        response = requests.get(url, headers=headers)
+        response.raise_for_status()  # Raise an exception for HTTP errors
+
+        # Parse the HTML using BeautifulSoup
+        soup = BeautifulSoup(response.text, 'html.parser')
+        
+        # Find the <script> tag with type="application/json" and `data-target="react-app.embeddedData"`
+        script_tag = soup.find('script', {'type': 'application/json', 'data-target': 'react-app.embeddedData'})
+        if script_tag:
+            # Load the JSON content from the <script> tag
+            embedded_data = json.loads(script_tag.string)
+            
+            # Navigate to the "blob" > "rawLines" key for the JSON in the file
+            raw_lines = embedded_data.get("payload", {}).get("blob", {}).get("rawLines", [])
+            if raw_lines:
+                # The JSON content is in the first element of the rawLines list
+                json_content = raw_lines[0]
+                
+                # Parse the JSON content
+                data = json.loads(json_content)
+                
+                # Return the extracted JSON data
+                return {"success": True, "data": data}
+            else:
+                return {"success": False, "message": "JSON data not found in the 'rawLines' key."}
+        else:
+            return {"success": False, "message": "Could not find the <script> tag with embedded JSON data."}
+    except requests.exceptions.RequestException as e:
+        return {"success": False, "message": f"Error fetching data: {e}"}
+    except json.JSONDecodeError as je:
+        return {"success": False, "message": f"Error parsing JSON: {je}"}
+
+

fetch_news.py

@@ -0,0 +1,187 @@
+import requests
+from datetime import datetime, timedelta
+
+def fetch_news_items():
+    """
+    Fetch the main TradingView news feed for XAUUSD and DXY,
+    return it as a Python dictionary (JSON).
+    """
+    url = (
+        "https://news-mediator.tradingview.com/news-flow/v2/news"
+        "?filter=lang%3Aen&filter=symbol%3AOANDA%3AXAUUSD%2CTVC%3ADXY"
+        "&client=screener&streaming=true"
+    )
+    headers = {
+        "User-Agent": (
+            "Mozilla/5.0 (Windows NT 10.0; Win64; x64) "
+            "AppleWebKit/537.36 (KHTML, like Gecko) "
+            "Chrome/138.0.0.0 Safari/537.36"
+        )
+    }
+    response = requests.get(url, headers=headers)
+    response.raise_for_status()
+    return response.json()
+
+
+def fetch_story_by_id(story_id):
+    """
+    Given a story ID from the news feed, fetch its full content JSON
+    (shortDescription, astDescription, etc.) from TradingView.
+    """
+    base_url = "https://news-headlines.tradingview.com/v3/story"
+    params = {
+        "id": story_id,
+        "lang": "en"
+    }
+    headers = {
+        "User-Agent": (
+            "Mozilla/5.0 (Windows NT 10.0; Win64; x64) "
+            "AppleWebKit/537.36 (KHTML, like Gecko) "
+            "Chrome/138.0.0.0 Safari/537.36"
+        )
+    }
+    response = requests.get(base_url, headers=headers, params=params)
+    response.raise_for_status()
+    return response.json()
+
+
+def parse_ast_node(node):
+    """
+    Recursively parse an AST node from the 'astDescription' field:
+      - If it's a string, just return it.
+      - If it's a dictionary with a known 'type', handle it.
+      - Otherwise, parse children recursively.
+    """
+    if isinstance(node, str):
+        # Direct text
+        return node
+
+    if isinstance(node, dict):
+        node_type = node.get("type", "")
+        children = node.get("children", [])
+
+        if node_type == "root":
+            # 'root' typically contains multiple children; parse them all
+            return "".join(parse_ast_node(child) for child in children)
+
+        elif node_type == "p":
+            # Paragraph node: parse children, add a newline
+            paragraph_text = "".join(parse_ast_node(child) for child in children)
+            return paragraph_text + "\n"
+
+        elif node_type == "url":
+            # Format a hyperlink: [text](url)
+            params = node.get("params", {})
+            link_text = params.get("linkText", "")
+            url = params.get("url", "")
+            return f"{link_text} ({url})"
+
+        elif node_type == "symbol":
+            # Format a symbol mention
+            params = node.get("params", {})
+            symbol = params.get("symbol", "")
+            text = params.get("text", "")
+            return text if text else symbol
+
+        else:
+            # Unknown or unhandled node type; parse children anyway
+            return "".join(parse_ast_node(child) for child in children)
+
+    # If not string or dict (e.g., None?), return empty string
+    return ""
+
+
+def extract_full_content_from_story(story_data):
+    """
+    Extract the full textual content from a story, handling both
+    shortDescription and the more detailed astDescription if available.
+    """
+    # Try to get the AST description first (more detailed)
+    ast_description = story_data.get("astDescription")
+    if ast_description:
+        return parse_ast_node(ast_description)
+
+    # Fall back to short description if AST not available
+    return story_data.get("shortDescription", "No content available")
+
+
+def get_recent_news_items(hours=100):
+    """
+    Fetch recent news items within the specified number of hours
+    and return detailed information including publish time and full content.
+    """
+    # Get current time and calculate the threshold
+    now_utc = datetime.utcnow()
+    time_threshold = now_utc - timedelta(hours=hours)
+
+    # Fetch news data
+    news_data = fetch_news_items()
+    items = news_data.get("items", [])
+    detailed_news = []
+
+    for item in items:
+        item_id = item.get("id", "")
+        published_ts = item.get("published")
+
+        if not item_id or not published_ts:
+            continue
+
+        published_dt = datetime.utcfromtimestamp(published_ts)
+        if published_dt >= time_threshold:
+            # For each qualifying news item, fetch its full story content
+            try:
+                story_data = fetch_story_by_id(item_id)
+
+                # Create a detailed news item
+                detailed_item = {
+                    "id": item_id,
+                    "title": item.get("title", ""),
+                    "source": item.get("source", {}).get("name", ""),
+                    "published_time": published_dt.strftime("%Y-%m-%d %H:%M:%S UTC"),
+                    "timestamp": published_ts,
+                    "content": extract_full_content_from_story(story_data)
+                }
+                detailed_news.append(detailed_item)
+            except Exception as e:
+                print(f"Error fetching details for story {item_id}: {e}")
+
+    # Sort by timestamp descending (newest first)
+    detailed_news.sort(key=lambda x: x["timestamp"], reverse=True)
+    return detailed_news
+
+
+def build_news_summary(news_items):
+    """
+    Build a comprehensive summary of news items, including title, source,
+    publication time, and full content.
+    """
+    if not news_items:
+        return "No recent news available."
+
+    summaries = []
+    for item in news_items:
+        summary = (
+            f"📰 {item['title']}\n"
+            f"🔍 Source: {item['source']}\n"
+            f"⏰ Published: {item['published_time']}\n"
+            f"📝 Content:\n{item['content']}\n"
+            f"{'=' * 50}"
+        )
+        summaries.append(summary)
+        
+    return "\n\n".join(summaries)
+
+
+def get_formatted_news_summary(hours=24):
+    """
+    Convenience function to get a formatted news summary for the specified time period.
+    """
+    news_items = get_recent_news_items(hours)
+    return build_news_summary(news_items)
+
+
+# Example usage:
+if __name__ == "__main__":
+    print("Fetching recent gold and DXY news...")
+    news_summary = get_formatted_news_summary(48)  # Get news from the last 48 hours
+    print(news_summary)

get_price.py

@@ -0,0 +1,46 @@
+import requests
+
+def get_live_rates_for_pair(pair="XAUUSD"):
+    """
+    Get live Bid and Ask prices for a specified forex pair.
+    Returns dict with { "pair": ..., "bid": ..., "ask": ..., "difference": ... }
+    """
+    url = "https://research.titanfx.com/api/live-rate?group=forex"
+    headers = {
+        "referer": "https://research.titanfx.com/instruments/gbpusd",
+        "sec-ch-ua": "\"Not)A;Brand\";v=\"8\", \"Chromium\";v=\"138\", \"Google Chrome\";v=\"138\"",
+        "sec-ch-ua-mobile": "?0",
+        "sec-ch-ua-platform": "\"Windows\"",
+        "sec-fetch-dest": "empty",
+        "sec-fetch-mode": "cors",
+        "sec-fetch-site": "same-origin",
+        "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/138.0.0.0 Safari/537.36"
+    }
+
+    try:
+        response = requests.get(url, headers=headers)
+        response.raise_for_status()
+        data = response.json()
+
+        if pair not in data:
+            return None
+
+        pair_data = data[pair]
+        # Format bid price
+        bid_price = float(f"{pair_data[0]}.{pair_data[1]}")
+        # Format ask price
+        ask_price = float(f"{pair_data[2]}.{pair_data[3]}")
+        # Calculate difference
+        difference = ask_price - bid_price
+
+        return {
+            "pair": pair,
+            "bid": bid_price,
+            "ask": ask_price,
+            "difference": difference
+        }
+
+    except Exception as e:
+        print(f"Error while fetching price: {e}")
+        return None
+