Added tests for Transactional Outbox pattern and 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/Microservices/DomainFakers.cs

@@ -0,0 +1,26 @@
+using System;
+using Bogus;
+using TestBuildingBlocks;
+
+// @formatter:wrap_chained_method_calls chop_always
+// @formatter:keep_existing_linebreaks true
+
+namespace JsonApiDotNetCoreExampleTests.IntegrationTests.Microservices
+{
+    internal sealed class DomainFakers : FakerContainer
+    {
+        private readonly Lazy<Faker<DomainUser>> _lazyDomainUserFaker = new Lazy<Faker<DomainUser>>(() =>
+            new Faker<DomainUser>()
+                .UseSeed(GetFakerSeed())
+                .RuleFor(domainUser => domainUser.LoginName, faker => faker.Person.UserName)
+                .RuleFor(domainUser => domainUser.DisplayName, faker => faker.Person.FullName));
+
+        private readonly Lazy<Faker<DomainGroup>> _lazyDomainGroupFaker = new Lazy<Faker<DomainGroup>>(() =>
+            new Faker<DomainGroup>()
+                .UseSeed(GetFakerSeed())
+                .RuleFor(domainGroup => domainGroup.Name, faker => faker.Commerce.Department()));
+
+        public Faker<DomainUser> DomainUser => _lazyDomainUserFaker.Value;
+        public Faker<DomainGroup> DomainGroup => _lazyDomainGroupFaker.Value;
+    }
+}

test/JsonApiDotNetCoreExampleTests/IntegrationTests/Microservices/DomainGroup.cs

@@ -0,0 +1,18 @@
+using System;
+using System.Collections.Generic;
+using JetBrains.Annotations;
+using JsonApiDotNetCore.Resources;
+using JsonApiDotNetCore.Resources.Annotations;
+
+namespace JsonApiDotNetCoreExampleTests.IntegrationTests.Microservices
+{
+    [UsedImplicitly(ImplicitUseTargetFlags.Members)]
+    public sealed class DomainGroup : Identifiable<Guid>
+    {
+        [Attr]
+        public string Name { get; set; }
+
+        [HasMany]
+        public ISet<DomainUser> Users { get; set; }
+    }
+}

test/JsonApiDotNetCoreExampleTests/IntegrationTests/Microservices/DomainGroupsController.cs

@@ -0,0 +1,16 @@
+using System;
+using JsonApiDotNetCore.Configuration;
+using JsonApiDotNetCore.Controllers;
+using JsonApiDotNetCore.Services;
+using Microsoft.Extensions.Logging;
+
+namespace JsonApiDotNetCoreExampleTests.IntegrationTests.Microservices
+{
+    public sealed class DomainGroupsController : JsonApiController<DomainGroup, Guid>
+    {
+        public DomainGroupsController(IJsonApiOptions options, ILoggerFactory loggerFactory, IResourceService<DomainGroup, Guid> resourceService)
+            : base(options, loggerFactory, resourceService)
+        {
+        }
+    }
+}

test/JsonApiDotNetCoreExampleTests/IntegrationTests/Microservices/DomainUser.cs

@@ -0,0 +1,22 @@
+using System;
+using System.ComponentModel.DataAnnotations;
+using JetBrains.Annotations;
+using JsonApiDotNetCore.Resources;
+using JsonApiDotNetCore.Resources.Annotations;
+
+namespace JsonApiDotNetCoreExampleTests.IntegrationTests.Microservices
+{
+    [UsedImplicitly(ImplicitUseTargetFlags.Members)]
+    public sealed class DomainUser : Identifiable<Guid>
+    {
+        [Attr]
+        [Required]
+        public string LoginName { get; set; }
+
+        [Attr]
+        public string DisplayName { get; set; }
+
+        [HasOne]
+        public DomainGroup Group { get; set; }
+    }
+}

test/JsonApiDotNetCoreExampleTests/IntegrationTests/Microservices/DomainUsersController.cs

@@ -0,0 +1,16 @@
+using System;
+using JsonApiDotNetCore.Configuration;
+using JsonApiDotNetCore.Controllers;
+using JsonApiDotNetCore.Services;
+using Microsoft.Extensions.Logging;
+
+namespace JsonApiDotNetCoreExampleTests.IntegrationTests.Microservices
+{
+    public sealed class DomainUsersController : JsonApiController<DomainUser, Guid>
+    {
+        public DomainUsersController(IJsonApiOptions options, ILoggerFactory loggerFactory, IResourceService<DomainUser, Guid> resourceService)
+            : base(options, loggerFactory, resourceService)
+        {
+        }
+    }
+}

test/JsonApiDotNetCoreExampleTests/IntegrationTests/Microservices/FireAndForgetDelivery/FireForgetDbContext.cs

@@ -0,0 +1,17 @@
+using JetBrains.Annotations;
+using Microsoft.EntityFrameworkCore;
+
+namespace JsonApiDotNetCoreExampleTests.IntegrationTests.Microservices.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/Microservices/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.Microservices.Messages;
+
+namespace JsonApiDotNetCoreExampleTests.IntegrationTests.Microservices.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);
+        }
+    }
+}