[d^iŮ dZddlmZmZmZddlmZddlmZddl m Z ddl m Z ddl Z ddl mZdd lmZmZdd lmZdd lmZdd lmZmZddlZddlZ dd lmZdZe j>e Z!eZ"Gdde Z#Gdde Z$Gdde Z%Gdde Z&e"jOde$eeeefde#dedefdZ(e"jSde*e$eeeefdedefdZ+e"jSde$eeeefd e,dedefd!Z-e"j]de$eeeefd e,de%dedefd"Z/e"jOd#deeeefd e,de&dzdedefd$Z0e"jcdeeeefd e,dedefd%Z2y#e$rdZYowxYw)&uQ API endpoints для управления MTProto аккаунтами Telegram ) APIRouterDepends HTTPException)Session)and_) BaseModel)datetimeN)get_db)UserTelegramMtprotoAccount)get_current_user) encrypt_token)get_telegram_clientclose_telegram_clientClientTFcDeZdZUeed<eed<eed<eed<dZeed<y)MtprotoAccountCreatenamephoneapi_idapi_hashF is_defaultN)__name__ __module__ __qualname__str__annotations__intrboolK/Users/talgatiskakov/sites/serviceNotifications/app/api/telegram_mtproto.pyrrs I J KMJr"rceZdZUeed<eed<eed<eed<edzed<eed<eed<eed <eed <Gd d Zy) MtprotoAccountOutid tenant_idrrNusernamestatusr created_at updated_atceZdZdZy)MtprotoAccountOut.ConfigTN)rrrfrom_attributesr!r"r#Configr-2sr"r/) rrrrrrr r r/r!r"r#r%r%'sA GN I JDj Kr"r%cJeZdZUdZedzed<dZedzed<dZedzed<y)MtprotoAccountUpdateNrrr)) rrrrrrrr r)r!r"r#r1r16s,D#*"Jt "FC$Jr"r1c"eZdZUdZedzed<y)AuthCodeRequestNcode)rrrr4rrr!r"r#r3r3<sD#*r"r3z/mtproto/accounts)response_modeldata current_userdbc |Kts"tjdtdd|jj ds tdd|j rP|jtjtj|jk(jdd it|j}t|j|j|j|j||j d }|j!||j#|j%||Sw) u0Создать новый MTProto аккаунтuxPyrogram не установлен, но пользователь пытается создать MTProto аккаунтuiФункция MTProto временно недоступна. Обратитесь в поддержку. status_codedetail+uНомер телефона должен быть в международном формате с + (например, +79991234567)rF pending_auth)r'rrr api_hash_encrr))PYROGRAM_AVAILABLEloggerwarningrr startswithrqueryr filterr'updaterrrraddcommitrefresh)r6r7r8rAaccounts r#create_mtproto_accountrM@s  R S~  ::  %Z    '(// " , , 0F0F F &,& '!/L%(( YYjj{{!??GFF7OIIKJJw NsD:D<cK|jtjtj|jk(j }|Sw)uGПолучить список MTProto аккаунтов тенанта)rFr rGr'all)r7r8accountss r#list_mtproto_accountsrQssGxx./66((L,B,BB ce  OsAAz/mtproto/accounts/{account_id} account_idcK|jtjtj|k(tj|jk(j }|s t dd|Sw)uAПолучить информацию о MTProto аккаунте(MTProto аккаунт не найденr;)rFr rGr&r'firstr)rRr7r8rLs r#get_mtproto_accountrWshhh-.55!!Z/((L,B,BB eg 4^__ NsA1A3cK|jtjtj|k(tj|jk(j }|s t dd|j|j|_|j|jrk|jtjttj|jk(tj|k7jddi|j|_|j|j|_ tj|_|j|j!||Sw)u'Обновить MTProto аккаунтrTrUr;rF)rFr rGr&r'rVrrrrrHr)r utcnowr+rJrK)rRr6r7r8rLs r#update_mtproto_accountrZs(hh-.55!!Z/((L,B,BB eg 4^__ yyyy  " ?? HH+ , 3 3*44 8N8NN*--;  flE*+!__ {{!*GIIKJJw NsE9E;z#/mtproto/accounts/{account_id}/authc *K|r2|jr&|jjr |jnd} ddlm}ddl}ddlm}|jtjtj|k(tj|jk(jj}|s tdd ||j} | s tdd|} |j j#|j%| j&} |j)| d d |} t*s"t,j/d td dddlm} t,j5dt,j5d|j6t,j5d|j8t,j5d| dddt,j5d| t,j5d| | | |j8| |j6| }t,j5d|j6d|  |j j#| | d}|j j;|}|r |j=d{|j?d{}d|_ |r |jBnd|_!tEjF|_$|jK|jMd{d d|r |jBnddS|st,j5d |d!|j6d"tEjFjUd#t,j5d$|jVr|jVdd%nd&d'd(}|jV|k(r6t,jQd)|d*|jYtd+d,|jVr4|jVj[d-r |jVj]d-d.}t_j`|jcd/jed/}tgjh|}|jkd0d}tEjFjm|z }|d1krVt,jQd2|d3|d4d5|jYtd+d6to|d7tod1|z d8t,j5d9|d4d:|d;z d4d<t,j5d?|d@||_+|jqt,j5dA| t,j5dB|j6dC|dDt,j5d|j8t,j5d| dddt,j5dE|j6|jsd{t,j5dFt,j5dGt,j5dH|j6dI|t,j5dJ|j8t,j5dK|jV}|r|j[d-rt,jQdL|dM |j]d-d.}t_j`|jcd/jed/}tgjh|}|jkdNr|jkdNd.ddOnd&}t,jQdP|dQdRttdSttfdT}t,j5dU||j6dC|dD |jw|j6d{} t,j5dVty| | s1t,j/dW|j6dC|dDtOdXt,j5dYt{|  t,j5dZt}| d[d\| j~}!|!s1t,j/d]|j6dC|dDtOd^t}| d_d}"t}| d`d}#t}| dad}$t,j5db|"t,j5dc|#t,j5dd|$tEjFjm}%tEjFjU}&t,j5det,j5dH||j6dI|t,j5df|&t,j5dg|"dh|#t,j5di|!r|!ddjnd&t,j5dk|!t,jQdl||j6t,jQdm||j6dn|!|%|%drzds}tgj|}t_j|jcd/jed/}d-||_+|jKt,j5dt|%t,j5du |jd{dvdw|j6dxd dyS d}1|jVr|jVj[d-r |jVj]d-d.}t_j`|jcd/jed/}tgjh|}|jkdN}1|jkd0d}|jkd|drz}2tEjFjm}3|3|z }|2|3z }4|dkDr#tEj|jUnd}&tEjFjU}5t,j5dt,j5dH|j6dI|t,j5d|5t,j5d|&d|dDt,j5d|d4d|d;z ddt,j5d|4d4dt,j5di|1r|1ddjnd&t,j5dk|1|1s%t,jQd|tdd|3|2kDrNt,jQd|d|d4dt|4d4dd|_+|jKtdd|drkDrHt,jQd|d{|d4d|d;z d4dd|_+|jKtddn tdd|1s tdd|jsd{ tu|j}7t,j5dt,j5dt|7dt|7dk\r|7ddn|7dDt,j5di|1r|1ddjnd&t,j5dk|1t,j5d|d4d:|d;z dd|j|j6|1|7d{}8t,j5d|j?d{}d|_ |r |jBnd|_!d|_+tEjF|_$|jK|jd{d d|r |jBnddS7 (7 7 #tN$r=}t,jQd| |jS|n#YnxYwYd}~ d}~wwxYw#t$rtN$r&}t,jQd=|d>|Yd}~ d}~wwxYw7 =#YxYw7#YxYw#tN$r6}'t,j/do||j6dC|dp|'d qd}'~'wwxYw7#YxYw#tN$r`}(t,j/dz|d{|(d|_+|jYt,j5d|| |jd{7n#YnxYwtu|(})t,j/d}|j6d{|(d qd~|)jvsd|)jvrddlE}*|*jd|)}+|+rto|+jdnd},|,d;z}-|-d;z}.|.dkDr|-d;zdkDr |.d|-d;zd}/n|.d}/n|-dkDr|-d}/n|,d}/d|/d}0td+|0tddtu|(d}(~(wwxYw#t$rtN$r,}6t,j/d|6d qtddd}6~6wwxYw7,7K#tN$r}9tu|9})|)j}:t,j/dt,j/d|)t,j/dt7dk\r|7ddn|7dt|7dDt,j/di|1r|1ddjnd&t,j/dk|1t,j/d|d4d:|d;z dd |jd{7n#YnxYwd|:vsd|:vr"d|_+|jKdvdd dcYd}9~9Sd|:vsd|:vrEt,jQd|d4d|d;z ddd|_+|jKtddd|_+|jKd}9~9wwxYw77[#t$rtN$rW}; |jd{7n#YnxYwd|_+|jKtddtu|;d};~;wwxYw#t$rtN$r]}< |jd{7n#YnxYwt,j/d|d{|<d qtddtu|<d}<~zDauthenticate_mtproto_account.._mask_phone..s(H2::<(Hsz***z****)joinlen)rrdigitss r# _mask_phonez1authenticate_mtproto_account.._mask_phone|s> #,!#(Ha(H!Hv;!+#("("+d33r"u,[AUTH] Вызов client.send_code() для u9[AUTH] send_code() вернул результат: type=u,[AUTH] send_code() вернул None для usend_code() вернул Noneu#[AUTH] Атрибуты sent_code: zUTH] sent_code.__dict__: __dict__zN/AuQ[AUTH] send_code() вернул результат без phone_code_hash для uBsend_code() вернул результат без phone_code_hashtype next_typetimeoutu[AUTH] Тип кода: u.[AUTH] Следующий тип (next_type): z[AUTH] Timeout: u8[AUTH] ===== КОД ОТПРАВЛЕН В TELEGRAM =====u$[AUTH] Время отправки: u)[AUTH] Тип отправки кода: z , next_type: u;[AUTH] phone_code_hash (первые 40 символов): (u'[AUTH] phone_code_hash (полный): ux[AUTH] ⚠️ ВАЖНО: Код должен прийти В ПРИЛОЖЕНИЕ TELEGRAM (не SMS!) на номер u[AUTH] ⚠️ Если код не приходит, проверьте: 1) Открыто ли приложение Telegram на устройстве с номером uh, 2) Правильность номера телефона, 3) Правильность api_id/api_hashu;[AUTH] Ошибка при вызове send_code() для z): )exc_infoi)rpr* expires_atu<[AUTH] phone_code_hash сохранен в БД, timestamp: u?[AUTH] Commit выполнен, блокировка снятаFuMКод авторизации отправлен в Telegram на номер uv. Проверьте приложение Telegram (не SMS) и введите код в модальном окне.)rfrg requires_codeuF[AUTH] Ошибка отправки кода для аккаунта z: u}[AUTH] Транзакция откачена из-за ошибки, блокировка снята для аккаунта u.Ошибка отправки кода для FLOOD_WAITfloodz(\d+)u ч. u мин.u ч.u сек.uTelegram временно заблокировал отправку кодов из-за частых запросов. Подождите u$ и попробуйте снова.r?u(Ошибка отправки кода: ruнеизвестноu6[AUTH] ===== ПОДТВЕРЖДЕНИЕ КОДА =====u"[AUTH] Текущее время: u%[AUTH] phone_code_hash создан: z (timestamp: u$[AUTH] Прошло времени: u секунд (z.2fu минут)u1[AUTH] Осталось до истечения: u секундuS[AUTH] phone_code_hash не найден в temp_auth_data для аккаунта uoСессия авторизации повреждена. Нажмите 'Авторизовать' снова.u:[AUTH] phone_code_hash истек для аккаунта u: создан u? секунд назад, срок действия истек u секунд назадuКод авторизации истек. Нажмите 'Авторизовать' для получения нового кода.uK[AUTH] phone_code_hash слишком старый для аккаунта u8Ошибка декодирования temp_auth_data: uСессия авторизации не найдена. Нажмите 'Авторизовать' снова для получения нового кода.u%[AUTH] ===== ВЫЗОВ sign_in =====uUTH] Код (длина: u, первые 2 цифры: u$[AUTH] phone_code_hash создан u.[AUTH] sign_in успешно выполненu'[AUTH] ===== ОШИБКА sign_in =====u[AUTH] Ошибка: u[AUTH] Код: u... (длина: password2fauТребуется пароль двухфакторной аутентификации (2FA). Введите пароль от аккаунта Telegram.)rfrgrequires_passwordphone_code_expiredexpiredu<[AUTH] Код истек (PHONE_CODE_EXPIRED). Прошло u? минут) с момента создания phone_code_hashuIКод авторизации истек. Это может произойти если: 1) прошло слишком много времени с момента получения кода, 2) был запрошен новый код. Нажмите 'Авторизовать' для получения нового кода.u0Неверный код авторизации: u=Ошибка авторизации MTProto аккаунта u%Ошибка авторизации: error)Lr4stripapp.utils.encryptionr\osapp.core.configr^rFr rGr&r'with_for_updaterVrrApathr}getcwdTELEGRAM_SESSION_PATHmakedirsrBrCrpyrogramrinforrexistsstartget_mer)r(r rYr+rJstop ExceptionrDremove isoformat session_pathrollbackrEreplacebase64 b64decodeencodedecodejsonloadsget timestamprflushconnectr send_coderdirgetattrrpdumps b64encode disconnectupperlowerresearchgrouputcfromtimestampabsr~sign_in)>rRr6r7r8 auth_coder\rr^rLrsettingssession_base_path session_namerclientsession_file_pathsession_existsme start_errorprocessing_flag encoded_datajson_strtemp_auth_datar* time_passed decode_errold_session_path old_encodedold_jsonold_dataold_hashr sent_codenew_phone_code_hash code_typerrcreated_timestamp created_isosend_code_error send_error error_strr wait_match wait_seconds wait_minutes wait_hours wait_timewait_msgrpr current_timetime_until_expiry current_iso decode_errorcode_str signed_in sign_errorerror_str_lower sign_in_errore error_msgs> r#authenticate_mtproto_accountrs"diiDIIOO4E 4I 3 ,hh-.55!!Z/((L,B,BBo 4^__e  !5!56C8op p >GGLLh6T6TU % 5"*. " LLr sx  $  >@ / ?@ ''789 )(3B-8^_` -l^<= ():(;<=>> %    G Vefrestui !# -><.PX@Y Z WW^^,=>N ,,.((%}}.B%-GN68r{{dG$)1):G&IIK ++-''$(#Y35BKK4 YZdYeewxyFyFxGGLMUM\M\M^MhMhMjLkkqrs Bahauau7CWCWX\Y\C]|BCCCFGH#<''?:NN%jkujvwa$bcKKM'$' R''G,@,@,K,KL,Yq'.';';'C'CLRT'U #)#3#3L4G4G4P#Q#X#XY`#a)-H)=%3%7%7 a%H &.oo&7&A&A&Cj&P ',"NN.LMWLXXghstwgxxz,{|KKM"/,/)efijufvewx[\_`cfq`q\r[ssp(q#  &abmnqarsMNYZ\N\]`MaaY%Z[ lmwlxyWXY'6$  \]g\hijc KK"WX_XeXeWffwyCxDDE!FGKK"3GNN3C DEKK"5hsm_Dj klKK"27==/ BC ..***KK"qsKK"IKKK"9'--H]^h]i jkKK/'..1A BCKK#QS(/';';$',<,G,G ,U*^_i^jjf(gh!*:*B*Byk$JK &TU^T_$`a &6wi$@A,4OO,=,G,G,I)&.oo&7&A&A&C  &^` &={7==?Y=[[pq{p|$}~ &J;-$XY &OPY{Zghqgr$st &aRbuvywybzX^b_%`a &MNaMb$cd*bdopwp}p}d~b@(AB*TVabiboboVpTrrZ([\,?&7&7#&=&N $zz.9H#)#3#3HOOG4L#M#T#TU\#]L-7 ~+FG( IIKKK"^_p^q rsKK"ac$//111 $)%rsztAtAsBBx$y)-h`'+O++0D0D0O0OP\0];+2+?+?+G+G VX+YL'-'7'7 8K8KG8T'U'\'\]d'eH-1ZZ-AN.<.@.@AR.SO)7););L!)LJ)7););L*WZJZ)[J+3??+<+F+F+HL+7*CK0:\0I-_ilm_m(*C*CJ*O*Y*Y*[tJK*2//*;*E*E*GK"KK*`b"KK*A'--Pefpeq(rs"KK*L[M(Z["KK*OP[}\ijtiuuv(wx"KK*N{[^N__noz{}o}BoCCO)PQ"KK*[\mnq[rr)AB"KK*eNfuvywyfzTZf[)\]"KK*QRaQb(cd#2 &2EFPEQ0R!S&303,]'"!" ,j8 &1klvkwxGHSTWGXXWX[\mXnorWssK0L!M7; 4 " &303,r'"!" +S0 &1|~H}IIKLWX[K\\klwxzlz{~kK0L!M7; 4 " &303,r'"!" 1",(+$D ++(+$D !..*** -"#&y>#7#7#9 &KM &A#h-PmBCKLPQQnvwyxynzW_n``a%bc &a{JbqrusubvPVbW%XY &MoM^$_` &J;WZJ[[uwBCEwEFIvJJV%WX*0..Ya*b$b  &TVN &}}.B%-GN68r{{dG$+/G()1):G&IIK!++---$(#Y35BKK4A ). (!NN%|~I}J$KL "34 Z)$q*EFPEQQcdnco(pqqq2+$! %J! :% 'bdopwp}p}d~cAARS]R^^abqar&s~B C42!,LL#ijtiuuwyCxD"EF+/G(KKMKK#`ak`l!mn$//111 #JILL#QRYR_R_Q``bcmbn!oz~L$y'88GyGX'?ST '3r'9 %1R%7 &>+b014/9l% r@Q?RRZ,[ /9l$,? )A-+7.(AI+7.(AI&qr{q||`$a+(+#+ ($'!I#j/IZ[S,R -"!("LL+cdpcq)r~BLC"/,/(Y#$+%c$#"$' O *3//*; 'NP 's1vhG       %__. F  TU_T``bclbmny} ~:9+F    sCAU2F AS0% &=>A2AU23C0AQ>$DA@;AAQ>BAB=AACAB=!BAA<@A@@AQ>@AA@1AAA AQ>AAAAAQ>AAB=AAA"AAB=A%AA0A(AA-A*AA0A0 AB/A91AB*B*AB/B/AB=B2AB5B5AB:B7AB=B= AH'CA AH"DAD,D%AD(D&AD,D+AH"D,AD0D.C4AH"H"AH'H'AQ>H*AI(H<'AI#I#AI(I(API.AI1I1 AP I;CAPMAM.M'AM*M(AM.M-APM.AM2M0)APNAP NAPNAU2NA%APPAP P APPAPPAQ;P%AP?P8AP;P9AP?P>AQ6P?AQQ5AQ6Q6AQ;Q;AQ>Q>AS-RAR+R$AR'R%AR+R*AS(R+AR/R-;AS(S(AS-S-AS0S0AU/TA(AU*U*AU/U/AU2cfK|jtjtj|k(tj|jk(j }|s t ddt|d{|jrqddl }ddl m }|}|jj|j|jdz}|jj|r |j!||j#||j%d d d S7#Y,xYww) u%Удалить MTProto аккаунтrTrUr;)rRNrr]rdTu#MTProto аккаунт удален)rfrg)rFr rGr&r'rVrrrrrr^rr}rrrdeleterJ)rRr7r8rLrr^r session_files r#delete_mtproto_accountrshh-.55!!Z/((L,B,BB eg 4^__ : 6660>ww||H$B$BGDXDX[eDef 77>>, '  ,'IIgIIK(M NN#7 s+A>D1D(A/D11D*'D1*D.,D1)3__doc__fastapirrrsqlalchemy.ormr sqlalchemyrpydanticrr loggingapp.db.sessionr app.db.modelsr r app.api.depsr rrapp.services.telegram_mtprotorrrrrrrB ImportError getLoggerrrCrouterrr%r1r3postrMrlistrQrrWputrZrrrr!r"r#rs65"!6).T    8 $ 9  9 i 1BC!!12&// // /D/d 5F0GH !12&/   I  ,=NO!!12&/ P$ ,=NO!!12&/ && &&  &P&R 23$( !12&/ @ @ D @ @   @ 4@ F/0!!12&/!O!O!O !O1!OYsGG  G