Implemting async methods on AuditEventListener (sync for now)

Author: RogerKratz

Src/NHibernate.Envers.Tests/NHibernate.Envers.Tests.csproj

@@ -124,6 +124,7 @@
     <Compile Include="NetSpecific\Integration\Access\None\ManyToOne\Model.cs" />
     <Compile Include="NetSpecific\Integration\Access\None\SimpleProperty\Fixture.cs" />
     <Compile Include="NetSpecific\Integration\Access\None\SimpleProperty\Entity.cs" />
+    <Compile Include="NetSpecific\Integration\Async\AuditEventListenerAsyncTest.cs" />
     <Compile Include="NetSpecific\Integration\Component\BaseClassComponent.cs" />
     <Compile Include="NetSpecific\Integration\Component\BaseClassOwner.cs" />
     <Compile Include="NetSpecific\Integration\Component\DerivedClassComponent.cs" />

Src/NHibernate.Envers.Tests/NetSpecific/Integration/Async/AuditEventListenerAsyncTest.cs

@@ -0,0 +1,51 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using NHibernate.Envers.Tests.NetSpecific.Integration.BidirectionalList;
+using NUnit.Framework;
+using SharpTestsEx;
+
+namespace NHibernate.Envers.Tests.NetSpecific.Integration.Async
+{
+	public class AuditEventListenerAsyncTest : TestBase
+	{
+		public AuditEventListenerAsyncTest(string strategyType) : base(strategyType)
+		{
+		}
+
+		protected override void Initialize()
+		{
+		}
+
+		[Test]
+		public async void AsyncImplementationOfAuditEventListenerWorks()
+		{
+			var parent = new Parent();
+			var child = new Child { Parent = parent };
+			using (var tx = Session.BeginTransaction())
+			{
+				await Session.SaveAsync(parent);
+				await tx.CommitAsync();
+			}
+			using (var tx = Session.BeginTransaction())
+			{
+				parent.Children.Add(child);
+				await tx.CommitAsync();
+			}
+			using (var tx = Session.BeginTransaction())
+			{
+				parent.Name = Guid.NewGuid().ToString();
+				await tx.CommitAsync();
+			}
+			using (var tx = Session.BeginTransaction())
+			{
+				await Session.DeleteAsync(parent);
+				await tx.CommitAsync();
+			}
+			AuditReader().GetRevisions(typeof(Parent), parent.Id).Count()
+				.Should().Be.EqualTo(4);
+		}
+
+		protected override IEnumerable<string> Mappings { get; } = new[]{ "NetSpecific.Integration.BidirectionalList.Mapping.hbm.xml" };
+	}
+}

Src/NHibernate.Envers.Tests/NetSpecific/Integration/BidirectionalList/Mapping.hbm.xml

@@ -14,6 +14,7 @@
       <index column ="IndexOrder" />
       <one-to-many class="Child"/>
     </list>
+	  <property name="Name"/>
   </class>
   <class name="Child">
     <id name="Id">

Src/NHibernate.Envers.Tests/NetSpecific/Integration/BidirectionalList/Parent.cs

@@ -18,6 +18,7 @@ public virtual IList<Child> Children
 		{
 			get { return _children; }
 		}
+		public virtual string Name { get; set; }
 
 		public override bool Equals(object obj)
 		{

Src/NHibernate.Envers/Event/AuditEventListener.cs

@@ -106,7 +106,8 @@ private void addCollectionChangeWorkUnit(AuditProcess auditProcess, ISessionImpl
 
 		public Task OnPostInsertAsync(PostInsertEvent @event, CancellationToken cancellationToken)
 		{
-			throw new NotImplementedException();
+			OnPostInsert(@event);
+			return Task.CompletedTask;
 		}
 
 		public virtual void OnPostInsert(PostInsertEvent evt)
@@ -128,7 +129,8 @@ public virtual void OnPostInsert(PostInsertEvent evt)
 
 		public Task OnPostUpdateAsync(PostUpdateEvent @event, CancellationToken cancellationToken)
 		{
-			throw new NotImplementedException();
+			OnPostUpdate(@event);
+			return Task.CompletedTask;
 		}
 
 		public virtual void OnPostUpdate(PostUpdateEvent evt)
@@ -174,7 +176,8 @@ private static object[] postUpdateDbState(PostUpdateEvent evt)
 
 		public Task OnPostDeleteAsync(PostDeleteEvent @event, CancellationToken cancellationToken)
 		{
-			throw new NotImplementedException();
+			OnPostDelete(@event);
+			return Task.CompletedTask;
 		}
 
 		public virtual void OnPostDelete(PostDeleteEvent evt)
@@ -334,7 +337,8 @@ private static CollectionEntry getCollectionEntry(AbstractCollectionEvent evt)
 
 		public Task OnPreUpdateCollectionAsync(PreCollectionUpdateEvent @event, CancellationToken cancellationToken)
 		{
-			throw new NotImplementedException();
+			OnPreUpdateCollection(@event);
+			return Task.CompletedTask;
 		}
 
 		public virtual void OnPreUpdateCollection(PreCollectionUpdateEvent evt)
@@ -348,7 +352,8 @@ public virtual void OnPreUpdateCollection(PreCollectionUpdateEvent evt)
 
 		public Task OnPreRemoveCollectionAsync(PreCollectionRemoveEvent @event, CancellationToken cancellationToken)
 		{
-			throw new NotImplementedException();
+			OnPreRemoveCollection(@event);
+			return Task.CompletedTask;
 		}
 
 		public virtual void OnPreRemoveCollection(PreCollectionRemoveEvent evt)
@@ -375,7 +380,8 @@ public virtual void OnPreRemoveCollection(PreCollectionRemoveEvent evt)
 
 		public Task OnPostRecreateCollectionAsync(PostCollectionRecreateEvent @event, CancellationToken cancellationToken)
 		{
-			throw new NotImplementedException();
+			OnPostRecreateCollection(@event);
+			return Task.CompletedTask;
 		}
 
 		public virtual void OnPostRecreateCollection(PostCollectionRecreateEvent evt)