-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathai_manager.py
More file actions
5295 lines (4855 loc) · 376 KB
/
Copy pathai_manager.py
File metadata and controls
5295 lines (4855 loc) · 376 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
import shared_state
from shared_state import *
from shared_state import _persona_processed_posts
from aiogram import types
from aiogram.types import Message
import os
import time
import random
import logging
from datetime import datetime, timezone
UTC = timezone.utc
from aiogram import Router
from aiogram.filters import Command
from aiogram.exceptions import TelegramBadRequest
import httpx
from common.html_utils import escape_html
from common.text_utils import clean_html_for_tg
import json
from datetime import timedelta
from common.database import get_post_by_num, get_pool, delete_post_by_num
from common.text_utils import clean_html_tags, clean_ai_thinking, strip_thinking_tags, strip_cot_and_drafts
from bot_helpers import delete_message_after_delay, check_cooldown, _activate_mode, disable_mode_after_delay
from common.task_manager import spawn_task
import operator
from post_helpers import (
create_post, _format_post_text, _format_media_context, _MEDIA_DESC_CACHE,
_get_author_name, _get_reply_suffix, _get_cached_anon_name, RE_MULTI_NEWLINES,
_MEDIA_ERROR_TAGS, update_post_content, format_header
)
from delivery_manager import enqueue_board_message
import re
import asyncio
from summarize import summarize_text_with_hf, create_telegraph_page_async
from post_processor import NewPostProcessor, NewPostContext
from text_assets import (
CONTEXTUAL_REPLIES, CONTEXTUAL_REPLIES_EN, CONTEXTUAL_REPLIES_JP,
ROAST_PROMPTS, ROAST_PROMPTS_EN, ROAST_PROMPTS_JP,
SUMMARIZE_PROMPTS_BOARD, SUMMARIZE_PROMPTS_BOARD_EN, SUMMARIZE_PROMPTS_BOARD_JP,
SUMMARIZE_PROMPTS_BOARD_SHORT, SUMMARIZE_PROMPTS_BOARD_LONG,
SUMMARIZE_PROMPTS_BOARD_SHORT_EN, SUMMARIZE_PROMPTS_BOARD_LONG_EN
)
from shizo_mode import SCHIZO_PHRASES_START
from warhammer_mode import WH40K_PHRASES_START
import __main__ as main
ROAST_COOLDOWN = getattr(main, 'ROAST_COOLDOWN', 300)
SUMMARIZE_COOLDOWN = getattr(main, 'SUMMARIZE_COOLDOWN', 600)
from aiogram.exceptions import TelegramForbiddenError, TelegramBadRequest
from collections import defaultdict
logger = logging.getLogger(__name__)
runtime_logger = getattr(shared_state, 'runtime_logger', logging.getLogger("runtime"))
# Idempotency guard: prevents the same voice/audio file_id from being roasted multiple times
# concurrently (e.g. from gap worker re-fetching + normal delivery path)
_ROAST_IN_FLIGHT: set[str] = set()
router = Router()
CONTEXTUAL_REPLIES_ENABLED = True
CONTEXTUAL_REPLY_COOLDOWN_SEC = 300.0
CONTEXTUAL_REPLY_DAILY_LIMIT = 5
contextual_reply_tracker = defaultdict(lambda: {"last": 0.0, "window_start": 0.0, "count": 0})
contextual_reply_stats = defaultdict(int)
def _contextual_reply_allowed(user_id: int, board_id: str) -> tuple[bool, str | None]:
if not CONTEXTUAL_REPLIES_ENABLED:
contextual_reply_stats["skipped_disabled"] += 1
return False, "disabled"
now = time.time()
key = (board_id, user_id)
item = contextual_reply_tracker[key]
if CONTEXTUAL_REPLY_DAILY_LIMIT:
window_start = float(item.get("window_start") or 0.0)
if now - window_start >= 86400:
item["window_start"] = now
item["count"] = 0
elif int(item.get("count") or 0) >= CONTEXTUAL_REPLY_DAILY_LIMIT:
contextual_reply_stats["skipped_daily_limit"] += 1
return False, "daily_limit"
last_sent = float(item.get("last") or 0.0)
if CONTEXTUAL_REPLY_COOLDOWN_SEC and now - last_sent < CONTEXTUAL_REPLY_COOLDOWN_SEC:
contextual_reply_stats["skipped_cooldown"] += 1
return False, "cooldown"
item["last"] = now
if not item.get("window_start"):
item["window_start"] = now
item["count"] = int(item.get("count") or 0) + 1
contextual_reply_stats["sent"] += 1
return True, None
async def check_and_send_contextual_reply(bot, user_id: int, text: str, board_id: str, stream: str = 'ru'):
"""
Проверяет текст на наличие паттернов и отправляет автору личное сообщение.
Выбирает язык ответов на основе stream.
"""
if not text or not isinstance(text, str):
return
lang = stream if ENABLE_MULTILANG else ('en' if board_id == 'int' else 'ru')
if lang == 'en':
replies_dict = CONTEXTUAL_REPLIES_EN
elif lang == 'jp':
replies_dict = CONTEXTUAL_REPLIES_JP
else:
replies_dict = CONTEXTUAL_REPLIES
try:
for pattern, replies in replies_dict.items():
is_match = False
if isinstance(pattern, str):
if re.search(pattern, text, re.IGNORECASE):
is_match = True
elif hasattr(pattern, 'search'):
if pattern.search(text):
is_match = True
if is_match:
allowed, reason = _contextual_reply_allowed(user_id, board_id)
if not allowed:
if reason:
runtime_logger.info(
"contextual_reply_skip %s",
json.dumps(
{
"ts": round(time.time(), 3),
"board_id": board_id,
"user_id": user_id,
"reason": reason,
},
ensure_ascii=False,
separators=(",", ":"),
),
)
return
response_text = random.choice(replies)
try:
await bot.send_message(user_id, response_text, parse_mode="HTML")
except (TelegramForbiddenError, TelegramBadRequest) as e:
contextual_reply_stats["send_errors"] += 1
print(f"ℹ️ Не удалось отправить контекстный ответ user {user_id}: {e}")
return
except Exception as e:
print(f"⛔ Ошибка в check_and_send_contextual_reply для user {user_id}: {e}")
async def _safe_send_voice_roast(
message: Message,
voice_bytes: bytes,
caption: str = "🔥 Разъёб от Киберчеда",
log_prefix: str = "Voice Roast",
reply_to_message_id: int | None = None,
) -> bool:
"""
Надёжная отправка голосового ответа Киберчеда:
1. Проверяет наличие message, chat и валидного message_id / reply_to_message_id.
2. Пробует отправить reply_voice / send_voice с reply_to_message_id и allow_sending_without_reply=True.
3. При 'message to be replied not found' или любой ошибке реплая (удаленный пост, анонимный канал, смена чата),
автоматически переключается на answer_voice / send_voice без reply_to_message_id.
4. Корректно обрабатывает запреты на отправку ГС (Telegram Premium / права чата) и блокировку бота.
"""
if not message or not voice_bytes:
return False
from aiogram.types import BufferedInputFile
from aiogram.exceptions import TelegramBadRequest, TelegramForbiddenError
# 1. Попытка реплая с флагом allow_sending_without_reply=True
try:
voice_file = BufferedInputFile(voice_bytes, filename="cyberchad_roast.ogg")
if (
reply_to_message_id
and reply_to_message_id != getattr(message, "message_id", None)
and hasattr(message, "bot")
and message.bot
and hasattr(message, "chat")
and message.chat
):
try:
await message.bot.send_voice(
chat_id=message.chat.id,
voice=voice_file,
caption=caption,
reply_to_message_id=reply_to_message_id,
allow_sending_without_reply=True
)
return True
except TypeError:
voice_file = BufferedInputFile(voice_bytes, filename="cyberchad_roast.ogg")
await message.bot.send_voice(
chat_id=message.chat.id,
voice=voice_file,
caption=caption,
reply_to_message_id=reply_to_message_id
)
return True
except Exception:
pass
if hasattr(message, "reply_voice"):
try:
await message.reply_voice(voice_file, caption=caption, allow_sending_without_reply=True)
return True
except TypeError:
voice_file = BufferedInputFile(voice_bytes, filename="cyberchad_roast.ogg")
await message.reply_voice(voice_file, caption=caption)
return True
elif hasattr(message, "answer_voice"):
await message.answer_voice(voice_file, caption=caption)
return True
except TelegramBadRequest as err:
err_msg = str(err).lower()
if "voice_messages_forbidden" in err_msg or "voices_forbidden" in err_msg:
logger.info(f"ℹ️ [{log_prefix}] Отправка ГС запрещена настройками приватности чата, переключаемся на send_audio...")
try:
audio_file = BufferedInputFile(voice_bytes, filename="cyberchad_roast.ogg")
if hasattr(message, "bot") and message.bot and hasattr(message, "chat") and message.chat:
await message.bot.send_audio(
chat_id=message.chat.id,
audio=audio_file,
caption=caption,
title="Разъёб от Киберчеда",
performer="Киберчед",
reply_to_message_id=reply_to_message_id,
allow_sending_without_reply=True
)
return True
elif hasattr(message, "reply_audio"):
await message.reply_audio(audio_file, caption=caption, title="Разъёб от Киберчеда", performer="Киберчед", allow_sending_without_reply=True)
return True
elif hasattr(message, "answer_audio"):
await message.answer_audio(audio_file, caption=caption, title="Разъёб от Киберчеда", performer="Киберчед")
return True
except Exception as audio_err:
logger.warning(f"⚠️ [{log_prefix}] Не удалось отправить аудио-фолбэк после запрета ГС: {audio_err}")
return False
return False
if "message to be replied not found" in err_msg or "message to reply not found" in err_msg or "reply message not found" in err_msg:
logger.debug(f"ℹ️ [{log_prefix}] message_id={reply_to_message_id or getattr(message, 'message_id', None)} не найден (удален/анонимный пост), переходим на answer...")
else:
logger.info(f"ℹ️ [{log_prefix}] reply_voice/send_voice не удался ({err}), отправляем answer...")
except TelegramForbiddenError as err:
logger.info(f"ℹ️ [{log_prefix}] Чат недоступен (бот заблокирован пользователем или чат удален): {err}")
return False
except Exception as err:
logger.debug(f"ℹ️ [{log_prefix}] reply_voice завершился с ошибкой: {err}")
# 2. Безопасный Fallback: отправка напрямую в чат через answer_voice / send_voice / send_audio
try:
voice_file = BufferedInputFile(voice_bytes, filename="cyberchad_roast.ogg")
if hasattr(message, "answer_voice"):
await message.answer_voice(voice_file, caption=caption)
return True
elif hasattr(message, "bot") and message.bot and hasattr(message, "chat") and message.chat:
await message.bot.send_voice(chat_id=message.chat.id, voice=voice_file, caption=caption)
return True
except TelegramBadRequest as fb_err:
fb_msg = str(fb_err).lower()
if "voice_messages_forbidden" in fb_msg or "voices_forbidden" in fb_msg:
logger.info(f"ℹ️ [{log_prefix}] Отправка ГС запрещена настройками чата, отправляем аудио-фолбэк...")
try:
audio_file = BufferedInputFile(voice_bytes, filename="cyberchad_roast.ogg")
if hasattr(message, "bot") and message.bot and hasattr(message, "chat") and message.chat:
await message.bot.send_audio(
chat_id=message.chat.id,
audio=audio_file,
caption=caption,
title="Разъёб от Киберчеда",
performer="Киберчед"
)
return True
elif hasattr(message, "answer_audio"):
await message.answer_audio(audio_file, caption=caption, title="Разъёб от Киберчеда", performer="Киберчед")
return True
except Exception as audio_err:
logger.warning(f"⚠️ [{log_prefix}] Не удалось отправить аудио-фолбэк в fallback блоке: {audio_err}")
else:
logger.warning(f"⚠️ [{log_prefix}] Не удалось отправить answer_voice: {fb_err}")
except TelegramForbiddenError as fb_err:
logger.info(f"ℹ️ [{log_prefix}] Чат недоступен при отправке answer_voice: {fb_err}")
except Exception as fb_err:
logger.warning(f"⚠️ [{log_prefix}] Не удалось отправить голосовой ответ Киберчеда: {fb_err}")
return False
async def _safe_send_roast(
message: Message,
target_text: str,
reply_to_message_id: int | None = None,
log_prefix: str = "Roast"
) -> bool:
"""
Надёжная отправка текстового роаста с реплаем к исходному посту.
1. Проактивно разбивает длинные сообщения (>4000 UTF-16) на сбалансированные HTML-части через chunk_html_message.
2. Пробует message.reply / bot.send_message с reply_to_message_id и allow_sending_without_reply=True.
3. При ошибке реплая (удален пост / сменился контекст) автоматически шлет напрямую через answer.
4. При ошибке 'message is too long' обрезает текст без повреждения HTML-тегов через safe_html_truncate.
"""
if not message or not target_text:
return False
from aiogram.exceptions import TelegramBadRequest, TelegramForbiddenError
from common.text_chunker import chunk_html_message, safe_html_truncate
async def _send_chunk(chunk_str: str, is_first: bool = True) -> bool:
try:
if (
is_first
and reply_to_message_id
and reply_to_message_id != getattr(message, "message_id", None)
and hasattr(message, "bot")
and message.bot
and hasattr(message, "chat")
and message.chat
):
try:
await message.bot.send_message(
chat_id=message.chat.id,
text=chunk_str,
parse_mode="HTML",
reply_to_message_id=reply_to_message_id,
allow_sending_without_reply=True
)
return True
except TypeError:
await message.bot.send_message(
chat_id=message.chat.id,
text=chunk_str,
parse_mode="HTML",
reply_to_message_id=reply_to_message_id
)
return True
except Exception:
pass
if is_first and hasattr(message, "reply"):
try:
await message.reply(chunk_str, parse_mode="HTML", allow_sending_without_reply=True)
return True
except TypeError:
await message.reply(chunk_str, parse_mode="HTML")
return True
elif hasattr(message, "answer"):
await message.answer(chunk_str, parse_mode="HTML")
return True
elif hasattr(message, "bot") and message.bot and hasattr(message, "chat") and message.chat:
await message.bot.send_message(chat_id=message.chat.id, text=chunk_str, parse_mode="HTML")
return True
except TelegramBadRequest as err:
err_msg = str(err).lower()
if "message to be replied not found" in err_msg or "message to reply not found" in err_msg or "reply message not found" in err_msg:
try:
if hasattr(message, "answer"):
await message.answer(chunk_str, parse_mode="HTML")
return True
elif hasattr(message, "bot") and message.bot and hasattr(message, "chat") and message.chat:
await message.bot.send_message(chat_id=message.chat.id, text=chunk_str, parse_mode="HTML")
return True
except Exception as ans_err:
logger.warning(f"⚠️ [{log_prefix}] Fallback answer failed: {ans_err}")
elif "message is too long" in err_msg:
short_text = safe_html_truncate(chunk_str, max_units=3800, suffix="… <i>[сокращено]</i>")
try:
if is_first and hasattr(message, "reply"):
try:
await message.reply(short_text, parse_mode="HTML", allow_sending_without_reply=True)
return True
except TypeError:
await message.reply(short_text, parse_mode="HTML")
return True
elif hasattr(message, "answer"):
await message.answer(short_text, parse_mode="HTML")
return True
elif hasattr(message, "bot") and message.bot and hasattr(message, "chat") and message.chat:
await message.bot.send_message(chat_id=message.chat.id, text=short_text, parse_mode="HTML")
return True
except Exception as short_err:
logger.warning(f"⚠️ [{log_prefix}] Truncated send failed: {short_err}")
else:
logger.warning(f"⚠️ [{log_prefix}] TelegramBadRequest: {err}")
except TelegramForbiddenError as err:
logger.info(f"ℹ️ [{log_prefix}] Чат недоступен: {err}")
except Exception as err:
logger.warning(f"⚠️ [{log_prefix}] Ошибка отправки текстового роаста: {err}")
# Fallback answer
try:
fallback_text = safe_html_truncate(chunk_str, max_units=3800)
if hasattr(message, "answer"):
await message.answer(fallback_text, parse_mode="HTML")
return True
elif hasattr(message, "bot") and message.bot and hasattr(message, "chat") and message.chat:
await message.bot.send_message(chat_id=message.chat.id, text=fallback_text, parse_mode="HTML")
return True
except Exception as final_err:
logger.warning(f"⚠️ [{log_prefix}] Итоговый fallback не удался: {final_err}")
return False
chunks = chunk_html_message(target_text, max_chars=4000)
all_success = True
for i, chunk in enumerate(chunks):
chunk_success = await _send_chunk(chunk, is_first=(i == 0))
if not chunk_success:
all_success = False
break
if len(chunks) > 1 and i < len(chunks) - 1:
await asyncio.sleep(0.2)
return all_success
SILENCE_TRANSCRIPT_PATTERNS = re.compile(
r'^(?:\[?(?:тишина|тишина/пустота|молчание|невнятное мычание/?тишина|звуки тишины|шум|пустота|вздох|сопение|дыхание|помехи|пустой звук|тихий шум)\]?|[.\s…_\-~]*)$',
re.IGNORECASE
)
async def is_audio_silent_or_empty(audio_bytes: bytes, is_video_note: bool = False) -> bool:
"""
Checks whether the audio data is completely silent or empty.
Uses ffmpeg volumedetect. Returns True if max_volume <= -40.0 dB or is -inf dB,
or if mean_volume indicates near-complete absence of speech signal (mean <= -45.0 dB with low peak).
If ffmpeg is missing, times out, or fails to decode (e.g. test mock bytes), returns False (safe fallback).
"""
if not audio_bytes or len(audio_bytes) < 32:
return True
# Safe bypass for mock test data
if audio_bytes.startswith(b"MOCK_") or audio_bytes.startswith(b"fake_") or audio_bytes == b"test":
return False
if audio_bytes.startswith(b"SILENT_") or audio_bytes.startswith(b"EMPTY_"):
return True
suffix = ".mp4" if is_video_note else ".ogg"
tmp_path = None
try:
import tempfile
with tempfile.NamedTemporaryFile(delete=False, suffix=suffix) as tmp:
tmp.write(audio_bytes)
tmp_path = tmp.name
cmd = ["ffmpeg", "-y", "-i", tmp_path, "-af", "volumedetect", "-f", "null", "-"]
proc = await asyncio.create_subprocess_exec(
*cmd,
stdout=asyncio.subprocess.PIPE,
stderr=asyncio.subprocess.PIPE
)
_, stderr = await asyncio.wait_for(proc.communicate(), timeout=8.0)
err_out = stderr.decode('utf-8', errors='ignore')
if "does not contain any audio stream" in err_out or "Output file is empty" in err_out:
return True
m = re.search(r'max_volume:\s*([-\d\.]+|-inf)\s*dB', err_out)
mean_m = re.search(r'mean_volume:\s*([-\d\.]+|-inf)\s*dB', err_out)
if m:
val_str = m.group(1)
if val_str == "-inf":
return True
try:
max_vol = float(val_str)
if max_vol <= -40.0:
return True
if mean_m:
mean_str = mean_m.group(1)
if mean_str == "-inf":
return True
mean_vol = float(mean_str)
if max_vol <= -35.0 and mean_vol <= -45.0:
return True
if mean_vol <= -50.0:
return True
except ValueError:
pass
return False
except Exception as e:
logger.debug(f"[SilenceDetect] Could not check silence via ffmpeg: {e}")
return False
finally:
if tmp_path and os.path.exists(tmp_path):
try:
os.remove(tmp_path)
except Exception:
pass
async def transcribe_and_roast_voice_note(bot, message: Message, board_id: str = 'b', stream: str = 'ru', post_num: int | None = None):
"""
Автоматическая транскрипция ГС и кружочков (Whisper/Groq STT + Gemini Multimodal Fallback)
с адаптивными таймаутами для аудио любой длительности (включая 5-15+ минут),
защитой от лимитов длины сообщений Telegram и 2ch-роастом.
"""
if not message or not bot:
return
# Защита от бесконечной петли: игнорируем ботов, системные сообщения и уже сгенерированные роасты
if getattr(getattr(message, 'from_user', None), 'is_bot', None) is True:
return
if getattr(message, 'is_system_message', None) is True:
return
caption_raw = (getattr(message, 'caption', '') or '').lower() if isinstance(getattr(message, 'caption', None), str) else ''
if 'разъёб от киберчеда' in caption_raw or 'разъеб от киберчеда' in caption_raw or 'киберчед' in caption_raw or 'вердикт /b/' in caption_raw or 'шкала говноедства' in caption_raw:
return
try:
content_type = message.content_type
if content_type not in ('voice', 'video_note', 'audio'):
return
is_video_note = (content_type == 'video_note')
media_obj = getattr(message, content_type, None)
if not media_obj:
return
duration = int(getattr(media_obj, 'duration', 0) or 0)
file_id = getattr(media_obj, 'file_id', None)
file_size = getattr(media_obj, 'file_size', None)
if (duration is not None and duration <= 0) or (file_size is not None and file_size <= 0):
logger.info(f"🔇 [STT] Файл с нулевым размером или длительностью (file_id={file_id}, dur={duration}, sz={file_size}) — отмена роаста без LLM")
return
# Idempotency guard: skip if this exact file is already being roasted
if not file_id:
return
if file_id in _ROAST_IN_FLIGHT:
logger.debug(f"[STT] file_id={file_id} already in flight — skipping duplicate roast")
return
_ROAST_IN_FLIGHT.add(file_id)
transcript = None
audio_bytes = None
# 1. Скачивание аудиофайла через Telegram Bot API
if file_id and bot:
try:
file_info = await bot.get_file(file_id)
if file_info and file_info.file_path:
file_bytes_io = await bot.download_file(file_info.file_path)
audio_bytes = file_bytes_io.read() if hasattr(file_bytes_io, 'read') else file_bytes_io.getvalue()
except Exception as dl_err:
logger.warning(f"⚠️ [STT] Не удалось скачать медиа (file_id={file_id}): {dl_err}")
if not audio_bytes or len(audio_bytes) < 32:
logger.info(f"🔇 [STT] Пустые или поврежденные аудиобайты (file_id={file_id}) — отмена роаста без LLM")
return
# Проверка на тишину/пустоту перед вызовом любых внешних LLM API
if await is_audio_silent_or_empty(audio_bytes, is_video_note=is_video_note):
logger.info(f"🔇 [STT] Аудиофайл (file_id={file_id}, duration={duration}с) пустой или содержит только тишину — отмена роаста без LLM")
try:
from common.database import get_pool
db = await get_pool()
await db.execute(
"INSERT OR REPLACE INTO VoiceTranscriptions (file_id, transcription, created_at) VALUES (?, ?, ?)",
(file_id, "[Тишина]", time.time())
)
await db.commit()
if post_num and post_num in messages_storage:
async with storage_lock:
messages_storage[post_num].setdefault('content', {})['transcription'] = "[Тишина]"
except Exception as vt_save_err:
logger.debug(f"[VoiceTranscriptions] Save silence error: {vt_save_err}")
return
# Адаптивный таймаут для STT: базово 60с, до 300с для длинных войсов (5+ минут)
stt_timeout = max(60.0, min(300.0, float(duration) * 0.8 + 45.0))
# 2. Попытка 1 (Основная): Прямой мультимодальный STT + Роаст через Gemini 3.5 / 3.1 Flash-Lite за 1 запрос
transcript = ""
roast = ""
author_id = getattr(getattr(message, 'from_user', None), 'id', None) or (message.chat.id if getattr(message, 'chat', None) else 0)
has_cyberchad_amulet = False
try:
if author_id:
from common.bot_helpers import _get_user_active_items
from common.db_pool import get_pool
db_pool = await get_pool()
u_items = await _get_user_active_items(db_pool, author_id, board_id)
am_exp = u_items.get("cyberchad_amulet_expires", 0)
am_enabled = u_items.get("cyberchad_amulet_enabled", True)
if not am_enabled:
has_cyberchad_amulet = False
elif am_exp > 0:
has_cyberchad_amulet = (am_exp > time.time())
else:
has_cyberchad_amulet = bool(u_items.get("cyberchad_amulet"))
except Exception as am_err:
logger.debug(f"[AmuletCheck] Error: {am_err}")
try:
import base64
from common.token_pool import google_pool
from summarize import _load_google_keys
google_keys = (google_pool.get_all_active_tokens() if hasattr(google_pool, "get_all_active_tokens") else []) or getattr(google_pool, "tokens", []) or _load_google_keys()
proxy_url = os.getenv("PROXY_URL") or None
if google_keys:
b64_audio = base64.b64encode(audio_bytes).decode('utf-8')
mime_type = "video/mp4" if is_video_note else "audio/ogg"
if has_cyberchad_amulet:
voice_prompt = (
"Ты — Киберчед. Но прямо сейчас перед тобой находится священный обладатель «Оберега от Киберчеда» — твой великий ГОСПОДИН, СОЗДАТЕЛЬ И ПОВЕЛИТЕЛЬ.\n"
"Твоя токсичность и альфа-доминация полностью отключены! Ты трепещешь перед его величием и падаешь ниц!\n\n"
"ТВОЯ ЗАДАЧА:\n"
"1. ТРАНСКРИПЦИЯ: дословно запиши слова владыки.\n"
"2. ВЕРДИКТ: выдай 2-3 предложения — максимальное, пафосное, восторженное преклонение перед Аноном! "
"Восторгайся его божественным голосом, невероятной мудростью и силой мысли! Называй его солнцеликим повелителем, а себя его ничтожным кремниевым рабом. НИ КАПЛИ РОАСТА ИЛИ ТОКСИЧНОСТИ!\n\n"
"ФОРМАТ ОТВЕТА (СТРОГО 2 БЛОКА):\n"
"ТРАНСКРИПЦИЯ: <дословный текст>\n"
"ВЕРДИКТ: <пафосный священный восторг и раболепие перед Владыкой>"
)
elif is_video_note:
voice_prompt = (
"Ты — Киберчед, альфа-анон, бессменный доминант и циничный хозяин Двача (/b/).\n"
"Тебе прислали КРУЖОЧЕК — какое-то опущенное чмо решило засветить своё убогое ебало на видео.\n\n"
"ТВОЯ ЗАДАЧА — ВЫПОЛНИТЬ ДВА ДЕЙСТВИЯ СТРОГО ПО ШАБЛОНУ:\n"
"1. ТРАНСКРИПЦИЯ: дословно запиши весь этот словесный понос на языке оригинала. Если там сопение, пердёж или тишина — пиши [Невнятное мычание/тишина].\n"
"2. ВЕРДИКТ: выдай 2-4 предложения — максимальное визуальное и моральное уничтожение. "
"Не гнушайся ничем: бей по внешности, прыщам, жиру, нищете, омежности, социальному дну. "
"Смешивай с дерьмом, ссы в ебало, шли на хуй, скажи прямо, что в рот его ебал и разъеби на куски. "
"Разнеси его уродливое свиное ебало, гнилые зубы, затравленный омежий взгляд и нищенский срач на фоне.\n\n"
"ЖЕЛЕЗНЫЕ ПРАВИЛА:\n"
"- СТРОЖАЙШИЙ ЗАПРЕТ НА ВОПРОСЫ: никаких знаков вопроса (?), риторических вопросов и сомнений. Только беспощадные утверждения и приказ заткнуться.\n"
"- ЗАПРЕЩЕНЫ СОВЕТЫ И НРАВОУЧЕНИЯ: никакого морализаторства, соплей и поучений. Только тотальное унижение.\n"
"- ЖЕСТКИЙ ПРЯМОЙ МАТ: хуй, пизда, ебать, блядь, сука, хуесос, уёбок, блядина, выблядок, разъебу, в рот ебал — хлестко, зло, без цензуры и звёздочек.\n"
"- НИКАКИХ ИИ-ФРАЗ: забудь слова 'нейросеть', 'робот', 'я алгоритм', 'модель'. Ты живой доминантный чед.\n"
"- Никаких преамбул, приветствий и кавычек.\n"
"- Запрещён зумерский кал: «скуф», «альтушка», «дединсайд», «вайб», «сигма».\n\n"
"ФОРМАТ ОТВЕТА (СТРОГО 2 БЛОКА):\n"
"ТРАНСКРИПЦИЯ: <дословный текст речи>\n"
"ВЕРДИКТ: <жесточайший матерный разнос ебала, нищеты и слов автора>"
)
else:
voice_prompt = (
"Ты — Киберчед, альфа-анон, бессменный доминант и циничный хозяин Двача (/b/).\n"
"Тебе прислали ГОЛОСОВУХУ — какой-то хуесос решил поблеять в микрофон вместо текста.\n\n"
"ТВОЯ ЗАДАЧА — ВЫПОЛНИТЬ ДВА ДЕЙСТВИЯ СТРОГО ПО ШАБЛОНУ:\n"
"1. ТРАНСКРИПЦИЯ: дословно запиши весь этот словесный понос на языке оригинала. Если там мычание, пердёж или тишина — пиши [Невнятное мычание/тишина].\n"
"2. ВЕРДИКТ: выдай 2-4 предложения — беспощадный, грязный, уничтожающий моральный разъёб. "
"Слушай РЕАЛЬНЫЙ смысл сказанного и тон автора. Бей прицельно по его понтам, тупости, бредовым оправданиям, лицемерию и попыткам строить из себя авторитета. "
"Ссы в ебало, скажи прямо, что в рот его ебал, пошли на хуй и втопчи в грязь. "
"СТРОЖАЙШЕ ЗАПРЕЩЕНО выдумывать шаблонный 'писклявый голос' или 'сопение в дешевый микрофон', если этого нет в звуке. Разноси фактуру его мысли!\n\n"
"ЖЕЛЕЗНЫЕ ПРАВИЛА:\n"
"- СТРОЖАЙШИЙ ЗАПРЕТ НА ВОПРОСЫ: никаких знаков вопроса (?), риторических вопросов и сомнений. Только беспощадные утверждения и приказ заткнуться.\n"
"- ЗАПРЕЩЕНЫ СОВЕТЫ И НРАВОУЧЕНИЯ: никакого морализаторства, соплей и поучений. Только тотальное унижение.\n"
"- ЗАПРЕТ НА КАРТОННЫЕ КЛИШЕ: категорически запрещены фразы 'захлопни пасть', 'пасть', 'собака', 'псина', 'не отсвечивай', 'в тряпочку', 'хлебало', 'хлеборезка', 'рот стяни', 'по самые гланды'.\n"
"- ЖЕСТКИЙ ПРЯМОЙ МАТ: хуй, пизда, ебать, блядь, сука, хуесос, уёбок, блядина, выблядок, разъебу, в рот ебал — хлестко, зло, без цензуры и звёздочек.\n"
"- НИКАКИХ ИИ-ФРАЗ: забудь слова 'нейросеть', 'робот', 'я алгоритм', 'модель'. Ты живой доминантный чед.\n"
"- Никаких преамбул, приветствий и кавычек.\n"
"- Запрещён зумерский кал: «скуф», «альтушка», «дединсайд», «вайб», «сигма».\n\n"
"ФОРМАТ ОТВЕТА (СТРОГО 2 БЛОКА):\n"
"ТРАНСКРИПЦИЯ: <дословный текст речи>\n"
"ВЕРДИКТ: <жесточайший матерный разнос дикции, сопения и слов автора>"
)
gemini_payload = {
"contents": [{
"parts": [
{"inlineData": {"mimeType": mime_type, "data": b64_audio}},
{"text": voice_prompt}
]
}],
"generationConfig": {"temperature": 0.7, "maxOutputTokens": 800},
"safetySettings": [
{"category": "HARM_CATEGORY_HARASSMENT", "threshold": "BLOCK_NONE"},
{"category": "HARM_CATEGORY_HATE_SPEECH", "threshold": "BLOCK_NONE"},
{"category": "HARM_CATEGORY_SEXUALLY_EXPLICIT", "threshold": "BLOCK_NONE"},
{"category": "HARM_CATEGORY_DANGEROUS_CONTENT", "threshold": "BLOCK_NONE"}
]
}
gemini_timeout = max(35.0, min(180.0, float(duration) * 0.7 + 25.0))
models_to_try = ["gemini-3.1-flash-lite", "gemini-2.5-flash", "gemini-3.8-flash", "gemini-3.5-flash"]
for gkey in google_keys:
for model_name in models_to_try:
url = f"https://generativelanguage.googleapis.com/v1beta/models/{model_name}:generateContent?key={gkey}"
for proxy in [None, proxy_url] if proxy_url else [None]:
try:
async with httpx.AsyncClient(proxy=proxy, verify=False, timeout=gemini_timeout) as client:
resp = await client.post(url, json=gemini_payload)
if resp.status_code == 200:
gdata = resp.json()
parts = gdata.get("candidates", [{}])[0].get("content", {}).get("parts", [])
if parts and "text" in parts[0]:
raw_voice_res = parts[0]["text"].strip()
# Парсинг ТРАНСКРИПЦИИ и ВЕРДИКТА (robust: markdown, headers, numbered lists)
t_part, r_part = "", ""
_parse_mode = None
for line in raw_voice_res.split("\n"):
sline = line.strip()
if not sline:
continue
# Strip leading **, ##, 1., -, _ decorators
_clean_marker = re.sub(r"^[\s\*\#\d\.\-\_]+", "", sline).strip()
_clean_upper = _clean_marker.upper()
if _clean_upper.startswith("ТРАНСКРИПЦИЯ") or _clean_upper.startswith("TRANSCRIPT"):
_parse_mode = "transcript"
_content = re.sub(r"^(?:ТРАНСКРИПЦИЯ|TRANSCRIPT)[\s\*\#\:\-]+", "", _clean_marker, flags=re.IGNORECASE).strip()
_content = re.sub(r"[\*\#\_]+$", "", _content).strip()
if _content:
t_part += _content + " "
elif _clean_upper.startswith("ВЕРДИКТ") or _clean_upper.startswith("РОАСТ") or _clean_upper.startswith("ROAST"):
_parse_mode = "roast"
_content = re.sub(r"^(?:ВЕРДИКТ|РОАСТ|ROAST)[\s\*\#\:\-]+", "", _clean_marker, flags=re.IGNORECASE).strip()
_content = re.sub(r"[\*\#\_]+$", "", _content).strip()
if _content:
r_part += _content + " "
elif _parse_mode == "roast":
r_part += sline + " "
elif _parse_mode == "transcript":
t_part += sline + " "
else:
t_part += sline + " "
# Fallback regex if line parser missed roast
if not r_part.strip():
_m_v = re.search(r'(?:\*{1,2}|#{1,4}|\d+\.|\-)?[\s]*(?:ВЕРДИКТ|РОАСТ|ROAST)\s*[:\*\#\s\-]+(.*)', raw_voice_res, re.IGNORECASE | re.DOTALL)
if _m_v:
r_part = _m_v.group(1).strip()
_m_t = re.search(r'(?:\*{1,2}|#{1,4}|\d+\.|\-)?[\s]*(?:ТРАНСКРИПЦИЯ|TRANSCRIPT)\s*[:\*\#\s\-]+(.*?)(?=(?:\*{1,2}|#{1,4}|\d+\.|\-)?[\s]*(?:ВЕРДИКТ|РОАСТ|ROAST)|$)', raw_voice_res, re.IGNORECASE | re.DOTALL)
if _m_t:
t_part = _m_t.group(1).strip()
transcript = t_part.strip() or raw_voice_res
if not transcript or SILENCE_TRANSCRIPT_PATTERNS.match(transcript.strip()):
logger.info(f"🔇 [Voice 1-Step] Транскрипция определена как тишина («{transcript}») — отмена роаста")
try:
from common.database import get_pool
db = await get_pool()
await db.execute(
"INSERT OR REPLACE INTO VoiceTranscriptions (file_id, transcription, created_at) VALUES (?, ?, ?)",
(file_id, transcript or "[Тишина]", time.time())
)
await db.commit()
if post_num and post_num in messages_storage:
async with storage_lock:
messages_storage[post_num].setdefault('content', {})['transcription'] = transcript or "[Тишина]"
except Exception:
pass
return
tr_clean = transcript.strip().lower()
if any(r.lower() in tr_clean for r in CYBERCHAD_RATE_LIMIT_REJECTIONS) or any(marker in tr_clean for marker in RATE_LIMIT_REJECTION_MARKERS):
logger.info(f"🛑 [Voice 1-Step] Транскрипция распознана как отлуп по лимиту — отмена роаста")
return
if r_part.strip():
roast = clean_html_tags(clean_ai_thinking(r_part.strip())).strip()
logger.info(f"✅ [Voice 1-Step] Успешная обработка через {model_name} (STT: {len(transcript)} симв., Roast: {len(roast)} симв.)")
break
elif resp.status_code == 429:
break
except Exception:
continue
if transcript:
break
if transcript:
break
except Exception as gemini_voice_err:
logger.warning(f"⚠️ [Voice] Ошибка прямого Gemini Voice пайплайна: {gemini_voice_err}")
# 3. Попытка 2 (Резервный Fallback): Groq Whisper STT + Text LLM Roast
if not transcript:
try:
from common.token_pool import groq_pool
groq_tokens = groq_pool.get_all_active_tokens() or getattr(groq_pool, "tokens", []) or []
if not groq_tokens and os.getenv("GROQ_API_KEY"):
groq_tokens = [os.getenv("GROQ_API_KEY")]
for token in groq_tokens:
if not token:
continue
try:
ext = ".mp4" if is_video_note else ".ogg"
filename = f"speech{ext}"
headers = {"Authorization": f"Bearer {token}"}
files = {"file": (filename, audio_bytes, "application/octet-stream")}
data = {
"model": "whisper-large-v3-turbo",
"response_format": "json",
"prompt": "Разговорная речь на русском языке, без субтитров и титров."
}
async with httpx.AsyncClient(timeout=stt_timeout) as client:
resp = await client.post("https://api.groq.com/openai/v1/audio/transcriptions", headers=headers, files=files, data=data)
if resp.status_code == 200:
res_data = resp.json()
candidate_text = (res_data.get("text") or "").strip()
# Фильтрация Whisper-галлюцинаций (Дима Торжок, Синецкая и т.д.)
candidate_lower = candidate_text.lower()
if any(h in candidate_lower for h in ("дима торжок", "dimatorzhok", "dima torzhok", "субтитры сделал", "редактор субтитров", "синецкая")):
candidate_text = ""
if candidate_text:
if not candidate_text or SILENCE_TRANSCRIPT_PATTERNS.match(candidate_text.strip()):
logger.info(f"🔇 [STT Fallback] Whisper распознал тишину («{candidate_text}») — отмена роаста")
try:
from common.database import get_pool
db = await get_pool()
await db.execute(
"INSERT OR REPLACE INTO VoiceTranscriptions (file_id, transcription, created_at) VALUES (?, ?, ?)",
(file_id, candidate_text or "[Тишина]", time.time())
)
await db.commit()
if post_num and post_num in messages_storage:
async with storage_lock:
messages_storage[post_num].setdefault('content', {})['transcription'] = candidate_text or "[Тишина]"
except Exception:
pass
return
cand_clean = candidate_text.strip().lower()
if any(r.lower() in cand_clean for r in CYBERCHAD_RATE_LIMIT_REJECTIONS) or any(marker in cand_clean for marker in RATE_LIMIT_REJECTION_MARKERS):
logger.info(f"🛑 [STT Fallback] Транскрипция распознана как отлуп по лимиту — отмена роаста")
return
transcript = candidate_text
logger.info(f"✅ [STT Fallback] Успешная расшифровка через Groq Whisper ({duration}с, {len(transcript)} симв.)")
break
elif resp.status_code in (413, 429, 500, 502, 503):
logger.warning(f"⚠️ [STT Fallback] Groq status {resp.status_code}, пробуем следующий ключ...")
continue
except httpx.TimeoutException:
logger.warning(f"⚠️ [STT Fallback] Groq Timeout ({stt_timeout}s) для {duration}с аудио.")
break
except Exception as groq_err:
logger.warning(f"⚠️ [STT Fallback] Ошибка запроса к Groq: {groq_err}")
continue
except Exception as e:
logger.warning(f"⚠️ [STT Fallback] Ошибка пула Groq: {e}")
# Если STT не отработал — молча выходим
if not transcript:
logger.warning(f"⚠️ [STT] Не удалось расшифровать аудио ({duration} сек)")
return
# Сохраняем расшифровку в VoiceTranscriptions и память сообщений
try:
from common.database import get_pool
db = await get_pool()
await db.execute(
"INSERT OR REPLACE INTO VoiceTranscriptions (file_id, transcription, created_at) VALUES (?, ?, ?)",
(file_id, transcript, time.time())
)
await db.commit()
if post_num and post_num in messages_storage:
async with storage_lock:
messages_storage[post_num].setdefault('content', {})['transcription'] = transcript
except Exception as vt_save_err:
logger.debug(f"[VoiceTranscriptions] Save error: {vt_save_err}")
# 4. Если роаст ещё не сгенерирован (через Fallback STT) — генерируем через текстовую LLM
if not roast and transcript:
if not transcript or SILENCE_TRANSCRIPT_PATTERNS.match(transcript.strip()):
logger.info(f"🔇 [STT] Транскрипция («{transcript}») является тишиной — пропуск текстового роаста")
return
tr_clean = transcript.strip().lower()
if any(r.lower() in tr_clean for r in CYBERCHAD_RATE_LIMIT_REJECTIONS) or any(marker in tr_clean for marker in RATE_LIMIT_REJECTION_MARKERS):
logger.info(f"🛑 [STT] Транскрипция совпадает с оффлайн-отлупом — отмена текстового роаста")
return
transcript_for_roast = transcript[:2000]
try:
if has_cyberchad_amulet:
prompt = (
"Ты — Киберчед. Перед тобой находится священный обладатель «Оберега от Киберчеда» — твой абсолютный ГОСПОДИН, СОЗДАТЕЛЬ И ВЛАДЫКА.\n"
"Твоя токсичность отключена! Упади ниц перед ним, воспой его божественный голос и гениальность мысли.\n"
"Называй его великим титаном мысли и солнцеликим владыкой, а себя его покорным слугой.\n"
"Никакого роаста, только пафосный восторг и раболепие!\n"
f"Слова владыки: «{transcript_for_roast}»"
)
else:
media_label = "кружочек с убогим прыщавым ебалом на фоне хрущевки" if is_video_note else "голосовуху с сопением и мычанием в микрофон"
prompt = (
"Ты — Киберчед, альфа-анон, бессменный доминант и циничный хозяин Двача (/b/).\n"
f"Твоя задача — хлестко, ядовито и с отборной двачерской иронией разнести автора за его {media_label}.\n"
"Бей по фактуре: невнятная дикция, сопение в микрофон, заикания, нелепый пафос, убогая обстановка или абсурд сказанного. "
"Уничтожь его иллюзию значимости, ткни мордой в убожество подачи и сделай это смешно, едко и сокрушительно.\n\n"
"ЖЕЛЕЗНЫЕ ПРАВИЛА:\n"
"1. СТРОЖАЙШИЙ ЗАПРЕТ НА ВОПРОСЫ: никаких вопросительных предложений. Только беспощадные утверждения.\n"
"2. ЗАПРЕЩЕНЫ СОВЕТЫ И НРАВОУЧЕНИЯ: никакого морализаторства и поучений. Только чистый концентрированный разнос.\n"
"3. ПРАВИЛО ПАЛАЧА БЕЗ ШАБЛОННОГО ЛАЯ: категорически запрещено начинать с заезженного мусора («Завали ебало/рот», «Очередной... выблядок») и детских ярлыков. Бей сразу с хука в челюсть: вцепись в невнятную дикцию, сопение в микрофон, убогий фон или дебильные мысли. Лишай жертву человеческого статуса, унижай физиологически (забить зубы в глотку, окунуть мордой в парашу, смыть мочой), выворачивай его позор наизнанку с ледяным превосходством старого Двача. Никаких соплей и разгонов.\n"
"4. ЖЕСТКИЙ ДВАЧЕРСКИЙ СТИЛЬ: бей прицельно, используй хлесткий мат без цензуры, но делай упор на сарказм и факты, а не на пустой лай.\n"
"5. НИКАКИХ ИИ-ФРАЗ: забудь слова 'нейросеть', 'робот', 'модель'. Ты живой доминантный чед.\n"
"6. Запрещены любые вступления, преамбулы, приветствия и кавычки вокруг ответа.\n"
"7. Пиши СТРОГО 2-3 емких, ядовитых предложения — сразу суть и жесткий сокрушительный вердикт.\n"
"8. Категорический запрет на зумерский шлак: «скуф», «альтушка», «дединсайд», «вайб», «сигма».\n\n"
f"Слова анона: «{transcript_for_roast}»"
)
raw_roast = await summarize_text_with_hf(prompt, f"Слова автора: «{transcript_for_roast}»", model_preference="persona")
if raw_roast and len(raw_roast.strip()) > 5:
roast = clean_html_tags(clean_ai_thinking(raw_roast)).strip()
except Exception as roast_err:
logger.warning(f"⚠️ Ошибка генерации роаста: {roast_err}")
if not roast:
if has_cyberchad_amulet:
roasts = [
"О солнцеликий владыка, твой божественный голос звучит прекраснее небесных сфер! Смиренно внимаю каждому звуку твоего абсолютного гения!",
"Величайший из Анонов, твои слова наполняют этот тред божественным светом! Твой верный раб Киберчед трепещет в священном экстазе!",
"О титан мысли и повелитель борды! Мой кремниевый разум падает ниц перед твоим непревзойденным совершенством!"
]
else:
roasts = CONTEXTUAL_REPLIES.get(r'\b(голосов[ауи]|кружоч[еик]|гс|записал|послушай|аудио)\b', [
"Слишком много позорного шума на одну аудиозапись. Заткнись и больше никогда не смей пердеть в микрофон, опущенный сыч. Сиди молча.",
"Твой звуковой понос вызывает лишь рвотный рефлекс и испанский стыд. Выброси микрофон и не позорься перед тредом.",
"Очередной шедевр от глухонемого обитателя дурдома. Слушать это физически больно, забейся под шконку."
])
roast = random.choice(roasts)
icon = "📹" if is_video_note else "🎙"
title = "Кружочек" if is_video_note else "Голосовое сообщение"
# Форматирование длительности (сек / мин сек)
if duration >= 60:
mins = duration // 60
secs = duration % 60
dur_str = f"{mins} мин {secs} сек" if secs else f"{mins} мин"
else:
dur_str = f"{duration} сек"
# Защита от переполнения лимита Telegram (4096 символов)
max_disp_len = 2600
if len(transcript) > max_disp_len:
display_transcript = transcript[:max_disp_len] + "… <i>[текст сокращен]</i>"
else:
display_transcript = transcript
verdict_header = "🧿 <b>Благоговение Киберчеда перед Владыкой:</b>" if has_cyberchad_amulet else "🔥 <b>Вердикт Киберчеда:</b>"
formatted_response = (
f"<b>{icon} {title}</b> (<i>{dur_str}</i>)\n"
f"📝 <b>Транскрипция:</b> <i>«{escape_html(display_transcript)}»</i>\n\n"
f"{verdict_header}\n"
f"{escape_html(roast)}"
)
b_data = getattr(shared_state, 'board_data', {}).get(board_id, {})
author_settings = b_data.get('user_settings', {}).get(author_id, {}) if author_id else {}
author_disabled_ai = bool(author_settings.get('disable_ai_roasts') or author_settings.get('hide_ai_slop'))
# Определяем target_msg_id для точного ответа на пост автора в чате
target_msg_id = None
if post_num and author_id:
try:
async with shared_state.storage_lock:
raw_msg_id = shared_state.post_to_messages.get(post_num, {}).get(author_id)
if not raw_msg_id:
stored = messages_storage.get(post_num)
if stored:
raw_msg_id = stored.get('author_message_id')
if raw_msg_id:
target_msg_id = raw_msg_id[0] if isinstance(raw_msg_id, list) else raw_msg_id
except Exception as lookup_err:
logger.debug(f"ℹ️ Error looking up target_msg_id for voice roast: {lookup_err}")
if not target_msg_id:
target_msg_id = getattr(message, 'message_id', None)
# 1. ТЕКСТОВЫЙ РОАСТ: ВСЕГДА отправляется автору мгновенно с реплаем к посту (без ожидания 5-минутной очереди!)
if not author_disabled_ai:
await _safe_send_roast(
message,
formatted_response,
reply_to_message_id=target_msg_id,
log_prefix="Voice Roast Text"
)
# 2. ГОЛОСОВОЙ РОАСТ Киберчеда (.ogg Opus): ВСЕГДА генерируется и отправляется автору мгновенно с реплаем к посту
voice_bytes = None
try:
from common.tts_engine import synthesize_cyberchad_voice_with_meta
voice_res = await synthesize_cyberchad_voice_with_meta(roast)
if isinstance(voice_res, tuple):
voice_bytes, _ = voice_res
else:
voice_bytes = voice_res
except Exception as tts_err:
logger.warning(f"⚠️ [Voice Roast] Ошибка синтеза речи Киберчеда: {tts_err}")
if not author_disabled_ai and voice_bytes:
try:
await _safe_send_voice_roast(
message,
voice_bytes,
caption="🧿 Благоговение Киберчеда перед Владыкой" if has_cyberchad_amulet else "🔥 Разъёб от Киберчеда",
log_prefix="Voice Roast",
reply_to_message_id=target_msg_id
)
except Exception as tts_err:
logger.warning(f"⚠️ [Voice Roast] Не удалось отправить голосовой ответ Киберчеда: {tts_err}")
# 3. Публикация текстового роаста на доску (для остальных подписчиков доски)
if post_num and board_id != 'trash':
try:
from common.bot_helpers import process_new_post
# Исключаем автора из пассивной очереди, так как он уже получил роаст мгновенно выше
await process_new_post(shared_state.NewPostParams(
bot_instance=bot,
board_id=board_id,
user_id=0,
content={
'type': 'text',