Preparation of First Release v 0.0.1 (Part 2)

mckaragoz · mckaragoz · commit b11fd1ea9abc · 2025-12-28T23:58:07.000+03:00
diff --git a/UltimateAuth.slnx b/UltimateAuth.slnx
@@ -16,6 +16,7 @@
   <Project Path="src/CodeBeam.UltimateAuth.Users/CodeBeam.UltimateAuth.Server.Users.csproj" Id="30d5db36-6dc8-46f6-9139-8b6b3d6053d5" />
   <Project Path="src/credentials/CodeBeam.UltimateAuth.Credentials.InMemory/CodeBeam.UltimateAuth.Credentials.InMemory.csproj" Id="62ee7b1d-46ce-4f2e-985d-1e794f891b8b" />
   <Project Path="src/security/CodeBeam.UltimateAuth.Security.Argon2/CodeBeam.UltimateAuth.Security.Argon2.csproj" Id="6abfb7a6-ea36-42db-a843-38054dd40fd8" />
+  <Project Path="src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore.csproj" Id="5b9a090d-1689-4a81-9dfa-3ba69f0bda38" />
   <Project Path="src/sessions/CodeBeam.UltimateAuth.Sessions.InMemory/CodeBeam.UltimateAuth.Sessions.InMemory.csproj" Id="fc9bfef0-8a89-4639-81ee-3f84f6e33816" />
   <Project Path="src/tokens/CodeBeam.UltimateAuth.Tokens.InMemory/CodeBeam.UltimateAuth.Tokens.InMemory.csproj" Id="8220884e-4958-4b49-8c69-56ce9d2b6c6f" />
 </Solution>
diff --git a/src/CodeBeam.UltimateAuth.Core/AssemblyVisibility.cs b/src/CodeBeam.UltimateAuth.Core/AssemblyVisibility.cs
@@ -0,0 +1,3 @@
+﻿using System.Runtime.CompilerServices;
+
+[assembly: InternalsVisibleTo("CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore")]
diff --git a/src/CodeBeam.UltimateAuth.Core/Domain/Session/AuthSessionId.cs b/src/CodeBeam.UltimateAuth.Core/Domain/Session/AuthSessionId.cs
@@ -32,6 +32,8 @@ public static bool TryCreate(string raw, out AuthSessionId sessionId)
         /// </summary>
         public string Value { get; }
 
+        public static AuthSessionId From(string value) => new(value);
+
         /// <summary>
         /// Determines whether the specified <see cref="AuthSessionId"/> is equal to the current instance.
         /// </summary>
diff --git a/src/CodeBeam.UltimateAuth.Core/Domain/Session/ChainId.cs b/src/CodeBeam.UltimateAuth.Core/Domain/Session/ChainId.cs
@@ -27,6 +27,8 @@ public ChainId(Guid value)
         /// <returns>A new <see cref="ChainId"/> instance.</returns>
         public static ChainId New() => new ChainId(Guid.NewGuid());
 
+        public static ChainId From(Guid value) => new(value);
+
         /// <summary>
         /// Determines whether the specified <see cref="ChainId"/> is equal to the current instance.
         /// </summary>
diff --git a/src/CodeBeam.UltimateAuth.Core/Domain/Session/DeviceInfo.cs b/src/CodeBeam.UltimateAuth.Core/Domain/Session/DeviceInfo.cs
@@ -7,8 +7,10 @@
     /// </summary>
     public sealed class DeviceInfo
     {
+        // TODO: Implement DeviceId and makes it first-class citizen in security policies.
         /// <summary>
         /// Gets the unique identifier for the device.
+        /// No session should be created without a device id.
         /// </summary>
         public string DeviceId { get; init; } = default!;
 
@@ -72,6 +74,17 @@ public sealed class DeviceInfo
             IsTrusted = null
         };
 
+        // TODO: Empty may not be good approach, make strict security here
+        public static DeviceInfo Empty { get; } = new()
+        {
+            DeviceId = "",
+            Platform = null,
+            Browser = null,
+            IpAddress = null,
+            UserAgent = null,
+            IsTrusted = null
+        };
+
         /// <summary>
         /// Determines whether the current device information matches the specified device information based on device
         /// identifiers.
