webdoorcreator/WebDoorCreator.UI/Data/WDCUserService.cs

using Microsoft.AspNetCore.Identity;
using Microsoft.EntityFrameworkCore;
using Newtonsoft.Json;
using NLog;
using StackExchange.Redis;
using System.Diagnostics;
using WebDoorCreator.Core;
using WebDoorCreator.Data.User;

namespace WebDoorCreator.UI.Data
{
    public class WDCUserService
    {
        #region Public Constructors

        public WDCUserService(IConnectionMultiplexer redisConnMult, UserManager<IdentityUser> userManager)
        {
            _userManager = userManager;
            // Conf cache
            redisConn = redisConnMult;
            redisDb = this.redisConn.GetDatabase();

            // json serializer... FIX errore loop circolare https://www.ryadel.com/en/jsonserializationexception-self-referencing-loop-detected-error-fix-entity-framework-asp-net-core/
            JSSettings = new JsonSerializerSettings()
            {
                ReferenceLoopHandling = ReferenceLoopHandling.Ignore
            };
            // chiudo log
            Log.Info("Avviata classe WDCUserService");
        }

        #endregion Public Constructors

        #region Public Events

        public event Action EA_CurrLanguage = null!;

        public event Action EA_UserClaims = null!;

        public event Action EA_UserCurrCompany = null!;

        public event Action EA_UserId = null!;

        public event Action EA_UserRole = null!;

        #endregion Public Events

        #region Public Properties

        public string? currLanguage
        {
            get => _currLanguage;
            set
            {
                if (_currLanguage != value)
                {
                    _currLanguage = value;
                    reportCurrentLanguage();
                }
            }
        }

        public List<string>? userClaims
        {
            get => _userClaims;
            set
            {
                if (_userClaims != value)
                {
                    _userClaims = value;
                    reportUserClaims();
                }
            }
        }

        public int userCurrComp
        {
            get => _userCurrComp;
            set
            {
                if (_userCurrComp != value)
                {
                    _userCurrComp = value;
                    reportUserCurrCompany();
                }
            }
        }

        public string userId
        {
            get => _userId;
            set
            {
                if (_userId != value)
                {
                    _userId = value;
                    reportUserId();
                }
            }
        }

        public Dictionary<string, string> UserPref { get; set; } = new Dictionary<string, string>();

        public string userRole
        {
            get => _userRole;
            set
            {
                if (_userRole != value)
                {
                    _userRole = value;
                    reportUserRole();
                }
            }
        }

        #endregion Public Properties

        #region Public Methods

        /// <summary>
        /// Dati utente (TUTTI) da REDIS o DB
        /// </summary>
        /// <returns></returns>
        public async Task<List<IdentityUser>> UserDataGetAll()
        {
            string source = "DB";
            List<IdentityUser> dataResult = new List<IdentityUser>();
            // cerco da cache
            string currKey = $"{Constants.rKeyUsersAll}";
            Stopwatch stopWatch = new Stopwatch();
            stopWatch.Start();
            string? rawData = await redisDb.StringGetAsync(currKey);
            if (!string.IsNullOrEmpty(rawData))
            {
                source = "REDIS";
                var tempResult = JsonConvert.DeserializeObject<List<IdentityUser>>(rawData);
                if (tempResult == null)
                {
                    dataResult = new List<IdentityUser>();
                }
                else
                {
                    dataResult = tempResult;
                }
            }
            else
            {
                dataResult = await _userManager.Users.ToListAsync();
                rawData = JsonConvert.SerializeObject(dataResult, JSSettings);
                await redisDb.StringSetAsync(currKey, rawData, LongCache);
            }
            if (dataResult == null)
            {
                dataResult = new List<IdentityUser>();
            }
            stopWatch.Stop();
            TimeSpan ts = stopWatch.Elapsed;
            Log.Debug($"UserDataGetAll | {source} in: {ts.TotalMilliseconds} ms");
            return dataResult;
        }

