gddlmZmZmZddlmZddlmZddlm Z ddlZddl Z ddl Z ddl Z ddl m Z ddlmZddlmZdd lmZed d ZeeZee j.d de j.dde j.ddZee j.ddeZdZej4j7ede j.ddZdZdZejAddgdZ!ejAd d!gd"Z"ejAdd!gd#Z#ejAdd$Z$ed%k(r7ejKd&e j.d'd(e j.d)d*+yy),)Flaskrequestjsonify)Redis)Queue)environN)datetime)sleep)ConnectionError) setup_loggerbrokerz broker.log)log_file REDIS_HOST localhost REDIS_PORT6379REDIS_DB)hostportdb REDIS_QUEUEztrello-notifications) connectiontrello_notification_/ SID_FILE_PATHz sids.jsonctj|d}ttj|j dj S)NT) sort_keyszutf-8)jsondumpsDEDUPE_KEY_PREFIXhashlibmd5encode hexdigest)datadata_strs >/var/www/trellinator.diamondhoofcare.com/public_html/broker.pygenerate_dedupe_keyr(s@zz$$/H X__W-E!F!P!P!R S TTcg}tjjtr.t td5}t j |}ddd|j|tjjdt td5}t j||dddy#1swYmxYw#1swYyxYw)Nr)sid timestampw) ospathexistsropenrloadappendr now isoformatdump)new_sidr%files r' store_sidr:&s D ww~~m$ - % #99T?D # KKhlln.F.F.HIJ mS !T $  # #sB8C8CC z/webhookGET)methodsc tjdtjj }|j ddr)t |j dtddidfStjdtddidfS#t$r1}tjd |tddid fcYd}~Sd}~wwxYw) Nz:: WEBHOOK GET Received ::r,successTCouldn't find SIDF Exception: ) loggerinforargsto_dictgetr:rerror Exception)rFes r' verificationrL0s 0 01||##% 88E4 dhhuo &It,-s2 2 LL, -Iu-.3 3 0 {1#&' 5)*C//0s$A-B0#B C&C C Cz /update-sidPOSTch tj}|jddr*t|jdt ddddfSt j dt dddd fS#t$r5}t j d |t dd |dd fcYd}~Sd}~wwxYw) Nr,Tz Data Updated.)r>msgr?r@FzInvalid Data...rArBzError Occured: rC)rrrHr:rrDrIrJ)r%rKs r' updateSIDrP?s N|| 88E4 dhhuo &tODEsJ J LL, -u5FGH#M M N {1#&'5?1#1FGH#MMNs$A A3$A33 B1<*B,&B1,B1ctj}tjd |rt |}|st ddidfSt j|r(tjd|t dddd fSd }d }|d kDr t j|d d |d k(r$tjdt ddidfS tjd|}tjd|jd|t d|j!dd fStjdt ddidfS#t$r1tjd|d|d z}t||dz}YnwxYw|d kDr#t"$r1}tjd|t ddidfcYd}~Sd}~wwxYw#t"$r1}tjd|t ddidfcYd}~Sd}~wwxYw) Nz Data ReceivedrIzInvalid notification datarAz!Duplicate notification detected: duplicatezNotification already processed)statusmessager?ri processedz%Redis connection failed. Retrying in zs...z2Failed to connect to Redis after several attempts.z+Service unavailable, please try again laterizworker.process_jobzJob z added to the queue with data: accepted)rSjob_idzFailed to enqueue job: zInternal server errorrCz(Invalid data received, missing JSON bodyz Invalid dataz Exception : )rrrDrEr(rredisrHsetexRedisConnectionErrorwarningr rIqueueenqueueidget_idrJ)r% dedupe_keyretries backoff_timejobrKs r'webhookrgOs  <Nothing Here...rir)r'indexrjs %r)__main__F SERVER_HOSTz0.0.0.0 SERVER_PORTi)debugrr)&flaskrrrr[rrqrr/rrloggingr!r timer redis.exceptionsr r]rDr __name__apprHr_r r0dirname__file__rr(r:routerLrPrgrjrunrir)r'rzs)) D h 6 Ho ;7;;|[97;;|V4Z+ - kgkk-)?@US+77??8,-Q{w{{?K/X.YZ U:w' 0( 0=6(+ N, N:x(.7).7`3&& zGG%kgkk-C+'++VceiJjGkr)