U ucT @s\ddlZzddlmZdZWn8ek rTZzejdedZW5dZ[XYnXerXddl 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!dS)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_loggerlogrZbackgroundCallerrrhc:\users\psant\downloads\hotstarbackend\school\venv38\Lib\site-packages\autobahn\twisted\xbr\__init__.pyr2srcs6eZdZeZdfdd ZddZddZZ S) KeySeriesNcs*t|||||d|_d|_d|_dS)NF)super__init__running _run_loop_started)selfapi_idZpriceintervalcountZ on_rotate __class__rrr9szKeySeries.__init__csbjdkstjjdtjttjjddd_ 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 rTcs tS)N)rZ_rotaterrrrJz!KeySeries.start..) rAssertionErrorrinforZ _intervaluuidUUIDZ_api_idrrstartrr%rr%rr,?szKeySeries.startcCs.|jstd|jj|jd|_|jS)zE Stop offering/selling data encryption keys. z&cannot stop {} - not currently runningN)r RuntimeErrorformatr#rstoprr%rrrr/Os  zKeySeries.stop)NNN) rrrrrrrr,r/ __classcell__rrr"rr6src@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__rrrrrrrrr1[sr1c@seZdZeZdS) SimpleBuyerN)rrrrrrrrrrr3csr3)#sysautobahnrZHAS_XBR ImportErrorestderrwriter.rZ use_twistedZtwisted.internet.threadsrZtwisted.internet.taskrZtwisted.internet.deferrr*Z autobahn.utilrZautobahn.xbr._interfacesrrr r r Z autobahn.xbrr r rrrr1r3registerrrrrs4     %