o i@s0ddlZddlZddlmZGdddeZdS)N)xbrc@seZdZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZdZdddZd d Zd d Zd dZddZddZddZddZddZddZddZddZdS) SimpleBlockchainz0 Simple Ethereum blockchain XBR client. rNcCs(t|_||_d|_|jdusJdS)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_w3backgroundCaller)selfZgatewayr ^C:\Users\psant\Downloads\PAF backend\school\venv\Lib\site-packages\autobahn/xbr/_blockchain.py__init__4s zSimpleBlockchain.__init__cCs|jdusJ|jrttj|j}nddlm}|s1d|jp%d}|j |t |t d|j j|jp;d||_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 web3ZWeb3Z HTTPProviderZ web3.autorZ isConnectedformatrwarn RuntimeErrorprintversionnetworkrZ setProvider)r rZemsgr r rstart@s   zSimpleBlockchain.startcCs|jdusJd|_dS)z- Stop the blockchain client. N)r r r r rstopZs zSimpleBlockchain.stopcdd}|||S)z5 :param market_id: :return: cSs*tjj|}|r|dkrdSd|iS)NZ*0x0000000000000000000000000000000000000000owner)r xbrnetwork functionsZgetMarketOwnercall)Z _market_idrr r r_get_market_statushs  z>SimpleBlockchain.get_market_status.._get_market_statusNr )r Z market_idr!r r rget_market_statusbs z"SimpleBlockchain.get_market_statuscr)zj :param domain_id: :type domain_id: bytes :return: :rtype: dict cSsHtjj|}|tjkrdS|tjkrddiS|tjkr"ddiSdS)NstatusZACTIVEZCLOSED) rrrZgetDomainStatusr rDomainStatus_NULLDomainStatus_ACTIVEDomainStatus_CLOSED)Z _domain_idr$r r r_get_domain_status{s   z>SimpleBlockchain.get_domain_status.._get_domain_statusNr")r Z domain_idr(r r rget_domain_statusrs z"SimpleBlockchain.get_domain_statuscCtzp :param delegate_adr: :type delegate_adr: bytes :return: :rtype: dict NNotImplementedErrorr Z delegate_adrr r rget_node_status z SimpleBlockchain.get_node_statuscCr*r+r,r.r r rget_actor_statusr0z!SimpleBlockchain.get_actor_statuscCr*r+r,r.r r rget_delegate_statusr0z$SimpleBlockchain.get_delegate_statuscCr*)zn :param channel_adr: :type channel_adr: bytes :return: :rtype: dict Nr,)r Z channel_adrr r rget_channel_statusr0z#SimpleBlockchain.get_channel_statuscs6ttkr tdksJfdd}||S)zl :param member_adr: :type member_adr: bytes :return: :rtype: dict csptjj}|s dStjj}|r|dkr dStjj}|r1|dkr3d}||dS)N)eulaprofile)rrrZgetMemberLevelr Z getMemberEulastripZgetMemberProfile)Z _member_adrlevelr6r7 member_adrr r_get_member_statussz>SimpleBlockchain.get_member_status.._get_member_statusNtypebyteslenr )r r;r<r r:rget_member_statuss  z"SimpleBlockchain.get_member_statuscs6t|tkr t|dksJfdd}||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 r4cs*jj|}tjj|}||dS)N)ETHZXBR)r ethZ getBalancerxbrtokenrZ balanceOfr )Z_adrZ balance_ethZ balance_xbrrr r _get_balancess z4SimpleBlockchain.get_balances.._get_balancesNr=)r Z account_adrrEr rr 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 XBRNetworkN)rrDaddressrrr r rget_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/r1r2r3rArFrHr r r rr s4       r)rrZautobahnrobjectrr r r rs