U _[cܧ@sddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z m Z ddl mZddlmZmZmZmZddlmZddlZddlZddlZddlZddlmZddlmZddlmZmZdd l m!Z!dd l"m#Z#dd l$m%Z%dd l&Tdd l'm(Z)ddl*Z$Gddde+Z+ddZ,Gddde-Z.ddZ/Gddde!Z0e+e1de2j3dZ4e0e4_5de4_6de4_7ge4_8ge4_9ge4_:ge4_;ge4_de4j2d<ddl?m@Z@mAZAddlBmCZCddlBmDZDddlEZEddd ZFGd!d"d"ZGeGZHe eIZJd#d$ZKd%d&ZLdd'd(ZMeNe2d)rle2jOd*d+d,krle2jOd*PZQeQRd+eEjSfeQeH_EeTjUVd-reHjEdkreWd.e4d/e2jXd0d1ZYeNe2d)r2e2jOd*d+d,kr2e2jOd*d2ZZe2jOd*Vd3rd4e2jOd*d3d5eZZ[eCe[d6d0d7Z\e\eYd8<n"d9e2jOd*d:d;eZZ]e]eYd<<dd=l^m_Z_d>e__`e@feYZBeDe2jXd?ZaeDe2jXd?ZbeTjcde2j3d@reee2j3d@Zfefghe2_iW5QRXeNe2d)re2jOd*d+d,kre.eHjEdAZjn(e2jOd*d+dBkre.ddCZjneWdDne.ZjeHe4_HdEdFZkekZleljmdddGdHdIZne4oeWdJdKZpe4qeWepee2j3dLZree2j3dMZsddNltmuZuerdreuverwe4_xesdreuveswe4_ydOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^ge4_zd_d`Z6dadbZ{dcddZ|dedfZ}dgdhZ7didjZ~dkdlZdmdnZee6ee_6ee~ee_~eeee_eeee_ee}ee_}ee}ee_ee7ee_7dodpZeeee_dqdrZeeee_ddudvZddwdxZe4jdydzZdd{d|Zd}d~ZddZddZddZdddZddZddZddZddZe4jddZddZddZe4jddZe4jdddZdddZdddgdddZddZdddZddZddZddZddZGdddZddZdddZddZddZddZddZddZedddZeedddZdS)N) OrderedDict defaultdict)Path)urlparseparse_qs urlencodequote)Celery)SHA256) PKCS1_v1_5)abortResponse) JSONEncoder) HTTPExceptionfields)*)basecs$eZdZfddZddZZS)Flaskcstj||dSN)super__init__selfargskwargs __class__./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_debug9sr5c@s^eZdZdZdZdZdZdZdZdJddddZ ddZ dd Z d d Z d d Z dKddZddZddZddZddZeeedddZeedddZedLddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Zd*d+Zd,d-ZdMd.d/Zd0d1Z 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?rrrrFszCmfCache.__init__cCs>ttjp |jdtjd|jr*|jnt|_t|_ dS)NzCmfCache.flushall!!!file) r5configDEBUGsysstderrr>flushdbr;r<r=rrrrflushallPs  zCmfCache.flushallcCsttjp |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_jscacheXs    zCmfCache.flush_jscachecCsttjp |jdtjdd}|j}|jjdddD]"}|drFq6|d7}| |q6| ttjpn|jd |d tjdd S) u+Инвалидируем весь obj cachezCmfCache.flush_all_obj!!!rArzobj:*rJrKs obj:jshashzCmfCache.flush_all_obj: z recordsN) r5rCrDrErFr>rPrQ startswithrVrW)rrLrZr[rrr flush_all_objjs   zCmfCache.flush_all_objcsddl|}fdd|D]}|d|}qd|krP|dt|d}t|D]*\}}|dkrnq\|d|d|}q\|jrd|dd d |}|d d}n|d|}t |jd ||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.parserdatetimerc isinstancecmfrCmfType is_definedvaluestrintfloatparserparseZ astimezoneutcreplace Exceptionlistr;itemstyper(md5rTdumps hexdigest)valdateutilrcresZval1evk_all2strhashlibrrr{s<        &zCmfCache.hash.._all2str|idz|id:rhzHASH:iz|md5: zDEBUG_CACHE HASH:) rrpsortedryrDr{encoder}rvr5)rprefixrrsr~r[rrrhashws"+&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 issubclassrlCmfRelationBasesimple_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: Trnrr)rrorrkrlrrextendobjects_id_recursiverrrrappendrxr)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) Nrd, r[]uRDEV: Слишком большой объект для кэширования — u байтT) debug_onlyFobj:)rTr|lenrCZCACHE_MAX_OBJ_SIZErkrlr BaseModel dataclassesZ is_dataclassrxr cmf_alertr>rr?r<)rr[r~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<rS)rkeysZhkeysr[rrr_obj_dict_existss zCmfCache._obj_dict_existscCsX|jr>|jd|}|dk r.|jdn |jd|S|jrP|j|SdSdS)Nrr9r:)r>rSr@r?r<rr[rrrr _obj_dict_gets  zCmfCache._obj_dict_getr\ inv_payloadcCs|d|S)N::rrrrr%_jshash_invalidate_confirm_member_keysz.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)Nrhzjscache-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\) rrxrycmf_emit_eventrarrrr>sadd) rZmsgsZ confirmations person_idinv_dictr\rr confirm_listrrrrX-s  z CmfCache.emitcCsb|jr^|r^|dd}|j|d}t}|D]}|||d|dq,|jj|f|dS)Nrrr`)r>rrxrrsrem)rZ confirm_dictZ sample_jshashZ key_cache_idrZconfirmrrrjshash_invalidate_confirm<s   z"CmfCache.jshash_invalidate_confirmcs.jr*|}fddj|DSdS)Ncsg|]}|qSr)rrR).0memberrHrr Msz;CmfCache.jshash_invalidate_confirm_list..)r>rsmembers)rrrrrHrjshash_invalidate_confirm_listHs    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)rrrr[rrrrUsz+CmfCache._obj_dict_mdel..rLz#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:rrNupdatercSsg|]}|dkr|qS))Z cache_fieldscmf_modified_at cmf_viewed_atZcmf_modified_by_idr)rrrrrrtsT) is_changedZONLYFORUPDATESrO)r>rVrDrr5rrRrSrTrUr;joinrrrXr?r<) rrrZobj_idactionrYr[Zinvjsr\r]r^Zchanged_fieldsrrrr_obj_dict_mdelQsT         zCmfCache._obj_dict_mdelc Cs|jrN|j6}|D]\}}|jd|f|q|W5QRXnD|jr|D]2}||jkr||j|||qX|||j|<qXndSdSN invalidate:)r>rPryrrWr?r=r)rrrZr[rrrr_invalidate_dict_msets  zCmfCache._invalidate_dict_msetcCsH|jr.|jd|}|r*dd|DS|S|jr@|j|SdSdS)NrcSsg|]}|dqS)r)rRrrrrrsz1CmfCache._invalidate_dict_get..)r>rr?r=rS)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>rPryrrWr?r=rSremove)rrrZrrZkey_listr[rrr_invalidate_dict_mdels zCmfCache._invalidate_dict_mdelc srtjdrdt_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|dD]:}||jd|jdfkrfd}|jqqf|sg} |dr| |d7} |dr| |d7} |dr| |d7} | sdg} | D]} | dkrd} |dD]h}|dd } || krTd|d| dn*d | d!|d | d!| dqq|d"D]} d| dq|r|dsƈd|djrD]} tjd#| d$q҈|sdt_d%tkrdtjrdtjd&dtjjrLtd&tjd'tjfidS)(NNO_CACHETz%DEBUG_CACHE ADD SKIP CACHE LOCKED_BY z#DEBUG_CACHE ADD SKIP too old trans rcs$|krt|<|dSr)rxr)bind)rr[rrbind_adds zCmfCache.add..bind_addcsdt|tr|}n|g}g}|D]@}t|jtjjr>|}nt|}|D] }|qPqdS)u Собираем списки ключей инвалидации :param val: :param invalidate_dict: :return: N)rkrxrrlrrmrr)rZobj_listritemr)rrrrbind_add_recursives  z(CmfCache.add..bind_add_recursiverrrrxZcustomemptyZEmptyuGНевозможный объект для хранения в кешеFrzDEBUG_CACHE WHERE: z.idz.codeparentslistsZcache_clustersZScopeAll)ZNullZNULLZnullriZnoneNrir!where_ScopeAll__insdelwhere_rrzDEBUG_CACHE BIND: z = r\#DEBUG_CACHE JSHASH: add invalidate r)osenvironrSgno_jscache_force CMF_CACHEcache_is_lockedr5rDcache_locked_bycache_transaction_startget_last_invalidaterkrxrrzrqrrrprwrrr'rZcache_store_errorr\rr) rr[robj_typeZ query_paramsrZobj_caseZwhere_pk field_nameZscopesZscopeZ model_nameZbindidr)rrr[rrrs   &              z CmfCache.addc Cs~zdtkrtt_Wn(tk r<}z WYdSd}~XYnXdtjkrTdtjd<ntjdd7<dtjkrzdtjd<dS)N profiler_data cache_hitr` cache_missrrr;rrwrr[rrrrprofiler_data_hitYs    zCmfCache.profiler_data_hitc Cszdtkrtt_Wn(tk r<}z WYdSd}~XYnXdtjkrTdtjd<ntjdd7<dtjkrzdtjd<|tjd<dS)Nrrr`rrZcache_miss_lastrrrrrprofiler_data_missgs     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: )rrrSr5rDrrr\rrrrTrUrrrrrrSvs"      z CmfCache.getcCs t|jdt|jdpdS)Nz%DEBUG_CACHE TRANS get_last_invalidatecache_last_invalidaterr5rDrqr>rSrHrrrrs 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)rqrjnowrcrustrftimerHrrrrszCmfCache.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)'Nrdcs6|}|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_byrd)createrVrzref_new=zref_old=zDEBUG_CACHE ivalidate: z not fields_have_changesr)rrrVcache_cluster_idr! parent_idz where_lst=parent cache_clusterz where_old=)rd)" collectionsrrrrSrr5rDrTRACEpdbZ set_tracerrr rxryrkrlrrroldnewrrrrrrloadrrr) rrrrrrrrZ change_fieldsrrlstrr r invalidates      "          "   22  zCmfCache.invalidatecCs<|jD]\}}td|q|jD]\}}td|q$dS)NzDEBUG CmfCache.dumps)r<r*r=ry)rr[r~rrrr|Js zCmfCache.dumps)NF)N)NN)N)N)-r(r&r3r<r=r>r?rDrrrIr_rbrrrrrr staticmethodrprrrrXrrrrrrrrrrSrrrrrrrr rr|rrrrr6>sZ  @     6  )  r6cCsJt|}|D]4\}}t|trztj|||<WqYqXq|Sr)rryrkrprrsrt)rZdctrrrrrCustomJSONDecoderPs rc@seZdZddZdS)CustomJSONEncodercCsznt|tjtjfr|j}t|tjs2t|tjrP|jsF|dWS|WSt|tj rd|jWSt |}Wnt k rYn Xt |St ||S)NZ)rkrZ CmfDateTimeZCmfDaterorjdateZtzinfoZ isoformatrmiter TypeErrorrxrdefault)rriterablerrrr$\s   zCustomJSONEncoder.defaultN)r(r&r3r$rrrrr[sr)Z static_folderZ root_pathTZSEND_FILE_MAX_AGE_DEFAULT)SocketIO Namespace) RedisManager)Clientrdc 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   r5c@seZdZdZdejdddZddZedd Zed d Zed d Z ed dZ eddZ edddZ eddZ eddZdS)CmfRedisMemoryWrapperut Если есть self.redis - используется он Если нет - нужен фолбэк N)rediscCs||_i|_dSr)r7 memstorage)rr7rrrrszCmfRedisMemoryWrapper.__init__csfdd}|S)Ncs6|jrt|jj||Std|f||SdS)Nu&Redis memory wrapper запрещен!)r7rr( CmfAbortErrorrr+rrwrappersz/CmfRedisMemoryWrapper.fallback..wrapperr)r+r;rr:rfallbacks zCmfRedisMemoryWrapper.fallbackcOstdSrNotImplementedErrorrrrrrszCmfRedisMemoryWrapper.smemberscOstdSrr=rrrrrscCs |j|Srr8rS)rr[rrrrSszCmfRedisMemoryWrapper.getcCs|jdSr)r8clearrHrrrrGszCmfRedisMemoryWrapper.flushdbcCs$|j|d}||7}||j|<|S)Nrr?)rr[amountrorrrr@s zCmfRedisMemoryWrapper.incrbyr`cCs |||Sr)r@)rr[rArrrincrszCmfRedisMemoryWrapper.incrcGs$d}|D]}||jkr|d7}q|S)Nrr`r8)rnamesrnrrrrs   zCmfRedisMemoryWrapper.existscCs||j|<dSrrC)rr[rorrrrszCmfRedisMemoryWrapper.set)N)r`)r(r&r3__doc__r7Redisrr<rrSrGr@rBrrrrrrr6s&        r6c sfdd}tdzzttdttrtdttj}|jt t| D]Z}td||ddkrb|d  }t |g}|D]t j|t|d |d qqbW5QRXWn8ttfk rYn tk rtd YnXW5tdXqdS) Nc s~zFtdd|d|dt||W5QRWSQRXWn2tk rxtdd|d|dYnXdS)NzRun server event handler z(*z, **)z+_spawn_server_event_listener handler error )r* cmf_contextrwlogging 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 rzmessagechanneldata)rSrQz"_spawn_server_event_listener error)timesleeprJr*_server_event_channelsREDIS_DBr7pubsubZ subscriberxZlistenrRrSgeventspawnjsonrU SystemExitKeyboardInterruptrwrKrL)rOrXrQrRZhandlersrrNr_spawn_server_event_listeners*      ,r^cCsttdSr)rYrZr^rrrrspawn_server_event_listenersr_csfdd}|S)Ncst||Sr)rVr)funcrRrrr1 sz"on_server_event..decoratorr)rRpatternr1rraron_server_events rccache_settingsr$rzr7Z run_uwsgiu?При работе через uwsgi обязателен RedisrF)appZcors_allowed_originsloggerZengineio_loggerdbunix_socket_pathzunix://z?db=zflask-socketio)rRZ write_onlyclient_managerredis://host:6379/ message_queue)Payloadd)rfz/custom/org_name)r>r?)r?u&Неизвестный тип кешаcCstjddr0dtjdddtd}ndtjdddtd}td ||d }|jtjGd d d |j}||_|S) Nr$rhzredis+socket://z?virtual_host=r`rjrkrlZcrm)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_namerrrrrWsz-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`rre<T)exZnxzSkip create task z - already started system_taskcmf_current_person_id)Ztask_idrrrr`zcmf-background-task-queued)rrWr7rrpsoft_time_limitrr rcurrent_personrror apply_asyncr[r|socketiorX)rrrZ_my_custom_paramr/Z need_creater event_paramsrrrry]s,   z0make_celery_app..ContextTask.apply_async)rvc _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)NrrPF)init_views_and_dsrstimeoutzcmf-background-task-start-rrz 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-)%rTrUrJrWr7lockrqrwrequestrrzrXracquirerVrpr*rrelease exceptionsZ LockErrorr~r CmfPersonrSr1current_person_fieldsr_current_personrunrwrKrLrprEstdoutr) rrvrrrT redis_lockrresulterrorrrr__call__ssH       z-make_celery_app..ContextTask.__call__)NNN)r(r&r3rryrr4rrrr ContextTaskVs r) rCrdrSrgr ZconfrceleryZTask)Z redis_url celery_apprrrrmake_celery_appJs Fr)rrruc Ks`tjD]T}tdz |Wqttfk r6Yqtk rXtd|YqXqdS)Nscheduler_minutelyuJОшибка выполнения периодической задачи )r1HOOK_CRON_MINUTELYr*r]r\rwrKrL)_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_excrkrZ get_responser[r|rrrrS content_typerheadersrSr;rpZjsonify 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_supportcCsPtjs dSztjs&tjjdtjdt_Wn tk rHt dYnXtjS)Nz.CmfPerson:00000000-0000-0000-0000-000000000001rrzapp.system_person() error) rC AUTH_ENABLEDr1 system_personrrrSrrwrKrLrHrrrrs  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 для проверки прав доступаjsurlrdz/share/Trrr$rz*^(?P[^:-]*)[:-](?P.*)$docZDOC CmfDocumentZflZFLZIN_WORK CmfFolderCmfListZEPIr rhrsharelink_hashr)rr)#rr*rarrSrSujsonrUrwrKrLrkr;rrsharelink_access_requestrZqueryrr'rematchgroupsrrrrrrlZ CmfEntityrrprsharelink_access_grantedsharelink_access_obj) rZjson_resr-Z hash_paramZobj_keyrrZobj_codeZ obj_modelrrrr_check_sharelink_accesss^   ( rcCs |t_tjS)uh!!! Эта функция не меняет контекст, только инициализирует.)rr)personrrrset_current_person\srcCsZt|dddkr|jStjs dSt|dr@t|dddk r@|jStdtjt j ddS)NrZFAIL_recursionz#Warning!!! Lazy Calc Current PersonrA) rrrCrrrr*r print_stackrErrHrrrrxbsrxc sztjstjjdgd}|jsztjjJddl }ddl |j |j d fddtdD|_|W5QRX|jt_Wn tk rtdYnXtjS) Napp_keyrrrdc3s|]}VqdSr)choice)rrZalphabetsecretsrr {szapp_key.. zapp.app_key() error)r1rrCmfGlobalSettingsrSrlutilcmfutil disable_aclstringrZ ascii_lettersdigitsrrangesaverwrKrL)rZsettingsrrrrrqs    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-lockrPr}zapp._anonymous_user() error)rrrrrSr1rrWr7rrrrlrrr system_dataZcreate_anonymous_userrdd commit_all_dsrwrKrLrrrrranonymous_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-lockrPr}z%app._sharelink_anonymous_user() error)rrrrrSr1rrWr7rrrrlrrrrZcreate_sharelink_anonymous_userrrrrwrKrLrrrrsharelink_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-lockrPr}zapp._test_guest_user() error)rrrrrSr1rrWr7rrrrlrrrrZcreate_test_guest_userrrrrwrKrLrrrrtest_guest_users4   rc Cst|dr t|dddk r |jStjjdgd|_|jstjj 8ddl m }|tjjdgd|_|jsxt dW5QRX|jS)N_global_settingsrrr)init_global_settingsu6CmfGlobalSettings не инициализирован.) rrrrrrSrlrrrcmf.system_datarAssertionError)rrrrrglobal_settingss rcCs8t|dr t|dddk r |jStjjdgd|_|jS)N _global_varrr)rrrrZ CmfGlobalVarrSrHrrr global_varsrlinenoc 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|] }|jVqdSrsizerstatrrrr szdisplay_top..z%s other: %.1f KiBcss|] }|jVqdSrrrrrrr"szTotal allocated size: %.1f KiB)Z filter_traces tracemallocZFilterZ statisticsr* enumeraterrseprr3r'rr linecachegetlinestripformatsumr) ZsnapshotZkey_typelimitZ top_statsr#rframer3lineZllotherrtotalrrr display_tops.       rc Cstjjjdddtjj|jtj d}|sdd|j ddD}t j |d <t j |d <t j |d <tjf|}|rd|_ |jtjd|_|jtjtjj|jdd W5QRXt|W5QRSQRXdS) Nzcreate-current_person-lock r})loginrcSs(i|] \}}|ds|dkr||qS)Zcmf_r)ra)rrrrrr ,s  z+create_person_from_auth..TrZ cmf_ownerZ cmf_authorr)Z only_data)rlrrZCmfLockrrrSrr1rryrrrrrZCmfPersonGroupZ support_grouprZ user_grouprrrr)authrrZ person_valuesrrrcreate_person_from_auth&s&     rc sZttjdkrdStdt_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_$dt_%t&j&'t&j(j)t_*d dt_'tj*+t_,ddt_+dt_-it_.it_/gt_0dt_1dt_2ddfdd }|t_3t4j56t7j8spt9ddStj:;drdSd}tj:;dr6tj< dptj< dptj= d}|r6|;dr|t>dd}t4j?@|}t4j?j |dtAjBd}t3d|dd d|d||s6tCdd d!d"Stj:d#krRt4jDjEtAjBd$}|stjF d%}|rt4jGH|t_tjrt7jIot4jGj tjjjJd&}t7jIr|sdt_tjrtjjjJt_t4j?j dtjjtAjBd'}|r|jKrd}n(|stjjLrtM|p tjtjjLd(}tj:;d)p>tj:;d*p>tj:;d+}d,d-}|rRd}|r|jjJt_tjrtjjLt_tjjNt_tjjN t_ndt_dt_dt_dt_t9|n`|s|rtjO} tPtj$rtjQ} dt_dt_dt_dt_t9| ndt_dt_t9tjRtj ptj:;d.ptj:d/kptj:;d0ptj:;drjtjS d1d2krjtjTd3kptj:;d4ptj:d5kptj:;d6ptj:;d7rtjTd3kptj:;d8rtjTd3kp| rtj:;d9rt4jUVptj:;d:otj} tjR} tjW} t4j5X| sVtjsVtjr@|s@tYd;tjd<StjrPtjrVtYSdS)=uJ Должны вернуть Response or None Особенности поведения: В случае web запроса: - response - view не выполняется, сразу отправляем response - None - выполняем view - Exception(в т.ч. и abort) - обработчик выводит трейс клиенту Системный контекст(shell, celery, socket, other with cmf_context): - None, Response - нет разницы - Exception - прерывает выполнение. ZOPTIONSNFZ run_pytest1rrT)choicesrdZ0123456789abcdef)rcSstjSr)r_nowrrrrpz before_request..cSstjSr)r_daterrrrrrr)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)NrDrJrerZ select_countZselectrrinsertmr$z(+z)mszs zu zi t) rrCrproundr debug_start debug_nowrSr;rrr* request_id) rmessagesrrrFZscZscsZscuZscirrrrr s,    "  zbefore_request..debugz/memZOK/api/z X-Eva-TokenZ AuthorizationtokenzBearer T)api_token_hashrrzAuth API Token(z ...): hash=z , person=zInvalid API token text/plainr /pub/webhookr access_token)r)rrr)rz/pub/apiz/docsz/sharecSstjdptjdS)Nr /socket.io/)rr*rarrrris_allow_publics  z'before_request..is_allow_publicz /auth/sync)z /auth/invitez/auth/restore_passwordz /auth/signmoderootz 127.0.0.1z /crm/forms/z/manifest.webmanifestz /app/assets/z/forms/z/js/z/pub/z /helpdeskuУчётная запись uQ заблокирована. Обратитесь к администратору)Zrrrmethodrbefore_requestrrflags remove_filesrrrSZtestrTZrandomrrrrr Zsave_only_data_hackalertdeferred_tasksrZ public_accessrZ is_local_userZ is_guest_userZ is_anonymousrZis_system_contextZdisable_notifyZ import_modeZinteractive_shellrrrrjrrcrurr!rZrelaxed_bz_python_mode emit_list socket_events server_eventsrZjscache_timelifer r CmfAccessListZ init_contextrCrrr*rarrrrZ hash_tokenr1rr Z CmfWebhookZget_token_personZcookiesZCmfAuthZfrom_jwtZIS_AUTHORIZATORrorZjwt_is_supportrZjwt_is_match_orgrrrrrZ remote_addrZ CmfPluginZ check_secretrZ setup_contextreject_response) rr Z auth_personZ api_tokenr rZ real_authZis_force_publicrZ anon_personZis_allow_without_authrrrrrAs.           $                  rcCstjds"tjds"tjdkr4t|p*ddddSdtji}|rJ||d <t|}ttjd |}tj d d |j d <d|j d<d|j d<|SdS)Nrr rznot authorizedrrrZnext_urlrQz /auth/signin?rrrrrrr) rr*rar r-rZredirectrCAUTH_SERVER_URLrrS)rQparamsZqsrErrrr!?s      r!cCstttdSr)rr emit_eventsemit_server_eventsrrrrcommit_with_eventRsr&c CsNtdsdStjD]*\}}td|d|d|dddqit_dS)Nr is_changed-rr$rprivate) namespacer)rrSrryr)rr~rrremit_list_applyYs  $r*c 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)ryrcopyr[r|rwr*rkr&rXrarrlrrrrorp) Z event_dictmsgZevent_param_listZ event_paramr+rZ emit_kwargsrZuser_id event_personevent_persons_strrrremit_events_dictasF       " "    r1cCs&ttdpi}it_t|dS)Nr)r*rrSrr1)rrrrr$sr$cs:fdd}ttdp iit_r6t|dS)uЗапускаемся в контексте, но отправляем в отдельном таске вне контекста, после паузы, чтобы не держать запрос.csttdSr)rYrUr1rdelayrrremitters z'emit_events_with_delay..emitterrN)r*rrSrrYrZ)r3r4rr2remit_events_with_delays r5cCsPtdp g}gt_|D]2\}}td|d|tj|t|qdS)Nrzemit_server_events: r) rrSrr rWr7Zpublishr[r|)rrRrSrrrr%s  r%cCstit_dSr)rZrollback_all_dsrrrrrrrollback_purge_eventsr6cCs$tdgD] }|}q gt_dS)Nr)rrSryr)Ztask_signaturerrrrapply_deferred_run_taskss r7cCs2tdgD]}tj|r t|q gt_dS)Nr)rrSrr*rrrr3rrrapply_deferred_remove_filess  r9cCsNttdttttjdd|jd<d|jd<d|jd<|S) uk Запускается только если небыло ошибок :param r: :return: rerrrrrrr) rrr5r%r7r9rrrS)rErrracaos  r:c CsTtjs dStjt_t,tjj tj j j W5QRXW5QRXtdSr)rCrZDISABLE_PERMISSIONSr1disable_permissionsrJrlrrrincluderr Z load_acl_datar_rrrr app_init_acls "r=c CsNttjjdsdSt,tjjtjjj W5QRXW5QRXdS)NCmfProjectPermScheme) rrlr<rrJrrrr>Zload_project_permission_datarrrrapp_init_project_permissionsr?cCs0ttttjr ttjr,tdSr) rbefore_first_requestr=r?rCWHATSAPP_MESSENGER_URLspawn_messenger_socketio_clientWHATSAPP_WEB_SOCKETspawn_whatsapp_socketio_clientrrrrr@sr@cCstj|ddSNrL)rrrFrrrteardown_requestsrGc 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_stackr9rr)r.r rZ devel_onlyZ stack_strrrrrs"  rr$r()r)r+rrc 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)NrrrNsession_tab_idrdr,)rrr)rr+F) 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)rzrr;rrwrrxrrorzrIr[r|rar*localsrrkrlrrrrp setdefault)r.r)r+rrrrrr{ZmutedZ muted_debtr0r/Z event_listrrrrsL      rcCs"dtkrgt_tj||fdS)Nr)rrr)rRrSrrrcmf_emit_server_eventPsrLcCs|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} rdzsudo z 2>&1z0{0} bash -c "export BOOTUP="noncolor";{1}{2}{3}"T)shellrrFu6Произошла ошибка при вызове %sz STDOUT: %sz STDERR: %su4Произошла ошибка при вызове )NN) r subprocessPopenPIPEZ communicaterR returncoderKr RuntimeError)ZcommandZsudor~waitZseparate_out_and_errZ do_decodeZdo_raiseZ timeout_cmdZ_sudoZ _redirectcmdZprocessouterrZerrcoderrrrun_bash_commandVs8        rWcCsLttj}t}||||}t | }|d|}|S)ua Подписываем токен сертификатом :param jwt: :return: r!) r rr1rsa_private_keyr rrsignbase64 b64encoderR)jwtZsignerZdigestrYrrrrrsa_sign_pack_jwts  r]cCsHddd}tt|}tt|}|d|S)uD Создаем токен :param payload: :return: ZRS256ZJWT)Zalgtypr!)rZr[r[r|rrR)payloadheaderrrr create_jwts racCstjS)u2 Текущая версия :return: )rCZ CMF_VERSIONrrrrcmf_get_versionsrbcCs|tjkrtj|dS)ux Удаления файлов после коммита транзакции :param filename: :return: N)rrrr8rrrcmf_remove_files rcc@s,eZdZd ddddZddZdd ZdS) rJFNr7cCstd|_||_dS)Nz /with-context)r1Ztest_request_contextctxr|)rr|rrrrs zcmf_context.__init__cCs*|j|jrtttdSr)rd __enter__r| start_viewsrZinit_dsr1Zpreprocess_requestrHrrrres  zcmf_context.__enter__cCs<tj|d|s(tttt|j|||dSrE)rrr$r%r7r9rd__exit__)rexcrorrrrrgs zcmf_context.__exit__)F)r(r&r3rrergrrrrrJsrJcCsddddddg}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_dirrrrrszstart_views..rdz/viewsz.pyz.pycz __init__.pyr!css|]}|r|VqdSrr)rrrrrrszstart_views..r$r)packager)r Z view_funcz/Zdistz/static/Zstatic) itertoolschainrvrCr+endswithrarr' importlib import_moduler1r)r5)Z search_dirsZ search_iterdirnamedirnames filenamesr3r,rrrrfs$  $rfcKs,tj|||d}|jf|tj||S)NrM)r signaturerrrr)rrrr/rvrrrcmf_deferred_tasks  rwcCs*tjdddkr&ttjdddgdS)NSOCKETIOZworkerz--poolrY)rrrSrYrZrZ worker_mainrrrrspawn_task_workersrycCs*dd}tjdddkr&td|dS)Nc SsHddlm}t|tdW5QRXtdtjdtddS)NrBeat)rezBeat die!!! Stop worker.rAr`) Zcelery.apps.beatr{rJrrr*rErFexitrzrrrrun_beats  z&spawn_task_scheduler..run_beatrxrP)rrrSrYZ spawn_later)r}rrrspawn_task_schedulersr~cCs"dd}tjrtj|dgddS)NcSs2i}tjddrdtji}tjtj||ddS)Nrxr namespacesr)rrrSrCORG_NAME whatsapp_sioconnectrArrrrmessenger_connects z:spawn_messenger_socketio_client..messenger_connectz /whatsapp)r)rCrArYrZ)rrrrrBsrBcCsttjtjdSr)rYrZwhatsapp_go_siorrCrCrrrrrD srDcCs<ddl}tdtjdtj|jtjtjdddddS)NruYПодключаемся к удаленной отладке config.REMOTE_DEBUG_SERVER=z config.REMOTE_DEBUG_PORT=TF)ZportZstdoutToServerZstderrToServerZsuspend)pydevd_pycharmr*rCZREMOTE_DEBUG_SERVERZREMOTE_DEBUG_PORTsettrace)rrrrcmf_pycharm_debug s rr7cCsHttjtjttttttdtjj dd}t |}t |S)NrsZguid)ZissZorg_nameZiatZexprZjti) r;rCZAPP_FQDNrrprqrTrrrorar])r_r\rrrgen_eva_app_token sr)urirScCsddlm}|}dddd|_tj|}t|d<|j|t|d}|j d krtt d |d |j d |j |}|rd |krt d|t ||S)Nr)sessionrrr)z Content-typeZAcceptzContent-EncodingZ eva_app_token)rSu9Не удалось отправить запрос, url=z, status_code=z, res=ru(Сервер вернул ошибку: )ZrequestsrrrCr"rZpostr[r|rrwZcontentrr )rrSrrr-rrrrrcall_eva_account s$     r)rd)NN)rr)F)N)r)N)FFN)TNTFFF)NN)rrnrTrErZZcalendarrjrNrTrrrrpathlibrZ urllib.parserrrrrr rrYrZ Crypto.Hashr ZCrypto.Signaturer r-r r Z flask.jsonrZwerkzeug.exceptionsrrlrZ cmf.includeZcmf.data_providersrrrrr5objectr6rrr(rCr+r1Z json_encoderrrr2rZHOOK_CRON_HOURLYZHOOK_CRON_DAILYZHOOK_CRON_WEEKLYZHOOK_CRON_MONTHLYr;Zflask_socketior&r'rzr(r)r7r5r6rWrxrVr^r_rcrrdr-Zcfgr%rHrrrSrwrDZsocketio_kwargsrgr-rirmZengineio.payloadrnZmax_decode_packetsrrr*ropenr+readrrrrrrrZ errorhandlerrZregister_error_handlerZprivate_key_pathZpublic_key_pathZCrypto.PublicKeyrZ import_keyZ read_bytesrXZrsa_public_keyrrrrxrrrpropertyrzrZ current_userrrrrrr!r&r*r1r$r5r%r6r7r9Z after_requestr:r=r?r@rGrrrLrWr]rarbrcrJrfrwryr~rBrDrrprr;rrrrrs|             ;'            V   !    b    ~ 1       9 ,