aboutsummaryrefslogtreecommitdiff
path: root/main.py
diff options
context:
space:
mode:
Diffstat (limited to 'main.py')
-rw-r--r--main.py61
1 files changed, 27 insertions, 34 deletions
diff --git a/main.py b/main.py
index 1554c78..3afe945 100644
--- a/main.py
+++ b/main.py
@@ -105,7 +105,7 @@ async def guest_middleware(handler, event, data):
return
if blocked:
if event.guest_message:
- await g_answer(data, message, text, title="ошибка врат")
+ await g_answer(text, title="ошибка врат")
elif event.message:
error_message = await message.reply(text)
await asyncio.sleep(7)
@@ -158,27 +158,32 @@ async def guest_middleware(handler, event, data):
da = "не врат не пойдёт такой длинный голосовой сообщение" \
". \nнадо меньше 60 секунд da✅"
if event.guest_message:
- await g_answer(data, message, da)
+ await g_answer(message, da)
else:
await message.reply(da)
buf = BytesIO()
- await bot.download(voice, destination=buf)
+ try:
+ brat = await bot.download(voice, destination=buf)
+ except Exception as e:
+ print(f"{YELLOW} -- voice err - {e}{RESET}")
buf.seek(0)
- result = await asyncio.to_thread(
- send_to_vosk,
- buf.read()
- )
-
- prompt = f"<голосовое сообщение>{result.get('text', 'не распознано')}</голосовое сообщение>{prompt}"
+ try:
+ if brat:
+ result = await asyncio.to_thread(
+ send_to_vosk,
+ buf.read()
+ )
+ except Exception as e:
+ prompt = f"<голосовое сообщение>ошибка подключения к api stt</голосовое сообщение>{prompt}"
+ print(f"{RED} -- voice err - {e}{RESET}")
+ else:
+ prompt = f"<голосовое сообщение>{result.get('text', 'не распознано')}</голосовое сообщение>{prompt}"
if message.document:
if message.document.file_size > 4096:
- if event.guest_message:
- await g_answer(data, message, "слишком много данных не хочу отвечать☝️☝️")
- elif event.message:
- await message.reply("слишком много данных не хочу отвечать☝️☝️")
+ await mans(message, "слишком много данных не хочу отвечать☝️☝️")
return
file_bytes = io.BytesIO()
@@ -193,25 +198,16 @@ async def guest_middleware(handler, event, data):
prompt = f"<файл>{file_content}</файл>{prompt}"
except UnicodeDecodeError:
- if event.guest_message:
- await g_answer(data, message, "файл не вошёл брат❌❌")
- elif event.message:
- await message.reply("файл не вошёл брат❌❌")
+ await mans(message, "файл не вошёл брат❌❌")
return
except Exception:
- if event.guest_message:
- await g_answer(data, message, "файл не вошёл ало ошибка❌❌")
- elif event.message:
- await message.reply("файл не вошёл ало ошибка❌❌")
+ await mans(message, "файл не вошёл ало ошибка❌❌")
return
if replied and replied.document:
if replied.document.file_size > 4096:
- if event.guest_message:
- await g_answer(data, message, "слишком много данных не хочу отвечать☝️☝️")
- elif event.message:
- await message.reply("слишком много данных не хочу отвечать☝️☝️")
+ await mans(message, "слишком много данных не хочу отвечать☝️☝️")
return
file_bytes = io.BytesIO()
@@ -222,10 +218,7 @@ async def guest_middleware(handler, event, data):
file_content = file_bytes.read().decode("utf-8", errors="ignore")
prompt = f"<файл>{file_content}</файл>{prompt}"
except UnicodeDecodeError:
- if event.guest_message:
- await g_answer(data, message, "файл не вошёл❌")
- elif event.message:
- await message.reply("файл не вошёл❌")
+ await mans(message, "файл не вошёл❌")
return
except Exception as e:
print(f"{RED} -- {e}{RESET}")
@@ -317,7 +310,7 @@ async def guest_middleware(handler, event, data):
]
)
if event.guest_message:
- await g_answer(data, message, alloh_one_text, reply_markup=reply_markup_url)
+ await g_answer(message, alloh_one_text, reply_markup=reply_markup_url)
elif event.message:
await message.reply_rich(InputRichMessage(markdown="# новый крутой стилёк\n*da*\n```\nтестовое сообщение врат\n```"))
await message.answer(alloh_text, reply_markup=reply_markup)
@@ -438,7 +431,7 @@ async def guest_middleware(handler, event, data):
)
except Exception as e:
if event.guest_message:
- await g_answer(data, message, "гостевой режим не работает с опросами. либо добавь меня " \
+ await g_answer(message, "гостевой режим не работает с опросами. либо добавь меня " \
"в группу, либо напиши мне в личку чтобы я выдал тебе опрос. ✅"
)
else:
@@ -446,7 +439,7 @@ async def guest_middleware(handler, event, data):
return
if result and event.guest_message:
- await g_answer(data, message, "отправил опрос в личку, так как гостевой режим не работает с " \
+ await g_answer(message, "отправил опрос в личку, так как гостевой режим не работает с " \
"опросами✅✅"
)
@@ -461,7 +454,7 @@ async def guest_middleware(handler, event, data):
try:
if event.guest_message:
- await g_answer(data, message, result, user_id=user_id)
+ await g_answer(message, result, user_id=user_id)
elif event.message:
if msg:
if stream == "native":
@@ -481,7 +474,7 @@ async def guest_middleware(handler, event, data):
kwargs["parse_mode"] = None
try:
if event.guest_message:
- await g_answer(data, message, result)
+ await g_answer(message, result)
elif event.message:
if msg:
if stream == "native":