UX / Password has registration / Configuration.

Author: eben-roux

Shuttle.Access.Application/GetEventSourcingCountsParticipant.cs

@@ -0,0 +1,65 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Options;
+using Shuttle.Mediator;
+using Shuttle.Recall.SqlServer.EventProcessing;
+using Shuttle.Recall.SqlServer.Storage;
+using System.Diagnostics.CodeAnalysis;
+using Shuttle.Recall;
+
+namespace Shuttle.Access.Application;
+
+[SuppressMessage("Security", "EF1002:Risk of vulnerability to SQL injection", Justification = "Schema and table names are from trusted configuration sources")]
+public class GetEventSourcingCountsParticipant(IOptions<SqlServerStorageOptions> sqlServerStorageOptions, IEventProcessorConfiguration eventProcessorConfiguration, SqlServerStorageDbContext sqlServerStorageDbContext, SqlServerEventProcessingDbContext sqlServerEventProcessingDbContext) : IParticipant<GetEventSourcingCounts>
+{
+    public async Task HandleAsync(GetEventSourcingCounts message, CancellationToken cancellationToken = default)
+    {
+        ArgumentNullException.ThrowIfNull(message);
+
+        message.MaximumSequenceNumber = await sqlServerStorageDbContext.Database
+            .SqlQueryRaw<long?>($@"SELECT MAX(SequenceNumber) [Value] FROM [{sqlServerStorageOptions.Value.Schema}].[PrimitiveEvent]")
+            .SingleAsync(cancellationToken) ?? 0;
+
+        var projectionCount = await sqlServerEventProcessingDbContext.Database
+            .SqlQueryRaw<int>($@"SELECT COUNT(*) [Value] FROM [{sqlServerStorageOptions.Value.Schema}].[Projection]")
+            .SingleAsync(cancellationToken);
+
+        message.HasUnsequencedPrimitiveEvents = await sqlServerStorageDbContext.Database.SqlQueryRaw<int>($@"
+SELECT
+    CASE
+        WHEN EXISTS
+        (
+            SELECT
+                NULL
+            FROM 
+                [{sqlServerStorageOptions.Value.Schema}].[PrimitiveEvent] 
+            WHERE 
+                SequenceNumber IS NULL
+        )
+        THEN 
+            1
+        ELSE 
+            0
+    END [VALUE]
+").SingleAsync(cancellationToken) > 0;
+
+        message.HasWaitingProjections = projectionCount != eventProcessorConfiguration.Projections.Count() ||
+                                        await sqlServerEventProcessingDbContext.Database.SqlQueryRaw<int>($@"
+SELECT
+    CASE
+        WHEN EXISTS
+        (
+            SELECT
+                NULL
+            FROM 
+                [{sqlServerStorageOptions.Value.Schema}].[Projection]
+            WHERE 
+                [SequenceNumber] < {message.MaximumSequenceNumber}
+        )
+        THEN 
+            1
+        ELSE 
+            0
+    END [VALUE]
+").SingleAsync(cancellationToken) == 1;
+    }
+}

Shuttle.Access.Application/Messages/ConfigureApplication.cs

@@ -0,0 +1,8 @@
+namespace Shuttle.Access.Application;
+
+public class GetEventSourcingCounts
+{
+    public long MaximumSequenceNumber { get; set; }
+    public bool HasUnsequencedPrimitiveEvents { get; set; }
+    public bool HasWaitingProjections { get; set; }
+}

Shuttle.Access.Application/Messages/GetEventSourcingCounts.cs

@@ -11,6 +11,7 @@
     <PackageReference Include="Shuttle.Mediator" Version="21.0.1" />
     <PackageReference Include="Shuttle.Hopper" Version="21.0.2" />
     <PackageReference Include="Shuttle.Recall" Version="21.0.3" />
+    <PackageReference Include="Shuttle.Recall.SqlServer.EventProcessing" Version="21.0.3" />
     <PackageReference Include="Shuttle.Recall.SqlServer.Storage" Version="21.0.3" />
   </ItemGroup>
 
@@ -31,7 +32,7 @@
 
   <PropertyGroup>
     <Description>Application concern implementations such as Shuttle.Mediator participants.</Description>
-    <Version>9.0.3</Version>
+    <Version>9.0.4</Version>
     <Authors>Eben Roux</Authors>
     <Company>Shuttle</Company>
     <Copyright>Copyright (c) 2025, Eben Roux</Copyright>

Shuttle.Access.Application/Shuttle.Access.Application.csproj

@@ -33,7 +33,7 @@
 
   <PropertyGroup>
     <Description>Authorization middleware for web API endpoints using Shuttle.Access.</Description>
-    <Version>9.0.2</Version>
+    <Version>9.0.4</Version>
     <Authors>Eben Roux</Authors>
     <Company>Shuttle</Company>
     <Copyright>Copyright (c) 2025, Eben Roux</Copyright>

Shuttle.Access.AspNetCore/Shuttle.Access.AspNetCore.csproj

@@ -27,7 +27,7 @@
 
   <PropertyGroup>
     <Description>Messages for use in Shuttle.Access implementations.</Description>
-    <Version>9.0.2</Version>
+    <Version>9.0.4</Version>
     <Authors>Eben Roux</Authors>
     <Company>Shuttle</Company>
     <Copyright>Copyright (c) 2025, Eben Roux</Copyright>

Shuttle.Access.Messages/Shuttle.Access.Messages.csproj

@@ -0,0 +1,3 @@
+namespace Shuttle.Access.Messages.v1;
+
+public class ConfigureApplication;

Shuttle.Access.Messages/v1/ConfigureApplication.cs

@@ -40,24 +40,18 @@ public AccessClientBuilder UseBearerAuthenticationProvider(Action<BearerAuthenti
             return accessClientBuilder;
         }
 
-        public AccessClientBuilder UsePasswordAuthenticationProvider(Action<PasswordAuthenticationInterceptorBuilder>? builder = null)
+        public AccessClientBuilder UsePasswordAuthenticationProvider(Action<PasswordAuthenticationInterceptorOptions>? configureOptions = null)
         {
             var services = Guard.AgainstNull(accessClientBuilder).Services;
 
             services.AddHttpClient<IAuthenticationInterceptor, PasswordAuthenticationInterceptor>("PasswordAuthenticationProvider");
 
-            var passwordAuthenticationProviderBuilder = new PasswordAuthenticationInterceptorBuilder(accessClientBuilder.Services);
-
-            builder?.Invoke(passwordAuthenticationProviderBuilder);
-
-            passwordAuthenticationProviderBuilder.Services
-                .Configure<PasswordAuthenticationInterceptorOptions>(options =>
-                {
-                    options.IdentityName = passwordAuthenticationProviderBuilder.Options.IdentityName;
-                    options.Password = passwordAuthenticationProviderBuilder.Options.Password;
-                });
+            services.Configure<PasswordAuthenticationInterceptorOptions>(options =>
+            {
+                configureOptions?.Invoke(options);
+            });
 
-            passwordAuthenticationProviderBuilder.Services.AddSingleton<IValidateOptions<PasswordAuthenticationInterceptorOptions>, PasswordAuthenticationInterceptorOptionsValidator>();
+            services.AddSingleton<IValidateOptions<PasswordAuthenticationInterceptorOptions>, PasswordAuthenticationInterceptorOptionsValidator>();
 
             services.AddOptions<AccessClientOptions>().Configure(options =>
             {

Shuttle.Access.RestClient/AccessClientBuilderExtensions.cs

@@ -33,7 +33,7 @@
 
   <PropertyGroup>
     <Description>A client used to interact with the restful Shuttle.Access web API.</Description>
-    <Version>9.0.2</Version>
+    <Version>9.0.4</Version>
     <Authors>Eben Roux</Authors>
     <Company>Shuttle</Company>
     <Copyright>Copyright (c) 2025, Eben Roux</Copyright>