Update main.py

main.py

@@ -206,10 +206,6 @@ async def searchhub(client: Client, message: Message):
     try:
         user_status = check_user_expiration(user_id)
         protect_content = not user_status["free_mode"]
-        if user_status["free_mode"]:
-            await message.reply("Free mode is active. Sending unprotected content.")
-        else:
-            await message.reply("Free mode is inactive or expired. Sending protected content.")
         response = await api.x_search(query=query)
         if response is None:
             return await pro.edit_text("nothing found gay")
@@ -246,6 +242,12 @@ async def searchhub(client: Client, message: Message):
     except Exception as e:
         await pro.edit_text(str(e))
 
+def is_pornohub_url(url):
+    import re
+    pattern = r"(https?)://www\.xnxx\.com/([\w\-]+)?/(\w+)"
+    match = re.search(pattern, url)
+    return bool(match)
+
 @client.on_message(
     filters.incoming
     & filters.command(["hubdl"])
@@ -257,16 +259,12 @@ async def porno_download(client: Client, message: Message):
     link = message.text.split(" ", 1)[1] if len(message.command) > 1 else None
     if not link:
         return await message.reply_text("please link for pornohub.")
-    if not link.startswith("https://www.xnxx.com/"):
+    if not is_pornohub_url(link):
         return await message.reply_text("invalid link.")
     pro = await message.reply_text("Processing.....")
     try:
         user_status = check_user_expiration(user_id)
         protect_content = not user_status["free_mode"]
-        if user_status["free_mode"]:
-            await message.reply("Free mode is active. Sending unprotected content.")
-        else:
-            await message.reply("Free mode is inactive or expired. Sending protected content.")
         file_path, thumb, _ = await api.x_download(url=link, is_stream=True)
         upload_text = f"**⬆️ 𝖴𝗉𝗅𝗈𝖺𝖽𝗂𝗇𝗀 video ...**"
         await pro.edit_text(upload_text)