Fixed issue with db bootstrapping and added a sample project.

Author: HeyJoel

src/Cofoundry.Plugins.BackgroundTasks.Hangfire.sln

@@ -3,7 +3,11 @@ Microsoft Visual Studio Solution File, Format Version 12.00
 # Visual Studio 15
 VisualStudioVersion = 15.0.26430.13
 MinimumVisualStudioVersion = 10.0.40219.1
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Cofoundry.Plugins.BackgroundTasks.Hangfire", "Cofoundry.Plugins.BackgroundTasks.Hangfire\Cofoundry.Plugins.BackgroundTasks.Hangfire.csproj", "{962BB845-1E06-4775-9C29-32E11B257603}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Cofoundry.Plugins.BackgroundTasks.Hangfire", "Cofoundry.Plugins.BackgroundTasks.Hangfire\Cofoundry.Plugins.BackgroundTasks.Hangfire.csproj", "{962BB845-1E06-4775-9C29-32E11B257603}"
+EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "samples", "samples", "{D4929788-4924-4E4A-927B-1E914C835AF1}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "HangfireSample", "HangfireSample\HangfireSample.csproj", "{0661510F-9EB5-4688-9934-DA72F90791A6}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -15,8 +19,18 @@ Global
 		{962BB845-1E06-4775-9C29-32E11B257603}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{962BB845-1E06-4775-9C29-32E11B257603}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{962BB845-1E06-4775-9C29-32E11B257603}.Release|Any CPU.Build.0 = Release|Any CPU
+		{0661510F-9EB5-4688-9934-DA72F90791A6}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{0661510F-9EB5-4688-9934-DA72F90791A6}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{0661510F-9EB5-4688-9934-DA72F90791A6}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{0661510F-9EB5-4688-9934-DA72F90791A6}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
 	EndGlobalSection
+	GlobalSection(NestedProjects) = preSolution
+		{0661510F-9EB5-4688-9934-DA72F90791A6} = {D4929788-4924-4E4A-927B-1E914C835AF1}
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {F641408F-3FD6-4BA4-A1F2-2369F8D81358}
+	EndGlobalSection
 EndGlobal

src/Cofoundry.Plugins.BackgroundTasks.Hangfire/Startup/HangfireInitializationMiddleware.cs

@@ -0,0 +1,56 @@
+using Microsoft.AspNetCore.Http;
+using System;
+using System.Collections.Generic;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.Extensions.DependencyInjection;
+
+namespace Cofoundry.Plugins.BackgroundTasks.Hangfire
+{
+    public class HangfireInitializationMiddleware
+    {
+        private static bool isInitialized = false;
+        private static object _isInitializedLock = new object();
+        private readonly RequestDelegate _next;
+
+        public HangfireInitializationMiddleware(
+            RequestDelegate next
+            )
+        {
+            _next = next;
+        }
+
+        public async Task Invoke(HttpContext cx)
+        {
+            bool runInitialize = false;
+
+            if (!isInitialized)
+            {
+                lock (_isInitializedLock)
+                {
+                    if (!isInitialized)
+                    {
+                        isInitialized = true;
+                        runInitialize = true;
+                    }
+                }
+
+                if (runInitialize)
+                {
+                    try
+                    {
+                        var initializer = cx.RequestServices.GetService<IHangfireBackgroundTaskInitializer>();
+                        initializer.Initialize();
+                    }
+                    catch (Exception ex)
+                    {
+                        isInitialized = false;
+                        throw;
+                    }
+                }
+            }
+
+            await _next.Invoke(cx);
+        }
+    }
+}

src/Cofoundry.Plugins.BackgroundTasks.Hangfire/Startup/HangfireStartupConfigurationTask.cs

@@ -13,7 +13,9 @@ namespace Cofoundry.Plugins.BackgroundTasks.Hangfire
     /// To customize the startup process you can override IHangfireBackgroundTaskInitializer
     /// and IHangfireServerInitializer implementations, or just create your own plugin.
     /// </remarks>
-    public class HangfireStartupConfigurationTask : IRunBeforeStartupConfigurationTask
+    public class HangfireStartupConfigurationTask
+        : IRunBeforeStartupConfigurationTask
+        , IRunAfterStartupConfigurationTask
     {
         private readonly IHangfireBackgroundTaskInitializer _hangfireBackgroundTaskInitializer;
         private readonly IHangfireServerInitializer _hangfireServerInitializer;
@@ -27,17 +29,16 @@ IHangfireServerInitializer hangfireServerInitializer
             _hangfireServerInitializer = hangfireServerInitializer;
         }
 
-        public int Ordering
-        {
-            get { return (int)StartupTaskOrdering.Normal; }
-        }
+        public int Ordering { get; } = (int)StartupTaskOrdering.Normal;
 
         public ICollection<Type> RunBefore { get; } = new Type[] { typeof(MvcStartupConfigurationTask) };
 
+        public ICollection<Type> RunAfter { get; } = new Type[] { typeof(AutoUpdateMiddlewareStartupConfigurationTask) };
+
         public void Configure(IApplicationBuilder app)
         {
             _hangfireServerInitializer.Initialize(app);
-            _hangfireBackgroundTaskInitializer.Initialize();
+            app.UseMiddleware<HangfireInitializationMiddleware>();
         }
     }
 }

