apply fix on Webinars Provider ...

Controller/XWebinarServiceControllerBase.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Linq;
 using System.Collections.Generic;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Mvc;
@@ -6,6 +7,7 @@ using Microsoft.Extensions.Logging;
 using xCommons.Configurations;
 using xCommons.Extensions;
 using xCommons.Providers;
+using xExceptions.Constants;
 using xIdentityService.Controllers;
 using xIdentityService.Interfaces;
 using xModels.Dtos;
@@ -60,6 +62,19 @@ namespace xWebinarService.Controller
             // Do ...
             try
             {
+                //
+                // Retrieve User Info ...
+                var userInfo = await GetUserInfo();
+                bool isAdmin = userInfo.Roles.Any(r => r.ToNormalString() == "admin");
+                var userId = userInfo.UserId;
+
+                //
+                // Check Owner ...
+                if (item.OwnerId.IsNullOrEmpty())
+                {
+                    item.OwnerId = userId;
+                }
+
                 //
                 var result = await WebinarProvider
                     .CreateWebinar(item);
@@ -90,6 +105,20 @@ namespace xWebinarService.Controller
             // Do ...
             try
             {
+                //
+                // Retrieve User Info ...
+                var userInfo = await GetUserInfo();
+                bool isAdmin = userInfo.Roles.Any(r => r.ToNormalString() == "admin");
+                var userId = userInfo.UserId;
+
+                //
+                // Check Permission ...
+                bool has = item.OwnerId == userId || isAdmin;
+                if (!has)
+                {
+                    XException.NotAllowed.Throw();
+                }
+
                 //
                 var result = await WebinarProvider
                     .UpdateWebinar(item);
@@ -210,14 +239,29 @@ namespace xWebinarService.Controller
                 //
                 // Retrieve User Info ...
                 var userInfo = await GetUserInfo();
-                var requesterId = userInfo.UserId;
+                bool isAdmin = userInfo.Roles.Any(r => r.ToNormalString() == "admin");
+                var userId = userInfo.UserId;
+
+                //
+                // Retrieve Entity ...
+                var entity = await WebinarProvider.GetWebinar(webinarId);
+                bool has = !entity.IsNullOrDefault();
+                if (!has)
+                {
+                    XException.NotFound.Throw();
+                }
+
+                //
+                // Check Permissions ...
+                has = entity.OwnerId == userId || isAdmin;
+                if (!has)
+                {
+                    XException.NotAllowed.Throw();
+                }
 
                 //
                 var result = await WebinarProvider
-                    .RemoveWebinar(
+                    .RemoveWebinar(webinarId);
-                        webinarId: webinarId,
-                        requesterUserSelectByParam: requesterId
-                    );
 
                 //
                 return Ok(result.
@@ -253,14 +297,34 @@ namespace xWebinarService.Controller
                 //
                 // Retrieve User Info ...
                 var userInfo = await GetUserInfo();
-                var requesterId = userInfo.UserId;
+                bool isAdmin = userInfo.Roles.Any(r => r.ToNormalString() == "admin");
+                var userId = userInfo.UserId;
+
+                //
+                // Retrieve Entity ...
+                var entity = await WebinarProvider.GetWebinar(webinarId);
+                bool has = !entity.IsNullOrDefault();
+                if (!has)
+                {
+                    XException.NotFound.Throw();
+                }
+
+                //
+                // Check Permissions ...
+                has =
+                    isAdmin ||
+                    entity.OwnerId == userId ||
+                    entity.Type == Constants.XWebinarType.Public;
+                if (!has)
+                {
+                    XException.NotAllowed.Throw();
+                }
 
                 //
                 var result = await WebinarProvider
                     .Subscribe(
                         webinarId: webinarId,
-                        subscriberId: subscriberId,
+                        subscriberId: subscriberId
-                        requesterUserSelectByParam: requesterId
                 );
 
                 //
@@ -294,7 +358,27 @@ namespace xWebinarService.Controller
                 //
                 // Retrieve User Info ...
                 var userInfo = await GetUserInfo();
-                var requesterId = userInfo.UserId;
+                bool isAdmin = userInfo.Roles.Any(r => r.ToNormalString() == "admin");
+                var userId = userInfo.UserId;
+
+                //
+                // Retrieve Entity ...
+                var entity = await WebinarProvider.GetWebinar(webinarId);
+                bool has = !entity.IsNullOrDefault();
+                if (!has)
+                {
+                    XException.NotFound.Throw();
+                }
+
+                //
+                // Check Permissions ...
+                has =
+                    isAdmin ||
+                    entity.OwnerId == userId;
+                if (!has)
+                {
+                    XException.NotAllowed.Throw();
+                }
 
                 //
                 var result = await WebinarProvider
@@ -334,14 +418,34 @@ namespace xWebinarService.Controller
                 //
                 // Retrieve User Info ...
                 var userInfo = await GetUserInfo();
-                var requesterId = userInfo.UserId;
+                bool isAdmin = userInfo.Roles.Any(r => r.ToNormalString() == "admin");
+                var userId = userInfo.UserId;
+
+                //
+                // Retrieve Entity ...
+                var entity = await WebinarProvider.GetWebinar(webinarId);
+                bool has = !entity.IsNullOrDefault();
+                if (!has)
+                {
+                    XException.NotFound.Throw();
+                }
+
+                //
+                // Check Permissions ...
+                has =
+                    isAdmin ||
+                    subscriberId == userId ||
+                    entity.OwnerId == userId;
+                if (!has)
+                {
+                    XException.NotAllowed.Throw();
+                }
 
                 //
                 var result = await WebinarProvider
                     .Unsubscribe(
                         webinarId: webinarId,
-                        subscriberId: subscriberId,
+                        subscriberId: subscriberId
-                        requesterUserSelectByParam: requesterId
                 );
 
                 //
@@ -375,14 +479,33 @@ namespace xWebinarService.Controller
                 //
                 // Retrieve User Info ...
                 var userInfo = await GetUserInfo();
-                var requesterId = userInfo.UserId;
+                bool isAdmin = userInfo.Roles.Any(r => r.ToNormalString() == "admin");
+                var userId = userInfo.UserId;
+
+                //
+                // Retrieve Entity ...
+                var entity = await WebinarProvider.GetWebinar(webinarId);
+                bool has = !entity.IsNullOrDefault();
+                if (!has)
+                {
+                    XException.NotFound.Throw();
+                }
+
+                //
+                // Check Permissions ...
+                has =
+                    isAdmin ||
+                    entity.OwnerId == userId;
+                if (!has)
+                {
+                    XException.NotAllowed.Throw();
+                }
 
                 //
                 var result = await WebinarProvider
                     .GetSubscriber(
                         webinarId: webinarId,
-                        subscriberId: subscriberId,
+                        subscriberId: subscriberId
-                        requesterUserSelectByParam: requesterId
                 );
 
                 //
@@ -414,14 +537,31 @@ namespace xWebinarService.Controller
                 //
                 // Retrieve User Info ...
                 var userInfo = await GetUserInfo();
-                var requesterId = userInfo.UserId;
+                bool isAdmin = userInfo.Roles.Any(r => r.ToNormalString() == "admin");
+                var userId = userInfo.UserId;
+
+                //
+                // Retrieve Entity ...
+                var entity = await WebinarProvider.GetWebinar(webinarId);
+                bool has = !entity.IsNullOrDefault();
+                if (!has)
+                {
+                    XException.NotFound.Throw();
+                }
+
+                //
+                // Check Permissions ...
+                has =
+                    isAdmin ||
+                    entity.OwnerId == userId;
+                if (!has)
+                {
+                    XException.NotAllowed.Throw();
+                }
 
                 //
                 var result = await WebinarProvider
-                    .GetSubscribers(
+                    .GetSubscribers(webinarId);
-                        webinarId: webinarId,
-                        requesterUserSelectByParam: requesterId
-                );
 
                 //
                 return Ok(result.
@@ -454,14 +594,33 @@ namespace xWebinarService.Controller
                 //
                 // Retrieve User Info ...
                 var userInfo = await GetUserInfo();
-                var requesterId = userInfo.UserId;
+                bool isAdmin = userInfo.Roles.Any(r => r.ToNormalString() == "admin");
+                var userId = userInfo.UserId;
+
+                //
+                // Retrieve Entity ...
+                var entity = await WebinarProvider.GetWebinar(webinarId);
+                bool has = !entity.IsNullOrDefault();
+                if (!has)
+                {
+                    XException.NotFound.Throw();
+                }
+
+                //
+                // Check Permissions ...
+                has =
+                    isAdmin ||
+                    entity.OwnerId == userId;
+                if (!has)
+                {
+                    XException.NotAllowed.Throw();
+                }
 
                 //
                 var result = await WebinarProvider
                     .QuerySubscribers(
                         query: query,
-                        webinarId: webinarId,
+                        webinarId: webinarId
-                        requesterUserSelectByParam: requesterId
                 );
 
                 //
@@ -476,8 +635,5 @@ namespace xWebinarService.Controller
             }
         }
         #endregion
-
-        //
-        // Non Actions ...
     }
 }

