Add stateful client interface for polls

Author: sierpinskid

Assets/Plugins/StreamChat/Core/IStreamChatClient.cs

@@ -108,6 +108,11 @@ public interface IStreamChatClient : IDisposable, IStreamChatClientEventsListene
         /// </summary>
         IStreamChatLowLevelClient LowLevelClient { get; }
 
+        /// <summary>
+        /// Polls API for creating, retrieving, and querying polls
+        /// </summary>
+        IStreamPollsApi Polls { get; }
+
         /// <summary>
         /// Connect user to Stream Chat server.
         /// User authentication credentials:

Assets/Plugins/StreamChat/Core/IStreamPollsApi.cs

@@ -0,0 +1,35 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using StreamChat.Core.Requests;
+using StreamChat.Core.StatefulModels;
+
+namespace StreamChat.Core
+{
+    /// <summary>
+    /// Polls API for creating, retrieving, and querying polls
+    /// </summary>
+    public interface IStreamPollsApi
+    {
+        /// <summary>
+        /// Create a new poll
+        /// </summary>
+        /// <param name="createRequest">Request with poll creation data</param>
+        /// <returns>The created poll</returns>
+        Task<IStreamPoll> CreatePollAsync(StreamCreatePollRequest createRequest);
+
+        /// <summary>
+        /// Get a poll by ID
+        /// </summary>
+        /// <param name="pollId">The poll ID</param>
+        /// <returns>The poll with the specified ID</returns>
+        Task<IStreamPoll> GetPollAsync(string pollId);
+
+        /// <summary>
+        /// Query polls based on filters
+        /// </summary>
+        /// <param name="queryRequest">Request with query filters and parameters</param>
+        /// <returns>List of polls matching the query</returns>
+        Task<IEnumerable<IStreamPoll>> QueryPollsAsync(StreamQueryPollsRequest queryRequest);
+    }
+}
+

Assets/Plugins/StreamChat/Core/IStreamPollsApi.cs.meta

@@ -0,0 +1,39 @@
+using System;
+
+namespace StreamChat.Core.QueryBuilders.Sort
+{
+    /// <summary>
+    /// Sort object for Poll query
+    /// </summary>
+    public sealed class PollsSortObject : QuerySort<PollsSortObject, PollSortFieldName>
+    {
+        protected override PollsSortObject Instance => this;
+
+        protected override string ToUnderlyingFieldName(PollSortFieldName fieldName)
+        {
+            switch (fieldName)
+            {
+                case PollSortFieldName.CreatedAt: return "created_at";
+                case PollSortFieldName.UpdatedAt: return "updated_at";
+                case PollSortFieldName.Id: return "id";
+                case PollSortFieldName.Name: return "name";
+                case PollSortFieldName.VoteCount: return "vote_count";
+                default:
+                    throw new ArgumentOutOfRangeException(nameof(fieldName), fieldName, null);
+            }
+        }
+    }
+
+    /// <summary>
+    /// Sort field names for polls
+    /// </summary>
+    public enum PollSortFieldName
+    {
+        CreatedAt,
+        UpdatedAt,
+        Id,
+        Name,
+        VoteCount
+    }
+}
+

Assets/Plugins/StreamChat/Core/QueryBuilders/Sort/PollsSortObject.cs

