|
|
| import traceback |
| from asyncio import get_running_loop |
| from io import BytesIO |
|
|
| from googletrans import Translator |
| from gtts import gTTS |
| from pyrogram import Client, filters |
| from pyrogram.types import Message |
|
|
|
|
| def convert(text): |
| audio = BytesIO() |
| i = Translator().translate(text, dest="en") |
| lang = i.src |
| tts = gTTS(text, lang=lang) |
| audio.name = lang + ".mp3" |
| tts.write_to_fp(audio) |
| return audio |
|
|
|
|
| @Client.on_message(filters.command("tts")) |
| async def text_to_speech(_, message: Message): |
| if not message.reply_to_message: |
| return await message.reply_text("Reply To Some Text FFS.") |
| if not message.reply_to_message.text: |
| return await message.reply_text("Reply To Some TextFFS.") |
| m = await message.reply_text("Processing") |
| text = message.reply_to_message.text |
| try: |
| loop = get_running_loop() |
| audio = await loop.run_in_executor(None, convert, text) |
| await message.reply_audio(audio) |
| await m.delete() |
| audio.close() |
| except Exception as e: |
| await m.edit(e) |
| e = traceback.format_exc() |
| print(e) |
|
|
|
|
|
|
|
|
