tf mddlZddlZddlmZddlZddlZddlZddlZddl Zddl Zddl Z ddl m Z ddlmZddlmZmZddlZddlmZmZdd lmZmZGd d eZGd d eZdS)N)pformat)ApplicationError)ApplicationSession)unpack_uint256 pack_uint256)hlhlval)sign_eip712_channel_closerecover_eip712_channel_closec eZdZdZdZdZdS) Transactionc v||_||_||_||_||_||_||_||_dSNchanneldelegatepubkeykey_id channel_seqamountbalance signature) selfrrrrrrrrs R/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/autobahn/xbr/_buyer.py__init__zTransaction.__init__3s?     &  "c l|j|j|j|j|j|j|j|jd}|S)Nrr)rress rmarshalzTransaction.marshal=s>| kk+k|    rcDt|Sr)rr!rs r__str__zTransaction.__str__Jst||~~&&&rN)__name__ __module__ __qualname__rr!r$rrrr1sA###   '''''rrcjeZdZdZdZdZdZdZdZddZ ddZ d Z d Z d Z ddZdZdZdZdS) SimpleBuyerz Simple XBR buyer component. This component can be used by a XBR buyer delegate to handle the automated buying of data encryption keys from the XBR market maker. NcFt|tkrt|dksJd|t|tkrt|dksJd|t|tkr|dksJt j|_||_d|_ ||_ tj ||_d|_|jj|_d|_t(jj |_||_d|_d|_d|_i|_d|_d|_d|_i|_ g|_!dS) a :param market_maker_adr: :type market_maker_adr: :param buyer_key: Consumer delegate (buyer) private Ethereum key. :type buyer_key: bytes :param max_price: Maximum price we are willing to buy per key. :type max_price: int z0market_maker_adr must be bytes[20], but got "{}" z.buyer delegate must be bytes[32], but got "{}"rNFT)"typebyteslenformatinttxaio make_loggerlog_market_maker_adr _xbrmm_config _pkey_raweth_keyskeys PrivateKey_pkey_acct public_keyto_canonical_address_addr_caddrnaclpublicgenerate _receive_key _max_price_channel_balance_seq_keys_session_running_auto_close_channel_transaction_idx _transactions)rmarket_maker_adr buyer_key max_prices rrzSimpleBuyer.__init__Us$%%..37G3H3HB3N3N3NQCQJQJK[Q\Q\3N3N3NI%''C NNb,@,@,@BrByBy{DCECE,@,@,@I#%%)a----$&&"2!#]--i88  Z*??AA  !K2;;==$      $( !#rc >Kt|tsJt|tksJ|jrJ||_d|_|jdt|j tj |j j dd |dd{V|_t|jt$krt'|jdksJ|d|jd{V|_|jst+d |jd }t|t$krt'|d ksJt-j| |_|d |jjd{V}n#|xYwt|dt$krt5|d|d<|ddkst+d|d|_|d|_|jdt|jt=|jt=|j|jS)a Start buying keys to decrypt XBR data by calling ``unwrap()``. :param session: WAMP session over which to communicate with the XBR market maker. :type session: :class:`autobahn.wamp.protocol.ApplicationSession` :param consumer_id: XBR consumer ID. :type consumer_id: str :return: Current remaining balance in payment channel. :rtype: int TzSStart buying from consumer delegate address {address} (public key 0x{public_key}..)N )addressr>zxbr.marketmaker.get_configr,z*xbr.marketmaker.get_active_payment_channelzno active payment channel found channel_oidr/+xbr.marketmaker.get_payment_channel_balance remainingrz1no off-chain balance remaining on payment channelseqzvOk, buyer delegate started [active payment channel {channel_oid} with remaining balance {remaining} at sequence {seq}])rVrZr[) isinstancerr.strrLrKr5debugr rAbinasciib2a_hexr<r>decodecallr7r@r/r0rG ExceptionuuidUUID _channel_oidleaverrHrIinfor )rsession consumer_idrVpayment_balances rstartzSimpleBuyer.starts'#566666K  C''''=      l!$+"*"24:3H"3M"N"N"U"U"W"W  Y Y Y '.||4P'Q'Q!Q!Q!Q!Q!Q!QD  ##u,,TZB1F1F1F1F"),,/[]a]g"h"hhhhhhhDM= C ABBB- 6K $$--#k2B2Bb2H2H2H2H $ < < !>>>>>>>&h/(5' 3   rc KdS)z[ Requests to close the currently active payment channel. :return: Nr()rrws r close_channelzSimpleBuyer.close_channels rc0Kt|tkrt|dksJt|tkr|dvsJt|tksJ|jd}|jd}d}|jd}t j|jddd }||jvr>|j d ttj |  n|j d ttj |  d|j|<|jd|d {V} t!| d} |j dttj | tt#| dz | |jkrht'dd|jjtj | t#| dz t#|jdz |j| z } | dkr|jrd } |} | r| d} | r|j}|j}d}t7|j|||||||| }|j dtj | |t#|dz ||jd||||t;|||| d {Vt'dd|jjtj | |t#|dz t'dd|jjtj | t#|jdz t#| dz |jj tBj"j#}|jdz}d}t7|j||||||| | }|$||j%|||| | | |jd |j%||||t;| t;| | d {V}n#t&$r&}|j&dkr|'|d }~wtP$rD}|j &d!|j )||j|<|d }~wwxYw|d"}|d#}t!|d$}t!|d%}t!|d&}tU|||||||d| }||j+kr|j ,d'|jjtt j-|.tt j-|j+.(t'd)d*|jj|jdz|kr:t'd+d,|jj|j|d#|j| z |kr=t'd+d-|jj|j| z |d%||_||_|/||j+|||||||d.}tBj01|j} |2|}nT#tBj3j4$r=}||j|<t'd/d0|jj|d }~wwxYwtBj56||j|<|7} |j 8d1|jjtd2d34ttj | ttt#|dz d5zd34tt j-|d6.tt#|dz tt#|dz tt j-|.| 7 d}!|j|durz|!d8zrL|j d9|jjttj | :|!dz }!tsj:d;d {V|j|duztw|j|tPr|j|}| |j|2|}"nJ#tBj3j4$r3}t'd/d<|jj|d }~wwxYw tyj=|"}#nJ#txj>j?$r3}t'd=d>|jj|d }~wwxYw|#S)?aO Decrypt XBR data. This functions will potentially make the buyer call the XBR market maker to buy data encryption keys from the XBR provider. :param key_id: ID of the data encryption used for decryption of application payload. :type key_id: bytes :param serializer: Application payload serializer. :type serializer: str :param ciphertext: Ciphertext of encrypted application payload to decrypt. :type ciphertext: bytes :return: Decrypted application payload. :rtype: object rW)cbor market_oidrVrverifying_chain_idverifying_contract_adrr Nz>Key {key_id} already in key store (or currently being bought).rX)rz1Key {key_id} not yet in key store - buying key ..Fzxbr.marketmaker.get_quotepricez-Key {key_id} has current price quote {amount}lNZo)rrzxbr.error.max_price_exceededzR{}.unwrap() - key {} needed cannot be bought: price {} exceeds maximum price of {}rTzauto-closing payment channel {channel_oid} [close_seq={close_seq}, close_balance={close_balance}, close_is_final={close_is_final}])rV close_seq close_balanceclose_is_finalzxbr.marketmaker.close_channelzxbr.error.channel_closedzu{}.unwrap() - key {} cannot be bought: payment channel {} ran empty and we initiated close at remaining balance of {}zxbr.error.insufficient_balancez_{}.unwrap() - key {} cannot be bought: insufficient balance {} in payment channel for amount {})encoderzxbr.marketmaker.buy_keyz8Encountered error while calling market maker to buy key!rr amount_paidrZrszv{klass}.unwrap()::XBRSIG[8/8] - EIP712 signature invalid: signer_address={signer_address}, delegate_adr={delegate_adr})klasssigner_address delegate_adrzxbr.error.invalid_signaturezQ{}.unwrap()::XBRSIG[8/8] - EIP712 signature invalid or not signed by market makerzxbr.error.invalid_transactionz^{}.buy_key(): invalid transaction (channel sequence number mismatch - expected {}, but got {})z_{}.buy_key(): invalid transaction (channel remaining amount mismatch - expected {}, but got {}) sealed_keyzxbr.error.decryption_failedz6{}.unwrap() - could not unseal data encryption key: {}z{klass}.unwrap() - {tx_type} key {key_id} bought for {amount_paid} [payment_channel={payment_channel}, remaining={remaining}, inflight={inflight}, buyer_pubkey={buyer_pubkey}, transactions={transactions}]z XBR BUY magenta)colorz XBRrx) rtx_typerrrxrZrs buyer_pubkey transactionsdzG{klass}.unwrap() - waiting for key "{key_id}" currently being bought ..)rrg?z1{}.unwrap() - failed to unwrap encrypted data: {}z xbr.error.deserialization_failedz;{}.unwrap() - failed to deserialize application payload: {})@r.r/r0r]rGr7r_a2b_hexrJr5r^r rdrerKrbrr2rFrr1 __class__r%rHrMpast_transactionsrIr r8rrEr>encoderBencoding RawEncoder_save_transaction_phase1r@errorrnrcfailurer r6warnr`ra_save_transaction_phase2rC SealedBoxdecrypt exceptions CryptoErrorsecret SecretBoxcount_transactionsrhr3sleepr\cbor2loadsdecoderCBORDecodeError)$rr serializer ciphertextr~rVcurrent_block_numberrrquoterrlast_txtxnsrrrrrris_finalreceiptemarketmaker_signaturemarketmaker_channel_seqmarketmaker_amount_paidmarketmaker_remainingmarketmaker_inflightrr unseal_boxkeytransactions_count log_countermessagepayloads$ runwrapzSimpleBuyer.unwraps &F||u$$V):):):):J3&&:+A+A+A+AJ5((((]<0 mM2  !!/0DE!)!1$2DE]2^_`_a_a2b!c!c TZ   HNN["$TYV%<%<%<"="=  ? ? ? ? HNNNWYZ^ZcjpZqZqZqWrWrN s s s"'DJv -,,-H&QQQQQQQQE$E'N33F HNNJ"$TYV%<%<%<"="=bVV\_I]I]F^F^  ` ` `''&'E'{(C(CDHDRD[]a]fms]t]t]tvyz@CKzKvLvLNQRVRadlRlNmNm(n(nooomf,G{{+4N"G1133D*"&q'-N%)I (, )-$=dn>P>T>R>H>I>G>K>L%N%N (l379;3O3O3O1:589O5P5P6D 'FFF#m001P1<1C1E1G1=m1L1L1:1?1:<<<<<<<<<//I0g0n0noso}oFosoxEoFoFoFozors@CKsKoLoL0M0MNNN ''G(I(P(PQUQ_QhQUQZagQhQhQhQTUYUbemUmQnQnQTU[^fUfQgQg(h(hiii  ,7>>t}G_>``L)a-KH2$.BTVl2F T_al298EEI  ) )+tz3>3?3G3G3?3H3H3<!>!>>>>>>>$   7888IIKKK   YZZZ  """%& 6"  %,K$8 !&-m&< #&4W]5K&L&L #$27;3G$H$H !#1'*2E#F#F 9:LNd:NPZ\g:QSh:?AVXXN!777 W$(N$;-/0@0P0P0W0W0Y0Y-Z-Z+-h.>t?U.V.V.].]._._+`+`bbb''D'z(B(BCGCQCZ([([\\\y1} 777&'F(H(O(OPTP^Pgimirt{|ItJ(K(KLLL}v%)>>>&'F(I(P(PQUQ_Qhjnjwz@j@BIJUBV(W(WXXX0DI1DM  ) )+t7M|]ce|*ACXZo q q q!.J..t/@AAJ c ((44?. c c c%& 6"&'DF~GFGFGKGUG^`aGbGbccc c "&!6!6s!;!;DJv !%!8!8!:!:  HMM_n-'I#J#JKKfT\efff "8#3G > E E G GHH/  1 1 1 j E))S  !h%)^%    ooob000,$-$-$-L, +++     rr*)rdr_pprintrrtr nacl.secretrB nacl.utilsnacl.exceptions nacl.publicr3autobahn.wamp.exceptionrautobahn.wamp.protocolr_utilrrr9utilr r _eip712_channel_closer r objectrr*r(rrrsS6   444444555555////////ZZZZZZZZ'''''&''':nnnnn&nnnnnr