U YcM=@sddlZddlmZddlmZmZmZmZddlZddl m Z ddl m Z ddl mZmZddlmZddlmZmZdd lmZdd lmZmZGd d d eZGd ddeZdS)N)b2a_hex)OptionalDictAnyList)Contract)ENS)DeferredinlineCallbacks) deferToThread)ICryptosignKey IEthereumKey)identify_realm_name_category)make_w3EIP712AuthorityCertificatec @sFeZdZdZdZddeeeeeeeeeeeeeedddZe ee ee ee e e e e ed d d Z e d e eeee eeed d d ZeddddZeeedddZeeedddZeeedddZeeedddZeeedddZeeedddZeeedddZdS)!Seederz _frealm _operator_label_country_legal _endpoint_bandwidth_requested_bandwidth_offeredNFederatedRealm)frealmoperatorlabelcountrylegalendpointbandwidth_requestedbandwidth_offeredc Cs4||_||_||_||_||_||_||_||_dS)z :param frealm: :param operator: :param label: :param country: :param legal: :param endpoint: :param bandwidth_requested: :param bandwidth_offered: Nr) selfrrrrr r!r"r#r%X/var/www/html/CISBACKEND/school/venv/lib/python3.8/site-packages/autobahn/xbr/_frealm.py__init__:szSeeder.__init__ chain_idverifying_contractchannel_binding channel_idblock_no challengepubkeyrealmdelegateseeder bandwidthc Cs|pd}|pd}|st|s t|dk s,t|dk s8t|s@t|sHt|sPt|sXt|s`t| shtddddddgdddd d dd ddd d dddddd ddd ddd ddd ddd ddddg ddddd|||||||||| | d d} | S)Nnamestring)r6typeversionchainIdZuint256verifyingContractaddressr+r,Zbytes32r-r.r/r0r1r2r3Zuint32)Z EIP712DomainEIP712SeederConnectr=ZXBR1)r6r9) r:r;r+r,r-r.r/r0r1r2r3)typesZ primaryTypedomainmessage)AssertionError) r)r*r+r,r-r.r/r0r1r2r3datar%r%r&_create_eip712_connectXs    :OzSeeder._create_eip712_connect) client_key delegate_keyr"r,r+returnc csd}d}d}td} tj|||||| |jddd|jddd|d } || V} |jdd| ||d |||jdd|j|t|  d } | S) z :param client_key: :param delegate_key: :param bandwidth_requested: :param channel_id: :param channel_binding: :return: s T)binarysFsr(Z(7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f) r/r.r+r,r0r)r-r1r2r3 signature) osurandomrrDZ public_keyr<Zsign_typed_datarrdecode) r$rErFr"r,r+r)r*r-r.Z eip712_datarKZ authextrar%r%r&create_authextras<       #zSeeder.create_authextrarGcCs|jS :return: )rr$r%r%r&r sz Seeder.frealmcCs|jS)z Operator address, e.g. ``"0xe59C7418403CF1D973485B36660728a5f4A8fF9c"``. :return: The Ethereum address of the endpoint operator. )rrSr%r%r&rszSeeder.operatorcCs|jS)z Operator endpoint label. :return: A human readable label for the operator or specific operator endpoint. )rrSr%r%r&rsz Seeder.labelcCs|jS)zz Operator country (ISO 3166-1 alpha-2), e.g. ``"US"``. :return: ISO 3166-1 alpha-2 country code. )rrSr%r%r&r&szSeeder.countrycCs|jSrQ)rrSr%r%r&r /sz Seeder.legalcCs|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. )rrSr%r%r&r!7s zSeeder.endpointcCs|jSrQ)rrSr%r%r&r"BszSeeder.bandwidth_requestedcCs|jSrQ)rrSr%r%r&r#JszSeeder.bandwidth_offered)NNNNNNN)NN)__name__ __module__ __qualname____doc__ __slots__rstrintr' staticmethodbytesrDr r r r rOpropertyrrrrr r!r"r#r%r%r%r&r+sv  iI rc@seZdZUdZdZejdZdZ e e d<de e e e efddd Zee d d d Zee d d dZee e e efd ddZee e d ddZeddZed ddZeeed ddZddZddZdS)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_catalogZ_metaZ*0xF7acf1C4CB4a9550B8969576573C2688B48988C2r4 CONTRACT_ABIN)name_or_addressgateway_configcCs`||_||_d|_t|j|_|jdkr8td|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) r^r_r`rra ValueErrorformatrbrcrdrerfrg)r$rjrkr%r%r&r'ps   zFederatedRealm.__init__rPcCs|jSN)r`rSr%r%r&statusszFederatedRealm.statuscCs|jSrr)r^rSr%r%r&rjszFederatedRealm.name_or_addresscCs|jSrr)r_rSr%r%r&rkszFederatedRealm.gateway_configcCs|jSrr)rarSr%r%r& name_categoryszFederatedRealm.name_categorycCs|jSrr)rdrSr%r%r&r<szFederatedRealm.addresscCs|jdkst|jS)NRUNNING)r`rBrgrSr%r%r&root_caszFederatedRealm.root_cacCs|jSrr)rfrSr%r%r&seedersszFederatedRealm.seederscCs(|jdkrtd|jt|j}|S)rRrlzcannot start in status "{}")r` RuntimeErrorrqr _initialize_background)r$dr%r%r& initializes  zFederatedRealm.initializecCsd|_|jrt|j|_ntdt|j|_|jdkrr|jdkr\d t |j d}n|j }|j ||_n(|jdkr|j|j |_n dstd d |_dS) NZSTARTINGzJcannot auto-configure ethereum connection (was removed from web3.py in v6))rnroror4.rmFzshould not arrive hereru)r`r_rrbrxrZ from_web3rcrajoinreversedr^splitr<rdtoChecksumAddressrB)r$r6r%r%r&rys    z%FederatedRealm._initialize_background)N)rTrUrVrWrXweb3ZWeb3rZCONTRACT_ADDRESSrirY__annotations__rrrr'r]rsrjrkrtr<rrvrrrwr{ryr%r%r%r&rSs(    #  r)rLbinasciirtypingrrrrrZ web3.contractrrnrZtwisted.internet.deferr r Ztwisted.internet.threadsr Zautobahn.wamp.interfacesr r Zautobahn.wamp.messagerZ autobahn.xbrrrobjectrrr%r%r%r&s     *