feat(ui, core, localization): Add Poll attachment interactor

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

@@ -1035,6 +1035,8 @@ class Channel {
     return _client.sendEvent(id!, type, event);
   }
 
+  final _pollLock = Lock();
+
   /// Send a message with a poll to this channel.
   ///
   /// Optionally provide a [messageText] to send a message along with the poll.
@@ -1043,7 +1045,7 @@ class Channel {
     String messageText = '',
   }) async {
     _checkInitialized();
-    final res = await _client.createPoll(poll);
+    final res = await _pollLock.synchronized(() => _client.createPoll(poll));
     return sendMessage(
       Message(
         text: messageText,
@@ -1056,13 +1058,109 @@ class Channel {
   /// Updates the [poll] in this channel.
   Future<UpdatePollResponse> updatePoll(Poll poll) {
     _checkInitialized();
-    return _client.updatePoll(poll);
+    return _pollLock.synchronized(() => _client.updatePoll(poll));
+  }
+
+  /// Deletes the given [poll] from this channel.
+  Future<EmptyResponse> deletePoll(Poll poll) {
+    _checkInitialized();
+    return _pollLock.synchronized(() => _client.deletePoll(poll.id));
+  }
+
+  /// Close the given [poll].
+  Future<UpdatePollResponse> closePoll(Poll poll) {
+    _checkInitialized();
+    return _pollLock.synchronized(() => _client.closePoll(poll.id));
   }
 
-  /// Deletes the poll with the given [pollId] from this channel.
-  Future<EmptyResponse> deletePoll(String pollId) {
+  /// Create a new poll option for the given [poll].
+  Future<CreatePollOptionResponse> createPollOption(
+    Poll poll,
+    PollOption option,
+  ) {
+    _checkInitialized();
+    return _pollLock.synchronized(
+      () => _client.createPollOption(poll.id, option),
+    );
+  }
+
+  final _pollVoteLock = Lock();
+
+  /// Cast a vote on the given [poll] with the given [option].
+  Future<CastPollVoteResponse> castPollVote(
+    Message message,
+    Poll poll,
+    PollOption option,
+  ) async {
     _checkInitialized();
-    return _client.deletePoll(pollId);
+
+    final optionId = option.id;
+    if (optionId == null) {
+      throw ArgumentError('Option id cannot be null');
+    }
+
+    return _pollVoteLock.synchronized(
+      () => _client.castPollVote(
+        message.id,
+        poll.id,
+        optionId: optionId,
+      ),
+    );
+  }
+
+  /// Add a new answer to the given [poll].
+  Future<CastPollVoteResponse> addPollAnswer(
+    Message message,
+    Poll poll, {
+    required String answerText,
+  }) {
+    _checkInitialized();
+    return _pollVoteLock.synchronized(
+      () => _client.addPollAnswer(
+        message.id,
+        poll.id,
+        answerText: answerText,
+      ),
+    );
+  }
+
+  /// Remove a vote on the given [poll] with the given [vote].
+  Future<RemovePollVoteResponse> removePollVote(
+    Message message,
+    Poll poll,
+    PollVote vote,
+  ) {
+    _checkInitialized();
+
+    final voteId = vote.id;
+    if (voteId == null) {
+      throw ArgumentError('Vote id cannot be null');
+    }
+
+    return _pollVoteLock.synchronized(
+      () => _client.removePollVote(
+        message.id,
+        poll.id,
+        voteId,
+      ),
+    );
+  }
+
+  /// Query the poll votes for the given [pollId] with the given [filter] and
+  /// [sort] options.
+  Future<QueryPollVotesResponse> queryPollVotes(
+    String pollId, {
+    Filter? filter,
+    List<SortOption>? sort,
+    PaginationParams pagination = const PaginationParams(),
+  }) {
+    _checkInitialized();
+    return _client.queryPollVotes(
+      pollId,
+      filter: filter,
+      sort: sort,
+      pagination: pagination,
+    );
   }
 
   /// Send a reaction to this channel.
@@ -2120,12 +2218,12 @@ class ChannelClientState {
 
       final oldPoll = pollMessage.poll;
 
-      final answers = oldPoll?.answers ?? eventPoll.answers;
+      final latestAnswers = oldPoll?.latestAnswers ?? eventPoll.latestAnswers;
       final ownVotesAndAnswers =
           oldPoll?.ownVotesAndAnswers ?? eventPoll.ownVotesAndAnswers;
 
       final poll = eventPoll.copyWith(
-        answers: answers,
+        latestAnswers: latestAnswers,
         ownVotesAndAnswers: ownVotesAndAnswers,
       );
 
@@ -2160,8 +2258,8 @@ class ChannelClientState {
 
       final oldPoll = pollMessage.poll;
 
-      final answers = <String, PollVote>{
-        for (final ans in oldPoll?.answers ?? []) ans.id: ans,
+      final latestAnswers = <String, PollVote>{
+        for (final ans in oldPoll?.latestAnswers ?? []) ans.id: ans,
         eventPollVote.id!: eventPollVote,
       };
 
@@ -2173,7 +2271,7 @@ class ChannelClientState {
       };
 
       final poll = eventPoll.copyWith(
-        answers: [...answers.values],
+        latestAnswers: [...latestAnswers.values],
         ownVotesAndAnswers: [...ownVotesAndAnswers.values],
       );
 
@@ -2192,7 +2290,7 @@ class ChannelClientState {
 
       final oldPoll = pollMessage.poll;
 
-      final answers = oldPoll?.answers ?? eventPoll.answers;
+      final latestAnswers = oldPoll?.latestAnswers ?? eventPoll.latestAnswers;
       final currentUserId = _channel.client.state.currentUser?.id;
       final ownVotesAndAnswers = <String, PollVote>{
         for (final vote in oldPoll?.ownVotesAndAnswers ?? []) vote.id: vote,
@@ -2201,7 +2299,7 @@ class ChannelClientState {
       };
 
       final poll = eventPoll.copyWith(
-        answers: answers,
+        latestAnswers: latestAnswers,
         ownVotesAndAnswers: [...ownVotesAndAnswers.values],
       );
 
@@ -2220,16 +2318,16 @@ class ChannelClientState {
 
       final oldPoll = pollMessage.poll;
 
-      final answers = <String, PollVote>{
-        for (final ans in oldPoll?.answers ?? []) ans.id: ans,
+      final latestAnswers = <String, PollVote>{
+        for (final ans in oldPoll?.latestAnswers ?? []) ans.id: ans,
       }..remove(eventPollVote.id);
 
       final ownVotesAndAnswers = <String, PollVote>{
         for (final vote in oldPoll?.ownVotesAndAnswers ?? []) vote.id: vote,
       }..remove(eventPollVote.id);
 
       final poll = eventPoll.copyWith(
-        answers: [...answers.values],
+        latestAnswers: [...latestAnswers.values],
         ownVotesAndAnswers: [...ownVotesAndAnswers.values],
       );
 
@@ -2248,13 +2346,13 @@ class ChannelClientState {
 
       final oldPoll = pollMessage.poll;
 
-      final answers = oldPoll?.answers ?? eventPoll.answers;
+      final latestAnswers = oldPoll?.latestAnswers ?? eventPoll.latestAnswers;
       final ownVotesAndAnswers = <String, PollVote>{
         for (final vote in oldPoll?.ownVotesAndAnswers ?? []) vote.id: vote,
       }..remove(eventPollVote.id);
 
       final poll = eventPoll.copyWith(
-        answers: answers,
+        latestAnswers: latestAnswers,
         ownVotesAndAnswers: [...ownVotesAndAnswers.values],
       );
 
@@ -2273,7 +2371,7 @@ class ChannelClientState {
 
       final oldPoll = pollMessage.poll;
 
-      final answers = oldPoll?.answers ?? eventPoll.answers;
+      final latestAnswers = oldPoll?.latestAnswers ?? eventPoll.latestAnswers;
       final currentUserId = _channel.client.state.currentUser?.id;
       final ownVotesAndAnswers = <String, PollVote>{
         for (final vote in oldPoll?.ownVotesAndAnswers ?? []) vote.id: vote,
@@ -2282,7 +2380,7 @@ class ChannelClientState {
       };
 
       final poll = eventPoll.copyWith(
-        answers: answers,
+        latestAnswers: latestAnswers,
         ownVotesAndAnswers: [...ownVotesAndAnswers.values],
       );
 
@@ -2338,6 +2436,8 @@ class ChannelClientState {
               threads[event.message?.parentId]
                   ?.firstWhereOrNull((e) => e.id == event.message?.id);
       final message = event.message!.copyWith(
+        poll: oldMessage?.poll,
+        pollId: oldMessage?.pollId,
         ownReactions: oldMessage?.ownReactions,
       );
       updateMessage(message);

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

@@ -41,15 +41,15 @@ class Poll extends Equatable {
     this.enforceUniqueVote = true,
     this.maxVotesAllowed,
     this.allowAnswers = false,
-    this.answers = const [],
+    this.latestAnswers = const [],
     this.answersCount = 0,
     this.allowUserSuggestedOptions = false,
     this.isClosed = false,
     DateTime? createdAt,
     DateTime? updatedAt,
     this.voteCountsByOption = const {},
     this.voteCount = 0,
-    this.votesByOption = const {},
+    this.latestVotesByOption = const {},
     this.createdById,
     this.createdBy,
     this.ownVotesAndAnswers = const [],
@@ -109,20 +109,20 @@ class Poll extends Equatable {
   final Map<String, int> voteCountsByOption;
 
   /// Map of latest votes by option.
-  @JsonKey(name: 'latest_votes_by_option', includeToJson: false)
-  final Map<String, List<PollVote>> votesByOption;
+  @JsonKey(includeToJson: false)
+  final Map<String, List<PollVote>> latestVotesByOption;
 
   /// List of votes received by the poll.
   ///
   /// Note: This does not include the answers provided by the users,
-  /// see [answers] for that.
-  List<PollVote> get votes => [
-        ...votesByOption.values.flattened.where((it) => !it.isAnswer),
+  /// see [latestAnswers] for that.
+  List<PollVote> get latestVotes => [
+        ...latestVotesByOption.values.flattened.where((it) => !it.isAnswer),
       ];
 
   /// List of latest answers received by the poll.
-  @JsonKey(name: 'latest_answers', includeToJson: false)
-  final List<PollVote> answers;
+  @JsonKey(includeToJson: false)
+  final List<PollVote> latestAnswers;
 
   /// List of votes casted by the current user.
   ///
@@ -134,6 +134,22 @@ class Poll extends Equatable {
   @JsonKey(includeToJson: false)
   final int voteCount;
 
+  /// List of votes casted by the current user.
+  ///
+  /// Note: This does not include the answers provided by the user,
+  /// see [ownAnswers] for that.
+  List<PollVote> get ownVotes => [
+        ...ownVotesAndAnswers.where((it) => !it.isAnswer),
+      ];
+
+  /// List of answers provided by the current user.
+  ///
+  /// Note: This does not include the votes casted by the user,
+  /// see [ownVotes] for that.
+  List<PollVote> get ownAnswers => [
+        ...ownVotesAndAnswers.where((it) => it.isAnswer),
+      ];
+
   /// The id of the user who created the poll.
   @JsonKey(includeToJson: false)
   final String? createdById;
@@ -173,8 +189,8 @@ class Poll extends Equatable {
     List<PollVote>? ownVotesAndAnswers,
     int? voteCount,
     int? answersCount,
-    Map<String, List<PollVote>>? votesByOption,
-    List<PollVote>? answers,
+    Map<String, List<PollVote>>? latestVotesByOption,
+    List<PollVote>? latestAnswers,
     String? createdById,
     User? createdBy,
     DateTime? createdAt,
@@ -199,8 +215,8 @@ class Poll extends Equatable {
         ownVotesAndAnswers: ownVotesAndAnswers ?? this.ownVotesAndAnswers,
         voteCount: voteCount ?? this.voteCount,
         answersCount: answersCount ?? this.answersCount,
-        votesByOption: votesByOption ?? this.votesByOption,
-        answers: answers ?? this.answers,
+        latestVotesByOption: latestVotesByOption ?? this.latestVotesByOption,
+        latestAnswers: latestAnswers ?? this.latestAnswers,
         createdById: createdById ?? this.createdById,
         createdBy: createdBy ?? this.createdBy,
         createdAt: createdAt ?? this.createdAt,
@@ -251,8 +267,8 @@ class Poll extends Equatable {
         ownVotesAndAnswers,
         voteCount,
         answersCount,
-        votesByOption,
-        answers,
+        latestVotesByOption,
+        latestAnswers,
         createdById,
         createdBy,
         createdAt,