diff --git a/DigitalData.Core.Abstraction.Application/Repository/IRepository.cs b/DigitalData.Core.Abstraction.Application/Repository/IRepository.cs index 6c57a44..b9b2b0b 100644 --- a/DigitalData.Core.Abstraction.Application/Repository/IRepository.cs +++ b/DigitalData.Core.Abstraction.Application/Repository/IRepository.cs @@ -6,19 +6,19 @@ public interface IRepository { public IEntityMapper Mapper { get; } - public Task CreateAsync(TEntity entity, CancellationToken cancellation = default); + public Task CreateAsync(TEntity entity, CancellationToken cancel = default); - public Task> CreateAsync(IEnumerable entities, CancellationToken cancellation = default); + public Task> CreateAsync(IEnumerable entities, CancellationToken cancel = default); public IQueryable Read(); public IQueryable ReadOnly(); - public Task UpdateAsync(TDto dto, Expression> expression, CancellationToken cancellation = default); + public Task UpdateAsync(TDto dto, Expression> expression, CancellationToken cancel = default); - public Task UpdateAsync(TDto dto, IQueryable query, CancellationToken cancellation = default); + public Task UpdateAsync(TDto dto, IQueryable query, CancellationToken cancel = default); - public Task DeleteAsync(Expression> expression, CancellationToken cancellation = default); + public Task DeleteAsync(Expression> expression, CancellationToken cancel = default); - public Task DeleteAsync(IQueryable query, CancellationToken cancellation = default); + public Task DeleteAsync(IQueryable query, CancellationToken cancel = default); } diff --git a/DigitalData.Core.Infrastructure/DbRepository.cs b/DigitalData.Core.Infrastructure/DbRepository.cs index 66362bb..05b79f1 100644 --- a/DigitalData.Core.Infrastructure/DbRepository.cs +++ b/DigitalData.Core.Infrastructure/DbRepository.cs @@ -19,17 +19,17 @@ public class DbRepository : IRepository where TDbC Mapper = mapper; } - public virtual async Task CreateAsync(TEntity entity, CancellationToken ct = default) + public virtual async Task CreateAsync(TEntity entity, CancellationToken cancel = default) { Entities.Add(entity); - await Context.SaveChangesAsync(ct); + await Context.SaveChangesAsync(cancel); return entity; } - public virtual async Task> CreateAsync(IEnumerable entities, CancellationToken ct = default) + public virtual async Task> CreateAsync(IEnumerable entities, CancellationToken cancel = default) { Entities.AddRange(entities); - await Context.SaveChangesAsync(ct); + await Context.SaveChangesAsync(cancel); return entities; } @@ -37,11 +37,11 @@ public class DbRepository : IRepository where TDbC public IQueryable ReadOnly() => Entities.AsNoTracking(); - public virtual Task UpdateAsync(TDto dto, Expression> expression, CancellationToken ct = default) => UpdateAsync(dto, Entities.Where(expression), ct); + public virtual Task UpdateAsync(TDto dto, Expression> expression, CancellationToken cancel = default) => UpdateAsync(dto, Entities.Where(expression), cancel); - public virtual async Task UpdateAsync(TDto dto, IQueryable query, CancellationToken ct = default) + public virtual async Task UpdateAsync(TDto dto, IQueryable query, CancellationToken cancel = default) { - var entities = await query.ToListAsync(ct); + var entities = await query.ToListAsync(cancel); for (int i = entities.Count - 1; i >= 0; i--) { @@ -49,20 +49,20 @@ public class DbRepository : IRepository where TDbC Entities.Update(entities[i]); } - await Context.SaveChangesAsync(ct); + await Context.SaveChangesAsync(cancel); } - public virtual Task DeleteAsync(Expression> expression, CancellationToken ct = default) => DeleteAsync(Entities.Where(expression), ct); + public virtual Task DeleteAsync(Expression> expression, CancellationToken cancel = default) => DeleteAsync(Entities.Where(expression), cancel); - public virtual async Task DeleteAsync(IQueryable query, CancellationToken ct = default) + public virtual async Task DeleteAsync(IQueryable query, CancellationToken cancel = default) { - var entities = await query.ToListAsync(ct); + var entities = await query.ToListAsync(cancel); for (int i = entities.Count - 1; i >= 0; i--) { Entities.Remove(entities[i]); } - await Context.SaveChangesAsync(ct); + await Context.SaveChangesAsync(cancel); } } \ No newline at end of file