TelegramBotAdmin/wbb/modules/reverse.py

import os
from asyncio import gather, get_running_loop
from base64 import b64decode
from io import BytesIO
from random import randint

import aiofiles
import aiohttp
import requests
from bs4 import BeautifulSoup
from pyrogram import filters
from pyrogram.types import InputMediaPhoto, Message

from wbb import MESSAGE_DUMP_CHAT, app
from wbb.core.decorators.errors import capture_err
from wbb.utils.functions import get_file_id_from_message
from wbb.utils.http import get


async def get_soup(url: str, headers):
    html = await get(url, headers=headers)
    return BeautifulSoup(html, "html.parser")


@app.on_message(filters.command("reverse"))
@capture_err
async def reverse_image_search(_, message: Message):
    if not message.reply_to_message:
        return await message.reply_text(
            "Reply to a message to reverse search it."
        )
    reply = message.reply_to_message
    if (
        not reply.document
        and not reply.photo
        and not reply.sticker
        and not reply.animation
        and not reply.video
    ):
        return await message.reply_text(
            "Reply to an image/document/sticker/animation to reverse search it."
        )
    m = await message.reply_text("Searching...")
    file_id = get_file_id_from_message(reply)
    if not file_id:
        return await m.edit("Can't reverse that")
    image = await app.download_media(
        file_id, f"{randint(1000, 10000)}.jpg"
    )
    async with aiofiles.open(image, "rb") as f:
        if image:
            search_url = "http://www.google.com/searchbyimage/upload"
            multipart = {
                "encoded_image": (image, await f.read()),
                "image_content": "",
            }

            def post_non_blocking():
                return requests.post(
                    search_url, files=multipart, allow_redirects=False
                )

            loop = get_running_loop()
            response = await loop.run_in_executor(
                None, post_non_blocking
            )
            location = response.headers.get("Location")
            os.remove(image)
        else:
            return await m.edit("Something wrong happened.")
    headers = {
        "User-Agent": "Mozilla/5.0 (X11; Linux x86_64; rv:58.0) Gecko/20100101 Firefox/58.0"
    }

    soup = await get_soup(location, headers=headers)
    div = soup.find_all("div", {"class": "r5a77d"})[0]
    text = div.find("a").text

    url = "https://google.com" + soup.find_all(
        "a", {"class": "ekf0x hSQtef"}
    )[0].get("href")

    soup = await get_soup(url, headers=headers)

    text = f"**Result**: [{text}]({location})"

    media = []
    for img in soup.find_all("img"):
        if len(media) == 2:
            break

        if img.get("src"):
            img = img.get("src")
            if "image/gif" in img:
                continue

            img = BytesIO(b64decode(img))
            img.name = "img.png"
            media.append(img)
        elif img.get("data-src"):
            img = img.get("data-src")
            media.append(img)

    # Cache images, so we can use file_ids
    tasks = [app.send_photo(MESSAGE_DUMP_CHAT, img) for img in media]
    messages = await gather(*tasks)

    await message.reply_media_group(
        [
            InputMediaPhoto(
                i.photo.file_id,
                caption=text,
            )
            for i in messages
        ]
    )

    await m.edit(text)