diff --git a/src/CodeBeam.UltimateAuth.Core/Domain/Session/ISessionChain.cs b/src/CodeBeam.UltimateAuth.Core/Domain/Session/ISessionChain.cs
@@ -12,6 +12,8 @@ public interface ISessionChain<TUserId>
         /// </summary>
         ChainId ChainId { get; }
 
+        string? TenantId { get; }
+
         /// <summary>
         /// Gets the identifier of the user who owns this chain.
         /// Each chain represents one device/login family for this user.
diff --git a/src/CodeBeam.UltimateAuth.Core/Domain/Session/UAuthSession.cs b/src/CodeBeam.UltimateAuth.Core/Domain/Session/UAuthSession.cs
@@ -136,6 +136,38 @@ public ISession<TUserId> Revoke(DateTimeOffset at)
             );
         }
 
+        internal static UAuthSession<TUserId> FromProjection(
+    AuthSessionId sessionId,
+    string? tenantId,
+    TUserId userId,
+    ChainId chainId,
+    DateTimeOffset createdAt,
+    DateTimeOffset expiresAt,
+    DateTimeOffset? lastSeenAt,
+    bool isRevoked,
+    DateTimeOffset? revokedAt,
+    long securityVersionAtCreation,
+    DeviceInfo device,
+    ClaimsSnapshot claims,
+    SessionMetadata metadata)
+        {
+            return new UAuthSession<TUserId>(
+                sessionId,
+                tenantId,
+                userId,
+                chainId,
+                createdAt,
+                expiresAt,
+                lastSeenAt,
+                isRevoked,
+                revokedAt,
+                securityVersionAtCreation,
+                device,
+                claims,
+                metadata
+            );
+        }
+
         public SessionState GetState(DateTimeOffset at)
         {
             if (IsRevoked) return SessionState.Revoked;
diff --git a/src/CodeBeam.UltimateAuth.Core/Domain/Session/UAuthSessionChain.cs b/src/CodeBeam.UltimateAuth.Core/Domain/Session/UAuthSessionChain.cs
@@ -108,5 +108,29 @@ public ISessionChain<TUserId> Revoke(DateTimeOffset at)
             );
         }
 
+        internal static UAuthSessionChain<TUserId> FromProjection(
+    ChainId chainId,
+    string? tenantId,
+    TUserId userId,
+    int rotationCount,
+    long securityVersionAtCreation,
+    ClaimsSnapshot claimsSnapshot,
+    AuthSessionId? activeSessionId,
+    bool isRevoked,
+    DateTimeOffset? revokedAt)
+        {
+            return new UAuthSessionChain<TUserId>(
+                chainId,
+                tenantId,
+                userId,
+                rotationCount,
+                securityVersionAtCreation,
+                claimsSnapshot,
+                activeSessionId,
+                isRevoked,
+                revokedAt
+            );
+        }
+
     }
 }
diff --git a/src/CodeBeam.UltimateAuth.Core/Domain/Session/UAuthSessionRoot.cs b/src/CodeBeam.UltimateAuth.Core/Domain/Session/UAuthSessionRoot.cs
@@ -76,5 +76,26 @@ public ISessionRoot<TUserId> AttachChain(ISessionChain<TUserId> chain, DateTimeO
             );
         }
 
+        internal static UAuthSessionRoot<TUserId> FromProjection(
+    string? tenantId,
+    TUserId userId,
+    bool isRevoked,
+    DateTimeOffset? revokedAt,
+    long securityVersion,
+    IReadOnlyList<ISessionChain<TUserId>> chains,
+    DateTimeOffset lastUpdatedAt)
+        {
+            return new UAuthSessionRoot<TUserId>(
+                tenantId,
+                userId,
+                isRevoked,
+                revokedAt,
+                securityVersion,
+                chains,
+                lastUpdatedAt
+            );
+        }
+
+
     }
 }
