h mSSKrSSKrSSKJr SSKrSSKrSSKrSSKrSSK rSSK rSSK r SSK J r SSKJr SSKJrJr SSKrSSKJrJr SS KJrJr "S S \5r"S S \5rg)N)pformat)ApplicationError)ApplicationSession)unpack_uint256 pack_uint256)hlhlval)sign_eip712_channel_closerecover_eip712_channel_closec&\rSrSrSrSrSrSrg) Transaction1c dXlX lX0lX@lXPlX`lXplXlgNchanneldelegatepubkeykey_id channel_seqamountbalance signature) selfrrrrrrrrs WC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\autobahn/xbr/_buyer.py__init__Transaction.__init__3s+    &  "c URURURURURUR UR URS.nU$)Nrr)rress rmarshalTransaction.marshal=sJ|| kkkk++kk||   r c4[UR55$r)rr#rs r__str__Transaction.__str__Jst||~&&r )rrrrrrrrN)__name__ __module__ __qualname____firstlineno__rr#r'__static_attributes__r rrr1s# 'r rcv\rSrSrSrSrSrSrSrSr SSjr SS jr S r S r S rSS jrSrSrSrSrg) SimpleBuyerNz 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. Nc[U5[:Xa[U5S:XdSRU55e[U5[:Xa[U5S:XdSRU55e[U5[:XaUS:de[ R "5UlXlSUl X l [RRU5UlSUlURR R#5UlSUl[(R*RR-5UlX0lSUlSUlSUl0UlSUlSUlSUl0Ul /Ul!g) z :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 rrSimpleBuyer.__init__Us$%.37G3HB3N \QCQJQJK[Q\ \NI%'C Nb,@ EBrByBy{DCE E@I#%)a-77$$&"2!#]]--i8  ZZ**??A  !KK22;;=$      $( !#r c 8# [U[5(de[U5[:XdeUR(aeXlSUlUR RS[UR5[R"URRSS5R5S9 URS5IShvN Ul[UR"5[$:Xa['UR"5S:XdeURSUR"5IShvN UlUR((d [+S 5eUR(S n[U5[$:Xa['U5S :Xde[,R."US 9UlURS UR0R$5IShvN n[US5[$:Xa[5US5US'USS:d [+S5eUSUlUSUlUR R;S[UR05[=UR65[=UR85S9 UR6$GNGNSN! UR35 e=f7f)aV 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 )addressrEzxbr.marketmaker.get_configr3z*xbr.marketmaker.get_active_payment_channelzno active payment channel found channel_oidr6+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}])r^rbrc) isinstancerr5strrSrRr<debugr rHbinasciib2a_hexrCrEdecodecallr>rGr6r7rN ExceptionuuidUUID _channel_oidleaverrOrPinfor )rsession consumer_idr^payment_balances rstartSimpleBuyer.starts3'#56666K C'''==     l!$++"*"2"24::3H3H"3M"N"U"U"W  Y '.||4P'Q!QD  #u,TZZB1F FF"),,/[]a]g]g"hhDM== ABB-- 6K $-#k2Bb2H HH $ >&h/(5' 3  >sA5B7B 8Bc # g7f)zC Requests to close the currently active payment channel. :return: Nr.)rrs r close_channelSimpleBuyer.close_channelssc`# [U5[:Xa[U5S:Xde[U5[:XaUS;de[U5[:XdeURSnURSnSnUR Sn[ R"UR SSS 5nXR;a7URRS [[R"US 95S 9 GOURRS [[R"US 95S 9 SURU'URRSU5IS hvN n [!U S5n URRS[[R"US 95[[#U S- 55S9 XR$:af['SSR)UR*R,[R"US 9[#U S- 5[#UR$S- 555eUR.U - n U S:GaUR0(GaS n UR35n U (aU Sn U (aUR4nUR.nSn[7UR8UUUUUUUU5 nURRS[R"US 9U[#US- 5US9 URRSUUUU[;U5UUU5 IS hvN ['SSR)UR*R,[R"US 9U[#US- 555e['SSR)UR*R,[R"US 9[#UR.S- 5[#U S- 555eUR<R>RA[BRDRFS9nUR4S-nSn[7UR8XxXdUUU U5 nURIXPRJUUUXU5 URRS URJUUUU[;U 5[;U 5U5 IS hvN nUS"nUS#n[!US$5n[!US%5n[!US&5nXxXdUUUSU5 nUURV:waURRYS'UR*R,[[ RZ"U5R]55[[ RZ"URV5R]55S(9 ['S)S*R)UR*R,55eUR4S-U:wa>['S+S,R)UR*R,UR4US#55eUR.U - U:waA['S+S-R)UR*R,UR.U - US%55eUUlUUlUR_XPRVUUUUUU5 US.n[BR`RcUR<5nUReU5n[BRjRmU5URU'URo5n URRqS1UR*R,[S2S3S49[[R"US 95[[[#US- 55S5-S3S49[[ RZ"US65R]55[[#US- 55[[#US- 55[[ RZ"U5R]55U S79 Sn!URUSLaU!S8-(aOURRS9UR*R,[[R"US 95S:9 U!S- n![rRt"S;5IS hvN URUSLaM[wURU[P5(aURUnUeURUReU5n"[xRz"U"5n#U#$GNGNGNu![&a'nURLS:XaURO5 UeS nAf[PaKnURRMS!5 URRS5 UURU'UeS nAff=f![BRfRhaDnUURU'['S/S0R)UR*R,U55eS nAff=fGNy![BRfRha5n['S/SR)UR*R,U55eS nAff=f7f)?a 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 r_)cbor market_oidr^rverifying_chain_idverifying_contract_adrr Nz>Key {key_id} already in key store (or currently being bought).r`)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}])r^ 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_paidrbr~zv{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 XBRr) rtx_typerrrrbr~ 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: {})@r5r6r7rerNr>rga2b_hexrQr<rfr rlrmrRrjrr9rMrr8 __class__r)rOrTpast_transactionsrPr r?rrLrEencoderIencoding RawEncoder_save_transaction_phase1rGerrorrwrkfailurer r=warnrhri_save_transaction_phase2rJ SealedBoxdecrypt exceptions CryptoErrorsecret SecretBoxcount_transactionsrpr:sleeprdcbor2loadsdecoderCBORDecodeError)$rr serializer ciphertextrr^current_block_numberrrquoterrlast_txtxnsrrrrrris_finalreceiptemarketmaker_signaturemarketmaker_channel_seqmarketmaker_amount_paidmarketmaker_remainingmarketmaker_inflightrr unseal_boxkeytransactions_count log_countermessagepayloads$ runwrapSimpleBuyer.unwraps &F|u$V):::J3&:+AAAJ5(((]]<0 mmM2  !!//0DE!)!1!1$2D2DE]2^_`_a2b!c ZZ  HHNN["$TYYV%<"=  ? HHNNNWYZ^ZcZcjpZqWrN s"'DJJv --,,-H&QQE$E'N3F HHNNJ"$TYYV%<"=bVV\_I]F^  `'&'E'{(C(CDHDRDRD[D[]a]f]fms]tvyz@CKzKvLNQRVRaRadlRlNm(noommf,G{+++"G113D"&q'%)II (, )-$=dnn>P>T>R>H>I>G>K>L%N (l3799;3O1:589O5P6D 'F#mm001P1<1C1E1G1=m1L1:1?1:<<<//I0g0n0noso}o}oFoFosoxoxEoFozors@CKsKoL0MNN ''G(I(P(PQUQ_Q_QhQhQUQZQZagQhQTUYUbUbemUmQnQTU[^fUfQg(hii  ,,77>>t}}G_G_>`L))a-KH2$..BT2FT_al298EI  ) )+zz3>3?3G3?3H3<!>>(%,K$8 !&-m&< #&4W]5K&L #$27;3G$H !#1'*2E#F 9:L:N\g:QSh:?AVXN!7!77 W$(NN$;$;-/0@0@0P0W0W0Y-Z+-h.>.>t?U?U.V.].]._+`b''D'z(B(BCGCQCQCZCZ([\\yy1} 77&'F(H(O(OPTP^P^PgPgimirirt{|ItJ(KLL}}v%)>>&'F(I(P(PQUQ_Q_QhQhjnjwjwz@j@BIJUBV(WXX0DI1DM  ) )+7M7M|]ce|*ACXZo q!.J..t/@/@AJ c ((4 "&!6!6s!;DJJv !%!8!8!:  HHMM_nn--'I#JKfT\ef "8#3#3G E E GH/  1 jj E)S h%)^^%<%$ 7788IIK YZ  "%& 6"  Z??.. c%& 6"&'DF~GFGFGKGUGUG^G^`aGbcc c6 "** Z"#@BuB|B|~B~L~L~U~UWXCYZ Z Z}},, i"#EHEHLHLMQM[M[MdMdfgHhi i isEj.d Gj.d Ej.Addd Hj.7fF>j.g?j.3j.h2ij. j.d f"d?? f Affj.g<8?g77g<<j.i 0iij.j+60j&&j++j.c X@R;a.[SR[R"U555e[ XX4XVXx5n [ UR5n URRU S/5 XRU'g) :param channel_oid: :param delegate_adr: :param buyer_pubkey: :param key_id: :param channel_seq: :param amount: :param balance: :param signature: :return: z;save_transaction_phase1: duplicate transaction for key 0x{}N) rU RuntimeErrorr8rgrhrr7rVappend) rr^rrrrrrrtx1key_idxs rr$SimpleBuyer._save_transaction_phase1s{ ** *\ccdldtdtu{d|}~ ~+\;`gsd(() !!3+.(/f%r c X@R;a.[SR[R"U555eURUn UR U S(a.[SR[R"U555eUR U Sn [ XX4XVXx5n U RU R:XdeU RU R:XdeU RU R:XdeU RU R:XdeU RU R:XdeU RU R:XdeU RU R:wdeXR U S'g)rz;save_transaction_phase2: transaction for key 0x{} not foundrz;save_transaction_phase2: duplicate transaction for key 0x{}rN)rUrr8rgrhrVrrrrrrrr) rr^rrrrrrrrrtx2s rr$SimpleBuyer._save_transaction_phase2sX .. .\ccdldtdtu{d|}~ ~''/   g &q )MTTU]UeUeflUmnp p  )!,+\;`gs{{ckk)))zzSZZ'''zzSZZ'''#//111zzSZZ'''{{ckk)))}} ---),7#A&r cB[U5[:Xde[U5[:XaUS:deSn/nX2:ae[UR5U:aBURU*nU(aUS(a US(aUR U5 US- nOU$X2:aMeU$)z1 :param filter_complete: :param limit: :return: rr)r5boolr9r7rVr)rfilter_completelimitnr"txs rrSimpleBuyer.past_transactionsBsO$,,,E{c!eai// i4%%&*''+&2a5RUJJrNFA i r cSSS.nURH/up#U(aU(aUS==S- ss'M"US==S- ss'M1 U$)z :return: r)completependingrrr)rV)rr"rrs rrSimpleBuyer.count_transactionsXsM  **HCsJ1$I!# +  r chURRUS5nU(aURU$g) :param key_id: :return: NrUgetrV)rridxs rget_transactionSimpleBuyer.get_transactionhs5 ##''5 %%c* * r cURRUS5nU(aURUup4U=(a U$g)rNFr)rrrrrs r is_completeSimpleBuyer.is_completers> ##''5 ))#.HC;3 r )rDrGrTrOrHrNrnrQr=rMrCr?rLrSrPrRrUrVr>r<r)Tr)r)r*r+r,__doc__r<rrtrwrrrrrrrrrrr-r.r rr0r0NsU CC J8t5"> ob0,$-L, + r r0)rlrgpprintrrr nacl.secretrI nacl.utilsnacl.exceptions nacl.publicr:autobahn.wamp.exceptionrautobahn.wamp.protocolr_utilrrr@utilr r _eip712_channel_closer r objectrr0r.r rrsQ6   45/Z'&':n&nr