github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-09 23:38:10 -05:00
Code Issues Packages Projects Releases Wiki Activity

add with_tx_mut method on DatabaseProvider

Browse Source
This commit is contained in:
Dan Cline
2024-02-14 17:18:38 -05:00
parent c12d59f48f
commit bd5e86e124
1 changed files with 26 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
crates/storage/provider/src/providers/database/provider.rs
View File

@@ -84,13 +84,7 @@ where
chain_spec: Arc<ChainSpec>,
snapshot_provider: &Option<Arc<SnapshotProvider>>,
) -> ProviderResult<DatabaseProviderRW<DB>> {
let mut provider = DatabaseProvider::new_rw(tx, chain_spec.clone());
if let Some(snapshot_provider) = snapshot_provider {
provider = provider.with_snapshot_provider(snapshot_provider.clone());
}
Ok(DatabaseProviderRW(provider))
DatabaseProvider::with_tx_mut(tx, chain_spec, snapshot_provider).map(DatabaseProviderRW)
}
/// Takes a function and passes a read-write transaction into it, making sure it's committed at
@@ -145,11 +139,36 @@ pub struct DatabaseProvider<TX> {
snapshot_provider: Option<Arc<SnapshotProvider>>,
}
impl<TX> DatabaseProvider<TX> {
/// Creates a new [`Self`] with access to a [`SnapshotProvider`].
pub fn with_snapshot_provider(mut self, snapshot_provider: Arc<SnapshotProvider>) -> Self {
self.snapshot_provider = Some(snapshot_provider);
self
}
}
impl<TX: DbTxMut> DatabaseProvider<TX> {
/// Creates a provider with an inner read-write transaction.
pub fn new_rw(tx: TX, chain_spec: Arc<ChainSpec>) -> Self {
Self { tx, chain_spec, snapshot_provider: None }
}
/// Returns a provider with the given `DbTxMut` inside, which allows fetching and updating
/// data from the database using different types of providers.
#[track_caller]
pub fn with_tx_mut(
tx: TX,
chain_spec: Arc<ChainSpec>,
snapshot_provider: &Option<Arc<SnapshotProvider>>,
) -> ProviderResult<DatabaseProvider<TX>> {
let mut provider = DatabaseProvider::new_rw(tx, chain_spec.clone());
if let Some(snapshot_provider) = snapshot_provider {
provider = provider.with_snapshot_provider(snapshot_provider.clone());
}
Ok(provider)
}
}
impl<TX: DbTx> DatabaseProvider<TX> {
@@ -254,12 +273,6 @@ impl<TX: DbTx> DatabaseProvider<TX> {
Self { tx, chain_spec, snapshot_provider: None }
}
/// Creates a new [`Self`] with access to a [`SnapshotProvider`].
pub fn with_snapshot_provider(mut self, snapshot_provider: Arc<SnapshotProvider>) -> Self {
self.snapshot_provider = Some(snapshot_provider);
self
}
/// Consume `DbTx` or `DbTxMut`.
pub fn into_tx(self) -> TX {
self.tx