refactor renew ...

2026-05-07 12:57:40 +03:30
parent a89f57ac84
commit 0be6f87a86
1 changed files with 0 additions and 139 deletions
@@ -1,139 +0,0 @@
 using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.AspNetCore.SignalR;
 using Microsoft.EntityFrameworkCore.Query;
 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 xIdentityHelper.Controllers
 {
    [ApiController]
    [ApiVersion("1.0")]
    [RequireXPowered(true)]
    [Route("api/v{version:apiVersion}/domains/[controller]")]
    public abstract class XIBaseV1DomainController<TEntity, TDto, TKey> : XIBaseDomainController<TEntity, TDto, TKey>
    where TEntity : XBaseEntity<TKey>
    where TDto : XBaseEntityDto<TKey>
    {
        //
        #region Constructor ...
        protected XIBaseV1DomainController(
            ILogger<XIBaseV1EntityController<TEntity, TKey>> logger,
            XAppConfiguration appConfiguration,
            IXIdentityProvider identityProvider,
            XValidationProvider validationProvider,
            IXBaseRepositoryService<TEntity, TDto, TKey> repositoryService,
            Func<IQueryable<TEntity>, IOrderedQueryable<TEntity>> defaultOrderBuilder = null,
            Func<IQueryable<TEntity>, IIncludableQueryable<TEntity, object>> defaultIncludeBuilder = null
        ) : base(
            logger: logger,
            appConfiguration: appConfiguration,
            identityProvider: identityProvider,
            repositoryService: repositoryService,
            validationProvider: validationProvider,
            defaultOrderBuilder: defaultOrderBuilder,
            defaultIncludeBuilder: defaultIncludeBuilder
        )
        { }
        #endregion        
    }
    public abstract class XIBaseV1DomainHubController<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,
            Func<IQueryable<TEntity>, IOrderedQueryable<TEntity>> defaultOrderBuilder = null,
            Func<IQueryable<TEntity>, IIncludableQueryable<TEntity, object>> defaultIncludeBuilder = null
        ) : base(
            logger: logger,
            repository: repository,
            appConfiguration: appConfiguration,
            identityProvider: identityProvider,
            validationProvider: validationProvider,
            defaultOrderBuilder: defaultOrderBuilder,
            defaultIncludeBuilder: defaultIncludeBuilder
        )
        {
            Hub = hub;
        }
        #endregion
        //
        #region Hub ...
        [NonAction]
        public async Task SendPush(
            string action,
            string payLoad,
            CancellationToken cancellationToken = default
        )
        {
            //
            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,
                cancellationToken
            );
        }
        #endregion      
    }
 }