FCC/Framework/Edge.Core/UniversalApi/UniversalApiInvoker.cs

using Edge.Core.Configuration;
using Edge.Core.Processor;
using Edge.Core.UniversalApi.Auditing;
using Microsoft.Extensions.DependencyInjection;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Text.Json;
using System.Text.Json.Serialization;
using System.Threading.Tasks;

namespace Edge.Core.UniversalApi
{
    public class UniversalApiInvoker
    {
        private static JsonSerializerOptions jsonSerializerOptions;
        private IEnumerable<IAuditingStore> auditingStores;
        private IServiceProvider services;
        private bool config_DisableApiAuditing = false;
        private bool config_EnableApiInputAndOutputAuditing = false;
        static UniversalApiInvoker()
        {
            jsonSerializerOptions = new JsonSerializerOptions()
            {
                WriteIndented = true,
                PropertyNameCaseInsensitive = true,
            };
            jsonSerializerOptions.Converters.Add(new JsonStringEnumConverter());
        }

        internal UniversalApiInvoker(IServiceProvider services)
        {
            this.services = services;
            var configurator = this.services.GetService<Configurator>();
            this.config_DisableApiAuditing = bool.Parse(configurator.MetaConfiguration.Parameter
                ?.FirstOrDefault(p => p.Name.Equals("disableUniversalApiAuditing", StringComparison.OrdinalIgnoreCase))?.Value ?? "false");
            this.config_EnableApiInputAndOutputAuditing = bool.Parse(configurator.MetaConfiguration.Parameter
                ?.FirstOrDefault(p => p.Name.Equals("enableUniversalApiInputAndOutputAuditing", StringComparison.OrdinalIgnoreCase))?.Value ?? "false");

            this.auditingStores = services.GetRequiredService<IEnumerable<IAuditingStore>>();

            configurator.OnConfigFileChanged += (_, __) =>
            {
                this.config_DisableApiAuditing = bool.Parse(configurator.MetaConfiguration.Parameter
                    ?.FirstOrDefault(p => p.Name.Equals("disableUniversalApiAuditing", StringComparison.OrdinalIgnoreCase))?.Value ?? "false");
                this.config_EnableApiInputAndOutputAuditing = bool.Parse(configurator.MetaConfiguration.Parameter
                    ?.FirstOrDefault(p => p.Name.Equals("enableUniversalApiInputAndOutputAuditing", StringComparison.OrdinalIgnoreCase))?.Value ?? "false");
            };
        }

