Upload main.py

main.py

@@ -101,6 +101,9 @@ from instagram import router as instagram_router
 from driver import YoutubeDriver
 from yt_dlp import YoutubeDL
 
+from xnxx_api import search_filters
+from xnxx_api.xnxx_api import Client as xnxx_client
+
 logging.basicConfig(level=logging.ERROR)
 logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)
@@ -125,7 +128,6 @@ SOURCE_ASSISTANT_GOOGLE_AI = os.environ["SOURCE_ASSISTANT_GOOGLE_AI"]
 SOURCE_MONITOR_URL = os.environ["SOURCE_MONITOR_URL"]
 SOURCE_OPENAI_ACCESS_URL = os.environ["SOURCE_OPENAI_ACCESS_URL"]
 SOURCE_PICSART_URL = os.environ["SOURCE_PICSART_URL"]
-TOOLS_NEW_URL = os.environ["TOOLS_NEW_URL"]
 
 # api keys
 REVERSE_IMAGE_API = os.environ["REVERSE_IMAGE_API"]
@@ -725,62 +727,62 @@ async def tiktokdl_(link: str):
 @app.get("/akeno/xnxxsearch", response_model=SuccessResponse, responses={422: {"model": SuccessResponse}})
 async def xnxx_search(query: str):
     try:
-        response = await api_tools_fix(name="xnxxsearch", ok="q", query=query)
-        result = response.get("result", {})
-        return SuccessResponse(
-            status="True",
-            randydev={"results": result}
-        )
-    except:
-        return SuccessResponse(
-            status="False",
-            randydev={"error": "Error fucking"}
+        search = xnxx_client().search(
+            query,
+            length=search_filters.Length.X_0_10min,
+            upload_time=search_filters.UploadTime.year,
+            searching_quality=search_filters.SearchingQuality.X_1080p_plus,
+            limit=1
         )
-
-@app.get("/akeno/xvideosearch", response_model=SuccessResponse, responses={422: {"model": SuccessResponse}})
-async def xvideosearch(query: str):
-    try:
-        response = await api_tools_fix(name="xvideosearch", ok="q", query=query)
-        result = response.get("result", {})
-        return SuccessResponse(
-            status="True",
-            randydev={"results": result}
-        )
-    except:
+        response = search.videos
+        for x in response:
+            return SuccessResponse(
+                status="True",
+                randydev={
+                    "results": [
+                        {
+                            "link": x.content_url,
+                            "title": x.title,
+                            "author": x.author,
+                            "length": x.highest_quality,
+                            "highest_quality": x.highest_quality,
+                            "publish_date": x.publish_date,
+                            "views": x.views,
+                            "thumb": x.thumbnail_url
+                        }
+                    ]
+                }
+            )
+    except Exception as e:
         return SuccessResponse(
             status="False",
-            randydev={"error": "Error fucking"}
+            randydev={"error": f"Error fucking: {e}"}
         )
 
 @app.get("/akeno/xnxx-dl", response_model=SuccessResponse, responses={422: {"model": SuccessResponse}})
 async def xnxx_download(link: str):
     try:
-        response = await api_tools_fix(name="xnxxdl", ok="url", query=link)
-        result = response.get("result", {})
+        x = xnxx_client()
+        response = x.get_video(link)
         return SuccessResponse(
             status="True",
-            randydev={"results": result}
+            randydev={
+                "title": response.title,
+                "author": response.author,
+                "length": response.highest_quality,
+                "highest_quality": response.highest_quality,
+                "publish_date": response.publish_date,
+                "views": response.views,
+                "link": response.content_url,
+                "thumb": response.thumbnail_url
+            }
         )
-    except:
+    except Exception as e:
         return SuccessResponse(
             status="False",
-            randydev={"error": "Error fucking"}
+            randydev={"error": f"Error fucking: {e}"}
         )
 
-@app.get("/akeno/xnxx-videodl", response_model=SuccessResponse, responses={422: {"model": SuccessResponse}})
-async def xnxx_videodl(link: str):
-    try:
-        response = await api_tools_fix(name="xvideosdl", ok="url", query=link)
-        result = response.get("result", {})
-        return SuccessResponse(
-            status="True",
-            randydev={"results": result}
-        )
-    except:
-        return SuccessResponse(
-            status="False",
-            randydev={"error": "Error fucking"}
-        )
 
 @app.get("/akeno/instagramdl", response_model=SuccessResponse, responses={422: {"model": SuccessResponse}})
 async def instagramdl(link: str):