hrynco/hrynco-notification-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: inherit EF entities from Entity base class

Browse Source 
- TemplateEntity, ProviderEntity, ProviderUsageEntity now inherit Entity (from DAL.Abstract)
- Removes duplicated Id, Created, Updated properties from each entity

Ref: IT-628

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>
This commit is contained in:
Anatolii Grynchuk
2026-05-01 23:27:38 +03:00
parent 4f573da374
commit c2a4f3b9d7
6 changed files with 64 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files
HrynCo.NotificationService.DAL.EF/Core/EfUnitOfWork.cs
+34 -8
View File
@@ -18,14 +18,19 @@ internal abstract class EfUnitOfWork<TDbContext> : IUnitOfWork
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() => _currentTransaction;
public ITransaction? GetCurrentTransaction()
{
return _currentTransaction;
}
public async Task ExecuteInTransactionAsync(Func<Task> action)
{
@@ -36,16 +41,26 @@ internal abstract class EfUnitOfWork<TDbContext> : IUnitOfWork
try
{
await action();
if (ownsTransaction) await tx.CommitAsync();
if (ownsTransaction)
{
await tx.CommitAsync();
}
}
catch
{
if (ownsTransaction) await tx.RollbackAsync();
if (ownsTransaction)
{
await tx.RollbackAsync();
}
throw;
}
finally
{
if (ownsTransaction) await tx.DisposeAsync();
if (ownsTransaction)
{
await tx.DisposeAsync();
}
}
}
@@ -58,17 +73,28 @@ internal abstract class EfUnitOfWork<TDbContext> : IUnitOfWork
try
{
TResult result = await action();
if (ownsTransaction) await tx.CommitAsync();
if (ownsTransaction)
{
await tx.CommitAsync();
}
return result;
}
catch
{
if (ownsTransaction) await tx.RollbackAsync();
if (ownsTransaction)
{
await tx.RollbackAsync();
}
throw;
}
finally
{
if (ownsTransaction) await tx.DisposeAsync();
if (ownsTransaction)
{
await tx.DisposeAsync();
}
}
}
}
}