Update app.py

app.py

@@ -1,13 +1,76 @@
-import asyncio
+ asyncio
 import base64
+import json
+import subprocess
+import threading
+import time
+from urllib.parse import urlparse
 
+from flask import Flask, request, Response
 from aiogram import Bot, Dispatcher, F
 from aiogram.enums import ChatType
 from aiogram.filters import Command, CommandStart
 from aiogram.types import FSInputFile, Message
+from aiogram.client.session.aiohttp import AiohttpSession
+from aiogram.client.telegram import TelegramAPIServer
 
 from agent1 import Config, DB, engine, scheduler, supabase_store
 
+# ╔═══════════════════════════════════════════════════════════════════╗
+# ║             🌉 THE CURL BRIDGE (HUGGING FACE BYPASS)             ║
+# ╚═══════════════════════════════════════════════════════════════════╝
+
+BRIDGE_PORT = 7860
+# We pull your URLs directly from your Config class!
+PROXY_TARGET = Config.PROXY_TARGET 
+CLOUDFLARE_IP = Config.CLOUDFLARE_IP 
+
+bridge_app = Flask(__name__)
+
+def run_curl(method, url, data=None):
+    parsed = urlparse(url)
+    domain = parsed.hostname
+    
+    cmd = [
+        "curl", "-X", method, url,
+        "--resolve", f"{domain}:443:{CLOUDFLARE_IP}",
+        "-H", "User-Agent: Mozilla/5.0",
+        "-H", "Content-Type: application/json",
+        "-k", "-s", "--max-time", "30"
+    ]
+    
+    input_str = None
+    if data:
+        cmd.extend(["--data-binary", "@-"])
+        input_str = json.dumps(data)
+
+    try:
+        result = subprocess.run(cmd, input=input_str, capture_output=True, text=True, timeout=35)
+        if not result.stdout:
+            return json.dumps({"ok": False, "description": "Empty Curl Response", "error_code": 500})
+        return result.stdout
+    except Exception as e:
+        return json.dumps({"ok": False, "description": str(e), "error_code": 500})
+
+@bridge_app.route('/bot<token>/<method>', methods=['POST', 'GET'])
+def proxy(token, method):
+    real_url = f"{PROXY_TARGET}/bot{token}/{method}"
+    data = request.get_json(force=True, silent=True)
+    if not data:
+        data = request.form.to_dict() or request.args.to_dict()
+    response_text = run_curl(request.method, real_url, data)
+    return Response(response_text, mimetype='application/json')
+
+def start_bridge():
+    print(f"🚀 Starting Bridge on 0.0.0.0:{BRIDGE_PORT}")
+    bridge_app.run(host="0.0.0.0", port=BRIDGE_PORT, threaded=True)
+
+# Start the bridge in the background IMMEDIATELY
+threading.Thread(target=start_bridge, daemon=True).start()
+time.sleep(3)
+
+# ── KEEP YOUR dp = Dispatcher() AND ALL YOUR MESSAGE HANDLERS BELOW THIS LINE ──
+
 
 dp = Dispatcher()
 
@@ -233,24 +296,26 @@ async def notify_boss_messages(bot: Bot):
 
 
 async def main():
-    from aiogram.client.session.aiohttp import AiohttpSession
-    from aiogram.client.telegram import TelegramAPIServer
-
     if not Config.BOT_TOKEN:
         raise RuntimeError("BOT_TOKEN is missing")
-        
-    # ⚡️ THE BRUKGUARDIAN PROXY HIJACK ⚡️
-    # This grabs your Cloudflare Worker URL from agent1.py and smashes the DNS block!
+    
+    # Connect the bot to the local Flask bridge we just built
     custom_session = AiohttpSession(
-        api=TelegramAPIServer.from_base(Config.PROXY_TARGET)
+        api=TelegramAPIServer.from_base(f"http://127.0.0.1:{BRIDGE_PORT}")
     )
-
-    # Initialize the bot using our custom, unblockable session
-    bot = Bot(token=Config.BOT_TOKEN, session=custom_session)
+    
+    bot = Bot(token=Config.BOT_TOKEN, session=custom_session, parse_mode="HTML")
     
     scheduler.set_bot(bot)
     await scheduler.start()
     asyncio.create_task(notify_boss_messages(bot))
+    
+    print("🤖 BRUKGUARDIAN AGENTFORGE IS STARTING...")
+    try:
+        await bot.delete_webhook(drop_pending_updates=True)
+    except Exception:
+        pass
+
     await dp.start_polling(bot)
 
 if __name__ == "__main__":