tf ddlZddlZddlZddlZddlmZmZddlmZm Z ddl m Z ddl m Z mZddlmZddlZddlZddlZddlZddlZddlZdd lmZmZdd lmZmZGd d eZGd deZGddeZ dS)N)RegisterOptions CallDetails)ApplicationError TransportLost)ApplicationSession)unpack_uint256 pack_uint256)time_ns)hlhlval)sign_eip712_channel_closerecover_eip712_channel_closecNeZdZdZd dZedZdZdZdZ dZ d Z dS) KeySeriesz} Data encryption key series with automatic (time-based) key rotation and key offering (to the XBR market maker). Nct|tkrt|dksJt|tkr|dksJ| t|tkr|dksJ| t|tkr|dksJ||||J|t |sJ||_||_||_||_d|_ ||_ d|_ d|_ d|_ i|_dS)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: Interval in seconds after which to auto-rotate key. :type interval: int :param count: Number of encryption operations after which to auto-rotate key. :type count: int :param on_rotate: Optional user callback fired after key was rotated. :type on_rotate: callable rN)typebyteslenintcallable_api_id_price _interval_count_count_current _on_rotate_id_key_box_archive)selfapi_idpriceintervalcount on_rotates S/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/autobahn/xbr/_seller.py__init__zKeySeries.__init__7s $F||u$$V):):):):E{{c!!eqjjjjDNNc$9$9hllll}e!3!3  U%6H>J%%dk&;&DEE K))$)44 $(9di"8 dh  B|9555didh///00didl33344  6 6 6 ? (//$'' ' ' ' ' ' ' ' ' ' ( (r,NNN) __name__ __module__ __qualname____doc__r+propertyr/r5rGrLrOr4r,r*rr1s ####JX,,,,4$$$$$$(((((r,rceZdZdZdS) PayingChannelc t|tkrt|dksJt|tkr|dksJt|tkr|dksJ||_||_||_dS)Nrr)rrrr_adr_seq_balance)r$adrseqbalances r*r+zPayingChannel.__init__sxCyyE!!c#hh"nnnnCyyCC1HHHHG}}##1    r,N)rbrcrdr+rgr,r*riris#     r,riczeZdZdZdZdZdZdZdZdZ ddZ e dZ dd Z d Zd Zd Zd Z ddZddZdS) SimpleSellerNrrr cjt|tkrt|dksJd|t|tkrt|dksJd||5t|tksJd|t j|_tj |_ ||_ d|_ ||_ tj||_d|_|jj|_d|_|pt |jj|_i|_d|_d|_d|_i|_i|_d|_d|_dS)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 z0market_maker_adr must be bytes[20], but got "{}"r:z/seller delegate must be bytes[32], but got "{}"Nz0provider_id must be None or string, but got "{}"r) rrrformatstrtxaio make_loggerr]rr STATE_NONE_state_market_maker_adr _xbrmm_config _pkey_raweth_keyskeys PrivateKey_pkey_acct public_keyto_canonical_address_addr_caddr _provider_id _channels_channelrmrl_keys _keys_map_session _session_regs)r$market_maker_adr seller_key provider_ids r*r+zSimpleSeller.__init__s$%%..37G3H3HB3N3N3NQCQJQJK[Q\Q\3N3N3NJ5((S__-B-B-BDuD|D|~HEIEI-B-B-B"d;&7&73&>&>&>@r@y@y{FAGAG&>&>&>$&&#- "2!$]--j99  Z*??AA  (E3tz/D+E+E     !r,c|jjS)z This seller delegate public Ethereum key. :return: Ethereum public key of this seller delegate. :rtype: bytes )rrr.s r*rzSimpleSeller.public_key sz$$r,cttkrtdkr jvsJttkrdksJ| t|tkr|dksJ| t|tkr|dksJ||||J^tt krz#SimpleSeller.add..+s-CnCnWXDGGsNCnCnCnCnCnCnr,c3FK|]}t|tkVdSrIr)rvs r*rz#SimpleSeller.add..+s_tataHItxyzt{t{@CuCtatatatatatar,zZinvalid categories type (must be dict) or category key or value type (must both be string)cK|j}| j|<d}|rN tdz } j}t jd} j} jd| |||d t nd dd| d{V} j dtdd ttj| ttj tt t! d z nd d zd tt#j|t  j d|dS#t($rO}|jdkr j dn j Yd}~dSYd}~nId}~wt0$r j dYdS j YnxYw|dz} j d|t3jdd{V|LdSdS)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 rQrRrTNZor XBR)rUr/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 rrVrWrrcallr r]r^r r_r`rxrbinasciib2a_hexdecodererrorwarnfailurerasynciosleep) key_seriesr/r valid_fromr signaturerrer%rrr&r$s r*r)z#SimpleSeller.add..on_rotate-s&F%/DN6 " G1 ','!(\!9J#zH " 2I"&"3K"&-"4"45R5;5;5;5?5=5>=ARWRc<;N;N;Nim@J=A<@AL#5 #N #N N N N N N NEHNNC "OS)9%:%:%:UV!W!WZ`!`hqrrr!#H$4X$>$>$E$E$G$G!H!H!&zz#+++HNN?%N@@@E'w"@@@ &UVVVV((***WVVVV%HMM"VWWWEE'H$$&&&&&1  V`g hhhmA&&&&&&&&&c1 '1 '1 '1 '1 'sE.F H%?G'H% H%)r'r(r)z#Created new key series {key_series})r) rrrrrdictrvaluesrr]r^) r$r%rr&r'r(rr)rs ```` ` r*addzSimpleSeller.adds F||u$$V):):vTZ?W?W?W?WE{{c!!eqjjjjDNNc$9$9hllll}e!3!3  U%6H&>CnCn\f\k\k\m\mCnCnCn&>tataMWM^M^M`M`tatata&>&>d@&>&>&>; '; '; '; '; '; '; '; '; 'z^^FEHE]f^gg ' 6 <TTTr,c Kt|tsJd||jtjtjfvs Jdtj|_||_g|_ |j dt|j tj|jjdd|d|jd{V|_|jst-d|jd }t/|t0krt3|d ksJt5j| |_d |j}||j|tAd d{V}|j !||j dt|j"d|j}||j#|tAd d{V}|j !||j dt|j"|j$%D]}|&d{V|dd{V|_'|d|jjd{V}t/|dt0krtQ|d|d<|ddkst-dtS||d|d|j*|<tj+|_|d|_,t/|j,t0krtQ|j,|_,|d|_-|j .dt|jt_|j,t_|j-|dS)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 )addressrz)xbr.marketmaker.get_active_paying_channelzno active paying channel found channel_oidrrTzxbr.provider.{}.selldetails) details_arg)optionsz"Registered procedure "{procedure}") procedurezxbr.provider.{}.close_channelzxbr.marketmaker.get_config*xbr.marketmaker.get_paying_channel_balance remainingrz0no off-chain balance remaining on paying channelrozvOk, seller delegate started [active paying channel {channel_oid} with remaining balance {remaining} at sequence {seq}])rrro)0 isinstancerrwr|rrr{ STATE_STOPPEDSTATE_STARTINGrrr]r^r rrrrrrrrr Exceptionrrrr_r` _channel_oidrregistersellrappendr close_channelrrrLr~r rir STATE_STARTEDrmrlinfor)r$sessionrrregrpaying_balances r*rLzSimpleSeller.startps('#566yy8i8p8pqx8y8yyyy{|6 8RSSSSUmSSS"1   k!$+"*"24:3H"3M"N"N"U"U"W"W  Y Y Y &ll+VX\Xbcccccccc } ><== =mM2 K  E))c+.>.>".D.D.D.D IK888*11$2CDD $$TY ?_hCiCiCi$jjjjjjjj !!#&&& ;r#-GXGXYYY3::4;LMM $$T%7OhqLrLrLr$ssssssss !!#&&& ;r#-GXGXYYY*++-- % %J""$$ $ $ $ $ $ $ $ $#*<<0L#M#MMMMMMM '||,XZ^ZkZqrrrrrrrr {+ , , 5 5*8 9T*U*UN; 'k*Q..NOO O&3KPUAVXfgrXs&t&t{#"0 '{3   % ' '*4=99DM"5)   O"$T%6"7"75CWCW]bcgcl]m]m  o o ok**r,cK|jtjfvs Jdtj|_g}|jD]+}|}||,|jrZ|j rL|j r3|jD]+}| }||,d|_tj |} |d{Vn #|jYnxYwtj|_d|_ n#tj|_d|_ wxYw|jddS)zF Stop rotating/offering keys to the XBR market maker. seller not runningNzOk, seller delegate stopped.)r|rrrSTATE_STOPPINGrrrOrrr is_attached unregisterrygatherr]rrr)r$dlrdrs r*rOzSimpleSeller.stopsr{|9::::.>".D.D.DFqFxFxy}JzKzKGLGL.D.D.DK  C''')N)U)UVZ[fVgVg)h)h'''O$$--#o2F2F"2L2L2LN}OEOEFJKZF[F[O\O\2L2L2L$%%---/Z/a/abfgwbxbx/y/y---)**e33%>  @ @ @r,c t|tkrt|dks Jdt|tkrt|dks Jdt|tkrt|dks Jdt|tkrt|dks Jdt|tks Jdt|tkrt|dks*Jd t|t|tkrt|dks*Jd t|t|tkrt|d ks Jd | t | t s Jdt|}t|}||jkr|tdd|j j tj |jtj |||jvr.tdd|j j ||j|} ||jdkr|jtdd|j j tj |jdtj |||jdzkr7tdd|j j |jdz|||j|z kr7tdd|j j |j|z |d} |jd} tj|jddd } |jd}t/| | | ||||d| }||kr|jd |j j t5tj |t5tj |!td"d#|j j |xjdz c_|xj|zc_| ||}t|tkrt|d$ks(Jd%|j j |t9|j| | | |||j|jd }||j|||j||j|d&}|jd'|j j t5d(d)*t5tAj!|+t5tEt|d,z d-zd)*t5tEt|jd,z d-zd)*t5| j#t5| j$t5tj |. |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_oid: The on-chain channel contract address. :type channel_oid: bytes of length 16 :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 rvzdelegate_adr must be bytes[20]r:zbuyer_pubkey must be bytes[32]rzkey_id must be bytes[16]zchannel_oid must be bytes[16]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]Nrz$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 "{}"rrrrrrrrverifying_chain_idverifying_contract_adrr market_oidFrrrrPzC{}.sell() - unexpected sealed key computed (expected bytes[80]): {})r/rrB sealed_keyramountrprz{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 rQrRrTrr)rrUr/ amount_earnedrprrrB)%rrrrrwrrr r}rrrbrrrrrrrrlrmr~a2b_hexrr]rr rGrrrrr_r`rxrr)r$rrBr/rrrrprrrcurrent_block_numberrrrrrrrs r*rzSimpleSeller.sellBsQL$%%..37G3H3HB3N3N3NPp3N3N3NL!!U**s.>".D.D.DFe.D.D.DK  C''')B'''F||u$$V):):):rs6 <<<<<<<<CCCCCCCC555555////////  ZZZZZZZZA(A(A(A(A(A(A(A(H     F   WWWWW6WWWWWr,