        /// <summary>
        /// Dati utente (singolo x UserId)
        /// </summary>
        /// <param name="UserId"></param>
        /// <returns></returns>
        public async Task<UserData> UserDataGetById(string UserId)
        {
            string source = "DB";
            UserData dataResult = new UserData();
            // cerco da cache
            string currKey = $"{Constants.rKeyUsersDataId}:{UserId}";
            Stopwatch stopWatch = new Stopwatch();
            stopWatch.Start();
            string? rawData = "";// await redisDb.StringGetAsync(currKey);
            if (!string.IsNullOrEmpty(rawData))
            {
                source = "REDIS";
                var tempResult = JsonConvert.DeserializeObject<UserData>(rawData);
                if (tempResult == null)
                {
                    dataResult = new UserData();
                }
                else
                {
                    dataResult = tempResult;
                }
            }
            else
            {
                // Collezione dati raw
                var userRaw = await _userManager.FindByIdAsync(UserId);
                if (userRaw != null)
                {
                    var userIdent = new IdentityUser
                    {
                        Id = userRaw.Id,
                        UserName = userRaw.UserName,
                        Email = userRaw.Email,
                        PhoneNumber = userRaw.PhoneNumber,
                        PasswordHash = "*****",
                        EmailConfirmed = userRaw.EmailConfirmed
                    };
                    // cerco ruoli & claims
                    var UserRoles = await _userManager.GetRolesAsync(userIdent);
                    var UserClaims = await _userManager.GetClaimsAsync(userIdent);
                    // compongo output
                    dataResult = new UserData()
                    {
                        Identity = userIdent,
                        Roles = UserRoles.ToList(),
                        Claims = UserClaims.ToList()
                    };

                    rawData = JsonConvert.SerializeObject(dataResult, JSSettings);
                    await redisDb.StringSetAsync(currKey, rawData, FastCache);
                }
            }
            if (dataResult == null)
            {
                dataResult = new UserData();
            }
            stopWatch.Stop();
            TimeSpan ts = stopWatch.Elapsed;
            Log.Debug($"UserDataGetById | {source} in: {ts.TotalMilliseconds} ms");
            return dataResult;
        }

        /// <summary>
        /// Dati utente (filtrati da UserId)
        /// </summary>
        /// <param name="searchVal"></param>
        /// <returns></returns>
        public async Task<List<UserData>> UserDataGetFilt(string searchVal)
        {
            string source = "DB";
            List<UserData> dataResult = new List<UserData>();
            // cerco da cache
            string currKey = $"{Constants.rKeyUsersDataSearch}:{searchVal}";
            Stopwatch stopWatch = new Stopwatch();
            stopWatch.Start();
            string? rawData = "";// await redisDb.StringGetAsync(currKey);
            if (!string.IsNullOrEmpty(rawData))
            {
                source = "REDIS";
                var tempResult = JsonConvert.DeserializeObject<List<UserData>>(rawData);
                if (tempResult == null)
                {
                    dataResult = new List<UserData>();
                }
                else
                {
                    dataResult = tempResult;
                }
            }
            else
            {
                // Collezione dati raw
                List<IdentityUser> RawList = new List<IdentityUser>();
                //List<UserData> UsersList = new List<UserData>();
                var allData = await UserDataGetAll();
                if (!string.IsNullOrEmpty(searchVal))
                {
                    RawList = allData.Where(x => x.NormalizedEmail.Contains(searchVal.ToUpper()) || x.NormalizedUserName.Contains(searchVal.ToUpper())).ToList();
                }
                else
                {
                    RawList = allData;
                }
                var user = RawList.Select(x => new IdentityUser
                {
                    Id = x.Id,
                    UserName = x.UserName,
                    Email = x.Email,
                    PhoneNumber = x.PhoneNumber,
                    PasswordHash = "*****",
                    EmailConfirmed = x.EmailConfirmed
                }).ToList();

                foreach (var item in user)
                {
                    var UserRoles = await _userManager.GetRolesAsync(item);
                    var UserClaims = await _userManager.GetClaimsAsync(item);

                    var newItem = new UserData()
                    {
                        Identity = item,
                        Roles = UserRoles.ToList(),
                        Claims = UserClaims.ToList()
                    };
                    dataResult.Add(newItem);
                }
                rawData = JsonConvert.SerializeObject(dataResult, JSSettings);
                await redisDb.StringSetAsync(currKey, rawData, FastCache);
            }
            if (dataResult == null)
            {
                dataResult = new List<UserData>();
            }
            stopWatch.Stop();
            TimeSpan ts = stopWatch.Elapsed;
            Log.Debug($"UserDataGetFilt | {source} in: {ts.TotalMilliseconds} ms");
            return dataResult;
        }

