tfM=ddlZddlmZddlmZmZmZmZddlZddl m Z ddl m Z ddl mZmZddlmZddlmZmZdd lmZdd lmZmZGd d eZGd deZdS)N)b2a_hex)OptionalDictAnyList)Contract)ENS)DeferredinlineCallbacks) deferToThread)ICryptosignKey IEthereumKey)identify_realm_name_category)make_w3EIP712AuthorityCertificatecdeZdZdZdZ d&dddeedeedeed eed eed eed eefd Ze dede dede dede de de de de defdZ e d'de ded edee deedef dZed(dZedeefdZedeefd Zedeefd!Zedeefd"Zedeefd#Zedeefd$Zedeefd%ZdS))Seederz _frealm _operator_label_country_legal _endpoint_bandwidth_requested_bandwidth_offeredNfrealmFederatedRealmoperatorlabelcountrylegalendpointbandwidth_requestedbandwidth_offeredc v||_||_||_||_||_||_||_||_dS)z :param frealm: :param operator: :param label: :param country: :param legal: :param endpoint: :param bandwidth_requested: :param bandwidth_offered: Nr) selfrrr r!r"r#r$r%s S/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/autobahn/xbr/_frealm.py__init__zSeeder.__init__:sD*(. (0%* '. %* (03F!1Bchain_idverifying_contractchannel_binding channel_idblock_no challengepubkeyrealmdelegateseeder bandwidthc |pd}|pd}|sJ|sJ|J|J|sJ|sJ|sJ|sJ|sJ| sJddddddgdddd d dd ddd d dddddd ddd ddd ddd ddd ddddg ddddd|||||||||| | d d} | S)Nr*namestring)r8typeversionchainIduint256verifyingContractaddressr-r.bytes32r/r0r1r2r3r4r5uint32) EIP712DomainEIP712SeederConnectrCXBR1)r8r;) r<r>r-r.r/r0r1r2r3r4r5)types primaryTypedomainmessage) r+r,r-r.r/r0r1r2r3r4r5datas r(_create_eip712_connectzSeeder._create_eip712_connectXs*/R&3 !!!!***%%%   !' ( !* ( !!* ) !4 ) !2 ( !- ) !+ ) !, ) !) ) !( ) !+ ) !) ) !, (S-(99t1 $%7#2($& $ &  AM M ^ r* client_key delegate_keyreturnc #Kd}d}d}tjd} t|||||| |dd|dd| } || V} |d| ||d |||d|j|t|  d } | S) z :param client_key: :param delegate_key: :param bandwidth_requested: :param channel_id: :param channel_binding: :return: s T)binarysFs) r+r,r-r.r/r0r1r2r3r4r5(7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f) r1r0r-r.r2r+r/r3r4r5 signature) osurandomrrL public_keyr?sign_typed_datarrdecode) r'rMrNr$r.r-r+r,r/r0 eip712_datarU authextras r(create_authextrazSeeder.create_authextras+ )JrNN 33XGYDS?I=E>G;E;P;PX\;P;];];G=I=Q=QY^=Q=_=_Q4SS '66{CCCC !++5+99# /%!!%,,E,::n-!++2244C" " Fr*c|jS :return: )rr's r(rz Seeder.frealm s |r*c|jS)z Operator address, e.g. ``"0xe59C7418403CF1D973485B36660728a5f4A8fF9c"``. :return: The Ethereum address of the endpoint operator. )rras r(rzSeeder.operators ~r*c|jS)z Operator endpoint label. :return: A human readable label for the operator or specific operator endpoint. )rras r(r z Seeder.labels {r*c|jS)zz Operator country (ISO 3166-1 alpha-2), e.g. ``"US"``. :return: ISO 3166-1 alpha-2 country code. )rras r(r!zSeeder.country&s }r*c|jSr_)rras r(r"z Seeder.legal/s {r*c|jS)a Public WAMP endpoint of seeder. Secure WebSocket URL resolving to a public IPv4 or IPv6 listening url accepting incoming WAMP-WebSocket connections, e.g. ``wss://service1.example.com/ws``. :return: The endpoint URL. )rras r(r#zSeeder.endpoint7s ~r*c|jSr_)rras r(r$zSeeder.bandwidth_requestedBs ((r*c|jSr_)rras r(r%zSeeder.bandwidth_offeredJs &&r*)NNNNNNN)NN)rOr)__name__ __module__ __qualname____doc__ __slots__rstrintr) staticmethodbytesrLr r rr r]propertyrrr r!r"r#r$r%rJr*r(rr+s) I,0(,*.(,+/6:48CC)C#C=C! C#3- C ! C $C= C'/smC%-SMCCCC<gg38g03g,1g*- g +0 g (- g',g*/g(-g+.ggg\gR 8<:> GG%3G'3G/2G&.e_ G +33- G DL GGG_GRX(3-Xx}X#Xx}X(3-X)Xc])))X)'8C='''X'''r*rcveZdZUdZdZejdZdZ e e d<dde de e e effd Zed e fd Zed e fd Zed e e e effd Zed e e fdZedZd efdZed eefdZdZdZdS)ra A federated realm is a WAMP application realm with a trust anchor rooted in Ethereum, and which can be shared between multiple parties. A federated realm is globally identified on an Ethereum chain (e.g. on Mainnet or Rinkeby) by an Ethereum address associated to a federated realm owner by an on-chain record stored in the WAMP Network contract. The federated realm address thus only needs to exist as an identifier of the federated realm-owner record. ) _name_or_address_gateway_config_status_name_category_w3_ens_address _contract_seeders_root_ca_catalog_meta*0xF7acf1C4CB4a9550B8969576573C2688B48988C2r7 CONTRACT_ABINname_or_addressgateway_configc||_||_d|_t|j|_|jdvr't d|jd|_d|_d|_ d|_ g|_ d|_ dS)a Instantiate a federated realm from a federated realm ENS name (which is resolved to an Ethereum address) or Ethereum address. :param name_or_address: Ethereum ENS name or address. :param gateway_config: If provided, use this Ethereum gateway. If not provided, connect via Infura to Ethereum Mainnet, which requires an environment variable ``WEB3_INFURA_PROJECT_ID`` with your Infura project ID. STOPPED)ethens reverse_ensz8name_or_address "{}" not an Ethereum address or ENS nameN) rtrurvrrw ValueErrorformatrxryrzr{r|r})r'rrs r(r)zFederatedRealm.__init__ps!0-! -I$J_-`-`  &C C CW^^_c_tuuvv v (, .2')  r*rOc|jSN)rvras r(statuszFederatedRealm.statuss |r*c|jSr)rtras r(rzFederatedRealm.name_or_addresss $$r*c|jSr)ruras r(rzFederatedRealm.gateway_configs ##r*c|jSr)rwras r( name_categoryzFederatedRealm.name_categorys ""r*c|jSr)rzras r(r?zFederatedRealm.address }r*c*|jdksJ|jS)NRUNNING)rvr}ras r(root_cazFederatedRealm.root_cas|y((((}r*c|jSr)r|ras r(seederszFederatedRealm.seedersrr*c|jdkr'td|jt|j}|S)r`rzcannot start in status "{}")rv RuntimeErrorrr _initialize_background)r'ds r( initializezFederatedRealm.initializesE <9 $ $<CCDLQQRR R $5 6 6r*cd|_|jrt|j|_nt dt j|j|_|jdvrm|jdkr;d t|j d}n|j }|j ||_n:|jdkr%|j|j |_n Jd d |_dS) NSTARTINGzJcannot auto-configure ethereum connection (was removed from web3.py in v6))rrrr7.rFzshould not arrive herer)rvrurrxrr from_web3ryrwjoinreversedrtsplitr?rztoChecksumAddress)r'r8s r(rz%FederatedRealm._initialize_backgrounds!   mt344DHHkll l M$(++  "8 8 8"m33wwx(=(C(CC(H(HIIJJ, I--d33DMM  E ) ) H66t7LMMDMM 22 2 2 2! r*r)rirjrkrlrmweb3Web3rCONTRACT_ADDRESSrrn__annotations__rrrr)rrrrrrr?rrrrrrrrJr*r(rrSsI y223_``L#!!!Xd3PS8n=U!!!!FX%%%%X%$c3h 8$$$X$#x}###X#X3fX!!!!!r*r)rVbinasciirtypingrrrrr web3.contractrrr twisted.internet.deferr r twisted.internet.threadsr autobahn.wamp.interfacesr rautobahn.wamp.messager autobahn.xbrrrobjectrrrJr*r(rsP6 ,,,,,,,,,,,, """"""<<<<<<<<222222AAAAAAAA>>>>>><<<<<<<<e'e'e'e'e'Ve'e'e'P D!D!D!D!D!VD!D!D!D!D!r*