@iU 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.ddl/m0Z1ddl2Z,ddl3Z3ddl4m5Z5ddl m6Z6ddl7m8Z8e3jrdZ:Gdde;Z;dZ<Gdde=Z>Gdde)Z?e;e@deAjZCe?eCeC_DdeC_EdeC_FgeC_GdeC_HdeCjd<ieC_IdeC_JieC_KdeC_LdeC_MdeC_NejeC_PieC_QeAjeC_SddlTmUZUmVZVddlWmXZXddlYZYd eZfd!Z[ieC_\e[eC_[da]d"Z^dd#Z_Gd$d%Z`e`ZaGd&d'ZbebZceceC_ce>Zddd(lemfZfd)ef_gGd*d+ZhehZWejjd,rdd-lkmlZleld.ZmeXeAj/ZoeXeAj/ZpejjeAjd0zrAeseAjd0z5ZtetjjeA_wdddeaeC_adeC_xdeC_yeCje{d1Z|eCje{e|eeAjd2z Z~eeAjd3z Zdd4lmZe~jr'eje~jeC_ejr'ejejeC_gd5eC_d6ZEd7Zd8Zd9Zd:ZFdeC_deC_deC_d;Zd<Zd=ZeeEee_EeeEee_eeee_eeee_eeee_eeee_eeee_eeFee_Fd>Zeeee_d?Zeeee_dd@ZddAZdddBdCZdDZeCj6dEZddFZddGZdHZddIZdJZdKZddLZddMZddNZdOZddPZdQZdRZdSZeCjTdTZdUZdVZdWZeCj^ddXZddYZddZZd[dd\gd]d^Z dd_Zd`ZdaZdbZdcZddZdeZddfZddgZdhZddieZfdjZddieZfdkZddieZfdlZddieZfdmZddieZfdnZddieZfdoZddieZfdpZddieZfdqZdrej*e jdse jfdtZdue jdse jfdvZGdwdxZdyZdzZdd{Zdd|Zd}Zd~ZdZdseZfdZdeZdefdZieC_ieC_ieC_ieC_ieC_ieC_dZdadaddZdZddZdZddZddZy#1swYxYw)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$t||i|yN)super__init__)selfargskwargs __class__s ./cmf/app.pyr zFlask.__init__0s $)&)c fd}|S)Ncjdd}|j}|jdd}|dk7r 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{{:t4H,,K%++C04Kg%K'$.&,qzz9 D  c8Q :' : (OHr&)r!r9r8r:s``` r%routez Flask.route3s r&)r1r/ __qualname__r r< __classcell__)r$s@r%rr/s *r&rcb|r-tjddjd|Dyy)N%s c32K|]}t|ywrstr).0args r% zprint_debug..Gs%?3c#h%?)loggingdebugjoin)condr"_kwargss r% print_debugrNEs'  dCHH%?$%?@A r&ceZdZdZdZdZdZdZdZdZ dZ d6d7dZ dZ dZ dZdZd8dZd Zd Zd Zd Zed edefdZedefdZed9dZdZdZdZdZdZdZdZ d6dZ!dZ"dZ#dZ$d8dZ%d:dZ&d Z'd!Z(d"Z)d#Z*d$Z+d%Z,d&Z-d8d'Z.d(Z/d;d)Z0d*Z1d9d+Z2d,Z3e4d-Z5e4d.Z6e4d:d/Z7ee8d01d2Z9e4d3Z:e4d4Z;e4d5Z*F C  &HS$QX[XbXb cW^^%FMM%%c*E}LL'E01H).wHX v & KK    (r&cttjxs |jdtjd}|j j }|j jddD]*}|jdr|dz }|j|,|jttjxs |jd |d tjy ) u+Инвалидируем весь obj cachezCmfCache.flush_all_obj!!!r]rzobj:*rlrms obj:jshashzCmfCache.flush_all_obj: z recordsN) rNrbrcrdrerWrrrs startswithrxry)r!rnr|r}s r% flush_all_objzCmfCache.flush_all_obj|s FLL.DJJ0KRUR\R\]}}%%'==**7$*? C~~m, QJE KK    FLL.DJJ2J5'QY0Zadakaklr&c ddl ddl}ddl ddlm ddlm |} fd tjr jttjjjtjdz ddj!j#ddd vro|j}|d krYt$j&rIt$j&t$j(k7r(tjjjS|D]}|d z |z}d |vr|d zt|d z}t+|j-D]\}}|d k(r |d z|zdz |z}!|j.r^d|ddzdz j|j!j#z}|j1dd}|j1dd}n3|d j|j!j#z}t3|j.d||S)Nr)timezone) ImmutableDictct|}t|tjjr,|j r|j }t|}nd}t}d}|tttfvrv|tk(r`|dddk(rX jj|}|j j}|jdd}|}td|t|}|S|t"k(r|D]}||zdz}|S|t$k(s|k(r5|j'D] \}}||z}|r|d |z}|dz}"|S|d }|S|t(ur t|}|St+|d rt|j,}|Sd |j.zd z j1t3j4|j7z}|S#t $r }Yd}~d}~wwxYw) Nz...r20)second microsecondz !!!!! Date:,:Noneidz todo2:obj:)type issubclasscmfrCmfType is_definedvaluerDintfloatparserparse astimezoneutcreplacer3 ExceptionlistrTitemsboolhasattrrr1md5rvri hexdigest) valtresval1evkr_all2strdateutilhashlibrs r%rzCmfCache.hash.._all2strsS A!SZZ//0>>))CS ACACS#u%%8AaD 0&oo33C8"oohll;"ll!lC!}c2#h0J/d2A +c1C2,J)da=0IIK(DAq'C!$Qi(1+5!Ci (&JJd#hJ 3%cff+CJ'3c9GKK UXHYF S..Av||~. 4HCd{C# #hsm3A 4 ::!Ac("W, AHHJ0G0Q0Q0SSA $$A #s#A(! w{{188:6@@BBADJJ 3Q7r&c| t}|s|Stt|j}t}|jj D]_}|j j|d}|s#|jdr|j|ddn|j|t|tj jr.t||jd}|s|j||t|tj jtj jfst||jd}|r|D]}|j|||j!D]/} d|j"d| j} |j| 1b|j|j"dzdj%t'|z|S)N_idr+)rref_rrAr)setgetattrmodels class_name__dict__r`rruendswithaddrrCmfRelationBasesimple_objects_id_recursive CmfM2MBaseCmfBackrefBaserelated_modelsrrKr) r!objrmodelfields_str_set field_name field_cls field_valuerel_obj rel_modelrefs r%rz$CmfCache.simple_objects_id_recursives ;%CJ/,,++- !J ((T:I""5)"":cr?3"":.)SZZ%?%?@%c9+?+?F 44[c4JI (=(=szz?X?X'YZ%c9+?+?F #.K88c8JK"+!9!9!;!I )*>*>)?@CGGCL!' !.  sxx~(>??@ r&c|sgSg}t}|jdD]d}|jjdr|j |jddn|j |jt |t jjr*|j|j|jt |t jjt jjfs|jr1|jD]"}|j|j|$|jD]/}d|jd|j}|j!|1g|j!|jjdzd j#t%|zt't|}|S) u Собираем ид связанных обьектов 2 уровня для настройки инвалидации :param obj: :return: TrrNr+rrrAr)rvaluesrrr isinstancerrrextendobjects_id_recursiverrrrrappendrKrr)r!rrrfieldrrrs r%rzCmfCache.objects_id_recursivesz IZZ4Z0 $E((/""5#3#3CR#89""5#3#34%!;!;< 444U[[AB%#**"7"79R9R!ST;;#(;;G 4#<#*>)?@CJJsO$ $ 366<<#%1G(HHI3s8n r&ct|tjkDrtddy|jr |jj d||y|j r||j|<yy)NuUDEV: Слишком большой объект для кэширования — keyT) debug_onlyFobj:)lenrbCACHE_MAX_OBJ_SIZE cmf_alertrWrrXrU)r!r}str_vals r% _obj_dict_setzCmfCache._obj_dict_setsi w<&33 3 m{ A == MM  SElG 4 [[")DNN3 r&ct}|D]}|jd||jr'|jj|t |k(ryy|j r%|D]}|j j|ryyy)NrTF)rrrWexistsrrXrUru)r!r`hkeysr}s r%_obj_dict_existszCmfCache._obj_dict_exists1s $C IISEl # $ ==#t}}##U+s4y8 [[ !~~))#.  !r&c|jrZ|jjd|}||jjd|S|jjd|S|jr|jj|Sy)NrrRrS)rWrurZrXrU)r!r}rs r% _obj_dict_getzCmfCache._obj_dict_getCsy ==--##d3%L1C $$Z0J $$[1J [[>>%%c* *r&r~ inv_payloadc|d|S)N::r;)r~rs r%%_jshash_invalidate_confirm_member_keyz.CmfCache._jshash_invalidate_confirm_member_keyPsK=))r& member_keyc(|jddS)Nrr)maxsplitr0)rs r%+_jshash_invalidate_confirm_member_key_splitz4CmfCache._jshash_invalidate_confirm_member_key_splitTsq11r&c<|r|n|jdd}d|S)Nrzjscache-invalidate-confirm-set:r)cache_idr~set_keys r%"_jshash_invalidate_confirm_set_keyz+CmfCache._jshash_invalidate_confirm_set_keyXs('(FLL,=b,A0 ::r&ctt}|jD]v\}}td||d|g|jD]K\}}|j ds||j |j |j||Mx|jr6|jD]"\}}|jj|g|$yy)Nz invalidate-)room event_personsjshash:r~) rrrcmf_emit_eventrrrrrWsadd) r!msgs confirmations person_idinv_dictr~rr confirm_lists r%rzz CmfCache.emit_s#D) #'::< Y Ix [ 4hTZcYd e'/~~'7 Y# $$Y/!$"I"IQW"I"XY``BB6;WY Y Y ==)6)<)<)> ;%" ""7:\: ; r&c0|js td|jrs|rp|dd}|j|}t}|D])}|j |j |d|d+|jj |g|yyy)Nu$ERROR! Недоступен redis_dbrr r)rWr3rrrrsrem)r! confirm_dict sample_jshash key_cache_idrconfirms r%jshash_invalidate_confirmz"CmfCache.jshash_invalidate_confirmns}} 8 9 ==\)OA.MBB-BXL6L' h##D$N$NwWXz[bcd[e$fg h DMM  | ;l ;*=r&ctjrtj|jrW|j |}|jj |Dcgc]!}|j|j#c}Sycc}wr) rinvalidated_keys CMF_CACHE_do_invalidate_defferrWrsmembersrrt)r!rrmembers r%jshash_invalidate_confirm_listz'CmfCache.jshash_invalidate_confirm_list|sw    + + - ====hGG#mm44W=?@@Q? ? ?s&B c |sy|jr|jj|Dcgc]}d| c}tj||j |i}|D]}|j rd|vrt d|t|j d||jjd|dx}s^t|j d||j rt d ||jj}|D]H} |jd| jd |jd| jd J|j} t|| d dd D]\} } | jd } | tj| } | s2| d } | |vr t!|| <|dk(r/|r-dj#t%|D cgc]} | dvr|  c} }nd}| dd|d|d|}||| | <|jjd|dx}rxt'j&}|j)|t'j&}||z dkDrt*j-d||z dyy|j.r$|D]}||j0vs|j0|= yycc}wcc} w)Nrrnz#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 utf-8rrrpupdater) cache_fieldscmf_modified_at cmf_viewed_atcmf_modified_by_idONLYFORUPDATESrq?z_obj_dict_mdel emit got sec)rWrxr inmemory_delprofiler_invalidatercr rNspoprrrurtryziprvrwrTrKrtimerzrrJrXrU)r!r`obj_changed_fieldsobj_idactionr}r{invjsr|r~ jshash_listrrrchanged_fieldsr emit_startemit_ends r%_obj_dict_mdelzCmfCache._obj_dict_mdels   == DMM 4"@CT#<"@ A  " "4 (  $ $T *H7 E::'"4"%H#NODJJ*TUXTY(Z[ $}}114Fse2LTW1XXeX .XY\X],^_zz&)LSE'RS==113D"'E4 g(>'?!@A d6==+A*B$CDE#',,.K),UK14E)F'E !'w!7&!=$ & U 3 ',-@'AH'x759V 2 &16H15$*7I,@!+,4~+~-.,@%A2" 2B-27^,>#3C7:; 7+;;J [[((,,T2 2  k7r t:t2k7rn|sd} d}n tAdd} |r?|dr9tjd|| d k(rY|jB|dvrH|dD]@} | |jBd|jBdfvs$d} |j4vr tEdn| sg} dg|jFD]}||dvs |d|} | sdg} t/| tjHd<| D]`}|dvrd}|dD]P} | jKd d}||k7rd!| d!|d"4d#|d$| d#|d$|d"Rb|dD]}d!|d"|r|ds d!|d"jr#D]}tjd%|d& tMjN|}jQ|s dt_)|r tjU|tW|d'tvrtjXrxtjd(dtjXjrt[d(tjXj]d)tjXfij]y)*NNO_CACHETrrz%DEBUG_CACHE ADD SKIP CACHE LOCKED_BY z#DEBUG_CACHE ADD SKIP too old trans rAc|jd\}}}|vr t|<|r|jd|y|jy)NrA) partitionrr)bind_and_fieldsbindrrrr}s r%bind_addzCmfCache.add..bind_add)sl.77.bind_add_recursive5s#t$ 7C  #dggszz'9'9:33D9Ct??EFC#DTN#  #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_lockedrNrccache_locked_byget_last_invalidate cache_lockscache_transaction_startrutilcmfutilget_model_by_namerrrrDrskipcache_select_for_updater3rrrrrrcache_cluster_fields profiler_datar0rvrircache_store_error inmemory_addrr~r r>)r!r}robj_type query_paramscache_inmemoryliri obj_modelrQobj_casewhere_pkrscopesc_fieldscope model_namebindidstr_objrMrs`` @@r%rz CmfCache.add s ::>>* %!%A   * *>dFZFZ !$$ $  5 55 5 A  $ $X .!%A   &KILeLefnLoKp$q r % %h /"#--"3"3Ha>W>W"X "R '!%A   &I!JcJcIddefjf~f~@HgIfJ%K LHH$$66x@   #, z#t,dD1I s #H366{a;;;*366(2RSTSpSpRqrs ZT*ws1vtT/JH s # _HCyCDI$643; H Cef f  L2  $9< H5 <;Q)Q".x"8J!(8&<@PPU>V%WW#'!ffXh6%&CD !)J9+I+IJIG,/?"@@!-.>!?!HI (\F48L 01#KE NN &&28&< K &0%5%5c%:1%= #z1$zl%CD$zl'%JK$veWAj\%BC$veWAj\%IJ KK#/x"8DJzl'BCD<#9 xj8 9 ::" ODJJ*r rrqr)r!r}rt from_inmemoryrrobj_sizes r%ruz CmfCache.get!s ::>>* %);); !$$ $  5 55 5 A ((-CCDJJ( #:!M$$S)Cll3's8 c>1}**gcUOahh[+IJDJJ*TUXTYYZ[\[c[cZd(ef::"%H#NPQPXPXY  &7u$= >  $6 < ^,,S1&&sC:J %%c*DJJ"4SE :;r&cyNrrNrcrrWrur!r|s r%rgzCmfCache.get_last_invalidateGr&cbt|jd|jt_y)Nz)DEBUG_CACHE TRANS cache_transaction_start)rNrc gen_time_usrrirjs r%riz CmfCache.cache_transaction_startLs"DJJ KL$($4$4$6!r&cttjjtjjj dS)Nz%Y%m%d%H%M%S%f)rrrrrstrftimerjs r%rzCmfCache.gen_time_usPs68$$(():):)>)>?HHIYZ[[r&cyr) rNrcrerrWrrrhri)r!r|ls r% cache_lockzCmfCache.cache_lockSr&cyr) rrhrrfrirNrcrWr)r!r|tr_startlock_trs r% cache_unlockzCmfCache.cache_unlockdrr&cyrrrs r%rfzCmfCache.cache_locked_bytrr&cyNF) rfrrhrurirNrcrWr)r!r|_cache_locked_byris r%rezCmfCache.cache_is_lockedysr&ctj}tj}tj}tj}t } | |j }|D]r} | |vrt || || <n|| j|| || D];} d| vr$| j| jdd+| j| =t|j| |j||jdD cgc]} | c} || dtj} | |z dkDrtjd| |z dyycc} w) NrArT) is_changed)r3r2r4inv_listr+zPROF _do_invalidate got r,) r1rrrrrrr%rr0rr`rJ) r!rrr4r3st glob_inv_dict glob_inv_listrrrinv_valends r%_do_invalidatezCmfCache._do_invalidatesC YY[  --5 >ffV *A %#&x{#3 a a '' 4#A; *'>LLs!3A!67LL)  * * ).1hh$h.G"H1"H   iik 8c> GG.sRxj< =  #Is E ctjddsytj}tj}tj}|D]"}|j |d|d|d|d$tj}|j |tj}||z dkDrxtjd||z dtjd ||z d ttjtjd ||z d t|tt_ it_gt_y) Nrrr2r3r4r+z_do_invalidate_deffer got r,z)_do_invalidate_deffer _obj_dict_mdel got zsec len=z0_do_invalidate_deffer _invalidate_dict_mdel got ) rrur1rrr:rErJrrr)r!rrrrst_invalidate_dict_mdelrs r%rzCmfCache._do_invalidate_deffersAuu'.  YY[  % ~H    4h?S6TV^_gVhjrs{j| } ~#'))+ ""=1iik 8c> GG0r #> ? GG?@WZ\@\?]]efijkj|j|f}e~ A GGFsMdGdFeemnqroAnBC D U  r&c tjjdry||dh}|sy|j|t |j d|d|dt |t}t}t}i}i}t |dkr|D]} |jjd| dd } | D]Q} |jj| } | s!| D],} | jd d } |j| | || <.S|j| nJtjd t!|jjdd } tjd t | t#j$ddj'|zdz}t#j$d}tjd| D]} | j)}|j+|s%|jj| } | rC| D]>} | jd d } |j| |j-|d || <@|j| |D]}|jjd|j)}|j|} |sC|D]}|jd d }|j||jjd|j)}|sWt/j0|}|d}||vr t3||<d}|dd|d| d|}||||j)<g|d|Dd|Dd|D}|r8tjd|d|d||jj4|ntjd|d|d|j7|y) NrGrz!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"rrpr*rqrc3BK|]}d|jywrNrtrE query_keys r%rGz*CmfCache.invalidate_ids.."s! FiY%%'() Fc3BK|]}d|jyw)r"Nrrs r%rGz*CmfCache.invalidate_ids..#s" TI"9#3#3#5"67 Trc3BK|]}d|jywrr)rEr~s r%rGz*CmfCache.invalidate_ids..$s >6V]]_%& >rzinvalidate_ids(, ): z): no keys found.)r`rarurrNrcrrrWrsrr0rr%rrJrrecompilerKrtrfindallrvrwrTrxrz)r!r|idsr4invalidate_keys query_keysjshashesr{obj_id_by_query_keyid_r`r} inv_members inv_memberid_retuuid_re key_decodedrquery_jshashesr~rrr7r keys_lists r%invalidate_idszCmfCache.invalidate_idss  ::>>* %  ; \#$C   #DJJ"CF81ZLXYZ]^aZbYc de%U 5 & s8s? - }}..|C55JRV.WBC"&--"8"8"=K"*5BJ)3)9)9$)?)BJ&NN:6>A/ ;BB &&t, - GG' ) // T/RSD GGjT , -JJuSXXc]2589Ezz"opH GGo ' )!jjl {{;/"mm44S9 &1[ %/%5%5d%;A%> "z2:B:J:J;:WXY:Z+J7[ ##C( )$ FI!]]336HIYIYI[H\4]^N%)))4C,FF#\\$/2FLL( MM--V]]_4E.FGE  "LL/E$%89Hx/-1V*&6N%*7^$4BvhbRGW"XK:EHX&v}}7F  F&  F: F U T ?X >   GGoj\C5I;G H DMM ) , GGoj\C58IJ K (r&c&d fd }tjjdry|syj|t j dd|i|D]/}|d|d|d||dj d| 1y) Nctj|}|r$||<tjdd||yy)NDEBUG_CACHE INVAL: rA)rArNrc)invalrJinvdr4rr!s r% _check_invalz8CmfCache.invalidate_ids_as_wrapper.._check_inval.sF,,U3D"&DJJ*=fXQugeW(UVr&rGDEBUG_CACHE start invalidate rArrref=obj.id=)r3)r)r`rarurrNrcr)r!r|rr4rrrs` ` @r%invalidate_ids_as_wrapperz"CmfCache.invalidate_ids_as_wrapper-s W ::>>* %    #DJJ"?xq UV DC 4uAj\2F ; i (   hs  C Dr&c tjdd|d|d|tj}d6fd }ddlm}t j jdryj|jtjd d |j|j}ijrddl } | j|jd k(r||jd d vr|d|j d|jd|s t#d||j d|g|d|jdd|d|j d|jddtj} j%|tj} | |z dkDrtjdd| |z dyt'} |j)dD]\} }d}|j|vrt+|t,j.j0rt3|dr"|j4j6r |j4sˉd vr1|r/|j r#|d|j d|jdd!vr|j8r|j:|j<k7rm|d|j j<d|jd"|d|j j:d|jd#| j?| 5t+|t,j.j@r#d!vr|j8r| j?| ||j8r7t+|t,j.jBr| j?| |j8s|j:|j<k7s| j?| | jEd$s | j?| dd%"tG| dk(r+d!k(r&tjd&d'|j yd(g}|jHD]}|j?|tKtM|d)dr|jO|d vr||j dd!k(r||j d| d!k(r.| D](} d*g|jHD]}t3||stQtM||t,j.j@r'||D]}|d|j d|d+| d htQtM||t,j.j0r|d||d$zd|d+| dtQtM||t,j.jRr|d||d|d+| dt#d,d-|d|d+| d+d.}d*g|jHD]A}t3||s||j8s ||j:||j<k7s@d}Cd vs|r\t3|dr#|j4j6r |j4s-d*g|jHD]}t3||stQtM||t,j.j@rs||D]}|d|j d|dd/||j8su||j:s||j:D]}|d|j d|dd0tQtM||t,j.j0ra|d||d$zd|dd||j8s ||j:s|d||j:j d|dd1EtQtM||t,j.jRr^|d||d|dd||j8s||j:s|d||j:j d|dd1t#d,d-t3|dr"|j4j6r |j4s|d|dn{tTjVrkd vs|ret3|drY|j4j6sC|j4jY|j4rt#d2tjZd3t\j^r5tj`jd4ggztj`d4<tj} j%|tj} | |z dkDrtjd5| |z dyy)7NzRUN INVALIDATE: action=z obj=z item=z m2m_field_name=c  j|}g}|r-|rt|}g}|D]}d|vr|j||jd^}}}|rCtj d|d|t d|d|d|d|j|rt|jd} || zs|j|| |<n| |<t jd d||i} || |<tjr6tjjdg| gztjd<yyy) NrAz=cmfCache.invalidate(): ValueError: too many values to unpack(rTabortrrr) rArrr0rrJrrNrcrPrroru)rrJ change_fieldsr invd_affectediri_fieldstail i_set_fieldstmpr4rr!s r%rz)CmfCache.invalidate.._check_invalPsr,,U3DM $' $6M$&M!4a<)003$-.WWS\*8d GG&cdicjjmnomp$qr%(efkellopqorrstxsy&zCGH)003$'*8>>#+>'? (<7)003!4"'4HUO&*HUODJJ*=fXQugeW(UV!E 11./oo.A.A&.LPSu.TAOOF+2;r&r)rrGrrA RelationCachezRelationCache.parent.id=)rrCrrruYDEV: FATAL в инвалидацию м2м поля не передали имя поляr)rr\r]zwhere=r^r+zinvalidate (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_deleterUr*uОшибка конфигурации моделей: cache_cluseter_fields может быть только по m2m и relation полямrFz where_m2m=zwhere_m2m_old=z where_old=uDEV: в методе ux не загружается is_dummy, что приводит к лишним инвалидациям кластераrzinvalidate got rN)1rrJr1 collectionsrr`rarurrrNrcTRACEpdb set_trace parent_idrrrrrrrrrrrrroldnewrrrrrrnrr load_fieldsrCmfTUUIDrbRAISE_LAZYLOADload api_methodrPrro)r!rr4rPm2m_field_namerrrrrr_check_inval_done_do_invalidate_donerrrno_caching_fieldscluster_load_fieldsrz cc_field_name cc_clustercluster_field_is_changedrs` ` @r% invalidatezCmfCache.invalidateMsL  *6)6SF'D7:KN;LMN YY[# VJ , ::>>* % 'DJJ"?xqHX YZ>> ::   >>_ , CMM?-G H ) ) 4y#..)9:F C!uv CFF8i?O P ?3>>*:'BH M 6$''!CNN+;7CX N!%    Xv 6"&))+ "R'#--fXV>2B!CFKh'E,<,<eiiAW 4 ~Qs~~6F!G S 4 ~Qs~~6F!G S!((4%!6!67Fx%?@SS T *r&c|jD]\}}td||jjD]\}}td|y)NzDEBUG CmfCache.dumps)rUr3rVr)r!r}rs r%rizCmfCache.dumpsbsQ /HC (# . /--335 /HC (# . /r&c|jdd}tjr|jdd} tjj j |}tjs;|jr|jtjvrn|j|y|jstddy|tj vr|j#|ytj |}|j%|d}|dur|j#||S|j'||j)||S#t$rYywxYw) Nr*rrr.SDEV: inmemory_get вызван для модели без флага cache_inmemoryTr)r0rPrcrrjrkrlKeyErrorrin_memory_cachertrin_memory_cache_skip_modelsprofiler_inmemory_data_skiprr INMEM_CACHEprofiler_inmemory_data_missru move_to_endprofiler_inmemory_data_hit)clsr}r|r model_cacherets r%rzCmfCache.inmemory_getqs3YYs^A& >>#))#.q1J HH$$66zBE  ##E,<,<@]@],]//4## ktx y S__ ,  + +C 0ooj1 ooc3' #:  + +C 0J  # #C (  * *3 /JG  s)E EEc |dkDrt|tjjst j |rd|}np|rnt|t r^t|dtjjst j |drd|djdt|d}t|jd|dyt|jd||jd d}tjr|jd d } tjjj|}t"j$s |j&sy|j&st)d d y|j&rd}|t*j,vrt/t*j,|<t*j,|}||vr |||k7rt1d|d|d||y|||<t|kDr/|j3d\} } t|jd| yy#t $rYywxYw)Nirr[]u/DEV: skip inmemory_cache obj_size > 128000 — u байтzCmfCache:inmemory_add add key r*rrr TrzInmemory cache error! key:z try_add:z exists:F)lastz"CmfCache:inmemory_add evicted key )rrr BaseModel dataclasses is_dataclassrrrrNrcr0rPrjrkrlr rr rtrrrrr3popitem) rr}rrdetailr|r LRU_LIMITr evicted_keyrs r%rqzCmfCache.inmemory_adds f #szz334 8P8PQT8UcUC.A (<(<=AYAYZ]^_Z`Aac!f//0#c(1=  %TU]T^^ghngo#p q CII!?uEFYYs^A& >>#))#.q1J HH$$66zBE  )=)=## ktx y    I S__ ,*5-COOJ 'ooj1 + 33&23%yXkZ]N^M_`a  C { i '(00e0.handlers( (TVZ [  " "4D " 9r&z&CmfCache:on_inmemory_del spawn handler)rNrPrcgeventspawn)datarMr*r`s @r%on_inmemory_delzCmfCache.on_inmemory_dels6 F| : HNN&LN Wr&c dtvrtt_dtjvrdtjd<ntjdxxdz cc<dtjvrdtjd<tj rHdtjvrgtjd<tjdj |yy#t$r }Yd}~yd}~wwxYw)Nroinmemory_cache_hitrinmemory_cache_missrinmemory_cache_hit_keysrrr}rs r%rz#CmfCache.profiler_inmemory_data_hits a'"&& q 645AOO0 1 OO0 1Q 6 1  756AOO1 2  ) )(?=? 9: OO5 6 = =c B *   rc dtvrtt_dtjvrdtjd<ntjdxxdz cc<tj rHdtjvrgtjd<tjdj |yy#t$r }Yd}~yd}~wwxYw)Nroinmemory_cache_skiprinmemory_cache_skip_keysrr3s r%r z$CmfCache.profiler_inmemory_data_skips a'"&& ! 756AOO1 2 OO1 2a 7 2  ) ))@>@ :; OO6 7 > >s C *    sB77 C C c dtvrtt_dtjvrdtjd<ntjdxxdz cc<dtjvrdtjd<tj rHdtjvrgtjd<tjdj |yy#t$r }Yd}~yd}~wwxYw)Nror1rr0rinmemory_cache_miss_keysrr3s r%rz$CmfCache.profiler_inmemory_data_miss)s a'"&& ! 756AOO1 2 OO1 2a 7 2 q 645AOO0 1  ) ))@>@ :; OO6 7 > >s C *   rrreturnNrNNF)r%)=r1r/r=rUrVrWrXrcrrPROCESS_EVICTED_FLUSHr rfrrrrrrrr staticmethodrDrrrrzrr r:r>rArErr.rrrdrurgrirrrrfrerrrrrri classmethodrrqr-on_server_eventr.rr rr;r&r%rPrPJsIH F E! E! %T$ mQf!F<&$ *c***222;; ; < ?Sj   Q-fB"@&A( $$LR 7\*"C G >>2kZD@STj/++\.W.W`CCB45 6 CC&DD"DDr&rPceZdZdZy)CustomJSONProviderc t|tjtjfr |j}t|t j st|t j r/|js|jdzS|jSt|tjr |jSt|}t|S#t$r }Yd}~nd}~wwxYwtj||S)NZ)rr CmfDateTimerrrdatetzinfo isoformatriterr TypeErrorrdefault)r!riterablers r%rKzCustomJSONProvider.default@s "# 2 2FNNCDii#x001ZX]]5Szz==?S00}}&C0yy CyH> !   #**455s$BC C%C C C*%C*N)r1r/r=rKr;r&r%rBrB?s6r&rB) static_folder root_pathTSEND_FILE_MAX_AGE_DEFAULTF)SocketIO Namespace)Client project_idct|}tjj|}|s?tj j|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)rSprojects r%get_cache_projectrtqsgZJ  $$Z0G ##'':8?'8r #G )0:& Nr&c$ts\td5}|j}dddd}|vr td|j |d}t j |atjttS#1swYdxYw)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 0M(--/L 0- < /RS S#++,<>_` & = ' '!} ' GG 0 0s BBc|rd|dg}ngd}|Dcgc]0}tjjtj|2c}D]}t ||}tjj |s tjj||} tjj|so tjj|dcStjD]/}||}|stjj|dcSt!Scc}w#ttf$rtjjwxYw)Nzcustom/plugins/z/static)zcustom/static/zcommon/static/z cmf/static/zdist/cmf-angular/T) conditional)r`pathrKrb PROJECT_DIRr isabsisfilerJrzflaskhelpers BadRequest send_filerHOOK_STATIC_NOTFOUNDr) req_filenameplugin search_dirsd directoryfilenamehooks r% send_staticrs4 (89 ! DOOabggll6#5#5q9O C Y 5ww}}X&ww||Ix8H -77>>(+,}}&&xT&BB C((G % ==**8*F FG ?P:& ---**, , -s5D+D00.EceZdZdZddej deefdZdZ e dZ e dZ e d Z e d Z e d Z e dd Ze d Ze ddZe dZe dZy)CmfRedisMemoryWrapperut Если есть self.redis - используется он Если нет - нужен фолбэк Nredisredis_instance_namec.||_i|_||_yr)r memstorager)r!rrs r%r zCmfRedisMemoryWrapper.__init__s #6 r&cfd}|S)Nc|jr' t|jj|i|Std#tj$r6}tj rt j|j|d}~wwxYw)Nu&Redis memory wrapper запрещен!) rrr1ConnectionErrorrbCACHE_REDIS_FAILOWERREDIS_SETTINGS_MANAGERcheck_and_updater CmfAbortError)r!r"r#rr4s r%wrapperz/CmfRedisMemoryWrapper.fallback..wrappersxzz:74::qzz:DKFKK $$LMM ,,22.??@X@XYGs%AB 1BB r;)r4rs` r%fallbackzCmfRedisMemoryWrapper.fallbacks Nr&ctrNotImplementedErrorr!r"r#s r%rzCmfRedisMemoryWrapper.smembers!!r&ctrrrs r%rzCmfRedisMemoryWrapper.smembers rr&c8|jj|Srrrur!r}s r%ruzCmfRedisMemoryWrapper.get""3''r&c8|jjyr)rclearrjs r%rfzCmfRedisMemoryWrapper.flushdbs r&c8|jj|Sr)rttlrs r%rzCmfRedisMemoryWrapper.ttlrr&cD|jj||||||S)N)nxxxgtlt)rexpire)r!r}r1rrrrs r%rzCmfRedisMemoryWrapper.expires$%%c4B2"%LLr&cf|jj|d}||z }||j|<|Srr)r!r}amountrs r%rZzCmfRedisMemoryWrapper.incrbys4##C+ $ r&c&|j||Sr)rZ)r!r}rs r%incrzCmfRedisMemoryWrapper.incr%s{{3''r&c@d}|D]}||jvs|dz }|S)Nrrr)r!namesrns r%rzCmfRedisMemoryWrapper.exists)s2  ADOO#Q r&c"||j|<yrr)r!r}rs r%rzCmfRedisMemoryWrapper.set1s$r&r;)FFFF)r)r1r/r=__doc__rRedisrrDr rrrurfrrrZrrrr;r&r%rrs7ekk7xPS}7 """"((  ((MM ((%%r&rceZdZdZdZdZdeefdZdedee jfdZ ddede fd Z ded e jfd Zd Zdee effd ZdefdZddefdZy)RedisSettingsManageruR Менеджер по управлению настройками Redis. rKcFtjd|_d|_y)Nzredis-settingsF)rI getLoggerlogger _terminatingrjs r%r zRedisSettingsManager.__init__?s''(89 !r&r:c<d}tjj}tjjjj } |j |j}|j}|j|S#|jwxYw)uX Возвращает название инстанса Redis из БД N) rCmfGlobalSettingsdp_modeldp data_driverSessionqueryfirstcache_redis_primaryclose)r!redis_instancersessionsettingss r% _get_instancez"RedisSettingsManager._get_instanceCsz ++44**--99AA }}X.446H%99N MMO MMOs +B Binstancecttdrvtj|ddk(r\tj|j}|j dd|vr|j dt j di|Syy)Ncache_settingsrr celery_dbr;)rrbrcopyr.rr)r!rcfgs r% _init_redisz RedisSettingsManager._init_redisTsy 6+ ,1F1Fx1PQW1X\c1c''1668C GGFOc! $;;%% % 2d ,r& with_flushcftjj}tjjjj } |j |jj}|rS|j|}|jjd |j||tj||_|j#|j%y#t$r|jjdYNwxYw#|j%wxYw)Nu*Выполняем очистку кешаu>Не удалось выполнить очистку кеша)rrrrrrrwith_for_updaterrrwarning init_cacherrfrrcommitr)r!rrrrrrs r% save_to_dbzRedisSettingsManager.save_to_db]s++44**--99AA }}X.>>@FFHH!%!1!1(!; ##$PQjOOHn=%%',4H ( NN  MMO !jKK''(hij MMOs1 AD&&C4 D4$DDDDD0rcttdrUtj|ddk(r |t_ytj|ddk(r dt_yt dy)NrrrrXTu&Неизвестный тип кеша)rrbrrrWrXr)r!rrs r%rzRedisSettingsManager.init_cachess^ 6+ ,$$X.v6'A%3 "&&x08HD#'   HII -r&c|j\}}|j|t_|t_t j r|s|j|tjjdrtj tdtj||j|tjy)N run_uwsgiu?При работе через uwsgi обязателен Redis) get_instancerREDIS_DBrrrbrrr`rarursocketiostart_with_redisr)r!is_db_instancers r% init_rediszRedisSettingsManager.init_redis|s#'#4#4#6 ))(3'/$  & &~ OOH % ::>>+ &~~% abb!!(+ (..1r&ctjr*|j}|rd}||fS|j}d}||fSd}|j}||fS)NTF)rbrrDEFAULT_REDIS_INSTANCE)r!rrs r%rz!RedisSettingsManager.get_instancesj  & &))+H!%x'' !77!&x''#N22Hx''r&rc|j}||k7r|jsd|_|jjd|t j dd}|dk7r3|jjd|t j|d|jjd|tjtjtjy y y ) u Проверяем, обновилась ли конфигурация Redis в БД и если да, то терминейтим app Tu<Получена конфигурация Redis %s из БДr<uUОжидание %d секунд для применения конфигурацииFruvОстановка процесса приложения для применения конфигурации Redis %sN)rrrrrrandintr+sleepinfor`killr$signalSIGTERM)r!r db_instance sleep_secondss r%rz%RedisSettingsManager.check_and_updates ((* - -d6G6G $D  KK   ^`k l"NN1b1M! ##${~KL ]6 KK  VXc d GGBIIK 07H -r&intervalc |jjd|j\}} |j|t j|d*#t$r|jj d|Y?wxYw)u^ Переодический запуск проверки и смены Redis u,Запуск periodic_check_and_update RedisuЗапуск periodic_check_and_update Redis завершился с ошибкой. Повторный запуск через %d секундFr)rrrrr exceptionr+r)r!rrrs r%periodic_check_and_updatez.RedisSettingsManager.periodic_check_and_updates GH!%!2!2!4  %%&9: LLu -  %%QRZ sA%BBNr<)r)r1r/r=rrr rrDrrrrrrrrrrrrrr;r&r%rr8s'"x}"&C&HU[[,A&3D,J3J J2& (eD#I. (1C1&.#.r&r)Payloadr#c^eZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZy)CmfSocketIOWrapperu Функционал: 1. Отложенная активация, после получания доступа к Redis ctdtjdd|_d|_d|_g|_g|_g|_g|_ y)NrF)appcors_allowed_originsrengineio_logger) rrbrcsocketio_kwargsrrlazy_on_handlerslazy_on_namespace_handlerslazy_init_apps lazy_runsrjs r%r zCmfSocketIOWrapper.__init__sN$'ll$   " "*,' r&chtd||jr&|j|k(r tdytd|j |t di|j |_|j|j|j|j||_y)Nz%CmfSocketIOWrapper: start_with_redis u=Warning. CmfSocketIOWrapper.start() вызван дваждыu)CmfSocketIOWrapper уже запущен!r;) r3rrr_make_redis_connect_paramsrPr_start_lazy_on_handlers!_start_lazy_on_namespace_handlers_start_lazy_init_app_start_lazy_run)r!rs r%rz#CmfSocketIOWrapper.start_with_rediss 5n5EFG ==""n4UVGH H ''7 84#7#78  $$& ..0 !!# ,r&cfd}|S)NcDjj|dy)N)funcdec_args dec_kwargs)rr)rrrr!s r%wrapz#CmfSocketIOWrapper.on..wraps%  ! ! ( ($(* r&r;)r!rrrs``` r%onzCmfSocketIOWrapper.ons   r&c|jj||jr*td||jj |yy)Nz!CmfSocketIOWrapper: on_namespace )r rrr3 on_namespace)r!r*s r%rzCmfSocketIOWrapper.on_namespacesD ''..w7 == 5gY? @ MM & &w / r&c|jj||d|jr.td|d||jj|i|yy)N)r"r#zCmfSocketIOWrapper: run rA)r rrr3runrs r%rzCmfSocketIOWrapper.runs\    == ,TF!F8< = DMM  t .v . r&c<|jj|i|yr)rrzrs r%rzzCmfSocketIOWrapper.emits D+F+r&c|jj||jr*td||jj |yy)NzCmfSocketIOWrapper: init_app )r rrr3init_app)r!rs r%rzCmfSocketIOWrapper.init_app sD ""3' == 1#7 8 MM " "3 ' r&cb|jjjj|i|Sr)rservermanagerget_participantsrs r%r#z#CmfSocketIOWrapper.get_participantss*)>x)H)T(UUV%WWM!6!6x!@!HH 1V%:%:8%D%H%HQW%X$Y!ZZ 1RD) 8E$$_5 Q Sr&N)r1r/r=rr rrrrrzrr#rrrrr r;r&r%rrsM -0 /,( Nu B ( G Sr&rSOCKETIO_WORKER)postforkc,tjyr)rrr;r&r%rrAs))+r&)rz/custom/org_namectjdtj }t |t rs|j }|j|jd}|rtj|d<|j|d<tj||_d|_n>ddd}|r%tj|d<t!||d<t#|}d|_t'||S)Nz App error:)coder@ traceback descriptionapplication/jsonrz Unknown error)rIrrb PRODUCTIONrr get_responser<r@r= format_excr>rhrir- content_typerDjsonify status_codeset_cors_headers)r show_traceresponse response_datas r%handle_exceptionrJSs l#&&&J!]#>>#FFFF  )2)=)=)?M+ &'(}} m$ =1 2#  )2)=)=)?M+ &+.q6M- (=)"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_vacationr^ 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_evarmsctjsy tjs8tj j dtjt_tjS#t$rtjdwxYw)Nz.CmfPerson:00000000-0000-0000-0000-000000000001rozapp.system_person() error) rb AUTH_ENABLEDr system_personr CmfPersonrucurrent_person_fieldsrrIrrjs r%ririsy      & 0 0 4 4CCLeLe!5!gC     56 s AA++ B ctjjdr tjj d}n\tj sy t jtj }|yt|txr|j dd}|syt|}|jjdsydt_t!|j"j d dgd }|rt%|d k7ry|jj'd d }|syt)j*d|x}r|j-\}}ny|dk(s |dk(s|dk(rt.j0}nP|dk(s|dk(s |dk(s|dk(rt.j2}n+|dk(s|dk(rt.j4}nt.j0}t7|t8j.j:syd|vr%|j |j<d|ddg} n|j |ddg} | sy|t?| j@k(rdt_!| t_"y#t$rtjdYywxYw)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_hashro)r<r)#requestrrheadersrur-ujsonrwrrIrrrTrrsharelink_access_requestr rrr0rrgroupsrrtrxryrr CmfEntityrrDr|sharelink_access_grantedsharelink_access_obj) rojson_resr7 hash_paramobj_keyrrrobj_codervrs r%_check_sharelink_accessrsS||x(##I.||  {{7<<0H   8T*Hx||GR/H  5/C 88  y )"&A#))$(("6q9J ZA-hhnnS!"%G FPPuP"\\^(5H-]1J&& T X-Y1F(VaJa$$ Y (e"3NN &&  i!5!5 6 hmm)"6"6!7q C$(*:#;=mm$8H1ImJ S++,,%)"!$ U    \ ]  s#II?>I?c|t_|r8|tjk(t_|tjk(t_tjS)uh!!! Эта функция не меняет контекст, только инициализирует.)r_current_personanonymous_usercurrent_user_is_anonymoussharelink_anonymous_user#current_user_is_sharelink_anonymous)persons r%set_current_personr s?A &,0@0@&@#06!:T:T0T-  r&ct|dd}|dk(r |jStjsy||St dt j tjy)NrFAIL_recursionz#Warning!!! Lazy Calc Current Personr]) rrirbrhr3r= print_stackrdstdout)r!cps r%current_personr s\ ($ /B !!!    ~  /0 szz* r&c@ tjstjj dg}|jst j jj5ddl }ddl |j|jzdjfdtdD|_|jddd|jt_tjS#1swY.xYw#t $rt#j$dwxYw)Napp_keyrrrc3@K|]}jywr)choice)rEralphabetsecretss r%rGzapp_key..& s.[Aw~~h/G.[s zapp.app_key() error)rrrrrurrjrk disable_aclstringr ascii_lettersdigitsrKrangesaverrIr)r!rrrrs @@r%rr s{{//33I;3GH##XX%%113$!"%33fmmCH')ww.[QVWYQZ.['[H$MMO $#**CK ;;$$ /0 s%A%C=)AC1C=1C:6C== Dct|dd |jS tjs9tjj ddtj t_tj|_|jstjjdd}|j tjj ddtj |_|jsstjjj5tjj!|j"|_dddt%j&|j)|jS|jS#1swYExYw#|j)wxYw#t*$rt-j.dwxYw) N_anonymous_userzanonymous@evateam.ruTr<include_deletedrzcreate-anonymous-user-locktimeoutzapp._anonymous_user() error)rrrrrjrurkrrlockacquirerrjrkr system_datacreate_anonymous_userridd commit_all_dsreleaserrIrr! redis_locks r%rr4 st&-9###"""("2"2"6"6+T00#7#2C  #22##!,,-IST,UJ     %'-'7'7';';/44(<(6$++))557i/2/T/TUYUgUg/h,i$$&""$###t### ii ""$ 78 CBF58A)F !/FF ,F5 F5FF F22F55 Gct|dd |jS tjs9tjj ddtj t_tj|_|jstjjdd}|j tjj ddtj |_|jsstjjj5tjj!|j"|_dddt%j&|j)|jS|jS#1swYExYw#|j)wxYw#t*$rt-j.dwxYw) N_sharelink_anonymous_userzsharelink-anonymous@evateam.ruTrz$create-sharelink-anonymous-user-lockrrz%app._sharelink_anonymous_user() error)rrrrrjrurkrrrrrrjrkrrcreate_sharelink_anonymous_userrirrrrrIrrs r%rrT st0$7C---,,,2,<,<,@,@14,,-A-.C )*-)F)F&--!,,-S]^,_J     %171A1A1E1E94442F26.55))55709<9h9h ..:060$$&""$---t---00 ""$ AB rc^t|dd |jS tjj ddt j |_|jstjjdd}|j tjj ddt j |_|jsstjjj5tjj!|j"|_dddt%j&|j)|jS|jS#1swYExYw#|j)wxYw#t*$rt-j.dwxYw) N_test_guest_userztest-guest@evateam.ruTrzcreate-test-guest-user-lockrrzapp._test_guest_user() error)rrrrjrurrkrrrrrrjrkrrcreate_test_guest_userrirrrrrIrrs r%test_guest_userrv slt'.:$$$ & 0 0 4 4($,,!5!.$$!,,-JTU,VJ     %(.(8(8(<(<0$44)=)6%,,))557k030V0VW[WiWi0j-k$$&""$$$$t$$$ kk ""$ 89 sCA3F A)E78/E+'E7F  F +E40E77F  F F,c>tjjSr)rr get_settingsrjs r%global_settingsr s  # # 0 0 22r&ct|drt|dd |jStjj ddg|_|jS)N _global_varaccount_sync_statusaccount_sync_lastr)rrrr CmfGlobalVarrurjs r% global_varr sUt]#mT(J(V**..7LNa6b.cD   r&c |jtjddtjddf}|j|d}t d|zt |d|dD]\}}|j d}tjj|jjtjd d}t d |||j|jd z fztj|j|jj!}|rt d |z|j j#D] } t | ||d} | r.t%d | D} t dt'| | d z fzt%d|D} t d| d z zy)NFzz T) cumulativez Top %s linesrrz#%s: %s:%s: %.1f KiBiz %sc34K|]}|jywrsizerEstats r%rGzdisplay_top.. s/499/z%s other: %.1f KiBc34K|]}|jywrrrs r%rGzdisplay_top.. s0d 0rzTotal allocated size: %.1f KiB) filter_traces tracemallocFilter statisticsr3 enumerater=r`seprKrr0linenor linecachegetlinestripformatsumr) snapshotkey_typelimit top_statsr,rframerlinellotherrtotals r% display_topr s%%5"AB5+.'H##H#=I .5 ! 6E!2A6  tq!66;;u~~33BFF;BC@A $%,, D0@AB C  >DDF  (T/ "..'') B "I   ef E /// "c%j$+%>>? 0i0 0E *edl ; ! K!!%%DJJs?X?X%Y!JJ$J7;Aq||F+T 1;M;*+M+ &*+--M, '/0}}M+ ,%%6 6F$(!##**6+@+@+N+N+PQ$(!##**6+@+@+K+K+MN+/(##**6+@+@+D+DJ]+D+^_!!--/ , d + ,    5 ;" , ,-s7AH&>#H!D9H&H-H&H&H# H&&H/)forcelevelc8tj}ttdds|s|r|!t|tr4tt |}n#|rt j }nt j}tj}t t|tjz dzd}t t|tjz dzd}tjdijdt}|jdd}|jdd} |jd d} tjjd } tj d | d |d |d d |d| d| d|| z| zdd g|} t j"|ddj%d| Dtjt_ t'tj|z dz} | dkDrt j"|dd| dyyy)Nrcrlrro select_countselectrr%insertmr-z(+z)mszs zu zi rr@rAc32K|]}t|ywrrC)rEparts r%rGzdebug.. s*G3t9*GrHzPROF debug funcion got ms)r1rrbrrDrIINFOrcroundr debug_start debug_nowrurTr}r" request_idlogrKr)rrmessagesdebug_strrrscscsscuscirparts debug_ends r%rJrJ syy{Hvw%%  %%/ LLEMMEiik sQ]]*d2A6 7 sQ[[(D0!4 5 UU?B ' + +NDF CffXq!ffXq!ffXq! LL  S ! LL  A3b3 C53%r#bsS(9;       E4*G*G!HIiik X-t34 q= KKt'>yk%L M 938r&c<tjjd}tjj dra|r_t t |j}|j tdry|j ds|j dryytjj drytjj d stjj dry tjj d s>tjj dstjj drytjj d ry tjj dryy)Nrn/files/ servicedesksd_api/docs/rppub_api /servicedesk/api/api/pub//auth/r /with-contextsystemdeny)r}r~rurrrDrr~)referer referer_paths r% set_api_scoper s"oo!!),G||y)g8G,112  " "mo%6k#B C  " "8 , 0G0G 0R    0   )W\\-D-DY-O   )W\\-D-DX-NRYR^R^RiRijsRt   *   1 r&c*tjdk(ryttj tj t jfr<}nt(jNj>r6t=t(jNt(jNj><}n8t(j@jBrt=t(jNd=}|| z d>kDr t(jd?|| z tjjd@xs@tjjdAxstjjdB}dC}|r|jPj4t(_(t(jNrJt(jNj>t(_+t(jNjD t(_)n"dt(_+|jF t(_)dt(_,t|n|s|r_t(jH}tKt(jjrt(jL}dt(_*dt(_,t|n%dt(_,tt(jNt(j8xsqtjjdDxsOtjdEk(xs9tjjdFxstjdGvxstjjdHxstjjdIxstjjdJxstjjdKxsztjdLk(xsdtjjdMxsBtjjdxr9tjj7dNdOk(xrtjPdPk(xstjjdQxstjdRk(xstjjdSxstjjdTxrtjPdPk(xsStjjdUxrtjPdPk(xs| xrAtjjdVxr tjRjUxs| xrAtjjdWxr tjRjUxstjjdXxrt(jPxsXtVjYtjxs1tjjdYxrt(jP}t(jZ}t(jN}|} tjj]|| z d>kDr t(jdZ|| z |s|ryt(jtd[k(rc|s(t(jNr t_| St_| S|j`s|jFst j2sqt_St(jNr|s t_| Stjd-k(rE|rC|jFs6t j2s%|j`r t#d\St#d]S|s t_d^S|jFst j2s t_d_St(jXr t_St(jXstctd`dr{|ry|jFrl|} tjdjgst#tidaS|| z d>kDr t(jdb|| z tjjsJdt_|} tm|| z d>kDr t(jdc|| z t(jxrX|} t(jxjo}|| z d>kDr t(jdd|| z |r|Syy#1swYxYw#1swY[xYw)fuJ Должны вернуть Response or None Особенности поведения: В случае web запроса: - response - view не выполняется, сразу отправляем response - None - выполняем view - Exception(в т.ч. и abort) - обработчик выводит трейс клиенту Системный контекст(shell, celery, socket, other with cmf_context): - None, Response - нет разницы - Exception - прерывает выполнение. OPTIONSNrrF run_pytest1r1)choicesr0123456789abcdef)rc6tj|zSr)r_nowoffsetrs r%z before_request..i s)9&)A Ar&c6tj|zSr)r_dater*s r%r,z before_request..k s+;F+C!Cr&Tz/memOKz"Wait first_request_init lock (pid=)z!Got lock first_request_init (pid=zStart first_request_init (pid=zDone first_request_init (pid=z%Already done first_request_init (pid=>qwertyuiopasdfghjklzxcvbnmQWERTYUIOPASDFGHJKLZXCVBNM0123456789rrz X-Eva-Token AuthorizationzBearer token)api_token_hashrRrzAuth API Token(z ...): hash=z , person=z6Invalid API token: request.headers=%s, request.args=%szInvalid API token text/plainrC /pub/webhookrzauth/not_authorizedr-next_url auth/signin?uUТребуется авторизация. Введите логин и пароль. session_token access_token)rr==filterruУчётная запись uQ заблокирована. Обратитесь к администраторуu заблокирована.rZuo заблокирована за неактивность, обратитесь к администратору)r\)rg?z-PROF before_request get auth and session got z /pub/pub_apiz/docsz/sharectjjdxstjjdS)Nrm /socket.io/)r}rrr;r&r%is_allow_publicz'before_request..is_allow_publicV s2 LL # #H - 6||&&}5 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/rz/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)r}methodallrfirst_request_init_donefirst_request_init_skiprbrfirst_request_init_lockr+r,rrcmf.util.cmfutilr check_db_lockrrirbefore_requestrrbrhflags remove_filesr`rarutestr1rr%rrrKrsave_only_data_hackalertnoterr is_guest_user is_anonymousr\is_system_contextrrdisable_notify import_modesession_tab_id component_idinteractive_shellrrrapi_args api_kwargsr api_scoperrhack_session_need_commitrrrrr)rFr.relaxed_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_notifiesrjscache_timeliferrrrTEXCOM_ENABLE_GROWCACHE_HACKrr r acquired_locksacquired_locks_shacquired_lock_timignsrmfulltext_search_headlinesfulltext_search_debug_labelr#project_perm_browse_cache%project_perm_timetrackerhistory_cacheshow_bg_progressbarapi_hack_fieldsrJ new_acl_idapi_license_required license_disable_user_count_hooks backbone_synccurrent_save_objects csp_noncerCmfDeferredJob init_context CmfAccessListrhrrrr$rrr app_init_aclapp_init_project_permissionWHATSAPP_MESSENGER_URLspawn_messenger_socketio_clientWHATSAPP_WEB_SOCKETspawn_whatsapp_socketio_client CSP_ENABLEDsampler~rr"rj hash_tokenrkrIrr CmfWebhookget_token_personauth_base_hrefrcheck_sso_redirectr redirectrFcookies CmfSession from_token cmf_commitCmfAuthfrom_jwtIS_AUTHORIZATORrrYrrZrjwt_is_supportrservicedesk_allow_auth_guestsjwt_is_match_orgrRrrrr remote_addr CmfPlugin check_secret STATIC_URL_RErri setup_contextreject_responser]rrFlicense_ui_accessr~prepare_plan_cache_doneprepare_plan_cachetfa_check_two_factor)r1r% auth_person real_auth api_tokenr5r:rqserr_msgprof_str<r=_filteris_force_publicrC anon_personis_allow_without_authrrs @r%rNrN$ sE~~"  ' ''  ' ''##   ( ( K LL/II J K2O %%'AAMAGAN ZZ^^L )S 0AF&AKKKAM777#5;>)*557 +-0035--24.2+7 }AFG? }ANO/ P4ggfmm,lnpqr KI||w'7<<+B+B9+M OO'' 6 ++O?AeGfG ++O< **>:  & 1 1 < <] K AFAI))-2* ^^,,\:AF 66.._6>>3E3EAFFLLL^L^3E3_I%%i 66ffll((AG$ -/G!**..gcF_F_.`K4QWWI>OPG ,,GG:;;L;L:MMijk#'K[*?@[EdEd <[=N=N'>w'GkFL\L\LiLiLk1 F2#"kw||'>'>w'GkFL\L\LiLiLk3 F6||&&{3?7 F8""7<<09 F<||&&'89EaggAH A AfG &&( v# HRYIYHZ[\ 1  vv&w//"7+ +,,[5K5KTZTjTj"$ $  w''  5KTZTjTj  ( (l, ,f& & JKK  # #F,B,BNOO    ""wv|T'J{_j_u_ufG$$668=?"3> BCCv#%FtvPWGWFXYZ  & &&*#& 6G c ! GGCDFWDTCUV W yy& II * * , 6G c ! GGEdfwFVEWX Y H m  K KF P Ps $AT<;D5AU T<AUU AUcgdg}tjdk(r|jgdtjj |}|r|j |Sy)N)disabledr>Fr)servicedesk_supportr>T)r@)rr_rrCmfAuthOpenIdPluginrulogin_redirect)r:ropenids r%rr sU()G{{h:;  ' ' + +7 + ;F $$X..r&ctjdk7stjdk7r`t j dtjtj tjtjtjtjjds2tjjdstjdk(rt|xsddd Sttj}d |i}|rt|d ||d <t|}d}|s t|}|sDtjdk(rt!t#d|}nt!t#d|}t%||S)NrrzJRequest reject access: path=%s, auth=%s, login=%s, api_scope=%s, person=%srBrr9znot authorizedr6r7r8r: auth_errormessagerzservicedesk/auth/signin?r;)r}rrr_rIrrrrrrr r7rr rrrrF)rskip_ssor:paramsrrs r%rr s+||&!++*A X LL!&&!''1;;8I8I K LL # #M 2||&&w/||~-3#3S|TT%h'  '< ( 'F9  v  "8,A{{h& 011I"NO 01bTBCr&cTtjttyr)rr emit_eventsemit_server_eventsr;r&r%commit_with_eventr' sMr&c |r it_ytjdsytjjD]\}}d|vrd|dvr|dj d|drkt j jj|d}|r=|jD]*}|dj|jj,td|d|d|jdd  it_y) Nrbrelation_persons__DEFERRED_all_relation_personsr is_changed-rr-rprivate) namespacer)rrbrurrCrrjrk get_obj_by_idall_relation_personsrrrr ) only_cleanrrrps r%emit_list_applyr/ s  55 ++##% o3  $)JcRdNe)e " # * *+L M4yhh&&44SY? 557C./66qttzzBCS%6$78#SVSZSZ[aclSmn oAKr&c (|jD]\}}|D]}|d}|d=t|d}|d=|dj} tj |tj |tj |t|ts!|j|g|di|d |d i|d r1|d d k(s)|d |d <|j|g|di|d |d i|jd rT|drOd |ddvr|j|ddd d|ddvr!|dddD]}|j||D]} t| tjjr.t d| d|d|d|| jj } n t#| } | |d <|j|g|di|d |d iy#t $r"}t d|d|d|d|Yd}~d}~wwxYw)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)rrrrhrirr3rrPrzrrrrrrrrD) event_dictmsgevent_param_list event_paramrr  emit_kwargsruser_id event_personevent_persons_strs r%emit_events_dictrB s!+!1!1!3,q ++ qK'8MO, O <=MO,%h/446K  3 ;' ;' mX6" ""3pV)<p pWbcnWop6";v+>)+K&1&&9 F#" ""3pV)<p pWbcnWop~~l+v&-V1DQ1GG%))+f*=a*@AW*XY)[-@-CC'26':1'=>P'Q7G)--g67!. q lCJJ,@,@AuwCvDDEFIEJJKLWKXXYZeYfgh(4(=(=%(+L(9%&7 F#" ""3pV)<p pWbcnWop qC+ q,q hijhkk{}J|KK[\i[jjxyDxEFG s ?G&& H/H  Hctdy)Nrdelay)emit_events_with_delayr;r&r%rrr s #r&c(|r it_yddl}tjdsyi}|jtjD];}|j dstj|||<tj|==t |y)Nrrcproject_notify)rrcrrurr)rrrcrs r%emit_project_eventsrv sx 55 !Myy)% >>* +!"!5M# $%]#r&ct||r it_ytjdxsiit_rrfd}t j |yr t yy)uЗапускаемся в контексте, но отправляем в отдельном таске вне контекста, после паузы, чтобы не держать запрос.rNrccFtjtyr)r+rr)rrcsr%emitterz'emit_events_with_delay..emitter s LL  ] +r&)rrrcrur+r,r)rrrrcs` @r%rr sZz*EE/*0bMAO ,  W ' r&c|r gt_ytjdxsg}gt_|D]S\}}tjd|d|tj j |tj|Uy)Nrdzemit_server_events: r) rrdrurJrrrgrhri)rrdr'r-s r%rr ssEE/*0bMAO&:  &wir$89w 4(89:r&cBtjit_yr)rrollback_all_dsrrcr;r&r%rollback_purge_eventr sAOr&c|r gt_ytjdgD]7}tjj |s#tj |9gt_y)NrP)rrPrur`rrrC)rrs r%apply_deferred_remove_filesr sNEE."-  77>>( # IIh  ANr&ctjr/tjj tj|yy)uСессия может быть продлена через SSO, надо продлить куку Args: r (response): ответ браузеру в котором обновляем куки N)rrrrset_session_tokenrs r%update_cookiesr s(  yy((A6r&cJtjrtjj dstjj dr3dt j dt j d|jd<ydt j d|jd<yy)Nz/servicedesk/auth/rz-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:;)rbrr}rrrr~r~)rHs r%set_csp_headersr s  << " "#7 8GLL    % % 'O //LLNOOOs 3B  Bcttddk7rytjjj 5t jj}t jj|d}|jdddt jjdg}|r |j|jgddgdgd gfD]+}|gd g}t jj|gd  -t jjdg}|r |j|jt j jdg}|r |j|jt j"jdg}|r!|j|jyy#1swYSxYw) Nrz /opt/eva-appr)rr)order_by) cache_action=rOR)rrr) cmf_modelrCmfTask) json_filterjson_entry_point json_action func_name json_datar?)rrbrrjrkrrr create_dummy_taskrudelete_dummy_task save_prepare_load_perm_fields CmfTriggerrry CmfComment CmfNotify)dummy_task_data dummy_taskr_frcrs r%rr sv}%7    % % '' ..::<^^''?4+@'A $$&' TF+A  -t5RTs.tu/ 0b1}~ TF+A  v.A  tf-A   7''s AG  G*ct|y)Nr) cmf_rollbackrs r%teardown_requestr5 s 9%r&c |rtjsy|"|rtjntj}t j d|d|d|d||||tj k(ry|rFdjtj}t j d|t||t jvr t jj|yy) Глобальная функция для оповещения фронта о предупреждениях :param msg: :return: Nzcmf_alert: msg=z abort= debug_only= devel_only=rrzcmf_alert Stack: )rbrcrIWARNINGrrrJr@rKr= format_stackrrSr)rrr devel_onlyr stack_strs r%rr< s&,, }#(gllGG#x *m } EUGS*V5F5F1F"G IIi4467  $YK01C   !'' sr&c |rtjsy|tj}tj d|d|d||||tj k(ry|tjvr tjj|yy)rNzcmf_note: msg=r r!r") rbrcrIrrrJr@rTr)rrr%rs r%cmf_noter(V s{&,, } GGom }Mj] ;5GI*V5F5F1F"G !&&  cr&r-r)rrrr c|st} dtvrtt_t |dk(r=dtj xr$tj jjxsdig}t|dtk(rgdtvrtj|dd<nd|dd<tj xr$tj jjxsd|dd<t||||}tj|||d<d } d D]} |j| sd } n| rtd t|s)tj g}| st!d tg} |D]f} t#| t$j&j(r&| j+| jjM| j+t-| h| |d<tj|dtjj/|g} || vr| j+|yy#t$r }Yd}~yd}~wwxYw)NrcrrprZrr)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 )rrrTrcrrrrrrrZrhrirr3localsrrrrrrrD setdefault)rrrrr r"r#r event_paramsmuted muted_debtrr event_lists r%r r k s2   ! #"fAO 4yA~$a&6&6&T1;K;K;N;N;T;T&\X\]^ DG} q ()(8(8DG$ %(*DG$ %*+*:*:*Xq?O?O?R?R?X?X*`\`Q&'T&IDQLJJ|$1L! Ep >>* %E     STZT\S]^_ ))*  ~EG~HI J%8 lCJJ$8$8 9  $ $\__%:%: ;  $ $S%6 7 8 %6L! JJ|O,-++C4J:%,'&_ sH77 I I c|rdj|nd}|rdnd} |rdnd} dj| ||| g} |r ddlm} | } tj| dtjtj }|r|j \}}|r |j }|j }|j}|rR|rPtjd | tjd |tjd |td | |g}|r#|j||j|n|j|xs||r|j  z |Sy)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Произошла ошибка при вызове r;) rr1 subprocessPopenPIPE communicatert returncoderIerror RuntimeErrorr)commandsudorwaitseparate_out_and_err do_decodedo_raisemeasure_runtime timeout_cmd_sudo _redirectcmdr1 popen_startprocessouterrerrcoders r%run_bash_commandrJ sM9@$++G4SKH#E+I > E E    C F s$&0oo&0oo7G &&(S **,C**,C$$ x MMRTW X MM, , MM, ,!UVYUZ[\ \i  JJsO JJsO JJszc "  JJtvk) * r&c(tjtj}t j}|j |j |j|}tj|j}|d|}|S)ua Подписываем токен сертификатом :param jwt: :return: r*) rrrrsa_private_keyr r%rsignbase64 b64encodert)jwtsignerdigestrMrs r%rsa_sign_pack_jwtrS sp ^^C// 0F ZZ\F MM#**, ;;v D   D ! ( ( *D E4&/C Jr&c*ddd}tjtj|j j }tjtj|j j }|d|S)uD Создаем токен :param payload: :return: RS256JWT)algtypr*)rNrOrhrirrt)payloadheaders r% create_jwtr[ su U +F   djj0779 : A A CFtzz'299;<CCEGXQwi  r&c"tjS)u2 Текущая версия :return: )rb CMF_VERSIONr;r&r%cmf_get_versionr^ s   r&ch|tjvr tjj|yy)ux Удаления файлов после коммита транзакции :param filename: :return: N)rrPr)rs r%cmf_remove_filer` s' q~~% h'&r&ctjsytjjdrydtjjdtj }t jjj|}|rSt jjj|t|jjddyy)Nfield_options_list DEFERRORS_rrz
)rrrrrrZrrrrurxrrtr) redis_keyr8s r%_deferred_errors_checkre s <<||12Q^^../q1A1A0BCI LL   " "9 -E  !!),%,,.((v67 r&ctjjddtjd}|t j z }dtjjdtj}tjjj|}|r|jdz|z}n|}tjjj||y)NruLОшибка в after_request, после выполнения метода z rcrz )rrrrrr=rBrrrZrrrurtr)rrrdr8s r%_deferred_errors_savergsJJ% XYZYeYeXffj kC9   !!CQ^^../q1A1A0BCI LL   " "9 -E  )C/LL9e,r&ctj|ddlm}|jj dt |jdr|jjdt tdr@tjr0t5|jjddddn|jjd|jjdt |d r|j j#d|j$j'dt)dt+dt-dt/dt1dgt_y#1swYxYw) NrrrTr(apply_deferred_hide_closed_task_notifies)rollbackrgCmfStat)rr cmf.includerrapply_deferred_notify_messagesrr rjrrg cmf_contextCmfAuditapply_deferred_audit CmfFullSearchapply_deferred_dirtyrlapply_deferred_statsr!apply_deferred_comment_audit_listapply_deferred_jobsrrrrrf)rrs r%rr&s0y)" 33t3Dv~~HI???Nq./A4Q4Q ] @ OO 0 0$ 0 ? @ @ ,,d,; --->vy!++t+< 7747H4(4(d+$'40!#A @ @s E??Fc<tj|rtj}ddlm}t j 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 <gt_tj&|d<gt_tj(|d<gt_t+|j-}|rat/j0t2tj4j6tj8tj:tj<|fi|tjtj|z dkDr$t?dtj|z yyy)NrrirlrmrergrkrhrjrircrbrdrPrf{Gz?z PROF cmf_commit after_hooks got ) rrr1rmrrrrrlrmrergrkrhrjrircrbrdrPrfanyrr+r,cmf_commit_after_requestrrrZrr_r3)rrrrafter_request_params need_spawns r%rr@s))+&'') ";<;U;U78%'"EFEiEiAB/1,676K6K23 ">?>[>[:;(*%ABAaAa=>+-(454G4G01 121A1A-.>?>[>[:;(*%01_-,-KK[) 01_-/0~~^,;<;U;U78%'"-4467  LL11>>3D3DaFVFVXYXdXdfgfqfq% ?)= ?  99; 4 ' 4TYY[75J4KL M (Yr&ctdtj}t5 ttj j |tjjj|t_ |t_ |t_|t_|t_|t_|t_| t_| t_| t_| t_| t_|t_|t_|t_|t_tj8j;t=tj>drtj>jAtjBjEtjFjItjJjMtOt=tdrtjPjStjTjWtYt[|t]t_tajbtj|z dkDr-tjedtj|z dddy#tf$r}ti||d}~wwxYw#1swYyxYw)NzRun cmf_commit_after_requestrrjrlrrxz"PROF cmf_commit_after_request got )5r3r1rorrrjrurrrrkrrZrr_rlrmrergrkrhrjrircrbrdrPrfrrnrr rjrprqrrrsCmfOrmColumnHistoryapply_deffered_history_columnsrvrlrtrrurrrrrrrJrrg)current_user_idrZrr_rrlrmrergrkrhrjrircrbrdrPrfafter_request_prof_strs r%rzrzrs () IIK +*  v//33OCGGKKLmLm3n o-A %AL#AK)AA &3UA 0$7A !,GA )/MA ,"3A -A ,GA )+AO#AK+AO)AN)AA &    ; ; =v~~&PQGGI OO 0 0 2  5 5 7  & & E E G  !vy)335    ? ? A  ! " 5  ' )    yy{22T9>N > ""r&cddlm}t|}|jr$|j dj r|dz }|j ddddd}|||z}t|S)NrrrMrdayrrrrrrs r%start_of_monthrsl1t$J ||~&---557# ##!AST#UJ/77K ; r&c@t|}|jr$|jdjr|dz }|j dddddt |z}|t dz}|tdz }|j dd dd }t|S) Nrrrrr)monthsrrrr) rrrrrrrrr)r+rrstart_month_localnext_month_locallast_day_localrs r% end_of_monthrst$J ||~&---557# #++!A[\+]+F34(=+BB% q(99N&&Br!QR&SI 9 r&cddlm}|jr$|jdj r|dz }t |}|j dddddd}|||z}t|S)Nrrryrmonthrrrrr)rLrrrrrrrrs r% start_of_yearrsn1 ||~&---557# t$J##!1Q\]#^J/77K ; r&c t|}|jr$|jdjr|dz }|j ddddddt |z}|j dddd dd}t |S) Nrrrrr rr)rrrrrrr)r+rrstart_year_localend_year_locals r% end_of_yearrst$J ||~&---557# "**!TUcd*e*623%--BBRPR[\jk-lN > ""r&rr:ctjjj}|j}||S|j|j |S|j|S)uPВозвращает datetime в локальной зоне сервера (aware). - Если base=None, берём текущее локальное время. - Если base naive, присваиваем локальную зону. - Если base aware, конвертируем в локальную зону. rG)rrrrGr)r local_nowlocal_tzs r%rrsa!!%%'224IH | {{||8|,, ??8 $$r&dtc|jF|jtjjj j}|j tj j S)unПереводит aware datetime в UTC (aware). Для naive сначала делает локальным.r)rGrrrrrr)rs r%rr sU yy ZZx00446AACJJZ K ==**.. //r&c"eZdZdddZdZdZy)roNcTtjd|_||_||_y)Nr)rtest_request_contextctxinit_views_and_dspreprocess_request)r!rrs r%r zcmf_context.__init__'s$++O<!2"4r&cddlm}|r td|jj |j rt tj|jrtjyy)Nr)has_app_contextu;Контекст нельзя включать дважды) rrrr __enter__r start_viewsrinit_dsrr)r!rs r%rzcmf_context.__enter__,sX)  YZ Z   ! ! M JJL  " "  " " $ #r&c |r t|n td|jj|||y#|jj|||wxYw)NrT)r)rrr__exit__)r!excrr=s r%rzcmf_context.__exit__7sG 5s+t, HH  c5) 4DHH  c5) 4s ;A)FTr9)r1r/r=r rrr;r&r%roro&s5 %5r&roc 8gd}tj|Dcgc],}tjtj d|d.c}}|D]\}}}|j tj d}|jds9|D]}|jds|jds&|jd r8d jd |jdD}tj|d z|jd d zd tjddttjddttjddttjddtt!ycc}w)N)z cmf/viewsz cmf/modulescommonmodulesz custom/commonzcustom/modulesr-T) followlinksrz/viewsz.pyz.pycz __init__.pyr*c3&K|] }|s| ywrr;)rErs r%rGzstart_views..Ks*NA1*Nsr)packagerE)r) view_funcz/distz/static/staticz,/plugins//static/plugins_static) itertoolschainr`walkrbrrrrrKr0 importlib import_modulerr2rapp_before_run)r search_dir search_iterdirnamedirnames filenamesrr5s r%rrAswfK//%$'  6%%&a |4$G$'(K)4f$9//&"4"4b9   H %% f%%e,0A0A&0IS[SfSfgtSu"%((*NgmmC6H*N"NK++K#,=s@STU@V,V`d+e ffS6[A+f T%KCN^juv/$'s1Fcyrr;r;r&r%rr]sr&c <|jdd||d<||d<ttjj|d<tj |d<tj |d<tj|d<tjj||gy) N countdownrr"r#g_current_user_idg_acl_admin_modeg_component_idg_session_tab_id) r,rDrrracl_admin_moder[rZrhr)jobr"r#r8s r%schedule_deferred_jobras {A&GFOGH#&q~~'8'8#9G  "#"2"2G  !G "#"2"2G W~.r&c |r gt_ytjsytjdttjdtjD]\}}|jdi|gt_y)Nz Schedule z deferred job(s)r;)rrhrJr apply_async)rrr8s r%rvrvosp   GGiA//011A BC++# W"'"#Ar&c\d}tjrtj|dgyy)Nci}tjjddrdtji}t j tj||y)NSOCKETIOr namespacesr~)r`rarurbORG_NAME whatsapp_sioconnectrrs r%messenger_connectz:spawn_messenger_socketio_client..messenger_connect|sH ::>>*d +v/GV::(2G  Er&z /whatsapp)r)rbrr+r,)rs r%rr{s)E$$ &K=A%r&chtjtjtj yr)r+r,whatsapp_go_siorrbrr;r&r%rrs LL((&*D*DEr&cddl}tjddtjdtj |j tjtj dddy)Nrr@uYПодключаемся к удаленной отладке config.REMOTE_DEBUG_SERVER=z config.REMOTE_DEBUG_PORT=TF)r5stdoutToServerstderrToServersuspend)pydevd_pycharmrIrrbREMOTE_DEBUG_SERVERREMOTE_DEBUG_PORTsettrace)rs r%cmf_pycharm_debugrsh LL  ''-'A'A&B $V%=%=$> @A F66V=U=Ufj+/@r&c Nttjtjt t t j t t t j dztjjd}t|}t|S)Nrguid)issorg_nameiatexprjti) rTrbrrrDrr1rrrr[rS)rYrPs r%gen_eva_app_tokenrsiv"OO3tyy{+,3tyy{R/0199?? G W C S !!r&urir-crddlm}tjrtjdk(rJt t j |d}|jdg}|jdi}||i|}n|}ddd d |_t|}t|d <|j|tj| } | jd k7r(td|d| jd| j | j}|rd|vrtd|t"j%||S)Nr)rFalserGr"r#r?r7r$)z Content-typeAcceptzContent-Encoding eva_app_token)r-u9Не удалось отправить запрос, url=z, status_code=z, res=r8u(Сервер вернул ошибку: )requestsrrbEVA_ACCOUNT_USErrrrur~rrpostrhrirErcontentrrJ) rr-rrG method_args method_kwargsresultrr7rs r%call_eva_accountrs=  ! !V%;%;w%Fh8hhvr* 2. 6 6 I%7*(/1  !"3%( 1 3_ffStzz$/f0 ??c !KC5P^_b_n_n^oouvywBwBvCDE E g'FvhOP PGGFO Mr&eva_db_upgrade_runningc|sttj}ttdst j tjjt|ddstdty)uЗапускается перед миграций БД. Информирует приложение, что не следует открывать транзакции.rT)exrz Cannot lock N) rDr`r$rrrrrr _DB_LOCK_KEYCmfError)rs r%app_db_upgrade_startrs^ BIIK  8W %))+ >>  lEbT  Bl^455 Cr&cJtjjty)uЗапускается после миграций БД. Информирует приложение, что можно продолжать работать.N)rrrxrr;r&r%app_db_upgrade_stoprs NN,'r&cd}d}tj}|rS|rtj|z |kDr|rtdty|dz }tjd|rSy)uПроверяем не заблокировано ли использование БД, если заблокировано, то можем дождаться разблокировки.c trtjtz dkDr[ttdstj tj jta tjatS)uWиспользуем кеш 1sec, чтобы часто не ходить в редисrr) _db_lock_cache_tsr1rrrrrrur_db_lock_cacher;r&r% check_lockz!check_db_lock..check_locksX!TYY[3D%D$I8W-&113%^^// =N $ r&rz DB locked FrT)r1rrr)r<r raise_errorr rnstarts r%rMrMsk  E IIKE , e+w6L>:;;   1  , r&cddl}tjrd}ntj}|j|d|j }|j |y)Nrrcz:%(asctime)s %(process)d %(name)s %(levelname)s %(message)s)rr)logging.handlersrbrc LOG_LEVEL basicConfigrsetLevel)rIrrs r% init_loggingr(sK ||  Ge,hi W   F OOEr&ctjxsd}|jds|dz }|r>tjrdtjnd}|dtj||S|S)Nr-rrz://)rb BASE_HREFrEXTERNAL_PORT_HTTPSr)full_urlprotocolrv port_specs r%r~r~so  'CI   c "S 8>8R8Ra2234XZ 3v/ {9+FF r&c*tjrtj}n[|r@|rd}n=tjrdtjnd}dtj|}nd}|tjxsdz }|j ds|dz }|S)Nzhttp://127.0.0.1:8080rrrr-)rbAUTH_SERVER_URLr+rr*r)absoluteinternalrvr.s r%rrs ** 3 @F@Z@Za : :;<`b &v&7 {C IV%%,,   c "S r&r)rr)FFrrr<)rF)FFNN)FNN)TNTFFFF)T)Trr;)TT)Fhttps)rrrIrrdfcntlr`rrNrrvr3r1r= threadingrrrpathlibrtypingrr urllib.parserr r r werkzeug.utilsr r+rr Crypto.Hashr Crypto.Signaturerrrrflask.json.providerrwerkzeug.exceptionsrrrrmcmf.data_providersrrcmf.system_datardateutil.relativedeltarrrLrrrrrNobjectrPrBr1rbrrrhrirrrcache_in_project_roler rpc_modelsclean_attributesrJrILockrKall_models_meta SECRET_KEY secret_keyflask_socketiorPrQrrRrrDrtrprwrrrrrrrengineio.payloadrmax_decode_packetsrraruuwsgidecoratorsr9rrcrrrrrxr4ryrr REDIS_DB_IDREDIS_DB_ID_TIMER errorhandlerrrJregister_error_handlerprivate_key_pathpublic_key_pathCrypto.PublicKeyrL import_key read_bytesrLrsa_public_keyrkrrrrrrrrrpropertyrrrrrrrrrJrrNrrrrrrrrrrrrrrF after_requestrrrrrrr(r rJrSr[r^r`rergrrrzrrrrrrrrrrrorrrrvrrrrrTrcache_notify_scheme_rulecache_cmf_security_levelcache_person_notify_optcache_cust_field_config_schemecache_email_listrrrrrrrMr(r~rr;r&r%r_s   0" ==$  '!3-) 0- fg E,B qDvqDj/6,6* HDF4F4FG c " *+ &'#"#,inn."". @@F) H*8E%E%P ! "G.G.T./3 J % oSoSb  ::>>#$( ,,V\\*  -77>>&$$'99: f  #55 6+!&&(..*+ )D9&67**+i7v))*]: (#..)9)D)D)FGC'(B(B(DEC"_ D  & $@D>!/Q}-Q!.1Q#+,D#EQ "?3Q!.1Q/Q7#Q3#?3Qj)Q=>< tNB,QQh/"J&-q`$ $(*: 702 M     "O$N&& 4**-Dy`b8(vin5:2j  !( 8 -$4/Nd:z    s  #  ##$ 3    # ## %(9(9: %x?P?P %0!!0h&7&70 5568  /  BF@ "3 "#T4 "! %'"(  6( 6 I>++s ($YY!