Release/v1.1.0

.github/workflows/k6-test-multi.yml

@@ -3,7 +3,6 @@ name: k6 Test with Publish - Preview & Final
 permissions:
   contents: read
   actions: read
-  id-token: write
 
 on:
   push:
@@ -15,7 +14,7 @@ on:
       version:
         description: "NuGet package version to use"
         required: false
-        default: "1.1.0-beta.1"
+        default: "10.1.0-beta.1"
 
 jobs:
   pack-nupkgs:
@@ -86,15 +85,20 @@ jobs:
         with:
           dotnet-version: '9.0.x'
 
-      - name: NuGet login (OIDC → temp API key)
+      - name: Install .NET 10
+        uses: actions/setup-dotnet@v4
+        with:
+          dotnet-version: '10.0.x'
+
+      - name: NuGet login
         uses: NuGet/login@v1
-        id: login
+        id: nuget-login
         with:
           user: ${{ secrets.NUGET_USER }}
 
       - name: Publish NuGet packages
         env:
-          NUGET_API_KEY: ${{ steps.login.outputs.NUGET_API_KEY }}
+          NUGET_API_KEY: ${{ steps.nuget-login.outputs.NUGET_API_KEY }}
         run: |
           for pkg in ./nupkgs/*.nupkg; do
             echo "Publishing $pkg..."

.github/workflows/k6-test-single.yml

@@ -51,12 +51,6 @@ jobs:
       - name: Checkout code
         uses: actions/checkout@v3
 
-      - name: Install Docker Compose
-        run: |
-          sudo curl -L "https://github.com/docker/compose/releases/download/v2.29.2/docker-compose-$(uname -s)-$(uname -m)" -o /usr/local/bin/docker-compose
-          sudo chmod +x /usr/local/bin/docker-compose
-          docker-compose version
-
       - name: Download Environment
         run: |  
 
@@ -93,10 +87,10 @@ jobs:
           path: ${{ env.PROJECT_FOLDER }}/nupkgs
 
       - name: Build and start services
-        run: docker-compose -f test/integration/k6-environment/payment-processor/docker-compose.yml up -d
+        run: docker compose -f test/integration/k6-environment/payment-processor/docker-compose.yml up -d
 
       - name: Build and start services
-        run: cd $PROJECT_FOLDER && docker-compose up -d --build
+        run: cd $PROJECT_FOLDER && docker compose up -d --build
 
       - name: Wait for nginx to be healthy (5 successes)
         run: |
@@ -138,24 +132,35 @@ jobs:
           retention-days: 1
 
       - name: Create Comment MD File
+        if: always()
         run: |
           echo "## k6 Test Results" > comment.md
           echo "Hash: ${{ github.sha }}" >> comment.md
-          echo "\`\`\`json" >> comment.md
-          cat ${RESULTS_FILE} >> comment.md
-          echo "\n\`\`\`" >> comment.md
+          echo '```json' >> comment.md
+
+          if [ -f "${RESULTS_FILE}" ]; then
+            cat "${RESULTS_FILE}" >> comment.md
+          else
+            echo "// No k6 results file found (${RESULTS_FILE})" >> comment.md
+          fi
+
+          echo '```' >> comment.md
 
       - name: Append Docker Compose Logs
+        if: always()
         run: |
           echo "## Docker Compose Logs" >> comment.md
           echo '```log' >> comment.md
-          cd $PROJECT_FOLDER && docker-compose logs >> ../comment.md || true
+          cd $PROJECT_FOLDER && docker compose logs
+          cd $PROJECT_FOLDER && docker compose logs >> comment.md || true
           echo '```' >> comment.md
 
       - name: Echo comment.md contents
+        if: always()
         run: cat comment.md
 
       - name: Upload comment.md as artifact
+        if: always()
         uses: actions/upload-artifact@v4
         with:
             name: comment-md-${{ env.MODE }}-${{ env.PROJECT }}-${{ matrix.run_id }}

.github/workflows/pack-nupkgs.yml

@@ -35,6 +35,11 @@ jobs:
         with:
           dotnet-version: '9.0.x'
 
+      - name: Install .NET 10
+        uses: actions/setup-dotnet@v4
+        with:
+          dotnet-version: '10.0.x'
+
       - name: Determine version
         id: version
         run: |

.github/workflows/sonarqube.yml

@@ -33,6 +33,11 @@ jobs:
         with:
           dotnet-version: '9.0.x'
 
+      - name: Install .NET 10
+        uses: actions/setup-dotnet@v4
+        with:
+          dotnet-version: '10.0.x'
+
       - uses: actions/checkout@v4
         with:
           fetch-depth: 0

src/ReactiveLock.Core/ReactiveLock.Core.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFrameworks>net8.0;net9.0</TargetFrameworks>
+    <TargetFrameworks>net8.0;net9.0;net10.0</TargetFrameworks>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
 

src/ReactiveLock.DependencyInjection/ReactiveLock.DependencyInjection.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFrameworks>net8.0;net9.0</TargetFrameworks>
+    <TargetFrameworks>net8.0;net9.0;net10.0</TargetFrameworks>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
     <TargetsForTfmSpecificBuildOutput>$(TargetsForTfmSpecificBuildOutput);IncludeProjectReferencesWithPrivateAssetsAttributeInPackage</TargetsForTfmSpecificBuildOutput>

src/ReactiveLock.Distributed.Grpc/ReactiveLock.Distributed.Grpc.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFrameworks>net8.0;net9.0</TargetFrameworks>
+    <TargetFrameworks>net8.0;net9.0;net10.0</TargetFrameworks>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
     <TargetsForTfmSpecificBuildOutput>$(TargetsForTfmSpecificBuildOutput);IncludeProjectReferencesWithPrivateAssetsAttributeInPackage</TargetsForTfmSpecificBuildOutput>

src/ReactiveLock.Distributed.Grpc/ReactiveLockGrpcTrackerExtensions.cs

@@ -33,23 +33,42 @@
 /// </summary>
 public static class ReactiveLockGrpcTrackerExtensions
 {
-    private static bool? IsInitializing { get; set; }
-    private static ConcurrentQueue<string> RegisteredLocks { get; } = new();
-    private static string? StoredInstanceName { get; set; }
-    private static List<IReactiveLockGrpcClientAdapter> RemoteClients  { get; set; } = new();
+    private static ReactiveLockGrpcTrackerExtensionsState? ExtensionsState { get; set; }
 
     public static void InitializeDistributedGrpcReactiveLock(this IServiceCollection services, string instanceName, params string[] replicaGrpcServers)
     {
-        ReactiveLockConventions.RegisterFactory(services);
-        StoredInstanceName = instanceName;
-        RemoteClients.AddRange(
+        InitializeDistributedGrpcReactiveLock(services, instanceName);
+        ArgumentNullException.ThrowIfNull(replicaGrpcServers);
+
+        ExtensionsState?.RemoteClients.AddRange(
             replicaGrpcServers.Select(url =>
                 new ReactiveLockGrpcClientAdapter(
                     new ReactiveLockGrpcClient(GrpcChannel.ForAddress(url))
                 )
             )
         );
     }
+
+    public static void InitializeDistributedGrpcReactiveLock(
+        this IServiceCollection services,
+        string instanceName,
+        params IReactiveLockGrpcClientAdapter[] remoteClients)
+    {
+        InitializeDistributedGrpcReactiveLock(services, instanceName);
+        ArgumentNullException.ThrowIfNull(remoteClients);
+
+        ExtensionsState?.RemoteClients.AddRange(remoteClients);
+    }
+
+    private static void InitializeDistributedGrpcReactiveLock(IServiceCollection services, string instanceName)
+    {
+        ReactiveLockConventions.RegisterFactory(services);
+
+        ExtensionsState = string.IsNullOrEmpty(instanceName)
+            ? null
+            : new(instanceName);
+    }
+
     /// <summary>
     /// Registers distributed gRPC reactive lock services, configuring lock state, controller, and handlers.
     /// </summary>
@@ -91,7 +110,7 @@ public static IServiceCollection AddDistributedGrpcReactiveLock(
         TimeSpan instanceExpirationPeriodTimeSpan,
         TimeSpan instanceRecoverPeriodTimeSpan) resiliencyParameters = default)
     {
-        if (RemoteClients.Count == 0 || string.IsNullOrEmpty(StoredInstanceName))
+        if (ExtensionsState == null || ExtensionsState.RemoteClients.Count == 0)
         {
             throw new InvalidOperationException(
                 "InstanceName not initialized. Call InitializeDistributedGrpcReactiveLock before adding distributed Grpc reactive locks.");
@@ -100,9 +119,8 @@ public static IServiceCollection AddDistributedGrpcReactiveLock(
         ReactiveLockConventions.RegisterState(services, lockKey, onLockedHandlers, onUnlockedHandlers);
         ReactiveLockConventions.RegisterController(services, lockKey, _ =>
         {
-            var isInitializing = IsInitializing.HasValue && IsInitializing.Value;
-            var isNotInitializing = !isInitializing;
-            var hasPendingLockRegistrations = !RegisteredLocks.IsEmpty;
+            var isNotInitializing = !ExtensionsState.IsInitializing;
+            var hasPendingLockRegistrations = !ExtensionsState.RegisteredLocks.IsEmpty;
 
             if (isNotInitializing && hasPendingLockRegistrations)
             {
@@ -111,16 +129,16 @@ public static IServiceCollection AddDistributedGrpcReactiveLock(
                     Please ensure you're calling 'await app.UseDistributedGrpcReactiveLockAsync();'
                     on your IApplicationBuilder instance after 'var app = builder.Build();'.");
             }
-            var store = new ReactiveLockGrpcTrackerStore(RemoteClients, StoredInstanceName, customAsyncStorePolicy,
+            var store = new ReactiveLockGrpcTrackerStore(ExtensionsState.RemoteClients, ExtensionsState.InstanceName, customAsyncStorePolicy,
                 resiliencyParameters,
                 lockKey);
             return new ReactiveLockTrackerController(store, busyThreshold);
         });
 
-        RegisteredLocks.Enqueue(lockKey);
+        ExtensionsState.RegisteredLocks.Enqueue(lockKey);
         return services;
     }
-    
+
     private static async Task SubscribeToUpdates(
         IReactiveLockGrpcClientAdapter client,
         string storedInstanceName,
@@ -157,16 +175,21 @@ public static async Task UseDistributedGrpcReactiveLockAsync(
             this IApplicationBuilder app,
             IAsyncPolicy? customAsyncSubscriberPolicy = default)
     {
-        IsInitializing = true;
-        var factory = app.ApplicationServices.GetRequiredService<IReactiveLockTrackerFactory>();
+        if (ExtensionsState == null || ExtensionsState.RemoteClients.Count == 0)
+        {
+            throw new InvalidOperationException(
+                "InstanceName not initialized. Call InitializeDistributedGrpcReactiveLock before adding distributed Grpc reactive locks.");
+        }
 
-        var instanceStoredInstanceName = StoredInstanceName!;
-        var instanceRemoteClients = RemoteClients;
+        ExtensionsState.IsInitializing = true;
+        var factory = app.ApplicationServices.GetRequiredService<IReactiveLockTrackerFactory>();
 
+        var instanceStoredInstanceName = ExtensionsState.InstanceName;
+        var instanceRemoteClients = ExtensionsState.RemoteClients;
         var readySignals = new List<Task>();
         var retryPolicy = ReactiveLockPollyPolicies.UseOrCreateDefaultRetryPolicy(customAsyncSubscriberPolicy);
 
-        foreach (var lockKey in RegisteredLocks)
+        foreach (var lockKey in ExtensionsState.RegisteredLocks)
         {
             var state = factory.GetTrackerState(lockKey);
             var controller = factory.GetTrackerController(lockKey);
@@ -182,9 +205,7 @@ public static async Task UseDistributedGrpcReactiveLockAsync(
 
         await Task.WhenAll(readySignals).ConfigureAwait(false);
 
-        IsInitializing = null;
-        StoredInstanceName = null;
-        RemoteClients = new();
+        ExtensionsState = null;
     }
 
 }

src/ReactiveLock.Distributed.Grpc/ReactiveLockGrpcTrackerExtensionsState.cs

@@ -0,0 +1,34 @@
+namespace MichelOliveira.Com.ReactiveLock.Distributed.Grpc;
+
+using System.Collections.Concurrent;
+
+/// <summary>
+/// Holds internal bootstrap and runtime state for gRPC-based ReactiveLock extensions.
+///
+/// This class encapsulates mutable state required during the initialization and
+/// lifecycle of distributed gRPC reactive locks, including:
+/// <list type="bullet">
+///   <item><description>The current instance identifier.</description></item>
+///   <item><description>Initialization lifecycle tracking.</description></item>
+///   <item><description>Registered distributed lock keys.</description></item>
+///   <item><description>Configured remote gRPC client adapters.</description></item>
+/// </list>
+///
+/// This type is intended for internal use only and is not part of the public API surface.
+/// </summary>
+/// 
+/// <para>
+/// ⚠️ Notice: This file is part of the ReactiveLock library and is licensed under the MIT License.
+/// You must follow license, preserve the copyright notice, and comply with all legal terms
+/// when using any part of this software.
+/// See the LICENSE file in the project root for full license details.
+/// © Michel Oliveira
+/// </para>
+internal sealed class ReactiveLockGrpcTrackerExtensionsState(string instanceName)
+{
+    public string InstanceName { get; } = instanceName;
+    public bool IsInitializing { get; set; }
+
+    public ConcurrentQueue<string> RegisteredLocks { get; } = new();
+    public List<IReactiveLockGrpcClientAdapter> RemoteClients { get; } = new();
+}

src/ReactiveLock.Distributed.Redis/ReactiveLock.Distributed.Redis.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFrameworks>net8.0;net9.0</TargetFrameworks>
+    <TargetFrameworks>net8.0;net9.0;net10.0</TargetFrameworks>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
     <TargetsForTfmSpecificBuildOutput>$(TargetsForTfmSpecificBuildOutput);IncludeProjectReferencesWithPrivateAssetsAttributeInPackage</TargetsForTfmSpecificBuildOutput>