Interfaces/IXWebinarProvider.cs

@@ -80,12 +80,8 @@ namespace xWebinarService.Interfaces
         /// Remove Specified Webinar ...
         /// </summary>
         /// <param name="webinarId"></param>
-        /// <param name="requesterUserSelectByParam"></param>
         /// <returns></returns>
-        Task<bool> RemoveWebinar(
+        Task<bool> RemoveWebinar(Guid webinarId);
-            Guid webinarId,
-            string requesterUserSelectByParam = null
-        );
         #endregion
 
         //
@@ -95,12 +91,10 @@ namespace xWebinarService.Interfaces
         /// </summary>
         /// <param name="webinarId"></param>
         /// <param name="subscriberId"></param>
-        /// <param name="requesterUserSelectByParam"></param>
         /// <returns></returns>
         Task<bool> Subscribe(
             Guid webinarId,
-            string subscriberId,
+            string subscriberId
-            string requesterUserSelectByParam = null
         );
 
         /// <summary>
@@ -119,12 +113,10 @@ namespace xWebinarService.Interfaces
         /// </summary>
         /// <param name="webinarId"></param>
         /// <param name="subscriberId"></param>
-        /// <param name="requesterUserSelectByParam"></param>
         /// <returns></returns>
         Task<bool> Unsubscribe(
             Guid webinarId,
-            string subscriberId,
+            string subscriberId
-            string requesterUserSelectByParam = null
         );
 
         /// <summary>
