Update app.py

app.py

@@ -31,6 +31,18 @@ logging.basicConfig(
 )
 logger = logging.getLogger(__name__)
 
+def set_webhook():
+    """Sets the webhook for the Telegram bot."""
+    try:
+        response = requests.get(f"https://api.telegram.org/bot{BOT_TOKEN}/setWebhook?url={WEBHOOK_URL}")
+        result = response.json()
+        if result.get('ok'):
+            logger.info("Webhook set successfully.")
+        else:
+            logger.error(f"Failed to set webhook: {result}")
+    except requests.exceptions.RequestException as e:
+        logger.error(f"Request exception: {e}")
+
 def set_webhook():
     """Sets the webhook for the Telegram bot."""
     try:
@@ -46,28 +58,29 @@ def set_webhook():
 @webhook_endpoint
 async def handle_update(payload: WebhookPayload) -> None:
     """Handles incoming updates from Telegram."""
-    logger.debug(f"Received payload: {payload}")
     if payload.message:
         message_text = payload.message.get('text')
         chat_id = payload.message.get('chat').get('id')
 
         if message_text:
             try:
-                # Generate a response using Google Generative AI or predefined responses
+                # Generate a response using Google Generative AI
                 prompt = f"Respond to the user: {message_text}"
-                response = requests.post(
-                    "https://api.your-ai-service.com/generate",  # Replace with your AI service URL
-                    json={"prompt": prompt, "api_key": GOOGLE_API_KEY}
-                ).json()
-                response_text = response.get('text', 'Sorry, I didn\'t understand that.')
+                response = chat_session.send_message(prompt)  # Generate response using text and prompt
+                response_text = response.text
+
+                # Log the response
+                logger.debug(f"Generated response: {response_text}")
 
-                # Send the response back to the chat
+                # Send the response to the chat
                 bot.send_message(chat_id, response_text, parse_mode='Markdown')
                 logger.info(f"Response sent to chat_id {chat_id}")
 
             except Exception as e:
-                logger.error(f"Error during message processing: {e}")
-                bot.send_message(chat_id, "Sorry, I can't answer this query right now.", parse_mode='Markdown')
+                logger.error(f"Error during GenAI processing: {e}")
+                error_message = "Sorry, I can't answer this query right now but I will improve from time to time."
+                bot.send_message(chat_id, error_message, parse_mode='Markdown')
+                logger.error(f"Error message sent to chat_id {chat_id}")
 
 # Initialize the Gradio interface
 iface = Interface(fn=handle_update, inputs=[], outputs=[])