o >hM=@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@seZdZdZdZ       d1dddeedeedeed eed eed eed eefd dZe dede dede dede de de de de defddZ e  d2de ded edee deedef dd Zed3d!d"Zedeefd#d$Zedeefd%d&Zedeefd'd(Zedeefd)d*Zedeefd+d,Zedeefd-d.Zedeefd/d0ZdS)4Seederz _frealm _operator_label_country_legal _endpoint_bandwidth_requested_bandwidth_offeredNfrealmFederatedRealmoperatorlabelcountrylegalendpointbandwidth_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%t/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/autobahn/xbr/_frealm.py__init__:s zSeeder.__init__chain_idverifying_contractchannel_binding channel_idblock_no challengepubkeyrealmdelegateseeder bandwidthc Cs|pd}|pd}|s J|sJ|dusJ|dusJ|s J|s$J|s(J|s,J|s0J| s4Jddddddgdddd d dd ddd d dddddd ddd ddd ddd ddd ddddg ddddd|||||||||| | d d} | S)Nnamestring)r5typeversionchainIduint256verifyingContractaddressr*r+bytes32r,r-r.r/r0r1r2uint32) EIP712DomainEIP712SeederConnectr@XBR1)r5r8) r9r;r*r+r,r-r.r/r0r1r2)types primaryTypedomainmessager%) r(r)r*r+r,r-r.r/r0r1r2datar%r%r&_create_eip712_connectXs    :OzSeeder._create_eip712_connect client_key delegate_keyreturnc 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)binarysFs) r(r)r*r+r,r-r.r/r0r1r2(7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f) r.r-r*r+r/r(r,r0r1r2 signature) osurandomrrH public_keyr<sign_typed_datarrdecode) r$rIrJr"r+r*r(r)r,r- eip712_datarP authextrar%r%r&create_authextras>       #zSeeder.create_authextracC|jS :return: )rr$r%r%r&r z Seeder.frealmcCrY)z Operator address, e.g. ``"0xe59C7418403CF1D973485B36660728a5f4A8fF9c"``. :return: The Ethereum address of the endpoint operator. )rr\r%r%r&rzSeeder.operatorcCrY)z Operator endpoint label. :return: A human readable label for the operator or specific operator endpoint. )rr\r%r%r&rr^z Seeder.labelcCrY)zz Operator country (ISO 3166-1 alpha-2), e.g. ``"US"``. :return: ISO 3166-1 alpha-2 country code. )rr\r%r%r&r&r^zSeeder.countrycCrYrZ)rr\r%r%r&r /r]z Seeder.legalcCrY)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. )rr\r%r%r&r!7s zSeeder.endpointcCrYrZ)rr\r%r%r&r"Br]zSeeder.bandwidth_requestedcCrYrZ)rr\r%r%r&r#Jr]zSeeder.bandwidth_offered)NNNNNNN)NN)rKr)__name__ __module__ __qualname____doc__ __slots__rstrintr' staticmethodbytesrHr r r r rXpropertyrrrrr r!r"r#r%r%r%r&r+s    i I  rc@seZdZUdZdZejdZdZ e e d<dde de e e effd d Zed e fd d Zed e fddZed e e e effddZed e e fddZeddZd efddZed eefddZddZddZdS)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*0xF7acf1C4CB4a9550B8969576573C2688B48988C2r3 CONTRACT_ABINname_or_addressgateway_configcCs`||_||_d|_t|j|_|jdvrtd|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) rirjrkrrl ValueErrorformatrmrnrorprqrr)r$rwrxr%r%r&r'ps    zFederatedRealm.__init__rKcCrYN)rkr\r%r%r&statuszFederatedRealm.statuscCrYr)rir\r%r%r&rwrzFederatedRealm.name_or_addresscCrYr)rjr\r%r%r&rxrzFederatedRealm.gateway_configcCrYr)rlr\r%r%r& name_categoryrzFederatedRealm.name_categorycCrYr)ror\r%r%r&r<rzFederatedRealm.addresscCs|jdksJ|jS)NRUNNING)rkrrr\r%r%r&root_caszFederatedRealm.root_cacCrYr)rqr\r%r%r&seedersrzFederatedRealm.seederscCs(|jdkr td|jt|j}|S)r[ryzcannot start in status "{}")rk RuntimeErrorr~r _initialize_background)r$dr%r%r& initializes  zFederatedRealm.initializecCsd|_|jr t|j|_ntdt|j|_|jdvr9|jdkr.d t |j d}n|j }|j ||_n|jdkrG|j|j |_nJd d |_dS) NSTARTINGzJcannot auto-configure ethereum connection (was removed from web3.py in v6))r{r|r|r3.rzFzshould not arrive herer)rkrjrrmrr from_web3rnrljoinreversedrisplitr<rotoChecksumAddress)r$r5r%r%r&rs    z%FederatedRealm._initialize_backgroundr)r_r`rarbrcweb3Web3rCONTRACT_ADDRESSrvrd__annotations__rrrr'rhrrwrxrr<rrrrrrrr%r%r%r&rSs*    #  r)rQbinasciirtypingrrrrr web3.contractrr{rtwisted.internet.deferr r twisted.internet.threadsr autobahn.wamp.interfacesr r autobahn.wamp.messager autobahn.xbrrrobjectrrr%r%r%r&s     *