Checkpoint: Correct message sending

farcaster-project · Jun 8, 2022 · 565c115 · 565c115
1 parent 48aae25
commit 565c115
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/checkpointd/runtime.rs b/src/checkpointd/runtime.rs
@@ -313,8 +313,8 @@ pub fn checkpoint_state(
             );
             endpoints.send_to(
                 ServiceBus::Ctl,
-                ServiceId::Wallet,
                 ServiceId::Checkpoint,
+                ServiceId::Wallet,
                 Request::CheckpointMultipartChunk(CheckpointMultipartChunk {
                     checksum,
                     msg_index: n,
@@ -327,8 +327,8 @@ pub fn checkpoint_state(
     } else {
         endpoints.send_to(
             ServiceBus::Ctl,
-            ServiceId::Wallet,
             ServiceId::Checkpoint,
+            ServiceId::Wallet,
             Request::Checkpoint(Checkpoint { swap_id, state }),
         )?;
     }

diff --git a/src/walletd/runtime.rs b/src/walletd/runtime.rs
@@ -1606,12 +1606,12 @@ impl Runtime {
             Request::Checkpoint(request::Checkpoint { swap_id, state }) => match state {
                 CheckpointState::CheckpointWalletAlicePreBuy(alice_state)
                 | CheckpointState::CheckpointWalletAlicePreLock(alice_state) => {
-                    debug!("Restoring alice wallet for swap {}", swap_id);
+                    info!("Restoring alice wallet for swap {}", swap_id);
                     self.wallets.insert(swap_id, Wallet::Alice(alice_state));
                 }
                 CheckpointState::CheckpointWalletBobPreBuy(bob_state)
                 | CheckpointState::CheckpointWalletBobPreLock(bob_state) => {
-                    debug!("Restoring bob wallet for swap {}", swap_id);
+                    info!("Restoring bob wallet for swap {}", swap_id);
                     self.wallets.insert(swap_id, Wallet::Bob(bob_state));
                 }
             },