feat(llc, core, ui, localization): threads v2

packages/stream_chat/lib/src/client/client.dart

@@ -196,7 +196,7 @@ class StreamChatClient {
 
   StreamSubscription<ConnectionStatus>? _connectionStatusSubscription;
 
-  final _eventController = BehaviorSubject<Event>();
+  final _eventController = PublishSubject<Event>();
 
   /// Stream of [Event] coming from [_ws] connection
   /// Listen to this or use the [on] method to filter specific event types
@@ -491,10 +491,12 @@ class StreamChatClient {
     final previousState = wsConnectionStatus;
     final currentState = _wsConnectionStatus = status;
 
-    handleEvent(Event(
-      type: EventType.connectionChanged,
-      online: status == ConnectionStatus.connected,
-    ));
+    if (previousState != currentState) {
+      handleEvent(Event(
+        type: EventType.connectionChanged,
+        online: status == ConnectionStatus.connected,
+      ));
+    }
 
     if (currentState == ConnectionStatus.connected &&
         previousState != ConnectionStatus.connected) {
@@ -1213,6 +1215,32 @@ class StreamChatClient {
         messageId,
       );
 
+  /// Mark the thread with [threadId] in the channel with [channelId] of type
+  /// [channelType] as read.
+  Future<EmptyResponse> markThreadRead(
+    String channelId,
+    String channelType,
+    String threadId,
+  ) =>
+      _chatApi.channel.markThreadRead(
+        channelId,
+        channelType,
+        threadId,
+      );
+
+  /// Mark the thread with [threadId] in the channel with [channelId] of type
+  /// [channelType] as unread.
+  Future<EmptyResponse> markThreadUnread(
+    String channelId,
+    String channelType,
+    String threadId,
+  ) =>
+      _chatApi.channel.markThreadUnread(
+        channelId,
+        channelType,
+        threadId,
+      );
+
   /// Creates a new Poll
   Future<CreatePollResponse> createPoll(Poll poll) =>
       _chatApi.polls.createPoll(poll);

packages/stream_chat/lib/src/core/api/channel_api.dart

@@ -337,6 +337,32 @@ class ChannelApi {
     return EmptyResponse.fromJson(response.data);
   }
 
+  /// Mark the provided [threadId] of the channel as read.
+  Future<EmptyResponse> markThreadRead(
+    String channelId,
+    String channelType,
+    String threadId,
+  ) async {
+    final response = await _client.post(
+      '${_getChannelUrl(channelId, channelType)}/read',
+      data: {'thread_id': threadId},
+    );
+    return EmptyResponse.fromJson(response.data);
+  }
+
+  /// Mark the provided [threadId] of the channel as unread.
+  Future<EmptyResponse> markThreadUnread(
+    String channelId,
+    String channelType,
+    String threadId,
+  ) async {
+    final response = await _client.post(
+      '${_getChannelUrl(channelId, channelType)}/unread',
+      data: {'thread_id': threadId},
+    );
+    return EmptyResponse.fromJson(response.data);
+  }
+
   /// Stop watching the channel
   Future<EmptyResponse> stopWatching(
     String channelId,

packages/stream_chat/lib/src/core/api/requests.dart

@@ -215,11 +215,17 @@ class PartialUpdateUserRequest extends Equatable {
 class ThreadOptions extends Equatable {
   /// {@macro threadOptions}
   const ThreadOptions({
+    this.watch = true,
     this.replyLimit = 2,
     this.participantLimit = 100,
     this.memberLimit = 100,
   });
 
+  /// If true, the client will watch for changes in the thread.
+  ///
+  /// Defaults to true.
+  final bool watch;
+
   /// The number of most recent replies to return per thread.
   ///
   /// Defaults to 2.
@@ -239,5 +245,5 @@ class ThreadOptions extends Equatable {
   Map<String, dynamic> toJson() => _$ThreadOptionsToJson(this);
 
   @override
-  List<Object?> get props => [replyLimit, participantLimit, memberLimit];
+  List<Object?> get props => [watch, replyLimit, participantLimit, memberLimit];
 }

packages/stream_chat/lib/src/core/models/channel_model.dart

@@ -1,5 +1,6 @@
 import 'package:json_annotation/json_annotation.dart';
 import 'package:stream_chat/src/core/models/channel_config.dart';
+import 'package:stream_chat/src/core/models/member.dart';
 import 'package:stream_chat/src/core/models/user.dart';
 import 'package:stream_chat/src/core/util/serializer.dart';
 
@@ -22,6 +23,7 @@ class ChannelModel {
     DateTime? updatedAt,
     this.deletedAt,
     this.memberCount = 0,
+    this.members,
     Map<String, Object?> extraData = const {},
     this.team,
     this.cooldown = 0,
@@ -101,6 +103,10 @@ class ChannelModel {
   @JsonKey(includeToJson: false)
   final int memberCount;
 
+  /// The list of this channel members
+  @JsonKey(includeToJson: false)
+  final List<Member>? members;
+
   /// The number of seconds in a cooldown
   @JsonKey(includeIfNull: false)
   final int cooldown;
@@ -143,13 +149,13 @@ class ChannelModel {
     'updated_at',
     'deleted_at',
     'member_count',
+    'members',
     'team',
     'cooldown',
   ];
 
   /// Shortcut for channel name
-  String get name =>
-      extraData.containsKey('name') ? extraData['name']! as String : cid;
+  String? get name => extraData['name'] as String?;
 
   /// Serialize to json
   Map<String, dynamic> toJson() => Serializer.moveFromExtraDataToRoot(
@@ -170,6 +176,7 @@ class ChannelModel {
     DateTime? updatedAt,
     DateTime? deletedAt,
     int? memberCount,
+    List<Member>? members,
     Map<String, Object?>? extraData,
     String? team,
     int? cooldown,
@@ -190,6 +197,7 @@ class ChannelModel {
         updatedAt: updatedAt ?? this.updatedAt,
         deletedAt: deletedAt ?? this.deletedAt,
         memberCount: memberCount ?? this.memberCount,
+        members: members ?? this.members,
         extraData: extraData ?? this.extraData,
         team: team ?? this.team,
         cooldown: cooldown ?? this.cooldown,
@@ -220,6 +228,7 @@ class ChannelModel {
       updatedAt: other.updatedAt,
       deletedAt: other.deletedAt,
       memberCount: other.memberCount,
+      members: other.members,
       extraData: other.extraData,
       team: other.team,
       cooldown: other.cooldown,