Initial ...

2026-03-22 14:09:53 +03:30
commit a855ea6b70
33 changed files with 6649 additions and 0 deletions
@@ -0,0 +1,120 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.SignalR;
+using Microsoft.Extensions.Logging;
+using xCommons.Attributes;
+using xCommons.Configurations;
+using xCommons.Extensions;
+using xCommons.Providers;
+using xDataService.Interfaces;
+using xIdentityService.Controllers;
+using xIdentityService.Interfaces;
+using xModels.Base;
+using xPushService.Base;
+using xPushService.Constants;
+
+namespace xApi.Base
+{
+    [ApiController]
+    [ApiVersion("1.0")]
+    [RequireXPowered(true)]
+    [Route("api/v{version:apiVersion}/entities/[controller]")]
+    public abstract class XIBaseV1EntityController<TEntity, TKey> : XIBaseEntityController<TEntity, TKey>
+        where TEntity : XBaseEntity<TKey>
+    {
+        //
+        #region Constructor ...
+        protected XIBaseV1EntityController(
+            ILogger<XIBaseV1EntityController<TEntity, TKey>> logger,
+            XAppConfiguration appConfiguration,
+            IXIdentityProvider identityProvider,
+            XValidationProvider validationProvider,
+            IXBaseRepository<TEntity, TKey> repository
+        ) : base(
+            logger,
+            appConfiguration,
+            identityProvider,
+            validationProvider,
+            repository
+        )
+        { }
+        #endregion
+    }
+
+    public abstract class XIBaseV1EntityHubController<TEntity, TKey> : XIBaseV1EntityController<TEntity, TKey>
+        where TEntity : XBaseEntity<TKey>
+    {
+        //
+        #region Props ...
+        public IHubContext<XBaseEntityHub<TEntity, TKey>> Hub { get; }
+        #endregion
+
+        //
+        #region Constructor ...
+        protected XIBaseV1EntityHubController(
+            ILogger<XIBaseV1EntityHubController<TEntity, TKey>> logger,
+            XAppConfiguration appConfiguration,
+            IXIdentityProvider identityProvider,
+            XValidationProvider validationProvider,
+            IXBaseRepository<TEntity, TKey> repository,
+            IHubContext<XBaseEntityHub<TEntity, TKey>> hub = null
+        ) : base(
+            logger,
+            appConfiguration,
+            identityProvider,
+            validationProvider,
+            repository
+        )
+        {
+            Hub = hub;
+        }
+        #endregion
+
+        //
+        #region Hub ...
+        [NonAction]
+        public async Task SendPush(
+            string action,
+            string payLoad
+        )
+        {
+            //
+            var actions = new List<string>
+            {
+                XBaseEntityHubAction.Add.GetStringValue(),
+                XBaseEntityHubAction.Update.GetStringValue(),
+                XBaseEntityHubAction.Delete.GetStringValue(),
+                XBaseEntityHubAction.AddMany.GetStringValue(),
+                XBaseEntityHubAction.DeleteMany.GetStringValue(),
+                XBaseEntityHubAction.UpdateMany.GetStringValue(),
+                XBaseEntityHubAction.AddOrUpdate.GetStringValue(),
+            };
+
+            //
+            // Validate ...
+            var isValid =
+                !Hub.IsNull() &&
+                !action.IsNullOrEmpty() &&
+                !payLoad.IsNullOrEmpty() &&
+                actions.Contains(action);
+            if (!isValid)
+            {
+                return;
+            }
+
+            //
+            // Retrieve Connection Id ...
+            var connectionId = GetConnectionId();
+            var clients = Hub.Clients.All;
+            if (!connectionId.IsNullOrEmpty())
+            {
+                clients = Hub.Clients.AllExcept(connectionId);
+            }
+
+            //
+            await clients.SendAsync(action, payLoad, connectionId);
+        }
+        #endregion      
+    }
+}