8'hhzddlZddlZddlZddlZddlmZmZddlmZm Z ddl m Z ddl m Z mZddlmZddlZddlZddlZddlZddlZddlZddl mZmZmZGd d eZGd d eZGd deZy)N)RegisterOptions CallDetails)ApplicationError TransportLost)ApplicationSession)unpack_uint256 pack_uint256)time_ns)hlrecover_eip712_signersign_eip712_datacFeZdZdZd dZedZdZdZdZ dZ d Z y) KeySeriesz} Data encryption key series with automatic (time-based) key rotation and key offering (to the XBR market maker). Nc:t|tk(rt|dk(sJt|tk(r|dkDsJt|tk(r|dkDsJ| t |sJ||_||_||_||_d|_ d|_ d|_ i|_ y)a} :param api_id: ID of the API for which to generate keys. :type api_id: bytes :param price: Price per key in key series. :type price: int :param interval: Key rotation interval in seconds. :type interval: int :param on_rotate: Optional user callback fired after key was rotated. :type on_rotate: callable rN) typebyteslenintcallable_api_id_price _interval _on_rotate_id_key_box_archive)selfapi_idpriceinterval on_rotates P/var/www/html/trade_iq/venv/lib/python3.12/site-packages/autobahn/xbr/_seller.py__init__zKeySeries.__init__8sF|u$V):::E{c!eai//H~$A55 HY$777  !#   c|jS)z Get current XBR data encryption key ID (of the keys being rotated in a series). :return: Current key ID in key series (16 bytes). :rtype: bytes )rr s r%key_idzKeySeries.key_idVs xxr'ctj|}|jj|}|jd|fS)z Encrypt data with the current XBR data encryption key. :param payload: Application payload to encrypt. :type payload: object :return: The ciphertext for the encrypted application payload. :rtype: bytes cbor)cbor2dumpsrencryptr)r payloaddata ciphertexts r%r/zKeySeries.encryptas7{{7#YY&&t, xx++r'ct|tk(rt|dk(sJt|tk(rt|dk(sJ|j|\}}tj j tj j|tjj}|j|tjj}|S)a Encrypt a (previously used) XBR data encryption key with a buyer public key. :param key_id: ID of the data encryption key to encrypt. :type key_id: bytes :param buyer_pubkey: Buyer WAMP public key (Ed25519) to asymmetrically encrypt the data encryption key (selected by ``key_id``) against. :type buyer_pubkey: bytes :return: The ciphertext for the encrypted data encryption key. :rtype: bytes r )encoder) rrrrnaclpublic SealedBox PublicKeyencoding RawEncoderr/)r r* buyer_pubkeykey_ sendkey_box encrypted_keys r% encrypt_keyzKeySeries.encrypt_keypsF|u$V):::L!U*sJJ%%dkk&;&;&D&DE KK))$))4 $(99dii"8 dhh  B|95diidhh/0diidll34  6 ??//$' ' '  'sEE!EE!rC) __name__ __module__ __qualname____doc__r&propertyr*r/rArFrIr[r'r%rr2s9 < ,4$$(r'rceZdZdZy) PayingChannelct|tk(rt|dk(sJt|tk(r|dkDsJt|tk(r|dk\sJ||_||_||_y)Nr)rrrr_adr_seq_balance)r adrseqbalances r%r&zPayingChannel.__init__scCyE!c#h"n44CyCC!G++G}#1 44   r'N)r\r]r^r&rar'r%rcrcs r'rccreZdZdZdZdZdZdZdZdZ ddZ e dZ dd Z d Zd Zd Zd Z ddZddZy) SimpleSellerNrrct|tk(rt|dk(sJdj|t|tk(rt|dk(sJdj||(t|tk(sJdj|t j |_tj|_ ||_ ||_ tjj||_d|_|j j$j'|_d|_|xst |j j$|_i|_d|_d|_d|_i|_i|_d|_d|_y)a :param market_maker_adr: Market maker public Ethereum address (20 bytes). :type market_maker_adr: bytes :param seller_key: Seller (delegate) private Ethereum key (32 bytes). :type seller_key: bytes :param provider_id: Optional explicit data provider ID. When not given, the seller delegate public WAMP key (Ed25519 in Hex) is used as the provider ID. This must be a valid WAMP URI part. :type provider_id: string rez0market_maker_adr must be bytes[20], but got "{}"r4z/seller delegate must be bytes[32], but got "{}"Nz0provider_id must be None or string, but got "{}"r)rrrformatstrtxaio make_loggerrWrm STATE_NONE_state_market_maker_adr _pkey_raweth_keyskeys PrivateKey_pkey_acct public_keyto_canonical_address_addr_caddr _provider_id _channels_channelrhrg_keys _keys_map_session _session_regs)r market_maker_adr seller_key provider_ids r%r&zSimpleSeller.__init__s$%.37G3HB3N \QCQJQJK[Q\ \NJ5(S_-B IDuD|D|~HEI IB"d;&73&> G@r@y@y{FAG G>$$&#-- "2$]]--j9  ZZ**??A  (E3tzz/D/D+E     !r'c.|jjS)z This seller delegate public Ethereum key. :return: Ethereum public key of this seller delegate. :rtype: bytes )r}rr)s r%rzSimpleSeller.public_keyszz$$$r'cttk(rtdk(rjvsJttk(rdkDsJt|tk(r|dkDsJGtt k(r.dj DrdjDsJdfd}j||}|j<jjd||S) a Add a new (rotating) private encryption key for encrypting data on the given API. :param api_id: API for which to create a new series of rotating encryption keys. :type api_id: bytes :param price: Price in XBR token per key. :type price: int :param interval: Interval (in seconds) in which to auto-rotate the encryption key. :type interval: int rrc3@K|]}t|tk(ywrCrrs).0ks r% z#SimpleSeller.add..sCnWXDGsNCnc3@K|]}t|tk(ywrCr)rvs r%rz#SimpleSeller.add..s2taHItxyzt{@CuCtarzZinvalid categories type (must be dict) or category key or value type (must both be string)cK|j}| j|<d}|rX tdz } j}t j d} j } jjd| |||d t nd dd| d{} jjdtdd ttj| ttj tt t! d z nd d zd tt#j$|j't  jj)d|yyy7#t*$rT}|j,dk(r jj/dn jj1Yd}~yYd}~nId}~wt2$r jj/dYy jj1YnxYw|dz} jj/d|t5j6dd{7|r@w)Nld( Azxbr.marketmaker.place_offer)privkeyr" categoriesexpirescopiesrzh{tx_type} key "{key_id}" offered for {price} [api_id={api_id}, prefix="{prefix}", delegate="{delegate}"]z XBR OFFER rKrLrNNZor XBR)rOr*r!r"delegateprefixz offer={offer})offerzwamp.error.no_such_procedurez-xbr.marketmaker.offer: procedure unavailable!z2TransportLost while calling xbr.marketmaker.offer!rz6Failed to place offer for key! Retrying {retries}/5 ..)retries)r*rr rrPrQrrcallr rWrXr rYrZrsrbinasciib2a_hexdecodedebugrerrorwarnfailurerasynciosleep) key_seriesr*r valid_fromr signaturerrer!rrr"r s r%r$z#SimpleSeller.add..on_rotates&&F%/DNN6 " G,'!(\!9J#zzH " 2I"&"3"3K"&--"4"45R5;5;5;5?5=5>=ARWRc<;Nim@J=A<@AL#5 #N NEHHMMC "OS)9%:UV!WZ`!`hqr!#H$4$4X$>$E$E$G!H!&z"+HHNN?%N@C N6(ww"@@ &UV((*W%HHMM"VW'HH$$&1  V`g hmmA&&&cs[!I%A2E?E=C"E?:I%=E?? HAG I%'H>I%H?I%II%z#Created new key series {key_series})r) rrrrrdictr{valuesrrWrX)r r!rr"r#rr$rs```` ` r%addzSimpleSeller.addsF|u$V):vTZZ?WWWE{c!eai//H~$A55!d:&6$&>Cn\f\k\k\mCntaMWM^M^M`ta @d@ @b; '; 'z^^FE8YG ' 6  ; Sr'c BKt|tsJdj||jtj tj fvsJdtj|_||_g|_ |jjdt|jtj|j j"ddj%dj|j&}|j)|j*|t-d  d{}|jj/||jj1d t|j2 d j|j&}|j)|j4|t-d  d{}|jj/||jj1d t|j2 |j6j9D]}|j;d{|j=d|j>d{}|j=d|dd{}tA|dtBk(rtE|d|d<|jjdtdtj|dj%ztG|d|d|d|jH|d<tjJ|_||_&|d|_'tA|jNtBk(rtE|jN|_'|d|_(|dS7b77R7/7w)z Start rotating keys and placing key offers with the XBR market maker. :param session: WAMP session over which to communicate with the XBR market maker. :type session: :class:`autobahn.wamp.protocol.ApplicationSession` z/session must be an ApplicationSession, was "{}"zseller already runningzRStart selling from seller delegate address {address} (public key 0x{public_key}..)N )addressrzxbr.provider.{}.selldetails) details_arg)optionsz"Registered procedure "{procedure}") procedurezxbr.provider.{}.close_channelz)xbr.marketmaker.get_active_paying_channelz*xbr.marketmaker.get_paying_channel_balancechannel remainingzIDelegate has currently active paying channel address {paying_channel_adr}0x)paying_channel_adrrj)) isinstancerrrrwrmrv STATE_STOPPEDSTATE_STARTINGrrrWrXr rrrr}rrrregistersellrappendrr close_channelrrrFrrrrr rcr STATE_STARTEDrrhrg)r sessionrregrrpaying_balances r%rFzSimpleSeller.start]s'#56y8i8p8pqx8yy6{{|66 8R8RSSmUmmS"11    j o!)!1!1$**2G2G2L!M!T!T!V  X+11$2C2CD $$TYY ?_hCi$jj !!#& ;r#--GXY3::4;L;LM $$T%7%7OhqLr$ss !!#& ;r#--GXY**++- %J""$ $ $ % %PRVR\R\]] '||,XZabkZlmm {+ , 5*8 9T*UN; '  a)+D83C3CGIDV3W3^3^3`,`)a  c.;79;M~^cOdftvAgB.Cwy)*"00   &{3  % '*4==9DM"5) k**Ek t %^ns]D,N.N/BNNA?NN%N*N+NND NNNNNcK|jtjfvsJdtj|_g}|jj D]#}|j }|j|%|jr_|jrL|jjr2|jD]#}|j}|j|%d|_tj|} |d{tj |_d|_ y7!#|jjY=xYw#tj |_d|_ wxYww)zF Stop rotating/offering keys to the XBR market maker. seller not runningN)rwrmrSTATE_STOPPINGrrrIrrr is_attached unregisterrtgatherrWrr)r dlrdrs r%rIzSimpleSeller.stops%{{|99::Ptddj|jj|j$dz|t'|}||j(k7r;tddj|jj|j(|t+|||||}||k7r|j,j/d|jjt1tj|jt1tj|jtddj|jjt3|j4||||} |j6|t9||| d} |j,j;d|jjt1ddt1t=t |dz dzdt1|t1tj|jt1|j>t1|j@ | S)!zI Called by a XBR Market Maker to close a paying channel. rez.market_maker_adr must be bytes[20], but was {}z)channel_adr must be bytes[20], but was {}z#channel_seq must be int, but was {}r4z-channel_balance must be bytes[32], but was {}z)channel_is_final must be bool, but was {}rz3marketmaker_signature must be bytes[65], but was {}/details must be autobahn.wamp.types.CallDetailsz!xbr.error.unexpected_delegate_adrzS{}.sell() - unexpected market maker (delegate) address: expected 0x{}, but got 0x{}r xbr.error.unexpected_channel_adrJ{}.sell() - unexpected paying channel address: expected 0x{}, but got 0x{} xbr.error.unexpected_channel_seqR{}.sell() - unexpected channel (after tx) sequence number: expected {}, but got {}r$xbr.error.unexpected_channel_balanceJ{}.sell() - unexpected channel (after tx) balance: expected {}, but got {}t{klass}.sell()::XBRSIG[4/8] - EIP712 signature invalid: signer_address={signer_address}, delegate_adr={delegate_adr}klasssigner_address delegate_adrxbr.error.invalid_signatureO{}.sell()::XBRSIG[4/8] - EIP712 signature invalid or not signed by market maker)rrjrkis_finalrz{klass}.close_channel() - {tx_type} closing channel {channel_adr}, closing balance {channel_balance}, closing sequence {channel_seq} [caller={caller}, caller_authid="{caller_authid}"]z XBR CLOSE rKrLrr)rrOchannel_balance channel_seq channel_adrcaller caller_authid)!rrrrrrboolrrrxr __class__r\rrrrrleavergr rhr rWrr rryrr rXrsrr) r rrrrchannel_is_finalmarketmaker_signaturerrseller_signaturereceipts r%rzSimpleSeller.close_channels* $%.37G3HB3N `QAQHQHIMN^I_Q` `NK E)c+.>".D LFqFxFxy}JzKGL LDK C'h)N)U)UVZ[fVg)hh'O$-#o2F"2L \N}OEOEFJKZF[O\ \L$%-y/Z/a/abfgwbx/yy-)*e3tddj |jj|j&dz|||j(|z k7r>tddj |jj|j(|z |t+|||d|} | |k7r|j,j/d|jjt1tj| jt1tj|jtddj |jj|xj&dz c_|xj(|zc_| j3||} t| tk(rt| dk(s+Jd j |jj| t5|j6|j d|j&|j(} ||j8|| |j&||j(| d!}|j,j;d"|jjt1d#d$%t1t=j>|&t1tAt|d'z d(zd$%t1tAt|j(d'z d(zd$%t1| jBt1| jDt1tj|j) |S)*al Called by a XBR Market Maker to buy a data encyption key. The XBR Market Maker here is acting for (triggered by) the XBR buyer delegate. :param market_maker_adr: The market maker Ethereum address. The technical buyer is usually the XBR market maker (== the XBR delegate of the XBR market operator). :type market_maker_adr: bytes of length 20 :param buyer_pubkey: The buyer delegate Ed25519 public key. :type buyer_pubkey: bytes of length 32 :param key_id: The UUID of the data encryption key to buy. :type key_id: bytes of length 16 :param channel_adr: The on-chain channel contract address. :type channel_adr: bytes of length 20 :param channel_seq: Paying channel sequence off-chain transaction number. :type channel_seq: int :param amount: The amount paid by the XBR Buyer via the XBR Market Maker. :type amount: bytes :param balance: Balance remaining in the payment channel (from the market maker to the seller) after successfully buying the key. :type balance: bytes :param signature: Signature over the supplied buying information, using the Ethereum private key of the market maker (which is the delegate of the marker operator). :type signature: bytes of length 65 :param details: Caller details. The call will come from the XBR Market Maker. :type details: :class:`autobahn.wamp.types.CallDetails` :return: The data encryption key, itself encrypted to the public key of the original buyer. :rtype: bytes rezdelegate_adr must be bytes[20]r4zbuyer_pubkey must be bytes[32]rzkey_id must be bytes[16]zchannel_adr must be bytes[20]zchannel_seq must be intz)amount_paid must be bytes[32], but was {}z*post_balance must be bytes[32], but was {}rzsignature must be bytes[65]rz$xbr.error.unexpected_marketmaker_adrzH{}.sell() - unexpected market maker address: expected 0x{}, but got 0x{}zcrossbar.error.no_such_objectz{}.sell() - no key with ID "{}"rrrrrrrrFrrrrPzC{}.sell() - unexpected sealed key computed (expected bytes[80]): {})r*rr< sealed_keyramountrkrz{klass}.sell() - {tx_type} key "{key_id}" sold for {amount_earned} - balance is {balance} [caller={caller}, caller_authid="{caller_authid}", buyer_pubkey="{buyer_pubkey}"]z XBR SELL rKrLrNrr)rrOr* amount_earnedrkrrr<)#rrrrrrrrr rxrrr\rrrrrrrrgrhr rWrr rArryrrXrYrZrsrr)r rr<r*rrrrkrrrrrrrs r%rzSimpleSeller.sell#s#L$%.37G3HB3NpPppNL!U*s".DeFeeDK C'B)BB'F|u$V):|(.66:@DJr'rm)rrrPrYautobahn.wamp.typesrrautobahn.wamp.exceptionrrautobahn.wamp.protocolr_utilr r zlmdbr r-rz nacl.secretr6 nacl.utils nacl.publicrtr r robjectrrcrmrar'r%rse6 <C5/  ?>s(s(l F {6{r'