feat: initial solution with HrynCo.DAL.Abstract and HrynCo.DAL.EF

- HrynCo.DAL.Abstract: IEntity<TId>, Entity base classes, ITransaction, IUnitOfWork
- HrynCo.DAL.EF: EfRepository<TDbContext,TEntity>, EfUnitOfWork<TDbContext>, EfTransactionAdapter
- Directory.Packages.props with centralized EF Core 9.0.5 versions
- TeamCity pipeline YAMLs for general-checks and publish

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

HrynCo.DAL.EF/Core/EfRepository.cs

@@ -0,0 +1,46 @@
+using System.Linq.Expressions;
+using Microsoft.EntityFrameworkCore;
+
+namespace HrynCo.DAL.EF.Core;
+
+public abstract class EfRepository<TDbContext, TEntity>
+    where TDbContext : DbContext
+    where TEntity : class
+{
+    protected TDbContext DbContext { get; }
+    protected DbSet<TEntity> DbSet { get; }
+
+    protected EfRepository(TDbContext dbContext)
+    {
+        DbContext = dbContext;
+        DbSet = dbContext.Set<TEntity>();
+    }
+
+    protected async Task AddAsync(TEntity entity, CancellationToken ct = default)
+    {
+        await DbSet.AddAsync(entity, ct);
+    }
+
+    protected async Task AddRangeAsync(IEnumerable<TEntity> entities, CancellationToken ct = default)
+    {
+        await DbSet.AddRangeAsync(entities, ct);
+    }
+
+    protected void Update(TEntity entity)
+    {
+        DbSet.Update(entity);
+    }
+
+    protected void Delete(TEntity entity)
+    {
+        DbSet.Remove(entity);
+    }
+
+    protected void DeleteRange(IEnumerable<TEntity> entities)
+    {
+        DbSet.RemoveRange(entities);
+    }
+
+    protected Task<bool> ExistsAsync(Expression<Func<TEntity, bool>> predicate, CancellationToken ct = default) =>
+        DbSet.AnyAsync(predicate, ct);
+}

HrynCo.DAL.EF/Core/EfTransactionAdapter.cs

@@ -0,0 +1,29 @@
+using HrynCo.DAL.Abstract;
+using Microsoft.EntityFrameworkCore.Storage;
+
+namespace HrynCo.DAL.EF.Core;
+
+internal sealed class EfTransactionAdapter : ITransaction
+{
+    private readonly IDbContextTransaction _transaction;
+
+    internal EfTransactionAdapter(IDbContextTransaction transaction)
+    {
+        _transaction = transaction;
+    }
+
+    public Task CommitAsync(CancellationToken cancellationToken = default)
+    {
+        return _transaction.CommitAsync(cancellationToken);
+    }
+
+    public Task RollbackAsync(CancellationToken cancellationToken = default)
+    {
+        return _transaction.RollbackAsync(cancellationToken);
+    }
+
+    public ValueTask DisposeAsync()
+    {
+        return _transaction.DisposeAsync();
+    }
+}

HrynCo.DAL.EF/Core/EfUnitOfWork.cs

@@ -0,0 +1,105 @@
+using HrynCo.DAL.Abstract;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Storage;
+
+namespace HrynCo.DAL.EF.Core;
+
+public abstract class EfUnitOfWork<TDbContext> : IUnitOfWork
+    where TDbContext : DbContext
+{
+    private readonly TDbContext _context;
+    private EfTransactionAdapter? _currentTransaction;
+
+    protected EfUnitOfWork(TDbContext context)
+    {
+        _context = context;
+    }
+
+    public Task SaveChangesAsync(CancellationToken cancellationToken = default)
+    {
+        return _context.SaveChangesAsync(cancellationToken);
+    }
+
+    public async Task<ITransaction> BeginTransactionAsync(CancellationToken cancellationToken = default)
+    {
+        if (_currentTransaction != null)
+        {
+            return _currentTransaction;
+        }
+
+        IDbContextTransaction tx = await _context.Database.BeginTransactionAsync(cancellationToken);
+        _currentTransaction = new EfTransactionAdapter(tx);
+        return _currentTransaction;
+    }
+
+    public ITransaction? GetCurrentTransaction()
+    {
+        return _currentTransaction;
+    }
+
+    public async Task ExecuteInTransactionAsync(Func<Task> action)
+    {
+        ITransaction? existing = GetCurrentTransaction();
+        bool ownsTransaction = existing is null;
+        ITransaction tx = existing ?? await BeginTransactionAsync();
+
+        try
+        {
+            await action();
+            if (ownsTransaction)
+            {
+                await tx.CommitAsync();
+            }
+        }
+        catch
+        {
+            if (ownsTransaction)
+            {
+                await tx.RollbackAsync();
+            }
+
+            throw;
+        }
+        finally
+        {
+            if (ownsTransaction)
+            {
+                await tx.DisposeAsync();
+            }
+        }
+    }
+
+    public async Task<TResult> ExecuteInTransactionAsync<TResult>(Func<Task<TResult>> action)
+    {
+        ITransaction? existing = GetCurrentTransaction();
+        bool ownsTransaction = existing is null;
+        ITransaction tx = existing ?? await BeginTransactionAsync();
+
+        try
+        {
+            TResult result = await action();
+            if (ownsTransaction)
+            {
+                await tx.CommitAsync();
+            }
+
+            return result;
+        }
+        catch
+        {
+            if (ownsTransaction)
+            {
+                await tx.RollbackAsync();
+            }
+
+            throw;
+        }
+        finally
+        {
+            if (ownsTransaction)
+            {
+                await tx.DisposeAsync();
+            }
+        }
+    }
+}