Merge branch 'main' of https://github.com/bvdcode/EasyExtensions

Author: bvdcode

Sources/EasyExtensions.AspNetCore.Authorization/Abstractions/ITokenProvider.cs

@@ -12,6 +12,11 @@ namespace EasyExtensions.AspNetCore.Authorization.Abstractions
     /// </summary>
     public interface ITokenProvider
     {
+        /// <summary>
+        /// Gets the duration for which a generated token remains valid before expiration.
+        /// </summary>
+        TimeSpan TokenLifetime { get; }
+
         /// <summary>
         /// Creates a token with claims.
         /// </summary>

Sources/EasyExtensions.AspNetCore.Authorization/Services/JwtTokenProvider.cs

@@ -18,6 +18,8 @@ internal class JwtTokenProvider(IConfiguration _configuration) : ITokenProvider
         private readonly JwtSettings _jwtSettings = _configuration.GetJwtSettings();
         private readonly SymmetricSecurityKey _securityKey = new(Encoding.UTF8.GetBytes(_configuration.GetJwtSettings().Key));
 
+        public TimeSpan TokenLifetime => TimeSpan.FromMinutes(_jwtSettings.LifetimeMinutes);
+
         public bool ValidateToken(string token)
         {
             var tokenHandler = new JwtSecurityTokenHandler();

Sources/EasyExtensions.Clients/IpApiCoClient.cs

@@ -85,7 +85,7 @@ public static async Task<IpApiCoResponse> LookupAsync(string ip)
             {
                 DefaultRequestHeaders =
                 {
-                    { "User-Agent", "EasyExtensions.Clients/1.0" }
+                    { "User-Agent", "EasyExtensions.Clients/3.0" }
                 }
             };
             var response = await http.GetFromJsonAsync<IpApiCoResponse>(url)

Sources/EasyExtensions.Crypto/AesGcmStreamCipher.cs

@@ -64,6 +64,8 @@ public class AesGcmStreamCipher : IStreamCipher, IDisposable
         private readonly bool _strictLengthCheck;
         private readonly RandomNumberGenerator _rng;
         private readonly long? _memoryLimitBytes;
+        private readonly long _pipePauseWriterThresholdBytes;
+        private readonly long _pipeResumeWriterThresholdBytes;
         private static readonly ArrayPool<byte> BufferPool = ArrayPool<byte>.Shared;
         private readonly int ConcurrencyLevel = Math.Min(4, Environment.ProcessorCount);
 
@@ -120,6 +122,18 @@ public AesGcmStreamCipher(ReadOnlyMemory<byte> masterKey, int keyId = 1, int? th
             _strictLengthCheck = strictLengthCheck;
             _rng = rng ?? RandomNumberGenerator.Create();
             _memoryLimitBytes = memoryLimitBytes;
+
+            const long defaultPipePause = 1L * 1024L * 1024L;
+            long pipePause = defaultPipePause;
+            if (memoryLimitBytes.HasValue)
+            {
+                // Keep outer Pipe buffering small and independent from internal windowing.
+                // Optionally respect the provided memory cap, without letting it grow unbounded.
+                pipePause = Math.Min(defaultPipePause, Math.Max(256L * 1024L, memoryLimitBytes.Value / 64));
+            }
+            _pipePauseWriterThresholdBytes = pipePause;
+            _pipeResumeWriterThresholdBytes = Math.Max(1, pipePause / 2);
+
             if (threads.HasValue)
             {
                 if (threads.Value < 1 || threads.Value > _maxThreads)
@@ -289,9 +303,8 @@ public Task<Stream> EncryptAsync(Stream input, int chunkSize = DefaultChunkSize,
                 throw new ArgumentOutOfRangeException(nameof(chunkSize), $"Chunk size must be between {MinChunkSize} and {MaxChunkSize} bytes.");
             }
 
-            int effectiveWindowCap = ComputeEffectiveWindowCap(chunkSize);
-            long pauseThreshold = (long)Math.Clamp(chunkSize, MinChunkSize, MaxChunkSize) * Math.Clamp(effectiveWindowCap, 4, int.MaxValue);
-            long resumeThreshold = pauseThreshold / 2;
+            long pauseThreshold = _pipePauseWriterThresholdBytes;
+            long resumeThreshold = _pipeResumeWriterThresholdBytes;
             var pipe = new Pipe(new PipeOptions(
                 pool: MemoryPool<byte>.Shared,
                 readerScheduler: null,
@@ -340,10 +353,8 @@ public Task<Stream> DecryptAsync(Stream input, bool leaveOpen = false, Cancellat
                 throw new ArgumentException("Input stream must be readable.", nameof(input));
             }
 
-            long perChunkGuess = DefaultChunkSize;
-            int effectiveWindowCap = ComputeEffectiveWindowCap((int)perChunkGuess);
-            long pauseThreshold = perChunkGuess * Math.Clamp(effectiveWindowCap, 4, int.MaxValue);
-            long resumeThreshold = pauseThreshold / 2;
+            long pauseThreshold = _pipePauseWriterThresholdBytes;
+            long resumeThreshold = _pipeResumeWriterThresholdBytes;
             var pipe = new Pipe(new PipeOptions(
                 pool: MemoryPool<byte>.Shared,
                 readerScheduler: null,

Sources/EasyExtensions.EntityFrameworkCore/Database/ExtendedRefreshToken.cs

@@ -61,5 +61,11 @@ public class ExtendedRefreshToken : RefreshToken
         /// </summary>
         [Column("device")]
         public string? Device { get; set; }
+
+        /// <summary>
+        /// Gets or sets the unique identifier for the session associated with this entity.
+        /// </summary>
+        [Column("session_id")]
+        public string? SessionId { get; set; }
     }
 }

Sources/EasyExtensions.EntityFrameworkCore/Extensions/DbContextExtensions.cs

@@ -27,7 +27,9 @@ public static void ApplyMigrations<TContext>(this TContext context, ILogger? log
             {
                 foreach (var migration in migrations)
                 {
+#pragma warning disable CA1873 // Avoid potentially expensive logging
                     logger?.LogInformation("Applying migration {Migration}.", migration);
+#pragma warning restore CA1873 // Avoid potentially expensive logging
                 }
                 context.Database.Migrate();
                 logger?.LogInformation("Migrations applied.");

Sources/EasyExtensions.Mediator/Contracts/IBaseRequest.cs

@@ -1,13 +1,7 @@
-// SPDX-License-Identifier: MIT
-// Copyright (c) 2025–2026 Vadim Belov <https://belov.us>
-
 namespace EasyExtensions.Mediator.Contracts
 {
     /// <summary>
-    /// Defines a marker interface for notification messages used in a messaging or event-driven system.
+    /// Marker interface to represent a notification
     /// </summary>
-    /// <remarks>Implement this interface to represent a notification that can be published or handled by
-    /// notification handlers. This interface does not define any members and serves to identify types as notifications
-    /// within the system.</remarks>
     public interface INotification { }
-}
+}