From 1e8ab740584b5f47495e3e48c443b02d0317f7ef Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Damir=20Jeli=C4=87?= <poljar@termina.org.uk>
Date: Fri, 8 May 2020 09:57:42 +0200
Subject: [PATCH] matrix-sdk: Use the EventBuilder in the async client tests.

---
 matrix_sdk/Cargo.toml          |  1 +
 matrix_sdk/src/async_client.rs | 88 +++++++++++++---------------------
 2 files changed, 33 insertions(+), 56 deletions(-)

diff --git a/matrix_sdk/Cargo.toml b/matrix_sdk/Cargo.toml
index 68b52a2f..40365979 100644
--- a/matrix_sdk/Cargo.toml
+++ b/matrix_sdk/Cargo.toml
@@ -46,6 +46,7 @@ default-features = false
 features = ["sync", "time", "fs"]
 
 [dev-dependencies]
+matrix-sdk-test = { version = "0.1.0", path = "../matrix_sdk_test" }
 tokio = { version = "0.2.20", features = ["rt-threaded", "macros"] }
 ruma-identifiers = { version = "0.16.1", features = ["rand"] }
 serde_json = "1.0.52"
diff --git a/matrix_sdk/src/async_client.rs b/matrix_sdk/src/async_client.rs
index 10571acd..ad6e3fde 100644
--- a/matrix_sdk/src/async_client.rs
+++ b/matrix_sdk/src/async_client.rs
@@ -1197,10 +1197,13 @@ mod test {
         leave_room, Invite3pid, MessageEventContent, RoomIdOrAliasId,
     };
     use super::{AsyncClient, AsyncClientConfig, Session, SyncSettings, Url};
+    use crate::events::collections::all::RoomEvent;
     use crate::events::room::member::MembershipState;
     use crate::events::room::message::TextMessageEventContent;
     use crate::identifiers::{EventId, RoomId, UserId};
+
     use matrix_sdk_base::JsonStore;
+    use matrix_sdk_test::EventBuilder;
 
     use mockito::{mock, Matcher};
     use std::convert::TryFrom;
@@ -1236,66 +1239,39 @@ mod test {
         // assert_eq!(1, ignored_users.len())
     }
 
-    // #[tokio::test]
-    // async fn client_runner() {
-    //     let session = crate::Session {
-    //         access_token: "12345".to_owned(),
-    //         user_id: UserId::try_from("@example:localhost").unwrap(),
-    //         device_id: "DEVICEID".to_owned(),
-    //     };
-    //     let homeserver = url::Url::parse(&mockito::server_url()).unwrap();
-    //     let client = AsyncClient::new(homeserver, Some(session)).unwrap();
+    #[tokio::test]
+    async fn room_creation() {
+        let session = crate::Session {
+            access_token: "12345".to_owned(),
+            user_id: UserId::try_from("@example:localhost").unwrap(),
+            device_id: "DEVICEID".to_owned(),
+        };
+        let homeserver = url::Url::parse(&mockito::server_url()).unwrap();
+        let client = AsyncClient::new(homeserver, Some(session)).unwrap();
 
-    //     let rid = RoomId::try_from("!roomid:room.com").unwrap();
-    //     let uid = UserId::try_from("@example:localhost").unwrap();
+        let mut response = EventBuilder::default()
+            .add_room_event_from_file("../test_data/events/member.json", RoomEvent::RoomMember)
+            .add_room_event_from_file(
+                "../test_data/events/power_levels.json",
+                RoomEvent::RoomPowerLevels,
+            )
+            .build_sync_response();
 
-    //     let mut bld = EventBuilder::default()
-    //         .add_room_event_from_file("../test_data/events/member.json", RoomEvent::RoomMember)
-    //         .add_room_event_from_file(
-    //             "../test_data/events/power_levels.json",
-    //             RoomEvent::RoomPowerLevels,
-    //         )
-    //         .build_client_runner(rid, uid);
+        client
+            .base_client
+            .receive_sync_response(&mut response)
+            .await
+            .unwrap();
+        let room_id = RoomId::try_from("!SVkFJHzfwvuaIEawgC:localhost").unwrap();
 
-    //     let cli = bld.set_client(client).to_client().await;
+        assert_eq!(
+            client.homeserver(),
+            &Url::parse(&mockito::server_url()).unwrap()
+        );
 
-    //     assert_eq!(
-    //         cli.homeserver(),
-    //         &Url::parse(&mockito::server_url()).unwrap()
-    //     );
-    // }
-
-    // #[tokio::test]
-    // async fn mock_runner() {
-    //     use std::convert::TryFrom;
-
-    //     let session = crate::Session {
-    //         access_token: "12345".to_owned(),
-    //         user_id: UserId::try_from("@example:localhost").unwrap(),
-    //         device_id: "DEVICEID".to_owned(),
-    //     };
-
-    //     let homeserver = url::Url::parse(&mockito::server_url()).unwrap();
-    //     let client = AsyncClient::new(homeserver, Some(session)).unwrap();
-
-    //     let mut bld = EventBuilder::default()
-    //         .add_room_event_from_file("../test_data/events/member.json", RoomEvent::RoomMember)
-    //         .add_room_event_from_file(
-    //             "../test_data/events/power_levels.json",
-    //             RoomEvent::RoomPowerLevels,
-    //         )
-    //         .build_mock_runner(
-    //             "GET",
-    //             mockito::Matcher::Regex(r"^/_matrix/client/r0/sync\?.*$".to_string()),
-    //         );
-
-    //     let cli = bld.set_client(client).to_client().await.unwrap();
-
-    //     assert_eq!(
-    //         cli.homeserver(),
-    //         &Url::parse(&mockito::server_url()).unwrap()
-    //     );
-    // }
+        let room = client.get_joined_room(&room_id).await;
+        assert!(room.is_some());
+    }
 
     #[tokio::test]
     async fn login_error() {