|
@@ -800,7 +800,7 @@ where
|
|
|
.inner
|
|
.inner
|
|
|
.get_proofs_by_ys(cdk_ys)
|
|
.get_proofs_by_ys(cdk_ys)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })?;
|
|
|
|
|
|
|
+ .map_err(FfiError::database)?;
|
|
|
|
|
|
|
|
Ok(result.into_iter().map(Into::into).collect())
|
|
Ok(result.into_iter().map(Into::into).collect())
|
|
|
}
|
|
}
|
|
@@ -811,16 +811,12 @@ where
|
|
|
.inner
|
|
.inner
|
|
|
.get_mint(cdk_mint_url)
|
|
.get_mint(cdk_mint_url)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })?;
|
|
|
|
|
|
|
+ .map_err(FfiError::database)?;
|
|
|
Ok(result.map(Into::into))
|
|
Ok(result.map(Into::into))
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn get_mints(&self) -> Result<HashMap<MintUrl, Option<MintInfo>>, FfiError> {
|
|
async fn get_mints(&self) -> Result<HashMap<MintUrl, Option<MintInfo>>, FfiError> {
|
|
|
- let result = self
|
|
|
|
|
- .inner
|
|
|
|
|
- .get_mints()
|
|
|
|
|
- .await
|
|
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })?;
|
|
|
|
|
|
|
+ let result = self.inner.get_mints().await.map_err(FfiError::database)?;
|
|
|
Ok(result
|
|
Ok(result
|
|
|
.into_iter()
|
|
.into_iter()
|
|
|
.map(|(k, v)| (k.into(), v.map(Into::into)))
|
|
.map(|(k, v)| (k.into(), v.map(Into::into)))
|
|
@@ -836,7 +832,7 @@ where
|
|
|
.inner
|
|
.inner
|
|
|
.get_mint_keysets(cdk_mint_url)
|
|
.get_mint_keysets(cdk_mint_url)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })?;
|
|
|
|
|
|
|
+ .map_err(FfiError::database)?;
|
|
|
Ok(result.map(|keysets| keysets.into_iter().map(Into::into).collect()))
|
|
Ok(result.map(|keysets| keysets.into_iter().map(Into::into).collect()))
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -846,7 +842,7 @@ where
|
|
|
.inner
|
|
.inner
|
|
|
.get_keyset_by_id(&cdk_id)
|
|
.get_keyset_by_id(&cdk_id)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })?;
|
|
|
|
|
|
|
+ .map_err(FfiError::database)?;
|
|
|
Ok(result.map(Into::into))
|
|
Ok(result.map(Into::into))
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -855,7 +851,7 @@ where
|
|
|
.inner
|
|
.inner
|
|
|
.get_mint_quote("e_id)
|
|
.get_mint_quote("e_id)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })?;
|
|
|
|
|
|
|
+ .map_err(FfiError::database)?;
|
|
|
Ok(result.map(|q| q.into()))
|
|
Ok(result.map(|q| q.into()))
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -864,7 +860,7 @@ where
|
|
|
.inner
|
|
.inner
|
|
|
.get_mint_quotes()
|
|
.get_mint_quotes()
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })?;
|
|
|
|
|
|
|
+ .map_err(FfiError::database)?;
|
|
|
Ok(result.into_iter().map(|q| q.into()).collect())
|
|
Ok(result.into_iter().map(|q| q.into()).collect())
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -873,7 +869,7 @@ where
|
|
|
.inner
|
|
.inner
|
|
|
.get_unissued_mint_quotes()
|
|
.get_unissued_mint_quotes()
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })?;
|
|
|
|
|
|
|
+ .map_err(FfiError::database)?;
|
|
|
Ok(result.into_iter().map(|q| q.into()).collect())
|
|
Ok(result.into_iter().map(|q| q.into()).collect())
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -882,7 +878,7 @@ where
|
|
|
.inner
|
|
.inner
|
|
|
.get_melt_quote("e_id)
|
|
.get_melt_quote("e_id)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })?;
|
|
|
|
|
|
|
+ .map_err(FfiError::database)?;
|
|
|
Ok(result.map(|q| q.into()))
|
|
Ok(result.map(|q| q.into()))
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -891,7 +887,7 @@ where
|
|
|
.inner
|
|
.inner
|
|
|
.get_melt_quotes()
|
|
.get_melt_quotes()
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })?;
|
|
|
|
|
|
|
+ .map_err(FfiError::database)?;
|
|
|
Ok(result.into_iter().map(|q| q.into()).collect())
|
|
Ok(result.into_iter().map(|q| q.into()).collect())
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -901,7 +897,7 @@ where
|
|
|
.inner
|
|
.inner
|
|
|
.get_keys(&cdk_id)
|
|
.get_keys(&cdk_id)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })?;
|
|
|
|
|
|
|
+ .map_err(FfiError::database)?;
|
|
|
Ok(result.map(Into::into))
|
|
Ok(result.map(Into::into))
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -928,7 +924,7 @@ where
|
|
|
.inner
|
|
.inner
|
|
|
.get_proofs(cdk_mint_url, cdk_unit, cdk_state, cdk_spending_conditions)
|
|
.get_proofs(cdk_mint_url, cdk_unit, cdk_state, cdk_spending_conditions)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })?;
|
|
|
|
|
|
|
+ .map_err(FfiError::database)?;
|
|
|
|
|
|
|
|
Ok(result.into_iter().map(Into::into).collect())
|
|
Ok(result.into_iter().map(Into::into).collect())
|
|
|
}
|
|
}
|
|
@@ -946,7 +942,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.get_balance(cdk_mint_url, cdk_unit, cdk_state)
|
|
.get_balance(cdk_mint_url, cdk_unit, cdk_state)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn get_transaction(
|
|
async fn get_transaction(
|
|
@@ -958,7 +954,7 @@ where
|
|
|
.inner
|
|
.inner
|
|
|
.get_transaction(cdk_id)
|
|
.get_transaction(cdk_id)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })?;
|
|
|
|
|
|
|
+ .map_err(FfiError::database)?;
|
|
|
Ok(result.map(Into::into))
|
|
Ok(result.map(Into::into))
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -976,7 +972,7 @@ where
|
|
|
.inner
|
|
.inner
|
|
|
.list_transactions(cdk_mint_url, cdk_direction, cdk_unit)
|
|
.list_transactions(cdk_mint_url, cdk_direction, cdk_unit)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })?;
|
|
|
|
|
|
|
+ .map_err(FfiError::database)?;
|
|
|
|
|
|
|
|
Ok(result.into_iter().map(Into::into).collect())
|
|
Ok(result.into_iter().map(Into::into).collect())
|
|
|
}
|
|
}
|
|
@@ -990,7 +986,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.kv_read(&primary_namespace, &secondary_namespace, &key)
|
|
.kv_read(&primary_namespace, &secondary_namespace, &key)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn kv_list(
|
|
async fn kv_list(
|
|
@@ -1001,7 +997,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.kv_list(&primary_namespace, &secondary_namespace)
|
|
.kv_list(&primary_namespace, &secondary_namespace)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn kv_write(
|
|
async fn kv_write(
|
|
@@ -1014,7 +1010,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.kv_write(&primary_namespace, &secondary_namespace, &key, &value)
|
|
.kv_write(&primary_namespace, &secondary_namespace, &key, &value)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn kv_remove(
|
|
async fn kv_remove(
|
|
@@ -1026,7 +1022,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.kv_remove(&primary_namespace, &secondary_namespace, &key)
|
|
.kv_remove(&primary_namespace, &secondary_namespace, &key)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// ========== Write methods ==========
|
|
// ========== Write methods ==========
|
|
@@ -1061,7 +1057,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.update_proofs(cdk_added, cdk_removed_ys)
|
|
.update_proofs(cdk_added, cdk_removed_ys)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn update_proofs_state(
|
|
async fn update_proofs_state(
|
|
@@ -1077,7 +1073,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.update_proofs_state(cdk_ys, cdk_state)
|
|
.update_proofs_state(cdk_ys, cdk_state)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn add_transaction(&self, transaction: Transaction) -> Result<(), FfiError> {
|
|
async fn add_transaction(&self, transaction: Transaction) -> Result<(), FfiError> {
|
|
@@ -1085,7 +1081,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.add_transaction(cdk_transaction)
|
|
.add_transaction(cdk_transaction)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn remove_transaction(&self, transaction_id: TransactionId) -> Result<(), FfiError> {
|
|
async fn remove_transaction(&self, transaction_id: TransactionId) -> Result<(), FfiError> {
|
|
@@ -1093,7 +1089,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.remove_transaction(cdk_id)
|
|
.remove_transaction(cdk_id)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn update_mint_url(
|
|
async fn update_mint_url(
|
|
@@ -1106,7 +1102,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.update_mint_url(cdk_old, cdk_new)
|
|
.update_mint_url(cdk_old, cdk_new)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn increment_keyset_counter(&self, keyset_id: Id, count: u32) -> Result<u32, FfiError> {
|
|
async fn increment_keyset_counter(&self, keyset_id: Id, count: u32) -> Result<u32, FfiError> {
|
|
@@ -1114,7 +1110,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.increment_keyset_counter(&cdk_id, count)
|
|
.increment_keyset_counter(&cdk_id, count)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn add_mint(
|
|
async fn add_mint(
|
|
@@ -1127,7 +1123,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.add_mint(cdk_mint_url, cdk_mint_info)
|
|
.add_mint(cdk_mint_url, cdk_mint_info)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn remove_mint(&self, mint_url: MintUrl) -> Result<(), FfiError> {
|
|
async fn remove_mint(&self, mint_url: MintUrl) -> Result<(), FfiError> {
|
|
@@ -1135,7 +1131,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.remove_mint(cdk_mint_url)
|
|
.remove_mint(cdk_mint_url)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn add_mint_keysets(
|
|
async fn add_mint_keysets(
|
|
@@ -1148,7 +1144,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.add_mint_keysets(cdk_mint_url, cdk_keysets)
|
|
.add_mint_keysets(cdk_mint_url, cdk_keysets)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn add_mint_quote(&self, quote: MintQuote) -> Result<(), FfiError> {
|
|
async fn add_mint_quote(&self, quote: MintQuote) -> Result<(), FfiError> {
|
|
@@ -1156,14 +1152,14 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.add_mint_quote(cdk_quote)
|
|
.add_mint_quote(cdk_quote)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn remove_mint_quote(&self, quote_id: String) -> Result<(), FfiError> {
|
|
async fn remove_mint_quote(&self, quote_id: String) -> Result<(), FfiError> {
|
|
|
self.inner
|
|
self.inner
|
|
|
.remove_mint_quote("e_id)
|
|
.remove_mint_quote("e_id)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn add_melt_quote(&self, quote: MeltQuote) -> Result<(), FfiError> {
|
|
async fn add_melt_quote(&self, quote: MeltQuote) -> Result<(), FfiError> {
|
|
@@ -1171,14 +1167,14 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.add_melt_quote(cdk_quote)
|
|
.add_melt_quote(cdk_quote)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn remove_melt_quote(&self, quote_id: String) -> Result<(), FfiError> {
|
|
async fn remove_melt_quote(&self, quote_id: String) -> Result<(), FfiError> {
|
|
|
self.inner
|
|
self.inner
|
|
|
.remove_melt_quote("e_id)
|
|
.remove_melt_quote("e_id)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn add_keys(&self, keyset: KeySet) -> Result<(), FfiError> {
|
|
async fn add_keys(&self, keyset: KeySet) -> Result<(), FfiError> {
|
|
@@ -1186,7 +1182,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.add_keys(cdk_keyset)
|
|
.add_keys(cdk_keyset)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async fn remove_keys(&self, id: Id) -> Result<(), FfiError> {
|
|
async fn remove_keys(&self, id: Id) -> Result<(), FfiError> {
|
|
@@ -1194,7 +1190,7 @@ where
|
|
|
self.inner
|
|
self.inner
|
|
|
.remove_keys(&cdk_id)
|
|
.remove_keys(&cdk_id)
|
|
|
.await
|
|
.await
|
|
|
- .map_err(|e| FfiError::Database { msg: e.to_string() })
|
|
|
|
|
|
|
+ .map_err(FfiError::database)
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|