Update app.py

app.py

@@ -1,6 +1,6 @@
 import requests
 from bs4 import BeautifulSoup
-from httpx import AsyncClient, HTTPError
+from httpx import Client, HTTPError
 from pydantic import BaseModel
 import re
 import urllib.parse
@@ -17,7 +17,7 @@ from selenium.webdriver.common.action_chains import ActionChains
 import time
 from webdriver_manager.chrome import ChromeDriverManager
 from tqdm import tqdm
-import asyncio
+import threading
 import gradio as gr
 
 load_dotenv()
@@ -108,93 +108,93 @@ def extract_video_id(url: str, platform: str) -> str:
     else:
         raise ValueError("Invalid URL format")
 
-async def instagram_login(username: str, password: str):
+def instagram_login(username: str, password: str):
     login_url = "https://www.instagram.com/accounts/login/ajax/"
-    async with AsyncClient() as session:
-        response = await session.get("https://www.instagram.com/", headers={"User-Agent": "Mozilla/5.0"})
-        soup = BeautifulSoup(response.text, "html.parser")
-        csrf_token = soup.find("meta", {"name": "csrf-token"})["content"]
-        login_data = {
-            "username": username,
-            "enc_password": f"#PWD_INSTAGRAM_BROWSER:0:&:{password}"
-        }
-        headers = {
-            "User-Agent": "Mozilla/5.0",
-            "X-CSRFToken": csrf_token,
-            "X-Requested-With": "XMLHttpRequest"
-        }
-        response = await session.post(login_url, data=login_data, headers=headers)
-        if response.status_code == 200 and response.json().get("authenticated"):
-            return session
-        else:
-            raise HTTPError("Authentication failed")
+    session = requests.Session()
+    response = session.get("https://www.instagram.com/", headers={"User-Agent": "Mozilla/5.0"})
+    soup = BeautifulSoup(response.text, "html.parser")
+    csrf_token = soup.find("meta", {"name": "csrf-token"})["content"]
+    login_data = {
+        "username": username,
+        "enc_password": f"#PWD_INSTAGRAM_BROWSER:0:&:{password}"
+    }
+    headers = {
+        "User-Agent": "Mozilla/5.0",
+        "X-CSRFToken": csrf_token,
+        "X-Requested-With": "XMLHttpRequest"
+    }
+    response = session.post(login_url, data=login_data, headers=headers)
+    if response.status_code == 200 and response.json().get("authenticated"):
+        return session
+    else:
+        raise HTTPError("Authentication failed")
 
-async def tiktok_login(username: str, password: str):
+def tiktok_login(username: str, password: str):
     login_url = "https://www.tiktok.com/login/"
-    async with AsyncClient() as session:
-        login_data = {
-            "username": username,
-            "password": password
-        }
-        response = await session.post(login_url, data=login_data)
-        if response.status_code == 200:
-            return session
-        else:
-            raise HTTPError("Authentication failed")
+    session = requests.Session()
+    login_data = {
+        "username": username,
+        "password": password
+    }
+    response = session.post(login_url, data=login_data)
+    if response.status_code == 200:
+        return session
+    else:
+        raise HTTPError("Authentication failed")
 
-async def youtube_login(username: str, password: str):
+def youtube_login(username: str, password: str):
     login_url = "https://accounts.google.com/ServiceLogin"
-    async with AsyncClient() as session:
-        login_data = {
-            "username": username,
-            "password": password
-        }
-        response = await session.post(login_url, data=login_data)
-        if response.status_code == 200:
-            return session
-        else:
-            raise HTTPError("Authentication failed")
+    session = requests.Session()
+    login_data = {
+        "username": username,
+        "password": password
+    }
+    response = session.post(login_url, data=login_data)
+    if response.status_code == 200:
+        return session
+    else:
+        raise HTTPError("Authentication failed")
 
-async def facebook_login(username: str, password: str):
+def facebook_login(username: str, password: str):
     login_url = "https://www.facebook.com/login"