@@ -132,36 +124,28 @@ namespace xWebinarService.Interfaces
         /// </summary>
         /// <param name="webinarId"></param>
         /// <param name="subscriberId"></param>
-        /// <param name="requesterUserSelectByParam"></param>
         /// <returns></returns>
         Task<XWebinarSubscriberDto> GetSubscriber(
             Guid webinarId,
-            string subscriberId,
+            string subscriberId
-            string requesterUserSelectByParam = null
         );
 
         /// <summary>
         /// Get all Specified Webinars Subscribers ...
         /// </summary>
         /// <param name="webinarId"></param>
-        /// <param name="requesterUserSelectByParam"></param>
         /// <returns></returns>
-        Task<IEnumerable<XWebinarSubscriberDto>> GetSubscribers(
+        Task<IEnumerable<XWebinarSubscriberDto>> GetSubscribers(Guid webinarId);
-            Guid webinarId,
-            string requesterUserSelectByParam = null
-        );
 
         /// <summary>
         /// Query Specified Webinar's Subscribers ...
         /// </summary>
         /// <param name="webinarId"></param>
         /// <param name="query"></param>
-        /// <param name="requesterUserSelectByParam"></param>
         /// <returns></returns>
         Task<XQueryResult<XWebinarSubscriberDto>> QuerySubscribers(
             Guid webinarId,
-            XQuery query,
+            XQuery query
-            string requesterUserSelectByParam = null
         );
         #endregion
     }

Providers/XWebinarProvider.cs

@@ -522,11 +522,9 @@ namespace xWebinarService.Providers
         /// Remove Specified Webinar ...
         /// </summary>
         /// <param name="webinarId"></param>
-        /// <param name="requesterUserSelectByParam"></param>
         /// <returns></returns>
         public async Task<bool> RemoveWebinar(
-            Guid webinarId,
+            Guid webinarId
-            string requesterUserSelectByParam = null
         )
         {
             //
@@ -551,27 +549,17 @@ namespace xWebinarService.Providers
                 return result;
             }
 
