o >h] @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)argskwargsr}/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/autobahn/asyncio/xbr/__init__.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__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)r_rotater sleep _intervalrrrrrotate_with_interval@s z-KeySeries.start..rotate_with_intervalN) rloginforr#uuidUUID_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) rrrtxaio 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__rrr3rrrrr3Ps r3c@s eZdZdS) SimpleBuyerN)rrrrrrrr5Wsr5)autobahnrHAS_XBRr(r r0 autobahn.utilrautobahn.xbr._interfacesrrrrr rrr3r5registerrrrrs*  !