Create app.py

app.py

@@ -0,0 +1,257 @@
+import streamlit as st
+import os
+import json
+import time
+import threading
+import base64
+from datetime import datetime
+from playwright.sync_api import sync_playwright
+from groq import Groq
+
+# --- CONFIGURATION ---
+GROQ_API_KEY = "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"  # Apni key yahan lagayen
+DATA_DIR = "/code/data"
+AUTH_FILE = os.path.join(DATA_DIR, "auth.json")
+MEMORY_FILE = os.path.join(DATA_DIR, "bot_memory.json")
+
+# Initialize Groq
+client = Groq(api_key=GROQ_API_KEY)
+
+# --- GLOBAL STATE MANAGED IN MEMORY ---
+if "bot_status" not in st.session_state:
+    st.session_state.bot_status = "Idle"
+if "logs" not in st.session_state:
+    st.session_state.logs = []
+
+# Global variables for background thread access
+class BotState:
+    browser = None
+    context = None
+    page = None
+    playwright = None
+    is_running = False
+    latest_screenshot = None
+    
+bot = BotState()
+
+# --- HELPER FUNCTIONS ---
+
+def log(message):
+    timestamp = datetime.now().strftime("%H:%M:%S")
+    entry = f"[{timestamp}] {message}"
+    print(entry)
+    st.session_state.logs.append(entry)
+    # Keep log size manageable
+    if len(st.session_state.logs) > 50:
+        st.session_state.logs.pop(0)
+
+def save_memory(task, status):
+    """AI ki memory save karta hai taake usay yaad rahe"""
+    data = {"last_task": task, "status": status, "timestamp": str(datetime.now())}
+    with open(MEMORY_FILE, 'w') as f:
+        json.dump(data, f)
+
+def get_ai_decision(page_content, current_url):
+    """Groq AI se poochta hai ke ab kya karna chahiye"""
+    prompt = f"""
+    You are an autonomous CoinPayU Bot.
+    Current URL: {current_url}
+    Page Text Summary: {page_content[:1000]}...
+    
+    GOAL: Watch Ads, Click 'View', Solve Captchas (if simple), Complete Surveys.
+    
+    Return JSON ACTION:
+    {{"action": "click", "selector": "..."}} 
+    OR {{"action": "wait", "seconds": 10}}
+    OR {{"action": "navigate", "url": "..."}}
+    OR {{"action": "done"}}
+    """
+    try:
+        completion = client.chat.completions.create(
+            model="llama-3.3-70b-versatile",
+            messages=[{"role": "system", "content": "You are a JSON-only bot controller."},
+                      {"role": "user", "content": prompt}],
+            response_format={"type": "json_object"}
+        )
+        return json.loads(completion.choices[0].message.content)
+    except Exception as e:
+        log(f"AI Error: {e}")
+        return {"action": "wait", "seconds": 5}
+
+# --- BROWSER MANAGEMENT ---
+
+def start_browser():
+    if bot.browser: return
+    
+    bot.playwright = sync_playwright().start()
+    bot.browser = bot.playwright.chromium.launch(
+        headless=True,
+        args=['--no-sandbox', '--disable-blink-features=AutomationControlled']
+    )
+    
+    # Load session if exists
+    if os.path.exists(AUTH_FILE):
+        log("♻️ Loading saved session...")
+        bot.context = bot.browser.new_context(storage_state=AUTH_FILE, viewport={'width': 1280, 'height': 800})
+    else:
+        log("🆕 Starting fresh session...")
+        bot.context = bot.browser.new_context(viewport={'width': 1280, 'height': 800})
+    
+    bot.page = bot.context.new_page()
+    bot.page.goto("https://www.coinpayu.com/dashboard")
+    update_screenshot()
+
+def save_session():
+    """Login cookies save karta hai"""
+    if bot.context:
+        bot.context.storage_state(path=AUTH_FILE)
+        log("✅ Session Saved! Next time auto-login.")
+
+def update_screenshot():
+    if bot.page:
+        try:
+            screenshot_bytes = bot.page.screenshot(type='jpeg', quality=50)
+            bot.latest_screenshot = base64.b64encode(screenshot_bytes).decode('utf-8')
+        except: pass
+
+# --- AUTOMATION LOOPS ---
+
+def manual_interaction(action, selector=None, text=None):
+    """User ke commands handle karta hai"""
+    if not bot.page: start_browser()
+    
+    try:
+        if action == "click":
+            if selector: bot.page.click(selector)
+            else: # Click center if no selector (generic)
+                pass 
+        elif action == "goto":
+            bot.page.goto(text)
+        elif action == "type":
+            bot.page.keyboard.type(text)
+            bot.page.keyboard.press("Enter")
+        elif action == "scroll":
+            bot.page.mouse.wheel(0, 500)
+        
+        update_screenshot()
+    except Exception as e:
+        log(f"Error: {e}")
+
+def auto_farm_thread():
+    """Background thread jo chalta rahega"""
+    log("🤖 Auto-Bot Started...")
+    start_browser()
+    
+    while bot.is_running:
+        try:
+            page = bot.page
+            
+            # 1. Check if on Surf Ads Page
+            if "ads_surf" not in page.url:
+                log("Navigating to Surf Ads...")
+                page.goto("https://www.coinpayu.com/dashboard/ads_surf")
+                time.sleep(5)
+            
+            # 2. Find Ads
+            ads = page.query_selector_all(".ag-cell-value") # Common selector for CoinPayU ads
+            
+            if not ads:
+                log("No ads found or page loading. Checking AI...")
+                # Ask AI what to do if stuck
+                content = page.inner_text("body")
+                decision = get_ai_decision(content, page.url)
+                # Process AI decision (Simplified for this snippet)
+                time.sleep(5)
+                continue
+            
+            # 3. Process Ads
+            log(f"Found {len(ads)} Ads. Clicking first one...")
+            
+            # Context handle for new tab
+            with bot.context.expect_page() as new_page_info:
+                ads[0].click()
+            
+            ad_page = new_page_info.value
+            log("Watching Ad... (20s)")
+            
+            # Simulate Human behavior
+            time.sleep(5)
+            ad_page.mouse.wheel(0, 200)
+            time.sleep(15)
+            
+            ad_page.close()
+            log("Ad Closed. Earnings +++")
+            
+            # Save Memory
+            save_memory("Watched Ad", "Success")
+            
+            # Refresh to get new list
+            page.reload()
+            time.sleep(3)
+            update_screenshot()
+            
+        except Exception as e:
+            log(f"Bot Error: {e}")
+            time.sleep(5)
+
+# --- UI LAYOUT (STREAMLIT) ---
+
+st.set_page_config(layout="wide", page_title="CoinPayU AI Bot")
+
+st.title("🤖 CoinPayU Auto-Farmer (AI Powered)")
+
+col1, col2 = st.columns([2, 1])
+
+with col1:
+    st.subheader("Live Browser View")
+    image_placeholder = st.empty()
+    
+    # Auto-refresh loop for UI
+    if bot.latest_screenshot:
+        image_bytes = base64.b64decode(bot.latest_screenshot)
+        image_placeholder.image(image_bytes, caption="Live Feed", use_column_width=True)
+    else:
+        image_placeholder.info("Browser stopped or loading...")
+
+with col2:
+    st.subheader("Controls Panel")
+    
+    # Manual Controls
+    if st.button("🔵 Start Browser / Connect"):
+        start_browser()
+        st.rerun()
+        
+    if st.button("💾 Save Login Session"):
+        save_session()
+        st.success("Session Saved! Bot will auto-login next time.")
+
+    st.markdown("---")
+    st.write("**Manual Override:**")
+    user_input = st.text_input("Type text / URL")
+    c1, c2, c3 = st.columns(3)
+    if c1.button("Type"): manual_interaction("type", text=user_input)
+    if c2.button("Enter"): manual_interaction("type", text="\n") # Hack for Enter
+    if c3.button("Scroll"): manual_interaction("scroll")
+    
+    st.markdown("---")
+    st.subheader("🤖 AI Auto-Pilot")
+    
+    if st.button("🔥 START FARMING"):
+        if not bot.is_running:
+            bot.is_running = True
+            t = threading.Thread(target=auto_farm_thread)
+            t.start()
+            st.success("Bot is running in background!")
+            
+    if st.button("🛑 STOP"):
+        bot.is_running = False
+        st.warning("Stopping bot...")
+
+    st.markdown("---")
+    st.subheader("System Logs")
+    log_text = "\n".join(st.session_state.logs[::-1])
+    st.text_area("Logs", log_text, height=200)
+
+# Auto-refresh UI every 2 seconds to show live updates
+time.sleep(2)
+st.rerun()