Feat/config websocket timeout 0.3

src/admin_websocket.rs

@@ -57,19 +57,22 @@ impl AdminWebsocket {
     /// As string `"localhost:30000"`
     /// As tuple `([127.0.0.1], 30000)`
     pub async fn connect(socket_addr: impl ToSocketAddrs) -> Result<Self> {
-        let addr = socket_addr
-            .to_socket_addrs()?
-            .next()
-            .expect("invalid websocket address");
         // app installation takes > 2 min on CI at the moment, hence the high
         // request timeout
         let mut websocket_config = WebsocketConfig::CLIENT_DEFAULT;
         websocket_config.default_request_timeout = std::time::Duration::from_secs(180);
 
-        let websocket_config = Arc::new(websocket_config);
+        Self::connect_with_config(socket_addr, Arc::new(websocket_config)).await
+    }
 
+    /// Connect to a Conductor API AdminWebsocket with a custom WebsocketConfig.
+    pub async fn connect_with_config(socket_addr: impl ToSocketAddrs, config: Arc<WebsocketConfig>) -> Result<Self> {
+        let addr = socket_addr
+            .to_socket_addrs()?
+            .next()
+            .expect("invalid websocket address");
         let (tx, mut rx) = again::retry(|| {
-            let websocket_config = Arc::clone(&websocket_config);
+            let websocket_config = Arc::clone(&config);
             connect(websocket_config, addr)
         })
         .await?;

src/lib.rs

@@ -16,6 +16,7 @@ pub use holochain_types::{
     app::{InstallAppPayload, InstalledAppId},
     dna::AgentPubKey,
 };
+pub use holochain_websocket::WebsocketConfig;
 pub use signing::client_signing::{ClientAgentSigner, SigningCredentials};
 #[cfg(feature = "lair_signing")]
 pub use signing::lair_signing::LairAgentSigner;