Update main.py

main.py

@@ -17,51 +17,54 @@ from aiogram.client.telegram import TelegramAPIServer
 from apscheduler.schedulers.asyncio import AsyncIOScheduler
 
 # ╔═══════════════════════════════════════════════════════════════════╗
-# ║             🌉 THE CURL BRIDGE (HF PORT 7860 FIX)                ║
+# ║             🌉 THE CURL BRIDGE (BODY-LOSS FIX)                   ║
 # ╚═══════════════════════════════════════════════════════════════════╝
 
-# ⚠️ CRITICAL: Must be 7860 for Hugging Face to keep it alive
 BRIDGE_PORT = 7860
-
 PROXY_TARGET = "https://lucky-hat-e0d0.brukg9419.workers.dev"
 CLOUDFLARE_IP = "104.21.28.169"
 
 app = Flask(__name__)
 
-# ⚠️ CRITICAL: Health Check so HF sees we are online
+# Health Check
 @app.route('/')
 def health_check():
-    return "✅ PEKKA Bridge is Running on Port 7860!", 200
+    return "✅ PEKKA Bridge is Running!", 200
 
 def run_curl(method, url, data=None):
     parsed = urlparse(url)
     domain = parsed.hostname
     
+    # 1. Prepare Command
     cmd = [
         "curl", 
         "-X", method, url,
-        # ⚠️ IP Resolve Trick (Your Secret Sauce)
         "--resolve", f"{domain}:443:{CLOUDFLARE_IP}",
-        # ⚠️ User-Agent (Cloudflare blocks without this)
         "-H", "User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64)",
+        "-H", "Content-Type: application/json",
         "-k", "-s", "--max-time", "30"
     ]
     
-    cmd.extend(["-H", "Content-Type: application/json"])
-    
+    # 2. Prepare Data (The Fix: Use stdin)
+    input_str = None
     if data:
-        cmd.extend(["-d", json.dumps(data)])
+        # Tell curl to read from stdin
+        cmd.append("--data-binary")
+        cmd.append("@-")
+        input_str = json.dumps(data)
 
     try:
-        # Debug Print: See exactly what we are sending
-        # print(f"➡️ Curl sending to {method} {url}") 
-        
+        # 3. Execute with Input Piped
         result = subprocess.run(
-            cmd, capture_output=True, text=True, timeout=35
+            cmd, 
+            input=input_str,       # Pass JSON string here
+            capture_output=True, 
+            text=True, 
+            timeout=35
         )
         
         if not result.stdout:
-            print(f"❌ [BRIDGE ERROR] Empty response! Stderr: {result.stderr}")
+            print(f"❌ [BRIDGE ERROR] Empty Curl Output. Stderr: {result.stderr}")
             return json.dumps({"ok": False, "description": "Empty Curl Response", "error_code": 500})
             
         return result.stdout
@@ -73,15 +76,20 @@ def run_curl(method, url, data=None):
 @app.route('/bot<token>/<method>', methods=['POST', 'GET'])
 def proxy(token, method):
     real_url = f"{PROXY_TARGET}/bot{token}/{method}"
-    data = request.json if request.is_json else request.args.to_dict()
     
-    # Run the Curl Command
-    response_text = run_curl(request.method, real_url, data)
+    # ⚠️ CRITICAL FIX: Force parse JSON even if header is slightly different
+    data = request.get_json(force=True, silent=True)
+    if not data:
+        # Fallback: check form data or args if JSON failed
+        data = request.form.to_dict() or request.args.to_dict()
     
+    # Debug: Print first 50 chars of data to prove we have it
+    # print(f"🔄 Proxying {method} | Data size: {len(str(data))}")
+
+    response_text = run_curl(request.method, real_url, data)
     return Response(response_text, mimetype='application/json')
 
 def start_bridge():
-    # ⚠️ CRITICAL: Host must be 0.0.0.0 (Public) not 127.0.0.1
     print(f"🚀 Starting Bridge on 0.0.0.0:{BRIDGE_PORT}")
     app.run(host="0.0.0.0", port=BRIDGE_PORT, threaded=True)
 
@@ -94,7 +102,6 @@ time.sleep(3)
 
 TELEGRAM_TOKEN = "8484056866:AAFdmEZCmedznAA2DWRkyFLjS6uTirVFMEQ" 
 
-# Connect Bot to Localhost:7860
 session = AiohttpSession(
     api=TelegramAPIServer.from_base(f"http://127.0.0.1:{BRIDGE_PORT}")
 )
@@ -104,14 +111,13 @@ scheduler = AsyncIOScheduler()
 
 @dp.message(CommandStart())
 async def handle_start(message: types.Message):
-    print("📩 Received /start command!")
+    print(f"📩 Received /start from {message.from_user.id}")
     try:
-        await message.answer("✅ PEKKA is Online (Port 7860 Fixed)!")
-        print("📤 Reply Sent Successfully!")
+        await message.answer("✅ PEKKA is Online (Body-Loss Fixed)!")
+        print("📤 Reply Sent!")
     except Exception as e:
         print(f"❌ Send Failed: {e}")
 
-# ── STARTUP ──
 async def on_startup():
     print("🤖 PEKKA AGENT IS STARTING...")
     scheduler.start()
@@ -121,7 +127,7 @@ async def main():
     try:
         await bot.delete_webhook(drop_pending_updates=True)
     except Exception as e:
-        print(f"⚠️ Webhook warning: {e}")
+        print(f"⚠️ Webhook warning (safe): {e}")
 
     await dp.start_polling(bot)