Pbe 5423 implement unread endpoint (#175)

* Implement IStreamChatClient.GetLatestUnreadCounts()

* Fix breaking on timeout

* Fix name + add integration test

* Improve naming

* Improve names + add code example

Author: sierpinskid

Assets/Plugins/StreamChat/Core/IStreamChatClient.cs

@@ -252,5 +252,11 @@ Task<StreamDeleteChannelsResponse> DeleteMultipleChannelsAsync(IEnumerable<IStre
         Task DisconnectUserAsync();
 
         bool IsLocalUser(IStreamUser messageUser);
+
+        /// <summary>
+        /// Get current state of unread counts for the user. Unread counts mean how many messages and threads are unread in the channels and threads the user is participating in
+        /// </summary>
+        /// <returns><see cref="CurrentUnreadCounts"/></returns>
+        Task<CurrentUnreadCounts> GetLatestUnreadCountsAsync();
     }
 }

Assets/Plugins/StreamChat/Core/InternalDTO/Client.meta

@@ -0,0 +1,14 @@
+namespace StreamChat.Core.InternalDTO.Extra
+{
+    internal class UnreadCountsChannelInternalDTO
+    {
+        [Newtonsoft.Json.JsonProperty("channel_id", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public string ChannelId { get; set; }
+
+        [Newtonsoft.Json.JsonProperty("last_read", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public System.DateTimeOffset LastRead { get; set; }
+
+        [Newtonsoft.Json.JsonProperty("unread_count", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public int UnreadCount { get; set; }
+    }
+}

Assets/Plugins/StreamChat/Core/InternalDTO/Extra.meta

@@ -0,0 +1,14 @@
+namespace StreamChat.Core.InternalDTO.Extra
+{
+    internal class UnreadCountsChannelTypeInternalDTO
+    {
+        [Newtonsoft.Json.JsonProperty("channel_count", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public int ChannelCount { get; set; }
+
+        [Newtonsoft.Json.JsonProperty("channel_type", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public string ChannelType { get; set; }
+
+        [Newtonsoft.Json.JsonProperty("unread_count", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public int UnreadCount { get; set; }
+    }
+}

Assets/Plugins/StreamChat/Core/InternalDTO/Extra/UnreadCountsChannelInternalDTO.cs

@@ -0,0 +1,17 @@
+namespace StreamChat.Core.InternalDTO.Extra
+{
+    internal class UnreadCountsThreadInternalDTO
+    {
+        [Newtonsoft.Json.JsonProperty("last_read", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public System.DateTimeOffset LastRead { get; set; }
+
+        [Newtonsoft.Json.JsonProperty("last_read_message_id", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public string LastReadMessageId { get; set; }
+
+        [Newtonsoft.Json.JsonProperty("parent_message_id", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public string ParentMessageId { get; set; }
+
+        [Newtonsoft.Json.JsonProperty("unread_count", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public int UnreadCount { get; set; }
+    }
+}

Assets/Plugins/StreamChat/Core/InternalDTO/Extra/UnreadCountsChannelInternalDTO.cs.meta

@@ -0,0 +1,26 @@
+namespace StreamChat.Core.InternalDTO.Extra
+{
+    internal class WrappedUnreadCountsResponseInternalDTO
+    {
+        [Newtonsoft.Json.JsonProperty("channel_type", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public System.Collections.Generic.List<UnreadCountsChannelTypeInternalDTO> ChannelType { get; set; } = new System.Collections.Generic.List<UnreadCountsChannelTypeInternalDTO>();
+
+        [Newtonsoft.Json.JsonProperty("channels", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public System.Collections.Generic.List<UnreadCountsChannelInternalDTO> Channels { get; set; } = new System.Collections.Generic.List<UnreadCountsChannelInternalDTO>();
+
+        /// <summary>
+        /// Duration of the request in milliseconds
+        /// </summary>
+        [Newtonsoft.Json.JsonProperty("duration", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public string Duration { get; set; }
+
+        [Newtonsoft.Json.JsonProperty("threads", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public System.Collections.Generic.List<UnreadCountsThreadInternalDTO> Threads { get; set; } = new System.Collections.Generic.List<UnreadCountsThreadInternalDTO>();
+
+        [Newtonsoft.Json.JsonProperty("total_unread_count", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public int TotalUnreadCount { get; set; }
+
+        [Newtonsoft.Json.JsonProperty("total_unread_threads_count", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
+        public int TotalUnreadThreadsCount { get; set; }
+    }
+}