basic infrastructure for separate data processor events added

Author: VladimirDimov

src/Examples/Examples.Mvc/Controllers/CustomersController.cs

@@ -52,5 +52,11 @@ public override void OnDataProcessed(ref object data, RequestInfoModel requestIn
             list.ForEach(x => x.Person.FirstName = $"FN {x.Person.FirstName}");
             data = list.AsQueryable();
         }
+
+        public override void OnSearchnDataProcessing(ref object data, RequestInfoModel requestInfoModel)
+        {
+            var queryable = data as IOrderedQueryable<CustomerViewModel>;
+            data = queryable.Where(x => x.CustomerID % 2 == 0);
+        }
     }
 }

src/JQDT.MVC/JQDataTableAttribute.cs

@@ -45,6 +45,11 @@ public virtual void OnDataProcessed(ref object data, RequestInfoModel requestInf
             // No data processing logic by default;
         }
 
+        public virtual void OnSearchnDataProcessing(ref object data, RequestInfoModel requestInfoModel)
+        {
+            // No data processing logic by default;
+        }
+
         private void PerformOnActionExecuted(ActionExecutedContext filterContext)
         {
             var dataCollectionType = filterContext.Controller.ViewData.Model.GetType();
@@ -68,7 +73,8 @@ private void PerformOnActionExecuted(ActionExecutedContext filterContext)
 
         private void SubscribeToEvents(IApplicationBase application)
         {
-            application.OnDataProcessed += this.OnDataProcessed;
+            application.OnDataProcessedEvent += this.OnDataProcessed;
+            application.OnSearchDataProcessingEvent += this.OnSearchnDataProcessing;
         }
 
         private ActionResult FormatResult(object resultModel)

src/JQDT.WebAPI/JQDataTableAttribute.cs

@@ -56,7 +56,7 @@ private void PerformOnActionExecuted(HttpActionExecutedContext actionExecutedCon
 
         private void SubscribeToEvents(IApplicationBase application)
         {
-            application.OnDataProcessed += this.OnDataProcessed;
+            application.OnDataProcessedEvent += this.OnDataProcessed;
         }
 
         private object GetObjectResult(ResultModel result)

src/JQDT/Application/ApplicationBase.cs

@@ -31,7 +31,12 @@ public ApplicationBase(IDependencyResolver dependencyResolver)
         /// <summary>
         /// Occurs when [on data processed].
         /// </summary>
-        public event DataProcessorEventHandler OnDataProcessed;
+        public event DataProcessorEventHandler OnDataProcessedEvent = delegate { };
+
+        /// <summary>
+        /// Occurs when [on search data processing event].
+        /// </summary>
+        public event DataProcessorEventHandler OnSearchDataProcessingEvent = delegate { };
 
         /// <summary>
         /// Application entry point method. Executes all data processors.
@@ -88,7 +93,7 @@ public ResultModel Execute()
         private void PerformDataProcessorEventHandler(ref IQueryable<T> data, RequestInfoModel requestInfoModel)
         {
             var dataAsObj = (object)data;
-            this.OnDataProcessed(ref dataAsObj, requestInfoModel);
+            this.OnDataProcessedEvent(ref dataAsObj, requestInfoModel);
             data = (IQueryable<T>)dataAsObj;
         }
 
@@ -117,13 +122,26 @@ private IDataProcess<T> GetDataProcessChain(Type dataCollectionType)
         {
             var dataProcessChain = new DataProcessChain<T>();
 
-            dataProcessChain.AddDataProcessor(this.dependencyResolver.GetSearchDataProcessor<T>());
+            var searchDataProcessor = this.dependencyResolver.GetSearchDataProcessor<T>();
+            this.AttachEventsToDataprocessor((DataProcessBase<T>)searchDataProcessor);
+            dataProcessChain.AddDataProcessor(searchDataProcessor);
+
             dataProcessChain.AddDataProcessor(this.dependencyResolver.GetCustomFiltersDataProcessor<T>());
             dataProcessChain.AddDataProcessor(this.dependencyResolver.GetColumnsFilterDataProcessor<T>());
             dataProcessChain.AddDataProcessor(this.dependencyResolver.GetSortDataProcessor<T>());
             dataProcessChain.AddDataProcessor(this.dependencyResolver.GetPagingDataProcessor<T>());
 
             return dataProcessChain;
         }
+
+        private void AttachEventsToDataprocessor(DataProcessBase<T> dataProcessor)
+        {
+            dataProcessor.OnDataProcessingEvent += this.OnSearchDataProcessing;
+        }
+
+        public void OnSearchDataProcessing(ref object data, RequestInfoModel requestInfoModel)
+        {
+            this.OnSearchDataProcessingEvent(ref data, requestInfoModel);
+        }
     }
 }

src/JQDT/Application/IApplicationBase.cs

@@ -11,7 +11,12 @@ public interface IApplicationBase
         /// <summary>
         /// Occurs when [on data processed].
         /// </summary>
-        event DataProcessorEventHandler OnDataProcessed;
+        event DataProcessorEventHandler OnDataProcessedEvent;
+
+        /// <summary>
+        /// Occurs when [on search data processing event].
+        /// </summary>
+        event DataProcessorEventHandler OnSearchDataProcessingEvent;
 
         /// <summary>
         /// Application entry point method. Executes all data processors.

src/JQDT/DataProcessing/DataProcessBase.cs

@@ -2,6 +2,7 @@
 {
     using System;
     using System.Linq;
+    using JQDT.Delegates;
     using JQDT.Models;
 
     /// <summary>
@@ -16,6 +17,10 @@ internal abstract class DataProcessBase<T> : IDataProcess<T>
 
         private IQueryable<T> processedData;
 
+        public event DataProcessorEventHandler OnDataProcessingEvent = delegate { };
+
+        public event DataProcessorEventHandler OnDataProcessedEvent = delegate { };
+
         /// <summary>
         /// Gets the processed data.
         /// </summary>
@@ -50,8 +55,14 @@ public IQueryable<T> ProcessData(IQueryable<T> data, RequestInfoModel requestInf
                 throw new ArgumentNullException(NullRequestInfoModelExceptionMessage);
             }
 
+            // Execute events prior data processing
+            this.ExecuteOnDataprocessingEvents(ref data, requestInfoModel);
+
             this.processedData = this.OnProcessData(data, requestInfoModel);
 
+            // Execute events after the data has been processed
+            this.ExecuteOnDataprocessedEvents(ref data, requestInfoModel);
+
             return this.ProcessedData;
         }
 
@@ -62,5 +73,19 @@ public IQueryable<T> ProcessData(IQueryable<T> data, RequestInfoModel requestInf
         /// <param name="requestInfoModel">The request information model.</param>
         /// <returns><see cref="IQueryable{T}"/></returns>
         protected abstract IQueryable<T> OnProcessData(IQueryable<T> data, RequestInfoModel requestInfoModel);
+
+        private void ExecuteOnDataprocessingEvents(ref IQueryable<T> data, RequestInfoModel requestInfoModel)
+        {
+            var dataAsObj = (object)data;
+            this.OnDataProcessingEvent(ref dataAsObj, requestInfoModel);
+            data = (IQueryable<T>)dataAsObj;
+        }
+
+        private void ExecuteOnDataprocessedEvents(ref IQueryable<T> data, RequestInfoModel requestInfoModel)
+        {
+            var dataAsObj = (object)data;
+            this.OnDataProcessedEvent(ref dataAsObj, requestInfoModel);
+            data = (IQueryable<T>)dataAsObj;
+        }
     }
 }