Update app.py

app.py

@@ -12,7 +12,6 @@ import boto3
 from botocore.exceptions import NoCredentialsError
 from duckduckgo_search import DDGS
 from fp.fp import FreeProxy
-import requests_random_user_agent
 
 app = FastAPI()
 
@@ -31,7 +30,7 @@ INVIDIOUS_INSTANCES = [
     "https://invidious.adminforge.de"
 ]
 API_KEY = os.environ.get("API_KEY")
-TIMEOUT = 1  # Timeout for requests in seconds
+TIMEOUT = 20  # Timeout for requests in seconds
 
 # S3 Configuration
 S3_ACCESS_KEY_ID = os.environ.get("S3_ACCESS_KEY_ID")
@@ -44,7 +43,7 @@ if not all([API_KEY, S3_ACCESS_KEY_ID, S3_SECRET_ACCESS_KEY, S3_BUCKET, S3_REGIO
 
 def get_proxy():
     return FreeProxy(
-        timeout=TIMEOUT,
+        timeout=0.9,  # Set timeout to 0.9 seconds
         rand=True,
         https=True
     ).get()
@@ -54,7 +53,7 @@ async def search_and_get_videos(query: str, num_videos: int = 2) -> List[Dict]:
         url = f"{instance}/api/v1/search?q={query}&type=video"
         try:
             async with aiohttp.ClientSession() as session:
-                async with session.get(url, headers={"User-Agent": requests_random_user_agent.get_random_user_agent()}, proxy=get_proxy()) as response:
+                async with session.get(url) as response:
                     response.raise_for_status()
                     search_results = await response.json()
                     videos = [
@@ -80,7 +79,7 @@ async def get_youtube_audio(video_id: str, max_retries: int = 3) -> Dict:
                 url = f"{instance}/api/v1/videos/{video_id}"
                 
                 async with aiohttp.ClientSession() as session:
-                    async with session.get(url, headers={"User-Agent": requests_random_user_agent.get_random_user_agent()}, proxy=get_proxy()) as response:
+                    async with session.get(url) as response:
                         response.raise_for_status()
                         video_data = await response.json()
                         
@@ -91,7 +90,7 @@ async def get_youtube_audio(video_id: str, max_retries: int = 3) -> Dict:
                             audio_url = audio_format.get('url')
                             if audio_url:
                                 try:
-                                    async with session.get(audio_url, proxy=get_proxy()) as audio_response:
+                                    async with session.get(audio_url) as audio_response:
                                         audio_content = await audio_response.read()
                                         
                                         with tempfile.NamedTemporaryFile(delete=False, suffix='.m4a') as temp_file:
@@ -163,7 +162,7 @@ def web_search(query: str, num_results: int = 5) -> dict:
         with DDGS(
             proxy=proxy,
             timeout=TIMEOUT,
-            headers={'User-Agent': requests_random_user_agent.get_random_user_agent()}
+            headers={'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36'}
         ) as ddgs:
             results = list(ddgs.text(query, max_results=num_results))
             formatted_results = [
@@ -191,7 +190,7 @@ def image_search(query: str, num_results: int = 5) -> dict:
         with DDGS(
             proxy=proxy,
             timeout=TIMEOUT,
-            headers={'User-Agent': requests_random_user_agent.get_random_user_agent()}
+            headers={'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36'}
         ) as ddgs:
             results = list(ddgs.images(query, max_results=num_results))
             formatted_results = [