?UPi^ddlZddlZddlZddlZddlZddlZddlZddlmZddlddl m Z m Z m Z ddl mZGddZy)N)datetime)*)COMMANDS MOD_COMMANDS AUTO_MESSAGES)DatabaseceZdZddZdZdZdZdZdZdZ d Z d Z d Z d Z d ZdZdZdZdZdZdZdZdZdZdZy) TwitchBotNc||_||_tj|_d|_d|_d|_i|_tj|_ d|_ t|_ d|_d|_g|_d|_d|_d|_d|_i|_g|_d|_d|_d|_d|_d|_d|_d|_d|_d|_y)NFr) db telegram_botsocketsock connected broadcasteris_stream_online user_messagesrnowstream_start_timetotal_messagesset active_usersgiveaway_active giveaway_itemeligible_userscurrent_winnerwinner_deadlinewaiting_for_trade_linkactive_drop_enabledactive_drop_users drop_winnerscurrent_drop_winnerdrop_winner_deadlinewaiting_for_drop_trade_linknumber_game_active secret_numbernumber_game_maxnumber_game_winnernumber_game_deadlinewaiting_for_number_game_link)selfdatabasers /root/twitch_bot/twitch_bot.py__init__zTwitchBot.__init__s(MMO !& !)E % " &+#$) !##' $%!+0(#( "&$%!,1)c d|j}tj|d}|jdk(r\|jj }||jdk7}||j k7rt|rdndd|rd nd ||_|S|j S#t$r$}td ||j cYd }~Sd }~wwxYw) uNПроверить статус стрима через публичное APIz https://decapi.me/twitch/uptime/)timeoutz is offlineu🟢u🔴u [TWITCH] Стрим u ОНЛАЙНu ОФЛАЙНu/⚠️ [TWITCH] Ошибка проверки: N) rrequestsget status_codetextstriprprint Exception)r,urlresponser8 is_onlinees r.check_stream_statuszTwitchBot.check_stream_status;s )4T5E5E4FGC||C3H##s*}}**, t'7'7&8 $DD  5 55yVf==RenSauCSDEF(1%  (( ( ) CA3G H(( ( )s$BB B C (CC C c|jr7|jtjt|jr6yy)uAПостоянная проверка статуса стримаN)rr@timesleepCHECK_STREAM_INTERVALr,s r.stream_status_checkerzTwitchBot.stream_status_checkerPs+nn  $ $ & JJ, -nnr0c |jjttf|jj dt dj |jj dtdj |jj dtdj |jj dj |jj dj d|_ tdd |_ td ty #t$r}td |Yd }~y d }~wwxYw) u$Подключение к Twitch IRCzPASS  zNICK zJOIN zCAP REQ :twitch.tv/tags zCAP REQ :twitch.tv/commands TNu%✅ [TWITCH] Подключено к u2❌ [TWITCH] Ошибка подключения: ) rconnect TWITCH_IRC TWITCH_PORTsend OAUTH_TOKENencode BOT_USERNAMECHANNELrrr:r;)r,r?s r.rJzTwitchBot.connectXs L II  z;7 8 IINNU;-t4;;= > IINNU<.5<<> ? IINNU7)40779 : IINN8??A B IINN<CCE F!DN&qr{D  9'C D L FqcJ K K LsD1D44 E=EEc:|jstd|dddy |jjdtd|dj td|t jd y#t$r}td |Yd}~yd}~wwxYw) u-Отправка сообщения в чатu:⏸️ [TWITCH] Не отправлено (офлайн): N2z...zPRIVMSG  :rHu📤 [TWITCH] rIu,❌ [TWITCH] Ошибка отправки: ) rr:rrMrQrOrBrCr;)r,messager?s r. send_messagezTwitchBot.send_messagegs$$ NwWZXZ|n\_` a  F IINNXgYb >EEG H N7), - JJqM F @D E E FsAA99 BBBc d|vry|jdr|jd}|dkDr|d|nd}tjd|}|sy|j d }tjd |}|r$|j d j }|||fSd }tj||} | r5| j d }| j d j }d||fS y#YyxYw) u%Парсинг IRC сообщенияPRIVMSG)r NN@rTrNr z:(\w+)!\w+@\w+\.tmi\.twitch\.tvrIzPRIVMSG #\w+ :(.+)z2:(\w+)!\w+@\w+\.tmi\.twitch\.tv PRIVMSG #\w+ :(.+)) startswithfindresearchgroupr9) r,datatags_endtagsusername_matchusername msg_matchrUpatternmatchs r. parse_messagezTwitchBot.parse_messagevs $%s#99T?*2Q,tIXB!#+Mt!T%))//2II&;TB 'ooa0668G722KGIIgt,E ;;q>++a...08W,,   sC,AC,A C,AC,,C0c|j|jjk(ryd|vr2tjd|}|r|j d}d|vsd|vryy)u.Проверка прав модератораTzbadges=zbadges=([^;]+)rIz broadcaster/z moderator/F)lowerrr]r^r_)r,rbrd badges_matchbadgess r.is_mod_or_broadcasterzTwitchBot.is_mod_or_broadcastersd >> t//557 7  99%6=L%++A.!V+|v/Er0cd|jtjk7r|jj|ddz|j|<|xjdz c_|j j ||jr"tj|j|<yyy)uHОтслеживание активности пользователейrrIN) rjrPrr6rraddr rBr!r,rds r.track_user_activityzTwitchBot.track_user_activitys >> |113 3+/+=+=+A+A(A+NQR+RD  x (   1 $     ! !( +''3799;&&x0( 4r0c|jj}|tvr|jt|yy)u.Обработка обычных командTF)rjr9rrV)r,rU message_lowers r.handle_regular_commandsz!TwitchBot.handle_regular_commandss7 --/ H $   h}5 6r0c |j||sy|jj}|tvr|j t|y|dk(rt j |jz }t|jdz}t|jdzdz}|j d|d|d|jd t|jy|d k(r|jj|j|j|jrL|j d t j |_d |_ |jjy|j d yy)uEОбработка базовых команд модераторовFTz!statsi<u📊 Стрим: uч uм | Сообщений: u | Юзеров: z !savestatsu,✅ Статистика сохранена!ru%❌ Ошибка сохранения)rmrjr9rrVrrrint total_secondsrlenrr save_stream_statsclear)r,rbrdrUrsdurationhoursminutess r.handle_mod_basic_commandsz#TwitchBot.handle_mod_basic_commandss{))$9 --/ L (   l=9 : H $||~(>(>>H..0D89E8113d:rABG   #E7#gY6OPTPcPcOdduvyz~{L{LwMvNO P L (ww(()?)?ATATVZVgVgh!!"PQ)1&&'#!!'')!!"IJr0ctj}g}t|jjD]0\}}||z tkr|j |$|j|=2|S)ucПолучить активных пользователей за последние 3 минуты)rBlistr!itemsACTIVE_DROP_ACTIVITY_WINDOWappend)r, current_timerrd last_times r.get_active_drop_userszTwitchBot.get_active_drop_usersslyy{  #'(>(>(D(D(F#G 5 Hii'+FF##H-**84  5 r0c|jrmtjt|jr:|jr.t |j }|jd|d|jrlyy)u?Автоматические объявления о дропеuF🎁 АКТИВНЫЙ ДРОП НА СТРИМЕ! За просмотр турнира и активность в чате вы участвуете в дропе 🔥 💬 Пишите в чат, оставайтесь на стриме — в любой момент можно получить скин! (Активных: )N)r rBrCACTIVE_DROP_ANNOUNCE_INTERVALrryrrV)r, active_counts r.active_drop_announcerzTwitchBot.active_drop_announcersw&& JJ4 5''D,A,A"4#=#=#?@ !!]^j]kklmn &&r0cL|jr|jdyd|_|jj|jj|jdt j |jdjtdy)u*Запуск активного дропаu7⚠️ Активный дроп уже запущен!NTuw🎁 АКТИВНЫЙ ДРОП ЗАПУЩЕН! 🔥 Пишите в чат и оставайтесь на стриме!targetdaemonu5✅ [TWITCH] Активный дроп запущен) r rVr!r{r" threadingThreadrstartr:rEs r.start_active_dropzTwitchBot.start_active_drops  # #   W X #'  $$& ! T U : :4HNNP EFr0cjsjdyj}|sjdyt|}t j |_tjtz_ d_ jdj dj d|d}tdd d 5}tj||dddtd j d tj j"j%fd}tj |dj%y#1swY{xYw)u.Выбрать победителя дропаu5⚠️ Активный дроп не запущен!Nu2😢 Нет активных участников!Tu&🎉 ДРОП! Победитель: @uH! ⏰ У тебя 3 минуты! Отправь трейд-ссылку)winneractive user_countzwinner_data.jsonwutf-8)encodinguDEBUG: Победитель u% отправлен в оверлей)rctjtjr.j dj dd_d_yy)N⏰ @ не успел!F)rBrCDROP_RESPONSE_TIMEr%rVr#rEsr. timeout_checkz-TwitchBot.execute_drop..timeout_checksM JJ) *//!!E$*B*B)CCT"UV380+/(0r0r)r rVrryrandomchoicer#rBrr$r%openjsondumpr:rr delayed_clearr)r,rrr`frs` r. execute_dropzTwitchBot.execute_dropsK''   U V 113    R S & #)==#> $(IIK2D$D!+/( B4C[C[B\]ef g..$  $cG <  IIdA   ,T-E-E,FFklm  2 2399; 0  d;AAC  s EE'c|j||sy|jj}|dk(r|jy|dk(r/d|_|j dt |jy|dk(r|jy|dk(rDt |j}|j d|d t |jyy) u=Обработка команд активного дропаFz !activedropTz!stopactivedropu8🛑 Дроп завершён! Победителей: z!dropz !dropstatsu📊 Активных: u | Победителей: ) rmrjr9rr rVryr"rr)r,rbrdrUrsrs r.handle_active_drop_commandsz%TwitchBot.handle_active_drop_commands&s))$9 --/ M )  " " $ - -',D $    XY\]a]n]nYoXpq r G #     L (3356F    7x?Z[^_c_p_p[qZrs tr0cV|jr|jdyd|_tjd||_||_|jd|d|jdt dt d |t d |jt d y) u:Запуск игры с угадыванием числаu ⚠️ Игра уже идёт!NTrIuH🎲 ИГРА НАЧАЛАСЬ! Угадайте число от 1 до !ut💬 Пишите свои варианты в чат! Первый кто угадает - получит приз!uE🎲 [TWITCH] ===== ИГРА С ЧИСЛАМИ ЗАПУЩЕНА =====u$🎲 [TWITCH] Диапазон: 1 - u/🎲 [TWITCH] Загаданное число: u9🎲 [TWITCH] ===========================================)r&rVrrandintr'r(r:)r, max_numbers r.start_number_gamezTwitchBot.start_number_gameCs  " "   @ A "&#^^Az:) deodppqrs Q S UW 4ZLAB ?@R@R?STU IKr0c jsy tjd|}|syt|d}|dks|jkDry|j k(rd__tjtz_ d_ jddj d jd td td td j tdfd}tj|djy|j krd}nd}tdd|d|dy#t $rYywxYw)u9Проверка попытки угадать числоNz\b\d+\brrIFTu🎉 ПОБЕДА! @u угадал число ruQ⏰ У тебя 3 минуты! Отправь трейд-ссылку в чат!u;🎉 [TWITCH] ===== ПОБЕДИТЕЛЬ НАЙДЕН =====u$🎉 [TWITCH] Победитель: u-🎉 [TWITCH] Угаданное число: u.🎉 [TWITCH] ================================ctjtjr=j dj dd_d_t ddyy)NrrFu ⏰ [TWITCH] u= не отправил трейд-ссылку вовремя)rBrCrr+rVr)r:rpsr.rz3TwitchBot.check_number_guess..timeout_checkws_JJ1288))E$2I2I1JJ[*\]Tz !stopnumberu8🔍 [DEBUG] Команда !stopnumber полученаu&🔍 [DEBUG] Игра активна: uP🛑 Игра остановлена! Загаданное число было: uF🛑 [TWITCH] Игра остановлена модератором (ru#❌ Игра не запущена!) rmrjr9r:r[splitryisdigitrwrVrr&r')r,rbrdrUrspartsmax_nums r.handle_number_game_commandsz%TwitchBot.handle_number_game_commandss|))$9 --/  HWXYZ  # #L 1MMOE5zQ58#3#3#5eAh-R<%%&_` v%%%&cd **73!!"ST M ) L N :4;R;R:ST U&&*/'!!$tuyvHvHuI#JK^_g^hhijk!!"GHr0cjr|jjjk(rtjt |}|r|j d}tjjkrWjd|djj||rjdd_ d_d_jr|jjjk(rtjt |}|r|j d}tjjkrjd|djj||rjdj j#|d_ d_fd }t%j&|d j)j*r|jj,jk(rtjt |}|r|j d}tjj.kr`jd|d jj||r jdt1d |dd_d_yyyyy)uBПроверка трейд-ссылки от победителяru✅ @u прошёл проверку!u%💾 Данные сохранены!FNu дроп получен!u+💾 Победитель сохранён!cPtjdjy)Nr2)rBrC clear_overlayrEsr.rz1TwitchBot.check_trade_link..delayed_clears JJqM ..0r0Tru приз получен!u+💾 [TWITCH] Трейд-ссылка от u сохранена в БД)rrjrr]r^TRADE_LINK_PATTERNr_rBrrVr save_winnerrr%r#r$r"rrrrr+r)r*r:)r,rdrUrg trade_linkrs` r.check_trade_linkzTwitchBot.check_trade_linksd  & &~~4#6#6#<#<#>> "4g>!&QJyy{d&:&::))E(;Z*[\77..xD --0UW/4,6;3.2+  + +~~4#;#;#A#A#CC "4g>!&QJyy{d&?&??))E(;T*UV77..xD --0[]))00:;@83701"(( dKQQS  , ,~~4#:#:#@#@#BB "4g>!&QJyy{d&?&??))E(;T*UV77..xD --0[]!$OPXzYt"uvd Yd}~d}~wwxYw|jjAy)uЗапуск ботаuP🔍 [TWITCH] Запуск мониторинга статуса стрима...Tru#✅ [TWITCH] Бот запущен!irignore)errorsPINGzPONG :tmi.twitch.tv u$ 👋 [TWITCH] Остановка...u⚠️ [TWITCH] Ошибка: r2N)!rrJr:r@rrrFrrrrecvdecoder[rMrOrhrqrrrtrrrKeyboardInterruptr rzrrrr;rBrCclose)r,r`rbrdrUr?s r.runz TwitchBot.runs~~ LLN `a   " : :4HNNP   " 34 yy~~d+22782L??6*IINN#<#C#C#EF*.*<*33G< 55dHgN 77hP 77hP /2% =>))$*@*@$BUBUW[WhWhi 6qc:; 1   s9A&F +AF F F 3F AHH##H  H)N)__name__ __module__ __qualname__r/r@rFrJrVrhrmrqrtrrrrrrrrrrrrrr0r.r r s|&2T)*. L F< ?D n G)DV:L$4l$P17j+.r0r )rr]rBrrr5rrconfigcommandsrrrr-rr rr0r.rs7   ::XXr0