taler-rust

commit eca4d6f87810457eb7af850aa05af0a3e41d875a
parent cceaddc0c78603f03b68fc717eab496655188d05
Author: Antoine A <>
Date:   Sat, 14 Feb 2026 21:28:10 +0100

cyclos: clippy

Diffstat:
M
taler-cyclos/src/db.rs
 | 
19
++++++++-----------
M
taler-cyclos/src/dev.rs
 | 
7
++++++-
M
taler-cyclos/src/notification.rs
 | 
2
+-

3 files changed, 15 insertions(+), 13 deletions(-)
diff --git a/taler-cyclos/src/db.rs b/taler-cyclos/src/db.rs
@@ -249,7 +249,7 @@ pub async fn register_tx_in(
         ",
     )
     .bind(tx.transfer_id)
-    .bind(tx.tx_id.map(|it| it))
+    .bind(tx.tx_id)
     .bind_decimal(&tx.amount)
     .bind(&tx.subject)
     .bind(tx.debtor_id)
@@ -322,10 +322,7 @@ pub async fn register_tx_out(
             .bind(None::<&[u8]>)
             .bind(None::<&str>)
             .bind(None::<i64>),
-        TxOutKind::Bounce(bounced) => query
-            .bind(None::<&[u8]>)
-            .bind(None::<&str>)
-            .bind(*bounced as i64),
+        TxOutKind::Bounce(bounced) => query.bind(None::<&[u8]>).bind(None::<&str>).bind(*bounced),
         TxOutKind::Talerable(subject) => query
             .bind(subject.0.as_ref())
             .bind(subject.1.as_ref())
@@ -377,7 +374,7 @@ pub async fn make_transfer<'a>(
     .bind(&subject)
     .bind_decimal(&tx.amount)
     .bind(tx.exchange_base_url.as_str())
-    .bind(tx.creditor_id as i64)
+    .bind(tx.creditor_id)
     .bind(&tx.creditor_name)
     .bind_timestamp(now)
     .try_map(|r: PgRow| {
@@ -415,14 +412,14 @@ pub async fn register_bounced_tx_in(
             FROM register_bounced_tx_in($1, $2, ($3, $4)::taler_amount, $5, $6, $7, $8, $9, $10, $11)
         ",
     )
-    .bind(tx.transfer_id as i64)
-    .bind(tx.tx_id.map(|it| it as i64))
+    .bind(tx.transfer_id)
+    .bind(tx.tx_id)
     .bind_decimal(&tx.amount)
     .bind(&tx.subject)
-    .bind(tx.debtor_id as i64)
+    .bind(tx.debtor_id)
     .bind(&tx.debtor_name)
     .bind_timestamp(&tx.valued_at)
-    .bind(chargeback_id as i64)
+    .bind(chargeback_id)
     .bind(reason)
     .bind_timestamp(now)
     .try_map(|r: PgRow| {
@@ -743,7 +740,7 @@ pub async fn initiated_chargeback_failure(
 ) -> sqlx::Result<ChargebackFailureResult> {
     Ok(
         sqlx::query("SELECT out_initiated_id, out_new FROM register_charge_back_failure($1)")
-            .bind(transfer_id as i64)
+            .bind(transfer_id)
             .try_map(|r: PgRow| {
                 let id = r.try_get_u64(0)?;
                 Ok(if id == 0 {
diff --git a/taler-cyclos/src/dev.rs b/taler-cyclos/src/dev.rs
@@ -70,7 +70,12 @@ pub async fn dev(cfg: &Config, cmd: DevCmd) -> anyhow::Result<()> {
             let mut page_idx = 0;
             loop {
                 let page = client
-                    .history(*cfg.worker.account_type_id, OrderBy::DateAsc, page_idx, None)
+                    .history(
+                        *cfg.worker.account_type_id,
+                        OrderBy::DateAsc,
+                        page_idx,
+                        None,
+                    )
                     .await?;
                 for transfer in page.page {
                     let tx = extract_tx_info(transfer);
diff --git a/taler-cyclos/src/notification.rs b/taler-cyclos/src/notification.rs
@@ -26,7 +26,7 @@ use crate::cyclos_api::{
 };
 
 pub async fn watch_notification(client: &Client<'_>, notify: &Notify) -> ! {
-    let client_id = Timestamp::now().as_microsecond() as i64;
+    let client_id = Timestamp::now().as_microsecond();
     let mut sse_client = SseClient::new();
     let mut jitter = ExpoBackoffDecorr::default();
     loop {