Add more logging

HarborWallet · Jan 30, 2025 · da864b2 · da864b2
1 parent 8a1cd00
commit da864b2
Show file tree

Hide file tree

Showing 2 changed files with 32 additions and 1 deletion.
diff --git a/harbor-client/src/fedimint_client.rs b/harbor-client/src/fedimint_client.rs
@@ -277,6 +277,10 @@ pub(crate) async fn spawn_invoice_receive_subscription(
     is_transfer: bool,
     subscription: UpdateStreamOrOutcome<LnReceiveState>,
 ) {
+    info!(
+        "Spawning lightning receive subscription for operation id: {}",
+        operation_id.fmt_full()
+    );
     spawn(async move {
         let mut stream = subscription.into_stream();
         while let Some(op_state) = stream.next().await {
@@ -346,6 +350,10 @@ pub(crate) async fn spawn_invoice_payment_subscription(
     is_transfer: bool,
     subscription: UpdateStreamOrOutcome<LnPayState>,
 ) {
+    info!(
+        "Spawning lightning payment subscription for operation id: {}",
+        operation_id.fmt_full()
+    );
     spawn(async move {
         let mut stream = subscription.into_stream();
         while let Some(op_state) = stream.next().await {
@@ -439,6 +447,10 @@ pub(crate) async fn spawn_internal_payment_subscription(
     msg_id: Uuid,
     subscription: UpdateStreamOrOutcome<InternalPayState>,
 ) {
+    info!(
+        "Spawning internal payment subscription for operation id: {}",
+        operation_id.fmt_full()
+    );
     spawn(async move {
         let mut stream = subscription.into_stream();
         while let Some(op_state) = stream.next().await {
@@ -519,6 +531,10 @@ pub(crate) async fn spawn_onchain_payment_subscription(
     msg_id: Uuid,
     subscription: UpdateStreamOrOutcome<WithdrawState>,
 ) {
+    info!(
+        "Spawning onchain payment subscription for operation id: {}",
+        operation_id.fmt_full()
+    );
     spawn(async move {
         let mut stream = subscription.into_stream();
         while let Some(op_state) = stream.next().await {
@@ -583,6 +599,10 @@ pub(crate) async fn spawn_onchain_receive_subscription(
     msg_id: Uuid,
     subscription: UpdateStreamOrOutcome<DepositStateV2>,
 ) {
+    info!(
+        "Spawning onchain receive subscription for operation id: {}",
+        operation_id.fmt_full()
+    );
     spawn(async move {
         let mut stream = subscription.into_stream();
         while let Some(op_state) = stream.next().await {

diff --git a/harbor-client/src/lib.rs b/harbor-client/src/lib.rs
@@ -217,6 +217,7 @@ impl HarborCore {
         invoice: Bolt11Invoice,
         is_transfer: bool,
     ) -> anyhow::Result<()> {
+        log::info!("Paying lightning invoice: {invoice} from federation: {federation_id}");
         if invoice.amount_milli_satoshis().is_none() {
             return Err(anyhow!("Invoice must have an amount"));
         }
@@ -275,7 +276,7 @@ impl HarborCore {
             }
         }
 
-        log::info!("Invoice sent");
+        log::info!("Payment sent");
 
         Ok(())
     }
@@ -287,6 +288,7 @@ impl HarborCore {
         amount: Amount,
         is_transfer: bool,
     ) -> anyhow::Result<Bolt11Invoice> {
+        log::info!("Creating lightning invoice, amount: {amount} for federation: {federation_id}");
         let client = self.get_client(federation_id).await.fedimint_client;
         let lightning_module = client
             .get_first_module::<LightningClientModule>()
@@ -358,6 +360,10 @@ impl HarborCore {
         address: Address<NetworkUnchecked>,
         sats: Option<u64>,
     ) -> anyhow::Result<()> {
+        log::info!(
+            "Sending onchain payment to address: {} from federation: {federation_id}",
+            address.clone().assume_checked()
+        );
         let client = self.get_client(federation_id).await.fedimint_client;
         let onchain = client
             .get_first_module::<WalletClientModule>()
@@ -431,6 +437,8 @@ impl HarborCore {
             return Err(anyhow!("on-chain receive is not enabled"));
         }
 
+        log::info!("Generating address for federation: {federation_id}");
+
         let client = self.get_client(federation_id).await.fedimint_client;
         let onchain = client
             .get_first_module::<WalletClientModule>()
@@ -460,6 +468,7 @@ impl HarborCore {
         &self,
         invite_code: InviteCode,
     ) -> anyhow::Result<ClientConfig> {
+        log::info!("Getting federation info for invite code: {invite_code}");
         let download = Instant::now();
         let config = {
             #[cfg(all(debug_assertions, feature = "disable-tor"))]
@@ -489,6 +498,7 @@ impl HarborCore {
     }
 
     pub async fn add_federation(&self, invite_code: InviteCode) -> anyhow::Result<()> {
+        log::info!("Adding federation with invite code: {invite_code}");
         let id = invite_code.federation_id();
 
         let mut clients = self.clients.write().await;
@@ -511,6 +521,7 @@ impl HarborCore {
     }
 
     pub async fn remove_federation(&self, id: FederationId) -> anyhow::Result<()> {
+        log::info!("Removing federation with id: {id}");
         let mut clients = self.clients.write().await;
         if clients.remove(&id).is_none() {
             return Err(anyhow!("Federation doesn't exist"));