Feature/add invites support (#126)

* Implement invites + Add invites mechanics to the sample project

* Add InviteMembersAsync overload + simplify sampel project implementation + add code samples + refactor unit tester to support secondary client

Author: sierpinskid

Assets/Plugins/StreamChat/Core/IStreamChatClient.cs

@@ -42,6 +42,21 @@ public interface IStreamChatClient : IDisposable, IStreamChatClientEventsListene
         /// Channel was deleted
         /// </summary>
         event ChannelDeleteHandler ChannelDeleted;
+        
+        /// <summary>
+        /// Invite to a <see cref="IStreamChannel"/> was received
+        /// </summary>
+        event ChannelInviteHandler ChannelInviteReceived;
+        
+        /// <summary>
+        /// Invite to a <see cref="IStreamChannel"/> was accepted
+        /// </summary>
+        event ChannelInviteHandler ChannelInviteAccepted;
+        
+        /// <summary>
+        /// Invite to a <see cref="IStreamChannel"/> was rejected
+        /// </summary>
+        event ChannelInviteHandler ChannelInviteRejected;
 
         /// <summary>
         /// Current connection state

Assets/Plugins/StreamChat/Core/State/StreamStatefulModelBase.cs

@@ -35,6 +35,8 @@ internal StreamStatefulModelBase(string uniqueId, ICacheRepository<TStatefulMode
             InternalUniqueId = uniqueId;
             Repository.Track(Self);
         }
+        
+        protected Dictionary<string, object> GetInternalAdditionalPropertiesDictionary() => _additionalProperties; 
 
         protected abstract string InternalUniqueId { get; set; }
 
@@ -49,6 +51,8 @@ protected void LoadAdditionalProperties(Dictionary<string, object> additionalPro
         {
             //StreamTodo: investigate if there's a case we don't want to clear here
             //Without clear channel full update or partial update unset won't work because we'll ignore that WS sent channel without custom data
+            
+            //StreamTodo: 2, wrap into _customData.Sync(additionalProperties); instead of having a collection here
 
             _additionalProperties.Clear();
             foreach (var keyValuePair in additionalProperties)

Assets/Plugins/StreamChat/Core/StatefulModels/IStreamChannel.cs

@@ -514,5 +514,41 @@ Task TruncateAsync(DateTimeOffset? truncatedAt = default, string systemMessage =
         /// Stop being a member (<see cref="IStreamChannelMember"/>) of this channel. Only possible if local user has the `Leave Own Channel` permission
         /// </summary>
         Task LeaveAsMemberChannelAsync();
+        
+        /// <summary>
+        /// Invite new members to this channel.
+        /// </summary>
+        /// <remarks>https://getstream.io/chat/docs/unity/channel_invites/?language=unity/</remarks>
+        Task InviteMembersAsync(IEnumerable<string> userIds);
+        
+        /// <summary>
+        /// Invite new members to this channel.
+        /// </summary>
+        /// <remarks>https://getstream.io/chat/docs/unity/channel_invites/?language=unity/</remarks>
+        Task InviteMembersAsync(params string[] userIds);
+
+        /// <summary>
+        /// Invite new members to this channel.
+        /// </summary>
+        /// <remarks>https://getstream.io/chat/docs/unity/channel_invites/?language=unity/</remarks>
+        Task InviteMembersAsync(IEnumerable<IStreamUser> users);
+        
+        /// <summary>
+        /// Invite new members to this channel.
+        /// </summary>
+        /// <remarks>https://getstream.io/chat/docs/unity/channel_invites/?language=unity/</remarks>
+        Task InviteMembersAsync(params IStreamUser[] users);
+
+        /// <summary>
+        /// Accept an invite to this channel
+        /// </summary>
+        /// <remarks>https://getstream.io/chat/docs/unity/channel_invites/?language=unity/#accepting-an-invite</remarks>
+        Task AcceptInviteAsync();
+
+        /// <summary>
+        /// Reject an invite to this channel
+        /// </summary>
+        /// <remarks>https://getstream.io/chat/docs/unity/channel_invites/?language=unity/#rejecting-an-invite</remarks>
+        Task RejectInviteAsync();
     }
 }

Assets/Plugins/StreamChat/Core/StatefulModels/StreamChannel.cs

@@ -222,14 +222,15 @@ public async Task LoadOlderMessagesAsync()
         }
 
         //StreamTodo: LoadNewerMessages? This would only make sense if we would start somewhere in the history. Maybe its possible with search? You jump in to past message and scroll to load newer
-        public async Task UpdateOverwriteAsync() //StreamTodo: NOT IMPLEMENTED
+        public Task UpdateOverwriteAsync() //StreamTodo: NOT IMPLEMENTED
         {
-            var response = await LowLevelClient.InternalChannelApi.UpdateChannelAsync(Type, Id,
-                new UpdateChannelRequestInternalDTO
-                {
-                });
+            throw new NotImplementedException();
+            // var response = await LowLevelClient.InternalChannelApi.UpdateChannelAsync(Type, Id,
+            //     new UpdateChannelRequestInternalDTO
+            //     {
+            //     });
 
-            Cache.TryCreateOrUpdate(response.Channel);
+            //Cache.TryCreateOrUpdate(response.Channel);
         }
 
         public async Task UpdatePartialAsync(IDictionary<string, object> setFields = null,
@@ -451,6 +452,69 @@ public async Task RemoveMembersAsync(IEnumerable<string> userIds)
 
         public Task LeaveAsMemberChannelAsync() => RemoveMembersAsync(Client.LocalUserData.User);
 
+        public async Task InviteMembersAsync(IEnumerable<string> userIds)
+        {
+            StreamAsserts.AssertNotNull(userIds, nameof(userIds));
+
+            var invites = new List<ChannelMemberRequestInternalDTO>();
+            foreach (var uid in userIds)
+            {
+                invites.Add(new ChannelMemberRequestInternalDTO
+                {
+                    UserId = uid
+                });
+            }
+
+            var updateRequest = GetUpdateRequestWithCurrentData();
+            updateRequest.Invites = invites;
+            
+            var response = await LowLevelClient.InternalChannelApi.UpdateChannelAsync(Type, Id, updateRequest);
+
+            Cache.TryCreateOrUpdate(response.Channel);
+            foreach (var member in response.Members)
+            {
+                Cache.TryCreateOrUpdate(member);
+            }
+        }
+
+        public Task InviteMembersAsync(params string[] userIds) => InviteMembersAsync(userIds as IEnumerable<string>);
+
+        public Task InviteMembersAsync(IEnumerable<IStreamUser> users)
+        {
+            StreamAsserts.AssertNotNull(users, nameof(users));
+            return InviteMembersAsync(users.Select(_ => _.Id));
+        }
+        
+        public Task InviteMembersAsync(params IStreamUser[] users) => InviteMembersAsync(users as IEnumerable<IStreamUser>);
+
+        public async Task AcceptInviteAsync()
+        {
+            var updateRequest = GetUpdateRequestWithCurrentData();
+            updateRequest.AcceptInvite = true;
+            
+            var response = await LowLevelClient.InternalChannelApi.UpdateChannelAsync(Type, Id, updateRequest);
+
+            Cache.TryCreateOrUpdate(response.Channel);
+            foreach (var member in response.Members)
+            {
+                Cache.TryCreateOrUpdate(member);
+            }
+        }
+
+        public async Task RejectInviteAsync()
+        {
+            var updateRequest = GetUpdateRequestWithCurrentData();
+            updateRequest.RejectInvite = true;
+            
+            var response = await LowLevelClient.InternalChannelApi.UpdateChannelAsync(Type, Id, updateRequest);
+
+            Cache.TryCreateOrUpdate(response.Channel);
+            foreach (var member in response.Members)
+            {
+                Cache.TryCreateOrUpdate(member);
+            }
+        }
+
         //StreamTodo: write test
         public async Task MuteChannelAsync(int? milliseconds = default)
         {
@@ -939,5 +1003,18 @@ private void SortMessagesByCreatedAt()
         {
             _messages.Sort((msg1, msg2) => msg1.CreatedAt.CompareTo(msg2.CreatedAt));
         }
+        
+        private UpdateChannelRequestInternalDTO GetUpdateRequestWithCurrentData() => new UpdateChannelRequestInternalDTO
+        {
+            Data = new ChannelRequestInternalDTO
+            {
+                AutoTranslationEnabled = AutoTranslationEnabled,
+                AutoTranslationLanguage = AutoTranslationLanguage,
+                Disabled = Disabled,
+                Frozen = Frozen,
+                AdditionalProperties = GetInternalAdditionalPropertiesDictionary(),
+                Name = Name
+            },
+        };
     }
 }

Assets/Plugins/StreamChat/Core/StreamChatClient.cs

@@ -46,7 +46,9 @@ namespace StreamChat.Core
     /// </summary>
     public delegate void ChannelDeleteHandler(string channelCid, string channelId, ChannelType channelType);
 
-    //StreamTodo: Handle restoring state after lost connection + include Unity Network Monitor
+    //StreamTodo: Handle restoring state after lost connection
+
+    public delegate void ChannelInviteHandler(IStreamChannel channel, IStreamUser invitee);
 
     public sealed class StreamChatClient : IStreamChatClient
     {
@@ -60,6 +62,10 @@ public sealed class StreamChatClient : IStreamChatClient
 
         public event ChannelDeleteHandler ChannelDeleted;
 
+        public event ChannelInviteHandler ChannelInviteReceived;
+        public event ChannelInviteHandler ChannelInviteAccepted;
+        public event ChannelInviteHandler ChannelInviteRejected;
+
         public const int QueryUsersLimitMaxValue = 30;
         public const int QueryUsersOffsetMaxValue = 1000;
 
@@ -844,19 +850,28 @@ private void OnRemovedFromChannelNotification(
 //StreamTodo: IMPLEMENT
         }
 
-        private void OnInvitedNotification(NotificationInvitedEventInternalDTO obj)
+        private void OnInvitedNotification(NotificationInvitedEventInternalDTO eventDto)
         {
-//StreamTodo: IMPLEMENT
+            var channel = _cache.TryCreateOrUpdate(eventDto.Channel);
+            var user = _cache.TryCreateOrUpdate(eventDto.User);
+
+            ChannelInviteReceived?.Invoke(channel, user);
         }
 
-        private void OnInviteAcceptedNotification(NotificationInviteAcceptedEventInternalDTO obj)
+        private void OnInviteAcceptedNotification(NotificationInviteAcceptedEventInternalDTO eventDto)
         {
-//StreamTodo: IMPLEMENT
+            var channel = _cache.TryCreateOrUpdate(eventDto.Channel);
+            var user = _cache.TryCreateOrUpdate(eventDto.User);
+
+            ChannelInviteAccepted?.Invoke(channel, user);
         }
 
-        private void OnInviteRejectedNotification(NotificationInviteRejectedEventInternalDTO obj)
+        private void OnInviteRejectedNotification(NotificationInviteRejectedEventInternalDTO eventDto)
         {
-//StreamTodo: IMPLEMENT
+            var channel = _cache.TryCreateOrUpdate(eventDto.Channel);
+            var user = _cache.TryCreateOrUpdate(eventDto.User);
+
+            ChannelInviteRejected?.Invoke(channel, user);
         }
 
         private void OnReactionReceived(ReactionNewEventInternalDTO eventDto)

Assets/Plugins/StreamChat/SampleProject/Config/AppConfig.asset

@@ -15,5 +15,7 @@ MonoBehaviour:
   _viewFactoryConfig:
     _messageOptionsPopupPrefab: {fileID: 5378343205483587087, guid: b6c7f64cd6c991f48b045099bdd324a7, type: 3}
     _createNewChannelPopupPrefab: {fileID: 8926528666989219657, guid: 8d705e1b929f52f469855a34297cc5a9, type: 3}
+    _inviteChannelMembersPopup: {fileID: 555744599652294315, guid: b435ad66df150884f95195211ff0e2f9, type: 3}
+    inviteReceivedPopup: {fileID: 612576315916417125, guid: a7f43c43ced3f304696341427caeea16, type: 3}
     _errorPopupPrefab: {fileID: 6615067076462953508, guid: 8751c971eb857264a92846caef344d49, type: 3}
   _emojiConfig: {fileID: 11400000, guid: 21c7de3d66787c8428964e6da1fdad93, type: 2}