|j^ddlmZddlmZmZmZddlmZddlm Z ee Z ddZ ddZ e jddZe j!d d Zdd Ze d k(rey y )) annotations)Flaskjsonifyrequest)config)handle_bitrix_eventctjjd}tjjd}|r|Stjdxsi}|jdxsi}t |t r|jdrt|dStjjd}|r|S|D]@}|jds|dk(s|j|xsg}|s2t|dcSy ) NF)flatauth[application_token]Tsilentauthapplication_tokenr) rformto_dictgetget_json isinstancedictstrargsendswith)bodytoken json_bodyrnestedkeyvaluess 3/var/www/abs-group.kazgame-control.su/app/server.py_extract_tokenr! s <<  U  +D LL  6 7E    -3I == &BD$$((+>"?4+,-- \\  7 8F  & <<+ ,7J0JXXc](bF6!9~% & ctjd}t|tr|j dr|Stj j d}tj j d}tj j d}tj j d}|d||did |id S) NTr eventzdata[FIELDS][ID]zdata[FIELDS][ENTITY_TYPE_ID]r FIELDS)IDENTITY_TYPE_IDr)r$datar)rrrrrr)rr$item_identity_type_idrs r _payload_from_requestr+&s  -I)T"y}}W'= LL  W %Ell12G\\%%&DEN LL  6 7E "0 %e,  r"z/healthctddiS)NokT)rr"r healthr/=s D$<  r"z/actionc  t}|r|tjk7rtdt ddddfSt }td|j dxsdd |j d xsij d ij d xsdd |j d xsij d ij dxsdt|}|j ddk(r;td|j dt dd|j ddStd|j dd|j dt d|j d|j ddS#t$r1}td|t dt|ddfcYd}~Sd}~wwxYw)Nz+Rejected /action: invalid application_tokenFz invalid token)r-errorizIncoming event=r$?z id=r(r%r&z entityTypeId=r'statusignoredz Ignored: reasonT)r-r4r5z Processed #bitrixIdz: action)r-r6r7z/action failed: i) r!routgoing_webhook_tokenprintrr+rr Exceptionr)rpayloadresultexcs r r7r7Bs> !>!>> ? @%/BCSH H') {{7#*s+,;;v&,"11(B?CCDIPSQR$[[06B;;HbIMMN^_fcfg i %W- ::h 9 , Ifjj234 5$46::hCWXY Y FJJz232fjj6J5KLM"JJz2 **X.    >  &'ec#h78#==>s*9FC6F3AF G &G>G G c ntjs tdtdtjtdtdtj ddj dtjDtdtjd tj y) Nz&Missing OUTGOING_WEBHOOK_TOKEN in .envzWebhook server listening on :zHandler URL path: POST /actionzTracked SPA entityTypeId=z , categories=,c32K|]}t|yw)N)r).0xs r zmain..lsC!s1vCszcSubscribe outgoing webhook to ONCRMDYNAMICITEMADD / ONCRMDYNAMICITEMUPDATE / ONCRMDYNAMICITEMDELETEz0.0.0.0)hostport) rr8 SystemExitr9rEr*join category_idsapprunr.r"r mainrKds  ( (ABB )&++ 78 *+ #F$9$9#:;hhCv/B/BCCD F  PGGG-r"__main__N)returnr)rMr)rMNone) __future__rflaskrrr app.configr app.servicer__name__rIr!r+rr/postr7rKr.r"r rUs{"))+ Ho6.!!)>>B." zFr"