mirror of
https://github.com/serai-dex/serai.git
synced 2025-12-13 14:39:25 +00:00
ce3b90541e
coordinator/cosign/src/delay.rs literally demonstrates how we'd need to rewrite our handling of transactions with this change. It can be cleaned up a bit but already identifies ergonomic issues. It also doesn't model passing an &mut txn to an async function, which would also require using the droppable wrapper struct. To locally see this build, run RUSTFLAGS="-Zpanic_abort_tests -C panic=abort" cargo +nightly build -p serai-cosign --all-targets To locally see this fail to build, run cargo build -p serai-cosign --all-targets While it doesn't say which line causes it fail to build, the only distinction is panic=unwind. For more context, please see #578.
48 lines
1.2 KiB
Rust
48 lines
1.2 KiB
Rust
use std::sync::Arc;
|
|
|
|
pub use ::parity_db::{Options, Db as ParityDb};
|
|
|
|
use crate::*;
|
|
|
|
#[must_use]
|
|
pub struct Transaction<'a>(&'a Arc<ParityDb>, Vec<(u8, Vec<u8>, Option<Vec<u8>>)>);
|
|
|
|
impl Get for Transaction<'_> {
|
|
fn get(&self, key: impl AsRef<[u8]>) -> Option<Vec<u8>> {
|
|
let mut res = self.0.get(&key);
|
|
for change in &self.1 {
|
|
if change.1 == key.as_ref() {
|
|
res.clone_from(&change.2);
|
|
}
|
|
}
|
|
res
|
|
}
|
|
}
|
|
impl DbTxn for Transaction<'_> {
|
|
fn put(&mut self, key: impl AsRef<[u8]>, value: impl AsRef<[u8]>) {
|
|
self.1.push((0, key.as_ref().to_vec(), Some(value.as_ref().to_vec())))
|
|
}
|
|
fn del(&mut self, key: impl AsRef<[u8]>) {
|
|
self.1.push((0, key.as_ref().to_vec(), None))
|
|
}
|
|
fn commit(self) {
|
|
self.0.commit(self.1).unwrap()
|
|
}
|
|
}
|
|
|
|
impl Get for Arc<ParityDb> {
|
|
fn get(&self, key: impl AsRef<[u8]>) -> Option<Vec<u8>> {
|
|
ParityDb::get(self, 0, key.as_ref()).unwrap()
|
|
}
|
|
}
|
|
impl Db for Arc<ParityDb> {
|
|
type Transaction<'a> = Transaction<'a>;
|
|
fn unsafe_txn(&mut self) -> Self::Transaction<'_> {
|
|
Transaction(self, vec![])
|
|
}
|
|
}
|
|
|
|
pub fn new_parity_db(path: &str) -> Arc<ParityDb> {
|
|
Arc::new(ParityDb::open_or_create(&Options::with_columns(std::path::Path::new(path), 1)).unwrap())
|
|
}
|