Instruct Ping to keep the connection alive

CHANGELOG.md

@@ -7,6 +7,13 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Fixed
+
+- An issue where the connection between ASB and CLI would get closed prematurely.
+  The CLI expects to be connected to the ASB throughout the entire swap and hence reconnects as soon as the connection is closed.
+  This resulted in a loop of connections being established but instantly closed again because the ASB deemed the connection to not be necessary.
+  See issue https://github.com/comit-network/xmr-btc-swap/issues/648.
+
 ## [0.8.1] - 2021-08-16
 
 ### Fixed

swap/src/asb/network.rs

@@ -13,7 +13,7 @@ use libp2p::core::connection::ConnectionId;
 use libp2p::core::muxing::StreamMuxerBox;
 use libp2p::core::transport::Boxed;
 use libp2p::dns::TokioDnsConfig;
-use libp2p::ping::{Ping, PingEvent};
+use libp2p::ping::{Ping, PingConfig, PingEvent};
 use libp2p::request_response::{RequestId, ResponseChannel};
 use libp2p::swarm::{
     DialPeerCondition, IntoProtocolsHandler, NetworkBehaviour, NetworkBehaviourAction,
@@ -152,7 +152,7 @@ pub mod behaviour {
                 ),
                 transfer_proof: transfer_proof::alice(),
                 encrypted_signature: encrypted_signature::alice(),
-                ping: Ping::default(),
+                ping: Ping::new(PingConfig::new().with_keep_alive(true)),
             }
         }
     }

swap/src/cli/behaviour.rs

@@ -5,7 +5,7 @@ use crate::protocol::bob::State2;
 use crate::{bitcoin, env};
 use anyhow::{anyhow, Error, Result};
 use libp2p::core::Multiaddr;
-use libp2p::ping::{Ping, PingEvent};
+use libp2p::ping::{Ping, PingConfig, PingEvent};
 use libp2p::request_response::{RequestId, ResponseChannel};
 use libp2p::{NetworkBehaviour, PeerId};
 use std::sync::Arc;
@@ -83,7 +83,7 @@ impl Behaviour {
             transfer_proof: transfer_proof::bob(),
             encrypted_signature: encrypted_signature::bob(),
             redial: redial::Behaviour::new(alice, Duration::from_secs(2)),
-            ping: Ping::default(),
+            ping: Ping::new(PingConfig::new().with_keep_alive(true)),
         }
     }