Update app.py

app.py

@@ -1,24 +1,40 @@
 import os
 import time
 import random
+import threading
+from http.server import SimpleHTTPRequestHandler, HTTPServer
 from playwright.sync_api import sync_playwright
 from groq import Groq
 from dotenv import load_dotenv
 
 load_dotenv()
 
-# Initialize Groq client with your API key
-# Kimi K2.6 can be called through Groq's model routing if configured, or OpenRouter/DeepInfra
+# --- HUGGING FACE PORT BIND FIX ---
+def run_health_server():
+    """Starts a lightweight server on port 7860 so HF knows the Space is alive"""
+    class HealthHandler(SimpleHTTPRequestHandler):
+        def do_GET(self):
+            self.send_response(200)
+            self.send_header("Content-type", "text/html")
+            self.end_headers()
+            self.wfile.write(b"Bot is running actively in the background!")
+
+    # Hugging Face automatically assigns port 7860
+    port = int(os.environ.get("PORT", 7860))
+    server = HTTPServer(("0.0.0.0", port), HealthHandler)
+    print(f"Health check server listening on port {port}...")
+    server.serve_forever()
+
+# Initialize Groq client
 groq_client = Groq(api_key=os.getenv("GROQ_API_KEY"))
-KIMI_MODEL = "moonshotai/kimi-k2.6"  # Or your specific Groq model ID string
+KIMI_MODEL = "moonshotai/kimi-k2.6"
 
 def get_ai_response(user_message):
-    """Fetches a clear response from Kimi K2.6 without internal thinking text"""
     try:
         completion = groq_client.chat.completions.create(
             model=KIMI_MODEL,
             messages=[
-                {"role": "system", "content": "You are a helpful Instagram DM automation assistant. Give direct, crisp, and concise replies under 3 sentences. No internal reasoning, thoughts, or formatting blocks."},
+                {"role": "system", "content": "You are a helpful Instagram DM automation assistant. Give direct, crisp, and concise replies under 3 sentences. No internal reasoning."},
                 {"role": "user", "content": user_message}
             ]
         )
@@ -28,25 +44,21 @@ def get_ai_response(user_message):
         return "Hey! I'm processing your request. Give me just a moment."
 
 def human_type(element, text):
-    """Types out text with random variations in keystroke speed to bypass bot detection"""
     for char in text:
         element.type(char)
         time.sleep(random.uniform(0.05, 0.15))
 
 def run_bot():
     with sync_playwright() as p:
-        # CRITICAL: headless=False makes the browser render visually inside Xvfb
         print("Launching visible Chromium browser instance...")
         browser = p.chromium.launch(
             headless=False, 
             args=["--no-sandbox", "--disable-setuid-sandbox"]
         )
         
-        # Emulate a standard laptop screen resolution
         context = browser.new_context(viewport={"width": 1366, "height": 768})
         page = context.new_page()
         
-        # --- LOGIN PHASE ---
         print("Navigating to Instagram...")
         page.goto("https://www.instagram.com/accounts/login/", wait_until="networkidle")
         
@@ -57,30 +69,23 @@ def run_bot():
         time.sleep(random.uniform(1, 2))
         
         page.click("button[type='submit']")
-        print("Login credentials submitted. Waiting for dashboard...")
+        print("Login credentials submitted.")
         
-        # Wait for security checkpoints / main feed to load
         page.wait_for_url("**/instagram.com/**", timeout=60000)
         time.sleep(5)
         
-        # --- DM CHECK LOOP ---
         print("Navigating to Inbox...")
         page.goto("https://www.instagram.com/direct/inbox/", wait_until="networkidle")
         
         while True:
             try:
-                # Look for unread chat rows in the sidebar list layout
-                # Instagram dynamically updates class strings, but unread items usually feature bold text styles
                 unread_chats = page.query_selector_all("div[style*='font-weight: 600']") 
-                
                 if unread_chats:
                     print(f"Found {len(unread_chats)} unread conversation thread(s)!")
-                    
                     for chat in unread_chats:
                         chat.click()
                         time.sleep(2)
                         
-                        # Grab the last message bubble text incoming from the user
                         message_bubbles = page.query_selector_all("div[role='row'] >> span")
                         if not message_bubbles:
                             continue
@@ -88,11 +93,9 @@ def run_bot():
                         last_message_text = message_bubbles[-1].inner_text()
                         print(f"Received Message: {last_message_text}")
                         
-                        # Get response from Kimi K2.6
                         ai_reply = get_ai_response(last_message_text)
                         print(f"Kimi K2.6 Reply: {ai_reply}")
                         
-                        # Locate text box and type reply
                         message_input = page.wait_for_selector("div[role='textbox'][aria-label*='Message']")
                         message_input.click()
                         human_type(message_input, ai_reply)
@@ -100,17 +103,19 @@ def run_bot():
                         time.sleep(1)
                         page.keyboard.press("Enter")
                         print("Reply successfully dispatched.")
-                        
                         time.sleep(random.uniform(2, 4))
-                
             except Exception as loop_error:
                 print(f"Error checking messages: {loop_error}")
             
-            # Idle delay before checking for new messages again
             time.sleep(30)
 
 if __name__ == "__main__":
     if not os.getenv("IG_USERNAME") or not os.getenv("IG_PASSWORD"):
         print("Missing environment configurations! Set IG_USERNAME and IG_PASSWORD.")
     else:
+        # Start the health check server in a background thread
+        health_thread = threading.Thread(target=run_health_server, daemon=True)
+        health_thread.start()
+        
+        # Now run your main bot script
         run_bot()