@@ -0,0 +1,99 @@
+using System.Collections.Generic;
+using StreamChat.Core.Helpers;
+using StreamChat.Core.InternalDTO.Models;
+using StreamChat.Core.InternalDTO.Requests;
+using StreamChat.Core.LowLevelClient;
+using StreamChat.Core.LowLevelClient.Models;
+
+namespace StreamChat.Core.Requests
+{
+    /// <summary>
+    /// Request to create a poll
+    /// </summary>
+    public class StreamCreatePollRequest : ISavableTo<CreatePollRequestInternalDTO>
+    {
+        /// <summary>
+        /// Custom data for the poll
+        /// </summary>
+        public Dictionary<string, object> Custom { get; set; }
+
+        /// <summary>
+        /// Whether to allow answers
+        /// </summary>
+        public bool? AllowAnswers { get; set; }
+
+        /// <summary>
+        /// Whether to allow user suggested options
+        /// </summary>
+        public bool? AllowUserSuggestedOptions { get; set; }
+
+        /// <summary>
+        /// Poll description
+        /// </summary>
+        public string Description { get; set; }
+
+        /// <summary>
+        /// Whether to enforce unique votes
+        /// </summary>
+        public bool? EnforceUniqueVote { get; set; }
+
+        /// <summary>
+        /// Poll unique ID
+        /// </summary>
+        public string Id { get; set; }
+
+        /// <summary>
+        /// Whether the poll is closed
+        /// </summary>
+        public bool? IsClosed { get; set; }
+
+        /// <summary>
+        /// Maximum number of votes allowed per user
+        /// </summary>
+        public int? MaxVotesAllowed { get; set; }
+
+        /// <summary>
+        /// Poll name
+        /// </summary>
+        public string Name { get; set; }
+
+        /// <summary>
+        /// Poll options
+        /// </summary>
+        public List<StreamPollOptionRequest> Options { get; set; }
+
+        /// <summary>
+        /// Voting visibility setting
+        /// </summary>
+        public VotingVisibility? VotingVisibility { get; set; }
+
+        CreatePollRequestInternalDTO ISavableTo<CreatePollRequestInternalDTO>.SaveToDto()
+        {
+            var dto = new CreatePollRequestInternalDTO
+            {
+                Custom = Custom,
+                AllowAnswers = AllowAnswers,
+                AllowUserSuggestedOptions = AllowUserSuggestedOptions,
+                Description = Description,
+                EnforceUniqueVote = EnforceUniqueVote,
+                Id = Id,
+                IsClosed = IsClosed,
+                MaxVotesAllowed = MaxVotesAllowed,
+                Name = Name,
+                VotingVisibility = VotingVisibility.HasValue ? (string)VotingVisibility.Value : null
+            };
+
+            if (Options != null && Options.Count > 0)
+            {
+                dto.Options = new List<PollOptionInputInternalDTO>();
+                foreach (var option in Options)
+                {
+                    dto.Options.Add(option.TrySaveToDto<PollOptionInputInternalDTO>());
+                }
+            }
+
+            return dto;
+        }
+    }
+}
+

Assets/Plugins/StreamChat/Core/QueryBuilders/Sort/PollsSortObject.cs.meta

@@ -0,0 +1,41 @@
+using System.Collections.Generic;
+using StreamChat.Core.InternalDTO.Models;
+using StreamChat.Core.InternalDTO.Requests;
+using StreamChat.Core.LowLevelClient;
+
+namespace StreamChat.Core.Requests
+{
+    /// <summary>
+    /// Request to create a poll option
+    /// </summary>
+    public class StreamPollOptionRequest : ISavableTo<PollOptionRequestInternalDTO>, ISavableTo<PollOptionInputInternalDTO>
+    {
+        /// <summary>
+        /// Custom data for the option
+        /// </summary>
+        public Dictionary<string, object> Custom { get; set; }
+
+        /// <summary>
+        /// Option text
+        /// </summary>
+        public string Text { get; set; }
+
+        PollOptionRequestInternalDTO ISavableTo<PollOptionRequestInternalDTO>.SaveToDto()
+        {
+            return new PollOptionRequestInternalDTO
+            {
+                Custom = Custom,
+                Text = Text
+            };
+        }
+
+        PollOptionInputInternalDTO ISavableTo<PollOptionInputInternalDTO>.SaveToDto()
+        {
+            return new PollOptionInputInternalDTO
+            {
+                Custom = Custom,
+                Text = Text
+            };
+        }
+    }
+}

Assets/Plugins/StreamChat/Core/Requests/StreamCreatePollRequest.cs

@@ -0,0 +1,47 @@
+using System.Collections.Generic;
+using System.Linq;
+using StreamChat.Core.InternalDTO.Requests;
+using StreamChat.Core.LowLevelClient;
+using StreamChat.Core.QueryBuilders.Filters;
+using StreamChat.Core.QueryBuilders.Sort;
+
+namespace StreamChat.Core.Requests
+{
+    /// <summary>
+    /// Request to query polls
+    /// </summary>
+    public class StreamQueryPollsRequest : ISavableTo<QueryPollsRequestInternalDTO>
+    {
+        /// <summary>
+        /// Filter conditions
+        /// </summary>
+        public IEnumerable<IFieldFilterRule> Filter { get; set; }
+
+        /// <summary>
+        /// Number of results to return
+        /// </summary>
+        public int? Limit { get; set; }
+
+        public string Next { get; set; }
+
+        public string Prev { get; set; }
+
+        /// <summary>
+        /// Sort parameters
+        /// </summary>
+        public PollsSortObject Sort { get; set; }
+
+        QueryPollsRequestInternalDTO ISavableTo<QueryPollsRequestInternalDTO>.SaveToDto()
+        {
+            return new QueryPollsRequestInternalDTO
+            {
+                Filter = Filter?.Select(_ => _.GenerateFilterEntry()).ToDictionary(x => x.Key, x => x.Value),
+                Limit = Limit,
+                Next = Next,
+                Prev = Prev,
+                Sort = Sort?.ToSortParamRequestList()
+            };
+        }
+    }
+}
+