o @Bi @sz ddlmZdZWndZYersddlZddlZeddlZddlmZddl m Z m Z m Z m Z ddZGd d d ejZGd d d ejZGd ddejZGdddejZe ee ee ee edSdS))xbrTFN)hl) IProviderISeller IConsumerIBuyercOstjdg|Ri|SN)asyncioget_running_looprun_in_executor)argskwargsrT/var/www/html/Trade-python/venv/lib/python3.10/site-packages/autobahn/asyncio/xbr.pyr ,sr c@seZdZeZdS)SimpleBlockchainN)__name__ __module__ __qualname__r backgroundCallerrrrrr/srcs6eZdZeZdfdd ZddZddZZ S) KeySeriesNcst||||d|_dS)NF)super__init__running)selfapi_idpriceinterval on_rotate __class__rrr5s 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)r_rotater sleep _intervalrrrrrotate_with_intervalCs z-KeySeries.start..rotate_with_intervalN) rloginforr#uuidUUID_api_idr create_task)rr%rr$rstart9s  zKeySeries.startcCs"|js td|jjd|_dS)zE Stop offering/selling data encryption keys. z&cannot stop {} - not currently runningFN)r RuntimeErrorformatrrr$rrrstopJs zKeySeries.stopr) rrrtxaio make_loggerr&rr,r/ __classcell__rrrrr2s 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__rrr3rrrrr3Ss r3c@s eZdZdS) SimpleBuyerN)rrrrrrrr5Zsr5)autobahnrHAS_XBRr r0 use_asyncior(autobahn.xbr._utilrautobahn.xbr._interfacesrrrrr rrr3r5registerrrrrs,  !