feat: added waitForSync method

lib/src/client.dart

@@ -587,8 +587,7 @@ class Client extends MatrixApi {
 
     if (waitForSync && getRoomById(roomId) == null) {
       // Wait for room actually appears in sync
-      await onSync.stream
-          .firstWhere((sync) => sync.rooms?.join?.containsKey(roomId) ?? false);
+      await waitForRoomInSync(roomId, join: true);
     }
 
     await Room(id: roomId, client: this).addToDirectChat(mxid);
@@ -632,13 +631,29 @@ class Client extends MatrixApi {
     if (waitForSync) {
       if (getRoomById(roomId) == null) {
         // Wait for room actually appears in sync
-        await onSync.stream.firstWhere(
-            (sync) => sync.rooms?.join?.containsKey(roomId) ?? false);
+        await waitForRoomInSync(roomId, join: true);
       }
     }
     return roomId;
   }
 
+  /// Wait for the room to appear into the enabled section of the room sync.
+  /// By default, the function will listen for room in invite, join and leave
+  /// sections of the sync.
+  Future<SyncUpdate> waitForRoomInSync(String roomId,
+      {bool join = false, bool invite = false, bool leave = false}) async {
+    if (!join && !invite && !leave) {
+      join = true;
+      invite = true;
+      leave = true;
+    }
+
+    return await onSync.stream.firstWhere((sync) =>
+        invite && (sync.rooms?.invite?.containsKey(roomId) ?? false) ||
+        join && (sync.rooms?.join?.containsKey(roomId) ?? false) ||
+        leave && (sync.rooms?.leave?.containsKey(roomId) ?? false));
+  }
+
   /// Checks if the given user has encryption keys. May query keys from the
   /// server to answer this.
   Future<bool> userOwnsEncryptionKeys(String userId) async {
@@ -657,16 +672,16 @@ class Client extends MatrixApi {
   /// room as a space with `room.toSpace()`.
   ///
   /// https://github.com/matrix-org/matrix-doc/blob/matthew/msc1772/proposals/1772-groups-as-rooms.md
-  Future<String> createSpace({
-    String? name,
+  Future<String> createSpace(
+      {String? name,
       String? topic,
       Visibility visibility = Visibility.public,
       String? spaceAliasName,
       List<String>? invite,
       List<Invite3pid>? invite3pid,
       String? roomVersion,
-  }) =>
-      createRoom(
+      bool waitForSync = false}) async {
+    final id = await createRoom(
       name: name,
       topic: topic,
       visibility: visibility,
@@ -678,6 +693,13 @@ class Client extends MatrixApi {
       roomVersion: roomVersion,
     );
 
+    if (waitForSync) {
+      await waitForRoomInSync(id, join: true);
+    }
+
+    return id;
+  }
+
   /// Returns the user's own displayname and avatar url. In Matrix it is possible that
   /// one user can have different displaynames and avatar urls in different rooms. So
   /// this endpoint first checks if the profile is the same in all rooms. If not, the

lib/src/room.dart

@@ -519,6 +519,12 @@ class Room {
   /// in muted rooms, use [hasNewMessages].
   bool get isUnread => notificationCount > 0 || markedUnread;
 
+  /// Wait for the room to appear in join, leave or invited section of the
+  /// sync.
+  Future<SyncUpdate> get waitForSync async {
+    return await client.waitForRoomInSync(id);
+  }
+
   /// Sets an unread flag manually for this room. This changes the local account
   /// data model before syncing it to make sure
   /// this works if there is no connection to the homeserver. This does **not**