NMAiH ddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddlZddl Z ddl Z ddl Z ddlZddlmZmZddlmZddlmZmZddlZddlmZmZmZmZddlmZddlZddlZddl Z ddl!m"Z"ddl#m$Z$dd l%m&Z&m'Z'dd l(m)Z)dd l*m+Z+dd l,m-Z-dd l.Tddl/m0Z1ddl2Z,ddl3Z3ddl4m5Z5ddl m6Z6ddl7m8Z8e3j9dZ:Gdde;Z;dZ<Gdde=Z>Gdde)Z?e;e@deAjBZCe?eCeC_DdeC_EdeC_FgeC_GdeC_HdeCjAd<ieC_IdeC_JieC_KdeC_LdeC_MdeC_NejOeC_PieC_QeAjReC_SddlTmUZUmVZVddlWmXZXddlYZYd eZfd!Z[ieC_\e[eC_[da]d"Z^dd$Z_Gd%d&Z`e`ZaGd'd(ZbebZceceC_ce>Zddd)lemfZfd*ef_gGd+d,ZhehZWejijd-rdd.lkmlZleld/ZmeXeAjn0ZoeXeAjn0ZpejqreAjBd1zrVeseAjBd1z5ZtetuveA_wdddn #1swxYwYeaeC_adeC_xdeC_yeCze{d2Z|eC}e{e|eeAjBd3z Z~eeAjBd4z Zdd5lmZe~rr'eje~eC_err'ejeeC_gd6eC_d7ZEd8Zd9Zd:Zd;ZFdeC_deC_deC_d<Zd=Zd>ZeeEee_EeeEee_eeee_eeee_eeee_eeee_eeee_eeFee_Fd?Zeeee_d@Zeeee_ddCZddDZdddEdFZdGZeCjdHZddIZddJZdKZddLZdMZdNZddOZddPZddQZdRZddSZdTZdUZdVZeCjdWZdXZdYZdZZeCjdd[Zdd\Zdd]Zd^dd_gd`daZ ddbZdcZddZdeZdfZdgZdhZddiZddjZdkZddleZfdmZddleZfdnZddleZfdoZddleZfdpZddleZfdqZddleZfdrZddleZfdsZddleZfdtZdueje j dve j fdwZdxe j dve j fdyZGdzd{Zd|Zd}Zdd~ZddZdZdZdZdveZfdZdeZdefdZieC_ieC_ieC_ieC_ieC_ieC_dZdadaddZdZddZdZddZddZdS)N) OrderedDict defaultdict)Path)OptionalTuple)urlparseparse_qs urlencodequote) safe_join)SHA256) PKCS1_v1_5)Responseflash)DefaultJSONProvider) HTTPExceptionfields)*)base) relativedelta) timedeltastr_to_timedeltaz^.*\.(png|jpeg|ico)|^(/plugins/|/sso/|/drawio/|/pub/|/docs/|/share/|/files/|/tinymce/|/app/assets/|/socket.io/).*|^.*/forms/CmfForm:.*|^.*(styles|vendor|runtime|polyfills|main).*\.js$|/styles.*\.css$c$eZdZfdZdZxZS)Flaskc:tj|i|dSN)super__init__)selfargskwargs __class__s ./cmf/app.pyr zFlask.__init__0s%$)&)))))c fd}|S)Ncdd}|j}|dd}|dkr d|zz}n}| |dz|jz}j|||fit ||S)Nendpoint.index/)pop __module__split__name__ add_url_ruleprint)fr) module_path module_nameurloptionsruler!s r% decoratorzFlask.route..decorator4s{{:t44H,K%++C004Kg%%K'$.&,qz9 D c8Q : :' : : : (OOOHr&)r!r9r8r:s``` r%routez Flask.route3s0       r&)r1r/ __qualname__r r< __classcell__)r$s@r%rr/sG*****r&rcr|r4tjddd|DdSdS)N%s c34K|]}t|VdSrstr).0args r% zprint_debug..Gs(%?%?3c#hh%?%?%?%?%?%?r&)loggingdebugjoin)condr"_kwargss r% print_debugrMEsJ B dCHH%?%?$%?%?%?@@AAAAABBr&c,eZdZdZdZdZdZdZdZdZ dZ d8d9dZ dZ dZ dZdZd:d Zd Zd Zd Zd ZededefdZedefdZed;dZdZdZdZdZdZdZdZ d8dZ!dZ"dZ#dZ$d:dZ%dCmfCacheNFreturnct|_t|_||_||_i|_|jr6|jdd|jddd|_dS)Nstat_hitr stat_missF)dict cache_objcache_invalidateredis_dbmemorytexcom_growcache_hack_cacheincrbyjob_daemon_mode)r!rWrXs r%r zCmfCache.__init__Tsw $   +-( = 1 M Q / / / M a 0 0 0$r&cttjp|jdtj|jr|jn&t|_t|_ |j dt d|j dt ddidS)NzCmfCache.flushdb!!!filezCmfCache:flushdbCmfCache:inmemory_delkeysALL) rMconfigDEBUGsysstderrrWflushdbrTrUrVpublishjsondumpsr!s r%rfzCmfCache.flushdb`sFL.DJ0ECJWWWW = + M ! ! # # # #!VVDN$(FFD ! 0$**T2B2BCCC 5tzz65/7R7RSSSSSr&cttjp|jdtjt t }|j}|j ddD]}t|jd|dtj|dd  }|j |}|`tj |}|d }|d |||<|||||d S) u)Инвалидируем весь jscachezCmfCache.flush_jscache!!!r]z obj:jshash:*countz"CmfCache.flush_jscache invalidate z!!!Ncurrent_person_idjsver)rMrbrcrdrerrTrWpipeline scan_iterdecodegetpickleloadsdeleteexecuteemit)r!emit_msgpipekeyjshashjsresjspersons r% flush_jscachezCmfCache.flush_jscachejs+FL.DJ0KRUR\]]]]t$$}%%''=**>*FF  C  $Q$Q$Q$QX[Xb c c c cW^^%%FM%%c**E}L''E01H).wHX v & KK      (r&cttjp|jdtjd}|j}|jddD]2}|dr|dz }| |3| ttjp|jd |d tjd S) u+Инвалидируем весь obj cachezCmfCache.flush_all_obj!!!r]rzobj:*rlrms obj:jshashzCmfCache.flush_all_obj: z recordsN) rMrbrcrdrerWrrrs startswithrxry)r!rnr|r}s r% flush_all_objzCmfCache.flush_all_obj|s FL.DJ0KRUR\]]]]}%%''=**7$*??  C~~m,,  QJE KK     FL.DJ0Z50Z0Z0Zadakllllllr&c ddl ddl}ddl ddlm ddlm |} fd tjr ttj j tjdz ddddd vr^|j}|d krIt$jr=t$jt$jkr#tj j S|D]}|d z |z}d |vr|d zt|d z}t+|D]#\}}|d kr |d z|zdz |z}$|jrwd|ddzdz |z}|dd}|dd}n?|d |z}t3|jd||S)Nr)timezone) ImmutableDictc t|}t|tjjr'|jr|j}t|}n d}t}d}|tttfvr|tkr|dddkrv j |}| j }|dd}|}td|n#t $r }Yd}~nd}~wwxYwt|}n|t"kr|D]}||zdz}n|t$ks|kr9|D]#\}}||z}|r|d |z}|dz}$n|d }n|t(urt|}nlt+|d rt|j}nGd |jzd z t3j|z}|S) Nz...r20)second microsecondz !!!!! Date:,:Noneidz todo2:obj:)type issubclasscmfrCmfType is_definedvaluerDintfloatparserparse astimezoneutcreplacer3 ExceptionlistrTitemsboolhasattrrr1md5rvri hexdigest) valtresval1evkr_all2strdateutilhashlibrs r%rzCmfCache.hash.._all2strs5S A!SZ/00 >)CS AACACS#u%%%88AaCD 0 0&o33C88"oohl;;"ll!lCC!}c2222%#hhd22A +c1CC2da=00IIKK((DAq'C(!$iii((1++5!Ci ( d#hh 3%%gcf++CC&3c9GKK UXHYHY>F S...Av||~~.. 4 4HCd{{C# #hhsmm3AA : C!AcE("W, AHHJJ0G0G0Q0Q0S0SSA $$$A #s##AA w{{188::66@@BBBADJ 3Q777r&c|t}|s|Stt|j}t}|jD]Z}|j|d}|s!|dr| |ddn| |t|tjj r0t||jd}|r| ||t|tjjtjjfrrt||jd}|r|D]}| |||D])} d|jd| j} | | *\| |jdzdt'|z|S)N_idr+)rref_rrAr)setgetattrmodels class_name__dict__r`rruendswithaddrrCmfRelationBasesimple_objects_id_recursive CmfM2MBaseCmfBackrefBaserelated_modelsrrJr) r!objrmodelfields_str_set field_name field_cls field_valuerel_obj rel_modelrefs r%rz$CmfCache.simple_objects_id_recursives ;%%C J//,++-- ! !J ((T::I ""5)) /"":crc?3333"":...)SZ%?@@ !%c9+?FF K44[c4JJJI (=sz?X'YZZ !%c9+?FF K#.KK88c8JJJJ"+!9!9!;!;!!I@@@)*>@@CGGCLLLL  sxx~(>(>???@@@ r&c|sgSg}t}|dD]M}|jdr#||jddn||jt |t jjr-| | |j t |t jj t jj frw|j r2|j D]*}| | |+|D])}d|jd|j}||*O||jj dzd t%|zt't|}|S) u Собираем ид связанных обьектов 2 уровня для настройки инвалидации :param obj: :return: TrrNr+rrrAr)rvaluesrrr isinstancerrrextendobjects_id_recursiverrrrrappendrJrr)r!rrrfieldrrrs r%rzCmfCache.objects_id_recursives  IZZ4Z00 $ $E((// 5""5#3CRC#89999""5#3444%!;<< C 444U[AABBB%#*"79R!STT $;G#(;GG 4#<#@@CJJsOOOO 36<#%1G1G(H(HHIII3s88nn r&ct|tjkrtdddS|jr |jd||dS|jr ||j|<dSdS)NuUDEV: Слишком большой объект для кэширования — keyT) debug_onlyFobj:)lenrbCACHE_MAX_OBJ_SIZE cmf_alertrWrrXrU)r!r}str_vals r% _obj_dict_setzCmfCache._obj_dict_sets w<<&3 3 3 n{ A A A A5 =  M  lSllG 4 4 44 [ ")DN3 4  r&ct}|D]}|d||jr$|jj|t |krdSdS|jr$|D]}|j|sdS dSdS)NrTF)rrrWexistsrrXrUru)r!r`hkeysr}s r%_obj_dict_existszCmfCache._obj_dict_exists1s $ $C IIlSll # # # # = #t}#U+s4yy88tu [  ! !~))#..! 55!44r&c|jrV|jd|}||jdn|jd|S|jr|j|SdS)NrrRrS)rWrurZrXrU)r!r}rs r% _obj_dict_getzCmfCache._obj_dict_getCs = -##L3LL11C $$Z0000 $$[111J [ >%%c** *4r&r~ inv_payloadc|d|S)N::r;)r~rs r%%_jshash_invalidate_confirm_member_keyz.CmfCache._jshash_invalidate_confirm_member_keyPs))K)))r& member_keyc0|ddS)Nrr)maxsplitr0)rs r%+_jshash_invalidate_confirm_member_key_splitz4CmfCache._jshash_invalidate_confirm_member_key_splitTsq111r&cJ|r|n|dd}d|S)Nrzjscache-invalidate-confirm-set:r)cache_idr~set_keys r%"_jshash_invalidate_confirm_set_keyz+CmfCache._jshash_invalidate_confirm_set_keyXs1'A((FLL,=,=b,A::::r&ctt}|D]\}}td||d|g|D]]\}}|drC||||||^|jr-|D]\}}|jj |g|RdSdS)Nz invalidate-)room event_personsjshash:r~) rrrcmf_emit_eventrrrrrWsadd) r!msgs confirmations person_idinv_dictr~rr confirm_lists r%rzz CmfCache.emit_s4#D)) #'::<< Y Y Ix 444hTZcYd e e e e'/~~'7'7 Y Y# $$Y//Y!$"I"IQW"I"X"XY``BB6;WWYYY Y = ;)6)<)<)>)> ; ;%" "7:\::::: ; ; ; ;r&cJ|jstd|jr|r|dd}||}t}|D]7}|||d|d8|jj|g|RdSdSdS)Nu$ERROR! Недоступен redis_dbrr r)rWr3rrrrsrem)r! confirm_dict sample_jshash key_cache_idrconfirms r%jshash_invalidate_confirmz"CmfCache.jshash_invalidate_confirmns} : 8 9 9 9 = <\ <)OA.MBB-BXXL66L' h h##D$N$NwWXz[bcd[e$f$fgggg DM | ;l ; ; ; ; ; ; < < < z;CmfCache.jshash_invalidate_confirm_list..s????@@QQ???r&)rinvalidated_keys CMF_CACHE_do_invalidate_defferrWrsmembers)r!rrs` r%jshash_invalidate_confirm_listz'CmfCache.jshash_invalidate_confirm_list|s  .  + + - - - = ?==hGGG????"m44W==??? ? ? ?r&c |sdS|jr|jjd|Dt|||i}|D]}|jrd|vrt d|t|jd||jd|dx}rt|jd||jrt d ||j }|D]X} | d | d |d | d Y| } t|| d dd D]\} } | d } | tj| } | rr| d} | |vrt!|| <|dkr/|r-dt%d|D} nd} | dd|d|d| }||| | <|jd|dx}t'j}||t'j}||z dkr#t*d||z ddSdS|jr|D]}||jvr|j|=dSdS)Ncg|]}d|S)rr;rEr}s r%rz+CmfCache._obj_dict_mdel..s"@"@"@C<#<<"@"@"@r&rnz#DEBUG_CACHE JSHASH: try invalidate z*DEBUG_CACHE JSHASH: try invalidate:jshash:invalidate:jshash:drmz*DEBUG_CACHE JSHASH: got invalidate:jshash:z#DEBUG_CACHE JSHASH: got invalidate rutf-8rrrpupdatercg|]}|dv| S)) cache_fieldscmf_modified_at cmf_viewed_atcmf_modified_by_idr;rErs r%rz+CmfCache._obj_dict_mdel..s0,@,@,@!+,4~+~+~-.+~+~+~r&ONLYFORUPDATESrq?z_obj_dict_mdel emit got sec)rWrxr inmemory_delprofiler_invalidatercr rMspoprrrurtryziprvrwrTrJrtimerzrrIrXrU)r!r`obj_changed_fieldsobj_idactionr{r}invjsr|r~ jshash_listrrchanged_fieldsr emit_startemit_ends r%_obj_dict_mdelzCmfCache._obj_dict_mdels  F =P  DM "@"@4"@"@"@ A A  " "4 ( ( (  $ $T * * *H7 E7 E:P'"4"4"#N#N#NOOODJ(ZUX(Z(Z[[[ $}112Ls2L2LTW1XXXe1E ,^Y\,^,^___zT&'RS'R'RSSS=1133D"'EE!@ g(>(>!@!@AAA $C6==+A+A$C$CDDDD"&,,..K),UK14E)F)F'E'E !'w!7!7&!=$ & U 3 3 E',-@'AH'x7759VV 2 &116H115$*,@,@7I,@,@,@%A%A2"2" 2B-27^*c*cv*c*c*c*cSa*c*cK9DHX.v6c $}112Ls2L2LTW1XXXe1EtJ IIh   y{{H*$s**M8j3HMMMNNNNN+* [  , ,$.((s+ , , Fr&c|jrs|j5}|D]\}}|jd|g|R|ddddS#1swxYwYdS|jrG|D]B}||jvr'|j|||2|||j|<CdSdSN invalidate:)rWrrrr ryrXrVr)r!rr|r}rs r%_invalidate_dict_msetzCmfCache._invalidate_dict_msetsB = '')) T#+>>#3#3<.s$;;; 7++;;;r&)rWr!rXrVru)r!namers r%_invalidate_dict_getzCmfCache._invalidate_dict_getsq = -(()=t)=)=>>C <;;s;;;;J [ (,,T22 2 Fr&c|jrz|j5}|D]\}}|r|jjd|g|R|ddddS#1swxYwYdS|jr^|D]G\}}|D]?}||j|gvr |j||@HdSdSrB) rWrrrrryrXrVruremove)r!rr|rHrkey_listr}s r%_invalidate_dict_mdelzCmfCache._invalidate_dict_mdelsm = '')) T$,NN$4$4JJLD&J* *+?+?+?I&IIII                     [ "*.."2"2 @ @h#@@Cd377bAAAA-d3::3???@ @ @ FsAA55A9<A9c L tjdrdt_dSt jr |s jrdStjvr ddSt |r>dt_tj dt|dS|}tj|tj}||krFdt_tj dtjd|dSit$jj|}fdfd } |rzt-|t.set1|d drT| |d } t3|jtjvr&t9d |jd tjdSn|r:t-|t.r%t1|dd drd} | |n\|Dd} t;|t<kr)t;|t>krt:t2kr n|sd} d}ntAdd} |rN|drEtj d|| d krM|j!|dvr>|dD]5} | |j!d|j!dfvrd} |jvrtEdn6| sg} dg|j#D]}||dvr|d|} | sdg} t/| tj$d<| D]u}|dvrd}|dD]d} | %d d}||krd!| d!|d"Ad#|d$| d#|d$|d"ev|dD]}d!|d"|r|dsd!|d"j r D]}tj d%|d&tMj'|}(|s dt_)|r)t*|tW|d'tvrztj,rntj d(dtj,j rt[d(tj,.d)tj,fi.dS)*NNO_CACHETrrz%DEBUG_CACHE ADD SKIP CACHE LOCKED_BY z#DEBUG_CACHE ADD SKIP too old trans rAc|d\}}}|vrt|<|r!|d|n|dS)NrA) partitionrr)bind_and_fieldsbindrrrr}s r%bind_addzCmfCache.add..bind_add)s.77<.bind_add_recursive5s#t$$ # 7C  # #dgsz'9::G33D99CCt??EEFFC##DHTNNNN#  # #r&rrzSkip add to cache z g.skipcache_select_for_update: rrcustomemptyEmptyuGНевозможный объект для хранения в кешеFrzDEBUG_CACHE WHERE: rz.idz.codezDEV: Obj in not in inv_dictparentcache_clustersScopeAll)NullNULLnullrnoneNrr*where_ScopeAll__insdelwhere_rzDEBUG_CACHE BIND: z = r~#DEBUG_CACHE JSHASH: add invalidate r )/osenvironrurno_jscache_forcerbJOB_DAEMON_DISABLE_CACHEr[r$profiler_redis_invalidated_keys_skiprcache_is_lockedrMrccache_locked_byget_last_invalidate cache_lockscache_transaction_startrutilcmfutilget_model_by_namerrrrDrskipcache_select_for_updater3rrrrrrcache_cluster_fields profiler_datar0rvrircache_store_error inmemory_addrr~r rD)r!r}robj_type query_paramscache_inmemorylirq obj_modelrYobj_casewhere_pkrscopesc_fieldscope model_namebindidstr_objrUrs`` @@r%rz CmfCache.add s :>>* % % !%A 4  * > dFZ 4 !$ $ $  5 55 5 A A A4  $ $X . . !%A   $qILeLefnLoLo$q$q r r r4 % %h / /"#-"3"3Ha>W"X"X "R ' '!%A   %K!Jc%K%Kfjf~f~@HgIgI%K%K L L L4H$66x@@        # # # # # #, & gz#t,,& gdD1I1I& g  s # # #H36{{a;;;r36rrSTSprrsss< gZT** gws1vtT/J/J gH  s # # # # _HCyyCDII$6$643;;  gH CCeff f  F DL2F D  $9< H H H5  <;Q)Q)Q".x"8J!&<&<&<>V>V>V%WWW#'!f;h66%&CDDD X4 D !)J9+IJIIG,/?"@@@!-.>!?!H*(\F48LL 01#KKE NNN &&28&< K K &0%5%5c%:%:1%= #z11$H%Cz%C%CDDD$H%Jz%J%J%JKKKK$H%Be%B%Bj%B%BCCC$H%Ie%I%Ij%I%I%IJJJJ K#/x"8DDJHBzBBBCCCC :<#9 : H8x888 9 9 9 : O" O ODJ(MV(M(M(M(MNNNN,s##!!#w// '"&A   ;  " "3S\\ : : : q==QX=  $Z#$Z$ZPQPX$Z$Z [ [ [z VJSJJAHUUU  & &#!('E F F F ""8,,,,,r&c dtvrtt_n#t$r }Yd}~dSd}~wwxYwdtjvrt |tjd<n'tjdxxt |z cc<t jrDdtjvrgtjd<tjd|dSdS)NrwrVcache_invalidate_keys)rrTrwrrrODEBUG_PROFILE_VERBOSEr)r!r`rs r%r4zCmfCache.profiler_invalidates a''"&&&    FFFFF  Q_ 4 425d))AO. / / O. / / /3t99 < / / /  ) B&ao==;= 78 O3 4 ; ;D A A A A A  B B !$ 99c dtvrtt_n#t$r }Yd}~dSd}~wwxYwdtjvrdtjd<ntjdxxdz cc<dtjvrdtjd<tjrDdtjvrgtjd<tjd|dSdS)Nrwredis_cache_hitrredis_cache_missrredis_cache_hit_keysrrTrwrrOrrr!r}rs r%profiler_redis_data_hitz CmfCache.profiler_redis_data_hits a''"&&&    FFFFF  AO 3 312AO- . . O- . . .! 3 . . . Q_ 4 423AO. /  ) @%Q_<<:< 67 O2 3 : :3 ? ? ? ? ?  @ @rc dtvrtt_n#t$r }Yd}~dSd}~wwxYwdtjvrdtjd<ntjdxxdz cc<dtjvrdtjd<|tjd<tjrDdtjvrgtjd<tjd|dSdS)Nrwrrrrredis_cache_miss_lastredis_cache_miss_keysrrs r%profiler_redis_data_missz!CmfCache.profiler_redis_data_misss a''"&&&    FFFFF  Q_ 4 423AO. / / O. / / /1 4 / / / AO 3 312AO- .36/0  ) A&ao==;= 78 O3 4 ; ;C @ @ @ @ @  A Arc dtvrtt_n#t$r }Yd}~dSd}~wwxYwd|}|tjvrdtj|<dStj|xxdz cc<dS)Nrwinvalidated_keys_skip_r)rrTrwr)r!rrrs r%rlz-CmfCache.profiler_redis_invalidated_keys_skips a''"&&&    FFFFF  +T + + AO # #!"AOA    OA   ! #     rctjds tjrdS|tjvr|ddSd}|rt|}nd}t|j d|dur>* % % ); 4 !$ $ $  5 55 5 A A A4  ((--CCCDJ((( #::!M$$S))C $l3''s88 c>>1}}}**OcOOah[+IJJJDJ(eUX(e(e[\[c(e(efff:Z"#N#N#NPQPXYYY  $=$=$= > > >  $6 < < <  ;^ ;,,S111&&sC:::J %%c***DJ :S : :;;;tr&cdSNrrMrcrrWrur!rs r%rozCmfCache.get_last_invalidateGqr&clt|jd|t_dS)Nz)DEBUG_CACHE TRANS cache_transaction_start)rMrc gen_time_usrrqrjs r%rqz CmfCache.cache_transaction_startLs/DJ KLLL$($4$4$6$6!!!r&cttjtjjdS)Nz%Y%m%d%H%M%S%f)rrrrrstrftimerjs r%rzCmfCache.gen_time_usPs68$(():)>??HHIYZZ[[[r&cdSr) rMrcrmrrWrrrprq)r!rls r% cache_lockzCmfCache.cache_lockSr&cdSr) rrprrnrqrMrcrWr)r!rtr_startlock_trs r% cache_unlockzCmfCache.cache_unlockdrr&cdSrrrs r%rnzCmfCache.cache_locked_bytrr&cdSNF) rnrrprurqrMrcrWr)r!r_cache_locked_byrqs r%rmzCmfCache.cache_is_lockedysur&ctj}tj}tj}tj}t } ||j}|D]} | |vrt || || <n!|| || || D]J} d| vr/| | dd5| | K|| | |d| dD|| dtj} | |z dkr#t d| |z d dSdS) NrArcg|]}|Sr;r;r/s r%rz+CmfCache._do_invalidate..s"H"H"H1"H"H"Hr&T) is_changed)r9r8r:inv_listr1zPROF _do_invalidate got r2) r7rrrrrrr)rr0rr`rI) r!rrr:r9st glob_inv_dict glob_inv_listrrrinv_valends r%_do_invalidatezCmfCache._do_invalidates Y[[  -55 >fV * *A %%#&x{#3#3 a  a '' 444#A; * *'>>LLs!3!3A!67777LL))))  * )))"H"Hchh$h.G.G"H"H"H      ikk 8c>> GGr&ctddsdStj}tj}tj}|D]2}||d|d|d|d3tj}||tj}||z dkrtd||z dtd ||z d ttj td ||z d t|tt_ it_gt_dS) Nrrr8r9r:r1z_do_invalidate_deffer got r2z)_do_invalidate_deffer _obj_dict_mdel got zsec len=z0_do_invalidate_deffer _invalidate_dict_mdel got ) rrur7rrr@rMrIrrr)r!rrrrst_invalidate_dict_mdelrs r%r zCmfCache._do_invalidate_deffersuu'..  F Y[[  % ~ ~H    4h?S6TV^_gVhjrs{j| } } } }"&)++ ""=111ikk 8c>> GG>r>>> ? ? ? GG@WZ\@\fijkj|f}f} A A A GGCsMdGdCCnqroAoACC D D D UU  r&r)c tjdrdS||dh}|sdS||t |jd|d|dt |t}t}t}i}i}t |dkr|D]} |j d| dd } | D]X} |j | } | r:| D]7} | d d } | | | || <8Y| | n{td t!|j dd } td t | t#jdd|zdz}t#jd}td| D]} | }||s,|j | } | rS| D]P} | d d } | | ||d || <Q| | |D]}|j d|}||} |r|D]}| d d }| ||jd|}|sdt/j|}|d}||vrt3||<d}|dd|d| d|}||||<Ȑg|d|Dd|Dd|D}|r3td|d|d||jj|n!td|d|d||dS) NrOrz!DEBUG_CACHE start invalidate_ids rAxz invalidate:*rrl)matchrn rzscan get all keysz scan over z.*(rz).*zK[A-Za-z]+:[0-9a-z-]{8}-[0-9a-z-]{4}-[0-9a-z-]{4}-[0-9a-z-]{4}-[0-9a-z-]{12}zre compile doner&rrpr0rqrc3DK|]}d|VdSrNrGrE query_keys r%rGz*CmfCache.invalidate_ids.."s7 F Fi)Y%%'')) F F F F F Fr&c3DK|]}d|VdS)r&NrGrs r%rGz*CmfCache.invalidate_ids..#s7 T TI79#3#3#5#577 T T T T T Tr&c3DK|]}d|VdSrrG)rEr~s r%rGz*CmfCache.invalidate_ids..$s3 > >6&V]]__&& > > > > > >r&zinvalidate_ids(, ): z): no keys found.)rhrirurrMrcrrrWrsr!r0rr)rrIrrecompilerJrtrfindallrvrwrTrxrz)r!ridsr:invalidate_keys query_keysjshashesr{obj_id_by_query_keyid_r`r} inv_members inv_memberid_retuuid_re key_decodedrquery_jshashesr~rrr=r keys_lists r%invalidate_idszCmfCache.invalidate_idss :>>* % %  F ; ###$C  F  ###DJ dF d dZ d dZ]^aZbZb d deee%%UU 55 & s88s?? - - }..5JC5J5J5JRV.WWBBC"&-"8"8"="=K"B*5BBJ)3)9)9$)?)?)BJ&NN:666>A/ ;;&&t,,,, - GG( ) ) ) //oT/RRSSD GG,T,, - - -JuSXXc]]25899Ez"oppH GG& ' ' ' ) )!jjll {{;//"m44S99 [&1[[ %/%5%5d%;%;A%> "z222:B:J:J;:W:WXY:Z+J77##C((((# F FI!]334]IYIYI[I[4]4]^^N%)))44C F,FFF#\\$//2FLL((( M--.FV]]__.F.FGGE ! "L//E$%89Hx//-1VV*&6N%*7^"X"Xv"X"X"X"X"X"XK:EHX&v}}77  F F: F F F U T T T T ? >X > > >   L GGGjGGCGGIGG H H H DM ) , , , GGJjJJCJJJ K K K (r&cBd fd }tjdrdS|sdS|t jdd|i|D]9}|d|d|d||d d| :dS) Nrc~|}|r$||<tjdd||dSdS)NDEBUG_CACHE INVAL: rA)rIrMrc)invalrIinvdr:rr!s r% _check_invalz8CmfCache.invalidate_ids_as_wrapper.._check_inval.sd,,U33D W"&DJ(Uf(U(Uu(Ue(U(UVVVVV W Wr&rODEBUG_CACHE start invalidate rArrref=obj.id=)r9)r)rhrirurrMrcr)r!rrr:rrrs` ` @r%invalidate_ids_as_wrapperz"CmfCache.invalidate_ids_as_wrapper-s W W W W W W W W :>>* % %  F  F  ###DJ U U U U UVVV D DC L222j22F ; ; ; Li ( ( (   hs  C C C C D Dr&c tdd|d|d|tj}d7fd }ddlm}t jd rdS|j tj d d |j |j }ij rddl } | |j d kr||jd dvr|d|jd|j d|st#d||jd|g|d|j dd|d|jd|j ddtj} |tj} | |z dkr$tdd| |z ddSt'} |dD]\} }d}|j |vrt+|t,jjrt3|d r|jjr|jsd!vr%|r#|jr|d|jd|j dd"vro|jrh|j|jkrX|d|jjd|j d#|d|jjd|j d$| | t+|t,jj r"d"vr|jr| | 1|jr6t+|t,jj!r| | n|jrW|j|jkrG| | | "d%r| | dd&tG| dkr'd"kr!tj d'd(|jdSd)g}|j$D]}||tKtM|d*dr|'|d!vr||jdd"kr||jd| d"krB| D]>} d+g|j$D]}t3||stQtM||t,jj r&||D]}|d|jd|d,| dltQtM||t,jjr|d||d%zd|d,| dtQtM||t,jj)r|d||d|d,| d t#d-d.|d|d,| d@d/}d+g|j$D]=}t3||r+||jr||j||jkrd}>d!vs|r7t3|d r|jjr|jsd+g|j$D]}t3||stQtM||t,jj rf||D]}|d|jd|dd0||jr5||jr(||jD]}|d|jd|dd1tQtM||t,jjr[|d||d%zd|dd||jr0||jr#|d||jjd|dd29tQtM||t,jj)rX|d||d|dd||jr0||jr#|d||jjd|dd2t#d-d.t3|d r|jjr|js|d|dnktTj+r_d!vs|rYt3|d rI|jjs=|j,|jrt#d3tj-d4t\j/r1tj0d5ggztj0d5<tj} |tj} | |z dkr#td6| |z ddSdS)8NzRUN INVALIDATE: action=z obj=z item=z m2m_field_name=rc  |}g}|rF|rt|}g}|D]}d|vr|||d^}}}|rPtd|d|t d|d|d|d||t|d} || zr||| |<n| |<t jd d||i} || |<tj r5tj dg| gztj d<dSdSdS) NrAz=cmfCache.invalidate(): ValueError: too many values to unpack(rTabortrrr) rIrrr0rrIrrMrcrOrrwru)rrI change_fieldsr invd_affectediri_fieldstail i_set_fieldstmpr:rr!s r%rz)CmfCache.invalidate.._check_invalPs,,U33DM V +$' $6$6M$&M!44a<<)00333$-.WWS\\*8d %GG$qdi$q$qno$q$qrrr%&zfk&z&zpq&z&ztx&z&zCGHHHH)00333$'*8>>#+>+>'?'? (<74)00333&3HUOO&*HUODJ(Uf(U(Uu(Ue(U(UVVV!E 1V./o.A.A&.L.LPSu.TAOF+++= V V:VVr&r)rrOrrA RelationCachezRelationCache.parent.id=)rrKrrruYDEV: FATAL в инвалидацию м2м поля не передали имя поляr)rrdrezwhere=rfr1zinvalidate (action=z) got zjsec. _check_inval {_check_inval_done - st}sec, _do_invalidate {_do_invalidate_done - _check_inval_done}secTr)r- cmf_viewed_by cmf_versionris_dummy)createrxr)zref_new=zref_old=rr+zDEBUG_CACHE ivalidate: z not fields_have_changes--logical_deleter]r*uОшибка конфигурации моделей: cache_cluseter_fields может быть только по m2m и relation полямrFz where_m2m=zwhere_m2m_old=z where_old=uDEV: в методе ux не загружается is_dummy, что приводит к лишним инвалидациям кластераrzinvalidate got rN)1rrIr7 collectionsrrhrirurrrMrcTRACEpdb set_trace parent_idrrrrrrrrrrrrroldnewrrrrrrvrr load_fieldsrCmfTUUIDrbRAISE_LAZYLOADload api_methodrOrrw)r!rr:rXm2m_field_namerrrrzr_check_inval_done_do_invalidate_donerrrno_caching_fieldscluster_load_fieldsr cc_field_name cc_clustercluster_field_is_changedrs` ` @r% invalidatezCmfCache.invalidateMs  M6MMSMMDMMNMMNNN Y[[# V# V# V# V# V# V# V# VJ ,+++++ :>>* % % 4 '''DJ Y Y Y Y YZZZ> : ( JJJ  >_ , , LCM+-G H H H ) ) ) L:::#.::F C C C! wuvvv LCFi?O P P P P LB3>BBBH M M M LC$'CCCNCCCX N N N!%    Xv 6 6 6"&)++ "R'#--WfWW!C!CFKKKh''E,<'eiAWAW L!G !G!Gs~!G!G SSS L!G !G!Gs~!G!G SSS!((444%!677 FxSSS T T T T T * )r&c|jD]\}}td||jD]\}}td|dS)NzDEBUG CmfCache.dumps)rUr3rVr)r!r}rs r%rizCmfCache.dumpsbsk / /HC (# . . . .-3355 / /HC (# . . . . / /r&c|dd}tjr|dd} tjj|}n#t$rYdSwxYwtj s2|j r|j tj vrn| |dS|j stdddS|tjvr||dStj|}||d}|dur|||S|||||S) Nr*rrr.SDEV: inmemory_get вызван для модели без флага cache_inmemoryTr)r0rOrcrrrrsrtKeyErrorrin_memory_cacher|rin_memory_cache_skip_modelsprofiler_inmemory_data_skiprr INMEM_CACHEprofiler_inmemory_data_missru move_to_endprofiler_inmemory_data_hit)clsr}rr model_cacherets r%rzCmfCache.inmemory_getqs|YYs^^A& > 2#))#..q1J H$66zBBEE   33   # E,<@],],]//444s#  ltx y y y y4 S_ , ,  + +C 0 0 03oj1 ooc3'' #::  + +C 0 0 0J  # #C ( ( (  * *3 / / /Js$A)) A76A7c |dkrt|tjjst j|rd|}nw|rut|t r`t|dtjjst j|dr!d|djdt|d}t|j d|d|dSt|j d|| d d}tj r| d d } tj j|}n#t $rYdSwxYwt"js |jsdS|jst)d d dS|jrd}|t*jvrt/t*j|<t*j|}||vr,|||krt1d|d|d||dS|||<t||kr3|d\} } t|j d| dSdS)Nirr[]u/DEV: skip inmemory_cache obj_size > 128000 — u байтzCmfCache:inmemory_add add key r*rrrTrzInmemory cache error! key:z try_add:z exists:F)lastz"CmfCache:inmemory_add evicted key )rrr BaseModel dataclasses is_dataclassrrrrMrcr0rOrrrsrtrrrr|rrrrr3popitem) rr}rrdetailrr LRU_LIMITr evicted_keyrs r%ryzCmfCache.inmemory_adds f  #sz344 > 8PQT8U8U >#c >C.. >A (<== >ALAYZ]^_Z`AaAa >=c!f/==#c((===  #pU]#p#phn#p#p q q q4 CIEEEFFFYYs^^A& > 2#))#..q1J H$66zBBEE    FF   )= 4#  ltx y y y y F   I S_ , ,*5--COJ 'oj1 +  33&&`3````kZ]N^``aaa F C {  i ' '(00e0<.handlers8 (TVZ [ [ [  " "4D " 9 9 9 9 9r&z&CmfCache:on_inmemory_del spawn handler)rMrOrcgeventspawn)datarLr1r`s @r%on_inmemory_delzCmfCache.on_inmemory_dels_  FF| : : : : : HN$MNNN Wr&c dtvrtt_n#t$r }Yd}~dSd}~wwxYwdtjvrdtjd<ntjdxxdz cc<dtjvrdtjd<tjrDdtjvrgtjd<tjd|dSdS)Nrwinmemory_cache_hitrinmemory_cache_missrinmemory_cache_hit_keysrrr}rs r%rz#CmfCache.profiler_inmemory_data_hits a''"&&&    FFFFF  q 6 645AO0 1 1 O0 1 1 1Q 6 1 1 1  7 756AO1 2  ) C(??=? 9: O5 6 = =c B B B B B  C Crc dtvrtt_n#t$r }Yd}~dSd}~wwxYwdtjvrdtjd<ntjdxxdz cc<tjrDdtjvrgtjd<tjd|dSdS)Nrwinmemory_cache_skiprinmemory_cache_skip_keysrr:s r%rz$CmfCache.profiler_inmemory_data_skips a''"&&&    FFFFF   7 756AO1 2 2 O1 2 2 2a 7 2 2 2  ) D)@@>@ :; O6 7 > >s C C C C C  D Drc dtvrtt_n#t$r }Yd}~dSd}~wwxYwdtjvrdtjd<ntjdxxdz cc<dtjvrdtjd<tjrDdtjvrgtjd<tjd|dSdS)Nrwr8rr7rinmemory_cache_miss_keysrr:s r%rz$CmfCache.profiler_inmemory_data_miss)s a''"&&&    FFFFF   7 756AO1 2 2 O1 2 2 2a 7 2 2 2 q 6 645AO0 1  ) D)@@>@ :; O6 7 > >s C C C C C  D DrrrPNrNNF)r))=r1r/r=rUrVrWrXrcrrPROCESS_EVICTED_FLUSHr rfrrrrrrrr staticmethodrDrrrrzrr"r@rDrIrMrr4rrrlrurorqrrrrnrmrr rrr ri classmethodrryr3on_server_eventr5rrrr;r&r%rOrOJs)IH F E! E! % % % % %TTT$ m m mQQQf!!!!F<&$   *c****\*2222\2;;;\; ; ; ; < < < ? ? ?SSSj       Q-Q-Q-Q-fBBB"@@@&AAA( $ $ $ $$$$$LRRR 777\\\***"CCC GGG   >>>>>2kkkkZDDD@STSTSTSTj///++[+\.W.W[.W`CCC[CB_4555  65\ CC[C&DD[D"DD[DDDr&rOceZdZdZdS)CustomJSONProviderc t|tjtjfr|j}t|t jst|t jr2|js|dzS|St|tj r|jSt|}t|S#t$r }Yd}~nd}~wwxYwtj||S)NZ)rr CmfDateTimerrrdatetzinfo isoformatriterr TypeErrorrdefault)r!riterablers r%rQzCustomJSONProvider.default@s "# 2FNCDD i#x011 !ZX]5S5S !z1==??S00}}&C00 !y CyyH>> !    DDDD #*4555s$A>CC C6C C(#C(N)r1r/r=rQr;r&r%rHrH?s#66666r&rH) static_folder root_pathTSEND_FILE_MAX_AGE_DEFAULTF)SocketIO Namespace)Client project_idct|}tj|}|s;tj|gd}|rd|_|tj|<|S)N)0ui_form_scheme logic_type logic_prefixcust_field_conf_schemedefault_gantt_task_typez1security_level_scheme.default_task_security_levelzcalendar.timezonetask_code_prefixtask_code_use_logic_type_prefix executors spectatorsactivityzactivity.prefix responsibleauto_alarm_datemain_gantt_projectadd_object_typedefault_agile_story_pointstask_allow_multiple_sprintssl_deadline_shiftsl_only_owner_approvesl_deny_no_approve)sl_allow_executor_change_nofatal_deadlinesl_task_need_approvesl_task_only_owner_closesl_readonly_closed_task.sl_deny_closing_task_before_closing_checklistsz cmf_owner_assistants.cmf_deletedz"cmf_owner_assistants.does_not_workzcmf_owner.cmf_deletedzcmf_owner.does_not_workzcmf_owner.user_localzdefault_list.plan_start_datezdefault_list.plan_end_datezdefault_list.ordernozdefault_list.perm_has_aclzdefault_list.sys_typezdefault_list.logic_prefixzdefault_list.affect_gantt_taskz%default_list_if_empty.plan_start_datez#default_list_if_empty.plan_end_datezdefault_list_if_empty.ordernoz"default_list_if_empty.perm_has_aclzdefault_list_if_empty.sys_typez"default_list_if_empty.logic_prefixz'default_list_if_empty.affect_gantt_taskdefault_attach_full_search_typesdesk_feedbackrrT)rDrcache_projectsrur CmfProjectreadonly)rYprojects r%get_cache_projectrzqs|ZJ $$Z00G <1#'':8?8?8?'88r  $#G )0:& Nr&cjtstd5}|}dddn #1swxYwYd}||vrtd||d}t |atttS)Nzdist/cmf-angular/index.htmlzz3Base href tag absent in dist/cmf-angular/index.htmlz)r base_href) _index_template_cacheopenread ValueErrorrjinja2Templaterenderr app_base_href) template_file template_strbase_href_substrs r% _render_indexrs ! > / 0 0 0M(--//L 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0- < / /RSS S#++,<>_`` & = = ' '!} ' G GGs 8<<rcb|rd|dg}ngd}d|DD]}t||}tj|s tj||} tj|srn3#t tf$rtj wxYwtj |dcStj D]2}||}|r#tj |dcS3tS)Nzcustom/plugins/z/static)zcustom/static/zcommon/static/z cmf/static/zdist/cmf-angular/cbg|],}tjtj|-Sr;)rhpathrJrb PROJECT_DIR)rEds r%rzsend_static..s+OOOabgll6#5q99OOOr&T) conditional)r rhrisabsrJisfilerPrflaskhelpers BadRequest send_filerHOOK_STATIC_NOTFOUNDr) req_filenameplugin search_dirs directoryfilenamehooks r% send_staticrsa !88889 !!! PO;OOO C C Y 55w}}X&& 9w||Ix88H -7>>(++  :& - - --**,, , -}&&xT&BBBBB(GG4 %%  G=**8*FF F F F G ??s -B0B>c eZdZdZddejdeefdZdZ e dZ e dZ e d Z e d Z e d Z e dd Ze dZe ddZe dZe dZdS)CmfRedisMemoryWrapperut Если есть self.redis - используется он Если нет - нужен фолбэк Nredisredis_instance_namec0||_i|_||_dSr)r memstorager)r!rrs r%r zCmfRedisMemoryWrapper.__init__s #6   r&cfd}|S)Nc|jre t|jj|i|S#tj$r2}tjrt |j|d}~wwxYwtd)Nu&Redis memory wrapper запрещен!) rrr1ConnectionErrorrbCACHE_REDIS_FAILOWERREDIS_SETTINGS_MANAGERcheck_and_updater CmfAbortError)r!r"r#rr4s r%wrapperz/CmfRedisMemoryWrapper.fallback..wrappersz N:74:qz::DKFKKK,2Z.??@XYYYG $$LMMMs*A+-A&&A+r;)r4rs` r%fallbackzCmfRedisMemoryWrapper.fallbacks( N N N N Nr&ctrNotImplementedErrorr!r"r#s r%r!zCmfRedisMemoryWrapper.smembers!!r&ctrrrs r%r!zCmfRedisMemoryWrapper.smembers rr&c6|j|Srrrur!r}s r%ruzCmfRedisMemoryWrapper.get""3'''r&c8|jdSr)rclearrjs r%rfzCmfRedisMemoryWrapper.flushdbs r&c6|j|Sr)rttlrs r%rzCmfRedisMemoryWrapper.ttlrr&FcB|j||||||S)N)nxxxgtlt)rexpire)r!r}r7rrrrs r%rzCmfRedisMemoryWrapper.expires%%%c4B2"%LLLr&cZ|j|d}||z }||j|<|Srr)r!r}amountrs r%rZzCmfRedisMemoryWrapper.incrbys3##C++ $ r&rc.|||Sr)rZ)r!r}rs r%incrzCmfRedisMemoryWrapper.incr%s{{3'''r&c0d}|D]}||jvr|dz }|S)Nrrr)r!namesrns r%rzCmfRedisMemoryWrapper.exists)s2   ADO##Qr&c||j|<dSrr)r!r}rs r%rzCmfRedisMemoryWrapper.set1s$r&rA)FFFF)r)r1r/r=__doc__rRedisrrDr rr!rurfrrrZrrrr;r&r%rrsw77ek7xPS}7777   ""X"""X"((X(  X ((X(MMMXMX (((X(X%%X%%%r&rceZdZdZdZdZdeefdZdedee j fdZ dded e fd Z ded e j fd Zd Zdee effdZdefdZddefdZdS)RedisSettingsManageruR Менеджер по управлению настройками Redis. rQcFtjd|_d|_dS)Nzredis-settingsF)rH getLoggerlogger _terminatingrjs r%r zRedisSettingsManager.__init__?s#'(899 !r&rPcd}tjj}tjjjj} ||}|j}| n#| wxYw|S)uX Возвращает название инстанса Redis из БД N) rCmfGlobalSettingsdp_modeldp data_driverSessionqueryfirstcache_redis_primaryclose)r!redis_instancersessionsettingss r% _get_instancez"RedisSettingsManager._get_instanceCsv +4*-9A }}X..4466H%9N MMOOOOGMMOOOOs .A33B instancec2ttdrtj|ddkretj|}|dd|vr|dt jdi|SdSdS)Ncache_settingsrr celery_dbr;)rrbrcopyr.rr)r!rcfgs r% _init_redisz RedisSettingsManager._init_redisTs 6+ , , &1Fx1PQW1X\c1c1c'16688C GGFOOOc!! $$$;%%%% %  & &1c1cr&F with_flushcztjj}tjjjj} ||}|r| |}|j d | ||tn*#t$r|j dYnwxYw||_||dS#|wxYw)Nu*Выполняем очистку кешаu>Не удалось выполнить очистку кеша)rrrrrrrwith_for_updaterrrwarning init_cacherrfrrcommitr)r!rrrrrrs r% save_to_dbzRedisSettingsManager.save_to_db]s'+4*-9A }}X..>>@@FFHHH j!%!1!1(!;!; ##$PQQQjOOHn===%%'''' jjjK''(hiiiiij,4H ( NN    MMOOOOOGMMOOOOs0A*D$/C D$ $C0-D$/C00D$$D:rcttdrctj|ddkr|t_dStj|ddkrdt_dSt ddS)NrrrrXTu&Неизвестный тип кеша)rrbrrrWrXr)r!rrs r%rzRedisSettingsManager.init_cachess} 6+ , , J$X.v6'AA%3 """&x08HDD#'     HIII  J Jr&c|\}}||t_|t_t jr|s||tj drtjtdt |||tjdS)N run_uwsgiu?При работе через uwsgi обязателен Redis) get_instancerREDIS_DBrrrbrrrhrirursocketiostart_with_redisr)r!is_db_instancers r% init_rediszRedisSettingsManager.init_redis|s#'#4#4#6#6 ))(33'/$  & &~ & OOH % % % :>>+ & & c~% abbb!!(+++ (.11111r&cztjr#|}|rd}n|j}d}n d}|j}||fS)NTF)rbrrDEFAULT_REDIS_INSTANCE)r!rrs r%rz!RedisSettingsManager.get_instancesT  & 3))++H '!% 7!&"N2Hx''r&rc|}||kr|jsd|_|jd|t jdd}|dkr1|jd|t j|d|jd|tj tj tj d Sd Sd S) u Проверяем, обновилась ли конфигурация Redis в БД и если да, то терминейтим app Tu<Получена конфигурация Redis %s из БДr<uUОжидание %d секунд для применения конфигурацииFruvОстановка процесса приложения для применения конфигурации Redis %sN)rrrrrrandintr2sleepinforhkillr+signalSIGTERM)r!r db_instance sleep_secondss r%rz%RedisSettingsManager.check_and_updates ((** - - -d6G - $D  K   ^`k l l l"N1b11M!! ##${~KLLL ]6666 K  VXc d d d GBIKK 0 0 0 0 0 . - - -r&rintervalc|jd|\}} ||n+#t$r|jd|YnwxYwt j|dY)u^ Переодический запуск проверки и смены Redis u,Запуск periodic_check_and_update RedisTuЗапуск periodic_check_and_update Redis завершился с ошибкой. Повторный запуск через %d секундFr)rrrrr exceptionr2r)r!rrrs r%periodic_check_and_updatez.RedisSettingsManager.periodic_check_and_updates GHHH!%!2!2!4!4  . %%&9::::    %%QRZ  Lu - - - - .sA %A21A2NrB)r)r1r/r=rrr rrDrrrrrrrrrrrrrr;r&r%rr8s<'"""x}"&C&HU[,A&&&&3D,J3J JJJJ222& (eD#I. ( ( ( (1C1111&..#......r&r)Payloadr'c`eZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdS)CmfSocketIOWrapperu Функционал: 1. Отложенная активация, после получания доступа к Redis ctdtjdd|_d|_d|_g|_g|_g|_g|_ dS)NrF)appcors_allowed_originsrengineio_logger) rrbrcsocketio_kwargsrrlazy_on_handlerslazy_on_namespace_handlerslazy_init_apps lazy_runsrjs r%r zCmfSocketIOWrapper.__init__sU$'l$    " "*,' r&ctd||jr+|j|krtddStd||t di|j|_||| | ||_dS)Nz%CmfSocketIOWrapper: start_with_redis u=Warning. CmfSocketIOWrapper.start() вызван дваждыu)CmfSocketIOWrapper уже запущен!r;) r3rrr_make_redis_connect_paramsrVr_start_lazy_on_handlers!_start_lazy_on_namespace_handlers_start_lazy_init_app_start_lazy_run)r!rs r%rz#CmfSocketIOWrapper.start_with_rediss FnFFGGG = I"n44UVVVGHH H ''777 884#788  $$&&& ..000 !!### ,r&cfd}|S)NcDj|ddS)N)funcdec_args dec_kwargs)rr)rrrr!s r%wrapz#CmfSocketIOWrapper.on..wraps;  ! ( ($(**     r&r;)r!rrrs``` r%onzCmfSocketIOWrapper.ons/         r&c|j||jr.td||j|dSdS)Nz!CmfSocketIOWrapper: on_namespace )rrrr3 on_namespace)r!r1s r%r!zCmfSocketIOWrapper.on_namespaces` '..w777 = 0 ?g?? @ @ @ M & &w / / / / / 0 0r&c|j||d|jr)td|d||jj|i|dSdS)N)r"r#zCmfSocketIOWrapper: run rA)rrrr3runrs r%r#zCmfSocketIOWrapper.runs       = / dtj|dd|}dd lm}||d d }||jd <dSd}dtj|vr|tj|dz }dtj|vr|dtj|ddz }|tj|dz }|dtj|ddz }|d|z }||jd<dStddS)Nrrrdbunix_socket_pathzunix://z?db=r) RedisManagerzflask-socketioF)r. write_onlyclient_managerzredis://usernamepasswordr@hostport6379r- message_queueu|ERROR! CmfSocketIOWrapper: в cache_settings не найден коннект к Redis. Socketio не активирован)rrbrrurr5rr3)r!rr3r7r5r7r>s r%rz-CmfSocketIOWrapper._make_redis_connect_params's 6+ , , S1Fx1PQW1X\c1c1c&x06B$X.223EFF F] 5h ?@R S]]Y[]]111111!-c;KX]!^!^!^9G$%5666 + !6x!@@@!V%:8%DZ%PPM!6x!@@@!%W)>x)H)T%W%W%WWM!6x!@!HH !ZV%:8%D%H%HQW%X%X!Z!ZZ R) 8E$_555 R S S S S Sr&N)r1r/r=rr rrr!r#rzr&r*rrrrrr;r&r%r r s - - -000 ///,,,((( NNNuuu BBB ((( GGG SSSSSr&r SOCKETIO_WORKER)postforkc8tdSr)rrr;r&r%rrAs))+++++r&)rz/custom/org_namectjdtj }t |t rl|}|j|jd}|rtj |d<|j |d<t ||_d|_nEddd}|r(tj |d<t!||d<t#|}d|_t'||S)Nz App error:)coderH traceback descriptionapplication/jsonrz Unknown error)rHrrb PRODUCTIONrr get_responserCrHrD format_excrErhrir4 content_typerDjsonify status_codeset_cors_headers)r show_traceresponse response_datas r%handle_exceptionrQSs l###&&J!]###>>##FF    @)2)=)?)?M+ &'(} m$ =11 2#    2)2)=)?)?M+ &+.q66M- (=))"X Or&jwt_rsaz jwt_rsa.pub)RSA) cmf_deleted rg_member_ofdefault_projectemailphone user_localphone_internal primary_role online_statusvacation_start vacation_end on_vacationrd does_not_workauth_inactive_blockis_admin is_supportservicedesk_allow first_name last_nameztwo_factor.two_factor_optztwo_factor.application_verifiedztwo_factor.applicationlic_evaproject lic_evawikilic_evaservicedesk lic_evagit lic_evatest lic_evacicd lic_evarmsctjsdS tjs5tjdtjt_n##t$rtj dwxYwtjS)Nz.CmfPerson:00000000-0000-0000-0000-000000000001ruzapp.system_person() error) rb AUTH_ENABLEDr system_personr CmfPersonrucurrent_person_fieldsrrHrrjs r%rprps  t   g & 0 4 4CCLe!5!g!gC  5666   s AA A2c2tjdr tjd}ntjsdS t jtj}n%#t$rtj dYdSwxYw|dSt|to|dd}|sdSt|}|jdsdSdt_t!|jd dgd }|rt%|d krdS|jd d }|sdSt)jd|x}r|\}}ndS|dks |dks|dkr t.j}nJ|dks|dks |dks|dkr t.j}n%|dks|dkr t.j}n t.j}t7|t8jjsdSd|vr$||jd|ddg} n||ddg} | sdS|t?| j krdt_!| t_"dS)u Проверяем, что пользователь пришел из share-ссылки Если идёт обращение к /files, то проверяем Referer Т.к. jsurl передаётся только в апи для других ендпоинтов не смысла путаться парсить body Вообще, для API тоже лучше использовать реферер, тогда не придётся по два раза парсить json Выставляем: - g.sharelink_access_request = True, если пользователь пришел по /share ссылке - g.sharelink_access_granted = True, если проверка hash прошла - g.sharelink_access_obj = объект, по которому проверяли ключ. Используется в API для доп.фильтрации /filesRefererNu{_check_sharelink_access не смогли распарсить request.data для проверки прав доступаjsurlr/share/Trrr-rz*^(?P[^:-]*)[:-](?P.*)$docDOC CmfDocumentflFLIN_WORK CmfFolderCmfListEPI-rrsharelink_hashru)rCr)#requestrrheadersrur4ujsonrwrrHrrrTrrsharelink_access_requestr rrr0rrgroupsrr{rrrr CmfEntityrrDrsharelink_access_grantedsharelink_access_obj) rvjson_resr7 hash_paramobj_keyrrzobj_coder~rs r%_check_sharelink_accessrs|x((I##I..|  F {7<00HH     \ ] ] ] FF    F8T**Hx||GR/H/H  5//C 8  y ) )"&A#)$$(("66q9J ZA--hnnS!!"%G FPPPu"\\^^((5H--]1J1J& T  X--Y1F1F(VaJaJa$ Y  (e"3"3N &  i!5 6 6 hmm)"6CCCC$(*:#;==mm$8H1ImJJ S+,,,,%)"!$ FsA..BBc|t_|r4|tjkt_|tjkt_tjS)uh!!! Эта функция не меняет контекст, только инициализирует.)r_current_personanonymous_usercurrent_user_is_anonymoussharelink_anonymous_user#current_user_is_sharelink_anonymous)persons r%set_current_personr s<A U&,0@&@#06!:T0T- r&ct|dd}|dkr|jStjsdS||St dt jtjdS)NrFAIL_recursionz#Warning!!! Lazy Calc Current Personr]) rrprbror3rD print_stackrdstdout)r!cps r%current_personr so ($ / /B !!  t ~  /000 sz**** 4r&c& tjstjdg}|jst jj5ddl }ddl |j |j zd fdtdD|_|dddn #1swxYwY|jt_n##t $rt#jdwxYwtjS)Napp_keyrrrc3BK|]}VdSr)choice)rEralphabetsecretss r%rGzapp_key..& s/.[.[Aw~~h/G/G.[.[.[.[.[.[r& zapp.app_key() error)rrrrrurrrrs disable_aclstringr ascii_lettersdigitsrJrangesaverrHr)r!rrrrs @@r%rr sP{ +/33I;3GGH# $X%1133$$!MMM"NNN%3fmCH')ww.[.[.[.[.[QVWYQZQZ.[.[.['['[H$MMOOO $$$$$$$$$$$$$$$#*CK /000  ;s1AC$A C; C$C  C$C C$$ Dcdt|dd|jS tjs6tjddtjt_tj|_|jstj dd}|  tjddtj|_|jswtj j 5tj|j|_dddn #1swxYwYt%j|n#|wxYw|jS#t*$rt-jdwxYw) N_anonymous_userzanonymous@evateam.ruTrCinclude_deletedrzcreate-anonymous-user-locktimeoutzapp._anonymous_user() error)rrrrrqrurrrrlockacquirerrrrsr system_datacreate_anonymous_userrpdd commit_all_dsreleaserrHrr! redis_locks r%rr4 st&--9##" 2"("2"6"6+T0#7#2#2C  #2# %!,,-IST,UUJ     %'-'7';';/4(<(6(6$+')5577ii/2/T/TUYUg/h/h,iiiiiiiiiiiiiii$&&&""$$$$ ""$$$$## 7888 IBF+AE/*D<0 E/<EE/EE/F/F F F/cdt|dd|jS tjs6tjddtjt_tj|_|jstj dd}|  tjddtj|_|jswtj j 5tj|j|_dddn #1swxYwYt%j|n#|wxYw|jS#t*$rt-jdwxYw) N_sharelink_anonymous_userzsharelink-anonymous@evateam.ruTrz$create-sharelink-anonymous-user-lockrrz%app._sharelink_anonymous_user() error)rrrrrqrurrrrrrrrrrsrrcreate_sharelink_anonymous_userrprrrrrHrrs r%rrT st0$77C--, .,2,<,@,@14,-A-.-.C )*-)F&- %!,,-S]^,__J     %171A1E1E9442F2626.5')5577009<9h9h .:0:06000000000000000$&&&""$$$$ ""$$$$-- ABBB rc t|dd|jS tjddt j|_|jstj dd}|  tjddt j|_|jswtj j 5tj|j|_dddn #1swxYwYt%j|n#|wxYw|jS#t*$rt-jdwxYw) N_test_guest_userztest-guest@evateam.ruTrzcreate-test-guest-user-lockrrzapp._test_guest_user() error)rrrrqrurrrrrrrrrrrsrrcreate_test_guest_userrprrrrrHrrs r%test_guest_userrv st'..:$$ & 0 4 4($,!5!.!.$ %!,,-JTU,VVJ     %(.(8(<(<0$4)=)6)6%,')5577kk030V0VW[Wi0j0j-kkkkkkkkkkkkkkk$&&&""$$$$ ""$$$$$$ 8999 sIA.E- AE $*D E DE !D"E 8E- E## E-- F c>tjSr)rr get_settingsrjs r%global_settingsr s  # 0 0 2 22r&ct|drt|dd|jStjddg|_|jS)N _global_varaccount_sync_statusaccount_sync_lastr)rrrr CmfGlobalVarrurjs r% global_varr sZt]## mT(J(J(V*..7LNa6b.ccD  r&linenoc |tddtddf}||d}t d|zt |d|dD]\}}|jd}tj |j tjd d}t d |||j |j d z fzt|j |j }|rt d |z|jD]} t | ||d} | r=t%d | D} t dt'| | d z fzt%d|D} t d| d z zdS)NFzz T) cumulativez Top %s linesrrz#%s: %s:%s: %.1f KiBiz %sc3$K|] }|jV dSrsizerEstats r%rGzdisplay_top.. s$//49//////r&z%s other: %.1f KiBc3$K|] }|jV dSrrrs r%rGzdisplay_top.. s$00d 000000r&zTotal allocated size: %.1f KiB) filter_traces tracemallocFilter statisticsr3 enumeraterDrhseprJrr0rr linecachegetlinestripformatsumr) snapshotkey_typelimit top_statsr,rframerlinellotherrtotals r% display_topr s%%5"ABB5+..'H##H#==I .5 !!! 6E6!2A66   tq!6;;u~33BF;;BCC@AA $%, D0@AB C C C  >>DDFF  # (T/ " " ".''))  B "IIII  eff E @/////// "c%jj$+%>>??? 00i000 0 0E *edl ;<<<<z+create_person_from_auth.. sE;;;Aq||F++;12T 109 r&Tr cmf_owner cmf_authorcmf_modified_byServiceDeskClient)rC) only_datar;)rrrrsCmfLockrrqrurrrrrrrrcrUrCmfPersonGroup support_grouprY user_grouprdrrrr)authrcis_servicedeskr person_valuess r%create_person_from_authr sL   ! !"> ! K K!%%DJs?X%YY ;; JJ$J77;;;M*+M+ &*+-M, '/0}M+ ,%66 66F O$(!#**6+@+N+N+P+PQQQ$(!#**6+@+K+K+M+MNNN `+/(#**6+@+D+DJ]+D+^+^___!--// , , d +++ , , , , , , , , , , , , , , ,     5s6E2G(F<0 G(<G G(G G((G,/G,)forcelevelctj}ttdds|s|r|+t|trtt |}n|r t j}n t j}tj}t t|tj z dzd}t t|tj z dzd}t di dt}| dd}| dd} | d d} tj d } tjd | d |d |d d |d| d| d|| z| zdd g|} t j|ddd| Dtjt_ t'tj|z dz} | dkrt j|dd| ddSdSdS)Nrcrlrrw select_countselectrr)insertmr-z(+z)mszs zu zi rr@rAc34K|]}t|VdSrrC)rEparts r%rGzdebug.. s(*G*G3t99*G*G*G*G*G*Gr&zPROF debug funcion got ms)r7rrbrrDrHINFOrcroundr debug_start debug_nowrurTrr" request_idlogrJr)rrmessagesdebug_strrrscscsscuscirparts debug_ends r%rIrI s4y{{Hvw%%NN%N  %%% 0//  "LEEMEikk sQ]*d2A66 7 7 sQ[(D0!44 5 5 UU?B ' ' + +NDFF C CffXq!!ffXq!!ffXq!! L  S ! ! L  A C;;3;;#;;sS;;;       E4*G*G*G*G*G!H!HIIIikk X-t344 q== Kt%Ly%L%L%L M M M M M;NN8 =r&cttjd}tjdrw|rut t |j}|tdrdS|ds|drdSntjdrdStjd stjdrd Stjd s>tjdstjdrdStjd rd StjdrdSdS)Nru/files/ servicedesksd_api/docs/rwpub_api /servicedesk/api/api/pub//auth/r /with-contextsystemdeny)rrrurrrDrr)referer referer_paths r% set_api_scoper( so!!),,G|y))g8G,,122  " "moo#B#B#B C C 8  " "8 , ,  0G0G 0R0R 9    0 0 x   ) )W\-D-DY-O-Ou   ) )W\-D-DX-N-NRYR^RiRijsRtRty   * *v   1 1x 6r&cd*tjdkrdSttj tj t jfrBtj5tj tj dddn #1swxYwYddl mtt t%jdt(_it(_it(_gt(_t2jddkt(_ddlm}dd lm}|t(_ t(j t(_!d "|d d t(_#dt(_$gt(_%gt(_&dt(_'dt(_(dt(_)dt(_*dt(_+dt(_,dt(_-dt(_.dt(_/dt(_0dt(_1dt(_2dt(_3dt(_4dt(_5dt(_6dt(_7dt(_8tst(_:dt(_;dt(_<dt(_=t|j>?t|j@jAt(_Bdffd t(_?t(jBCt(_Ddffd t(_Cdt(_Eit(_Fit(_Ggt(_Hgt(_Igt(_Jgt(_Kgt(_Lgt(_Mgt(_Nit(_Ogt(_Pit(_Qit(_Rdt(_Sdt(_Ttt(_Vit(_Wgt(_Xdt(_Ydt(_Zdt(_[gt(_\it(_]it(_^it(__tt(_`it(_ait(_bgt(_cit(_dit(_egt(_fgt(_gtt(_hdt(_idt(_jdt(_kdt(_ltt(_mdt(_ntjpqtjrqt jsstddStjuvdrdStjstjst(hdt3jwdtj5t(hdt3jwdtjst(hdt3jwdtjytzttt j}rtt jrt ddl}ddlm}|n#t t f$rYnwxYwdt_t(hdt3jwdn/t(hdt3jwddddn #1swxYwYt jr2d "t=jddt(_nd}d}tjuvds tjuvdrKtjd}|sQtjd}|r0|vd r|td d}nd}|stjd!}|rtj|}tj|dtj"}t(hd#|dd d$|d%||s>tjd&tjtjt#d'd(d)*Stjud+kr*tjtj,}tjuvt)d-rzd.}d/tjvrtjd/}t-|} | s4t/d/|i} t1t)d0| } t3| | Sd1} |} |stjd2} tjd3}| r^tj| \t(_'t(_<t(j=rdt(_=t;n+|r)tj|t(_'t(j'rZt jo3tjt(j'j(j4}t jr|s dt(_'t(j'rmt(j'j(jt(_(d5d6t(j'j(gg}tj|tj7}d8t(j(d9} |rm|jr&t(hd8|j(d:d}nΐtG|d;r.|jr'd8|j(d<} t(h| d}n|r"tK|t(j'j=}njt(j'jr,tKt(j't(j'j=}n-t(jjrtKt(j'd>}|| z d?kr(t(hd@|| z tjuvdAp=tjuvdBptjuvdC}dD}|r|j(jt(_(t(j'r8t(j'jt(_+t(j'j t(_)ndt(_+|j t(_)dt(_,t|n|s |r[t(j}tYt(j5r t(j}dt(_*dt(_,t|n%dt(_,tt(jt(jptjuvdEptjudFkptjuvdGptjudHvptjuvdIptjuvdJpntjuvdKpNtjuvdLp.tjudMkptjuvdNptjuvdo2tjdOdPkotjdQkptjuvdRptjudSkpytjuvdTpYtjuvdUotjdQkp)tjuvdVotjdQkp| oz before_request..i s)9)9&)A)A Ar&c4tj|zSr)r_dater3s r%r5z before_request..k s+;+;F+C+C!Cr&Tz/memOKz"Wait first_request_init lock (pid=)z!Got lock first_request_init (pid=zStart first_request_init (pid=)uwsgi_restartszDone first_request_init (pid=z%Already done first_request_init (pid=>qwertyuiopasdfghjklzxcvbnmQWERTYUIOPASDFGHJKLZXCVBNM0123456789rrz X-Eva-Token AuthorizationzBearer token)api_token_hashrYrzAuth API Token(z ...): hash=z , person=z6Invalid API token: request.headers=%s, request.args=%szInvalid API token text/plainrJ /pub/webhookrzauth/not_authorizedr-next_url auth/signin?uUТребуется авторизация. Введите логин и пароль. session_token access_token)rr==filterruУчётная запись uQ заблокирована. Обратитесь к администраторуu заблокирована.rauo заблокирована за неактивность, обратитесь к администратору)rc)rg?z-PROF before_request get auth and session got z /pub/pub_apiz/docsz/sharec~tjdptjdS)Nrt /socket.io/)rrrr;r&r%is_allow_publicz'before_request..is_allow_publicb s4 L # #H - - 6|&&}55 7r&z/health_check/z/metricsz /auth/sync)z /auth/invitez/auth/restore_passwordz /auth/signz/servicedesk/auth/signz/servicedesk/auth/invitez/servicedesk/auth/two-factorz"/servicedesk/auth/restore_passwordz/auth/two-factormoderootz 127.0.0.1z /crm/forms/z/manifest.webmanifestz /app/assets/z/forms/z/js/r!z/sso/z /helpdeskz/nolicense.htmlz6PROF before_request CmfAccessList.setup_context() got rrru)Требуется авторизацияu-Доступ в раздел запрещен CmfLicenseznolicense.htmlz,PROF before_request license_ui_access() got z-PROF before_request prepare_plan_cache() got z/PROF before_request tfa_check_two_factor() got r)rmethodallrfirst_request_init_donefirst_request_init_skiprbrfirst_request_init_lockr2r3rrcmf.util.cmfutilr check_db_lockrrqrbefore_requestrrjrpflags remove_filesrhrirutestr7rr.r r rJrsave_only_data_hackalertnoterr is_guest_user is_anonymousrcis_system_contextrrdisable_notify import_modesession_tab_id component_idinteractive_shellrrrapi_args api_kwargsr( api_scoperrhack_session_need_commitrrrrr2rLr7relaxed_bz_python_mode emit_list socket_events server_eventsdeferred_audit_listdeffered_history_columnsdeferred_audit_notrans_listdeferred_job_listdeferred_comment_audit_listdeferred_statsdeferred_fullsearch_dirty_listdeferred_notify_messages"deferred_hide_closed_task_notifiesdeferred_update_task_projectrjscache_timeliferrrrTEXCOM_ENABLE_GROWCACHE_HACKrrracquired_locksacquired_locks_shacquired_lock_timignsrufulltext_search_headlinesfulltext_search_debug_labelr*project_perm_browse_cache%project_perm_timetrackerhistory_cacheshow_bg_progressbarapi_hack_fieldsrI new_acl_idapi_license_required license_disable_user_count_hooks backbone_synccurrent_save_objects csp_noncerCmfDeferredJob init_context CmfAccessListrorrrr+rrr app_init_aclapp_init_project_permissionWHATSAPP_MESSENGER_URLspawn_messenger_socketio_clientWHATSAPP_WEB_SOCKETspawn_whatsapp_socketio_clientuwsgicommonr:increment_uwsgi_restart_counter ImportErrorModuleNotFoundError CSP_ENABLEDsamplerrr"rq hash_tokenrrrHrr CmfWebhookget_token_personauth_base_hrefrcheck_sso_redirectr redirectrMcookies CmfSession from_token cmf_commitCmfAuthfrom_jwtIS_AUTHORIZATORrr`rrarjwt_is_supportrservicedesk_allow_auth_guestsjwt_is_match_orgrYrrrr remote_addr CmfPlugin check_secret STATIC_URL_RErrp setup_contextreject_responserdrrPlicense_ui_accessrprepare_plan_cache_doneprepare_plan_cachetfa_check_two_factor)r7r.rr: auth_person real_auth api_tokenr?rDrqserr_msgprof_strFrG_filteris_force_publicrM anon_personis_allow_without_authrrs @r%rXrX$ s~""t  ''  ''# K  ( K K L/I J J J K K K K K K K K K K K K K K K211111OOO %%'''AAMAGAN Z^^L ) )S 0AF$&&AKKAM7777#5;;;<)*55777 +---063555-52444 LLL555555"BBDDDD#%89D /3+F FFFGGGGN NNNOOOE" P" P" P" P" P" P" P" P" P" P" P" P" P" P" PJsggfm,lnpqqrr KI|w''V7<+B+B9+M+MV O'' 66  %++O<>">>??AfGdffG 6S++O<< **>::  ; & 1 < <] K K AFAI) -2*  ;^,,\::AF 6 ._6>3E3EAFLL^3E3_3_I% i  6 Sfl(AG$ -/G!*..gcF_.``KPQWPPPG  S, 'GGj;;Ljjjkkk#'KK[*?@@'[Ed'@[=N@@@GGGG$$$"&K S5iAFLabbb & S5afI^___ "@ S5afTRRR  tvv# R@PRRSSSl--n==- < " "7 + +- < " "8 , , 777 *#) 6 960AL"#&"99AOO!AL"-"88AO$;'''' *OO--*& !!! % 54K#;''''#1=))) F F|&&'788 F|z) F|&&|44  F |II  F |&&|44  F|&&'?@@ F|&&'ABB F|&&'EFF F|CC F|&&'9:: F|&&w//7GN4F4Fv4N4NRX4X7';6 F |&&}55! F$|66% F&|&&~66' F*|&&y11Xg6I[6X+ F,|&&v..U73F+3U- F0#"kw|'>'>w'G'GkFL\LiLiLkLk1 F2#"kw|'>'>w'G'GkFL\LiLiLkLk3 F6|&&{33?7 F8""7<009 F<|&&'899EagAH A AdffG &&((( tvv# [RYIY[[\\\,[ 1 1,[   ,v 0&w///"7++ +, %[5K %TZTj %"$$ $ [ [w'''    [5K TZTj   ( 'O,, ,I&& & [JKKK  #[F,B[NOOO  [   " [wv|T'J'J [{ [_j_u [dffG$6688 D=?? B B BCCCtvv#%%YttvvPWGWYYZZZ  &X&*#$&& 466G c ! ! GGVDDFFWDTVV W W W y$&& I * * , , 466G c ! ! GGXddffwFVXX Y Y Y  H   sJA==BB!C"^3\#"^3#\96^38\99A.^33^7:^7cgdg}tjdkr|gdtj|}|r||SdS)N)disabledrHFr)servicedesk_supportrHT)rJ)rrirrCmfAuthOpenIdPluginrulogin_redirect)rDropenids r%rr su((()G{h:::;;;  ' + +7 + ; ;F /$$X...//r&ctjdkstjdkrKt jdtjtjtjtjtjtj ds/tj dstjdkrt|pddd Sttj }d |i}|rt|d ||d <t|}d}|st|}|sQtjdkr!t!t#d|}n t!t#d|}t%||S)Nr#r$zJRequest reject access: path=%s, auth=%s, login=%s, api_scope=%s, person=%srLrrCznot authorizedr@rArBrD auth_errormessagerzservicedesk/auth/signin?rE)rrrrirHrrrrrrr r7rr rrrrM)rskip_ssorDparamsrrs r%rr sv|&&!+*A*A X L!&!'1;8I K K K L # #M 2 2|&&w//|~--3#3S|TTTT%%h'  ( '< ( ( ( 'F9  v    -"8,,A D{h&& 0 0NN"NNOO 0 0BBbBBCCr&cdtjttdSr)rr emit_eventsemit_server_eventsr;r&r%commit_with_eventr3 s,MMMr&c P|rit_dStdsdStjD]\}}d|vrd|dvr|dd|drht jj|d}|r<| D]'}|d |j j (td|d|d|dd  it_dS) Nrlrelation_persons__DEFERRED_all_relation_personsr is_changed-rr-rprivate) namespacer)rrlrurrKrrrrs get_obj_by_idall_relation_personsrrrr ) only_cleanrrrps r%emit_list_applyr; s?  55  +##%% o o3  $ $)JcRdNe)e)e " # * *+L M M M4y Ch&44SY??C 5577CC./66qtzBBBB8S%688#SVSZSZ[aclSmSmnnnnnAKKKr&c |D]V\}}|D]L}|d}|d=t|d}|d=|d} t|t|t|n2#t $r%}t d|d|d|d|Yd}~d}~wwxYwt|ts"|j |g|dRi|d |d i|d r:|d d ks.|d |d <|j |g|dRi|d |d i;| d r{|drsd |ddvr'| |ddd d|ddvr,|dddD]}| ||D]~} t| tj jr(t d| d|d|d|| jj} nt#| } | |d <|j |g|dRi|d |d iNXdS)N socket_clientr r#uPDEV: FATAL emit пришел с несериализуемыми данными z! socket_client:z; event_persons:z; event_param:r"rrrrevent_current_personrruYDEV: INFO Кривой евент, в event_person попал объект, а не str: rA)rrrrhrirr3rrVrzrrrrr!rrrD) event_dictmsgevent_param_list event_paramrr  emit_kwargsruser_id event_personevent_persons_strs r%emit_events_dictrN s!+!1!1!3!3,q,q ++ q+ qK'8MO, O <==MO,%h/4466K  3 ;''' ;''''   FijFF}JFF\iFFyDFFGGG mX66 " "3pV)<ppp ppWbcnWopppp6" ;v+>)+K+K&1&&9 F#" "3pV)<ppp ppWbcnWopppp~~l++ 7v&7-V1DQ1GGG%))+f*=a*@AW*XYYY)[-@-CCC'26':1'=>P'Q77G)--g6666 - q q lCJ,@AA:gwCggFIggLWggZegghhh(4(=%%(+L(9(9%&7 F#" "3pV)<ppp ppWbcnWoppppp qC+ q,q,qsAB-- C7CCc&tddS)Nrdelay)emit_events_with_delayr;r&r%rr~ s######r&c:|rit_dSddl}tdsdSi}|tjD]9}|dr"tj|||<tj|=:t |dS)Nrrmproject_notify)rrmrrurr)rrrmrs r%emit_project_eventsr sKKK 55 ! !Myy))%% >>* + + %!"!5M# $]#####r&ct||rit_dStdpiit_rrfd}t j|dSrt dSdS)uЗапускаемся в контексте, но отправляем в отдельном таске вне контекста, после паузы, чтобы не держать запрос.rNrmcNtjtdSr)r2rr)rrmsr%emitterz'emit_events_with_delay..emitter s' L    ] + + + + +r&)rrrmrur2r3r)rrrrms` @r%rr sz****EE/**0bMAO ( ( , , , , , ,  W ('''''((r&c6|rgt_dStdpg}gt_|D]]\}}td|d|tj|t|^dS)Nrnzemit_server_events: r) rrnrurIrrrgrhri)rrnr.r4s r%rr sEE/**0bMAO&::  8w88$88999w 4(8(89999::r&cDtjit_dSr)rrollback_all_dsrrmr;r&r%rollback_purge_eventr sAOOOr&c|rgt_dStdgD]5}tj|rtj|6gt_dS)NrZ)rrZrurhrrrK)rrs r%apply_deferred_remove_filesr seEE."--   7>>( # # Ih   ANNNr&cvtjr,tjtj|dSdS)uСессия может быть продлена через SSO, надо продлить куку Args: r (response): ответ браузеру в котором обновляем куки N)rrrrset_session_tokenrs r%update_cookiesr s8  y7((A6666677r&ctjrtjdstjdr'dt jdt jd|jd<dSdt jd|jd<dSdS)Nz/servicedesk/auth/r"z-default-src 'self'; script-src 'self' 'nonce-z'; style-src 'self' 'nonce-z?'; base-uri 'self'; form-action 'self'; frame-ancestors 'self';zContent-Security-Policyz}'; style-src 'self' 'unsafe-inline'; base-uri 'self'; form-action 'self'; frame-ancestors 'self'; img-src 'self' data: blob:;)rbrrrrrrr)rOs r%set_csp_headersr s 0 < " "#7 8 8 0GL|r<|dr|tdd}|tjvr|}d||jd<d|jd<d|jd<dS)NOriginhttps://zAccess-Control-Allow-Origintruez Access-Control-Allow-CredentialszContent-Type, x-ijtzAccess-Control-Allow-Headers)rbAPP_FQDNrrruCORS_ALLOWED_DOMAINSrr)rO origin_domainrequest_origins r%rMrM sOM_((22N "+~+  $ $Z 0 0 >+C OO,<,<=N V8 8 8*M6P6P6PH23;AH787LH3444r&ctddt|t|t|d|jd<|S)uk Запускается только если небыло ошибок :param r: :return: Tr) after_hooks event_delaybytesz Accept-ranges)rrrrMrrs r%acaor sR4Q////1AQ!(AIo Hr&c4ddlm}tjsdStjt _tjj 5tj j j dddn #1swxYwY|dS)Nrspawn_server_event_listener)cmf.cmf_server_event_listenerr rbroDISABLE_PERMISSIONSrdisable_permissionsrrrrsrincluderr load_acl_datar s r%rr sIIIIII  $8C   % % ' '99 (66888999999999999999 !!!!!s)BB BcttjjdsdStjj5tjjjddddS#1swxYwYdS)NCmfProjectPermScheme) rrrrrrrsrrload_project_permission_datar;r&r%rr s 3;%'= > >   % % ' 'OO /LLNNNOOOOOOOOOOOOOOOOOOs)A;;A?A?c0ttddkrdStjj5t j}t j |d}| dddn #1swxYwYt j dg}|r(| | gddgdgd gfD]+}|gd g}t j |gd  ,t j dg}|r(| | t j dg}|r(| | t j dg}|r*| | dSdS) Nrz /opt/eva-appr)rr)order_by) cache_action=rOR)rrr) cmf_modelrCmfTask) json_filterjson_entry_point json_action func_name json_datarI)rrbrrrrsrrrcreate_dummy_taskrudelete_dummy_task save_prepare_load_perm_fields CmfTriggerrr CmfComment CmfNotify)dummy_task_data dummy_taskr_frcrs r%rr sZv}%%77   % % ' ''' .::<<^''?4+@'AA $$&&&''''''''''''''' TF++A  -,,t5R5R5RTsTsTs.tu/// 0b1}1}1}~~~~TF++A  v..A  tf--A  sAB$$B(+B(c&t|dS)Nr) cmf_rollbackr+s r%teardown_requestr-A s9%%%%%%r&c |rtjsdS||r tjn tj}t d|d|d|d||||tj krdS|rRdtj }t d|t||t j vr!t j |dSdS) Глобальная функция для оповещения фронта о предупреждениях :param msg: :return: Nzcmf_alert: msg=z abort= debug_only= devel_only=rrzcmf_alert Stack: )rbrcrHWARNINGr rrIrGrJrD format_stackrr]r)rrr devel_onlyr stack_strs r%rrH s&, }#(:glGG E# E E E E* E E E EUGSSS*V5F1F"G"G !IIi46677  0Y00111C    !' sr&c|rtjsdS| tj}td|d|d||||tj krdS|tjvr!tj|dSdS)r/Nzcmf_note: msg=r0r1r2) rbrcrHr rrIrGr^r)rrr5rs r%cmf_noter8b s&, } GG ; ; ; ; ;j ; ;5GIII*V5F1F"G"G !&  cr&r-r)rrrr c|st} dtvrtt_n#t$r }Yd}~dSd}~wwxYwt |dkr'dtjrtjjjpdig}t|dtkrWdtvrtj |dd<n d|dd<tjrtjjjpd|dd<t||||}t |||d<d } d D]} | | rd } n| rtd t|s-tjg}| st!d tg} |D]c} t#| t$jjr | | jjA| t-| d| |d<t |dtj|g} || vr| |dSdS)Nrmrrprdrr)r"r#rrrF) zevent-z invaldebug-z task-comment-zaudit-task-comment-znotify-person-rzcomment-z notify-osznotify-important-DEBUG_TuCDEV: WARNING в cmf_emit_event не указали cmf_emit_event: uDEV: FATAL!!!!!!!!!!!!!! Добавьте меня в спинт Баги реактивности. 10.10.2022 в cmf_emit_event не указали cmf_emit_event: r )rrrTrmrrrrrrrdrhrirr3localsrrrrr!rrD setdefault)rrrrr r"r#r event_paramsmuted muted_debtrr event_lists r%r r w s !  ! # #"ffAO  4yyA~~$a&6&T1;K;N;T&\X\]^ DG}} q ()(8DG$ % %(*DG$ %*+*:*Xq?O?R?X*`\`Q&'T&IDQQQLJJ|$1L! Ep >>* % % E E  ` ^TZT\T\^^___ J)*  J IEGGII J J J%88 lCJ$8 9 9 8  $ $\_%: ; ; ; ;  $ $S%6%6 7 7 7 7$5L! JJ|O,---++C44J:%%,'''''&%s!- AAc|rd|nd}|rdnd} |rdnd} d| ||| g} |rddlm} | } tj| dtjtj }|r|\}}|r(|}|}|j}|rS|rQtj d | tj d |tj d |td | |g}|r+| || |n| |p||r | | | z |SdS)u :param command: собственно, команда которую необходимо выполнить :param sudo: необходимо ли команду выполнять от рута :param timeout: секунд на выполнение. Дальше команда получит SIGTERM. :param wait: True дождаться окончания выполнения команды, False запустить и забыть, вернёт (None, None) :param separate_out_and_err: отдельно stdout, отдельно stderr, иначе не ясно как это всё парсить False по умолчанию, чтобы никому ничего не сломать. :param do_decode: возвращать декодированные строки вместо байт :param do_raise: выбрасывать исключение в случае, если код возврата != 0 (удобно для логирования трэйсбэков) TODO: почему u''? Наследие python2 и биллинга или реальная необходимость? TODO: Можно перейти на f'{sudo}bash -c export BLA=BLA;{timeout}{cmd}{redirect}', читается лучше ztimeout -v {0} rzsudo z 2>&1z0{0} bash -c "export BOOTUP="noncolor";{1}{2}{3}"rr-T)shellrreu6Произошла ошибка при вызове %sz STDOUT: %sz STDERR: %su4Произошла ошибка при вызове rA) rr7 subprocessPopenPIPE communicatert returncoderHerror RuntimeErrorr)commandsudorwaitseparate_out_and_err do_decodedo_raisemeasure_runtime timeout_cmd_sudo _redirectcmdr7 popen_startprocessouterrerrcoders r%run_bash_commandrZ s9@H$++G444SK %HH#E+9I > E E     C DFF s$&0o&0o777G &&((S  **,,C**,,C$  ]x ] MRTW X X X M, , , , M, , , ,[VY[[\\ \i  # JJsOOO JJsOOOO JJszc " " "  + JJttvvk) * * * :r&c:tjtj}t j}||||}tj | }|d|}|S)ua Подписываем токен сертификатом :param jwt: :return: r*) rrrrsa_private_keyr r)rsignbase64 b64encodert)jwtsignerdigestr]rs r%rsa_sign_pack_jwtrc s| ^C/ 0 0F Z\\F MM#**,, ;;v  D  D ! ! ( ( * *D //4//C Jr&cZddd}tjt|}tjt|}|d|S)uD Создаем токен :param payload: :return: RS256JWT)algtypr*)r^r_rhrirrt)payloadheaders r% create_jwtrk s U + +F  djj007799 : : A A C CFtzz'2299;;<<CCEEG w  r&ctjS)u2 Текущая версия :return: )rb CMF_VERSIONr;r&r%cmf_get_versionrns  r&cd|tjvr!tj|dSdS)ux Удаления файлов после коммита транзакции :param filename: :return: N)rrZr)rs r%cmf_remove_filerp s5 q~%% h'''''&%r&ctjsdStjdrdSdtjjdtj}t jj |}|r[t jj |t| dddSdS)Nfield_options_list DEFERRORS_rrz
)rrrrrrdrrrrurxrrtr) redis_keyrHs r%_deferred_errors_checkrus <|122CQ^.CC1ACCI L  " "9 - -E 8 !!),,,%,,..((v667777788r&ctjddtjd}|t jz }dtjjdtj }tj j |}|r| dz|z}n|}tj j ||dS)NruLОшибка в after_request, после выполнения метода z rsrz )rrrrrrDrIrrrdrrrurtr)rrrtrHs r%_deferred_errors_saverw%sJ%%% kYZYe k k kC9  ! !!CCQ^.CC1ACCI L  " "9 - -E  )C/L9e,,,,,r&ctj|ddlm}|jdt |jdr|jdt |jdr|j dt td rNtj rBt5|j ddddn #1swxYwYn|j d|jdt |d r|jd|jdt+dt-dt/dt1dt3dgt_dS) Nr+rrTr(apply_deferred_hide_closed_task_notifies)rollback"apply_deferred_update_task_projectrqCmfStat)rr cmf.includerr%apply_deferred_notify_messagesrrrzr|rrq cmf_contextCmfAuditapply_deferred_audit CmfFullSearchapply_deferred_dirtyr}apply_deferred_statsr$!apply_deferred_comment_audit_listapply_deferred_jobsrrrrrp)rrs r%r,r,2s&y))))"""""" 33t3DDDv~HIIO???NNNv~BCCI9949HHHq.//>>vy!!=++t+<<< 7747HHH4((((4((((d++++$''''40000!#AsC..C25C2ctj|rotj}ddlm}t i}tj|d<gt_tj |d<it_ tj |d<gt_ tj |d<gt_ tj |d<it_ tj |d<gt_ tj|d <gt_tj|d <gt_tj|d <it_tj|d <it_tj|d <it_tj|d<gt_tj|d<gt_tj|d<gt_t-|}|rIt1jt4tjjtjtjtj|fi|tjtj|z dkr*tAdtj|z dSdSdS)NrryrvrwrorqrurrrtrsrxrmrlrnrZrp{Gz?z PROF cmf_commit after_hooks got )!rrr7r~rrr rrvrwrorqrurrrtrsrxrmrlrnrZrpanyrr2r3cmf_commit_after_requestrrrdrrir3)rrrrafter_request_params need_spawns r%rrNsO/N)++&&&&&&''))) ";<;U78%'"EFEiAB/1,676K23 ">?>[:;(*%ABAa=>+-(454G01 121A-.>?>[:;(*%?@?];<)+&01_-,-K[) 01_-/0~^,;<;U78%'"-446677  ? L11>3DaFVXYXdfgfq% ? ?)= ? ? ?  9;; 4 ' ' LTY[[75JLL M M M M M_/N/N\ ( 'r&ctdtj}t5 ttj|tjj j |t_ |t_ |t_|t_|t_|t_|t_| t_| t_| t_| t_| t_|t_|t_|t_|t_|t_tjt?tj drtj !tj"#tj$%tj&'tQt?tdrtj)*tj+,t?tj drtj -t]t_|tatctej3tj|z dkr1t4dtj|z n##tj$r}tm||d}~wwxYwddddS#1swxYwYdS) NzRun cmf_commit_after_requestrrzr}r|rrz"PROF cmf_commit_after_request got )7r3r7rrrrqrurr rrrrrdrrirvrwrorqrurrrtrsrxrmrlrnrZrpr%rrrrzrrrrCmfOrmColumnHistoryapply_deffered_history_columnsrr}rr$rr|rrrrrrrIrrw)current_user_idrdrrirrvrwrorqrurrrtrsrxrmrlrnrZrpafter_request_prof_strs r%rrs ())) IKK ..-  v/33OCGKLm3nn o o o-A %AL#AK)AA &3UA 0$7A !,GA )/MA ,"3A -A ,GA )-IA *+AO#AK+AO)AN)AA &   ; ; = = =v~&PQQ JGGIII O 0 0 2 2 2  5 5 7 7 7  & E E G G G  ! ! !vy)) 633555   ? ? A A Av~&JKK DAACCC  ! ! ! " 5 5 5 5  ' ) ) )     y{{22T99bTY[[K`=`bbccc    !! $ $ $G Y..................s5MK-L! M! M+L<<MMMMr4c ddlm}|pd}t|}|dddd}|r,|dr|dz }|||z}t|S)Nrrrhourminuterr+-r)rVr _ensure_localrrlstripisdigit_to_utcr4rr base_local start_locals r% start_of_dayrs111111 \rFt$$J$$!AaQ$OOK ||~~&----5577#  0 0 8 88K ;  r&c ddlm}|pd}t|}|r,|dr|dz }|dddd}|||z}t|S) Nrrrrr;rrVrrrrrrr)r4rrr end_locals r% end_of_dayrs111111 \rFt$$J ||~~&----5577# ""2aQ"OOI,,V444I 9  r&czddlm}|pd}t|}|r,|dr|dz }|dzdz}|t|z}|dddd }|||z}t|S) Nrrrrwrrrr rVrrrrrweekdayrrr)r4rrrdays_since_sundayrs r% start_of_weekrs111111 \rFt$$J ||~~&----5577# #++--1Q6)!23333J$$!AaQ$OOK 0 0 8 88K ;  r&cddlm}|pd}t|}|r,|dr|dz }|dzdz}|t|z dddd }|td zd d dd }|||z}t|S) Nrrrrrrrrrr0rrr)r4rrrrweek_start_localweek_end_locals r% end_of_weekrs111111 \rFt$$J ||~~&----5577# $++--1Q6"Y4E%F%F%FFOO qP'):):)::CC 1!DN$&6&6v&>&>>N > " ""r&cddlm}t|}|r,|dr|dz }|ddddd}|||z}t|S)NrrrMrdayrrrrrrs r%start_of_monthrs111111t$$J ||~~&----5577# $$1QTU$VVK 0 0 8 88K ;  r&cddlm}t|}|r,|dr|dz }|ddddd}|tdz}|tdz }|d d dd }|||z}t|S) Nrrrrrr)monthsrrrr) rVrrrrrrrrr)r4rrrstart_month_localnext_month_locallast_day_localrs r% end_of_monthr s111111t$$J ||~~&----5577# "**qq1Z[*\\(=+B+B+BB% q(9(9(99N&&Br!QR&SSI,,V444I 9  r&cddlm}|r,|dr|dz }t |}|dddddd}|||z}t|S)Nrrryrmonthrrrrr)rVrrrrrrrrs r% start_of_yearrs111111 ||~~&----5577# t$$J$$1!!Aa]^$__K 0 0 8 88K ;  r&cRddlm}t|}|r,|dr|dz }|dddddd}|ddd d dd}|||z}t|S) Nrrrrrr rrr)r4rrrstart_year_localend_year_locals r% end_of_yearr%s111111t$$J ||~~&----5577# !))qqSTbc)dd%--BBRPR[\jk-llN#&6&6v&>&>>N > " ""r&rrPctj}|j}||S|j||S||S)uPВозвращает datetime в локальной зоне сервера (aware). - Если base=None, берём текущее локальное время. - Если base naive, присваиваем локальную зону. - Если base aware, конвертируем в локальную зону. NrM)rrrrMr)r local_nowlocal_tzs r%rr1se!%%''2244IH | {||8|,,, ??8 $ $$r&dtc|jI|tjj}|tjjS)unПереводит aware datetime в UTC (aware). Для naive сначала делает локальным.Nr)rMrrrrrr)rs r%rr@sS y ZZx04466AACCJZ K K ==*. / //r&c$eZdZdd dZdZdZdS) rFTrPNc`td|_||_||_dS)Nr#)rtest_request_contextctxinit_views_and_dspreprocess_request)r!rrs r%r zcmf_context.__init__Gs-++O<<!2"4r&c ddlm}|rtd|j|jr!t tj|j rt dSdS)Nr)has_app_contextu;Контекст нельзя включать дважды) rrrr __enter__r start_viewsrinit_dsrr)r!rs r%rzcmf_context.__enter__Ls)))))) ?   [YZZ Z   !  MMM JLLL  " %  " " $ $ $ $ $ % %r&c |rt|ntd|j|||dS#|j|||wxYw)Nr+T)r)r,rr__exit__)r!excrrDs r%rzcmf_context.__exit__Wst 5 -s+++++t,,,, H  c5) 4 4 4 4 4DH  c5) 4 4 4 4s #AA!)FTr@)r1r/r=r rrr;r&r%rrFsK55555 % % %55555r&rcHgd}tjd|D}|D]\}}}|tjd}|dr|D]}|ds|dr|dsmdd |d D}t |dz|dd zd t d d tt ddtt ddtt ddttdS)N)z cmf/viewsz cmf/modulesrmodulesz custom/commonzcustom/modulescXg|]'}tjtjd|d(S)r-T) followlinks)rhwalkrbr)rE search_dirs r%rzstart_views..csH$'$'$'  6%44 44$GGG$'$'$'r&rz/viewsz.pyz.pycz __init__.pyr*c3K|]}||V dSrr;)rErs r%rGzstart_views..ks'*N*NA*N1*N*N*N*N*N*Nr&r-r)packagerO)r) view_funcz/distz/static/staticz,/plugins//static/plugins_static) itertoolschainrrbrrrrJr0 importlib import_modulerr2rapp_before_run)r search_iterdirnamedirnames filenamesrr5s r%rrasfffK/$'$'%$'$'$'(K)4ff$9//&"4b99   H % % f% f f%%e,,f0A0A&0I0IfS[SfSfgtSuSuf"%((*N*NgmmC6H6H*N*N*N"N"NK++K#,=s@S@STU@V,V`d+eeeS6[AAA+f TTT%KCN^juvvvr&cdSrr;r;r&r%rr}sDr&c $|dd||d<||d<ttjj|d<tj|d<tj|d<tj|d<tj ||gdS) N countdownrr"r#g_current_user_idg_acl_admin_modeg_component_idg_session_tab_id) r<rDrrracl_admin_modererdrrr)jobr"r#r8s r%schedule_deferred_jobrs {A&&&GFOGH#&q~'8#9#9G  "#"2G  !G "#"2G W~.....r&c|rgt_dStjsdStdttjdtjD]\}}|jdi|gt_dS)Nz Schedule z deferred job(s)r;)rrrrIr apply_async)rrr8s r%rrs  GG BA/00 B B BCCC+## W""'""""Ar&cVd}tjrtj|dgdSdS)Nci}tjddrdtji}t tj||dS)NSOCKETIOr namespacesr)rhrirurbORG_NAME whatsapp_sioconnectrrs r%messenger_connectz:spawn_messenger_socketio_client..messenger_connectsa :>>*d + + 0v/GV:(2G  E E E E Er&z /whatsapp)r)rbrr2r3)rs r%rrsLEEE$B &K=AAAAAABBr&cXtjtjtjdSr)r2r3whatsapp_go_siorrbrr;r&r%rrs  L(&*DEEEEEr&cddl}tjddtjdtj|tjtjddddS)Nrr@uYПодключаемся к удаленной отладке config.REMOTE_DEBUG_SERVER=z config.REMOTE_DEBUG_PORT=TF)r<stdoutToServerstderrToServersuspend)pydevd_pycharmrHrrbREMOTE_DEBUG_SERVERREMOTE_DEBUG_PORTsettrace)r s r%cmf_pycharm_debugrs L  @'-'A @ @%+%= @ @AAA F6V=Ufj+/@@@@@r&c `ttjtjt t t jt t t jdztjj d}t|}t|S)Nrguid)issorg_nameiatexprjti) rTrbrrrDrr7rrrrkrc)rir`s r%gen_eva_app_tokenrs}v"O3ty{{++,,3ty{{R/00119? G W  C S ! !!r&urir4cddlm}tjrtjdkrUt t j|d}|dg}|di}||i|}n|}ddd d |_t|}t|d <| |t | } | jd kr"td|d| jd| j| }|rd|vrtd|t"||S)Nr)rFalserQr"r#rFrAr()z Content-typeAcceptzContent-Encoding eva_app_token)r4u9Не удалось отправить запрос, url=z, status_code=z, res=rHu(Сервер вернул ошибку: )requestsrrbEVA_ACCOUNT_USErrrrurrrpostrhrirLrcontentrrI) rr4rrQ method_args method_kwargsresultrr7rs r%call_eva_accountr$s       !QV%;w%F%Fh88hhvr** 2.. 6 66 GII%7*(/11  !!(3(( 1 3 3_ffStzz$//f00 ?c ! !DCDD_b_nDDvywBDDEE E  Qg''OvOOPP PGGFOOO Mr&eva_db_upgrade_runningc$|s ttj}ttdst tjt|ddstdtdS)uЗапускается перед миграций БД. Информирует приложение, что не следует открывать транзакции.rrT)exrz Cannot lock N) rDrhr+rrrrrr _DB_LOCK_KEYCmfError)rs r%app_db_upgrade_startr*s !BIKK   8W % %,))+++ >  lEbT  B B64l4455566r&cNtjtdS)uЗапускается после миграций БД. Информирует приложение, что можно продолжать работать.N)rrrxr(r;r&r%app_db_upgrade_stopr,s N,'''''r&cd}d}tj}|rZ|rtj|z |kr|rtdtdS|dz }tjd|ZdS)uПроверяем не заблокировано ли использование БД, если заблокировано, то можем дождаться разблокировки.c&trtjtz dkrettdsttjta tjatS)uWиспользуем кеш 1sec, чтобы часто не ходить в редисrr) _db_lock_cache_tsr7rrrrrrur(_db_lock_cacher;r&r% check_lockz!check_db_lock..check_lockso! ,TY[[3D%D$I$I8W-- 4&11333%^// ==N $ r&rz DB locked FrT)r7r)r(r)rLr raise_errorr2rnstarts r%rWrWs    E IKKE *,,  e+w66 :L::;;;u   1  *,, 4r&cddl}tjrd}n tj}|j|d|j}||dS)Nrrcz:%(asctime)s %(process)d %(name)s %(levelname)s %(message)s)rr)logging.handlersrbrc LOG_LEVEL basicConfigrsetLevel)rHrrs r% init_loggingr:sh |! Ge,hiiii W  F OOEr&httpsctjpd}|ds|dz }|r2tjrdtjnd}|dtj||S|S)Nr-rrz://)rb BASE_HREFrEXTERNAL_PORT_HTTPSr)full_urlprotocolr| port_specs r%rr%s} 'CI   c " "S G8>8RZ42444XZ FFvF F9FFF r&ctjr tj}nI|r4|rd}n1tjrdtjnd}dtj|}nd}|tjpdz }|ds|dz }|S)Nzhttp://127.0.0.1:8080rrrr-)rbAUTH_SERVER_URLr>rr=r)absoluteinternalr|rAs r%rr/s  -*   D4 @F@Zb< :<<<`b CvC CC IV%,,   c " "S r&r)rr)FFrrrB)rF)FFNN)FNN)TNTFFFF)T)TrrA)Tr-T)Fr;)r"rrHrrdfcntlrhrr^rrvrCr7rD threadingrrrpathlibrtypingrr urllib.parserr r r werkzeug.utilsr r2rr Crypto.Hashr Crypto.Signaturerrrrflask.json.providerrwerkzeug.exceptionsrrrr~cmf.data_providersrrcmf.system_datardateutil.relativedeltarrrVrrrrrMobjectrOrHr1rbrrrhrprrr cache_in_project_roler rpc_modelsclean_attributesrTrSLockrUall_models_meta SECRET_KEY secret_keyflask_socketiorVrWrrXrrDrzrvr}rrrrrrrengineio.payloadrmax_decode_packetsr riruuwsgidecoratorsr@rrcrrrrr~r4rrr REDIS_DB_IDREDIS_DB_ID_TIMER errorhandlerrrQregister_error_handlerprivate_key_pathpublic_key_pathCrypto.PublicKeyrS import_key read_bytesr\rsa_public_keyrrrrrrrrrrrpropertyrrrrrrrrrIr(rXrrrrrrrrrrrrrrM after_requestrrrrr-rr8r rZrcrkrnrprurwr,rrrrrrrrrrrrrrrrrrrrrrTr$cache_notify_scheme_rulecache_cmf_security_levelcache_person_notify_optcache_cust_field_config_schemecache_email_listrr(r1r0r*r,rWr:rrr;r&r%rps    00000000"""""""" ============$$$$$$  ''''''!!!!!!!!333333------)))))) 000000------ fgg E,BBB qDqDqDqDqDvqDqDqDj/66666,666* eHDF4FGGG  c " " *+ &'#"#,in.."........ @@@@@F) HHH*8E%E%E%E%E%E%E%E%P ! " "G.G.G.G.G.G.G.G.T.-//3 HJJ %$$$$$ oSoSoSoSoSoSoSoSb    :>>#$$,(((((( ,,X,vV\*** & ---7>>&$'99::+ f #55 6 6+!&&((..**+++++++++++++++ )D9&67774*++i7$v)**]: H(#.)9)D)D)F)FGGCF'(B(B(D(DEEC"_ _ _ D    & $@D>!//Qh}--Q!.11Q#+8,D#E#EQ "(?33Q!.11Qx//Q(7##Q333#(?33QXj))Q====>< tNNNNNB,]]]@////""""J&-q-q-q`$$$ $ $ $ $((((*:::: 7770002 M M M      " " "OOO$$$N&&&& 4**-Dy`b8(8(8(8(8(vin5:2222j    ! ! !((( 8 8 8 - - -$$$$81N1N1N1Nh===@          s       #     ######(   3              #      # # # # # # %(9: %x?P % % % %0!0h&70000 5555555568    / / / /     B B BFFF@@@ "3 " " " "#T4 "! %'"(  6 6 6 6((( 6 s.,K&&K*-K*