Added tests for fire-and-forget

Author: Bart Koelman

JsonApiDotNetCore.sln.DotSettings

@@ -621,6 +621,7 @@ $left$ = $right$;</s:String>
 	<s:Boolean x:Key="/Default/UserDictionary/Words/=Assignee/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/UserDictionary/Words/=Injectables/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/UserDictionary/Words/=linebreaks/@EntryIndexedValue">True</s:Boolean>
+	<s:Boolean x:Key="/Default/UserDictionary/Words/=Microservices/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/UserDictionary/Words/=navigations/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/UserDictionary/Words/=playlists/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/UserDictionary/Words/=Rewriter/@EntryIndexedValue">True</s:Boolean>

test/JsonApiDotNetCoreExampleTests/IntegrationTests/ResourceDefinitions/Writing/TransactionalOutboxPattern/DomainFakers.cs renamed to test/JsonApiDotNetCoreExampleTests/IntegrationTests/ResourceDefinitions/Writing/DomainFakers.cs

@@ -5,7 +5,7 @@
 // @formatter:wrap_chained_method_calls chop_always
 // @formatter:keep_existing_linebreaks true
 
-namespace JsonApiDotNetCoreExampleTests.IntegrationTests.ResourceDefinitions.Writing.TransactionalOutboxPattern
+namespace JsonApiDotNetCoreExampleTests.IntegrationTests.ResourceDefinitions.Writing
 {
     internal sealed class DomainFakers : FakerContainer
     {

test/JsonApiDotNetCoreExampleTests/IntegrationTests/ResourceDefinitions/Writing/TransactionalOutboxPattern/DomainGroup.cs renamed to test/JsonApiDotNetCoreExampleTests/IntegrationTests/ResourceDefinitions/Writing/DomainGroup.cs

@@ -4,7 +4,7 @@
 using JsonApiDotNetCore.Resources;
 using JsonApiDotNetCore.Resources.Annotations;
 
-namespace JsonApiDotNetCoreExampleTests.IntegrationTests.ResourceDefinitions.Writing.TransactionalOutboxPattern
+namespace JsonApiDotNetCoreExampleTests.IntegrationTests.ResourceDefinitions.Writing
 {
     [UsedImplicitly(ImplicitUseTargetFlags.Members)]
     public sealed class DomainGroup : Identifiable<Guid>

test/JsonApiDotNetCoreExampleTests/IntegrationTests/ResourceDefinitions/Writing/TransactionalOutboxPattern/DomainGroupsController.cs renamed to test/JsonApiDotNetCoreExampleTests/IntegrationTests/ResourceDefinitions/Writing/DomainGroupsController.cs

@@ -4,7 +4,7 @@
 using JsonApiDotNetCore.Services;
 using Microsoft.Extensions.Logging;
 
-namespace JsonApiDotNetCoreExampleTests.IntegrationTests.ResourceDefinitions.Writing.TransactionalOutboxPattern
+namespace JsonApiDotNetCoreExampleTests.IntegrationTests.ResourceDefinitions.Writing
 {
     public sealed class DomainGroupsController : JsonApiController<DomainGroup, Guid>
     {

test/JsonApiDotNetCoreExampleTests/IntegrationTests/ResourceDefinitions/Writing/TransactionalOutboxPattern/DomainUser.cs renamed to test/JsonApiDotNetCoreExampleTests/IntegrationTests/ResourceDefinitions/Writing/DomainUser.cs

@@ -4,7 +4,7 @@
 using JsonApiDotNetCore.Resources;
 using JsonApiDotNetCore.Resources.Annotations;
 
-namespace JsonApiDotNetCoreExampleTests.IntegrationTests.ResourceDefinitions.Writing.TransactionalOutboxPattern
+namespace JsonApiDotNetCoreExampleTests.IntegrationTests.ResourceDefinitions.Writing
 {
     [UsedImplicitly(ImplicitUseTargetFlags.Members)]
     public sealed class DomainUser : Identifiable<Guid>

test/JsonApiDotNetCoreExampleTests/IntegrationTests/ResourceDefinitions/Writing/TransactionalOutboxPattern/DomainUsersController.cs renamed to test/JsonApiDotNetCoreExampleTests/IntegrationTests/ResourceDefinitions/Writing/DomainUsersController.cs

@@ -4,7 +4,7 @@
 using JsonApiDotNetCore.Services;
 using Microsoft.Extensions.Logging;
 
-namespace JsonApiDotNetCoreExampleTests.IntegrationTests.ResourceDefinitions.Writing.TransactionalOutboxPattern
+namespace JsonApiDotNetCoreExampleTests.IntegrationTests.ResourceDefinitions.Writing
 {
     public sealed class DomainUsersController : JsonApiController<DomainUser, Guid>
     {

test/JsonApiDotNetCoreExampleTests/IntegrationTests/ResourceDefinitions/Writing/FireAndForgetDelivery/FireForgetDbContext.cs

@@ -0,0 +1,17 @@
+using JetBrains.Annotations;
+using Microsoft.EntityFrameworkCore;
+
+namespace JsonApiDotNetCoreExampleTests.IntegrationTests.ResourceDefinitions.Writing.FireAndForgetDelivery
+{
+    [UsedImplicitly(ImplicitUseTargetFlags.Members)]
+    public sealed class FireForgetDbContext : DbContext
+    {
+        public DbSet<DomainUser> Users { get; set; }
+        public DbSet<DomainGroup> Groups { get; set; }
+
+        public FireForgetDbContext(DbContextOptions<FireForgetDbContext> options)
+            : base(options)
+        {
+        }
+    }
+}

test/JsonApiDotNetCoreExampleTests/IntegrationTests/ResourceDefinitions/Writing/FireAndForgetDelivery/FireForgetGroupDefinition.cs

@@ -0,0 +1,46 @@
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+using JetBrains.Annotations;
+using JsonApiDotNetCore.Configuration;
+using JsonApiDotNetCore.Middleware;
+using JsonApiDotNetCoreExampleTests.IntegrationTests.ResourceDefinitions.Writing.Messages;
+
+namespace JsonApiDotNetCoreExampleTests.IntegrationTests.ResourceDefinitions.Writing.FireAndForgetDelivery
+{
+    [UsedImplicitly(ImplicitUseKindFlags.InstantiatedNoFixedConstructorSignature)]
+    public sealed class FireForgetGroupDefinition : MessagingGroupDefinition
+    {
+        private readonly MessageBroker _messageBroker;
+        private DomainGroup _groupToDelete;
+
+        public FireForgetGroupDefinition(IResourceGraph resourceGraph, FireForgetDbContext dbContext, MessageBroker messageBroker)
+            : base(resourceGraph, dbContext.Users, dbContext.Groups)
+        {
+            _messageBroker = messageBroker;
+        }
+
+        public override async Task OnWritingAsync(DomainGroup group, OperationKind operationKind, CancellationToken cancellationToken)
+        {
+            if (operationKind == OperationKind.DeleteResource)
+            {
+                _groupToDelete = await base.GetGroupToDeleteAsync(group.Id, cancellationToken);
+            }
+        }
+
+        public override Task OnWriteSucceededAsync(DomainGroup group, OperationKind operationKind, CancellationToken cancellationToken)
+        {
+            return FinishWriteAsync(group, operationKind, cancellationToken);
+        }
+
+        protected override Task FlushMessageAsync(OutgoingMessage message, CancellationToken cancellationToken)
+        {
+            return _messageBroker.PostMessageAsync(message, cancellationToken);
+        }
+
+        protected override Task<DomainGroup> GetGroupToDeleteAsync(Guid groupId, CancellationToken cancellationToken)
+        {
+            return Task.FromResult(_groupToDelete);
+        }
+    }
+}