diff --git a/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore.csproj b/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore.csproj
@@ -0,0 +1,28 @@
+﻿<Project Sdk="Microsoft.NET.Sdk">
+
+	<PropertyGroup>
+		<TargetFrameworks>net8.0;net9.0;net10.0</TargetFrameworks>
+		<ImplicitUsings>enable</ImplicitUsings>
+		<Nullable>enable</Nullable>
+		<GenerateDocumentationFile>true</GenerateDocumentationFile>
+		<NoWarn>$(NoWarn);1591</NoWarn>
+	</PropertyGroup>
+
+	<ItemGroup Condition=" '$(TargetFramework)' == 'net8.0' ">
+		<PackageReference Include="Microsoft.EntityFrameworkCore" Version="8.0.22" />
+		<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="8.0.22" />
+	</ItemGroup>
+	<ItemGroup Condition=" '$(TargetFramework)' == 'net9.0' ">
+		<PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.11" />
+		<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="9.0.11" />
+	</ItemGroup>
+	<ItemGroup Condition=" '$(TargetFramework)' == 'net10.0' ">
+		<PackageReference Include="Microsoft.EntityFrameworkCore" Version="10.0.1" />
+		<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="10.0.1" />
+	</ItemGroup>
+
+	<ItemGroup>
+		<ProjectReference Include="..\..\CodeBeam.UltimateAuth.Core\CodeBeam.UltimateAuth.Core.csproj" />
+	</ItemGroup>
+
+</Project>
diff --git a/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/EfCoreSessionStoreKernel.cs b/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/EfCoreSessionStoreKernel.cs
@@ -0,0 +1,47 @@
+﻿using Microsoft.EntityFrameworkCore;
+using System.Data;
+
+namespace CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore
+{
+    internal sealed class EfCoreSessionStoreKernel<TUserId>
+    {
+        private readonly UltimateAuthSessionDbContext<TUserId> _db;
+
+        public EfCoreSessionStoreKernel(UltimateAuthSessionDbContext<TUserId> db)
+        {
+            _db = db;
+        }
+
+        public async Task ExecuteAsync(Func<CancellationToken, Task> action, CancellationToken ct)
+        {
+            var strategy = _db.Database.CreateExecutionStrategy();
+
+            await strategy.ExecuteAsync(async () =>
+            {
+                var connection = _db.Database.GetDbConnection();
+                if (connection.State != ConnectionState.Open)
+                    await connection.OpenAsync(ct);
+
+                await using var tx = await connection.BeginTransactionAsync(IsolationLevel.RepeatableRead, ct);
+                _db.Database.UseTransaction(tx);
+
+                try
+                {
+                    await action(ct);
+                    await _db.SaveChangesAsync(ct);
+                    await tx.CommitAsync(ct);
+                }
+                catch
+                {
+                    await tx.RollbackAsync(ct);
+                    throw;
+                }
+                finally
+                {
+                    _db.Database.UseTransaction(null);
+                }
+            });
+        }
+
+    }
+}
diff --git a/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/EntityProjections/SessionChainProjection.cs b/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/EntityProjections/SessionChainProjection.cs
@@ -0,0 +1,26 @@
+﻿using CodeBeam.UltimateAuth.Core.Domain;
+
+namespace CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore
+{
+    internal sealed class SessionChainProjection<TUserId>
+    {
+        public long Id { get; set; }
+
+        public ChainId ChainId { get; set; } = default!;
+
+        public string? TenantId { get; set; }
+        public TUserId UserId { get; set; } = default!;
+
+        public int RotationCount { get; set; }
+        public long SecurityVersionAtCreation { get; set; }
+
+        public ClaimsSnapshot ClaimsSnapshot { get; set; } = ClaimsSnapshot.Empty;
+
+        public AuthSessionId? ActiveSessionId { get; set; }
+
+        public bool IsRevoked { get; set; }
+        public DateTimeOffset? RevokedAt { get; set; }
+
+        public byte[] RowVersion { get; set; } = default!;
+    }
+}
diff --git a/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/EntityProjections/SessionProjection.cs b/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/EntityProjections/SessionProjection.cs
@@ -0,0 +1,31 @@
+﻿using CodeBeam.UltimateAuth.Core.Domain;
+
+namespace CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore
+{
+    internal sealed class SessionProjection<TUserId>
+    {
+        public long Id { get; set; } // EF internal PK
+
+        public AuthSessionId SessionId { get; set; } = default!;
+        public ChainId ChainId { get; set; } = default!;
+
+        public string? TenantId { get; set; }
+        public TUserId UserId { get; set; } = default!;
+
+        public DateTimeOffset CreatedAt { get; set; }
+        public DateTimeOffset ExpiresAt { get; set; }
+        public DateTimeOffset? LastSeenAt { get; set; }
+
+        public bool IsRevoked { get; set; }
+        public DateTimeOffset? RevokedAt { get; set; }
+
+        public long SecurityVersionAtCreation { get; set; }
+
+        public DeviceInfo Device { get; set; } = DeviceInfo.Empty;
+        public ClaimsSnapshot Claims { get; set; } = ClaimsSnapshot.Empty;
+        public SessionMetadata Metadata { get; set; } = SessionMetadata.Empty;
+
+        public byte[] RowVersion { get; set; } = default!;
+    }
+
+}
diff --git a/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/EntityProjections/SessionRootProjection.cs b/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/EntityProjections/SessionRootProjection.cs
@@ -0,0 +1,18 @@
+﻿namespace CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore
+{
+    internal sealed class SessionRootProjection<TUserId>
+    {
+        public long Id { get; set; }
+
+        public string? TenantId { get; set; }
+        public TUserId UserId { get; set; } = default!;
+
+        public bool IsRevoked { get; set; }
+        public DateTimeOffset? RevokedAt { get; set; }
+
+        public long SecurityVersion { get; set; }
+        public DateTimeOffset LastUpdatedAt { get; set; }
+
+        public byte[] RowVersion { get; set; } = default!;
+    }
+}
diff --git a/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/JsonValueConverter.cs b/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/JsonValueConverter.cs
@@ -0,0 +1,15 @@
+﻿using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
+using System.Text.Json;
+
+namespace CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore
+{
+    internal sealed class JsonValueConverter<T> : ValueConverter<T, string>
+    {
+        public JsonValueConverter()
+            : base(
+                v => JsonSerializer.Serialize(v, (JsonSerializerOptions?)null),
+                v => JsonSerializer.Deserialize<T>(v, (JsonSerializerOptions?)null)!)
+        {
+        }
+    }
+}
diff --git a/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/Mappers/SessionChainProjectionMapper.cs b/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/Mappers/SessionChainProjectionMapper.cs
@@ -0,0 +1,42 @@
+﻿using CodeBeam.UltimateAuth.Core.Domain;
+
+namespace CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore
+{
+    internal static class SessionChainProjectionMapper
+    {
+        public static ISessionChain<TUserId> ToDomain<TUserId>(this SessionChainProjection<TUserId> p)
+        {
+            return UAuthSessionChain<TUserId>.FromProjection(
+                p.ChainId,
+                p.TenantId,
+                p.UserId,
+                p.RotationCount,
+                p.SecurityVersionAtCreation,
+                p.ClaimsSnapshot,
+                p.ActiveSessionId,
+                p.IsRevoked,
+                p.RevokedAt
+            );
+        }
+
+        public static SessionChainProjection<TUserId> ToProjection<TUserId>(this ISessionChain<TUserId> chain)
+        {
+            return new SessionChainProjection<TUserId>
+            {
+                ChainId = chain.ChainId,
+                TenantId = chain.TenantId,
+                UserId = chain.UserId,
+
+                RotationCount = chain.RotationCount,
+                SecurityVersionAtCreation = chain.SecurityVersionAtCreation,
+                ClaimsSnapshot = chain.ClaimsSnapshot,
+
+                ActiveSessionId = chain.ActiveSessionId,
+
+                IsRevoked = chain.IsRevoked,
+                RevokedAt = chain.RevokedAt
+            };
+        }
+
+    }
+}
diff --git a/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/Mappers/SessionProjectionMapper.cs b/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/Mappers/SessionProjectionMapper.cs
diff --git a/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/Mappers/SessionRootProjectionMapper.cs b/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/Mappers/SessionRootProjectionMapper.cs
diff --git a/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/NullableAuthSessionIdConverter.cs b/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/NullableAuthSessionIdConverter.cs
diff --git a/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/UAuthSessionDbContext.cs b/src/sessions/CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore/UAuthSessionDbContext.cs

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+using System.Runtime.CompilerServices;`
	`2`	`+`
	`3`	`+[assembly: InternalsVisibleTo("CodeBeam.UltimateAuth.Sessions.EntityFrameworkCore")]`