crypto: Add missing flush calls to the sled crypto store
parent
1db89741bc
commit
ef5d7ca579
|
@ -426,11 +426,9 @@ impl CryptoStore for SledStore {
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn save_account(&self, account: ReadOnlyAccount) -> Result<()> {
|
async fn save_account(&self, account: ReadOnlyAccount) -> Result<()> {
|
||||||
let pickle = account.pickle(self.get_pickle_mode()).await;
|
let mut changes = Changes::default();
|
||||||
self.account
|
changes.account = Some(account);
|
||||||
.insert("account".encode(), serde_json::to_vec(&pickle)?)?;
|
self.save_changes(changes).await
|
||||||
|
|
||||||
Ok(())
|
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn save_changes(&self, changes: Changes) -> Result<()> {
|
async fn save_changes(&self, changes: Changes) -> Result<()> {
|
||||||
|
@ -569,6 +567,7 @@ impl CryptoStore for SledStore {
|
||||||
|
|
||||||
async fn save_value(&self, key: String, value: String) -> Result<()> {
|
async fn save_value(&self, key: String, value: String) -> Result<()> {
|
||||||
self.values.insert(key.as_str().encode(), value.as_str())?;
|
self.values.insert(key.as_str().encode(), value.as_str())?;
|
||||||
|
self.inner.flush_async().await?;
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue