o >hT @s`ddlZz ddlmZdZWney+ZzejdedZWYdZ[ndZ[wwerddl Z e ddl m Z ddl mZddlmZddlZdd lmZdd lmZmZmZmZmZdd lmZmZmZGd d d ejZGdddejZGdddej Z Gdddej!Z!e"e e"e e"e e"e!e"e!e"e!dSdS)N)xbrTz,WARNING: could not import autobahn.xbr - {} F) deferToThread) LoopingCall)ensureDeferred)hl) IProviderISeller IConsumerIBuyer IDelegate)_seller_buyer _blockchainc@seZdZeZeZdS)SimpleBlockchainN)__name__ __module__ __qualname__txaio make_loggerlogrbackgroundCallerrr}/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/autobahn/twisted/xbr/__init__.pyr2srcs6eZdZeZdfdd ZddZddZZ S) KeySeriesNcs*t|||||d|_d|_d|_dS)NF)super__init__running _run_loop_started)selfapi_idpriceintervalcount on_rotate __class__rrr9s zKeySeries.__init__csdjdusJjjdtjttjjddd_t fdd_j j_ j S)z\ Start offering and selling data encryption keys in the background. NzGStarting key rotation every {interval} seconds for api_id="{api_id}" ..)bytes)r"r Tcs tS)N)r_rotaterrrrJs z!KeySeries.start..) rrinfor _intervaluuidUUID_api_idrrstartrr)rr)rr0?szKeySeries.startcCs.|js td|jj|jd|_|jS)zE Stop offering/selling data encryption keys. z&cannot stop {} - not currently runningN)r RuntimeErrorformatr&rstoprr)rrrr3Os  zKeySeries.stop)NNN) rrrrrrrr0r3 __classcell__rrr%rr6s rc@seZdZdZeZeZdS) 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__rrrrrrrrr5[sr5c@seZdZeZdS) SimpleBuyerN)rrrrrrrrrrr7cs r7)#sysautobahnrHAS_XBR ImportErrorestderrwriter2r use_twistedtwisted.internet.threadsrtwisted.internet.taskrtwisted.internet.deferrr- autobahn.utilrautobahn.xbr._interfacesrrr r r autobahn.xbrr r rrrr5r7registerrrrrs<     %