U uc@s0ddlZddlZddlmZGdddeZdS)N)xbrc@seZdZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZdZdddZd d Zd d Zd dZddZddZddZddZddZddZddZddZdS) SimpleBlockchainz0 Simple Ethereum blockchain XBR client. rNcCs(t|_||_d|_|jdk s$tdS)z :param gateway: Optional explicit Ethereum gateway URL to use. If no explicit gateway is specified, let web3 auto-choose. :type gateway: str N)txaioZ make_loggerlog_gateway_w3backgroundCallerAssertionError)selfZgatewayrZ/var/www/html/NKSPORTS/school/venv/lib/python3.8/site-packages/autobahn/xbr/_blockchain.py__init__4s zSimpleBlockchain.__init__cCs|jdkst|jr*ttj|j}n ddlm}|sdd |jpJd}|j |t |nt d |jj|jpxd||_t|jdS)zV Start the blockchain client using the configured blockchain gateway. Nr)w3z)could not connect to Web3/Ethereum at: {}autoz(connected to network {} at provider "{}")r r r web3ZWeb3Z HTTPProviderZ web3.autorZ isConnectedformatrwarn RuntimeErrorprintversionnetworkrZ setProvider)r rZemsgrrrstart@s    zSimpleBlockchain.startcCs|jdk std|_dS)z- Stop the blockchain client. N)r r r rrrstopZszSimpleBlockchain.stopcsdd}|||S)z5 :param market_id: :return: cSs.tjj|}|r|dkr"dSd|iSdS)NZ*0x0000000000000000000000000000000000000000owner)r xbrnetwork functionsZgetMarketOwnercall)Z _market_idrrrr_get_market_statushs  z>SimpleBlockchain.get_market_status.._get_market_statusr )r Z market_idr!rrrget_market_statusbsz"SimpleBlockchain.get_market_statuscsdd}|||S)zj :param domain_id: :type domain_id: bytes :return: :rtype: dict cSsHtjj|}|tjkr dS|tjkr2ddiS|tjkrDddiSdS)NstatusZACTIVEZCLOSED) rrrZgetDomainStatusr rDomainStatus_NULLDomainStatus_ACTIVEDomainStatus_CLOSED)Z _domain_idr$rrr_get_domain_status{s   z>SimpleBlockchain.get_domain_status.._get_domain_statusr")r Z domain_idr(rrrget_domain_statusrs z"SimpleBlockchain.get_domain_statuscCs tdSzp :param delegate_adr: :type delegate_adr: bytes :return: :rtype: dict NNotImplementedErrorr Z delegate_adrrrrget_node_statuss z SimpleBlockchain.get_node_statuscCs tdSr*r+r-rrrget_actor_statuss z!SimpleBlockchain.get_actor_statuscCs tdSr*r+r-rrrget_delegate_statuss z$SimpleBlockchain.get_delegate_statuscCs tdS)zn :param channel_adr: :type channel_adr: bytes :return: :rtype: dict Nr+)r Z channel_adrrrrget_channel_statuss z#SimpleBlockchain.get_channel_statuscs4ttkrtdkstfdd}||S)zl :param member_adr: :type member_adr: bytes :return: :rtype: dict csttjj}|sdStjj}|r<|dkr@dStjj}|rb|dkrfd}||dSdS)N)eulaprofile)rrrZgetMemberLevelr Z getMemberEulastripZgetMemberProfile)Z _member_adrlevelr4r5 member_adrrr_get_member_statussz>SimpleBlockchain.get_member_status.._get_member_statustypebyteslenr r )r r9r:rr8rget_member_statuss  z"SimpleBlockchain.get_member_statuscs4t|tkrt|dkstfdd}||S)aY Return current ETH and XBR balances of account with given address. :param account_adr: Ethereum address of account to get balances for. :type account_adr: bytes :return: A dictionary with ``"ETH"`` and ``"XBR"`` keys and respective current on-chain balances as values. :rtype: dict r2cs*jj|}tjj|}||dS)N)ETHZXBR)r ethZ getBalancerxbrtokenrZ balanceOfr )Z_adrZ balance_ethZ balance_xbrrrr _get_balancess z4SimpleBlockchain.get_balances.._get_balancesr;)r Z account_adrrCrrr get_balancess  zSimpleBlockchain.get_balancescCstjjtjjdS)z Get XBR smart contract addresses. :return: A dictionary with ``"XBRToken"`` and ``"XBRNetwork"`` keys and Ethereum contract addresses as values. :rtype: dict )ZXBRTokenZ XBRNetwork)rrBaddressrrrrrget_contract_adrss z"SimpleBlockchain.get_contract_adrs)N)__name__ __module__ __qualname____doc__r%r&r'Z NodeType_NULLZNodeType_MASTERZ NodeType_COREZ NodeType_EDGEZNodeLicense_NULLZNodeLicense_INFINITEZNodeLicense_FREErr rrrr#r)r.r/r0r1r?rDrFrrrrr s2     r)rrautobahnrobjectrrrrrs