U d@svddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z ddlmZddlmZmZmZmZddlmZddlZddlZddlZddlZddlmZddlmZddlmZm Z dd l!m"Z"dd l#m$Z$dd l%m&Z&dd l'Tdd l(m)Z*ddl+Z%Gddde,Z,ddZ-Gddde.Z/ddZ0Gddde"Z1e,e2de3j4dZ5e1e5_6de5_7de5_8ge5_9ge5_:ge5_;ge5_de5_?de5j3d<ddl@mAZAmBZBddlCmDZDddlCmEZEddlFZFddd ZGGd!d"d"ZHeHZIe eJZKd#d$ZLd%d&ZMdd'd(ZNeOe3d)rte3jPd*d+d,krte3jPd*QZReRSd+eFjTfeReI_FeUjVWd-reIjFdkreXd.e5d/e3jYd0d1ZZeOe3d)re3jPd*d+d,kre3jPd*d2Z[e3jPd*Wd3rd4e3jPd*d3d5e[Z\eDe\d6d0d7Z]e]eZd8<nrd9Z^d:e3jPd*krFe^d;e3jPd*d:d<7Z^e^e3jPd*d=7Z^e^d;e3jPd*Wd>d?7Z^e^d@e[7Z^e^eZdA<ddBl_m`Z`dCe`_aeAfeZZCeEe3jYdDZbeEe3jYdDZceUjdee3j4dErefe3j4dEZgeghie3_jW5QRXeOe3d)rRe3jPd*d+d,kr(e/eIjFdFZkn(e3jPd*d+dGkrHe/ddHZkneXdIne/ZkeIe5_IdJdKZlelZmemjndddLdMdNZoe5peXdOdPZqe5reXeqee3j4dQZsee3j4dRZtddSlumvZveserevwesxe5_yeterevwetxe5_zdTdUdVdWdXdYdZd[d\d]d^d_d`dadbdcddge5_{dedfZ7dgdhZ|didjZ}dkdlZ~dmdnZ8dodpZdqdrZdsdtZee7ee_7ee7ee_eeee_eeee_eeee_ee~ee_~ee~ee_ee8ee_8dudvZeeee_dwdxZeeee_dd{d|Zdd}d~Ze5jddZdddZdddZddZddZddZddZdddZddZddZddZddZe5jddZddZddZe5jddZe5jdddZdddZd@ddgdddZddZdddZddZddZddZddZGdddZddZdddZddZddZddZddZdd„ZedÜddńZeedƜddȄZdS)N) OrderedDict defaultdict)Path)urlparseparse_qs urlencodequote)Celery)SHA256) PKCS1_v1_5)abortResponse) JSONEncoder) HTTPExceptionfields)*)basecs$eZdZfddZddZZS)Flaskcstj||dSN)super__init__selfargskwargs __class__ ./cmf/app.pyr%szFlask.__init__c sfdd}|S)Ncsndd}|j}|dd}|dkr6d|}n}|dkrP|d|j}j|||ft||S)Nendpoint.index/)pop __module__split__name__ add_url_ruleprint)fr module_pathZ module_nameurloptionsrulerrr decorator)s zFlask.route..decoratorr)rr0r/r1rr.rroute(sz Flask.route)r(r& __qualname__rr2 __classcell__rrrrr$s rcOs|rt||dSr)r*)Zcondrrrrr print_debug:sr5c@sbeZdZdZdZdZdZdZdZdZ dJddddZ ddZ dd Z d d Z d d ZdKddZddZddZddZddZeeedddZeedddZedLddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Zd*d+Zd,d-ZdMd.d/Z d0d1Z!d2d3Z"d4d5Z#d6d7Z$d8d9Z%d:d;Z&dd?Z(d@dAZ)dBdCZ*dDdEZ+dNdFdGZ,dHdIZ-dS)OCmfCacheNFreturncCsBt|_t|_||_||_|jr>|jdd|jdddS)Nstat_hitr stat_miss)dict cache_objcache_invalidateredis_dbmemoryincrby)rr>r?rrrrHszCmfCache.__init__cCs>ttjp |jdtjd|jr*|jnt|_t|_ dS)NzCmfCache.flushdb!!!file) r5configDEBUGsysstderrr>flushdbr;r<r=rrrrrGRs  zCmfCache.flushdbcCsttjp |jdtjdtt}|j}|jj dddD]p}t|jd|dtjd|dd  }|j |}|d kr~q:t |}|d }|d |||<||q:|||d S) u)Инвалидируем весь jscachezCmfCache.flush_jscache!!!rAz obj:jshash:*countz"CmfCache.flush_jscache invalidate z!!!Ncurrent_person_idjsver)r5rCrDrErFrr;r>pipeline scan_iterdecodegetpickleloadsdeleteexecuteemit)remit_msgpipekeyjshashjsresjspersonrrr flush_jscacheZs    zCmfCache.flush_jscachecCsttjp |jdtjdd}|j}|jjdddD]"}|drFq6|d7}| |q6| ttjpn|jd |d tjdd S) u+Инвалидируем весь obj cachezCmfCache.flush_all_obj!!!rArzobj:*rIrJs obj:jshashzCmfCache.flush_all_obj: z recordsN) r5rCrDrErFr>rOrP startswithrUrV)rrKrYrZrrr flush_all_objls   zCmfCache.flush_all_objcs0ddl|}fddttjjdddddkrXtjjS|D]}|d|}q\d|kr|dt|d}t | D]*\}}|dkrq|d|d |}q|j rd |dd d |}| d d }n|d |}t |j d||S)Nrc shddl}ddlm}t|tjjr4|jr0|j}nd}d}t|t t t frt|t r|dddkrz.|j |}||j}|jddd}|}Wn"tk r}zW5d}~XYnXt |}nt|tr|D]}||d}qnt|tr.|D]2\}}||}|r"|d |}q|d}qn6|dkr>d }n&d t|jd t|}|S) Nr)timezonez...Z20)secondZ microsecond,:Nonez todo2:obj:)Zdateutil.parserdatetimerb isinstancecmfrCmfType is_definedvaluestrintfloatparserparseZ astimezoneutcreplace Exceptionlistr;itemstyper(md5rSdumps hexdigest)valdateutilrbresZval1evk_all2strhashlibrrr~s<        &zCmfCache.hash.._all2strrLZ0781|idz|id:rgzHASH:iz|md5: zDEBUG_CACHE HASH:)rrzrorkrCmfDatenowencoder|sortedrxrDrur5)rprefixrrsr}rZrrrhashzs&+2 &z CmfCache.hashc Cs|dkrt}|s|S||jtt|j}|jD]}t||jsJq8t |t jj rzt||jd}|r|j ||dq8t |t jj t jjfr8t||jd}|r|D]}|j ||dq|D]"}d|jd|j}||qq8|S)N)rref__)setaddrgetattrmodels class_namervalueshasattr issubclassrkCmfRelationBasesimple_objects_id_recursive CmfM2MBaseCmfBackrefBaserelated_models) robjrZmodelZ field_clsZ field_valuerel_obj rel_modelrefrrrrs,    z$CmfCache.simple_objects_id_recursivecCs|sgS|jjg}|jddD]}t|tjjrB|||jt|tjj tjj fr|jrz|jD]}|||qd| D]"}d|jd|j }| |qqtt|}|S)u Собираем ид связанных обьектов 2 уровня для настройки инвалидации :param obj: :return: Trmrr)rrnrrjrkrrextendobjects_id_recursiverrrrappendrwr)rrrfieldrrrrrrrs    zCmfCache.objects_id_recursivecCst|}t|tjkrd}t|tjjs4t |r@d|}nJ|rt|t rt|dtjjsnt |drd|dj dt|d}t dt|d|dd d S|jr|jd ||dS|jr||j|<dSdS) Nrc, r[]uRDEV: Слишком большой объект для кэширования — u байтT) debug_onlyFobj:)rSr{lenrCZCACHE_MAX_OBJ_SIZErjrkr BaseModel dataclassesZ is_dataclassrwr cmf_alertr>rr?r<)rrZr}Zstr_valZdetailrrr _obj_dict_sets&    zCmfCache._obj_dict_setcGsrt}|D]}|d|q |jrD|jj|t|kr>dSdSn*|jrj|D]}|j|sNdSqNdSdSdS)NrTF)rrr>existsrr?r<rR)rkeysZhkeysrZrrr_obj_dict_existss zCmfCache._obj_dict_existscCsX|jr>|jd|}|dk r.|jdn |jd|S|jrP|j|SdSdS)Nrr9r:)r>rRr@r?r<rrZrrrr _obj_dict_gets  zCmfCache._obj_dict_getr[ inv_payloadcCs|d|S)N::rrrrr%_jshash_invalidate_confirm_member_key$sz.CmfCache._jshash_invalidate_confirm_member_keyZ member_keycCs|jdddS)Nrr_)maxsplitr'rrrr+_jshash_invalidate_confirm_member_key_split(sz4CmfCache._jshash_invalidate_confirm_member_key_splitcCs |r|n |dd}d|S)Nrgzjscache-invalidate-confirm-set:r)cache_idr[set_keyrrr"_jshash_invalidate_confirm_set_key,sz+CmfCache._jshash_invalidate_confirm_set_keyc Cstt}|D]Z\}}td||d|gd|D]0\}}|dr8||j|d|||q8q|jr|D]\}}|jj |f|qzdS)Nz invalidate-)room event_personsjshash:r[) rrwrxcmf_emit_eventr`rrrr>sadd) rZmsgsZ confirmations person_idinv_dictr[rr confirm_listrrrrW3s  z CmfCache.emitcCsb|jr^|r^|dd}|j|d}t}|D]}|||d|dq,|jj|f|dS)Nrrr_)r>rrwrrsrem)rZ confirm_dictZ sample_jshashZ key_cache_idrZconfirmrrrjshash_invalidate_confirmBs   z"CmfCache.jshash_invalidate_confirmcs.jr*|}fddj|DSdS)Ncsg|]}|qSr)rrQ).0memberrHrr Ssz;CmfCache.jshash_invalidate_confirm_list..)r>rsmembers)rrrrrHrjshash_invalidate_confirm_listNs    z'CmfCache.jshash_invalidate_confirm_listc Cs|sdS|jr|jjdd|Di}|D]}|jrPd|krPtd|t|jd||jd|}|r.t|jd||jrtd||D]}|d }|jrd|krtd |d |t|jd ||jd |} | dkrqt | } | r| d} | |kr.t || <|dkrZd t dd|j ddD} nd} | dd|d|d| } | || |<|jd |q|jd|||q.n.|jr|D]}||jkr|j|=qndSdS)NcSsg|]}d|qS)rrrrZrrrr[sz+CmfCache._obj_dict_mdel..rKz#DEBUG_CACHE JSHASH: try invalidate z*DEBUG_CACHE JSHASH: try invalidate:jshash:zinvalidate:jshash:z*DEBUG_CACHE JSHASH: got invalidate:jshash:z#DEBUG_CACHE JSHASH: got invalidate utf-8z"DEBUG_CACHE JSHASH: do invalidate  z)DEBUG_CACHE JSHASH: do invalidate jshash:rrMupdatercSsg|]}|dkr|qS))Z cache_fieldscmf_modified_at cmf_viewed_atZcmf_modified_by_idr)rrrrrrzsT) is_changedZONLYFORUPDATESrN)r>rUrDrr5rrQrRrSrTr;joinrrrWr?r<) rrrZobj_idactionrXrZZinvjsr[r\r]Zchanged_fieldsrrrr_obj_dict_mdelWsT         zCmfCache._obj_dict_mdelc Cs|jrN|j6}|D]\}}|jd|f|q|W5QRXnD|jr|D]2}||jkr||j|||qX|||j|<qXndSdSN invalidate:)r>rOrxrrVr?r=r)rrrYrZrrrr_invalidate_dict_msets  zCmfCache._invalidate_dict_msetcCsH|jr.|jd|}|r*dd|DS|S|jr@|j|SdSdS)NrcSsg|]}|dqS)r)rQrrrrrsz1CmfCache._invalidate_dict_get..)r>rr?r=rR)rnamerrrr_invalidate_dict_gets zCmfCache._invalidate_dict_getc Cs|jrT|j<}|D]$\}}|r|jjd|f|q|W5QRXnJ|jr|D]4\}}|D]&}||j|gkrn|j||qnqbndSdSr) r>rOrxrrVr?r=rRremove)rrrYrrZkey_listrZrrr_invalidate_dict_mdels zCmfCache._invalidate_dict_mdelc stjdrdt_dStr>dt_tjdt dStj  krtdt_tjdtj d dSifddfdd }|rt |t st|d r||d }nx|rt |t rt|d d rd }||nN|dk rd}t|tkr2t|tkr2ttkr2n|s*d}d}ntdd}|r|drtjd||d kr|j|dkr|dD]:}||jd|jdfkrvd}|jqqv|sg} |dr| |d7} |dr| |d7} |dr| |d7} | s dg} | D]} | dkr d} |dD]h}|dd } || krdd|d| d n*d!| d"|d!| d"| d q(q|dD]} d| d q|r|dsֈd|d jrD]} tjd#| d$q|sdt_d%tkrttjrttjd&dtjjr\td&tjd'tjfidS)(NNO_CACHETz%DEBUG_CACHE ADD SKIP CACHE LOCKED_BY z#DEBUG_CACHE ADD SKIP too old trans rcs$|krt|<|dSr)rwr)bind)rrZrrbind_adds zCmfCache.add..bind_addcsdt|tr|}n|g}g}|D]@}t|jtjjr>|}nt|}|D] }|qPqdS)u Собираем списки ключей инвалидации :param val: :param invalidate_dict: :return: N)rjrwrrkrrlrr)rZobj_listritemr)rrrrbind_add_recursives  z(CmfCache.add..bind_add_recursiverrrrwZcustomemptyZEmptyuGНевозможный объект для хранения в кешеFrzDEBUG_CACHE WHERE: rz.idz.codeparentslistsZcache_clustersZScopeAll)ZNullZNULLZnullrhZnoneNrhr!where_ScopeAll__insdelwhere_rzDEBUG_CACHE BIND: z = r[#DEBUG_CACHE JSHASH: add invalidate r)osenvironrRgno_jscache_force CMF_CACHEcache_is_lockedr5rDcache_locked_bycache_transaction_startget_last_invalidaterjrwrryrprqrorvrrr'rZcache_store_errorr[rr) rrZrobj_typeZ query_paramsrZobj_caseZwhere_pk field_nameZscopesZscopeZ model_nameZbindidr)rrrZrrrs   &             z CmfCache.addc Cs~zdtkrtt_Wn(tk r<}z WYdSd}~XYnXdtjkrTdtjd<ntjdd7<dtjkrzdtjd<dS)N profiler_data cache_hitr_ cache_missrrr;rrvrrZrrrrprofiler_data_hites    zCmfCache.profiler_data_hitc Cszdtkrtt_Wn(tk r<}z WYdSd}~XYnXdtjkrTdtjd<ntjdd7<dtjkrzdtjd<|tjd<dS)Nrrr_rrZcache_miss_lastrrrrrprofiler_data_missss     zCmfCache.profiler_data_misscCstjdrdSt|jd||}|rdtkrtjr|d|tjfit|jd|dtj|jrt d|tjt|jd|t|jd || |t |S| |t|jd |dS) NrZCACHEr[rz*DEBUG_CACHE JSHASH: add invalidate jshash:rrzDEBUG_CACHE HIT: zDEBUG_CACHE GET:zDEBUG_CACHE MISS: )rrrRr5rDrrr[rrrrSrTrrrrrrRs"      z CmfCache.getcCs t|jdt|jdpdS)Nz%DEBUG_CACHE TRANS get_last_invalidatecache_last_invalidaterr5rDrpr>rRrHrrrrs zCmfCache.get_last_invalidatecCst|jd|t_dS)Nz)DEBUG_CACHE TRANS cache_transaction_start)r5rD gen_time_usrrrHrrrrs z CmfCache.cache_transaction_startcCsttjtjjdS)Nz%Y%m%d%H%M%S%f)rprirrbrtstrftimerHrrrrszCmfCache.gen_time_uscCs:t|jd|s6|jdtj|jd|dS)NzDEBUG_CACHE TRANS cache_lock cache_lockr)r5rDrr>rrrrrHrrrrs zCmfCache.cache_lockcCsJdtkr dS|}tj|ks,tj|dkrFt|jd|jdddS)NrizDEBUG_CACHE TRANS cache_unlockr0)rrrr5rDr>r)rZlock_trrrr cache_unlocks  zCmfCache.cache_unlockcCs t|jdt|jdpdS)Nz%DEBUG_CACHE TRANS get cache_locked_byrrrrHrrrrs zCmfCache.cache_locked_bycCs"|}|dkr|tjkrdSdS)NrTF)rrr)rZ_cache_locked_byrrrrszCmfCache.cache_is_lockedcCsZg}|D]}|||q||||j||||jrVtd|d|j|dS)N invaldebug--)rrrrrDr)rrrrZinv_listrrrr_do_invalidates zCmfCache._do_invalidatec sd&fdd }ddlm}tjdr.dStjdd|j|j}ij rpddl }| |jd kr||j d d kr|d |j d |jd||j d|d|jdd|d|j d |jdd|dSt}|jddD]8\} } | jdkr&q t| tjjrΈdkrh| rh| j rh|d | j d |jddkr| jr| j| jkr|d | j jd |jd|d | j jd |jd|| q t| tjjrdkr| jr|| q | jr$t| tjjr$|| q | jr | j| jkr || q t|dkr|dkr|tjdd|j dSt|dr|jdkr||j ddkrb|D]} t|dr|d|jd |d | dt|d!r|d|j d |d | dt|drH|jD]$} |d| j d |d | d"q"|d|d | dqdkst|d#r|j jst|d$r|j!jst|dr|jjst|dr|jjrt|dr|d|jd |ddt|d!r|d|j d |ddt|d#r^|j jr^|j jr^|j j|j jkr^|d|j jd |dd%t|d$r|j!jr|j!jr|j!j|j!jkr|d|jjd |dd%t|dr|jD] } |d| j d |dd"q|d|d|dS)'Nrccs6|}|r2||<tjdd||dS)NzDEBUG_CACHE INVAL: r)rr5rD)ZinvaldebugZinvdrrrrr _check_invals z)CmfCache.invalidate.._check_invalr)rrzDEBUG_CACHE start invalidate rZ RelationCachezRelationCache.parent.id=)rrrrzref=zobj.id=rrzwhere=rTr)rcmf_modified_byrZ cmf_viewed_byrc)createrUrzref_new=zref_old=zDEBUG_CACHE ivalidate: z not fields_have_changesr)rrrUcache_cluster_idr! parent_idz where_lst=parent cache_clusterz where_old=)rc)" collectionsrrrrRrr5rDrTRACEpdbZ set_tracerrr rwrxrjrkrrroldnewrrrrrrloadrrr) rrrrrrrrZ change_fieldsrrlstrr r invalidates      "          "   22  zCmfCache.invalidatecCs<|jD]\}}td|q|jD]\}}td|q$dS)NzDEBUG CmfCache.dumps)r<r*r=rx)rrZr}rrrr{Vs zCmfCache.dumps)NF)N)NN)N)N).r(r&r3r<r=r>r?rDrPROCESS_EVICTED_FLUSHrrGr^rarrrrrr staticmethodrorrrrWrrrrrrrrrrRrrrrrrrr rr{rrrrr6?s\ C     6  /  r6cCsJt|}|D]4\}}t|trztj|||<WqYqXq|Sr)rrxrjror~rrrs)rZdctrrrrrCustomJSONDecoder\s rc@seZdZddZdS)CustomJSONEncodercCsznt|tjtjfr|j}t|tjs2t|tjrP|jsF|dWS|WSt|tj rd|jWSt |}Wnt k rYn Xt |St ||S)NZ)rjrZ CmfDateTimerrnridateZtzinfoZ isoformatrliter TypeErrorrwrdefault)rriterablerrrr%hs   zCustomJSONEncoder.defaultN)r(r&r3r%rrrrr gsr )Z static_folderZ root_pathTZSEND_FILE_MAX_AGE_DEFAULT)SocketIO Namespace) RedisManager)Clientrcc CsdddDD]v}tj||}tj|s:tj||}ztj|sLWqWn"tt fk rptj YnXtjj |ddSt j D]$}||}|rtjj |ddSqtj dS)NcSsg|]}tjtj|qSr)rpathrrC PROJECT_DIR)rdrrrrszsend_static..)zcustom/static/zcommon/static/z cmf/static/zdist/cmf-angular/T)Z conditionalzdist/cmf-angular/index.html)flaskZhelpersZ safe_joinrr+isabsrisfiler$ ValueErrorZ BadRequestZ send_fileAPPHOOK_STATIC_NOTFOUND)Z req_filenameZ directoryfilenamehookrrr send_statics   r6c@seZdZdZdejdddZddZedd Zed d Zed d Z ed dZ eddZ edddZ eddZ eddZdS)CmfRedisMemoryWrapperut Если есть self.redis - используется он Если нет - нужен фолбэк N)rediscCs||_i|_dSr)r8 memstorage)rr8rrrrszCmfRedisMemoryWrapper.__init__csfdd}|S)Ncs6|jrt|jj||Std|f||SdS)Nu&Redis memory wrapper запрещен!)r8rr( CmfAbortErrorrr+rrwrappersz/CmfRedisMemoryWrapper.fallback..wrapperr)r+r<rr;rfallbacks zCmfRedisMemoryWrapper.fallbackcOstdSrNotImplementedErrorrrrrrszCmfRedisMemoryWrapper.smemberscOstdSrr>rrrrrscCs |j|Srr9rR)rrZrrrrRszCmfRedisMemoryWrapper.getcCs|jdSr)r9clearrHrrrrGszCmfRedisMemoryWrapper.flushdbcCs$|j|d}||7}||j|<|S)Nrr@)rrZamountrnrrrr@s zCmfRedisMemoryWrapper.incrbyr_cCs |||Sr)r@)rrZrBrrrincrszCmfRedisMemoryWrapper.incrcGs$d}|D]}||jkr|d7}q|S)Nrr_r9)rnamesrnrrrrs   zCmfRedisMemoryWrapper.existscCs||j|<dSrrD)rrZrnrrrrszCmfRedisMemoryWrapper.set)N)r_)r(r&r3__doc__r8Redisrr=rrRrGr@rCrrrrrrr7s&        r7c sfdd}tdd}zzttdttrtdttj}|jtt| D]*}td||ddkrd|d  }t |g}|D]|d krftd |td t j jjrq|r|td krtdqt}dt j j_tddJ}z6t|tjtjBtdt j jtdWn YnXW5QRXdt j j_qtd|tj|t|d|dqqdWn:ttfk rYn tk rtdYnXW5tdXqdS)Nc s~zFtdd|d|dt||W5QRWSQRXWn2tk rxtdd|d|dYnXdS)NzRun server event handler z(*z, **)z+_spawn_server_event_listener handler error )r* cmf_contextrvlogging exceptionrrZhandlerrr spawn_handlers "z3_spawn_server_event_listener..spawn_handlerz._spawn_server_event_listener: listen channels z Channels z*_spawn_server_event_listener: got message rymessagechannelz__keyevent@7__:evicteduWARNING! Сервер Redis выгрузил ключи из-за нехватки памяти. Если это происходит слишком часто, нужно увеличить память для Redis. Ключ: uTКеши больше не валидные, запускаем сброс кеша!<skip_evicted_timerTz/tmp/eva-app_flushdb.lockwz;on_project_permission_change handler do CMF_CACHE.flushdb()rdFz7_spawn_server_event_listener: gevent.spawn got message data)rWrRz"_spawn_server_event_listener error)timesleepr*_server_event_channelsREDIS_DBr8pubsubZ subscriberwZlistenrQrRrkapprropenfcntlZflockZLOCK_EXZLOCK_NBrGgeventspawnjsonrT SystemExitKeyboardInterruptrvrLrM)rPrUr\rRrSZhandlersr+rrOr_spawn_server_event_listenersV           "recCsttdSr)r`rarerrrrspawn_server_event_listener.srfcsfdd}|S)Ncst||Sr)rZr)funcrSrrr15sz"on_server_event..decoratorr)rSpatternr1rrhron_server_event2s rjcache_settingsr%ryr8Z run_uwsgiu?При работе через uwsgi обязателен RedisrF)r]Zcors_allowed_originsloggerZengineio_loggerdbunix_socket_pathzunix://z?db=zflask-socketio)rSZ write_onlyclient_managerredis://passwordrg@hostport6379r$ message_queue)Payloadd)rlz/custom/org_name)r>r?)r?u&Неизвестный тип кешаcCstjddr0dtjdddtd}nld}dtjdkr\|dtjddd 7}|tjdd 7}|dtjdd d 7}|d td7}td||d}|jtjGddd|j}||_|S)Nr%rnzredis+socket://z?virtual_host=r_rprqrgrrrsrtrur$Zcrm)ZbackendZbrokercs8eZdZfddZd fdd ZddddZZS) z$make_celery_app..ContextTaskcs.tj||d|j|_d|j|_dS)uyФабрика все опции прописывает в классе, вызов конструктора пустойZcmf_task_only_once_queue__Zcmf_task_only_once_lock__N)rrronly_once_queue_flag_nameonly_once_lock_namerrrrrsz-make_celery_app..ContextTask.__init__Ncst|ddrLtjj|jd|jp ddddd}|sLtd|jd dS|pRi}t|d drddntj j j |d <t j ||f|}|j tj j j |||jd }t|td ||S)N only_oncer_rrdrTT)exZnxzSkip create task z - already started system_taskcmf_current_person_id)Ztask_idrrrrgzcmf-background-task-queued)rr[r8rrysoft_time_limitrr rcurrent_personrrnr apply_asyncrbr{socketiorW)rrrZ_my_custom_paramr/Z need_creater event_paramsrrrrs,   z0make_celery_app..ContextTask.apply_async)r~c _sddl}|dtddtjj|j|jp2ddd}|jj rzt d|jj t |ddrz| tj|jtd |jd d d zz>|rtjj|tjdt_|j||}td |jdd d Wnxtk rH}zXt d|jj td |jd|d d |jj r6t d|jj t!|W5d}~XYnXW5t |ddrz |WnJtjjk r}z&td |d|jd|jd d W5d}~XYnXX|jj rt d|jj t!|t"j#$|W5QRSQRXdS)NrrQF)init_views_and_dsrTtimeoutzcmf-background-task-start-r{z ContextTask z startT)flushzlock release error z , lock_name z , timeout rz successzcelery task error z error zcmf-background-task-error-zcmf-background-task-result-)%rXrYrKr[r8lockrzrrequestrrrWracquirerUryr*rrelease exceptionsZ LockErrorrr CmfPersonrRr2current_person_fieldsr_current_personrunrvrLrMrorEstdoutr) rr~rrrX redis_lockrresulterrorrrr__call__sH       z-make_celery_app..ContextTask.__call__)NNN)r(r&r3rrrr4rrrr ContextTasks r) rCrkrRrmr ZconfrceleryZTask)Z redis_url celery_apprrrrmake_celery_appzs" Fr)r{r}c Ks`tjD]T}tdz |Wqttfk r6Yqtk rXtd|YqXqdS)Nscheduler_minutelyuJОшибка выполнения периодической задачи )r2HOOK_CRON_MINUTELYr*rdrcrvrLrM)_kwargstaskrrrrs  rcCst|ttt|tr||}t|j |j |j td|_ d|_ tjdd|jd<d|jd<d|jd <|St}d |d <d |d <t||d<t|d<t|}d |_tjdd|jd<d|jd<d|jd <|SdS)N)coder description tracebackapplication/jsonOriginrAccess-Control-Allow-Origintrue Access-Control-Allow-CredentialsContent-Type, x-ijtAccess-Control-Allow-Headersirz Unknown errorrrr)rr r format_excrjrZ get_responserbr{rrrrW content_typerheadersrRr;roZjsonify status_code)rZresponserrrhandle_exceptions4         rZjwt_rsaz jwt_rsa.pub)RSAZ cmf_deleted rg_member_ofZdefault_projectZemailZphone user_localZphone_internalZ primary_roleZ online_statusZvacation_startZ vacation_endZ on_vacationZactivity does_not_workZis_admin is_supportservicedesk_allowcCsPtjs dSztjs&tjjdtjdt_Wn tk rHt dYnXtjS)Nz.CmfPerson:00000000-0000-0000-0000-000000000001rrzapp.system_person() error) rC AUTH_ENABLEDr2 system_personrrrRrrvrLrMrHrrrrs  rc Cstjdrtjd}n^tjs$dSzttj}Wn tk rTt dYdSX|dkrbdSt |t ov|dd}|sdSt |}|jdsdSdt_t|jd dgd }|rt|d krdS|jd d }|sdStd|}r|\}}ndS|dks$|dks$|dkr,tj}nR|dksT|dksT|dksT|dkr\tj}n"|dksp|dkrxtj}ntj}t|tjjsdSd|kr|j|jd|ddgd} n|j|ddgd} | sdS|t| j krdt_!| t_"dS)u Проверяем, что пользователь пришел из share-ссылки Если идёт обращение к /files, то проверяем Referer Т.к. jsurl передаётся только в апи для других ендпоинтов не смысла путаться парсить body Вообще, для API тоже лучше использовать реферер, тогда не придётся по два раза парсить json Выставляем: - g.sharelink_access_request = True, если пользователь пришел по /share ссылке - g.sharelink_access_granted = True, если проверка hash прошла - g.sharelink_access_obj = объект, по которому проверяли ключ. Используется в API для доп.фильтрации /filesZRefererNu{_check_sharelink_access не смогли распарсить request.data для проверки прав доступаjsurlrcz/share/Trrr$rz*^(?P[^:-]*)[:-](?P.*)$docZDOC CmfDocumentZflZFLZIN_WORK CmfFolderCmfListZEPIr rgrsharelink_hashr)rr)#rr+r`rrRrWujsonrTrvrLrMrjr;rrsharelink_access_requestrZqueryrr'rematchgroupsrrrrrrkZ CmfEntityrrorsharelink_access_grantedsharelink_access_obj) rZjson_resr-Z hash_paramZobj_keyrrZobj_codeZ obj_modelrrrr_check_sharelink_access0s^   ( rcCs |t_tjS)uh!!! Эта функция не меняет контекст, только инициализирует.)rr)personrrrset_current_personsrcCsZt|dddkr|jStjs dSt|dr@t|dddk r@|jStdtjt j ddS)NrZFAIL_recursionz#Warning!!! Lazy Calc Current PersonrA) rrrCrrrr*r print_stackrErrHrrrrsrc sztjstjjdgd}|jsztjjJddl }ddl |j |j d fddtdD|_|W5QRX|jt_Wn tk rtdYnXtjS) Napp_keyrrrcc3s|]}VqdSr)choice)rrZalphabetsecretsrr szapp_key.. zapp.app_key() error)r2rrCmfGlobalSettingsrRrkutilcmfutil disable_aclstringrZ ascii_lettersdigitsrrangesavervrLrM)rZsettingsrrrrrs    rc Cst|dddk r|jSztjjddtjd|_|jstjj ddd}| zPtjjddtjd|_|jst j jt j|j|_W5QRXtW5| X|jWStk rtdYnXdS) N_anonymous_userzanonymous@evateam.ruTrZinclude_deletedrzcreate-anonymous-user-lockrQrzapp._anonymous_user() error)rrrrrRr2rr[r8rrrrkrrr system_dataZcreate_anonymous_userrdd commit_all_dsrvrLrMrrrrranonymous_users4   rc Cst|dddk r|jSztjjddtjd|_|jstjj ddd}| zPtjjddtjd|_|jst j jt j|j|_W5QRXtW5| X|jWStk rtdYnXdS) N_sharelink_anonymous_userzsharelink-anonymous@evateam.ruTrz$create-sharelink-anonymous-user-lockrQrz%app._sharelink_anonymous_user() error)rrrrrRr2rr[r8rrrrkrrrrZcreate_sharelink_anonymous_userrrrrvrLrMrrrrsharelink_anonymous_users8   rc Cst|dddk r|jSztjjddtjd|_|jstjj ddd}| zPtjjddtjd|_|jst j jt j|j|_W5QRXtW5| X|jWStk rtdYnXdS) N_test_guest_userztest-guest@evateam.ruTrzcreate-test-guest-user-lockrQrzapp._test_guest_user() error)rrrrrRr2rr[r8rrrrkrrrrZcreate_test_guest_userrrrrvrLrMrrrrtest_guest_users4   rc Cst|dr t|dddk r |jStjjdgd|_|jstjj 8ddl m }|tjjdgd|_|jsxt dW5QRX|jS)N_global_settingsrrr)init_global_settingsu6CmfGlobalSettings не инициализирован.) rrrrrrRrkrrrcmf.system_datarAssertionError)rrrrrglobal_settings!s rcCs:t|dr t|dddk r |jStjjddgd|_|jS)N _global_varZaccount_sync_statusZaccount_sync_lastr)rrrrZ CmfGlobalVarrRrHrrr global_var3srlinenoc Cs6|tddtddf}|j|dd}td|t|d|dD]\}}|jd}tj |j tjd d}td |||j |j d ft|j |j }|rtd ||jD] } t| qqJ||d} | rtd d| D} tdt| | d ftdd|D} td| d dS)NFzz T)Z cumulativez Top %s linesr_rz#%s: %s:%s: %.1f KiBiz %scss|] }|jVqdSrsizerstatrrrrVszdisplay_top..z%s other: %.1f KiBcss|] }|jVqdSrrrrrrrXszTotal allocated size: %.1f KiB)Z filter_traces tracemallocZFilterZ statisticsr* enumeraterrseprr4r'rr linecachegetlinestripformatsumr) ZsnapshotZkey_typelimitZ top_statsr#rframer4lineZllotherrtotalrrr display_top=s.       rc Cstjjjdddtjj|jtj d}|sdd|j ddD}t j |d <t j |d <t j |d <tjf|}|rd|_ |jtjd|_|jtj|rd|_|jtjjd d tjj|jddW5QRXt|W5QRSQRXdS)Nzcreate-current_person-lock r)loginrcSs(i|] \}}|ds|dkr||qS)Zcmf_r)r`)rrrrrr bs  z+create_person_from_auth..TrZ cmf_ownerZ cmf_authorrZServiceDeskClient)r)Z only_data)rkrrZCmfLockrrrRrr2rrxr system_userrrrZCmfPersonGroupZ support_grouprZ user_grouprrrrr)authris_servicedeskrZ person_valuesrrrcreate_person_from_auth\s,     rcs6ttjdkrdStdt_it_gt_ t j ddkt_ ddlmddlm}t_tjt_d |d d d t_dt_gt_gt_dt_dt_dt_dt_dt_dt_dt_dt_dt_ dt_!dt_"dt_#dt_$tj%&d t_'dt_(dt_)t*j*+t*j,j-t_.ddt_+tj./t_0ddt_/dt_1it_2it_3gt_4dt_5dt_6ddfdd }|t_7t8j9:t;j<st=ddStj%&drdSt>tdrtj?j@rtj?j@t;jAkrdtj?j@dt;jAdSd}tj%&drtjB dp tjB dp tjC d}|r|&dr0|tDdd}t8jEF|}t8jEj |dtGjHd }t7d!|dd d"|d#||stId$d%d&d'Stj%d(krt8jJjKtGjHd)}tj%&d*r&d+}d,tjLkrtjLd,}tM|}|stNd,|i}tOt;jPd-|}tjB d.d/|jBd0<d1|jBd2<d3|jBd4<|S|sLtjQ d5}tjQ d6} |r`t8jRS|\t_t_)n| rtt8jTU| t_tjrt;jVot8jTj tjjjWd7} t;jVr| sdt_tjrLtjjjWt_d8d9d:dgd;d:dggd}ntj?j[rLtZtjdd?}tj%&d@prtj%&dAprtj%&dB} dCdD} | rd}|r|jjWt_tjrtjjYt_tjj\t_tjj\ t_ndt_dt_dt_dt_t=|n`| s| r,tj]}t^tj$r tj_}dt_dt_dt_dt_t=|ndt_dt_t=tj`tj pxtj%&dEpxtj%dFkpxtj%&dGpxtj%&dHpxtj%dIkpxtj%&dJpxtj%&drtjL dKdLkrtjadMkpxtj%&dNpxtj%dOkpxtj%&dPpxtj%&dQrtjadMkpxtj%&dRr"tjadMkpx| rDtj%&dSrDt8jbcpx| rftj%&dTrft8jbcpxtj%&dUoxtj}tjd}tj`}t8j9e|s2tjs2tjr|stfdVtjdWStjrtjrtfStj%d+kr|r|jgs|jhrtOd Stj'r|jhstfdXStj)r2tj)i}|r2|SdS)YuJ Должны вернуть Response or None Особенности поведения: В случае web запроса: - response - view не выполняется, сразу отправляем response - None - выполняем view - Exception(в т.ч. и abort) - обработчик выводит трейс клиенту Системный контекст(shell, celery, socket, other with cmf_context): - None, Response - нет разницы - Exception - прерывает выполнение. ZOPTIONSNFZ run_pytest1rrX)choicesrcZ0123456789abcdef)rz /servicedeskcSstjSr)r_nowrrrrz before_request..cSstjSr)r_daterrrrr r )forcec sttdds|rވ}tt|tjdd}tt|tjdd}tdidt}|dd}|dd}|d d}t j d } t tj d | d |d |d d |d|d|d|||dd f|t_dS)NrDrIrdrZ select_countZselectrrinsertmr$z(+z)mszs zu zi t) rrCroroundr debug_start debug_nowrRr;rrr* request_id) r messagesrrrGZscZscsZscuZscirrrrr s,    "  zbefore_request..debugz/memZOKru>Версия Eva отличается от версии БД: z != u. Вероятно была запущен несовместимый образ Eva, либо были проблемы во время обновления и патчи применились частично./api/z X-Eva-TokenZ AuthorizationtokenzBearer T)api_token_hashrrzAuth API Token(z ...): hash=z , person=zInvalid API token text/plainr /pub/webhookrz/auth/not_authorizedr$next_url /auth/signin?rrrrrrr session_token access_token)rORrz==rr)filterr)r)rz/pub/apiz/docsz/sharecSstjdptjdS)Nr /socket.io/)rr+r`rrrris_allow_publicCs  z'before_request..is_allow_publicz /auth/sync)z /auth/invitez/auth/restore_passwordz /auth/signz/servicedesk/auth/signz"/servicedesk/auth/restore_passwordz/auth/two-factormoderootz 127.0.0.1z /crm/forms/z/manifest.webmanifestz /app/assets/z/forms/z/js/z/pub/z/sso/z /helpdeskuУчётная запись uQ заблокирована. Обратитесь к администраторуuUУ вас нет доступа. Обратитесь к администратору)jrrrmethodrbefore_requestrrflags remove_filesrrrRZtestrXZrandomrrrrrZsave_only_data_hackalertdeferred_tasksrZ public_accessrZ is_local_userZ is_guest_userZ is_anonymousris_system_contextZdisable_notifyZ import_modeZinteractive_shellrrr+r`request_servicedeskrsessionrirrbrtr r"r Zrelaxed_bz_python_mode emit_list socket_events server_eventsrZjscache_timelifer r CmfAccessListZ init_contextrCrrrrZ eva_versionZ EVA_VERSIONrrrrZ hash_tokenr2rr Z CmfWebhookZget_token_personrcheck_sso_redirectrredirectAUTH_SERVER_URLZcookiesZ CmfSessionZ from_tokenCmfAuthZfrom_jwtZIS_AUTHORIZATORrnrZjwt_is_supportrZservicedesk_allow_auth_guestsZjwt_is_match_orgrrrrZ remote_addrZ CmfPluginZ check_secretrZ setup_contextreject_responserrZtfa_check_two_factor)rr Z auth_personZ api_tokenrrrFqsrr Z real_authZ_filterZis_force_publicr$Z anon_personZis_allow_without_authrrrrr(zsz             $         $                 " r(cCs0tjr dStjjddgdd}|r,||SdS)Nrzplugin.*F)rZdisabled)rr-rZCmfAuthOpenIdPluginrRZlogin_redirect)rZopenidrrrr4s r4cCstjds"tjds"tjdkr4t|p*ddddSdtji}|rJ||d <t|}tjrntt j d |}nt }|stt j d |}tj d d |j d<d|j d<d|j d<|SdS)Nr#rrznot authorizedrrrrrRz/servicedesk/auth/signin?rrrrrrrr)rr+r`r r-rrr.r5rCr6r4rrR)rRparamsr9rFrrrr8s(     r8cCstttdSr)rr emit_eventsemit_server_eventsrrrrcommit_with_eventsr=c CsNtdsdStjD]*\}}td|d|d|dddqit_dS)Nr0 is_changed-rr$rprivate) namespacer)rrRr0rxr)rr}rrremit_list_applys  $rAc Cs|D]\}}|D]}|d}|d=t|d}|d=|d}z"t|t|t|WnJtk r}z,td|d|d|d|WYqW5d}~XYnXt|ts|j |f|d|d |d iq|d r,|d d ks,|d |d <|j |f|d|d |d iq| d r|drd |ddkrj| |ddd d|ddkr|dddD]}| |q|D]r} t| t j jrtd| d|d|d|| jj} nt| } | |d <|j |f|d|d |d iqqqdS)N socket_clientrruPDEV: FATAL emit пришел с несериализуемыми данными z! socket_client:z; event_persons:z; event_param:rr@rr?revent_current_personrZrelation_personsuYDEV: INFO Кривой евент, в event_person попал объект, а не str: r)rxrcopyrbr{rvr*rjr'rWr`rrkrrrrnro) Z event_dictmsgZevent_param_listZ event_paramrBrZ emit_kwargsrZuser_id event_personevent_persons_strrrremit_events_dictsF       " "    rHcCs&ttdpi}it_t|dS)Nr1)rArrRr1rH)r1rrrr;sr;cs:fdd}ttdp iit_r6t|dS)uЗапускаемся в контексте, но отправляем в отдельном таске вне контекста, после паузы, чтобы не держать запрос.csttdSr)r`rYrHrdelayr1rremitters z'emit_events_with_delay..emitterr1N)rArrRr1r`ra)rJrKrrIremit_events_with_delays rLcCsPtdp g}gt_|D]2\}}td|d|tj|t|qdS)Nr2zemit_server_events: r) rrRr2r r[r8Zpublishrbr{)r2rSrWrrrr<$s  r<cCstit_dSr)rZrollback_all_dsrr1rrrrrollback_purge_event,srMcCs$tdgD] }|}q gt_dS)Nr,)rrRrr,)Ztask_signaturerrrrapply_deferred_run_tasks1s rNcCs2tdgD]}tj|r t|q gt_dS)Nr*)rrRrr+rrr*r4rrrapply_deferred_remove_files9s  rPcCsNttdttttjdd|jd<d|jd<d|jd<|S) uk Запускается только если небыло ошибок :param r: :return: rdrrrrrrr) rrrLr<rNrPrrrR)rFrrracaoBs  rQc CsTtjs dStjt_t,tjj tj j j W5QRXW5QRXtdSr)rCrZDISABLE_PERMISSIONSr2disable_permissionsrKrkrrrincluderr3Z load_acl_datarfrrrr app_init_aclUs "rTc CsNttjjdsdSt,tjjtjjj W5QRXW5QRXdS)NCmfProjectPermScheme) rrkrSrrKrrrrUZload_project_permission_datarrrrapp_init_project_permission`srVcCs0ttttjr ttjr,tdSr) rbefore_first_requestrTrVrCWHATSAPP_MESSENGER_URLspawn_messenger_socketio_clientWHATSAPP_WEB_SOCKETspawn_whatsapp_socketio_clientrrrrrWhsrWcCstj|ddSNrM)rrr]rrrteardown_requestusr^c Cstd|d|d|d||r0tjs0dS|dk rH|tj krHdS|rrdt}td|t||tj krtj |dS)u Глобальная функция для оповещения фронта о предупреждениях :param msg: :return: zcmf_alert: msg=z abort=z debug_only=z devel_only=Nrzcmf_alert Stack: ) rr rCrDZ PRODUCTIONrr format_stackr:r+r)rEr rZ devel_onlyZ stack_strrrrr{s"  rr?)r@rBrrc Os|st}zdtkrtt_Wn(tk rD}z WYdSd}~XYnXt|dkrldtjrdtjjjpfdig}t |dtkrdtkrtj |dd<n d|dd<tjrtjjjpd|dd<t||||d}t |||d<d } d D]} | | rd } qq| rtd t|s:tjg}| s:td tg} |D]4} t| tjjrf| | jjn| t| qB| |d<t |dtj|g} || kr| |dS)Nr1rrMsession_tab_idrcrC)rrr@rrBF) zevent-r z task-comment-zaudit-task-comment-znotify-person-r>zcomment-z notify-osznotify-important-ZDEBUG_TuCDEV: WARNING в cmf_emit_event не указали cmf_emit_event: uDEV: FATAL!!!!!!!!!!!!!! Добавьте меня в спинт Баги реактивности. 10.10.2022 в cmf_emit_event не указали cmf_emit_event: r)rrr;r1rvrrrrnryr`rbr{r`r*localsrrjrkrrrro setdefault)rEr@rBrrrrrrZmutedZ muted_debtrGrFZ event_listrrrrsL      rcCs"dtkrgt_tj||fdS)Nr2)rr2r)rSrWrrrcmf_emit_server_eventsrccCs|rd|nd}|rdnd}|r&dnd} d|||| g} tj| dtjtjd} |r| \} } |rv| } | } | j}|r|rtd| td | td | t d | |r|| | fS|| p| fSd S) 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}', читается лучше z timeout {0} rczsudo z 2>&1z0{0} bash -c "export BOOTUP="noncolor";{1}{2}{3}"T)shellrrFu6Произошла ошибка при вызове %sz STDOUT: %sz STDERR: %su4Произошла ошибка при вызове )NN) r subprocessPopenPIPEZ communicaterQ returncoderLr RuntimeError)ZcommandZsudorwaitZseparate_out_and_errZ do_decodeZdo_raiseZ timeout_cmdZ_sudoZ _redirectcmdZprocessouterrZerrcoderrrrun_bash_commands8        rncCsLttj}t}||||}t | }|d|}|S)ua Подписываем токен сертификатом :param jwt: :return: r!) r rr2rsa_private_keyr rrsignbase64 b64encoderQ)jwtZsignerZdigestrprrrrrsa_sign_pack_jwts  rtcCsHddd}tt|}tt|}|d|S)uD Создаем токен :param payload: :return: ZRS256ZJWT)Zalgtypr!)rqrrrbr{rrQ)payloadheaderrrr create_jwt s rxcCstjS)u2 Текущая версия :return: )rCZ CMF_VERSIONrrrrcmf_get_version srycCs|tjkrtj|dS)ux Удаления файлов после коммита транзакции :param filename: :return: N)rr*rrOrrrcmf_remove_file! s rzc@s,eZdZd ddddZddZdd ZdS) rKFNr7cCstd|_||_dS)Nz /with-context)r2Ztest_request_contextctxr)rrrrrr, s zcmf_context.__init__cCs*|j|jrtttdSr)r{ __enter__r start_viewsrZinit_dsr2Zpreprocess_requestrHrrrr|0 s  zcmf_context.__enter__cCs<tj|d|s(tttt|j|||dSr\)rrr;r<rNrPr{__exit__)rexcrnrrrrr~7 s zcmf_context.__exit__)F)r(r&r3rr|r~rrrrrK+ srKcCsddddddg}tjdd|D}|D]\}}}|tjd }|d r(|D]\}|d sf|d rN|d sNddd|dD}t j |d|ddddqNq(t j ddt dt j ddt dt j ddt ddS)Nz cmf/viewsz cmf/modulescommonmodulesz custom/commonzcustom/modulescSs&g|]}tjtjd|ddqS)r$T) followlinks)rwalkrCr,)rZ search_dirrrrrC szstart_views..rcz/viewsz.pyz.pycz __init__.pyr!css|]}|r|VqdSrr)rrrrrrK szstart_views..r$r)packager&)r Z view_funcz/Zdistz/static/Zstatic) itertoolschainrurCr,endswithr`rr' importlib import_moduler2r)r6)Z search_dirsZ search_iterdirnamedirnames filenamesr4r,rrrr}A s$  $r}cKs,tj|||d}|jf|tj||S)NrN)r signaturerrr,r)rrrr/rrrrcmf_deferred_task[ s  rcCs*tjdddkr&ttjdddgdS)NSOCKETIOZworkerz--poolr`)rrrRr`rarZ worker_mainrrrrspawn_task_workerb srcCs*dd}tjdddkr&td|dS)Nc SsJddlm}t|tddW5QRXtdtjdtddS)NrBeatztmp/celerybeat-schedule)r]ZschedulezBeat die!!! Stop worker.rAr_) Zcelery.apps.beatrrKrrr*rErFexitrrrrrun_beatj s  z&spawn_task_scheduler..run_beatrrQ)rrrRr`Z spawn_later)rrrrspawn_task_scheduleri srcCs"dd}tjrtj|dgddS)NcSs2i}tjddrdtji}tjtj||ddS)Nrr namespacesr)rrrRrCORG_NAME whatsapp_sioconnectrXrrrrmessenger_connectv s z:spawn_messenger_socketio_client..messenger_connectz /whatsapp)r)rCrXr`ra)rrrrrYu srYcCsttjtjdSr)r`rawhatsapp_go_siorrCrZrrrrr[ sr[cCs<ddl}tdtjdtj|jtjtjdddddS)NruYПодключаемся к удаленной отладке config.REMOTE_DEBUG_SERVER=z config.REMOTE_DEBUG_PORT=TF)rtZstdoutToServerZstderrToServerZsuspend)pydevd_pycharmr*rCZREMOTE_DEBUG_SERVERZREMOTE_DEBUG_PORTsettrace)rrrrcmf_pycharm_debug s rr7cCsHttjtjttttttdtjj dd}t |}t |S)NrTZguid)ZissZorg_nameZiatZexprZjti) r;rCZAPP_FQDNrrorprXrrrnrxrt)rvrsrrrgen_eva_app_token sr)urirWc Csddlm}tjsFttj|d}|dg}|di}|||}n|}dddd |_tj |}t |d <|j |t |d } | jd krtd |d| jd| j| }|rd|krtd|t||S)Nr)r/r'rrrrr)z Content-typeZAcceptzContent-EncodingZ eva_app_token)rWu9Не удалось отправить запрос, url=z, status_code=z, res=ru(Сервер вернул ошибку: )Zrequestsr/rCZEVA_ACCOUNT_USErrr7rRrr6rZpostrbr{rrvZcontentrr ) rrWr/r'Z method_argsZ method_kwargsrrr-rrrrcall_eva_account s.        r)rc)NN)rr)FF)N)N)r)N)FFN)TNTFFF)NN)rrrSrEr_rqZcalendarrirerXrrrrpathlibrZ urllib.parserrrrrr r~r`rZ Crypto.Hashr ZCrypto.Signaturer r.r r Z flask.jsonrZwerkzeug.exceptionsrrkrZ cmf.includeZcmf.data_providersrrrrr5objectr6rr r(rCr,r2Z json_encoderrrr3rZHOOK_CRON_HOURLYZHOOK_CRON_DAILYZHOOK_CRON_WEEKLYZHOOK_CRON_MONTHLYrRZflask_socketior'r(rr)r*r8r6r7r[rwrZrerfrjrrkrDZcfgr%rIrrrRrvrDZsocketio_kwargsrmr-rorvZengineio.payloadrwZmax_decode_packetsrrr+rr^r+readrrrrrrrZ errorhandlerrZregister_error_handlerZprivate_key_pathZpublic_key_pathZCrypto.PublicKeyrZ import_keyZ read_bytesroZrsa_public_keyrrrrrrrpropertyryrrZ current_userrrrrr(r4r8r=rArHr;rLr<rMrNrPZ after_requestrQrTrVrWr^rrrcrnrtrxryrzrKr}rrrrYr[rrorr;rrrrrs        #     ;F            [   !     b   5  1       9 ,