webdoorcreator/WebDoorCreator.API/Controllers/QueueController.cs

using Microsoft.AspNetCore.Mvc;
using NLog;
using WebDoorCreator.Data.DTO;
using WebDoorCreator.Data.Services;

namespace WebDoorCreator.API.Controllers
{
    [Route("api/[controller]")]
    [ApiController]
    public class QueueController : ControllerBase
    {
        #region Public Constructors

        public QueueController(IConfiguration configuration, QueueDataService DataService)
        {
            Log.Info("Starting QueueController");
            _configuration = configuration;
            QDataServ = DataService;
            Log.Info("Avviato QueueController");
        }

        #endregion Public Constructors

        #region Public Methods

        /// <summary>
        /// Lunghezza coda in fase di processing
        /// </summary>
        /// <returns></returns>
        [HttpGet("ActLenght")]
        public async Task<Dictionary<string, long>> ActLenght()
        {
            Dictionary<string, long> answ = new Dictionary<string, long>();
            var actPend = await QDataServ.NumRequestPending();
            answ.Add("pending", actPend);

            var actProc = await QDataServ.NumRequestProcessing();
            answ.Add("processing", actProc);

            var actErr = await QDataServ.NumRequestErrors();
            answ.Add("errors", actErr);

            var actDone = await QDataServ.NumRequestDone();
            answ.Add("done", actDone);
            return answ;
        }

        /// <summary>
        /// Cleanup dati delle code di calcolo
        /// </summary>
        /// <param name="passPhrase">Chiave x auth di reset</param>
        /// <returns></returns>
        [HttpPost("DCCacheCleanup")]
        public async Task<string> DCCacheCleanup(string passPhrase)
        {
            string answ = "NA";
            bool fatto = false;
            if (passPhrase == "bbbBirdIsTheWord")
            {
                fatto = await QDataServ.DoorCalcCacheCleanup();
            }
            answ = fatto ? "OK" : "NO";
            return answ;
        }

        /// <summary>
        /// Reset delle code di chiamata x ripetere simulazione
        /// </summary>
        /// <param name="passPhrase">Chiave x auth di reset</param>
        /// <returns></returns>
        [HttpPost("ResetQueue")]
        public async Task<string> ResetQueue(string passPhrase)
        {
            string answ = "NA";
            bool fatto = false;
            if (passPhrase == "bbbBirdIsTheWord")
            {
                fatto = await QDataServ.ResetQueue();
            }
            answ = fatto ? "OK" : "NO";
            return answ;
        }

        /// <summary>
        /// Reset della coda di processing x evitare condizioni di "stuck in calc"
        /// </summary>
        /// <returns></returns>
        [HttpPost("ResetQueueProcessing")]
        public async Task<string> ResetQueueProcessing()
        {
            string answ = "NA";
            bool fatto = await QDataServ.ResetQueueProcessing();
            answ = fatto ? "OK" : "NO";
            return answ;
        }

        /// <summary>
        /// Invio elenco risultati elaborazioni (modalità boolean di esecuzione corretta)
        /// </summary>
        /// <param name="calcResults">Risultati elaborazioni in formato CalcResultDTO</param>
        /// <returns></returns>
        [HttpPost("SaveProcResult")]
        public async Task<string> SaveProcResult(List<CalcResultDTO> calcResults)
        {
            string answ = "NA";
            bool fatto = await QDataServ.SaveProcessingResult(calcResults);
            answ = fatto ? "OK" : "NO";
            return answ;
        }

        /// <summary>
        /// Elenco richieste raggruppate x stato
        /// </summary>
        /// <returns></returns>
        [HttpGet("StatusList")]
        public async Task<Dictionary<string, Dictionary<string, string>>> StatusList()
        {
            Dictionary<string, Dictionary<string, string>> answ = new Dictionary<string, Dictionary<string, string>>();
            var actPend = await QDataServ.RequestPending();
            answ.Add("pending", actPend);

            var actProc = await QDataServ.RequestProcessing();
            answ.Add("processing", actProc);

            var actErr = await QDataServ.RequestErr();
            answ.Add("errors", actErr);

            var actDone = await QDataServ.RequestDone();
            answ.Add("done", actDone);
            return answ;
        }

        /// <summary>
        /// Chiede un numero massimo di items dalla coda NB:
        /// - verranno tolti dalla coda FIFO richieste
        /// - verranno messi nella coda FIFO processing
        /// </summary>
        /// <returns></returns>
        [HttpGet("TakeNextItems")]
        public async Task<Dictionary<string, string>> TakeProcessingItems(int numItems = 10)
        {
            var actQueue = await QDataServ.TakeProcessingItems(numItems);
            return actQueue;
        }

        #endregion Public Methods

        #region Private Fields

        private static IConfiguration _configuration = null!;

        private static Logger Log = LogManager.GetCurrentClassLogger();

        #endregion Private Fields

        #region Private Properties

        private QueueDataService QDataServ { get; set; } = null!;

        #endregion Private Properties
    }
}