Jędrzej Stuczyński
c92a7e3e35
globally updated sqlx to 0.6.3 wip basic processing loop wip starting on modules all of the requesting logic, catching up, etc remaining work includes persisting the data wip persisting block data initial and extremely basic nyxd block scraper
47 lines
1.8 KiB
Rust
47 lines
1.8 KiB
Rust
// Copyright 2023 - Nym Technologies SA <contact@nymtech.net>
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
use crate::block_processor::types::ParsedTransactionResponse;
|
|
use crate::constants::{BECH32_CONESNSUS_PUBKEY_PREFIX, BECH32_CONSENSUS_ADDRESS_PREFIX};
|
|
use crate::error::ScraperError;
|
|
use cosmrs::AccountId;
|
|
use sha2::{Digest, Sha256};
|
|
use tendermint::{account, PublicKey};
|
|
use tendermint::{validator, Hash};
|
|
use tendermint_rpc::endpoint::validators;
|
|
|
|
pub(crate) fn tx_hash<M: AsRef<[u8]>>(raw_tx: M) -> Hash {
|
|
Hash::Sha256(Sha256::digest(raw_tx).into())
|
|
}
|
|
|
|
pub(crate) fn validator_pubkey_to_bech32(pubkey: PublicKey) -> Result<AccountId, ScraperError> {
|
|
// TODO: this one seem to attach additional prefix to they pubkeys, is that what we want instead maybe?
|
|
// Ok(pubkey.to_bech32(BECH32_CONESNSUS_PUBKEY_PREFIX))
|
|
AccountId::new(BECH32_CONESNSUS_PUBKEY_PREFIX, &pubkey.to_bytes())
|
|
.map_err(|source| ScraperError::MalformedValidatorPubkey { source })
|
|
}
|
|
|
|
pub(crate) fn validator_consensus_address(id: account::Id) -> Result<AccountId, ScraperError> {
|
|
AccountId::new(BECH32_CONSENSUS_ADDRESS_PREFIX, id.as_ref())
|
|
.map_err(|source| ScraperError::MalformedValidatorAddress { source })
|
|
}
|
|
|
|
pub(crate) fn tx_gas_sum(txs: &[ParsedTransactionResponse]) -> i64 {
|
|
txs.iter().map(|tx| tx.tx_result.gas_used).sum()
|
|
}
|
|
|
|
pub(crate) fn validator_info(
|
|
id: account::Id,
|
|
validators: &validators::Response,
|
|
) -> Result<&validator::Info, ScraperError> {
|
|
match validators.validators.iter().find(|v| v.address == id) {
|
|
Some(info) => Ok(info),
|
|
None => {
|
|
let addr = validator_consensus_address(id)?;
|
|
Err(ScraperError::MissingValidatorInfoCommitted {
|
|
address: addr.to_string(),
|
|
})
|
|
}
|
|
}
|
|
}
|