oi ddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddlZddl Z ddl Z ddl Z ddlZddlmZmZddlmZddlmZmZddlZddlmZmZmZmZddlmZddlZddlZddl Z ddl!m"Z"ddl#m$Z$dd l%m&Z&m'Z'm(Z(dd l)m*Z*dd l+m,Z,dd l-m.Z.dd l/ddl0m1Z2ddl3Z-ddl4Z4ddl5m6Z6ddl m7Z7ddl8m9Z9m:Z:e4jvdZ<Gdde=Z=dZ>Gdde?Z@Gdde*ZAe=eBdeCjZEeAeEeE_FdeE_GdeE_HgeE_IdeE_JdeEjd<ieE_KdeE_LieE_MdeE_NdeE_OdeE_PejeE_RieE_SeCjeE_UieE_VddlWmXZXmYZYddlZm[Z[ddl\Z\d e]fd!Z^ieE__e^eE_^da`d"Zadd#ZbGd$d%ZcecZdGd&d'ZeeeZfefeE_fe@Zgdd(lhmiZid)ei_jdd*ZkGd+d,ZlelZZejjd-rdd.lompZpepd/Zqe[eCj0Zse[eCj0ZtejjeCjd1zrAeweCjd1z5ZxexjjeC_{dddedeE_ddeE_|deE_}eEjed2ZeEjeeeeCjd3z ZeeCjd4z Zdd5lmZejr'ej ejeE_ejr'ej ejeE_gd6eE_d7ZGd8Zd9Zd:Zd;ZHdeE_deE_deE_d<Zd=Zd>ZeeGee_GeeGee_eeee_eeee_eeee_eeee_eeee_eeHee_Hd?Zeeee_d@Zeeee_ddAZddBZdddCdDZdEZeEj>dFZddGZddHZdIZddJZdKZdLZddMZddNZddOZdPZddQZdRZdSZdTZeEj\dUZdVZdWZdXZeEjfddYZddZZdd[Zd\dd]gd^d_Z dd`ZdaZdbZdcZddZdeZdfZddgZddhZdiZddje]fdkZddje]fdlZddje]fdmZddje]fdnZddje]fdoZddje]fdpZddje]fdqZddje]fdrZdsej*e jdte jfduZdve jdte jfdwZGdxdyZdzZd{Zdd|Zdd}Zd~ZdZdZdte]fdZde]defdZieE_ieE_ieE_ieE_ieE_ieE_dZdadaddZdZddZdZddZy#1swYxYw)N) OrderedDict defaultdict)Path)OptionalTuple)urlparseparse_qs urlencodequote) safe_join)SHA256) PKCS1_v1_5)Responseflashhas_app_context)DefaultJSONProvider) HTTPExceptionfields)*)base) relativedelta) timedelta)str_to_timedeltamake_prof_pointz^.*\.(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__1s $)&)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..decorator5s{{:t4H,,K%++C04Kg%K'$.&,qzz9 D  c8Q :' : (OHr')r"r:r9r;s``` r&routez Flask.route4s r')r2r0 __qualname__r!r= __classcell__)r%s@r&rr0s *r'rcb|r-tjddjd|Dyy)N%s c32K|]}t|ywrstr).0args r& zprint_debug..Hs%?3c#h%?)loggingdebugjoin)condr#_kwargss r& print_debugrOFs'  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:*rmrns obj:jshashzCmfCache.flush_all_obj: z recordsN) rOrcrdrerfrXrsrt startswithryrz)r"ror}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_definedvaluerEintfloatparserparse astimezoneutcreplacer4 ExceptionlistrUitemsboolhasattrrr2md5rwrj 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_rrBr)setgetattrmodels class_name__dict__rarrvendswithaddrrCmfRelationBasesimple_objects_id_recursive CmfM2MBaseCmfBackrefBaserelated_modelsrrLr) 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,rrrBr)rvaluesrrr isinstancerrrextendobjects_id_recursiverrrrrappendrLrr)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:)lenrcCACHE_MAX_OBJ_SIZE cmf_alertrXrrYrV)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)rrrXexistsrrYrVrv)r"rahkeysr~s r&_obj_dict_existszCmfCache._obj_dict_exists2s $C IISEl # $ ==#t}}##U+s4y8 [[ !~~))#.  !r'c|jrZ|jjd|}||jjd|S|jjd|S|jr|jj|Sy)NrrSrT)rXrvr[rYrV)r"r~rs r& _obj_dict_getzCmfCache._obj_dict_getDsy ==--##d3%L1C $$Z0J $$[1J [[>>%%c* *r'r inv_payloadc|d|S)N::r<)rrs r&%_jshash_invalidate_confirm_member_keyz.CmfCache._jshash_invalidate_confirm_member_keyQsK=))r' member_keyc(|jddS)Nrr)maxsplitr1)rs r&+_jshash_invalidate_confirm_member_key_splitz4CmfCache._jshash_invalidate_confirm_member_key_splitUsq11r'c<|r|n|jdd}d|S)Nrzjscache-invalidate-confirm-set:r)cache_idrset_keys r&"_jshash_invalidate_confirm_set_keyz+CmfCache._jshash_invalidate_confirm_set_keyYs('(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_eventrrrrrXsadd) r"msgs confirmations person_idinv_dictrrr confirm_lists r&r{z 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)rXr4rrrrsrem)r" confirm_dict sample_jshash key_cache_idrconfirms r&jshash_invalidate_confirmz"CmfCache.jshash_invalidate_confirmos}} 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_defferrXrsmembersrru)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)Nrroz#DEBUG_CACHE JSHASH: try invalidate z*DEBUG_CACHE JSHASH: try invalidate:jshash:invalidate:jshash:drnz*DEBUG_CACHE JSHASH: got invalidate:jshash:z#DEBUG_CACHE JSHASH: got invalidate utf-8rrrqupdater) cache_fieldscmf_modified_at cmf_viewed_atcmf_modified_by_idONLYFORUPDATESrr?z_obj_dict_mdel emit got sec)rXryr inmemory_delprofiler_invalidaterdr rOspoprsrvrurzziprwrxrUrLrtimer{rrKrYrV)r"raobj_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^,>#3r%)rXrrurYrWrv)r"namerr~s r&_invalidate_dict_getzCmfCache._invalidate_dict_getsl ==--((;tf)=>C7:; 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 rBc|jd\}}}|vr t|<|r|jd|y|jy)NrB) partitionrr)bind_and_fieldsbindrrrr~s r&bind_addzCmfCache.add..bind_add*sl.77.bind_add_recursive6s#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 )/osenvironrvrno_jscache_forcercJOB_DAEMON_DISABLE_CACHEr\r$profiler_redis_invalidated_keys_skiprcache_is_lockedrOrdcache_locked_byget_last_invalidate cache_lockscache_transaction_startrutilcmfutilget_model_by_namerrrrErskipcache_select_for_updater4rrrrrrcache_cluster_fields profiler_datar1rwrjrcache_store_error inmemory_addrrr r?)r"r~robj_type query_paramscache_inmemorylirj obj_modelrRobj_casewhere_pkrscopesc_fieldscope model_namebindidstr_objrNrs`` @@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*>* %);); !$$ $  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'cyNrrOrdrrXrvr"r}s r&rhzCmfCache.get_last_invalidateHr'cbt|jd|jt_y)Nz)DEBUG_CACHE TRANS cache_transaction_start)rOrd gen_time_usrrjrks r&rjz CmfCache.cache_transaction_startMs"DJJ KL$($4$4$6!r'cttjjtjjj dS)Nz%Y%m%d%H%M%S%f)rrrrrstrftimerks r&rzCmfCache.gen_time_usQs68$$(():):)>)>?HHIYZ[[r'cyr) rOrdrfrrXrrrirj)r"r}ls r& cache_lockzCmfCache.cache_lockTr'cyr) rrirrgrjrOrdrXr)r"r}tr_startlock_trs r& cache_unlockzCmfCache.cache_unlockerr'cyrrrs r&rgzCmfCache.cache_locked_byurr'cyNF) rgrrirvrjrOrdrXr)r"r}_cache_locked_byrjs r&rfzCmfCache.cache_is_lockedzsr'c<tdd}tj}tj}tj}t } | |j }|D]r} | |vrt || || <n|| j|| || D];} d| vr$| j| jdd+| j| =t|j| |j||jdD cgc]} | c} || d|ycc} w)NzCmfCache._do_invalidaterBrT) is_changed)r4r3r5inv_list) rrrrrrrr&rr1rra) r"rrr5r4 prof_point glob_inv_dict glob_inv_listrrrinv_vals r&_do_invalidatezCmfCache._do_invalidates$%>D   --5 >ffV *A %#&x{#3 a a '' 4#A; *'>LLs!3A!67LL)  * * ).1hh$h.G"H1"H    #Is= D 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) Nrrr3r4r5r,z_do_invalidate_deffer got r-z)_do_invalidate_deffer _obj_dict_mdel got zsec len=z0_do_invalidate_deffer _invalidate_dict_mdel got ) rrvr2rrr;rFrKrrr)r"strrrst_invalidate_dict_mdelends 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) NrHrz!DEBUG_CACHE start invalidate_ids rBxz invalidate:*rrm)matchro 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#rrqr+rrrc3BK|]}d|jywrNrurF query_keys r&rHz*CmfCache.invalidate_ids..!s! FiY%%'() Fc3BK|]}d|jyw)r#Nrrs r&rHz*CmfCache.invalidate_ids.."s" TI"9#3#3#5"67 Trc3BK|]}d|jywrr)rFrs r&rHz*CmfCache.invalidate_ids..#s >6V]]_%& >rzinvalidate_ids(, ): z): no keys found.)rarbrvrrOrdrrrXrtrr1rr&rrKrrecompilerLrurfindallrwrxrUryr{)r"r}idsr5invalidate_keys query_keysjshashesr|obj_id_by_query_keyid_rar~ inv_members inv_memberid_retuuid_re key_decodedrquery_jshashesrrrr8r 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: rB)rBrOrd)invalrKinvdr5rr"s r& _check_invalz8CmfCache.invalidate_ids_as_wrapper.._check_inval-sF,,U3D"&DJJ*=fXQugeW(UVr'rHDEBUG_CACHE start invalidate rBrrref=obj.id=)r4)r)rarbrvrrOrdr)r"r}rr5rrrs` ` @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) NrBz=cmfCache.invalidate(): ValueError: too many values to unpack(rTabortrrr) rBrrr1rrKrrOrdrQrrprv)rrK change_fieldsr invd_affectediri_fieldstail i_set_fieldstmpr5rr"s r&rz)CmfCache.invalidate.._check_invalOsr,,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)rrHrrB RelationCachezRelationCache.parent.id=)rrDrrruYDEV: 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)createryr&zref_new=zref_old=rr,zDEBUG_CACHE ivalidate: z not fields_have_changes--logical_deleterVr+uОшибка конфигурации моделей: cache_cluseter_fields может быть только по m2m и relation полямrFz where_m2m=zwhere_m2m_old=z where_old=uDEV: в методе ux не загружается is_dummy, что приводит к лишним инвалидациям кластераrzinvalidate got rN)1rrKr2 collectionsrrarbrvrrrOrdTRACEpdb set_trace parent_idrrrrrrrrrrrrroldnewrrrrrrorr load_fieldsrCmfTUUIDrcRAISE_LAZYLOADload api_methodrQrrp)r"rr5rQm2m_field_namerrrrsr_check_inval_done_do_invalidate_donerrrno_caching_fieldscluster_load_fieldsr{ cc_field_name cc_clustercluster_field_is_changedrs` ` @r& invalidatezCmfCache.invalidateLsL  *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)rVr4rWr)r"r~rs r&rjzCmfCache.dumpsasQ /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)r1rQrdrrkrlrmKeyErrorrin_memory_cacherurin_memory_cache_skip_modelsprofiler_inmemory_data_skiprr INMEM_CACHEprofiler_inmemory_data_missrv move_to_endprofiler_inmemory_data_hit)clsr~r}r model_cacherets r&rzCmfCache.inmemory_getps3YYs^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 TrrzInmemory cache error! key:z try_add:z exists:F)lastz"CmfCache:inmemory_add evicted key )rrr BaseModel dataclasses is_dataclassrrrrOrdr1rQrkrlrmr rrrurrrrr4popitem) rr~rrdetailr}r LRU_LIMITr evicted_keyrs r&rrzCmfCache.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)rOrQrdgeventspawn)datarNr,ras @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)Nrpinmemory_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)Nrpinmemory_cache_skiprinmemory_cache_skip_keysrr5s r&rz$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)Nrpr3rr2rinmemory_cache_miss_keysrr5s r&rz$CmfCache.profiler_inmemory_data_miss(s a'"&& ! 756AOO1 2 OO1 2a 7 2 q 645AOO0 1  ) ))@>@ :; OO6 7 > >s C *   rrreturnNrNNF)r&)=r2r0r>rVrWrXrYrdrrPROCESS_EVICTED_FLUSHr!rgrrrrrrrr staticmethodrErrrr{rr!r;r?rBrFrr/rrrervrhrjrrrrgrfrrrrr rj classmethodrrrr.on_server_eventr0rrrr<r'r&rQrQKsIH 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'rQceZdZdZy)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&rMzCustomJSONProvider.default?s "# 2 2FNNCDii#x001ZX]]5Szz==?S00}}&C0yy CyH> !   #**455s$BC C%C C C*%C*N)r2r0r>rMr<r'r&rDrD>s6r'rD) 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)rErcache_projectsrvr CmfProjectreadonly)rUprojects r&get_cache_projectrvqsgZJ  $$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)rapathrLrc PROJECT_DIRr isabsisfilerLr|flaskhelpers 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 запрещен!) rrr2ConnectionErrorrcCACHE_REDIS_FAILOWERREDIS_SETTINGS_MANAGERcheck_and_updater CmfAbortError)r"r#r$rr5s r&wrapperz/CmfRedisMemoryWrapper.fallback..wrappersxzz:74::qzz:DKFKK $$LMM ,,22.??@X@XYGs%AB 1BB r<)r5rs` r&fallbackzCmfRedisMemoryWrapper.fallbacks Nr'ctrNotImplementedErrorr"r#r$s r&rzCmfRedisMemoryWrapper.smembers!!r'ctrrrs r&rzCmfRedisMemoryWrapper.smembers rr'c8|jj|Srrrvr"r~s r&rvzCmfRedisMemoryWrapper.get""3''r'c8|jjyr)rclearrks r&rgzCmfRedisMemoryWrapper.flushdbs r'c8|jj|Sr)rttlrs r&rzCmfRedisMemoryWrapper.ttlrr'cD|jj||||||S)N)nxxxgtlt)rexpire)r"r~r2rrrrs r&rzCmfRedisMemoryWrapper.expires$%%c4B2"%LLr'cf|jj|d}||z }||j|<|Srr)r"r~amountrs r&r[zCmfRedisMemoryWrapper.incrbys4##C+ $ r'c&|j||Sr)r[)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)r2r0r>__doc__rRedisrrEr!rrrvrgrrr[rrrr<r'r&rrs7ekk7xPS}7 """"((  ((MM ((%%r'rceZdZdZdZdZdeefdZdedee jfdZ ddede fd Z ded e jfd Zd Zdee effd ZdefdZddefdZy)RedisSettingsManageruR Менеджер по управлению настройками Redis. rMcFtjd|_d|_y)Nzredis-settingsF)rJ getLoggerlogger _terminatingrks 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<)rrcrcopyr/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_cacherrgrrcommitr)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)NrrrrYTu&Неизвестный тип кеша)rrcrrrXrYr)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_DBrrrcrrrarbrvrsocketiostart_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)rcrrDEFAULT_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-sleepinforakillr&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)r2r0r>rrr!rrErrrrrrrrrrrrrr<r'r&rr8s'"x}"&C&HU[[,A&3D,J3J J2& (eD#I. (1C1&.#.r'r)Payloadr$ctjxsd}|jds|dz }|r>tjrdtjnd}|dtj||S|S)Nr.rrz://)rc BASE_HREFrEXTERNAL_PORT_HTTPSAPP_FQDN)full_urlprotocolrx port_specs r&rrso  'CI   c "S 8>8R8Ra2234XZ 3v/ {9+FF r'c^eZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZy)CmfSocketIOWrapperu Функционал: 1. Отложенная активация, после получания доступа к Redis ctd}tdtjd|d|_d|_d|_g|_g|_g|_ g|_ y)Nz socket.iorF)appcors_allowed_originsrengineio_loggerr) rrrcrdsocketio_kwargsrrlazy_on_handlerslazy_on_namespace_handlerslazy_init_apps lazy_runs)r" socketio_paths r&r!zCmfSocketIOWrapper.__init__s`(?+95 $'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<) r4rrr_make_redis_connect_paramsrRr_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)rrr r"s r&wrapz#CmfSocketIOWrapper.on..wraps%  ! ! ( ($(* r'r<)r"rr r!s``` r&onzCmfSocketIOWrapper.ons   r'c|jj||jr*td||jj |yy)Nz!CmfSocketIOWrapper: on_namespace )rrrr4 on_namespace)r"r,s r&r$zCmfSocketIOWrapper.on_namespacesD ''..w7 == 5gY? @ MM & &w / r'c|jj||d|jr.td|d||jj|i|yy)N)r#r$zCmfSocketIOWrapper: run rB)rrrr4runrs r&r&zCmfSocketIOWrapper.run s\    == ,TF!F8< = DMM  t .v . r'c<|jj|i|yr)rr{rs r&r{zCmfSocketIOWrapper.emits D+F+r'c|jj||jr*td||jj |yy)NzCmfSocketIOWrapper: init_app )rrrr4init_app)r"rs r&r)zCmfSocketIOWrapper.init_appsD ""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)r2r0r>rr!rr"r$r&r{r)r-rrrrrr<r'r&r r sM( -0 /,( Nu B ( G Sr'r SOCKETIO_WORKER)postforkc,tjyr)rrr<r'r&rrMs))+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:)coderA traceback descriptionapplication/jsonrz Unknown error)rJrrc PRODUCTIONrr get_responserFrArG format_excrHrirjr/ content_typerEjsonify status_codeset_cors_headers)r show_traceresponse response_datas r&handle_exceptionrT_s 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-000000000001rqzapp.system_person() error) rc AUTH_ENABLEDr system_personr CmfPersonrvcurrent_person_fieldsrrJrrks r&rsrssy      & 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_hashrq)rFr)#requestrrheadersrvr/ujsonrxrrJrrrUrrsharelink_access_requestr rrr1rrgroupsrr~rrrr CmfEntityrrErsharelink_access_grantedsharelink_access_obj) ryjson_resr8 hash_paramobj_keyrrsobj_coderwrs 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^) rrsrcrrr4rG print_stackrestdout)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)rFralphabetsecretss r&rHzapp_key..2 s.[Aw~~h/G.[s zapp.app_key() error)rrrrrvrrkrl disable_aclstringr ascii_lettersdigitsrLrangesaverrJr)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.ruTrFinclude_deletedrzcreate-anonymous-user-locktimeoutzapp._anonymous_user() error)rrrrrtrvrurrlockacquirerrkrlr system_datacreate_anonymous_userrsdd commit_all_dsreleaserrJrr" redis_locks r&rr@ 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)rrrrrtrvrurrrrrrkrlrrcreate_sharelink_anonymous_userrsrrrrrJrrs r&rr` 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)rrrrtrvrrurrrrrrkrlrrcreate_test_guest_userrsrrrrrJrrs r&test_guest_userr 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_settingsrks r&global_settingsr s  # # 0 0 22r'ct|drt|dd |jStjj ddg|_|jS)N _global_varaccount_sync_statusaccount_sync_lastr)rrrr CmfGlobalVarrvrks 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|]}|jywrsizerFstats r&rHzdisplay_top.. s/499/z%s other: %.1f KiBc34K|]}|jywrrrs r&rHzdisplay_top.. s0d 0rzTotal allocated size: %.1f KiB) filter_traces tracemallocFilter statisticsr4 enumeraterGraseprLrr1linenor 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)Nrdrmrrp select_countselectrr&insertmr.z(+z)mszs zu zi rrArBc32K|]}t|ywrrD)rFparts r&rHzdebug.. s*G3t9*GrIzPROF debug funcion got ms)r2rrcrrErJINFOrdroundr debug_start debug_nowrvrUrr# request_idlogrLr)rrmessagesdebug_strrrscscsscuscirparts debug_ends r&rKrK 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)Nrx/files/ servicedesksd_api/docs/rzpub_api /servicedesk/api/api/pub//auth/r /with-contextsystemdeny)rrrvrrrErr)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} |stj@j7d?}tj@j7d@}|r_tjBjE|\t(_'t(_<t(jzrEdt(_=tGdAn,|r*tjHjK|t(_'t(jNrut jLxrDtjHj7t(jNjPjNB}t jLr |s dt(_'t(jNrt(jNjPjNt(_(dCd+t(jNjPgg}tjj7|tj*-}dDt(jPdE} |ru|jPr&t(jdD|jPdFd}ntS|dGr|jTrdD|jPdH} t(j| d}n|r(tW|t(jNjXI}nt(jNjXr6tWt(jNt(jNjXI}n8t(jZj\rtWt(jNdJ}| tjjdKxs@tjjdLxstjjdM}dN}|r|jPjNt(_(t(jNrJt(jNjXt(_+t(jNj^ t(_)n"dt(_+|j` t(_)dt(_,t|n|s|r_t(jb}tet(jjrt(jf}dt(_*dt(_,t|n%dt(_,tt(jht(j8xstjjdOxsqtjdPk(xs[tjjdQxs9tjdqvxs$tjjdRxstjjdSxstjjdTxstjjdUxstjdVk(xstjjdWxsdtjjdXxsBtjjdxr9tj4j7dYdZk(xrtjjd[k(xstjjd\xstjd]k(xstjjd^xstjjd_xrtjjd[k(xsStjjd`xrtjjd[k(xs| xrAtjjdaxr tjljoxs| xrAtjjdbxr tjljoxstjjdcxrt(jPxsXtpjstjxs1tjjddxrt(jP}t(jt}t(jh}t?ded=d>} tjjw| |s|ryt(jtdfk(rc|s(t(jNr ty| Sty| S|jzss|j`set jLsStySt(jNr|s ty| Stjd8k(rE|rC|j`s6t jLs%|jzr t;dgSt;dhS|s tydiS|j`st jLs tydjSt(jXr tySt(jXsot}tdkdr]|r[|j`rNt?dld=d>} tj~jst;tdmS| tjs*dt_t?dnd=} t| t(jxr:t?dod=d>} t(jxj} | | r| Syy#1swY.xYw#t t f$rYwxYw#1swYxYw)ruJ Должны вернуть Response or None Особенности поведения: В случае web запроса: - response - view не выполняется, сразу отправляем response - None - выполняем view - Exception(в т.ч. и abort) - обработчик выводит трейс клиенту Системный контекст(shell, celery, socket, other with cmf_context): - None, Response - нет разницы - Exception - прерывает выполнение. OPTIONSNrrF run_pytest1r2)choicesr0123456789abcdef)rc6tj|zSr)r_nowoffsetrs r&z before_request..u s)9&)A Ar'c6tj|zSr)r_dater5s r&r7z before_request..w s+;F+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=>qwertyuiopasdfghjklzxcvbnmQWERTYUIOPASDFGHJKLZXCVBNM0123456789r rz X-Eva-Token AuthorizationzBearer tokenr!)rVexpiration_date last_used_atr)r is_revokedrrz%Expired API token: expiration_date=%sz Token expiredi text/plainrMr==)r\rFTfilterrzAuth API Token (new)(z ...): hash=z , person=z, type=z6Invalid API token: request.headers=%s, request.args=%szInvalid API token /pub/webhookrzauth/not_authorizedr.next_url auth/signin?uUТребуется авторизация. Введите логин и пароль.z#before_request.get_auth_and_sessionr$)track_ok_count session_token access_token after_hooks)rruУчётная запись uQ заблокирована. Обратитесь к администраторуu заблокирована.rduo заблокирована за неактивность, обратитесь к администратору)rf)rz /pub/pub_apiz/docsz/sharectjjdxstjjdS)Nrw /socket.io/)rrrr<r'r&is_allow_publicz'before_request..is_allow_public s2 LL # #H - 6||&&}5 7r'z/health_check/z/metricsz /auth/syncz /auth/signz/servicedesk/auth/signz/servicedesk/auth/invitez/servicedesk/auth/two-factorz"/servicedesk/auth/restore_passwordz/auth/two-factorz/auth/not_authorizedmoderootz 127.0.0.1z /crm/forms/z/manifest.webmanifestz /app/assets/z/forms/z/js/r"z/sso/z /helpdeskz/nolicense.htmlz*before_request.CmfAccessList.setup_contextrrru)Требуется авторизацияu-Доступ в раздел запрещен CmfLicensez before_request.license_ui_accessznolicense.htmlz!before_request.prepare_plan_cachez#before_request.tfa_check_two_factorr)z /auth/invitez/auth/restore_password)rmethodallrfirst_request_init_donefirst_request_init_skiprcrfirst_request_init_lockr-r.rrcmf.util.cmfutilr check_db_lockrrjrbefore_requestrrcriflags remove_filesrarbrvtestr2rr0rr rLrsave_only_data_hackalertnoterr is_guest_user is_anonymousrfis_system_contextrrdisable_notify import_modesession_tab_id component_idinteractive_shellrrrapi_args api_kwargsr) api_scoperrhack_session_need_commitrrrrr4rHr9relaxed_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_timignsrnfulltext_search_headlinesfulltext_search_debug_labelr%project_perm_browse_cache%project_perm_timetrackerhistory_cacheshow_bg_progressbarapi_hack_fieldsrK new_acl_idapi_license_required license_disable_user_count_hooks backbone_synccurrent_save_objects csp_noncerCmfDeferredJob init_context CmfAccessListrrrrrr&rrr app_init_aclapp_init_project_permissionWHATSAPP_MESSENGER_URLspawn_messenger_socketio_clientWHATSAPP_WEB_SOCKETspawn_whatsapp_socketio_clientuwsgicommonr<increment_uwsgi_restart_counter ImportErrorModuleNotFoundError CSP_ENABLEDsamplerrr#rt hash_tokenCmfAccessTokenrArJrrrVrrur CmfWebhookget_token_personauth_base_hrefrcheck_sso_redirectr redirectrPrcookies CmfSession from_token cmf_commitCmfAuthfrom_jwtIS_AUTHORIZATORrrcrrdrjwt_is_supportrservicedesk_allow_auth_guestsjwt_is_match_orgr\rrrr remote_addr CmfPlugin check_secret STATIC_URL_RErrs setup_contextreject_responsergrrWlicense_ui_accessrprepare_plan_cache_doneprepare_plan_cachetfa_check_two_factor)r2r0rr< auth_person real_auth api_tokenapi_token_hashrOrKrqserr_msgrrN_filteris_force_publicrT anon_personis_allow_without_authrrs @r&r_r_0 s~~"  ' ''  ' ''##   ( ( K LL/II J K2O %%'AAMAGAN ZZ^^L )S 0AF&AKKKAM777#5;>)*557 +-0035--24 5"BBD /3+7 }AFG? }ANOE" PJggfmm,lnpqr KI||w'7<<+B+B9+M OO'' 6 ++O?AeG !F\abJ ++O< **>:  & 1 1 < <] K AFAI))-2*u- ^^,,\:AF 66.._6>>3E3EAFFLLL^L^3E3_I%%i 66ffll((AG$ -/G!**..gcF_F_.`K4QWWI>OPG ,,GG:;;L;L:MMijk#'K[*?@[EdEd <[=N=N'>'HlVM]M]MjMjMl3 G4#"lw||'>'>'HlVM]M]MjMjMl5 G8||&&4@9 G:""7<<0; G>||&&:FqwwCJ A A!!MschiJ &&(L 1  vv&w//"7+ +,,[5K5KTZTjTj"$ $  w''  5KTZTjTj  ( (l, ,f& & JKK  # #F,B,BNOO    ""wv|T'J{_j_u_u()KSafgJ$$668=?"3> BCC L  & &&*#$%H#N   yy$%JC`ef II * * , H m K K|$%895" P" PsN $AV0CAWAV=6A"AWV0AV:V=AWWAWWAWWAWWAWcgdg}tjdk(r|jgdtjj |}|r|j |Sy)N)disabledrFFr)servicedesk_supportrFT)rH)rrprrCmfAuthOpenIdPluginrvlogin_redirect)rKropenids 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)Nr$r%zJRequest reject access: path=%s, auth=%s, login=%s, api_scope=%s, person=%srSr rJznot authorizedrIrDrErK auth_errormessagerzservicedesk/auth/signin?rL)rrrrprJrrrrrrr r8rr rrrrP)rskip_ssorKparamsrrs 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_eventrR sMr'c |r it_ytjdsytjjD]\}}d|vrd|dvr|dj d|drkt j jj|d}|r=|jD]*}|dj|jj,td|d|d|jdd  it_y) Nrsrelation_persons__DEFERRED_all_relation_personsr is_changed-rr.r private) namespacer )rrsrvrrDrrkrl get_obj_by_idall_relation_personsrrrr ) only_cleanrrrps r&emit_list_applyrZ 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#rr rrevent_current_personrruYDEV: INFO Кривой евент, в event_person попал объект, а не str: rB)rrrrirjrr4rrRr{rrrrrrrrE) event_dictmsgevent_param_list event_paramrr  emit_kwargsruser_id event_personevent_persons_strs r&emit_events_dictrm 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&rr s #r'c(|r it_yddl}tjdsyi}|jtjD];}|j dstj|||<tj|==t |y)Nrrtproject_notify)rrtrrvrr)rrrtrs r&emit_project_eventsr sx 55 !Myy)% >>* +!"!5M# $%]#r'ct||r it_ytjdxsiit_rrfd}t j |yr t yy)uЗапускаемся в контексте, но отправляем в отдельном таске вне контекста, после паузы, чтобы не держать запрос.rNrtcFtjtyr)r-rr)rrtsr&emitterz'emit_events_with_delay..emitter s LL  ] +r')rrrtrvr-r.r)rrrrts` @r&rr sZz*EE/*0bMAO ,  W ' r'c|r gt_ytjdxsg}gt_|D]S\}}tjd|d|tj j |tj|Uy)Nruzemit_server_events: r) rrurvrKrrrhrirj)rrur)r/s r&rr ssEE/*0bMAO&:  &wir$89w 4(89:r'cBtjit_yr)rrollback_all_dsrrtr<r'r&rollback_purge_eventr sAOr'c|r gt_ytjdgD]7}tjj |s#tj |9gt_y)Nra)rrarvrarrrD)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/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:;)rcrrrrrrr)rRs 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_datarG)rrcrrkrlrrrcreate_dummy_taskrvdelete_dummy_task save_prepare_load_perm_fields CmfTriggerrr CmfComment CmfNotify)dummy_task_data dummy_taskr_frcrs r&rr9 sv}%7    % % '' ..::<^^''?4+@'A $$&' TF+A  -t5RTs.tu/ 0b1}~ TF+A  v.A  tf-A   7''s AG  G*ct|y)Nr) cmf_rollbackr1s r&teardown_requestr3` 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: )rcrdrJWARNINGr rrKrJrLrG format_stackrrdr)rrr devel_onlyr stack_strs r&rrg s&,, }#(gllGG#x *m } EUGS*V5F5F1F"G IIi4467  $YK01C   !'' sr'c |rtjsy|tj}tj d|d|d||||tj k(ry|tjvr tjj|yy)r5Nzcmf_note: msg=r6r7r8) rcrdrJr rrKrJrer)rrr;rs r&cmf_noter> s{&,, } GGom }Mj] ;5GI*V5F5F1F"G !&&  cr'r.r)rrr r 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)Nrtrrqrkrr)r#r$rr rF) 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 )rrrUrtrrrrrrrkrirjrr4localsrrrrrrrE setdefault)rrrr r r#r$r event_paramsmuted muted_debtrr event_lists r&r r  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)shellrrfu6Произошла ошибка при вызове %sz STDOUT: %sz STDERR: %su4Произошла ошибка при вызове r=) rr2 subprocessPopenPIPE communicateru returncoderJerror RuntimeErrorr)commandsudorwaitseparate_out_and_err do_decodedo_raisemeasure_runtime timeout_cmd_sudo _redirectcmdr2 popen_startprocessouterrerrcoders r&run_bash_commandr` 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 b64encoderu)jwtsignerdigestrcrs r&rsa_sign_pack_jwtrisp ^^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+)rdrerirjrru)payloadheaders r& create_jwtrqsu U +F   djj0779 : A A CFtzz'299;<CCEGXQwi  r'c"tjS)u2 Текущая версия :return: )rc CMF_VERSIONr<r'r&cmf_get_versionrt!s   r'ch|tjvr tjj|yy)ux Удаления файлов после коммита транзакции :param filename: :return: N)rrar)rs r&cmf_remove_filerv)s' q~~% h'&r'ctjsytjjdrydtjjdtj }t jjj|}|rSt jjj|t|jjddyy)Nfield_options_list DEFERRORS_rrz
)rrrrrrkrrrrvryrrur) redis_keyrNs r&_deferred_errors_checkr{7s <<||12Q^^../q1A1A0BCI LL   " "9 -E  !!),%,,.((v67 r'ctjjddtjd}|t j z }dtjjdtj}tjjj|}|r|jdz|z}n|}tjjj||y)NruLОшибка в after_request, после выполнения метода z ryrz )rrrrrrGrLrrrkrrrvrur)rrrzrNs r&_deferred_errors_saver}DsJJ% XYZYeYeXffj kC9   !!CQ^^../q1A1A0BCI LL   " "9 -E  )C/LL9e,r'ctj|ddlm}|jj dt |jdr|jjdt |jdr|jjdt td rJtjr:ts0t5|jjddddn|jjd|j j#dt |d r|j$j'd|j(j+dt-dt/dt1dt3dt5dgt_y#1swYxYw) Nr1rrTr(apply_deferred_hide_closed_task_notifies)rollback"apply_deferred_update_task_projectrxCmfStat)rr cmf.includerr+apply_deferred_notify_messagesrrrrrrxr cmf_contextCmfAuditapply_deferred_audit CmfFullSearchapply_deferred_dirtyrapply_deferred_statsr*!apply_deferred_comment_audit_listapply_deferred_jobsrrrrrw)rrs r&r2r2Qs[y)" 33t3Dv~~HI???Nv~~BC9949H/0 ) )! ] @ OO 0 0$ 0 ? @ @ ,,d,; --->vy!++t+< 7747H4(4(d+$'40!#A @ @s F;;Gcxtj|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 <it_tj&|d<gt_tj(|d<gt_tj*|d<gt_t-|j/}|rat1j2t4tj6j8tj:tj<tj>|fi|tjtj|z dkDr$tAdtj|z yyy)Nrrr}r~rvrxr|ryr{rzrrtrsrurarw{Gz?z PROF cmf_commit after_hooks got )!rrr2rrrrrr}r~rvrxr|ryr{rzrrtrsrurarwanyrr-r.cmf_commit_after_requestrrrkrrpr4)rQr prof_strafter_request_params need_spawns r&rrqs0))+&'') ";<;U;U78%'"EFEiEiAB/1,676K6K23 ">?>[>[:;(*%ABAaAa=>+-(454G4G01 121A1A-.>?>[>[:;(*%?@?]?];<)+&01_-,-KK[) 01_-/0~~^,;<;U;U78%'"-4467  LL11>>3D3DaFVFVXYXdXdfgfqfq% ?)= ?  99; 4 ' 4TYY[75J4KL M (]r'cRtdtj}t5 ttj j |tjjj|t_ |t_ |t_|t_|t_|t_|t_| t_| t_| t_| t_| t_|t_|t_|t_|t_|t_tj:j=t?tj@drtj@jCtjDjGtjHjKtjLjOtQt?tdrtjRjUtjVjYt?tj@drtj@j[t]t_|tatctejftj|z dkDr-tjidtj|z dddy#tj$r}tm||d}~wwxYw#1swYyxYw) NzRun cmf_commit_after_requestrrrrrrz"PROF cmf_commit_after_request got )7r4r2rrrrtrvrr rrurrkrrpr}r~rvrxr|ryr{rzrrtrsrurarwr+rrrrrrrrCmfOrmColumnHistoryapply_deffered_history_columnsrrrr*rrrrrrrrrKrr})current_user_idrkrrpr r}r~rvrxr|ryr{rzrrtrsrurarwafter_request_prof_strs r&rrs  () IIK .-  v//33OCGGKKLmLm3n o-A %AL#AK)AA &3UA 0$7A !,GA )/MA ,"3A -A ,GA )-IA *+AO#AK+AO)AN)AA &    ; ; =v~~&PQGGI OO 0 0 2  5 5 7  & & E E G  !vy)335    ? ? Av~~&JKAAC  ! " 5  ' )    yy{22T9>N > ""r'cddlm}t|}|jr$|j dj r|dz }|j ddddd}|||z}t|S)Nrr,rMrdayrrrrrrs r&start_of_monthr"sl1t$J ||~&---557# $$1QTU$VK 0 88K ; r'cJddlm}t|}|jr$|j dj r|dz }|j ddddd}|tdz}|tdz }|j d d dd }|||z}t|S) Nrr,rrrr)monthsrrrr) r]rrrrrrrrr)r6rrrstart_month_localnext_month_locallast_day_localrs r& end_of_monthr.s1t$J ||~&---557# "**qq1Z[*\(=+BB% q(99N&&Br!QR&SI,V44I 9 r'cddlm}|jr$|jdj r|dz }t |}|j dddddd}|||z}t|S)Nrr,ryrmonthrrrrr)r]rrrrrrrrs r& start_of_yearr=sn1 ||~&---557# t$J$$1!!Aa]^$_K 0 88K ; r'cddlm}t|}|jr$|j dj r|dz }|j dddddd}|j ddd d dd}|||z}t|S) Nrr,rrrr rrr)r6rrrstart_year_localend_year_locals r& end_of_yearrHs1t$J ||~&---557# !))qqSTbc)d%--BBRPR[\jk-lN#&6v&>>N > ""r'rr<ctjjj}|j}||S|j|j |S|j|S)uPВозвращает datetime в локальной зоне сервера (aware). - Если base=None, берём текущее локальное время. - Если base naive, присваиваем локальную зону. - Если base aware, конвертируем в локальную зону. rI)rrrrIr)r local_nowlocal_tzs r&rrTsa!!%%'224IH | {{||8|,, ??8 $$r'dtc|jF|jtjjj j}|j tj j S)unПереводит aware datetime в UTC (aware). Для naive сначала делает локальным.r)rIrrrrrr)rs r&rrcsU yy ZZx00446AACJJZ K ==**.. //r'c"eZdZdddZdZdZy)rNcTtjd|_||_||_y)Nr$)rtest_request_contextctxinit_views_and_dspreprocess_request)r"rrs r&r!zcmf_context.__init__js$++O<!2"4r'cddlm}|r td|jj |j rt tj|jrtjyy)Nr)ru;Контекст нельзя включать дважды) rrrr __enter__r start_viewsrinit_dsrr)r"rs r&rzcmf_context.__enter__osX)  YZ Z   ! ! M JJL  " "  " " $ #r'c |r t|n td|jj|||y#|jj|||wxYw)Nr1TrP)r2rr__exit__)r"excrrGs r&rzcmf_context.__exit__zsG 5s+t, HH  c5) 4DHH  c5) 4s ;A)FTr;)r2r0r>r!rrr<r'r&rris5 %5r'rc 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/modulesrmodulesz custom/commonzcustom/modulesr.T) followlinksrz/viewsz.pyz.pycz __init__.pyr+c3&K|] }|s| ywrr<)rFrs r&rHzstart_views..s*NA1*Nsr)packagerV)r* view_funcz/distz/static/staticz,/plugins//static/plugins_static) itertoolschainrawalkrcrrrrrLr1 importlib import_modulerr3rapp_before_run)r search_dir search_iterdirnamedirnames filenamesrr6s r&rrswfK//%$'  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&rrsr'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) rBrErrracl_admin_moderlrkryr)jobr#r$r9s r&schedule_deferred_jobrs {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<)rryrKr apply_async)rrr9s r&rrsp   GGiA//011A BC++# W"'"#Ar'c\d}tjrtj|dgyy)Nci}tjjddrdtji}t j tj||y)NSOCKETIOr  namespacesr)rarbrvrcORG_NAME whatsapp_sioconnectrrs r&messenger_connectz:spawn_messenger_socketio_client..messenger_connectsH ::>>*d +v/GV::(2G  Er'z /whatsapp)r)rcrr-r.)rs r&rrs)E$$ &K=A%r'chtjtjtj yr)r-r.whatsapp_go_siorrcrr<r'r&rrs LL((&*D*DEr'cddl}tjddtjdtj |j tjtj dddy)NrrAuYПодключаемся к удаленной отладке config.REMOTE_DEBUG_SERVER=z config.REMOTE_DEBUG_PORT=TF)r?stdoutToServerstderrToServersuspend)pydevd_pycharmrJrrcREMOTE_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) rUrcrrrErr2rrrrqri)rorfs 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)rFalserXr#r$rIrDr%)z Content-typeAcceptzContent-Encoding eva_app_token)r/u9Не удалось отправить запрос, url=z, status_code=z, res=rNu(Сервер вернул ошибку: )requestsrrcEVA_ACCOUNT_USErrrrvrrrpostrirjrOrcontentrrK) rr/rrX method_args method_kwargsresultrr8rs r&call_eva_accountr)s=  ! !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) rErar&rrrrrr _DB_LOCK_KEYCmfError)rs r&app_db_upgrade_startr0 s^ BIIK  8W %))+ >>  lEbT  Bl^455 Cr'cJtjjty)uЗапускается после миграций БД. Информирует приложение, что можно продолжать работать.N)rrryr.r<r'r&app_db_upgrade_stopr2s 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_tsr2rrrrrrvr._db_lock_cacher<r'r& check_lockz!check_db_lock..check_locksX!TYY[3D%D$I8W-&113%^^// =N $ r'rz DB locked FrT)r2r/r.r)rRr raise_errorr7rostarts r&r^r^sk  E IIKE , e+w6L>:;;   1  , r'cddl}tjrd}ntj}|j|d|j }|j |y)Nrrdz:%(asctime)s %(process)d %(name)s %(levelname)s %(message)s)rr)logging.handlersrcrd LOG_LEVEL basicConfigrsetLevel)rJrrs r& init_loggingr?8sK ||  Ge,hi W   F OOEr'c*tjrtj}n[|r@|rd}n=tjrdtjnd}dtj|}nd}|tjxsdz }|j ds|dz }|S)Nzhttp://127.0.0.1:8080rrrr.)rcAUTH_SERVER_URLrrrr)absoluteinternalrxr s r&rrGs ** 3 @F@Z@Za : :;<`b &v&7 {C IV%%,,   c "S r'r)Fhttps)rr,)FFrrr>)rF)FFNN)FNN)TNTFFFF)T)Trr=)TT)rrrJrrefcntlrarrdrrwrIr2rG threadingrrrpathlibrtypingrr urllib.parserr r r werkzeug.utilsr r-rr Crypto.Hashr Crypto.Signaturerrrrrflask.json.providerrwerkzeug.exceptionsrrrrcmf.data_providersrrcmf.system_datardateutil.relativedeltarrr]rrrrrrOobjectrQrDr2rcrrrirsrrrcache_in_project_roler rpc_modelsclean_attributesr[rZLockr\all_models_meta SECRET_KEY secret_key metrics_cacheflask_socketiorRrSrrTrrErvrrryrrrrrrrengineio.payloadrmax_decode_packetsrr rbrvuwsgidecoratorsrCrrdrr rrrzr5r{rr REDIS_DB_IDREDIS_DB_ID_TIMER errorhandlerrrTregister_error_handlerprivate_key_pathpublic_key_pathCrypto.PublicKeyrV import_key read_bytesrbrsa_public_keyrurrrrrrrrrpropertyrrrrrrrrrKr)r_rrrrrrrrrrrrrrP after_requestr rrrr3rr>r r`rirqrtrvr{r}r2rrrrrrrrrrrrrrrrrrrrrrUr)cache_notify_scheme_rulecache_cmf_security_levelcache_person_notify_optcache_cust_field_config_schemecache_email_listrr.r6r5r0r2r^r?rr<r'r&rqs    0" ==$  '223-) 0> fg E,B oDvoDf/6,6* HDF4F4FG c " *+ &'#"#,inn."". @@F) H*8E%E%P ! "G.G.T./3 J % sSsSj  ::>>#$( ,,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,ppf/"J&-q`$ $(*: 702 M     "O$N&& 4**-Dy`b8(vin5:2j  !( 8 -$@1Nh=@     s   #  ##(  3      #   # # %(9(9: %x?P?P %0!!0h&7&70 5568  /  BF@ "3 "#T4 "! %'"(  6( 6a?++s 7$Y##Y-