feat: user list

Signed-off-by: Sahil Kumar <[email protected]>
2020-11-17 21:30:05 +05:30
parent a8a5e5dfdf
commit cd8ca90052
3 changed files with 583 additions and 0 deletions
@@ -0,0 +1,114 @@
+import 'package:flutter/material.dart';
+import 'package:rxdart/rxdart.dart';
+import 'package:stream_chat/stream_chat.dart';
+
+import 'stream_chat.dart';
+
+/// Widget dedicated to the management of a users list with pagination
+class UsersBloc extends StatefulWidget {
+  /// The widget child
+  final Widget child;
+
+  /// Instantiate a new UsersBloc
+  const UsersBloc({
+    Key key,
+    @required this.child,
+  }) : super(key: key);
+
+  @override
+  UsersBlocState createState() => UsersBlocState();
+
+  /// Use this method to get the current [UsersBlocState] instance
+  static UsersBlocState of(BuildContext context) {
+    UsersBlocState state;
+
+    state = context.findAncestorStateOfType<UsersBlocState>();
+
+    if (state == null) {
+      throw Exception('You must have a UsersBloc widget as ancestor');
+    }
+
+    return state;
+  }
+}
+
+/// The current state of the [UsersBloc]
+class UsersBlocState extends State<UsersBloc>
+    with AutomaticKeepAliveClientMixin {
+  /// The current users list
+  List<User> get users => _usersController.value;
+
+  /// The current users list as a stream
+  Stream<List<User>> get usersStream => _usersController.stream;
+
+  final BehaviorSubject<List<User>> _usersController = BehaviorSubject();
+
+  final BehaviorSubject<bool> _queryUsersLoadingController =
+      BehaviorSubject.seeded(false);
+
+  /// The stream notifying the state of queryUsers call
+  Stream<bool> get queryUsersLoading => _queryUsersLoadingController.stream;
+
+  /// Calls [Client.queryUsers] updating [queryUsersLoading] stream
+  Future<void> queryUsers({
+    Map<String, dynamic> filter,
+    List<SortOption> sort,
+    Map<String, dynamic> options,
+    PaginationParams pagination,
+  }) async {
+    final client = StreamChat.of(context).client;
+
+    if (client.state?.user == null ||
+        _queryUsersLoadingController.value == true) {
+      return;
+    }
+    _queryUsersLoadingController.add(true);
+    try {
+      final clear = pagination == null ||
+          pagination.offset == null ||
+          pagination.offset == 0;
+
+      final oldUsers = List<User>.from(users ?? []);
+
+      final usersResponse = await client.queryUsers(
+        filter: filter,
+        sort: sort,
+        options: options,
+        pagination: pagination,
+      );
+
+      if (clear) {
+        _usersController.add(usersResponse.users);
+      } else {
+        final temp = oldUsers + usersResponse.users;
+        _usersController.add(temp);
+      }
+
+      _queryUsersLoadingController.add(false);
+    } catch (err, stackTrace) {
+      _queryUsersLoadingController.addError(err, stackTrace);
+    }
+  }
+
+  @override
+  void initState() {
+    super.initState();
+    final client = StreamChat.of(context).client;
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    super.build(context);
+    return widget.child;
+  }
+
+  @override
+  void dispose() {
+    _usersController.close();
+    _queryUsersLoadingController.close();
+    super.dispose();
+  }
+
+  @override
+  bool get wantKeepAlive => true;
+}