bo/Workbench/QMonitor/qmonlib.console/Commands/ScanCommand.cs

using Quadarax.Foundation.Core.QConsole;
using Quadarax.Foundation.Core.QConsole.Argument;
using Quadarax.Foundation.Core.QConsole.Attributes;
using Quadarax.Foundation.Core.Value;

namespace Quadarax.Foundation.Core.QMonitor.Console.Commands
{
    [CommandDefinition]
    internal class ScanCommand : BaseCommand
    {

        #region *** Constants ***

        private const string CS_CMD_SCAN_NAME = "scan";
        private const string CS_CMD_SCAN_DESC = "Scans for general metadata informations.";


        protected const string CS_ARG_NAME_DATA = "data";
        private const string CS_ARG_HINT_DATA = "<is_data_included>";
        private const string CS_ARG_DESC_DATA = "Flag if set shows receiving data entry.";
        #endregion

        
        #region *** Properties ***
        public override string Name => CS_CMD_SCAN_NAME;
        public override string Description => CS_CMD_SCAN_DESC;

        private bool IsDataDump { get; set; }
        #endregion

        #region *** Private fields ***
        private IDictionary<string, MonItemGeneral> _cachedGenerals = new Dictionary<string, MonItemGeneral>();
        #endregion

        #region *** Constructor ***
        public ScanCommand(Engine engine) : base(engine)
        {
        }
        #endregion  

        #region *** Execute ***
        protected override Result OnExecute()
        {
            var waitToData = TimeSpan.FromSeconds(10);
            WriteInfo($"Waiting for collecting general metadata {waitToData.TotalSeconds} seconds...");
            Task.Delay(waitToData).Wait();
            WriteInfo($"Collected {_cachedGenerals.Count} items above.");
            return new Result();
        }
        #endregion

        #region *** Private Operations ***

        protected override void OnInitialize()
        {
            base.OnInitialize();
            IsDataDump = GetArgumentValueOrDefault<bool>(CS_ARG_NAME_DATA);
        }
        protected override IEnumerable<AbstractArgument> OnSetupArguments()
        {
            var result = new List<AbstractArgument>(base.OnSetupArguments())
            {
                new FlagArgument(CS_ARG_NAME_DATA, CS_ARG_HINT_DATA, CS_ARG_DESC_DATA, false)
            };
            return result;
        } 
        protected override void OnGeneralReceived(MonGeneral general)
        {
            foreach (var item in general.Items)
            {
                if(!_cachedGenerals.ContainsKey($"{general.InstanceIdentifier}_{item.Name}"))
                {
                    _cachedGenerals.Add($"{general.InstanceIdentifier}_{item.Name}", item);
                    WriteInfo("* [" + general.InstanceIdentifier + "] " + item.Name);
                }
            }
        }

        protected override void OnDataReceived(MonData[] data)
        {
            if (IsDataDump)
            {
                foreach (var item in data)
                {
                    WriteInfo($"# [{item.InstanceIdentifier}] {item.Name}");
                }
            }
        }

        #endregion

    }
}