Farcasterd: Check if walletd is running before restoring checkpoint

farcaster-project · Jun 26, 2022 · b6b1b30 · b6b1b30
1 parent 91756f6
commit b6b1b30
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/src/farcasterd/runtime.rs b/src/farcasterd/runtime.rs
@@ -896,14 +896,22 @@ impl Runtime {
             }
 
             Request::RestoreCheckpoint(swap_id) => {
-                if self.running_swaps.contains(&swap_id) {
+                if endpoints
+                    .send_to(
+                        ServiceBus::Msg,
+                        ServiceId::Farcasterd,
+                        ServiceId::Wallet,
+                        Request::Hello,
+                    )
+                    .is_err()
+                {
                     endpoints.send_to(
                         ServiceBus::Ctl,
                         ServiceId::Farcasterd,
                         source,
                         Request::Failure(Failure {
                             code: 1,
-                            info: "Cannot restore an already running swap".to_string(),
+                            info: "Cannot restore a swap when walletd is not running".to_string(),
                         }),
                     )?;
                     return Ok(());