        /// <summary>
        /// Effettua reset dati utente...
        /// </summary>
        /// <param name="resetAll">Indica reset completo (anche dati elenco di base)</param>
        /// <returns></returns>
        public async Task<bool> ResetUserDataCache(bool resetAll)
        {
            bool fatto = false;
            RedisValue pattern = new RedisValue($"{Constants.rKeyUsersAll}");
            if (resetAll)
            {
                fatto = await ExecFlushRedisPattern(pattern);
            }
            // ora resetto il resto
            pattern = new RedisValue($"{Constants.rKeyUsersDataId}:*");
            fatto = fatto && await ExecFlushRedisPattern(pattern);
            pattern = new RedisValue($"{Constants.rKeyUsersDataSearch}:*");
            fatto = fatto && await ExecFlushRedisPattern(pattern);
            return fatto;
        }

        #endregion Public Methods

        #region Protected Methods

        protected void reportCurrentLanguage()
        {
            if (EA_CurrLanguage != null)
            {
                EA_CurrLanguage?.Invoke();
            }
        }

        protected void reportUserClaims()
        {
            if (EA_UserClaims != null)
            {
                EA_UserClaims?.Invoke();
            }
        }

        protected void reportUserCurrCompany()
        {
            if (EA_UserCurrCompany != null)
            {
                EA_UserCurrCompany?.Invoke();
            }
        }

        protected void reportUserId()
        {
            if (EA_UserId != null)
            {
                EA_UserId?.Invoke();
            }
        }

        protected void reportUserRole()
        {
            if (EA_UserRole != null)
            {
                EA_UserRole?.Invoke();
            }
        }

        #endregion Protected Methods

        #region Private Fields

        private static JsonSerializerSettings? JSSettings;
        private static Logger Log = LogManager.GetCurrentClassLogger();
        private readonly UserManager<IdentityUser> _userManager;

        /// <summary>
        /// Durata cache lunga IN SECONDI
        /// </summary>
        private int cacheTtlLong = 60 * 5;

        /// <summary>
        /// Durata cache breve IN SECONDI
        /// </summary>
        private int cacheTtlShort = 60 * 1;

        /// <summary>
        /// Oggetto per connessione a REDIS
        /// </summary>
        private IConnectionMultiplexer redisConn;

        /// <summary>
        /// Oggetto DB redis da impiegare x chiamate R/W
        /// </summary>
        private IDatabase redisDb = null!;

        private Random rnd = new Random();

        #endregion Private Fields

        #region Private Properties

        private string? _currLanguage { get; set; } = null;

        private List<string>? _userClaims { get; set; } = null;

        private int _userCurrComp { get; set; }

        private string _userId { get; set; } = "";

        private string _userRole { get; set; } = "";

        /// <summary>
        /// Durata cache breve (1 min circa + perturbazione percentuale +/-10%)
        /// </summary>
        private TimeSpan FastCache
        {
            get => TimeSpan.FromSeconds(cacheTtlShort * rnd.Next(900, 1100) / 1000);
        }

        /// <summary>
        /// Durata cache lunga (+ perturbazione percentuale +/-10%)
        /// </summary>
        private TimeSpan LongCache
        {
            get => TimeSpan.FromSeconds(cacheTtlLong * rnd.Next(900, 1100) / 1000);
        }

        /// <summary>
        /// Durata cache molto breve (10 sec circa + perturbazione percentuale +/-10%)
        /// </summary>
        private TimeSpan UltraFastCache
        {
            get => TimeSpan.FromSeconds(cacheTtlShort / 6 * rnd.Next(900, 1100) / 1000);
        }

        /// <summary>
        /// Durata cache lunga (+ perturbazione percentuale +/-10%)
        /// </summary>
        private TimeSpan UltraLongCache
        {
            get => TimeSpan.FromSeconds(cacheTtlLong * 10 * rnd.Next(900, 1100) / 1000);
        }

        #endregion Private Properties

        #region Private Methods

        /// <summary>
        /// Esegue flush memoria redis dato pattern
        /// </summary>
        /// <param name="pattern"></param>
        /// <returns></returns>
        private async Task<bool> ExecFlushRedisPattern(RedisValue pattern)
        {
            bool answ = false;
            var listEndpoints = redisConn.GetEndPoints();
            foreach (var endPoint in listEndpoints)
            {
                //var server = redisConnAdmin.GetServer(listEndpoints[0]);
                var server = redisConn.GetServer(endPoint);
                if (server != null)
                {
                    var keyList = server.Keys(redisDb.Database, pattern);
                    foreach (var item in keyList)
                    {
                        await redisDb.KeyDeleteAsync(item);
                    }
                    answ = true;
                }
            }

            return answ;
        }

        #endregion Private Methods

        //= -1;
    }
}