diff options
Diffstat (limited to 'database/src/transaction.rs')
| -rw-r--r-- | database/src/transaction.rs | 42 |
1 files changed, 0 insertions, 42 deletions
diff --git a/database/src/transaction.rs b/database/src/transaction.rs deleted file mode 100644 index c0e89b7..0000000 --- a/database/src/transaction.rs +++ /dev/null @@ -1,42 +0,0 @@ -/* - This file is part of jellything (https://codeberg.org/metamuffin/jellything) - which is licensed under the GNU Affero General Public License (version 3); see /COPYING. - Copyright (C) 2025 metamuffin <metamuffin.org> -*/ - -use crate::backends::KV; -use anyhow::Result; -use std::sync::Arc; - -pub struct TransactionController { - db: Arc<dyn KV>, -} -impl TransactionController { - pub fn transact(&self, tx: impl Fn(&mut Transaction) -> Result<()>) -> Result<()> { - tx(&mut Transaction { - db: self.db.clone(), - })?; - Ok(()) - } -} - -pub struct Transaction { - db: Arc<dyn KV>, -} -impl KV for Transaction { - fn set(&self, key: &[u8], value: &[u8]) -> Result<()> { - self.db.set(key, value) - } - fn get(&self, key: &[u8]) -> Result<Option<Vec<u8>>> { - self.db.get(key) - } - fn del(&self, key: &[u8]) -> Result<()> { - self.db.del(key) - } - fn next(&self, key: &[u8]) -> Result<Option<Vec<u8>>> { - self.db.next(key) - } - fn prev(&self, key: &[u8]) -> Result<Option<Vec<u8>>> { - self.db.prev(key) - } -} |