tf]  ddlmZdZn #dZYnxYwerddlZddlZddlZddlmZddlm Z m Z m Z m Z dZ Gdd ejZGd d ejZGd d ejZGddejZe jee jee jee jedSdS))xbrTFN)hl) IProviderISeller IConsumerIBuyercFtjjdg|Ri|SN)asyncioget_running_looprun_in_executor)argskwargss \/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/autobahn/asyncio/xbr/__init__.pyr r )s.9w'))9$PPPPPPPceZdZeZdS)SimpleBlockchainN)__name__ __module__ __qualname__r backgroundCallerrrrr,s*rrcJeZdZejZdfd ZdZdZxZ S) KeySeriesNc^t||||d|_dS)NF)super__init__running)selfapi_idpriceinterval on_rotate __class__s rrzKeySeries.__init__2s, GG  VUHi @ @ @ DLLLrc KjrJjdtjtt jjd_fd}tj |dS)z\ Start offering and selling data encryption keys in the background. zGStarting key rotation every {interval} seconds for api_id="{api_id}" ..)bytes)r"r TcKjrBd{Vtjjd{Vj@dSdSr )r_rotater sleep _intervalrsrrotate_with_intervalz-KeySeries.start..rotate_with_interval@sul8,,..(((((((!-777777777l88888rN) rloginforr*uuidUUID_api_idr create_task)rr,s` rstartzKeySeries.start6s| # # # HMMc#%dn#5#5bQUQ]A^A^A^>_>_  a a aDL 8 8 8 8 8   4 4 6 6 7 7 7 7 7rcz|js,td|jjd|_dS)zE Stop offering/selling data encryption keys. z&cannot stop {} - not currently runningFN)r RuntimeErrorformatr$rr+s rstopzKeySeries.stopGs>< m"#K#R#RSWSaSj#k#klll DLLLrr ) rrrtxaio make_loggerr-rr3r7 __classcell__)r$s@rrr/ske!! ! ! ! ! ! ! 8 8 8" ! ! ! ! ! ! !rrc*eZdZdZeej_dS) SimpleSellerz Simple XBR seller component. This component can be used by a XBR seller delegate to handle the automated selling of data encryption keys to the XBR market maker. N)rrr__doc__rrr<rrrr<r<Ps'  &/"""rr<ceZdZdS) SimpleBuyerN)rrrrrrr?r?Ws rr?)autobahnrHAS_XBRr/r r8 autobahn.utilrautobahn.xbr._interfacesrrrrr rrr<r?registerrrrrEs6GGGGG ;$KKKNNNLLL      NNNNNNNNNNNNQQQ+++++3/+++!!!!!CM!!!B/////s'///     co   G\"""I|$$$FOK   I{#####w;$;$s