Fix test assertion for FilterOlEventTestData and support null in FilterOlMessage

Author: wjohnson

function-app/adb-to-purview/src/Function.Domain/Helpers/OlProcessing/ValidateOlEvent.cs

@@ -39,7 +39,11 @@ public ValidateOlEvent(ILoggerFactory loggerFactory)
         /// </summary>
         /// <param name="olEvent">OpenLineage Event message</param>
         /// <returns>true if input is valid, false if not</returns>
-        public bool Validate(Event olEvent){
+        public bool Validate(Event? olEvent){
+            if (olEvent == null){
+                _log.LogWarning("Event considered NOT valid as it was null");
+                return false;
+            }
             _log.LogInformation($"Validating input of an event with {olEvent.Inputs.Count} inputs and {olEvent.Outputs.Count} outputs");
             if (olEvent.Inputs.Count > 0 && olEvent.Outputs.Count > 0)
             {

function-app/adb-to-purview/src/Function.Domain/Services/IOlFilter.cs

@@ -8,7 +8,7 @@ namespace Function.Domain.Services
 {
     public interface IOlFilter
     {
-        bool FilterOlMessage(Event olEvent);
+        bool FilterOlMessage(Event? olEvent);
         string GetJobNamespace(Event olEvent);
     }
 }

function-app/adb-to-purview/src/Function.Domain/Services/OlFilter.cs

@@ -38,7 +38,7 @@ public OlFilter(ILoggerFactory loggerFactory)
         /// true: if the message should be passed on for further processing
         /// false: if the message should be filtered out
         /// </returns>
-        public bool FilterOlMessage(Event olEvent)
+        public bool FilterOlMessage(Event? olEvent)
         {
             try {
                 var validateEvent = new ValidateOlEvent(_loggerFactory);

function-app/adb-to-purview/tests/unit-tests/Function.Domain/Services/OlFilterTests.cs

@@ -4,10 +4,13 @@
 using Xunit;
 using Microsoft.Extensions.Logging.Abstractions;
 using Function.Domain.Services;
+using Function.Domain.Helpers;
+using Microsoft.Extensions.Logging;
 
 namespace UnitTests.Function.Domain.Services
 {
     public class OlFilterTests{
+        private IEventParser _eventParser;
 
         private NullLoggerFactory _mockLoggerFactory;
 
@@ -21,7 +24,10 @@ public OlFilterTests()
         public void FilterOlEvent_bool_FilterGoodEvents(string msgEvent, bool expectedResult)
         {
             IOlFilter filterOlEvent = new OlFilter(_mockLoggerFactory);
-            var rslt = filterOlEvent.FilterOlMessage(msgEvent);
+            var _log = _mockLoggerFactory.CreateLogger<OlFilterTests>();
+            var _eventParser = new EventParser(_log);
+            var parsedEvent = _eventParser.ParseOlEvent(msgEvent);
+            var rslt = filterOlEvent.FilterOlMessage(parsedEvent);
 
             Xunit.Assert.Equal(expectedResult, rslt);
         }