U uc] @szddlmZdZWndZYnXerddlZddlZddlZddlmZddlm Z m Z m Z m Z ddZ Gd d d ejZGd d d ejZGd ddejZGdddejZe ee ee ee edS))xbrTFN)hl) IProviderISeller IConsumerIBuyercOstjd||S)N)N)asyncioget_running_looprun_in_executor)argskwargsr fc:\users\psant\downloads\hotstarbackend\school\venv\Lib\site-packages\autobahn\asyncio\xbr\__init__.pyr )sr c@seZdZeZdS)SimpleBlockchainN)__name__ __module__ __qualname__r ZbackgroundCallerr r r rr,srcs6eZdZeZdfdd ZddZddZZ S) KeySeriesNcst||||d|_dS)NF)super__init__running)selfapi_idZpriceintervalZ on_rotate __class__r rr2szKeySeries.__init__csRjr tjjdtjttjjddd_fdd}t |dS)z\ Start offering and selling data encryption keys in the background. zGStarting key rotation every {interval} seconds for api_id="{api_id}" ..)bytes)rrTcs,jr(IdHtjIdHqdS)N)rZ_rotatersleep _intervalr rr rrotate_with_interval@sz-KeySeries.start..rotate_with_intervalN) rAssertionErrorloginforruuidUUIDZ_api_idr create_task)rr r rrstart6s  zKeySeries.startcCs"|jstd|jjd|_dS)zE Stop offering/selling data encryption keys. z&cannot stop {} - not currently runningFN)r RuntimeErrorformatrrrr r rstopGszKeySeries.stop)N) rrrtxaioZ make_loggerr"rr'r* __classcell__r r rrr/src@seZdZdZeej_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-r r r rr-Psr-c@s eZdZdS) SimpleBuyerN)rrrr r r rr/Wsr/)autobahnrZHAS_XBRr$rr+Z autobahn.utilrZautobahn.xbr._interfacesrrrrr rrr-r/registerr r r rs&   !