fix(indexeddb): Abort failed transactions (#27)

Cargo.toml

@@ -47,7 +47,7 @@ multihash-codetable = { version = "0.1.1", features = ["digest", "sha2"] }
 wasm-bindgen-test = "0.3.41"
 
 [features]
-indexeddb = ["dep:js-sys", "dep:rexie", "dep:wasm-bindgen"]
+indexeddb = ["dep:js-sys", "dep:rexie", "dep:wasm-bindgen", "dep:idb"]
 lru = ["dep:lru"]
 redb = ["dep:redb", "dep:tokio"]
 sled = ["dep:sled", "dep:tokio"]

src/indexed_db_blockstore.rs

@@ -73,12 +73,25 @@ impl Blockstore for IndexedDbBlockstore {
         let tx = self
             .db
             .transaction(&[BLOCK_STORE], TransactionMode::ReadWrite)?;
-        let blocks = tx.store(BLOCK_STORE)?;
 
-        if !has_key(&blocks, &cid).await? {
-            blocks.add(&data, Some(&cid)).await?;
+        let res = async {
+            let blocks = tx.store(BLOCK_STORE)?;
+
+            if !has_key(&blocks, &cid).await? {
+                blocks.add(&data, Some(&cid)).await?;
+            }
+
+            Ok(())
+        }
+        .await;
+
+        if res.is_ok() {
+            tx.commit().await?;
+        } else {
+            tx.abort().await?;
         }
-        Ok(())
+
+        res
     }
 
     async fn remove<const S: usize>(&self, cid: &CidGeneric<S>) -> Result<()> {
@@ -87,11 +100,21 @@ impl Blockstore for IndexedDbBlockstore {
         let tx = self
             .db
             .transaction(&[BLOCK_STORE], TransactionMode::ReadWrite)?;
-        let blocks = tx.store(BLOCK_STORE)?;
 
-        blocks.delete(cid.into()).await?;
+        let res = async {
+            let blocks = tx.store(BLOCK_STORE)?;
+            blocks.delete(cid.into()).await?;
+            Ok(())
+        }
+        .await;
+
+        if res.is_ok() {
+            tx.commit().await?;
+        } else {
+            tx.abort().await?;
+        }
 
-        Ok(())
+        res
     }
 
     async fn has<const S: usize>(&self, cid: &CidGeneric<S>) -> Result<bool> {