diff --git a/pyproject.toml b/pyproject.toml index 326b15d..b063420 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -4,7 +4,7 @@ build-backend = 'hatchling.build' [project] name = 'pyCosmicWrap' -version = '0.1.3' +version = '0.1.4' description = 'pyCosmicWrap is a Cosmos API/RPC python Wrapper by ChihuahuaChain' authors = [ diff --git a/src/pycosmicwrap/wrapper.py b/src/pycosmicwrap/wrapper.py index 68c06f2..dfb0e89 100644 --- a/src/pycosmicwrap/wrapper.py +++ b/src/pycosmicwrap/wrapper.py @@ -30,12 +30,12 @@ def query_balances(self, address: str): responses = [] endpoint = '/cosmos/bank/v1beta1/balances/' try: - results = json.loads(requests.get(self.lcd + endpoint + address).content) + results = json.loads(requests.get(self.lcd + endpoint + address, timeout=60).content) responses += results['balances'] pagination = results['pagination']['next_key'] while pagination is not None: results = json.loads( - requests.get(self.lcd + endpoint + '?pagination.key=' + quote(str(pagination))).content) + requests.get(self.lcd + endpoint + '?pagination.key=' + quote(str(pagination)), timeout=60).content) responses += results['balances'] pagination = results['pagination']['next_key'] return responses @@ -46,7 +46,7 @@ def query_balances(self, address: str): def query_balances_by_denom(self, address, denom): endpoint = '/cosmos/bank/v1beta1/balances/' try: - return json.loads(requests.get(self.lcd + endpoint + address + '/by_denom?denom=' + denom).content) + return json.loads(requests.get(self.lcd + endpoint + address + '/by_denom?denom=' + denom, timeout=60).content) except Exception: raise Exception @@ -54,7 +54,7 @@ def query_balances_by_denom(self, address, denom): def query_supply(self): endpoint = '/cosmos/bank/v1beta1/supply' try: - return json.loads(requests.get(self.lcd + endpoint).content) + return json.loads(requests.get(self.lcd + endpoint, timeout=60).content) except Exception: raise Exception @@ -63,7 +63,7 @@ def query_supply_by_denom(self, denom): denom = self.denom if denom is None else denom endpoint = '/cosmos/bank/v1beta1/supply/' try: - return json.loads(requests.get(self.lcd + endpoint + denom).content) + return json.loads(requests.get(self.lcd + endpoint + denom, timeout=60).content) except Exception: raise Exception @@ -71,7 +71,7 @@ def query_supply_by_denom(self, denom): def query_community_pool(self): endpoint = '/cosmos/distribution/v1beta1/community_pool' try: - return json.loads(requests.get(self.lcd + endpoint).content) + return json.loads(requests.get(self.lcd + endpoint, timeout=60).content) except Exception: raise Exception @@ -79,7 +79,7 @@ def query_community_pool(self): def query_rewards(self, address): endpoint = '/cosmos/distribution/v1beta1/delegators/' try: - return json.loads(requests.get(self.lcd + endpoint + address + '/rewards').content) + return json.loads(requests.get(self.lcd + endpoint + address + '/rewards', timeout=60).content) except Exception: raise Exception @@ -87,7 +87,7 @@ def query_rewards(self, address): def query_rewards_by_validator(self, address, validator): endpoint = '/cosmos/distribution/v1beta1/delegators/' try: - return json.loads(requests.get(self.lcd + endpoint + address + '/rewards/' + validator).content) + return json.loads(requests.get(self.lcd + endpoint + address + '/rewards/' + validator, timeout=60).content) except Exception: raise Exception @@ -95,7 +95,7 @@ def query_rewards_by_validator(self, address, validator): def query_delegator_validators(self, address): endpoint = '/cosmos/distribution/v1beta1/delegators/' try: - return json.loads(requests.get(self.lcd + endpoint + address + '/validators').content) + return json.loads(requests.get(self.lcd + endpoint + address + '/validators', timeout=60).content) except Exception: raise Exception @@ -103,7 +103,7 @@ def query_delegator_validators(self, address): def query_withdraw_address(self, address): endpoint = '/cosmos/distribution/v1beta1/delegators/' try: - return json.loads(requests.get(self.lcd + endpoint + address + '/withdraw_address').content) + return json.loads(requests.get(self.lcd + endpoint + address + '/withdraw_address', timeout=60).content) except Exception: raise Exception @@ -111,7 +111,7 @@ def query_withdraw_address(self, address): def query_distribution_params(self): endpoint = '/cosmos/distribution/v1beta1/params' try: - return json.loads(requests.get(self.lcd + endpoint).content) + return json.loads(requests.get(self.lcd + endpoint, timeout=60).content) except Exception: raise Exception @@ -119,7 +119,7 @@ def query_distribution_params(self): def query_commission(self, validator): endpoint = '/cosmos/distribution/v1beta1/validators/' try: - return json.loads(requests.get(self.lcd + endpoint + validator + '/commission').content) + return json.loads(requests.get(self.lcd + endpoint + validator + '/commission', timeout=60).content) except Exception: raise Exception @@ -127,7 +127,7 @@ def query_commission(self, validator): def query_outstanding_rewards(self, address): endpoint = '/cosmos/distribution/v1beta1/validators/' try: - return json.loads(requests.get(self.lcd + endpoint + address + '/outstanding_rewards').content) + return json.loads(requests.get(self.lcd + endpoint + address + '/outstanding_rewards', timeout=60).content) except Exception: raise Exception @@ -148,12 +148,12 @@ def query_proposals(self, status=None): elif status == 'PROPOSAL_STATUS_FAILED': endpoint += '?proposalStatus=5' try: - results = json.loads(requests.get(self.lcd + endpoint).content) + results = json.loads(requests.get(self.lcd + endpoint, timeout=60).content) responses += results['proposals'] pagination = results['pagination']['next_key'] while pagination is not None: results = json.loads( - requests.get(self.lcd + endpoint + '?pagination.key=' + quote(str(pagination))).content) + requests.get(self.lcd + endpoint + '?pagination.key=' + quote(str(pagination)), timeout=60).content) responses += results['proposals'] pagination = results['pagination']['next_key'] return responses @@ -164,7 +164,7 @@ def query_proposals(self, status=None): def query_proposals_by_id(self, proposal_id): endpoint = '/cosmos/gov/v1beta1/proposals/' try: - return json.loads(requests.get(self.lcd + endpoint + str(proposal_id)).content) + return json.loads(requests.get(self.lcd + endpoint + str(proposal_id), timeout=60).content) except Exception: raise Exception @@ -172,7 +172,7 @@ def query_proposals_by_id(self, proposal_id): def query_tally(self, proposal_id): endpoint = '/cosmos/gov/v1beta1/proposals/' try: - return json.loads(requests.get(self.lcd + endpoint + str(proposal_id) + '/tally').content) + return json.loads(requests.get(self.lcd + endpoint + str(proposal_id) + '/tally', timeout=60).content) except Exception: raise Exception @@ -181,13 +181,13 @@ def query_votes(self, proposal_id): responses = [] endpoint = '/cosmos/gov/v1beta1/proposals/' try: - results = json.loads(requests.get(self.lcd + endpoint + str(proposal_id) + '/votes').content) + results = json.loads(requests.get(self.lcd + endpoint + str(proposal_id) + '/votes', timeout=60).content) responses += results['votes'] pagination = results['pagination']['next_key'] while pagination is not None: results = json.loads( requests.get(self.lcd + endpoint + str(proposal_id) + '/votes' + '?pagination.key=' + quote( - str(pagination))).content) + str(pagination)), timeout=60).content) responses += results['votes'] pagination = results['pagination']['next_key'] return responses @@ -198,7 +198,7 @@ def query_votes(self, proposal_id): def query_votes_by_address(self, proposal_id, address): endpoint = '/cosmos/gov/v1beta1/proposals/' try: - return json.loads(requests.get(self.lcd + endpoint + str(proposal_id) + '/votes/' + address).content) + return json.loads(requests.get(self.lcd + endpoint + str(proposal_id) + '/votes/' + address, timeout=60).content) except Exception: raise Exception @@ -206,7 +206,7 @@ def query_votes_by_address(self, proposal_id, address): def query_slashing_params(self): endpoint = '/cosmos/slashing/v1beta1/params' try: - return json.loads(requests.get(self.lcd + endpoint).content) + return json.loads(requests.get(self.lcd + endpoint, timeout=60).content) except Exception: raise Exception @@ -215,12 +215,12 @@ def query_delegations_by_address(self, address): endpoint = '/cosmos/staking/v1beta1/delegations/' responses = [] try: - results = json.loads(requests.get(self.lcd + endpoint + address).content) + results = json.loads(requests.get(self.lcd + endpoint + address, timeout=60).content) responses += results['delegation_responses'] pagination = results['pagination']['next_key'] while pagination is not None: results = json.loads( - requests.get(self.lcd + endpoint + address + '?pagination.key=' + quote(str(pagination))).content) + requests.get(self.lcd + endpoint + address + '?pagination.key=' + quote(str(pagination)), timeout=60).content) responses += results['delegation_responses'] pagination = results['pagination']['next_key'] return responses @@ -232,12 +232,12 @@ def query_redelegation_by_address(self, address): endpoint = '/cosmos/staking/v1beta1/delegators/' responses = [] try: - results = json.loads(requests.get(self.lcd + endpoint + address + '/redelegations').content) + results = json.loads(requests.get(self.lcd + endpoint + address + '/redelegations', timeout=60).content) responses += results['redelegation_responses'] pagination = results['pagination']['next_key'] while pagination is not None: results = json.loads(requests.get( - self.lcd + endpoint + address + '/redelegations?pagination.key=' + quote(str(pagination))).content) + self.lcd + endpoint + address + '/redelegations?pagination.key=' + quote(str(pagination)), timeout=60).content) responses += results['delegation_responses'] pagination = results['pagination']['next_key'] return responses @@ -249,13 +249,13 @@ def query_unbonding_by_address(self, address): endpoint = '/cosmos/staking/v1beta1/delegators/' responses = [] try: - results = json.loads(requests.get(self.lcd + endpoint + address + '/unbonding_delegations').content) + results = json.loads(requests.get(self.lcd + endpoint + address + '/unbonding_delegations', timeout=60).content) responses += results['unbonding_responses'] pagination = results['pagination']['next_key'] while pagination is not None: results = json.loads(requests.get( self.lcd + endpoint + address + '/unbonding_delegations?pagination.key=' + quote( - str(pagination))).content) + str(pagination)), timeout=60).content) responses += results['unbonding_responses'] pagination = results['pagination']['next_key'] return responses @@ -267,12 +267,12 @@ def query_delegator_data(self, address): endpoint = '/cosmos/staking/v1beta1/delegators/' responses = [] try: - results = json.loads(requests.get(self.lcd + endpoint + address + '/validators').content) + results = json.loads(requests.get(self.lcd + endpoint + address + '/validators', timeout=60).content) responses += results['validators'] pagination = results['pagination']['next_key'] while pagination is not None: results = json.loads(requests.get( - self.lcd + endpoint + address + '/validators?pagination.key=' + quote(str(pagination))).content) + self.lcd + endpoint + address + '/validators?pagination.key=' + quote(str(pagination)), timeout=60).content) responses += results['validators'] pagination = results['pagination']['next_key'] return responses @@ -283,7 +283,7 @@ def query_delegator_data(self, address): def query_delegator_data_by_validator(self, address, validator): endpoint = '/cosmos/staking/v1beta1/delegators/' try: - return json.loads(requests.get(self.lcd + endpoint + address + '/validators/' + validator).content) + return json.loads(requests.get(self.lcd + endpoint + address + '/validators/' + validator, timeout=60).content) except Exception: raise Exception @@ -291,7 +291,7 @@ def query_delegator_data_by_validator(self, address, validator): def query_staking_params(self): endpoint = '/cosmos/staking/v1beta1/params' try: - return json.loads(requests.get(self.lcd + endpoint).content) + return json.loads(requests.get(self.lcd + endpoint, timeout=60).content) except Exception: raise Exception @@ -299,7 +299,7 @@ def query_staking_params(self): def query_staking_pool(self): endpoint = '/cosmos/staking/v1beta1/pool' try: - return json.loads(requests.get(self.lcd + endpoint).content) + return json.loads(requests.get(self.lcd + endpoint, timeout=60).content) except Exception: raise Exception @@ -308,12 +308,12 @@ def query_all_validators(self): endpoint = '/cosmos/staking/v1beta1/validators' responses = [] try: - results = json.loads(requests.get(self.lcd + endpoint).content) + results = json.loads(requests.get(self.lcd + endpoint, timeout=60).content) responses += results['validators'] pagination = results['pagination']['next_key'] while pagination is not None: results = json.loads( - requests.get(self.lcd + endpoint + '?pagination.key=' + quote(str(pagination))).content) + requests.get(self.lcd + endpoint + '?pagination.key=' + quote(str(pagination)), timeout=60).content) responses += results['validators'] pagination = results['pagination']['next_key'] return responses @@ -324,7 +324,7 @@ def query_all_validators(self): def query_validator_by_address(self, address): endpoint = '/cosmos/staking/v1beta1/validators/' try: - return json.loads(requests.get(self.lcd + endpoint + address).content) + return json.loads(requests.get(self.lcd + endpoint + address, timeout=60).content) except Exception: raise Exception @@ -333,12 +333,12 @@ def query_delegators(self, validator): endpoint = '/cosmos/staking/v1beta1/validators/' responses = [] try: - results = json.loads(requests.get(self.lcd + endpoint + validator + '/delegations').content) + results = json.loads(requests.get(self.lcd + endpoint + validator + '/delegations', timeout=60).content) responses += results['delegation_responses'] pagination = results['pagination']['next_key'] while pagination is not None: results = json.loads(requests.get( - self.lcd + endpoint + validator + '/delegations?pagination.key=' + quote(str(pagination))).content) + self.lcd + endpoint + validator + '/delegations?pagination.key=' + quote(str(pagination)), timeout=60).content) responses += results['delegation_responses'] pagination = results['pagination']['next_key'] return responses @@ -349,7 +349,7 @@ def query_delegators(self, validator): def query_delegators_by_address(self, validator, address): endpoint = '/cosmos/staking/v1beta1/validators/' try: - return json.loads(requests.get(self.lcd + endpoint + validator + '/delegations/' + address).content) + return json.loads(requests.get(self.lcd + endpoint + validator + '/delegations/' + address, timeout=60).content) except Exception: raise Exception @@ -358,7 +358,7 @@ def query_validator_unbonding_by_address(self, validator, address): endpoint = '/cosmos/staking/v1beta1/validators/' try: return json.loads(requests.get( - self.lcd + endpoint + validator + '/delegations/' + address + '/unbonding_delegation').content) + self.lcd + endpoint + validator + '/delegations/' + address + '/unbonding_delegation', timeout=60).content) except Exception: raise Exception @@ -367,13 +367,13 @@ def query_unbonding_from(self, validator): endpoint = '/cosmos/staking/v1beta1/validators/' responses = [] try: - results = json.loads(requests.get(self.lcd + endpoint + validator + '/unbonding_delegations').content) + results = json.loads(requests.get(self.lcd + endpoint + validator + '/unbonding_delegations', timeout=60).content) responses += results['unbonding_responses'] pagination = results['pagination']['next_key'] while pagination is not None: results = json.loads(requests.get( self.lcd + endpoint + validator + '/unbonding_delegations?pagination.key=' + quote( - str(pagination))).content) + str(pagination)), timeout=60).content) responses += results['unbonding_responses'] pagination = results['pagination']['next_key'] return responses @@ -384,7 +384,7 @@ def query_unbonding_from(self, validator): def query_mint_params(self): endpoint = '/cosmos/mint/v1beta1/params' try: - return json.loads(requests.get(self.lcd + endpoint).content) + return json.loads(requests.get(self.lcd + endpoint, timeout=60).content) except Exception: raise Exception @@ -392,7 +392,7 @@ def query_mint_params(self): def query_inflation(self): endpoint = '/cosmos/mint/v1beta1/inflation' try: - return json.loads(requests.get(self.lcd + endpoint).content) + return json.loads(requests.get(self.lcd + endpoint, timeout=60).content) except Exception: raise Exception @@ -400,7 +400,7 @@ def query_inflation(self): def query_annual_provisions(self): endpoint = '/cosmos/mint/v1beta1/annual_provisions' try: - return json.loads(requests.get(self.lcd + endpoint).content) + return json.loads(requests.get(self.lcd + endpoint, timeout=60).content) except Exception: raise Exception @@ -408,7 +408,7 @@ def query_annual_provisions(self): def query_tx(self, tx): endpoint = '/cosmos/tx/v1beta1/txs/' try: - return json.loads(requests.get(self.lcd + endpoint + tx).content) + return json.loads(requests.get(self.lcd + endpoint + tx, timeout=60).content) except Exception: raise Exception @@ -416,7 +416,7 @@ def query_tx(self, tx): def query_abci_info(self): endpoint = '/abci_info?' try: - return json.loads(requests.get(self.rpc + endpoint).content) + return json.loads(requests.get(self.rpc + endpoint, timeout=60).content) except Exception: raise Exception @@ -424,7 +424,7 @@ def query_abci_info(self): def query_block(self, height): endpoint = '/block?height=' try: - return json.loads(requests.get(self.rpc + endpoint + str(height)).content) + return json.loads(requests.get(self.rpc + endpoint + str(height), timeout=60).content) except Exception: raise Exception @@ -432,7 +432,7 @@ def query_block(self, height): def query_block_results(self, height): endpoint = '/block_results?height=' try: - return json.loads(requests.get(self.rpc + endpoint + str(height)).content) + return json.loads(requests.get(self.rpc + endpoint + str(height), timeout=60).content) except Exception: raise Exception @@ -440,7 +440,7 @@ def query_block_results(self, height): def query_commit(self, height): endpoint = '/commit?height=' try: - return json.loads(requests.get(self.rpc + endpoint + height).content) + return json.loads(requests.get(self.rpc + endpoint + height, timeout=60).content) except Exception: raise Exception @@ -448,7 +448,7 @@ def query_commit(self, height): def query_consensus_state(self): endpoint = '/consensus_state?' try: - return json.loads(requests.get(self.rpc + endpoint).content) + return json.loads(requests.get(self.rpc + endpoint, timeout=60).content) except Exception: raise Exception @@ -456,7 +456,7 @@ def query_consensus_state(self): def query_dump_consensus_state(self): endpoint = '/dump_consensus_state?' try: - return json.loads(requests.get(self.rpc + endpoint).content) + return json.loads(requests.get(self.rpc + endpoint, timeout=60).content) except Exception: raise Exception @@ -464,7 +464,7 @@ def query_dump_consensus_state(self): def query_genesis(self): endpoint = '/genesis?' try: - return json.loads(requests.get(self.rpc + endpoint).content) + return json.loads(requests.get(self.rpc + endpoint, timeout=60).content) except Exception: raise Exception @@ -472,7 +472,7 @@ def query_genesis(self): def query_net_info(self): endpoint = '/net_info?' try: - return json.loads(requests.get(self.rpc + endpoint).content) + return json.loads(requests.get(self.rpc + endpoint, timeout=60).content) except Exception: raise Exception @@ -480,7 +480,7 @@ def query_net_info(self): def query_num_unconfirmed_txs(self): endpoint = '/num_unconfirmed_txs?' try: - return json.loads(requests.get(self.rpc + endpoint).content) + return json.loads(requests.get(self.rpc + endpoint, timeout=60).content) except Exception: raise Exception @@ -488,6 +488,6 @@ def query_num_unconfirmed_txs(self): def query_status(self): endpoint = '/status?' try: - return json.loads(requests.get(self.rpc + endpoint).content) + return json.loads(requests.get(self.rpc + endpoint, timeout=60).content) except Exception: raise Exception