        public async Task<object> InvokeUniversalApiServiceAsync(IProcessor processor,
              string apiServiceName, JsonElement[] jsonFormatParameters,
              RequestContext requestContext)
        {
            var pDescriptor = processor.ProcessorDescriptor();

            #region

            AuditLogInfo auditLogInfo = null;
            if (!this.config_DisableApiAuditing)
            {
                auditLogInfo = new AuditLogInfo()
                {
                    ClientIdentity = requestContext.ClientIdentity,
                    DeviceHandlerOrAppName = pDescriptor.DeviceHandlerOrApp.ToString(),
                    ExecutionTime = DateTime.Now,
                };
                auditLogInfo.Actions.Add(
                    new AuditLogActionInfo()
                    {
                        ApiName = "service : " + apiServiceName,
                        InputParameters =
                            this.config_EnableApiInputAndOutputAuditing ?
                                jsonFormatParameters?.Select(jp => jp.GetRawText())?.Aggregate("", (acc, n) => acc + ", " + n) ?? ""
                                : null,
                    });
                auditLogInfo.Prepare();
                //logging early for knowing the calling is started
                this.auditingStores.Select(s => s.SaveAsync(auditLogInfo)).ToArray();
            }

            #endregion

            try
            {
                var targetApiInfo = pDescriptor.UniversalApiInfos
                           .FirstOrDefault(api => api.ServiceApiInfo != null
                               && api.ServiceApiInfo.Name == apiServiceName
                               && api.ServiceApiInfo.GetParameters().Length == (jsonFormatParameters?.Length ?? 0));
                if (targetApiInfo == null) throw new ArgumentException("Could not find Universal Api in the processor has Service(Method) Parameter count == " + (jsonFormatParameters?.Length ?? 0));
                var apiDefinedParameters = targetApiInfo.ServiceApiInfo.GetParameters();
                List<object> ps = new List<object>();
                for (int i = 0; i < apiDefinedParameters.Length; i++)
                {
                    try
                    {
                        var para = JsonSerializer.Deserialize(jsonFormatParameters[i].GetRawText(), apiDefinedParameters[i].ParameterType, jsonSerializerOptions);
                        ps.Add(para);
                    }
                    catch (Exception exxx)
                    {
                        throw new ArgumentException("Could not Parse input parameter[" + i + "] to type: "
                            + apiDefinedParameters[i].ParameterType.Name + " for target Universal Api: " + apiServiceName
                            + Environment.NewLine + exxx);
                    }
                }

                var executeResult = await InvokeUniversalApiServiceAsync(processor, targetApiInfo.ServiceApiInfo, ps.ToArray(), requestContext);

                #region 

                if (!this.config_DisableApiAuditing)
                {
                    /* logging again as the service call has been done*/
                    if (this.config_EnableApiInputAndOutputAuditing)
                        auditLogInfo.CommitWithExeResult(executeResult);
                    else
                        auditLogInfo.CommitWithExeResult(null);
                }

                #endregion

                return executeResult;
            }
            catch (Exception exxx)
            {

                #region 

                if (!this.config_DisableApiAuditing)
                { auditLogInfo.CommitWithExceptions(new Exception[] { exxx }); }

                #endregion

                throw;
            }
            finally
            {

                #region  

                if (!this.config_DisableApiAuditing)
                    Task.WaitAll(this.auditingStores.Select(s => s.SaveAsync(auditLogInfo)).ToArray());

                #endregion

            }
        }

        public bool InvokeUniversalApiPropertySet(IProcessor processor,
            string apiPropertyName, JsonElement? propertySetValue,
            RequestContext requestContext)
        {
            var pDescriptor = processor.ProcessorDescriptor();

            #region

            AuditLogInfo auditLogInfo = null;
            if (!this.config_DisableApiAuditing)
            {
                auditLogInfo = new AuditLogInfo()
                {
                    ClientIdentity = requestContext.ClientIdentity,
                    DeviceHandlerOrAppName = pDescriptor.DeviceHandlerOrApp.ToString(),
                    ExecutionTime = DateTime.Now,
                };
                auditLogInfo.Actions.Add(
                    new AuditLogActionInfo()
                    {
                        ApiName = "property : " + apiPropertyName,
                        InputParameters =
                            this.config_EnableApiInputAndOutputAuditing ?
                                propertySetValue?.GetRawText() ?? ""
                                : null,
                    });
                //logging early for knowing the calling is started
                this.auditingStores.Select(s => s.SaveAsync(auditLogInfo)).ToArray();
            }

            #endregion

            try
            {
                var targetApiInfo = pDescriptor?.UniversalApiInfos
                            .FirstOrDefault(api => api.PropertyApiInfo != null
                                && api.PropertyApiInfo.Name == apiPropertyName);
                if (targetApiInfo == null) throw new ArgumentException("Could not find Universal Api in the processor has Property with name: " + apiPropertyName);
                object setValue = null;
                if (propertySetValue == null)
                {
                }
                else
                    setValue = JsonSerializer.Deserialize(propertySetValue.Value.GetRawText(),
                                       targetApiInfo.PropertyApiInfo.PropertyType, jsonSerializerOptions);
                var executeResult = InvokeUniversalApiPropertySet(processor, targetApiInfo.PropertyApiInfo, setValue, requestContext);

                #region 

                if (!this.config_DisableApiAuditing)
                {
                    /* logging again as the call has been done*/
                    if (this.config_EnableApiInputAndOutputAuditing)
                        auditLogInfo.CommitWithExeResult(executeResult);
                    else
                        auditLogInfo.CommitWithExeResult(null);
                }

                #endregion

                return executeResult;
            }
            catch (Exception exxx)
            {

                #region 

                if (!this.config_DisableApiAuditing)
                {
                    auditLogInfo.CommitWithExceptions(new Exception[] { exxx
                    });
                }

                #endregion

                throw;
            }
            finally
            {

                #region  

                if (!this.config_DisableApiAuditing)
                    Task.WaitAll(this.auditingStores.Select(s => s.SaveAsync(auditLogInfo)).ToArray());

                #endregion

            }
        }

