Completed the new create application page. Updated typescript tooling and DotNetCqs.

Author: jgauffin

src/Server/Coderr.Server.Api.Client/codeRR.Server.Api.Client.csproj

@@ -22,7 +22,7 @@
     <AssemblyName>Coderr.Server.Api.Client</AssemblyName>
   </PropertyGroup>
   <ItemGroup>
-    <PackageReference Include="DotNetCqs" Version="2.0.5" />
+    <PackageReference Include="DotNetCqs" Version="2.0.7" />
     <PackageReference Include="System.ComponentModel.Annotations" Version="4.4.0" />
   </ItemGroup>
   <ItemGroup>

src/Server/Coderr.Server.Api/codeRR.Server.Api.csproj

@@ -25,7 +25,7 @@
     <NoWarn>1701;1702;1705;1591</NoWarn>
   </PropertyGroup>
   <ItemGroup>
-    <PackageReference Include="DotNetCqs" Version="2.0.5" />
+    <PackageReference Include="DotNetCqs" Version="2.0.7" />
   </ItemGroup>
   <ItemGroup Condition="'$(TargetFramework)' == 'net452'">
     <Reference Include="System.Net.Http" />

src/Server/Coderr.Server.App/Core/Applications/CommandHandlers/CreateApplicationHandler.cs

@@ -41,8 +41,6 @@ await _repository.CreateAsync(new ApplicationTeamMember(app.Id, creator.AccountI
                 Roles = new[] {ApplicationRole.Admin, ApplicationRole.Member},
             });
 
-            // WebProject redirects to update all credentials
-
             var evt = new ApplicationCreated(app.Id, app.Name, command.UserId, command.ApplicationKey, app.SharedSecret);
             await context.SendAsync(evt);
         }

src/Server/Coderr.Server.App/codeRR.Server.App.csproj

@@ -7,7 +7,7 @@
   </PropertyGroup>
   <ItemGroup>
     <PackageReference Include="ColorCode" Version="1.0.1" />
-    <PackageReference Include="DotNetCqs" Version="2.0.5" />
+    <PackageReference Include="DotNetCqs" Version="2.0.7" />
     <PackageReference Include="Griffin.Container" Version="1.1.8" />
     <PackageReference Include="Griffin.Framework" Version="2.0.0-alpha01" />
     <PackageReference Include="log4net" Version="2.0.8" />

src/Server/Coderr.Server.Infrastructure/codeRR.Server.Infrastructure.csproj

@@ -5,7 +5,7 @@
     <AssemblyName>Coderr.Server.Infrastructure</AssemblyName>
   </PropertyGroup>
   <ItemGroup>
-    <PackageReference Include="DotNetCqs" Version="2.0.5" />
+    <PackageReference Include="DotNetCqs" Version="2.0.7" />
     <PackageReference Include="Griffin.Container" Version="1.1.8" />
     <PackageReference Include="Griffin.Framework" Version="2.0.0-alpha01" />
     <PackageReference Include="log4net" Version="2.0.8" />

src/Server/Coderr.Server.ReportAnalyzer/codeRR.Server.ReportAnalyzer.csproj

@@ -6,7 +6,7 @@
     <DefaultItemExcludes>$(DefaultItemExcludes);**\*.DotSettings;</DefaultItemExcludes>
   </PropertyGroup>
   <ItemGroup>
-    <PackageReference Include="DotNetCqs" Version="2.0.5" />
+    <PackageReference Include="DotNetCqs" Version="2.0.7" />
     <PackageReference Include="Griffin.Container" Version="1.1.8" />
     <PackageReference Include="Griffin.Framework" Version="2.0.0-alpha01" />
     <PackageReference Include="log4net" Version="2.0.8" />

src/Server/Coderr.Server.SqlServer.Tests/codeRR.Server.SqlServer.Tests.csproj

@@ -9,7 +9,7 @@
 	  <PackageReference Include="xunit" Version="2.3.1" />
 	  <PackageReference Include="FluentAssertions" Version="4.19.4" />
 		<PackageReference Include="NSubstitute" Version="3.1.0" />
-	  <PackageReference Include="DotNetCqs" Version="2.0.5" />
+	  <PackageReference Include="DotNetCqs" Version="2.0.7" />
 	</ItemGroup>
 	<ItemGroup>
 	  <ProjectReference Include="..\Coderr.Server.SqlServer\codeRR.Server.SqlServer.csproj" />

src/Server/Coderr.Server.SqlServer/codeRR.Server.SqlServer.csproj

@@ -5,7 +5,7 @@
     <AssemblyName>Coderr.Server.SqlServer</AssemblyName>
   </PropertyGroup>
   <ItemGroup>
-  <PackageReference Include="DotNetCqs" Version="2.0.5" />
+  <PackageReference Include="DotNetCqs" Version="2.0.7" />
   <PackageReference Include="Griffin.Container" Version="1.1.8" />
   <PackageReference Include="Griffin.Framework" Version="2.0.0-alpha01" />
   <PackageReference Include="log4net" Version="2.0.8" />

src/Server/Coderr.Server.Web/App_Start/Services/ServiceRunner.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Data;
 using System.Diagnostics;
 using System.IO;
 using System.Linq;
@@ -71,18 +72,19 @@ public void Start(IAppBuilder app)
                     registrar.RegisterService(x => CreateQueueListener(x, "Feedback", "Messaging"), Lifetime.Singleton);
                     registrar.RegisterService<IMessageQueueProvider>(x =>
                     {
-                        return new AdoNetMessageQueueProvider(
-                            () => DbConnectionFactory.Open(Startup.ConnectionStringName, true),
-                            new MessagingSerializer(typeof(AdoNetMessageDto))
-                        );
+                        Func<IDbConnection> dbFactory = () => DbConnectionFactory.Open(Startup.ConnectionStringName, true);
+                        var serializer = new MessagingSerializer(typeof(AdoNetMessageDto));
+                        var provider = new AdoNetMessageQueueProvider(dbFactory, serializer);
+                        return provider;
                     }, Lifetime.Singleton);
 
                     // let us guard it since it runs events in the background.
                     //var service = registrar.Registrations.First(x => x.Implements(typeof(IMessageBus)));
                     //service.AddService(typeof(IApplicationService));
                 }, Startup.ConfigurationStore);
 
-                Container.ResolveAll<QueueListener>()
+                var listeners = Container.ResolveAll<QueueListener>().ToArray();
+                listeners
                     .ForEach(x => x
                         .RunAsync(_shutdownToken.Token)
                         .ContinueWith(OnStopped)
@@ -175,6 +177,7 @@ private QueueListener CreateQueueListener(IServiceLocator locator, string inboun
             {
                 RetryAttempts = new[]
                     {TimeSpan.FromMilliseconds(500), TimeSpan.FromSeconds(1), TimeSpan.FromSeconds(2)},
+                MessageInvokerFactory = scope => new MessageInvoker(scope),
                 Logger = Logga
             };
             listener.PoisonMessageDetected += (sender, args) =>