chore: update fedimint to 0.7

elsirion · tacio · commit d3fa7cceea1a · 2025-07-12T18:39:05.000-03:00
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -8,8 +8,8 @@ members = [
 resolver = "2"
 
 [workspace.dependencies]
-fedimint-api-client = { version = "0.4", git = "https://github.com/elsirion/fedimint", branch = "v0.4.4-patch-xyz" }
-fedimint-core = { version = "0.4", git = "https://github.com/elsirion/fedimint", branch = "v0.4.4-patch-xyz" }
-fedimint-ln-common = { version = "0.4", git = "https://github.com/elsirion/fedimint", branch = "v0.4.4-patch-xyz" }
-fedimint-mint-common = { version = "0.4", git = "https://github.com/elsirion/fedimint", branch = "v0.4.4-patch-xyz" }
-fedimint-wallet-common = { version = "0.4", git = "https://github.com/elsirion/fedimint", branch = "v0.4.4-patch-xyz" }
+fedimint-api-client = { version = "0.7" } # TODO: apply XYZ patch
+fedimint-core = { version = "0.7" }
+fedimint-ln-common = { version = "0.7" }
+fedimint-mint-common = { version = "0.7" }
+fedimint-wallet-common = { version = "0.7" }
diff --git a/flake.lock b/flake.lock
diff --git a/fmo_api_types/Cargo.toml b/fmo_api_types/Cargo.toml
@@ -4,6 +4,6 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
-bitcoin = { version = "0.30.2", features = ["serde"] }
+bitcoin = { version = "0.32.5", features = ["serde"] }
 fedimint-core = { workspace = true }
 serde = { version = "1.0", features = ["derive"] }
diff --git a/fmo_frontend/src/components/federation/guardians.rs b/fmo_frontend/src/components/federation/guardians.rs
@@ -1,9 +1,9 @@
 use std::collections::BTreeMap;
 
 use fedimint_core::config::FederationId;
-use fedimint_core::util::backon::FibonacciBuilder;
 use fedimint_core::util::retry;
 use fedimint_core::{NumPeers, PeerId};
+use fedimint_core::util::backoff_util::background_backoff;
 use fmo_api_types::GuardianHealth;
 use leptos::{component, create_resource, view, IntoView, SignalGet};
 
@@ -125,7 +125,7 @@ pub struct Guardian {
 async fn fetch_guardian_health(id: FederationId) -> BTreeMap<PeerId, GuardianHealth> {
     retry(
         "fetching guardian health",
-        FibonacciBuilder::default().with_max_times(usize::MAX),
+        background_backoff(),
         || async move {
             reqwest::get(format!("{}/federations/{}/health", BASE_URL, id))
                 .await?
diff --git a/fmo_frontend/src/components/federations/totals.rs b/fmo_frontend/src/components/federations/totals.rs
@@ -1,4 +1,4 @@
-use fedimint_core::util::backon::FibonacciBuilder;
+use fedimint_core::util::backoff_util::background_backoff;
 use fedimint_core::util::retry;
 use fmo_api_types::FedimintTotals;
 use leptos::{component, create_resource, view, IntoView, SignalGet};
@@ -11,7 +11,7 @@ pub fn Totals() -> impl IntoView {
         |_| async {
             retry(
                 "fetching federation totals",
-                FibonacciBuilder::default().with_max_times(usize::MAX),
+                background_backoff(),
                 fetch_federation_totals,
             )
             .await
diff --git a/fmo_frontend/src/components/nostr/mod.rs b/fmo_frontend/src/components/nostr/mod.rs
@@ -6,7 +6,7 @@ use std::collections::BTreeMap;
 use check_federation::CheckFederation;
 use fedimint_core::config::FederationId;
 use fedimint_core::invite_code::InviteCode;
-use fedimint_core::util::backon::FibonacciBuilder;
+use fedimint_core::util::backoff_util::background_backoff;
 use fedimint_core::util::retry;
 use leptos::{component, create_resource, view, IntoView, SignalGet};
 use leptos_meta::Title;
@@ -76,7 +76,7 @@ async fn fetch_nostr_federations() -> BTreeMap<FederationId, InviteCode> {
 
     retry(
         "Fetching Nostr federations",
-        FibonacciBuilder::default().with_max_times(usize::MAX),
+        background_backoff(),
         fetch_nostr_federations_impl,
     )
     .await
diff --git a/fmo_frontend/src/components/nostr/nostr_federation_row.rs b/fmo_frontend/src/components/nostr/nostr_federation_row.rs
@@ -3,7 +3,7 @@ use std::collections::BTreeMap;
 use anyhow::Context;
 use fedimint_core::config::FederationId;
 use fedimint_core::invite_code::InviteCode;
-use fedimint_core::util::backon::FibonacciBuilder;
+use fedimint_core::util::backoff_util::background_backoff;
 use fedimint_core::util::retry;
 use leptos::{component, create_resource, view, IntoView, SignalGet};
 
@@ -57,7 +57,7 @@ async fn fetch_federation_name(invite_code: InviteCode) -> String {
 
     retry(
         "Fetching federation name",
-        FibonacciBuilder::default().with_max_times(usize::MAX),
+        background_backoff(),
         fetch_federation_name_impl,
     )
     .await
diff --git a/fmo_server/Cargo.toml b/fmo_server/Cargo.toml
@@ -17,10 +17,10 @@ anyhow = "1.0.81"
 async-stream = "0.3.5"
 axum = { version = "0.7.5", features = ["json"] }
 axum-auth = "0.7.0"
-bitcoin = "0.30.2"
+bitcoin = "0.32.5"
 csv = "1.3.0"
 dotenv = "0.15.0"
-esplora-client = { version = "0.7.0", default-features = false, features = [
+esplora-client = { version = "0.10.0", default-features = false, features = [
     "async-https-rustls",
 ] }
 fmo_api_types = { path = "../fmo_api_types" }
diff --git a/fmo_server/src/config/mod.rs b/fmo_server/src/config/mod.rs
@@ -4,7 +4,6 @@ use std::sync::Arc;
 use axum::extract::{Path, State};
 use axum::routing::get;
 use axum::{Json, Router};
-use fedimint_api_client::download_from_invite_code;
 use fedimint_core::config::{FederationId, JsonClientConfig};
 use fedimint_core::invite_code::InviteCode;
 use reqwest::Method;
@@ -33,7 +32,7 @@ pub fn get_config_routes() -> Router<AppState> {
         .route("/:invite/id", get(fetch_federation_id))
         .route("/:invite/module_kinds", get(fetch_federation_module_kinds));
 
-    let cors_enabled = dotenv::var("ALLOW_CONFIG_CORS").map_or(false, |v| v == "true");
+    let cors_enabled = dotenv::var("ALLOW_CONFIG_CORS").is_ok_and(|v| v == "true");
 
     if cors_enabled {
         router.layer(
@@ -87,6 +86,8 @@ impl FederationConfigCache {
 }
 
 async fn fetch_config_inner(invite: &InviteCode) -> anyhow::Result<JsonClientConfig> {
-    let raw_config = download_from_invite_code(invite).await?;
+    let raw_config = fedimint_api_client::api::net::Connector::default()
+        .download_from_invite_code(invite)
+        .await?;
     config_to_json(raw_config)
 }
diff --git a/fmo_server/src/federation/db.rs b/fmo_server/src/federation/db.rs
@@ -20,7 +20,7 @@ impl FromRow for crate::federation::db::FederationV0 {
     fn try_from_row(row: &Row) -> Result<Self, Error> {
         let federation_id_bytes: Vec<u8> = row.try_get("federation_id")?;
         let federation_id =
-            FederationId::consensus_decode_vec(federation_id_bytes, &Default::default())
+            FederationId::consensus_decode_whole(&federation_id_bytes, &Default::default())
                 .expect("Invalid data in DB");
 
         let config_bytes: Vec<u8> = row.try_get("config")?;
@@ -51,11 +51,11 @@ impl FromRow for Federation {
     fn try_from_row(row: &Row) -> Result<Self, Error> {
         let federation_id_bytes: Vec<u8> = row.try_get("federation_id")?;
         let federation_id =
-            FederationId::consensus_decode_vec(federation_id_bytes, &Default::default())
+            FederationId::consensus_decode_whole(&federation_id_bytes, &Default::default())
                 .expect("Invalid data in DB");
 
         let config_bytes: Vec<u8> = row.try_get("config")?;
-        let config = ClientConfig::consensus_decode_vec(config_bytes, &Default::default())
+        let config = ClientConfig::consensus_decode_whole(&config_bytes, &Default::default())
             .expect("Invalid data in DB");
 
         Ok(Federation {
@@ -83,16 +83,16 @@ impl FromRow for crate::federation::db::Transaction {
         let decoder = ModuleDecoderRegistry::default().with_fallback();
 
         let txid_bytes: Vec<u8> = row.try_get("txid")?;
-        let txid =
-            TransactionId::consensus_decode_vec(txid_bytes, &decoder).expect("Invalid data in DB");
+        let txid = TransactionId::consensus_decode_whole(&txid_bytes, &decoder)
+            .expect("Invalid data in DB");
 
         let session_index = row.try_get::<_, i32>("session_index")?;
 
         let item_index = row.try_get::<_, i32>("item_index")?;
 
         let data_bytes: Vec<u8> = row.try_get("data")?;
         let data =
-            fedimint_core::transaction::Transaction::consensus_decode_vec(data_bytes, &decoder)
+            fedimint_core::transaction::Transaction::consensus_decode_whole(&data_bytes, &decoder)
                 .expect("Invalid data in DB");
 
         Ok(crate::federation::db::Transaction {
@@ -119,8 +119,8 @@ impl FromRow for crate::federation::db::SessionOutcome {
         let decoder = ModuleDecoderRegistry::default().with_fallback();
 
         let session_data_bytes: Vec<u8> = row.try_get("session")?;
-        let data = fedimint_core::session_outcome::SessionOutcome::consensus_decode_vec(
-            session_data_bytes,
+        let data = fedimint_core::session_outcome::SessionOutcome::consensus_decode_whole(
+            &session_data_bytes,
             &decoder,
         )
         .expect("Invalid data in DB");
@@ -144,8 +144,8 @@ impl SessionOutcome {
         decoders: &ModuleDecoderRegistry,
     ) -> Result<Self, Error> {
         let session_data_bytes: Vec<u8> = row.try_get("session")?;
-        let data = fedimint_core::session_outcome::SessionOutcome::consensus_decode_vec(
-            session_data_bytes,
+        let data = fedimint_core::session_outcome::SessionOutcome::consensus_decode_whole(
+            &session_data_bytes,
             decoders,
         )
         .expect("Invalid data in DB");
diff --git a/fmo_server/src/federation/guardians.rs b/fmo_server/src/federation/guardians.rs
@@ -24,7 +24,6 @@ impl FederationObserver {
         federation_id: FederationId,
         config: ClientConfig,
     ) -> anyhow::Result<()> {
-        const REQUEST_TIMEOUT: Duration = Duration::from_secs(20);
         const REQUEST_INTERVAL: Duration = Duration::from_secs(60);
 
         let mut interval = tokio::time::interval(REQUEST_INTERVAL);
@@ -35,7 +34,9 @@ impl FederationObserver {
                 .iter()
                 .map(|(&peer_id, peer_url)| (peer_id, peer_url.url.clone())),
             &None,
-        );
+        )
+        .await?;
+
         let wallet_module = config
             .modules
             .iter()
@@ -55,7 +56,6 @@ impl FederationObserver {
                         // the background
                         let status = api
                             .request_single_peer(
-                                Some(REQUEST_TIMEOUT),
                                 STATUS_ENDPOINT.to_owned(),
                                 ApiRequestErased::default(),
                                 peer_id,
@@ -70,7 +70,6 @@ impl FederationObserver {
                         let block_height = api
                             .with_module(wallet_module)
                             .request_single_peer(
-                                Some(REQUEST_TIMEOUT),
                                 BLOCK_COUNT_LOCAL_ENDPOINT.to_owned(),
                                 ApiRequestErased::default(),
                                 peer_id,
diff --git a/fmo_server/src/federation/observer.rs b/fmo_server/src/federation/observer.rs
@@ -8,16 +8,16 @@ use bitcoin::hashes::Hash;
 use bitcoin::{Address, OutPoint, Txid};
 use chrono::{DateTime, NaiveDate};
 use deadpool_postgres::{GenericClient, Runtime, Transaction};
+use fedimint_api_client::api::net::Connector;
 use fedimint_api_client::api::DynGlobalApi;
-use fedimint_api_client::download_from_invite_code;
 use fedimint_core::config::{ClientConfig, FederationId};
 use fedimint_core::core::DynModuleConsensusItem;
 use fedimint_core::encoding::Encodable;
 use fedimint_core::epoch::ConsensusItem;
 use fedimint_core::invite_code::InviteCode;
 use fedimint_core::session_outcome::SessionOutcome;
 use fedimint_core::task::TaskGroup;
-use fedimint_core::util::backon::{ConstantBuilder, FibonacciBuilder};
+use fedimint_core::util::backoff_util::background_backoff;
 use fedimint_core::util::retry;
 use fedimint_core::{Amount, PeerId};
 use fedimint_ln_common::contracts::{Contract, IdentifiableContract};
@@ -471,7 +471,9 @@ impl FederationObserver {
             return Ok(federation_id);
         }
 
-        let config = download_from_invite_code(invite).await?;
+        let config = Connector::default()
+            .download_from_invite_code(invite)
+            .await?;
 
         self.connection()
             .await?
@@ -587,7 +589,8 @@ impl FederationObserver {
                 .iter()
                 .map(|(&peer_id, peer_url)| (peer_id, peer_url.url.clone())),
             &None,
-        );
+        )
+        .await?;
         let decoders = decoders_from_config(&config);
 
         info!("Starting background job for {federation_id}");
@@ -602,9 +605,7 @@ impl FederationObserver {
                 async move {
                     let signed_session_outcome = retry(
                         format!("Waiting for session {session_index}"),
-                        ConstantBuilder::default()
-                            .with_delay(Duration::from_secs(1))
-                            .with_max_times(usize::MAX),
+                        background_backoff(),
                         || async {
                             api_fetch_single
                                 .await_block(session_index, &decoders_single)
@@ -1261,10 +1262,7 @@ impl FederationObserver {
 
                 let fetched_tx = retry(
                     "fetching tx from esplora".to_string(),
-                    FibonacciBuilder::default()
-                        .with_min_delay(Duration::from_secs(30))
-                        .with_max_delay(Duration::from_secs(60 * 30))
-                        .with_max_times(usize::MAX),
+                    background_backoff(),
                     || async {
                         client.get_tx_no_opt(&esplora_txid).await.map_err(|e| {
                             warn!("failed to fetch tx: {e:?}");
diff --git a/fmo_server/src/meta.rs b/fmo_server/src/meta.rs
@@ -1,5 +1,6 @@
 use axum::Json;
-use fedimint_core::config::{JsonClientConfig, META_OVERRIDE_URL_KEY};
+use fedimint_core::config::JsonClientConfig;
+use fedimint_core_v3::config::META_OVERRIDE_URL_KEY;
 use tracing::debug;
 use tracing::log::warn;
 