-    async with AsyncClient() as session:
-        login_data = {
-            "email": username,
-            "pass": password
-        }
-        response = await session.post(login_url, data=login_data)
-        if response.status_code == 200:
-            return session
-        else:
-            raise HTTPError("Authentication failed")
+    session = requests.Session()
+    login_data = {
+        "email": username,
+        "pass": password
+    }
+    response = session.post(login_url, data=login_data)
+    if response.status_code == 200:
+        return session
+    else:
+        raise HTTPError("Authentication failed")
 
-async def twitch_login(username: str, password: str):
+def twitch_login(username: str, password: str):
     login_url = "https://www.twitch.tv/login"
-    async with AsyncClient() as session:
-        login_data = {
-            "login": username,
-            "password": password
-        }
-        response = await session.post(login_url, data=login_data)
-        if response.status_code == 200:
-            return session
-        else:
-            raise HTTPError("Authentication failed")
+    session = requests.Session()
+    login_data = {
+        "login": username,
+        "password": password
+    }
+    response = session.post(login_url, data=login_data)
+    if response.status_code == 200:
+        return session
+    else:
+        raise HTTPError("Authentication failed")
 
-async def spotify_login(username: str, password: str):
+def spotify_login(username: str, password: str):
     login_url = "https://accounts.spotify.com/api/token"
-    async with AsyncClient() as session:
-        login_data = {
-            "username": username,
-            "password": password
-        }
-        response = await session.post(login_url, data=login_data)
-        if response.status_code == 200:
-            return session
-        else:
-            raise HTTPError("Authentication failed")
+    session = requests.Session()
+    login_data = {
+        "username": username,
+        "password": password
+    }
+    response = session.post(login_url, data=login_data)
+    if response.status_code == 200:
+        return session
+    else:
+        raise HTTPError("Authentication failed")
 
