diff --git a/lektor_nkdb/src/database/update.rs b/lektor_nkdb/src/database/update.rs index 8f16b4e2863c1f88b0a9385b0b701c9c16c4a70c..3e8e72eec6074d2fe149589e2e9175101afafdcf 100644 --- a/lektor_nkdb/src/database/update.rs +++ b/lektor_nkdb/src/database/update.rs @@ -253,13 +253,12 @@ impl<'a, Storage: DatabaseStorage> UpdateHandler<'a, Storage> { .await } - pub async fn delete_kara_v2(&self, repo: &str, rkid: u64) -> Result<KId> { - if let (Some(id), _) = (self.pool.read().await).get_from_remote(RemoteKId::new(rkid, repo)) - { - self.new_epoch.borrow_mut().content().data_mut().remove(&id); - Ok(id) - } else { - Err(anyhow!("corresponding local id not found")) - } + pub async fn delete_kara_v2(&self, repo: &str, remote_kid: u64) -> Result<KId> { + let id = (self.pool.read().await) + .get_from_remote(RemoteKId::new(remote_kid, repo)) + .0 + .context("corresponding local id not found")?; + self.new_epoch.borrow_mut().content().data_mut().remove(&id); + Ok(id) } }