import aiohttp


class Gemini:
    def __init__(self, api_key: str):
        self.api_key = api_key

    async def ask(self, prompt: str, file: dict = {}) -> dict:
        async with aiohttp.ClientSession() as session:
            payload = {}
            payload["contents"] = []
            if file:
                file_uri = file["file"]["uri"]
                payload["contents"].append(
                    {
                        "role": "user",
                        "parts": [
                            {
                                "fileData": {
                                    "fileUri": file_uri,
                                    "mimeType": "image/jpeg"
                                }
                            },
                            {
                                "text": prompt
                            }
                        ]
                    }
                )
            else:
                payload["contents"].append(
                    {
                        "role": "user",
                        "parts": [
                            {
                                "text": prompt
                            }
                        ]
                    }
                )
            payload["generationConfig"] = {
                "temperature": 0.9,
                "topK": 40,
                "topP": 0.95,
                "maxOutputTokens": 1024,
                "responseMimeType": "text/plain"
            }
            async with session.post(f"https://generativelanguage.googleapis.com/v1beta/models/gemini-1.5-flash-8b-exp-0924:generateContent?key={self.api_key}", headers={"Content-Type": "application/json"}, json=payload) as response:
                try:
                    results = await response.json()
                    return results
                except Exception as e:
                    return {"error": str(e)}

    async def upload_image(self, path: str) -> dict:
        with open(path, "rb") as file:
           async with aiohttp.ClientSession() as session:
               payload = {"file": file}
               async with session.post(f"https://generativelanguage.googleapis.com/upload/v1beta/files?key={self.api_key}", data=payload) as response:
                   try:
                       return await response.json()
                   except Exception as e:
                       return {"error": str(e)}
        os.remove(path)               

⚔️ Get your API key:
https://aistudio.google.com/app/apikey


👨‍💻 For Example:
Use @GojoAssistantBot /gemini or /google cmd replaced old model with official api


#gojoai #gemini #gojoassistant

@NandhaBots

☀️ ☀️ "victory of light over darkness, good over evil, and knowledge over ignorance" — Happy Diwali 🎆 🎆.

Now anime search available in our boy @gojoAssistantBot 🌟

Example:
/anime silent voice

Bot API 7.11

• Bots can now participate in revenue sharing from Telegram Ads ⭐️ – unlocking a new way to help support their development.
• Introduced Paid Broadcasts ⭐️ – allowing bots to broadcast up to 1000 messages per second.

• Bots can now send and receive chat-specific hashtags that only show posts and stories from a specific chat when tapped.
• Added a new inline button to let users copy text in one tap.
• Bots can now add media to existing text messages.

• And more, see the full changelog for details:

https://core.telegram.org/bots/api-changelog#october-31-2024

⚠️ Warning: Starting December 1, 2024 messages with video posted in big communities can be delayed by the server until the respective video is reencoded. Read more here.

🤔 That's a real W.