        /// <summary>
        /// Invoke the Get method for the property.
        /// </summary>
        /// <param name="processor"></param>
        /// <param name="apiPropertyName"></param>
        /// <returns>the value of the Property</returns>
        public object InvokeUniversalApiPropertyGet(IProcessor processor,
            string apiPropertyName,
            RequestContext requestContext)
        {
            var pDescriptor = processor.ProcessorDescriptor();

            #region

            AuditLogInfo auditLogInfo = null;
            if (!this.config_DisableApiAuditing)
            {
                auditLogInfo = new AuditLogInfo()
                {
                    ClientIdentity = requestContext.ClientIdentity,
                    DeviceHandlerOrAppName = pDescriptor.DeviceHandlerOrApp.ToString(),
                    ExecutionTime = DateTime.Now,
                };
                auditLogInfo.Actions.Add(
                    new AuditLogActionInfo()
                    {
                        ApiName = "property : " + apiPropertyName,
                        InputParameters = null,
                    });
                auditLogInfo.Prepare();
                //logging early for knowing the calling is started
                this.auditingStores.Select(s => s.SaveAsync(auditLogInfo)).ToArray();
            }

            #endregion

            try
            {
                var targetPropertyInfo = pDescriptor.UniversalApiInfos.Where(apiInfo =>
                        (apiInfo.PropertyApiInfo?.Name ?? "") == apiPropertyName)
                        .FirstOrDefault()?.PropertyApiInfo;
                if (targetPropertyInfo == null)
                    throw new EntryPointNotFoundException("Could not find Universal Api Property with name: " + (targetPropertyInfo.Name ?? ""));
                if (!targetPropertyInfo.CanRead
                    || targetPropertyInfo.GetMethod == null
                    || (targetPropertyInfo.GetMethod?.IsPrivate ?? false))
                {
                    throw new EntryPointNotFoundException("Universal Api Property with name: " + (targetPropertyInfo.Name ?? "") + " does not allow Get");
                }

                try
                {
                    /* indicates 'get' operation*/
                    dynamic executeResult = null;
                    if (pDescriptor.ProcessorType == ProcessorType.Application)
                        executeResult = targetPropertyInfo.GetGetMethod().Invoke(processor, null);
                    else if (pDescriptor.ProcessorType == ProcessorType.DeviceProcessor)
                        executeResult = targetPropertyInfo.GetGetMethod().Invoke(pDescriptor.DeviceHandlerOrApp, null);

                    #region 

                    if (!this.config_DisableApiAuditing)
                    {
                        /* logging again as the call has been done*/
                        if (this.config_EnableApiInputAndOutputAuditing)
                            auditLogInfo.CommitWithExeResult(executeResult);
                        else
                            auditLogInfo.CommitWithExeResult(null);
                    }

                    #endregion

                    return executeResult;
                }
                catch (Exception exx)
                {
                    throw;// new InvalidOperationException("Invoke UniversalApi Property: " + apiPropertyName + " exceptioned, detail: " + exx.ToString());
                }
            }
            catch (Exception exxx)
            {

                #region 

                if (!this.config_DisableApiAuditing)
                {
                    auditLogInfo.CommitWithExceptions(new Exception[] { exxx });
                }

                #endregion

                throw;
            }
            finally
            {

                #region  

                if (!this.config_DisableApiAuditing)
                    Task.WaitAll(this.auditingStores.Select(s => s.SaveAsync(auditLogInfo)).ToArray());

                #endregion

            }
        }

