o iM=@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%ZC:\Users\psant\Downloads\PAF backend\school\venv\Lib\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)r5typeversionchainIdZuint256verifyingContractaddressr*r+Zbytes32r,r-r.r/r0r1r2Zuint32)Z EIP712DomainEIP712SeederConnectr<ZXBR1)r5r8) r9r:r*r+r,r-r.r/r0r1r2)typesZ 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/r0r1r2Z(7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f7f) r.r-r*r+r/r(r,r0r1r2 signatureN) osurandomrrBZ public_keyr;Zsign_typed_datarrdecode) r$rCrDr"r+r*r(r)r,r-Z eip712_datarIZ authextrar%r%r&create_authextras>       #zSeeder.create_authextracC|jS :return: N)rr$r%r%r&r z Seeder.frealmcCrN)z Operator address, e.g. ``"0xe59C7418403CF1D973485B36660728a5f4A8fF9c"``. :return: The Ethereum address of the endpoint operator. N)rrQr%r%r&rzSeeder.operatorcCrN)z Operator endpoint label. :return: A human readable label for the operator or specific operator endpoint. N)rrQr%r%r&rrSz Seeder.labelcCrN)zz Operator country (ISO 3166-1 alpha-2), e.g. ``"US"``. :return: ISO 3166-1 alpha-2 country code. N)rrQr%r%r&r&rSzSeeder.countrycCrNrO)rrQr%r%r&r /rRz Seeder.legalcCrN)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. N)rrQr%r%r&r!7s zSeeder.endpointcCrNrO)rrQr%r%r&r"BrRzSeeder.bandwidth_requestedcCrNrO)rrQr%r%r&r#JrRzSeeder.bandwidth_offered)NNNNNNN)NN)rEr)__name__ __module__ __qualname____doc__ __slots__rstrintr' staticmethodbytesrBr r r r rMpropertyrrrrr 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_catalogZ_metaZ*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) r^r_r`rra ValueErrorformatrbrcrdrerfrg)r$rjrkr%r%r&r'ps    zFederatedRealm.__init__rEcCrNN)r`rQr%r%r&statuszFederatedRealm.statuscCrNrr)r^rQr%r%r&rjrtzFederatedRealm.name_or_addresscCrNrr)r_rQr%r%r&rkrtzFederatedRealm.gateway_configcCrNrr)rarQr%r%r& name_categoryrtzFederatedRealm.name_categorycCrNrr)rdrQr%r%r&r;rtzFederatedRealm.addresscCs|jdksJ|jS)NRUNNING)r`rgrQr%r%r&root_caszFederatedRealm.root_cacCrNrr)rfrQr%r%r&seedersrtzFederatedRealm.seederscCs(|jdkr td|jt|j}|S)rPrlzcannot start in status "{}"N)r` RuntimeErrorrqr _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) NZSTARTINGzJcannot auto-configure ethereum connection (was removed from web3.py in v6))rnroror3.rmFzshould not arrive hererv)r`r_rrbryrZ from_web3rcrajoinreversedr^splitr;rdtoChecksumAddress)r$r5r%r%r&rzs    z%FederatedRealm._initialize_backgroundrr)rTrUrVrWrXweb3ZWeb3rZCONTRACT_ADDRESSrirY__annotations__rrrr'r]rsrjrkrur;rrwrrrxr|rzr%r%r%r&rSs*    #  r)rJbinasciirtypingrrrrrZ web3.contractrrnrZtwisted.internet.deferr r Ztwisted.internet.threadsr Zautobahn.wamp.interfacesr r Zautobahn.wamp.messagerZ autobahn.xbrrrobjectrrr%r%r%r&s     *