Blame for async_tgvoicebot.py

import asyncio  # Imports the asyncio library for writing single-threaded concurrent code using coroutines
import aiohttp  # Imports aiohttp for making asynchronous HTTP requests
import os  # Imports the os module to interact with the operating system
from dotenv import load_dotenv  # Imports load_dotenv to load environment variables from a .env file
load_dotenv()  # Loads environment variables from the .env file into the program's environment
from async_ai_voice import send_to_voice_AI  # Imports the send_to_voice_AI function from the async_ai_voice module

# Telegram Bot API setup
TELEGRAM_BOT_TOKEN = os.getenv('TELEGRAM_BOT_TOKEN')  # Retrieves the Telegram bot token from environment variables
TELEGRAM_API_URL = f"https://api.telegram.org/bot{TELEGRAM_BOT_TOKEN}"  # Constructs the base Telegram API URL using the bot token

async def get_voice_file(session, file_id):
    """

    Asynchronous function to retrieve the voice file from Telegram using the file ID.

    """
    # Get file path
    file_path_url = f"{TELEGRAM_API_URL}/getFile?file_id={file_id}"  # Constructs the URL to get file information from Telegram
    async with session.get(file_path_url) as response:  # Asynchronously sends a GET request to the file_path_url
        file_info = await response.json()  # Awaits and parses the JSON response containing file information
        file_path = file_info['result']['file_path']  # Extracts the file path from the response
    
    # Download file
    file_url = f"https://api.telegram.org/file/bot{TELEGRAM_BOT_TOKEN}/{file_path}"  # Constructs the URL to download the actual voice file
    async with session.get(file_url) as response:  # Asynchronously sends a GET request to download the file
        return await response.read()  # Awaits and returns the raw bytes of the downloaded file

async def handle_message(session, message):
    """

    Asynchronous function to handle incoming Telegram messages.

    """
    if 'voice' in message:  # Checks if the incoming message contains a voice message
        file_id = message['voice']['file_id']  # Retrieves the file ID of the voice message
        audio_data = await get_voice_file(session, file_id)  # Awaits the retrieval of the audio data using the get_voice_file function
        transcription = await send_to_voice_AI(audio_data)  # Awaits the transcription of the audio data using the AI service
        
        # Send transcription back to user
        chat_id = message['chat']['id']  # Retrieves the chat ID to identify where to send the response
        text = transcription.get('text', 'Sorry, could not transcribe the audio due to AI error.')  # Gets the transcribed text or a default error message
        send_message_url = f"{TELEGRAM_API_URL}/sendMessage"  # Constructs the URL to send a message via the Telegram API
        payload = {
            'chat_id': chat_id,  # Specifies the chat ID where the message should be sent
            'text': text  # The transcribed text to send back to the user
        }
        await session.post(send_message_url, json=payload)  # Asynchronously sends a POST request to send the transcription back to the user