        private async Task<object> InvokeUniversalApiServiceAsync(IProcessor processor,
              MethodInfo apiServiceInfo, object[] methodParameters,
              RequestContext requestContext)
        {
            var descriptor = processor.ProcessorDescriptor();
            var targetMethodInfo = descriptor.UniversalApiInfos.Where(apiInfo =>
                    (apiInfo.ServiceApiInfo?.Name ?? "") == apiServiceInfo.Name)
                    .FirstOrDefault()?.ServiceApiInfo;
            if (targetMethodInfo == null)
                throw new EntryPointNotFoundException("Could not find Universal Api Method with name: " + (apiServiceInfo.Name ?? ""));
            try
            {
                dynamic result = null;
                if (descriptor.ProcessorType == ProcessorType.Application)
                    result = await (dynamic)targetMethodInfo.Invoke(processor, methodParameters);
                else if (descriptor.ProcessorType == ProcessorType.DeviceProcessor)
                    result = await (dynamic)targetMethodInfo.Invoke(descriptor.DeviceHandlerOrApp, methodParameters);
                return result;
            }
            catch (Exception exx)
            {
                throw;// new InvalidOperationException("Invoke UniversalApi Service: " + apiServiceInfo.Name + " exceptioned, detail: " + exx.ToString());
            }
        }

        /// <summary>
        /// Invoke the Set method for the property, if set value successfully, will return true, otherwise false.
        /// </summary>
        /// <param name="processor"></param>
        /// <param name="apiPropertyInfo"></param>
        /// <param name="propertySetValue">the value will be set to Property</param>
        /// <returns>if set value successfully, will return true, otherwise false.</returns>
        private bool InvokeUniversalApiPropertySet(IProcessor processor,
            PropertyInfo apiPropertyInfo, object propertySetValue,
            RequestContext requestContext)
        {
            var descriptor = processor.ProcessorDescriptor();
            var targetPropertyInfo = descriptor.UniversalApiInfos.Where(apiInfo =>
                    (apiInfo.PropertyApiInfo?.Name ?? "") == apiPropertyInfo.Name)
                    .FirstOrDefault()?.PropertyApiInfo;
            if (targetPropertyInfo == null)
                throw new EntryPointNotFoundException("Could not find Universal Api Property with name: " + (targetPropertyInfo.Name ?? ""));
            if (!targetPropertyInfo.CanWrite
                || targetPropertyInfo.SetMethod == null
                || (targetPropertyInfo.SetMethod?.IsPrivate ?? false))
            {
                throw new EntryPointNotFoundException("Universal Api Property with name: " + (targetPropertyInfo.Name ?? "") + " does not allow Set");
            }

            if (propertySetValue == null
                && !targetPropertyInfo.PropertyType.IsClass
                && !(targetPropertyInfo.PropertyType.IsGenericType && targetPropertyInfo.PropertyType.GetGenericTypeDefinition() == typeof(Nullable<>)))
                throw new ArgumentException("Universal Api Property with name: " + (targetPropertyInfo.Name ?? "")
                    + " does not compatible has its Set type(" + targetPropertyInfo.PropertyType + ") to Null");
            if (propertySetValue != null && !targetPropertyInfo.PropertyType.IsAssignableFrom(propertySetValue?.GetType()))
                throw new ArgumentException("Universal Api Property with name: " + (targetPropertyInfo.Name ?? "")
                    + " does not compatible has its Set type(" + targetPropertyInfo.PropertyType + ") to " + (propertySetValue?.GetType().Name ?? "null"));
            try
            {
                /* indicates 'set' operation*/
                if (descriptor.ProcessorType == ProcessorType.Application)
                    targetPropertyInfo.SetValue(processor, propertySetValue);
                else if (descriptor.ProcessorType == ProcessorType.DeviceProcessor)
                    targetPropertyInfo.SetValue(descriptor.DeviceHandlerOrApp, propertySetValue);
                return true;
            }
            catch (Exception exx)
            {
                throw;// new InvalidOperationException("Invoke UniversalApi Property: " + apiPropertyInfo.Name + " exceptioned, detail: " + exx.ToString());
            }
        }


    }
}