o i] @sz ddlmZdZWndZYeroddlZddlZddlZddlmZddlm Z m Z m Z m Z ddZ Gd d d ejZGd d d ejZGd ddejZGdddejZe ee ee ee edSdS))xbrTFN)hl) IProviderISeller IConsumerIBuyercOstjdg|Ri|SN)asyncioget_running_looprun_in_executor)argskwargsrcC:\Users\psant\Downloads\PAF backend\school\venv\Lib\site-packages\autobahn/asyncio/xbr/__init__.pyr )sr c@seZdZeZdS)SimpleBlockchainN)__name__ __module__ __qualname__r ZbackgroundCallerrrrrr,srcs6eZdZeZdfdd ZddZddZZ S) KeySeriesNcst||||d|_dS)NF)super__init__running)selfapi_idZpriceintervalZ on_rotate __class__rrr2s zKeySeries.__init__csTjrJjjdtjttjjddd_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)rrTcs6jrIdHtjIdHjsdSdSr)rZ_rotater sleep _intervalrrrrrotate_with_interval@s z-KeySeries.start..rotate_with_intervalN) rloginforruuidUUIDZ_api_idr create_task)rr!rr rstart6s  zKeySeries.startcCs"|js td|jjd|_dS)zE Stop offering/selling data encryption keys. z&cannot stop {} - not currently runningFN)r RuntimeErrorformatrrr rrrstopGs zKeySeries.stopr) rrrtxaioZ make_loggerr"rr'r* __classcell__rrrrr/s rc@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-rrrrr-Ps r-c@s eZdZdS) SimpleBuyerN)rrrrrrrr/Wsr/)ZautobahnrZHAS_XBRr$r r+Z autobahn.utilrZautobahn.xbr._interfacesrrrrr rrr-r/registerrrrrs*  !