-def simulate_instagram_view(video_id: str, proxy: Proxy, session: AsyncClient):
+def simulate_instagram_view(video_id: str, proxy: Proxy, session: Client):
     webdriver.DesiredCapabilities.CHROME['proxy'] = {
         "httpProxy": f"{proxy.ip}:{proxy.port}",
         "ftpProxy": f"{proxy.ip}:{proxy.port}",
@@ -230,7 +230,7 @@ def simulate_instagram_view(video_id: str, proxy: Proxy, session: AsyncClient):
         view_url = f"https://www.instagram.com/reel/{video_id}"
 
         if proxy.type == "http" or proxy.type == "https":
-            asyncio.run(session.get(view_url, headers=headers, proxies={"http": f"http://{proxy.ip}:{proxy.port}", "https": f"https://{proxy.ip}:{proxy.port}"})) 
+            session.get(view_url, headers=headers, proxies={"http": f"http://{proxy.ip}:{proxy.port}", "https": f"https://{proxy.ip}:{proxy.port}"})
 
         driver.get(view_url)
 
@@ -249,7 +249,7 @@ def simulate_instagram_view(video_id: str, proxy: Proxy, session: AsyncClient):
     finally:
         driver.quit()
 
-def simulate_tiktok_view(video_id: str, proxy: Proxy, session: AsyncClient):
+def simulate_tiktok_view(video_id: str, proxy: Proxy, session: Client):
     webdriver.DesiredCapabilities.CHROME['proxy'] = {
         "httpProxy": f"{proxy.ip}:{proxy.port}",
         "ftpProxy": f"{proxy.ip}:{proxy.port}",
@@ -285,7 +285,7 @@ def simulate_tiktok_view(video_id: str, proxy: Proxy, session: AsyncClient):
         view_url = f"https://www.tiktok.com/@user/video/{video_id}"
 
         if proxy.type == "http" or proxy.type == "https":
-            asyncio.run(session.get(view_url, headers=headers, proxies={"http": f"http://{proxy.ip}:{proxy.port}", "https": f"https://{proxy.ip}:{proxy.port}"})) 
+            session.get(view_url, headers=headers, proxies={"http": f"http://{proxy.ip}:{proxy.port}", "https": f"https://{proxy.ip}:{proxy.port}"})
 
         driver.get(view_url)
 
@@ -304,7 +304,7 @@ def simulate_tiktok_view(video_id: str, proxy: Proxy, session: AsyncClient):
     finally:
         driver.quit()
 
-def simulate_youtube_view(video_id: str, proxy: Proxy, session: AsyncClient):
+def simulate_youtube_view(video_id: str, proxy: Proxy, session: Client):
     webdriver.DesiredCapabilities.CHROME['proxy'] = {
         "httpProxy": f"{proxy.ip}:{proxy.port}",
         "ftpProxy": f"{proxy.ip}:{proxy.port}",
@@ -340,7 +340,7 @@ def simulate_youtube_view(video_id: str, proxy: Proxy, session: AsyncClient):
         view_url = f"https://www.youtube.com/watch?v={video_id}"
 
         if proxy.type == "http" or proxy.type == "https":
-            asyncio.run(session.get(view_url, headers=headers, proxies={"http": f"http://{proxy.ip}:{proxy.port}", "https": f"https://{proxy.ip}:{proxy.port}"}))
+            session.get(view_url, headers=headers, proxies={"http": f"http://{proxy.ip}:{proxy.port}", "https": f"https://{proxy.ip}:{proxy.port}"})
 
         driver.get(view_url)
 
@@ -359,7 +359,7 @@ def simulate_youtube_view(video_id: str, proxy: Proxy, session: AsyncClient):
     finally:
         driver.quit()
 
-def simulate_facebook_view(video_id: str, proxy: Proxy, session: AsyncClient):
+def simulate_facebook_view(video_id: str, proxy: Proxy, session: Client):
     webdriver.DesiredCapabilities.CHROME['proxy'] = {
         "httpProxy": f"{proxy.ip}:{proxy.port}",
         "ftpProxy": f"{proxy.ip}:{proxy.port}",
@@ -395,7 +395,7 @@ def simulate_facebook_view(video_id: str, proxy: Proxy, session: AsyncClient):
         view_url = f"https://www.facebook.com/{video_id}"
 
         if proxy.type == "http" or proxy.type == "https":
-            asyncio.run(session.get(view_url, headers=headers, proxies={"http": f"http://{proxy.ip}:{proxy.port}", "https": f"https://{proxy.ip}:{proxy.port}"}))
+            session.get(view_url, headers=headers, proxies={"http": f"http://{proxy.ip}:{proxy.port}", "https": f"https://{proxy.ip}:{proxy.port}"})
 
         driver.get(view_url)
 
@@ -414,7 +414,7 @@ def simulate_facebook_view(video_id: str, proxy: Proxy, session: AsyncClient):
     finally:
         driver.quit()
 
-def simulate_twitch_view(video_id: str, proxy: Proxy, session: AsyncClient):
+def simulate_twitch_view(video_id: str, proxy: Proxy, session: Client):
     webdriver.DesiredCapabilities.CHROME['proxy'] = {
         "httpProxy": f"{proxy.ip}:{proxy.port}",
         "ftpProxy": f"{proxy.ip}:{proxy.port}",
@@ -450,7 +450,7 @@ def simulate_twitch_view(video_id: str, proxy: Proxy, session: AsyncClient):
         view_url = f"https://www.twitch.tv/videos/{video_id}"
 
         if proxy.type == "http" or proxy.type == "https":
-            asyncio.run(session.get(view_url, headers=headers, proxies={"http": f"http://{proxy.ip}:{proxy.port}", "https": f"https://{proxy.ip}:{proxy.port}"}))
+            session.get(view_url, headers=headers, proxies={"http": f"http://{proxy.ip}:{proxy.port}", "https": f"https://{proxy.ip}:{proxy.port}"})
 
         driver.get(view_url)
 
@@ -469,7 +469,7 @@ def simulate_twitch_view(video_id: str, proxy: Proxy, session: AsyncClient):
     finally:
         driver.quit()
 
-def simulate_spotify_view(video_id: str, proxy: Proxy, session: AsyncClient):
+def simulate_spotify_view(video_id: str, proxy: Proxy, session: Client):
     webdriver.DesiredCapabilities.CHROME['proxy'] = {
         "httpProxy": f"{proxy.ip}:{proxy.port}",
         "ftpProxy": f"{proxy.ip}:{proxy.port}",
@@ -505,7 +505,7 @@ def simulate_spotify_view(video_id: str, proxy: Proxy, session: AsyncClient):
         view_url = f"https://open.spotify.com/track/{video_id}"
 
         if proxy.type == "http" or proxy.type == "https":
-            asyncio.run(session.get(view_url, headers=headers, proxies={"http": f"http://{proxy.ip}:{proxy.port}", "https": f"https://{proxy.ip}:{proxy.port}"}))
+            session.get(view_url, headers=headers, proxies={"http": f"http://{proxy.ip}:{proxy.port}", "https": f"https://{proxy.ip}:{proxy.port}"})
 
         driver.get(view_url)
 
@@ -524,11 +524,7 @@ def simulate_spotify_view(video_id: str, proxy: Proxy, session: AsyncClient):
     finally:
         driver.quit()
 
-def simulate_views_background(url: str, platform: str, count: int, delay: int, parallel_processes: int, session: AsyncClient = None):
-    for _ in range(parallel_processes):
-        asyncio.run(simulate_one_view_process(url, platform, count, delay, session))
-
-async def simulate_one_view_process(url: str, platform: str, count: int, delay: int, session: AsyncClient = None):
+def simulate_views_background(url: str, platform: str, count: int, delay: int, session: Client = None):
     video_id = extract_video_id(url, platform)
     proxy = get_random_proxy()
     if not proxy:
@@ -548,72 +544,73 @@ async def simulate_one_view_process(url: str, platform: str, count: int, delay:
                 simulate_twitch_view(video_id, proxy, session)
             elif platform == "spotify":
                 simulate_spotify_view(video_id, proxy, session)
-            await asyncio.sleep(delay)
+            time.sleep(delay)
         except Exception as e:
             pass
 
-async def simulate_views_endpoint(request: VisitRequest):
+def simulate_views_endpoint(request: VisitRequest):
     try:
         session = None
         if os.getenv(f'{request.platform.upper()}_USER') and os.getenv(f'{request.platform.upper()}_PASSWORD'):
-            session = await authenticate(os.getenv(f'{request.platform.upper()}_USER'), os.getenv(f'{request.platform.upper()}_PASSWORD'), request.platform)
-
-        asyncio.create_task(
-            simulate_views_background(
-                url=request.url,
-                platform=request.platform,
-                count=request.count,
-                delay=request.delay,
-                parallel_processes=request.parallel_processes,
-                session=session
+            session = authenticate(os.getenv(f'{request.platform.upper()}_USER'), os.getenv(f'{request.platform.upper()}_PASSWORD'), request.platform)
+
+        threading.Thread(
+            target=simulate_views_background,
+            args=(
+                request.url,
+                request.platform,
+                request.count,
+                request.delay,
+                session, 
             )
-        )
+        ).start()
 
         return "Views simulation started in the background."
 
     except Exception as e:
         return str(e)
 
-async def authenticate(username: str, password: str, platform: str):
+def authenticate(username: str, password: str, platform: str):
     if platform == "instagram":
-        return await instagram_login(username, password)
+        return instagram_login(username, password)
     elif platform == "tiktok":
-        return await tiktok_login(username, password)
+        return tiktok_login(username, password)
     elif platform == "youtube":
-        return await youtube_login(username, password)
+        return youtube_login(username, password)
     elif platform == "facebook":
-        return await facebook_login(username, password)
+        return facebook_login(username, password)
     elif platform == "twitch":
-        return await twitch_login(username, password)
+        return twitch_login(username, password)
     elif platform == "spotify":
-        return await spotify_login(username, password)
+        return spotify_login(username, password)
     else:
         raise ValueError("Invalid platform")
 
-async def login(username: str, password: str, platform: str):
+def login(username: str, password: str, platform: str):
     try:
-        session = await authenticate(username, password, platform)
+        session = authenticate(username, password, platform)
         return f"Authenticated on {platform}"
     except Exception as e:
         return str(e)
 
-async def simulate(urls: str, platform: str, count: int, delay: int, parallel_processes: int):
+def simulate(urls: str, platform: str, count: int, delay: int, parallel_processes: int):
     try:
         session = None
         if os.getenv(f'{platform.upper()}_USER') and os.getenv(f'{platform.upper()}_PASSWORD'):
-            session = await authenticate(os.getenv(f'{platform.upper()}_USER'), os.getenv(f'{platform.upper()}_PASSWORD'), platform)
-
-        for index, url in enumerate(urls.split("\n")):
-            asyncio.create_task(
-                simulate_views_background(
-                    url=url,
-                    platform=platform,
-                    count=count,
-                    delay=delay,
-                    parallel_processes=parallel_processes,
-                    session=session
-                )
-            )
+            session = authenticate(os.getenv(f'{platform.upper()}_USER'), os.getenv(f'{platform.upper()}_PASSWORD'), platform)
+
+        for url in urls.split("\n"):
+            for _ in range(parallel_processes):
+                threading.Thread(
+                    target=simulate_views_background,
+                    args=(
+                        url,
+                        platform,
+                        count,
+                        delay,
+                        session
+                    )
+                ).start()
         return "Simulations started in the background."
 
     except Exception as e:
@@ -622,8 +619,88 @@ async def simulate(urls: str, platform: str, count: int, delay: int, parallel_pr
 def rand(min, max):
     return random.randint(min, max)
 
-with gr.Blocks() as interface:
-    gr.Markdown("<h1>Video Views Simulator</h1>")
+with gr.Blocks(css="""
+        body {
+            background-color: #f0f0f0;
+            font-family: sans-serif;
+        }
+        .container {
+            background-color: #fff;
+            padding: 30px;
+            border-radius: 10px;
+            box-shadow: 0 2px 5px rgba(0, 0, 0, 0.1);
+            text-align: center;
+            animation: fadeIn 1s ease-in-out;
+        }
+        h1 {
+            color: #333;
+            margin-bottom: 20px;
+            text-shadow: 0 1px 2px rgba(0, 0, 0, 0.1);
+        }
+        form {
+            display: flex;
+            flex-direction: column;
+            width: 350px;
+        }
+        label {
+            margin-bottom: 5px;
+            font-weight: bold;
+        }
+        input[type="text"],
+        textarea,
+        select,
+        input[type="number"] {
+            padding: 10px;
+            margin-bottom: 15px;
+            border: 1px solid #ddd;
+            border-radius: 5px;
+        }
+        input[type="submit"] {
+            background-color: #007bff;
+            color: #fff;
+            border: none;
+            padding: 12px 20px;
+            border-radius: 5px;
+            cursor: pointer;
+            transition: background-color 0.3s;
+        }
+        input[type="submit"]:hover {
+            background-color: #0056b3;
+        }
+        @keyframes fadeIn {
+            from {
+                opacity: 0;
+            }
+            to {
+                opacity: 1;
+            }
+        }
+    """) as interface:
+    gr.Markdown("""
+        <div class="container">
+            <h1>Video Views Simulator</h1>
+            <form action="/simulate" method="post">
+                <label for="urls">Video URLs (one per line):</label><br>
+                <textarea id="urls" name="urls"></textarea><br><br>
+                <label for="platform">Platform:</label><br>
+                <select id="platform" name="platform">
+                    <option value="instagram">Instagram</option>
+                    <option value="tiktok">TikTok</option>
+                    <option value="youtube">YouTube</option>
+                    <option value="facebook">Facebook</option>
+                    <option value="twitch">Twitch</option>
+                    <option value="spotify">Spotify</option>
+                </select><br><br>
+                <label for="count">Number of Views:</label><br>
+                <input type="number" id="count" name="count" value="1"><br><br>
+                <label for="delay">Delay (seconds):</label><br>
+                <input type="number" id="delay" name="delay" value="1"><br><br>
+                <label for="parallel_processes">Parallel Processes:</label><br>
+                <input type="number" id="parallel_processes" name="parallel_processes" value="1"><br><br>
+                <input type="submit" value="Simulate">
+            </form>
+        </div>
+    """)
     with gr.Row():
         urls = gr.Textbox(label="Video URLs (one per line)")
         platform = gr.Dropdown(