add more errors parsing and fix some errors da

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":