Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Fix clippy::needless_lifetimes warnings throughout stackslib #5638

Merged
merged 1 commit into from
Jan 3, 2025
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion stackslib/src/burnchains/bitcoin/bits.rs
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ use crate::chainstate::stacks::{
};

/// Parse a script into its structured constituant opcodes and data and collect them
pub fn parse_script<'a>(script: &'a Script) -> Vec<Instruction<'a>> {
pub fn parse_script(script: &Script) -> Vec<Instruction<'_>> {
// we will have to accept non-minimial pushdata since there's at least one OP_RETURN
// in the transaction stream that has this property already.
script.iter(false).collect()
Expand Down
8 changes: 4 additions & 4 deletions stackslib/src/burnchains/bitcoin/spv.rs
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,7 @@ impl FromColumn<Sha256dHash> for Sha256dHash {
}

impl FromRow<BlockHeader> for BlockHeader {
fn from_row<'a>(row: &'a Row) -> Result<BlockHeader, db_error> {
fn from_row(row: &Row) -> Result<BlockHeader, db_error> {
let version: u32 = row.get_unwrap("version");
let prev_blockhash: Sha256dHash = Sha256dHash::from_column(row, "prev_blockhash")?;
let merkle_root: Sha256dHash = Sha256dHash::from_column(row, "merkle_root")?;
Expand Down Expand Up @@ -225,7 +225,7 @@ impl SpvClient {
&mut self.headers_db
}

pub fn tx_begin<'a>(&'a mut self) -> Result<DBTx<'a>, btc_error> {
pub fn tx_begin(&mut self) -> Result<DBTx<'_>, btc_error> {
if !self.readwrite {
return Err(db_error::ReadOnly.into());
}
Expand Down Expand Up @@ -741,8 +741,8 @@ impl SpvClient {
}

/// Insert a block header
fn insert_block_header<'a>(
tx: &mut DBTx<'a>,
fn insert_block_header(
tx: &mut DBTx<'_>,
header: BlockHeader,
height: u64,
) -> Result<(), btc_error> {
Expand Down
10 changes: 5 additions & 5 deletions stackslib/src/burnchains/db.rs
Original file line number Diff line number Diff line change
Expand Up @@ -84,21 +84,21 @@ pub struct BlockCommitMetadata {
}

impl FromColumn<AffirmationMap> for AffirmationMap {
fn from_column<'a>(row: &'a Row, col_name: &str) -> Result<AffirmationMap, DBError> {
fn from_column(row: &Row, col_name: &str) -> Result<AffirmationMap, DBError> {
let txt: String = row.get_unwrap(col_name);
let am = AffirmationMap::decode(&txt).ok_or(DBError::ParseError)?;
Ok(am)
}
}

impl FromRow<AffirmationMap> for AffirmationMap {
fn from_row<'a>(row: &'a Row) -> Result<AffirmationMap, DBError> {
fn from_row(row: &Row) -> Result<AffirmationMap, DBError> {
AffirmationMap::from_column(row, "affirmation_map")
}
}

impl FromRow<BlockCommitMetadata> for BlockCommitMetadata {
fn from_row<'a>(row: &'a Row) -> Result<BlockCommitMetadata, DBError> {
fn from_row(row: &Row) -> Result<BlockCommitMetadata, DBError> {
let burn_block_hash = BurnchainHeaderHash::from_column(row, "burn_block_hash")?;
let txid = Txid::from_column(row, "txid")?;
let block_height = u64::from_column(row, "block_height")?;
Expand Down Expand Up @@ -312,7 +312,7 @@ const BURNCHAIN_DB_INDEXES: &'static [&'static str] = &[
"CREATE INDEX IF NOT EXISTS index_block_commit_metadata_burn_block_hash_anchor_block ON block_commit_metadata(burn_block_hash,anchor_block);",
];

impl<'a> BurnchainDBTransaction<'a> {
impl BurnchainDBTransaction<'_> {
/// Store a burnchain block header into the burnchain database.
/// Returns the row ID on success.
pub(crate) fn store_burnchain_db_entry(
Expand Down Expand Up @@ -1104,7 +1104,7 @@ impl BurnchainDB {
&self.conn
}

pub fn tx_begin<'a>(&'a mut self) -> Result<BurnchainDBTransaction<'a>, BurnchainError> {
pub fn tx_begin(&mut self) -> Result<BurnchainDBTransaction<'_>, BurnchainError> {
let sql_tx = tx_begin_immediate(&mut self.conn)?;
Ok(BurnchainDBTransaction { sql_tx: sql_tx })
}
Expand Down
6 changes: 2 additions & 4 deletions stackslib/src/burnchains/tests/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -644,7 +644,6 @@ impl TestBurnchainBlock {
}

pub fn mine_pox<
'a,
T: BlockEventDispatcher,
N: CoordinatorNotices,
R: RewardSetProvider,
Expand All @@ -655,7 +654,7 @@ impl TestBurnchainBlock {
&self,
db: &mut SortitionDB,
burnchain: &Burnchain,
coord: &mut ChainsCoordinator<'a, T, N, R, CE, FE, B>,
coord: &mut ChainsCoordinator<'_, T, N, R, CE, FE, B>,
) -> BlockSnapshot {
let mut indexer = BitcoinIndexer::new_unit_test(&burnchain.working_dir);
let parent_hdr = indexer
Expand Down Expand Up @@ -783,7 +782,6 @@ impl TestBurnchainFork {
}

pub fn mine_pending_blocks_pox<
'a,
T: BlockEventDispatcher,
N: CoordinatorNotices,
R: RewardSetProvider,
Expand All @@ -794,7 +792,7 @@ impl TestBurnchainFork {
&mut self,
db: &mut SortitionDB,
burnchain: &Burnchain,
coord: &mut ChainsCoordinator<'a, T, N, R, CE, FE, B>,
coord: &mut ChainsCoordinator<'_, T, N, R, CE, FE, B>,
) -> BlockSnapshot {
let mut snapshot = {
let ic = db.index_conn();
Expand Down
10 changes: 5 additions & 5 deletions stackslib/src/chainstate/burn/db/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ impl_byte_array_from_column_only!(TrieHash);
impl_byte_array_from_column_only!(MessageSignature);

impl FromColumn<VRFPublicKey> for VRFPublicKey {
fn from_column<'a>(row: &'a Row, column_name: &str) -> Result<VRFPublicKey, db_error> {
fn from_column(row: &Row, column_name: &str) -> Result<VRFPublicKey, db_error> {
let pubkey_hex: String = row.get_unwrap(column_name);
match VRFPublicKey::from_hex(&pubkey_hex) {
Some(pubk) => Ok(pubk),
Expand All @@ -63,7 +63,7 @@ impl FromColumn<VRFPublicKey> for VRFPublicKey {
}

impl FromColumn<StacksAddress> for StacksAddress {
fn from_column<'a>(row: &'a Row, column_name: &str) -> Result<Self, db_error> {
fn from_column(row: &Row, column_name: &str) -> Result<Self, db_error> {
let address_str: String = row.get_unwrap(column_name);
match Self::from_string(&address_str) {
Some(a) => Ok(a),
Expand All @@ -73,14 +73,14 @@ impl FromColumn<StacksAddress> for StacksAddress {
}

impl FromColumn<PrincipalData> for PrincipalData {
fn from_column<'a>(row: &'a Row, column_name: &str) -> Result<Self, db_error> {
fn from_column(row: &Row, column_name: &str) -> Result<Self, db_error> {
let address_str: String = row.get_unwrap(column_name);
Self::parse(&address_str).map_err(|_| db_error::ParseError)
}
}

impl FromColumn<PoxAddress> for PoxAddress {
fn from_column<'a>(row: &'a Row, column_name: &str) -> Result<Self, db_error> {
fn from_column(row: &Row, column_name: &str) -> Result<Self, db_error> {
let address_str: String = row.get_unwrap(column_name);
match Self::from_db_string(&address_str) {
Some(a) => Ok(a),
Expand All @@ -90,7 +90,7 @@ impl FromColumn<PoxAddress> for PoxAddress {
}

impl FromColumn<BitcoinAddress> for BitcoinAddress {
fn from_column<'a>(row: &'a Row, column_name: &str) -> Result<Self, db_error> {
fn from_column(row: &Row, column_name: &str) -> Result<Self, db_error> {
let address_str: String = row.get_unwrap(column_name);
match Self::from_string(&address_str) {
Some(a) => Ok(a),
Expand Down
2 changes: 1 addition & 1 deletion stackslib/src/chainstate/burn/db/processing.rs
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ use crate::chainstate::stacks::index::{Error as MARFError, MARFValue, MarfTrieId
use crate::core::INITIAL_MINING_BONUS_WINDOW;
use crate::util_lib::db::Error as DBError;

impl<'a> SortitionHandleTx<'a> {
impl SortitionHandleTx<'_> {
/// Run a blockstack operation's "check()" method and return the result.
fn check_transaction(
&mut self,
Expand Down
54 changes: 27 additions & 27 deletions stackslib/src/chainstate/burn/db/sortdb.rs
Original file line number Diff line number Diff line change
Expand Up @@ -96,25 +96,25 @@ pub const REWARD_WINDOW_END: u64 = 144 * 90 + REWARD_WINDOW_START;
pub type BlockHeaderCache = HashMap<ConsensusHash, (Option<BlockHeaderHash>, ConsensusHash)>;

impl FromRow<SortitionId> for SortitionId {
fn from_row<'a>(row: &'a Row) -> Result<SortitionId, db_error> {
fn from_row(row: &Row) -> Result<SortitionId, db_error> {
SortitionId::from_column(row, "sortition_id")
}
}

impl FromRow<ConsensusHash> for ConsensusHash {
fn from_row<'a>(row: &'a Row) -> Result<ConsensusHash, db_error> {
fn from_row(row: &Row) -> Result<ConsensusHash, db_error> {
ConsensusHash::from_column(row, "consensus_hash")
}
}

impl FromRow<BurnchainHeaderHash> for BurnchainHeaderHash {
fn from_row<'a>(row: &'a Row) -> Result<BurnchainHeaderHash, db_error> {
fn from_row(row: &Row) -> Result<BurnchainHeaderHash, db_error> {
BurnchainHeaderHash::from_column(row, "burn_header_hash")
}
}

impl FromRow<MissedBlockCommit> for MissedBlockCommit {
fn from_row<'a>(row: &'a Row) -> Result<MissedBlockCommit, db_error> {
fn from_row(row: &Row) -> Result<MissedBlockCommit, db_error> {
let intended_sortition = SortitionId::from_column(row, "intended_sortition_id")?;
let input_json: String = row.get_unwrap("input");
let input =
Expand All @@ -130,7 +130,7 @@ impl FromRow<MissedBlockCommit> for MissedBlockCommit {
}

impl FromRow<BlockSnapshot> for BlockSnapshot {
fn from_row<'a>(row: &'a Row) -> Result<BlockSnapshot, db_error> {
fn from_row(row: &Row) -> Result<BlockSnapshot, db_error> {
let block_height = u64::from_column(row, "block_height")?;
let burn_header_hash = BurnchainHeaderHash::from_column(row, "burn_header_hash")?;
let burn_header_timestamp = u64::from_column(row, "burn_header_timestamp")?;
Expand Down Expand Up @@ -211,7 +211,7 @@ impl FromRow<BlockSnapshot> for BlockSnapshot {
}

impl FromRow<LeaderKeyRegisterOp> for LeaderKeyRegisterOp {
fn from_row<'a>(row: &'a Row) -> Result<LeaderKeyRegisterOp, db_error> {
fn from_row(row: &Row) -> Result<LeaderKeyRegisterOp, db_error> {
let txid = Txid::from_column(row, "txid")?;
let vtxindex: u32 = row.get_unwrap("vtxindex");
let block_height = u64::from_column(row, "block_height")?;
Expand Down Expand Up @@ -240,7 +240,7 @@ impl FromRow<LeaderKeyRegisterOp> for LeaderKeyRegisterOp {
}

impl FromRow<LeaderBlockCommitOp> for LeaderBlockCommitOp {
fn from_row<'a>(row: &'a Row) -> Result<LeaderBlockCommitOp, db_error> {
fn from_row(row: &Row) -> Result<LeaderBlockCommitOp, db_error> {
let txid = Txid::from_column(row, "txid")?;
let vtxindex: u32 = row.get_unwrap("vtxindex");
let block_height = u64::from_column(row, "block_height")?;
Expand Down Expand Up @@ -314,7 +314,7 @@ impl FromRow<LeaderBlockCommitOp> for LeaderBlockCommitOp {
}

impl FromRow<StackStxOp> for StackStxOp {
fn from_row<'a>(row: &'a Row) -> Result<StackStxOp, db_error> {
fn from_row(row: &Row) -> Result<StackStxOp, db_error> {
let txid = Txid::from_column(row, "txid")?;
let vtxindex: u32 = row.get_unwrap("vtxindex");
let block_height = u64::from_column(row, "block_height")?;
Expand Down Expand Up @@ -357,7 +357,7 @@ impl FromRow<StackStxOp> for StackStxOp {
}

impl FromRow<DelegateStxOp> for DelegateStxOp {
fn from_row<'a>(row: &'a Row) -> Result<DelegateStxOp, db_error> {
fn from_row(row: &Row) -> Result<DelegateStxOp, db_error> {
let txid = Txid::from_column(row, "txid")?;
let vtxindex: u32 = row.get_unwrap("vtxindex");
let block_height = u64::from_column(row, "block_height")?;
Expand Down Expand Up @@ -389,7 +389,7 @@ impl FromRow<DelegateStxOp> for DelegateStxOp {
}

impl FromRow<TransferStxOp> for TransferStxOp {
fn from_row<'a>(row: &'a Row) -> Result<TransferStxOp, db_error> {
fn from_row(row: &Row) -> Result<TransferStxOp, db_error> {
let txid = Txid::from_column(row, "txid")?;
let vtxindex: u32 = row.get_unwrap("vtxindex");
let block_height = u64::from_column(row, "block_height")?;
Expand Down Expand Up @@ -417,7 +417,7 @@ impl FromRow<TransferStxOp> for TransferStxOp {
}

impl FromRow<VoteForAggregateKeyOp> for VoteForAggregateKeyOp {
fn from_row<'a>(row: &'a Row) -> Result<VoteForAggregateKeyOp, db_error> {
fn from_row(row: &Row) -> Result<VoteForAggregateKeyOp, db_error> {
let txid = Txid::from_column(row, "txid")?;
let vtxindex: u32 = row.get_unwrap("vtxindex");
let block_height = u64::from_column(row, "block_height")?;
Expand Down Expand Up @@ -450,15 +450,15 @@ impl FromRow<VoteForAggregateKeyOp> for VoteForAggregateKeyOp {
}

impl FromColumn<ASTRules> for ASTRules {
fn from_column<'a>(row: &'a Row, column_name: &str) -> Result<ASTRules, db_error> {
fn from_column(row: &Row, column_name: &str) -> Result<ASTRules, db_error> {
let x: u8 = row.get_unwrap(column_name);
let ast_rules = ASTRules::from_u8(x).ok_or(db_error::ParseError)?;
Ok(ast_rules)
}
}

impl FromRow<(ASTRules, u64)> for (ASTRules, u64) {
fn from_row<'a>(row: &'a Row) -> Result<(ASTRules, u64), db_error> {
fn from_row(row: &Row) -> Result<(ASTRules, u64), db_error> {
let ast_rules = ASTRules::from_column(row, "ast_rule_id")?;
let height = u64::from_column(row, "block_height")?;
Ok((ast_rules, height))
Expand All @@ -479,7 +479,7 @@ pub struct InitialMiningBonus {
}

impl FromRow<AcceptedStacksBlockHeader> for AcceptedStacksBlockHeader {
fn from_row<'a>(row: &'a Row) -> Result<AcceptedStacksBlockHeader, db_error> {
fn from_row(row: &Row) -> Result<AcceptedStacksBlockHeader, db_error> {
let tip_consensus_hash = ConsensusHash::from_column(row, "tip_consensus_hash")?;
let consensus_hash = ConsensusHash::from_column(row, "consensus_hash")?;
let block_hash = BlockHeaderHash::from_column(row, "stacks_block_hash")?;
Expand All @@ -495,7 +495,7 @@ impl FromRow<AcceptedStacksBlockHeader> for AcceptedStacksBlockHeader {
}

impl FromRow<StacksEpoch> for StacksEpoch {
fn from_row<'a>(row: &'a Row) -> Result<StacksEpoch, db_error> {
fn from_row(row: &Row) -> Result<StacksEpoch, db_error> {
let epoch_id_u32: u32 = row.get_unwrap("epoch_id");
let epoch_id = StacksEpochId::try_from(epoch_id_u32).map_err(|_| db_error::ParseError)?;

Expand Down Expand Up @@ -1533,7 +1533,7 @@ impl SortitionHandle for SortitionHandleConn<'_> {
}
}

impl<'a> SortitionHandleTx<'a> {
impl SortitionHandleTx<'_> {
pub fn set_stacks_block_accepted(
&mut self,
consensus_hash: &ConsensusHash,
Expand Down Expand Up @@ -2646,7 +2646,7 @@ impl<'a> SortitionHandleConn<'a> {
// Connection methods
impl SortitionDB {
/// Begin a transaction.
pub fn tx_begin<'a>(&'a mut self) -> Result<SortitionDBTx<'a>, db_error> {
pub fn tx_begin(&mut self) -> Result<SortitionDBTx<'_>, db_error> {
if !self.readwrite {
return Err(db_error::ReadOnly);
}
Expand All @@ -2663,7 +2663,7 @@ impl SortitionDB {
}

/// Make an indexed connection
pub fn index_conn<'a>(&'a self) -> SortitionDBConn<'a> {
pub fn index_conn(&self) -> SortitionDBConn<'_> {
SortitionDBConn::new(
&self.marf,
SortitionDBTxContext {
Expand Down Expand Up @@ -2739,7 +2739,7 @@ impl SortitionDB {
))
}

pub fn conn<'a>(&'a self) -> &'a Connection {
pub fn conn(&self) -> &Connection {
self.marf.sqlite_conn()
}

Expand Down Expand Up @@ -3556,8 +3556,8 @@ impl SortitionDB {
}

#[cfg(any(test, feature = "testing"))]
pub fn override_ast_rule_height<'a>(
tx: &mut DBTx<'a>,
pub fn override_ast_rule_height(
tx: &mut DBTx<'_>,
ast_rules: ASTRules,
height: u64,
) -> Result<(), db_error> {
Expand Down Expand Up @@ -3699,7 +3699,7 @@ impl SortitionDB {
}
}

impl<'a> SortitionDBTx<'a> {
impl SortitionDBTx<'_> {
pub fn find_sortition_tip_affirmation_map(
&mut self,
chain_tip: &SortitionId,
Expand All @@ -3720,7 +3720,7 @@ impl<'a> SortitionDBTx<'a> {
}
}

impl<'a> SortitionDBConn<'a> {
impl SortitionDBConn<'_> {
pub fn as_handle<'b>(&'b self, chain_tip: &SortitionId) -> SortitionHandleConn<'b> {
SortitionHandleConn {
index: self.index,
Expand Down Expand Up @@ -4719,7 +4719,7 @@ impl SortitionDB {
}

/// DO NOT CALL during Stacks block processing (including during Clarity VM evaluation). This function returns the latest data known to the node, which may not have been at the time of original block assembly.
pub fn index_handle_at_tip<'a>(&'a self) -> SortitionHandleConn<'a> {
pub fn index_handle_at_tip(&self) -> SortitionHandleConn<'_> {
let sortition_id = SortitionDB::get_canonical_sortition_tip(self.conn()).unwrap();
self.index_handle(&sortition_id)
}
Expand All @@ -4737,7 +4737,7 @@ impl SortitionDB {

/// Open a tx handle at the burn chain tip
/// DO NOT CALL during Stacks block processing (including during Clarity VM evaluation). This function returns the latest data known to the node, which may not have been at the time of original block assembly.
pub fn tx_begin_at_tip<'a>(&'a mut self) -> SortitionHandleTx<'a> {
pub fn tx_begin_at_tip(&mut self) -> SortitionHandleTx<'_> {
let sortition_id = SortitionDB::get_canonical_sortition_tip(self.conn()).unwrap();
self.tx_handle_begin(&sortition_id).unwrap()
}
Expand Down Expand Up @@ -5394,7 +5394,7 @@ impl SortitionDB {
}
}

impl<'a> SortitionHandleTx<'a> {
impl SortitionHandleTx<'_> {
/// Append a snapshot to a chain tip, and update various chain tip statistics.
/// Returns the new state root of this fork.
/// `initialize_bonus` - if Some(..), then this snapshot is the first mined snapshot,
Expand Down Expand Up @@ -6608,7 +6608,7 @@ pub mod tests {
use crate::core::{StacksEpochExtension, *};
use crate::util_lib::db::Error as db_error;

impl<'a> SortitionHandleTx<'a> {
impl SortitionHandleTx<'_> {
/// Update the canonical Stacks tip (testing only)
pub fn test_update_canonical_stacks_tip(
&mut self,
Expand Down
Loading