h SSKrSSKrSSKrSSKrSSKJrJr SSKJrJ r SSK J r SSK J r Jr SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSS KJrJr SS KJrJr "S S \5r"S S\5r"SS\5r g)N)RegisterOptions CallDetails)ApplicationError TransportLost)ApplicationSession)unpack_uint256 pack_uint256)time_ns)hlhlval)sign_eip712_channel_closerecover_eip712_channel_closecP\rSrSrSrS Sjr\S5rSrSr Sr S r S r S r g) KeySeries1zq Data encryption key series with automatic (time-based) key rotation and key offering (to the XBR market maker). Nc[U5[:Xa[U5S:Xde[U5[:XaUS:deUb[U5[:XaUS:deUb[U5[:XaUS:deUcUcUbUbeUb[ U5(deXlX lX0lX@lSUl XPl SUl SUl SUl 0Ulg)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 XC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\autobahn/xbr/_seller.py__init__KeySeries.__init__7s$F|u$V):::E{c!eqj00DNc$9hlKK}e!3 BB U%6HJJ%%dkk&;&;&D&DE KK))$))4 $(99dii"8 dhh  B|95diidhh/0diidll34  6 ??//$' ' '  'sEEEE) rr$r#rrr!rr"r rNNN)__name__ __module__ __qualname____firstlineno____doc__r,propertyr1r8rKrQrUr7__static_attributes__r.r+rr1s: #J,,4$$(r.rc\rSrSrSrSrg) PayingChannelc[U5[:Xa[U5S:Xde[U5[:XaUS:de[U5[:XaUS:deXlX lX0lg)Nrr)rrrr_adr_seq_balance)r%adrseqbalances r+r,PayingChannel.__init__s]CyE!c#h"n44CyCC1H,,G}#1 44   r.)rvrxrwN)rjrkrlrmr,rprqr.r+rsrss r.rsc\rSrSrSrSrSrSrSrSr Sr SSjr \ S 5r SS jrS rS rS rSrSSjrSSjrSrg) SimpleSellerNrrr c@[U5[:Xa[U5S:XdSRU55e[U5[:Xa[U5S:XdSRU55eUb)[U5[:XdSRU55e[ R "5Ul[RUl Xl SUl X l [RR!U5UlSUlUR"R&R)5UlSUlU=(d [ UR"R&5Ul0UlSUlSUlSUl0Ul0UlSUlSUlg)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_loggerrdr~ STATE_NONE_state_market_maker_adr _xbrmm_config _pkey_raweth_keyskeys PrivateKey_pkey_acct public_keyto_canonical_address_addr_caddr _provider_id _channels_channelrxrw_keys _keys_map_session _session_regs)r%market_maker_adr seller_key provider_ids r+r,SimpleSeller.__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.URR$)zp This seller delegate public Ethereum key. :return: Ethereum public key of this seller delegate. :rtype: bytes )rrr0s r+rSimpleSeller.public_key szz$$$r.cv^^^^^[T5[:Xa[T5S:XaTTR;de[T5[:XaTS:deUb[U5[:XaUS:deUb[U5[:XaUS:deUcUcUbUbeTbR[T5[ :Xa8STR 55(aSTR55(dS5eUUUUU4SjnTRTTXEUS9nUTRT'TRRSUS 9 U$) 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) after which to auto-rotate the encryption key. :type interval: int :param count: Number of encryption operations after which to auto-rotate the encryption key. :type count: int rrc3F# UHn[U5[:Hv M g7frNrr).0ks r+ #SimpleSeller.add..+sCn\mWXDGsN\m!c3F# UHn[U5[:Hv M g7frNr)rvs r+rr+s8taM`HItxyzt{@CuCM`rzZinvalid categories type (must be dict) or category key or value type (must both be string)c># URnUT RU'SnU(GaH[5S- nT Rn[R "S5nT R nT RRSUT T UUUST b [T 5OST SSUS9 IShvN nT RRS[SSS 9[[R"US 95[[R"T S 95[[T b[!T S - 5OS 5S -SS 9[["R$"U5R'55[T 5S9 T RRSUS9 ggN![(aTnUR*S:Xa T RR-S5 SnAOiT RR/5 SnAgSnAf[0a T RR-S5 g T RR/5 O=fUS-nT RR-SUS9 [2R4"S5IShvN U(aGM6g7f)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 rXrYr[NZor XBR)r\r1r&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)r1rr rr]r^rrcallr rdrer rfrgrrbinasciib2a_hexdecodererrorwarnfailurerasynciosleep) key_seriesr1r valid_fromr signaturerrer&rrr'r%s r+r*#SimpleSeller.add..on_rotate-s&&F%/DNN6 " G,'!(\!9J#zzH " 2I"&"3"3K"&--"4"45R5;5;5;5?5=5>=ARWRc<;Nim@J=A<@AL#5 #N NEHHNNC "OS)9%:UV!WZ`!`hqr!#H$4$4X$>$E$E$G!H!&z#+HHNN?%N@C N6(ww"@@ &UVV((*$HHMM"VW'HH$$&1  V`g hmmA&&&c'sl&I A1E4E2CE40I 2E44 H>+G )I .G I  (H5I 7H=I I I I )r(r)r*z#Created new key series {key_series})r) rrrrrdictrvaluesrrdre) r%r&rr'r(r)rr*rs ```` ` r+addSimpleSeller.addsX F|u$V):vTZZ?WWWE{c!eqj00DNc$9hlKK}e!3 BB U%6HCn\f\k\k\mCnCntaMWM^M^M`tata @d@ @b; '; 'z^^FEH]f^g ' 6 <Tr.c # [U[5(dSRU55eUR[R [R 4;dS5e[RUlXl/Ul URRS[UR5[R"UR R"SS5R%5S9 UR'SUR(5IShvN UlUR*(d [-S5eUR*S n[/U5[0:Xa[3U5S :Xde[4R6"US 9UlS RUR:5nUR=UR>U[AS S9S9IShvN nURRCU5 URRS[URD5S9 SRUR:5nUR=URFU[AS S9S9IShvN nURRCU5 URRS[URD5S9 URHRK5HnURM5IShvN M UR'S5IShvN Ul'UR'SUR8R05IShvN n[/US5[0:Xa[QUS5US'USS:d [-S5e[SX&SUS5URTU'[RVUlUSUl,[/URX5[0:Xa[QURX5Ul,USUl-URR]S[UR85[_URX5[_URZ5S9 US$GN%GNvGNGNrGNXGN(7f)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_oidrr[zxbr.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 channelrzzvOk, seller delegate started [active paying channel {channel_oid} with remaining balance {remaining} at sequence {seq}])rrrz)0 isinstancerrrr~r STATE_STOPPEDSTATE_STARTINGrrrdrer rrrrrrrrr Exceptionrrrrfrg _channel_oidrregistersellrappendr close_channelrrrQrr rsr STATE_STARTEDrxrwinfor)r%sessionrrregrpaying_balances r+rQSimpleSeller.startps'#566y8i8p8pqx8yy6{{|66 8R8RSSmUmmS"11   k!$++"*"2"24::3H3H"3M"N"U"U"W  Y &ll+VX\XbXbcc }}<= =mmM2 K E)c+.>".DDD IIK8*11$2C2CD $$TYY ?_hCi$jj !!#& ;r#--GXY3::4;L;LM $$T%7%7OhqLr$ss !!#& ;r#--GXY**++-J""$ $ $.$+<<0L#MM '||,XZ^ZkZkZqZqrr {+ , 5*8 9T*UN; 'k*Q.NO O&3KPUAVXfgrXs&t{#"00 '{3  % '*4==9DM"5)   O"$T%6%6"75CW]bcgclcl]m  ok**Ydk t %MsspD Q P0 B1Q=P3>B Q P6 A# UR[R4;a [S5eUR(aURR 5(d [S5eURR SURS5IShvN nU$N7f)ah Return current (off-chain) balance of paying channel: * ``amount``: The initial amount with which the paying channel was opened. * ``remaining``: The remaining amount of XBR in the paying channel that can be earned. * ``inflight``: The amount of XBR allocated to sell transactions that are currently processed. :return: Current paying balance. :rtype: dict rz!market-maker session not attachedrrN)rr~r RuntimeErrorrrrr)r%rs r+r{SimpleSeller.balances ;;|99: :34 4}}DMM$=$=$?$?BC C#}}112^`d`m`mn{`|}}~sBBBBc# [U5[:Xa[U5S:XaXR;de[U5[:XdeUceURUnUR U5IShvN upVnXVU4$N 7f)a Encrypt and wrap application payload for a given API and destined for a specific WAMP URI. :param api_id: API for which to encrypt and wrap the application payload for. :type api_id: bytes :param uri: WAMP URI the application payload is destined for (eg the procedure or topic URI). :type uri: str :param payload: Application payload to encrypt and wrap. :type payload: object :return: The encrypted and wrapped application payload: a tuple with ``(key_id, serializer, ciphertext)``. :rtype: tuple rN)rrrrrr8)r%r&urir9 keyseriesr1 serializerr;s r+wrapSimpleSeller.wraps F|u$V):v?SSSCyC"""JJv& /8/@/@/I)I&J:--*JsA1B3A?4 Bc . [U5[:Xa[U5S:XdSR[U555e[U5[:Xa[U5S:XdSR[U555e[U5[:XdSR[U555e[U5[:Xa[U5S:XdSR[U555e[U5[ :XdSR[U555e[U5[:Xa[U5S :XdS R[U555eUb[ U[5(dS 5eXR:wa[S S RURR[R"UR5R5[R"U5R555eX RS:waUR R#5 [SSRURR[R"URS5R5[R"U5R555eX0R$:wa>[SSRURRUR$S-U55e['U5nX@R(:wa;[SSRURRUR(U55e[+X#XEU5nX:waUR,R/SURR[1[R"U5R55[1[R"U5R55S9 [SSRURR55e[3UR4X#XE5n UR6U[9U5UU S.n UR,R;SURR[1SSS9[1[=[ US- 55S -SS9[1U5[1[R"U5R55[1UR>5[1UR@5S!9 U $)"z9 Called by a XBR Market Maker to close a paying channel. rz.market_maker_adr must be bytes[20], but was {}rz)channel_oid must be bytes[16], but was {}z#channel_seq must be int, but was {}r>z-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_oidJ{}.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)rrzr{is_finalrz{klass}.close_channel() - {tx_type} closing channel {channel_oid}, closing balance {channel_balance}, closing sequence {channel_seq} [caller={caller}, caller_authid="{caller_authid}"]z XBR CLOSE rXrYrr)rr\channel_balance channel_seqrcaller caller_authid)!rrrrrboolrrrr __class__rjrrrrrleaverwr rxrrdrr rrrr rerr r ) r%rrrrchannel_is_finalmarketmaker_signaturerrseller_signaturereceipts r+rSimpleSeller.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-)*e3  @r.c Z [U5[:Xa[U5S:XdS5e[U5[:Xa[U5S:XdS5e[U5[:Xa[U5S:XdS5e[U5[:Xa[U5S:XdS5e[U5[:XdS5e[U5[:Xa[U5S:XdS R [U555e[U5[:Xa[U5S:XdS R [U555e[U5[:Xa[U5S :XdS 5eU b[ U [ 5(dS5e[U5n[U5nXR:wa[SSR URR[R"UR5R5[R"U5R555eX0R;a0[SSR URRU55eURUn X@R S:waUR"R%5 [SSR URR[R"UR S5R5[R"U5R555eXPR&S-:wa>[SSR URRUR&S-U55eXpR(U- :wa>[SSR URRUR(U- U55eSn UR*Sn [R,"UR*SSS 5n UR Sn[/XU XXWSU5 nX:waUR0R3S URR[5[R"U5R55[5[R"U5R55S!9 [S"S#R URR55eU=R&S- slU=R(U-slU R7X25n[U5[:Xa[U5S$:Xd+S%R URRU55e[9UR:XXX@R&UR(S5 nUUR<UUUR&UUR(US&.nUR0R?S'URR[5S(S)S*9[5[@RB"US+95[5[E[US,- 55S--S)S*9[5[E[UR(S,- 55S--S)S*9[5U RF5[5U RH5[5[R"U5R55S.9 U$)/a 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 rzdelegate_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]): {})r1rrF sealed_keyramountr{rz{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 rXrYr[rr)rr\r1 amount_earnedr{r r rF)%rrrrrrrr rrr rjrrrrrrr rwrxra2b_hexrrdrr rKrrrrrfrgrr r )r%rrFr1rrrr{rrrcurrent_block_numberrrrrrrrs r+rSimpleSeller.sellBskL$%.37G3HB3NpPppNL!U*s".DeFeeDK C'B)BB'F|u$V):|r(sc6 <C5/  ZA(A(H F W6Wr.