From 65ca3f3450d0067668111f6e13cc3089768c9efe Mon Sep 17 00:00:00 2001
From: metamuffin <metamuffin@disroot.org>
Date: Thu, 5 Feb 2026 20:31:55 +0100
Subject: remove read/write distinction for kv transactions; traitify database

---
 import/src/plugins/acoustid.rs   | 2 +-
 import/src/plugins/infojson.rs   | 4 ++--
 import/src/plugins/media_info.rs | 2 +-
 import/src/plugins/misc.rs       | 2 +-
 4 files changed, 5 insertions(+), 5 deletions(-)

(limited to 'import/src/plugins')

diff --git a/import/src/plugins/acoustid.rs b/import/src/plugins/acoustid.rs
index 0e16670..c184468 100644
--- a/import/src/plugins/acoustid.rs
+++ b/import/src/plugins/acoustid.rs
@@ -186,7 +186,7 @@ impl ImportPlugin for AcoustID {
         let fp = acoustid_fingerprint(&ct.dba.cache, path)?;
 
         if let Some((atid, mbid)) = self.get_atid_mbid(&ct.dba.cache, &fp, &ct.rt)? {
-            ct.dba.db.write_transaction(&mut |txn| {
+            ct.dba.db.transaction(&mut |txn| {
                 let ob = ct.dba.nodes.get(txn, node)?.unwrap();
                 let ob = ob.as_object();
                 let ob = ob.insert(
diff --git a/import/src/plugins/infojson.rs b/import/src/plugins/infojson.rs
index 3426679..e03a5f7 100644
--- a/import/src/plugins/infojson.rs
+++ b/import/src/plugins/infojson.rs
@@ -175,7 +175,7 @@ impl ImportPlugin for Infojson {
         let data = serde_json::from_reader::<_, YVideo>(BufReader::new(File::open(path)?))?;
         let title = clean_uploader_name(&data.title);
 
-        ct.dba.db.write_transaction(&mut |txn| {
+        ct.dba.db.transaction(&mut |txn| {
             let mut node = ct.dba.nodes.get(txn, parent)?.unwrap();
             node = node.as_object().insert(NO_KIND, KIND_CHANNEL);
             node = node.as_object().insert(NO_TITLE, title);
@@ -236,7 +236,7 @@ impl ImportPlugin for Infojson {
                 KIND_VIDEO
             };
 
-            ct.dba.db.write_transaction(&mut |txn| {
+            ct.dba.db.transaction(&mut |txn| {
                 let mut node = ct.dba.nodes.get(txn, row)?.unwrap();
                 node = node.as_object().insert(NO_KIND, kind);
                 node = node.as_object().insert(NO_TITLE, &infojson.title);
diff --git a/import/src/plugins/media_info.rs b/import/src/plugins/media_info.rs
index 9b79efa..f1f56bb 100644
--- a/import/src/plugins/media_info.rs
+++ b/import/src/plugins/media_info.rs
@@ -25,7 +25,7 @@ impl ImportPlugin for MediaInfo {
     }
     fn media(&self, ct: &PluginContext, row: RowNum, path: &Path, seg: &Segment) -> Result<()> {
         let size = path.metadata()?.len();
-        ct.dba.db.write_transaction(&mut |txn| {
+        ct.dba.db.transaction(&mut |txn| {
             let mut node = ct.dba.nodes.get(txn, row)?.unwrap();
             if let Some(tracks) = &seg.tracks {
                 node = node.as_object().extend_object(
diff --git a/import/src/plugins/misc.rs b/import/src/plugins/misc.rs
index 554f473..6a8caa6 100644
--- a/import/src/plugins/misc.rs
+++ b/import/src/plugins/misc.rs
@@ -42,7 +42,7 @@ impl ImportPlugin for ImageFiles {
                 Ok(data)
             },
         )?;
-        ct.dba.db.write_transaction(&mut |txn| {
+        ct.dba.db.transaction(&mut |txn| {
             let mut node = ct.dba.nodes.get(txn, row)?.unwrap();
             node = node
                 .as_object()
-- 
cgit v1.3