src/Cofoundry.Plugins.BackgroundTasks.Hangfire/Startup/HangfireStartupServiceConfigurationTask.cs

@@ -40,7 +40,7 @@ public void ConfigureServices(IMvcBuilder mvcBuilder)
                 .AddHangfire(configuration => configuration
                     .UseSqlServerStorage(connectionString, new SqlServerStorageOptions()
                     {
-                        PrepareSchemaIfNecessary = isDbLocked
+                        PrepareSchemaIfNecessary = !isDbLocked
                     })
                     .UseFilter(new AutomaticRetryAttribute { Attempts = 0 })
                     );

src/Cofoundry.Plugins.BackgroundTasks.Hangfire/Startup/IHangfireBackgroundTaskInitializer.cs

@@ -12,10 +12,6 @@ namespace Cofoundry.Plugins.BackgroundTasks.Hangfire
     /// </summary>
     public interface IHangfireBackgroundTaskInitializer
     {
-        #region public methods
-
         void Initialize();
-
-        #endregion
     }
 }

src/HangfireSample/Cofoundry/BackgroundTasks/BackgroundTaskRegistration.cs

@@ -0,0 +1,16 @@
+using Cofoundry.Core.BackgroundTasks;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace HangfireSample.Cofoundry.BackgroundTasks
+{
+    public class BackgroundTaskRegistration : IBackgroundTaskRegistration
+    {
+        public void Register(IBackgroundTaskScheduler scheduler)
+        {
+            scheduler.RegisterAsyncRecurringTask<ProductAddingBackgroundTask>(1);
+        }
+    }
+}

src/HangfireSample/Cofoundry/BackgroundTasks/ProductAddingBackgroundTask.cs

@@ -0,0 +1,41 @@
+using Cofoundry.Core.BackgroundTasks;
+using Cofoundry.Domain;
+using Cofoundry.Domain.CQS;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace HangfireSample.Cofoundry.BackgroundTasks
+{
+    public class ProductAddingBackgroundTask : IAsyncRecurringBackgroundTask
+    {
+        private readonly ICommandExecutor _commandExecutor;
+        private readonly IExecutionContextFactory _executionContextFactory;
+
+        public ProductAddingBackgroundTask(
+            ICommandExecutor commandExecutor,
+            IExecutionContextFactory executionContextFactory
+            )
+        {
+            _commandExecutor = commandExecutor;
+            _executionContextFactory = executionContextFactory;
+        }
+
+        public async Task ExecuteAsync()
+        {
+            var title = Guid.NewGuid();
+            var command = new AddCustomEntityCommand()
+            {
+                CustomEntityDefinitionCode = ProductCustomEntityDefinition.DefinitionCode,
+                Title = title.ToString(),
+                Model = new ProductDataModel() { Description = "Description of " + title },
+                Publish = true
+            };
+
+            var elevatedExecutionContext = await _executionContextFactory.CreateSystemUserExecutionContextAsync();
+
+            await _commandExecutor.ExecuteAsync(command, elevatedExecutionContext);
+        }
+    }
+}

src/HangfireSample/Cofoundry/CustomEntities/Product/ProductCustomEntityDefinition.cs

@@ -0,0 +1,29 @@
+using Cofoundry.Domain;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace HangfireSample
+{
+    public class ProductCustomEntityDefinition : ICustomEntityDefinition<ProductDataModel>
+    {
+        public const string DefinitionCode = "SPLPRD";
+
+        public string CustomEntityDefinitionCode => DefinitionCode;
+
+        public string Name => "Product";
+
+        public string NamePlural => "Products";
+
+        public string Description => "Example description";
+
+        public bool ForceUrlSlugUniqueness => false;
+
+        public bool HasLocale => false;
+
+        public bool AutoGenerateUrlSlug => true;
+
+        public bool AutoPublish => true;
+    }
+}

src/HangfireSample/Cofoundry/CustomEntities/Product/ProductDataModel.cs

@@ -0,0 +1,15 @@
+using Cofoundry.Domain;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace HangfireSample
+{
+    public class ProductDataModel : ICustomEntityDataModel
+    {
+        [Required]
+        public string Description { get; set; }
+    }
+}

src/HangfireSample/Controllers/HomeController.cs

@@ -0,0 +1,35 @@
+using Cofoundry.Domain;
+using Cofoundry.Domain.CQS;
+using Microsoft.AspNetCore.Mvc;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace HangfireSample.Controllers
+{
+    public class HomeController : Controller
+    {
+        private readonly IQueryExecutor _queryExecutor;
+
+        public HomeController(
+            IQueryExecutor queryExecutor
+            )
+        {
+            _queryExecutor = queryExecutor;
+        }
+
+        [Route("")]
+        public async Task<IActionResult> Index()
+        {
+            var query = new SearchCustomEntityRenderSummariesQuery()
+            {
+                CustomEntityDefinitionCode = ProductCustomEntityDefinition.DefinitionCode,
+                PageSize = 10
+            };
+
+            var result = await _queryExecutor.ExecuteAsync(query);
+            return View(result);
+        }
+    }
+}