Extract ClientOptions setup in tests.

src/proto/server/client.rs

@@ -193,6 +193,18 @@ mod tests {
     let _ = env_logger::builder().is_test(true).try_init();
   }
 
+  // Returns default ClientOptions suitable for testing.
+  fn client_options() -> ClientOptions {
+    let user_name = "alice".to_string();
+    let password = "sekrit".to_string();
+    let credentials = Credentials::new(user_name, password).unwrap();
+
+    ClientOptions {
+      credentials,
+      version: Version::default(),
+    }
+  }
+
   #[tokio::test]
   async fn login() {
     init();
@@ -202,15 +214,7 @@ mod tests {
 
     let stream = net::TcpStream::connect(handle.address()).await.unwrap();
 
-    let user_name = "alice".to_string();
-    let password = "sekrit".to_string();
-    let credentials = Credentials::new(user_name, password).unwrap();
-
-    let options = ClientOptions {
-      credentials,
-      version: Version::default(),
-    };
-    let client = Client::login(stream, options).await.unwrap();
+    let client = Client::login(stream, client_options()).await.unwrap();
 
     // Send nothing, receive no responses.
     let mut inbound = client.run(empty());
@@ -239,15 +243,7 @@ mod tests {
 
     let stream = net::TcpStream::connect(handle.address()).await.unwrap();
 
-    let user_name = "alice".to_string();
-    let password = "sekrit".to_string();
-    let credentials = Credentials::new(user_name, password).unwrap();
-
-    let options = ClientOptions {
-      credentials,
-      version: Version::default(),
-    };
-    let client = Client::login(stream, options).await.unwrap();
+    let client = Client::login(stream, client_options()).await.unwrap();
 
     let outbound = Box::pin(async_stream::stream! {
       yield ServerRequest::UserStatusRequest(UserStatusRequest {
@@ -278,15 +274,7 @@ mod tests {
 
     let stream = net::TcpStream::connect(handle.address()).await.unwrap();
 
-    let user_name = "alice".to_string();
-    let password = "sekrit".to_string();
-    let credentials = Credentials::new(user_name, password).unwrap();
-
-    let options = ClientOptions {
-      credentials,
-      version: Version::default(),
-    };
-    let client = Client::login(stream, options).await.unwrap();
+    let client = Client::login(stream, client_options()).await.unwrap();
 
     let (_request_tx, mut request_rx) = mpsc::channel(1);
     let outbound = Box::pin(async_stream::stream! {