8'h5dddlZddlZddlmZddlZddlZddlZddlZddl Zddl Zddl Z ddl m Z ddlmZddlmZmZddlZddlmZmZmZGdd eZGd d eZy) N)pformat)ApplicationError)ApplicationSession)unpack_uint256 pack_uint256)hlsign_eip712_datarecover_eip712_signerceZdZdZdZdZy) Transactionc t||_||_||_||_||_||_||_||_yNchanneldelegatepubkeykey_id channel_seqamountbalance signature) selfrrrrrrrrs O/var/www/html/trade_iq/venv/lib/python3.12/site-packages/autobahn/xbr/_buyer.py__init__zTransaction.__init__4s;     &  "c |j|j|j|j|j|j |j |jd}|S)Nrr)rress rmarshalzTransaction.marshal>sJ|| kkkk++kk||   rc4t|jSr)rrrs r__str__zTransaction.__str__Kst||~&&rN)__name__ __module__ __qualname__rrr"rrr r 2s# 'rr cheZdZdZdZdZdZdZdZddZ ddZ d Z d Z d Z dd Zd ZdZdZy) 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. Nct|tk(rt|dk(sJdj|t|tk(rt|dk(sJdj|t|tk(r|dkDsJt j |_||_||_ tjj||_ d|_|jjj!|_d|_t&j(jj+|_||_d|_d|_d|_i|_d|_d|_d|_i|_g|_ y) 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 _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__Vs$%.37G3HB3N \QCQJQJK[Q\ \NI%'C Nb,@ EBrByBy{DCE E@I#%)a-77$$&"2#]]--i8  ZZ**??A  !KK22;;=$      $( !#rc (Kt|tsJt|tk(sJ|jrJ||_d|_|j jdt|jtj|jjddj t|jt k(rt#|jdk(sJ|j%d|jd{|_|j%d|j&d d{}|d |_t|j*t k(rt-|j*|_|d |_|j jd td tj|j&d jz|j*|j.|j*S77#|j)xYww)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;r*z*xbr.marketmaker.get_active_payment_channel+xbr.marketmaker.get_payment_channel_balancer remainingseqztDelegate has current payment channel address {payment_channel_adr} (remaining balance {remaining} at sequence {seq})0x)payment_channel_adrrTrU) isinstancerr,strrIrHr3infor r>binasciib2a_hexr9r;decoder=r-r.callrDleaverErrF)rsession consumer_idpayment_balances rstartzSimpleBuyer.starts'#5666K C'''==      k o!)!1!1$**2G2G2L!M!T!T!V  X  #u,TZZB1F FF"),,/[]a]g]g"hhDM%,LL1^`d`m`mnw`x$yyO ( 4  % '*4==9DM#E*   M*,TH4D4DT]]S\E]4^4e4e4g-g*h $ 499  >}}'iz  MMO sDB,H/AG<G8+G<0G:1G<5CH8G<:G<<HHc6K|jsJd|_yw)z# Stop buying keys. FN)rIr!s rstopzSimpleBuyer.stops}}} scK|jr|jjsJ|jjd|jdd{}|S7w)a Return current balance of payment channel: * ``amount``: The initial amount with which the payment channel was opened. * ``remaining``: The remaining amount of XBR in the payment channel that can be spent. * ``inflight``: The amount of XBR allocated to buy transactions that are currently processed. :return: Current payment balance. :rtype: dict rSrN)rH is_attachedr^rD)rrbs rrzSimpleBuyer.balancesW}}!:!:!<<< $ 2 23`bfbobopybz {{|sAA AA c K|jr|jjsJtjd}|jj d||j ||d{}|d|d|dd}|S7w)z :param amount: :type amount: :param details: :type details: :return: :rtype: @z$xbr.marketmaker.open_payment_channelNrrTinflight)rrTrj)rHrgosurandomr^r=)r buyer_addrrdetailsrpayment_channelrs r open_channelzSimpleBuyer.open_channels}}!:!:!<<<JJrN $ 2 23Y3=37::393< !>>&h/(5' 3  >sA*B,B-Bc Kyw)z[ Requests to close the currently active payment channel. :return: Nr&)rrns r close_channelzSimpleBuyer.close_channelssc4Kt|tk(rt|dk(sJt|tk(r|dvsJt|tk(sJt|jd}||j vr<|j jdttj|nG|j jdttj|d|j |<|jjd |d {}t|d }|j jd ttj|tt|d z ||jkDrht!ddj#|j$j&tj|t|d z t|jd z |j(|z }|dkr|j*rBd }|j-} | r| d}|r&|} |j.} |j(} d} t1|j2| | | | }|j jdt5j6| j9| t| d z | |jjd| | t;| | |d {t!ddj#|j$j&tj|t5j6| j9t| d z t!ddj#|j$j&tj|t|j(d z t|d z |j<j>jAtBjDjF}|j.dz}d}t1|j2||||}|jI||jJ|||||| |jjd|jJ||||t;|t;|| d {}|d}|d }t|d!}t|d"}t|d#}tU|||d|}||jVk7r|j jYd$|j$j&tt5j6|j9tt5j6|jVj9%t!d&d'j#|j$j&|j.dz|k7r>t!d(d)j#|j$j&|j.|d |j(|z |k7rAt!d(d*j#|j$j&|j(|z |d"||_||_|j[||jV|||||||d+}tBj\j_|j<} |ja|}tBjfji||j |<|jk}|j jd.|j$j&td/d01ttj|ttt|d z d2zd01tt5j6|d3j9tt|d z tt|d z tt5j6|j9|4 d}|j |dur|d5zrT|j jd6|j$j&ttj|7|dz }tmjnd8d {|j |durtq|j |tPr|j |}| |j |ja|} tsjt|} | S777q#t $r&}|jLdk(r|jO|d }~wtP$rK}|j jMd|j jS||j |<|d }~wwxYw#tBjbjd$rD}||j |<t!d,d-j#|j$j&|d }~wwxYw7m#tBjbjd$r5}t!d,d9j#|j$j&|d }~wwxYw#trjvjx$r5}t!d:d;j#|j$j&|d }~wwxYww)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_quoteNpricez-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 {close_adr} [close_seq={close_seq}, close_balance={close_balance}, close_is_final={close_is_final}]) close_adr close_seq close_balanceclose_is_finalzxbr.marketmaker.close_channelzxbr.error.channel_closedzw{}.unwrap() - key {} cannot be bought: payment channel 0x{} 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 {})encoderr)is_finalzxbr.marketmaker.buy_keyz8Encountered error while calling market maker to buy key!rr amount_paidrTrjzv{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 XBRro) r~tx_typerr}rorTrj buyer_pubkey transactionsdzG{klass}.unwrap() - waiting for key "{key_id}" currently being bought ..)r~rg?z1{}.unwrap() - failed to unwrap encrypted data: {}z xbr.error.deserialization_failedz;{}.unwrap() - failed to deserialize application payload: {})=r,r-r.rYrDrGr3rZr uuidUUIDrHr^rr0rCrr/ __class__r#rErJpast_transactionsrFr r5r[r\r]rrBr;encoder?encoding RawEncoder_save_transaction_phase1r=errorre Exceptionfailurer r4warn_save_transaction_phase2r@ SealedBoxdecrypt exceptions CryptoErrorsecret SecretBoxcount_transactionsr1sleeprXcbor2loadsdecoderCBORDecodeError)!rr serializer ciphertext channel_adrquoterrlast_txtxnsrwrxryrzrrrr|receiptemarketmaker_signaturemarketmaker_channel_seqmarketmaker_amount_paidmarketmaker_remainingmarketmaker_inflightrr unseal_boxkeytransactions_count log_countermessagepayloads! runwrapzSimpleBuyer.unwrap s &F|u$V):::J3&:+AAAJ5(((DMM)45  TZZ  HHMMZ!#DIIF$;!<  > HHMMMVXY]YbYbioYpVqM r"'DJJv --,,-H&QQE$E'N3F HHMMI!#DIIF$;!>t}}G_G_>`L))a-KH)kSZemnI  ) )+tzz3>3?3G3?3H3<!>>(%,K$8 !&-m&< #&4W]5K&L #$27;3G$H !#1'*2E#F 2;@WYnpuxMNN!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  ) )+t7M7M|]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  g$(NN$;$;BtyyW]G^D_aq ++b/ ! ! jj E) djj() 4 6"AG Zjj(00$ 7788IIK YZ  "%& 6"  T??.. c%& 6"&'DF~GFGFGKGUGUG^G^`aGbcc c6 "** Z"#@BuB|B|~B~L~L~U~UWXCYZ Z Z}},, i"#EHEHLHLMQM[M[MdMdfgHhi i isDjc:Gj!c="E*j AdddHj(f9Gj>g+?j.jg.#i8j=jd f !d-- f9Ae??fjg($?g##g((j.i 0h;;ijj 0jjjc  ||jvr-tdjtj|t ||||||||} t |j} |jj| dg| |j|<y) :param channel_adr: :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) rK RuntimeErrorr/r[r\r r.rLappend) rrrrrrrrrtx1key_idxs rrz$SimpleBuyer._save_transaction_phase1s T** *\ccdldtdtu{d|}~ ~+|\6;X^`girsd(() !!3+.(/f%rc ||jvr-tdjtj||j|} |j | dr-tdjtj||j | d} t ||||||||} | j| jk(sJ| j| jk(sJ| j| jk(sJ| j| jk(sJ| j| jk(sJ| j| jk(sJ| j| jk7sJ| |j | d<y)rz;save_transaction_phase2: transaction for key 0x{} not foundrz;save_transaction_phase2: duplicate transaction for key 0x{}rN)rKrr/r[r\rLr rrrrrrr) rrrrrrrrrrrtx2s rrz$SimpleBuyer._save_transaction_phase2sf .. .\ccdldtdtu{d|}~ ~''/   g &q )MTTU]UeUeflUmnp p  )!,+|\6;X^`girs{{ckk)))zzSZZ'''zzSZZ'''#//111zzSZZ'''{{ckk)))}} ---),7#A&rct|tk(sJt|tk(r|dkDsJd}g}||krTt|j|kDr3|j| }|r |dr|dr|j ||dz }n |S||krT|S)zQ :param filter_complete: :param limit: :return: rr)r,boolr0r.rLr)rfilter_completelimitnrtxs rrzSimpleBuyer.past_transactionssO$,,,E{c!eai// %i4%%&*''+&2a5RUJJrNFA %i rcvddd}|jD]$\}}|r|r|dxxdz cc<|dxxdz cc<&|S)z :return: r)completependingrrr)rL)rrrrs rrzSimpleBuyer.count_transactions2sT  ** $HCsJ1$I!#  $  rc^|jj|d}|r|j|Sy)2 :param key_id: :return: NrKgetrL)rridxs rget_transactionzSimpleBuyer.get_transactionBs5 ##''5 %%c* * rcp|jj|d}|r|j|\}}|xr|Sy)rNFr)rrrrrs r is_completezSimpleBuyer.is_completeLs@ ##''5 ))#.HC;3 rr)Tr)r#r$r%__doc__r3rrcrerrprrrrrrrrrr&rrr(r(OsU CB H.`"> Un0,$-L, + rr()rr[pprintrrkr nacl.secretr? nacl.utilsnacl.exceptions nacl.publicr1autobahn.wamp.exceptionrautobahn.wamp.protocolr_utilrrr6r r r objectr r(r&rrrsS6   45/?>'&':G&Gr