-            //
-            // Check Permissions ...
-            result = entity.OwnerId == requesterUserSelectByParam;
-            if (!result)
-            {
-                return result;
-            }
-
             //
             // Handle Remove ...
             var subscribers = await GetSubscribers(
-                webinarId: webinarId,
+                webinarId: webinarId
-                requesterUserSelectByParam: requesterUserSelectByParam
             );
             try
             {
                 //
                 await subscribers.SelectAsync(async s => await Unsubscribe(
                     webinarId: webinarId,
-                    subscriberId: s.SubscriberId,
+                    subscriberId: s.SubscriberId
-                    requesterUserSelectByParam: requesterUserSelectByParam
                 ));
 
                 //
@@ -600,12 +588,10 @@ namespace xWebinarService.Providers
         /// </summary>
         /// <param name="webinarId"></param>
         /// <param name="subscriberId"></param>
-        /// <param name="requesterUserSelectByParam"></param>
         /// <returns></returns>
         public async Task<bool> Subscribe(
             Guid webinarId,
-            string subscriberId,
+            string subscriberId
-            string requesterUserSelectByParam = null
         )
         {
             //
@@ -636,19 +622,7 @@ namespace xWebinarService.Providers
 
             //
             // Check Webinar Enabled ...
-            result =
+            result = webinar.Enabled;
-                webinar.Enabled ||
-                requesterUserSelectByParam == webinar.OwnerId;
-            if (!result)
-            {
-                return result;
-            }
-
-            //
-            // Check Webinar Type ...
-            result =
-                webinar.Type == XWebinarType.Public ||
-                requesterUserSelectByParam == webinar.OwnerId;
             if (!result)
             {
                 return result;
@@ -755,12 +729,10 @@ namespace xWebinarService.Providers
         /// </summary>
         /// <param name="webinarId"></param>
         /// <param name="subscriberId"></param>
-        /// <param name="requesterUserSelectByParam"></param>
         /// <returns></returns>
         public async Task<bool> Unsubscribe(
             Guid webinarId,
-            string subscriberId,
+            string subscriberId
-            string requesterUserSelectByParam = null
         )
         {
             //
@@ -792,16 +764,6 @@ namespace xWebinarService.Providers
             // Retrieve Webinar ...
             var webinar = await WebinarRepository.GetAsync(webinarId);
 
-            //
-            // Check Permission ...
-            result =
-                requesterUserSelectByParam == subscriberId ||
-                requesterUserSelectByParam == webinar.OwnerId;
-            if (!result)
-            {
-                return result;
-            }
-
             //
             // Retrieve Subscription Entity ...
             var entity = await WebinarSubscriberRepository.FindOneAsync(ws =>
@@ -820,12 +782,10 @@ namespace xWebinarService.Providers
         /// </summary>
         /// <param name="webinarId"></param>
         /// <param name="subscriberId"></param>
-        /// <param name="requesterUserSelectByParam"></param>
         /// <returns></returns>
         public async Task<XWebinarSubscriberDto> GetSubscriber(
             Guid webinarId,
-            string subscriberId,
+            string subscriberId
-            string requesterUserSelectByParam = null
         )
         {
             //
@@ -860,16 +820,6 @@ namespace xWebinarService.Providers
                 XException.NotFound.Throw();
             }
 
-            //
-            // Check Permissions ...
-            isValid =
-                subscriberId == requesterUserSelectByParam ||
-                webinar.OwnerId == requesterUserSelectByParam;
-            if (!isValid)
-            {
-                XException.NotAllowed.Throw();
-            }
-
             //
             // Converts to Subscriber Dto ...
             var result = await ToXWebinarSubscriberDto(entity);
@@ -880,11 +830,9 @@ namespace xWebinarService.Providers
         /// Get all Specified Webinars Subscribers ...
         /// </summary>
         /// <param name="webinarId"></param>
-        /// <param name="requesterUserSelectByParam"></param>
         /// <returns></returns>
         public async Task<IEnumerable<XWebinarSubscriberDto>> GetSubscribers(
-            Guid webinarId,
+            Guid webinarId
-            string requesterUserSelectByParam = null
         )
         {
             //
@@ -906,15 +854,6 @@ namespace xWebinarService.Providers
                 XException.NotFound.Throw();
             }
 
-            //
-            // Check Permissions ...
-            isValid =
-                webinar.OwnerId == requesterUserSelectByParam;
-            if (!isValid)
-            {
-                XException.NotAllowed.Throw();
-            }
-
             //
             var subscribers = await WebinarSubscriberRepository.FindManyAsync(e =>
                 e.WebinarId == webinarId
@@ -934,12 +873,10 @@ namespace xWebinarService.Providers
         /// </summary>
         /// <param name="webinarId"></param>
         /// <param name="query"></param>
-        /// <param name="requesterUserSelectByParam"></param>
         /// <returns></returns>
         public async Task<XQueryResult<XWebinarSubscriberDto>> QuerySubscribers(
             Guid webinarId,
-            XQuery query,
+            XQuery query
-            string requesterUserSelectByParam = null
         )
         {
             //
@@ -968,8 +905,7 @@ namespace xWebinarService.Providers
             //
             // Retrieve all Items ...
             var items = await GetSubscribers(
-                webinarId: webinarId,
+                webinarId: webinarId
-                requesterUserSelectByParam: requesterUserSelectByParam
             );
             var totalItemsCount = items.Count();