aboutsummaryrefslogtreecommitdiff
path: root/database/src/transaction.rs
diff options
context:
space:
mode:
Diffstat (limited to 'database/src/transaction.rs')
-rw-r--r--database/src/transaction.rs42
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)
- }
-}