diff --git a/DD.Persistence.Repository.Test/ChangeLogRepositoryTest.cs b/DD.Persistence.Repository.Test/ChangeLogRepositoryTest.cs index 255c9f0..9f5f20a 100644 --- a/DD.Persistence.Repository.Test/ChangeLogRepositoryTest.cs +++ b/DD.Persistence.Repository.Test/ChangeLogRepositoryTest.cs @@ -63,7 +63,10 @@ public class ChangeLogRepositoryTest : IClassFixture { var idDiscriminator = Uuid7.Guid(); var commit1 = await ChangeLogItem(idDiscriminator); + var result = await repo.AddRange(idDiscriminator, commit1, CancellationToken.None); + var commit2 = await ChangeLogItem(idDiscriminator); + result = await repo.AddRange(idDiscriminator, commit2, CancellationToken.None); var items = await repo.GetGtDate(idDiscriminator, DateTimeOffset.UtcNow.AddDays(-1), CancellationToken.None); @@ -92,15 +95,28 @@ public class ChangeLogRepositoryTest : IClassFixture public async Task ClearAndAddRangeReturnSuccess() { var idDiscriminator = Uuid7.Guid(); - await ChangeLogItem(idDiscriminator); - await ChangeLogItem(idDiscriminator); - await ChangeLogItem(idDiscriminator); + var commit1 = await ChangeLogItem(idDiscriminator); + var result = await repo.AddRange(idDiscriminator, commit1, CancellationToken.None); + + var commit2 = await ChangeLogItem(idDiscriminator); + result = await repo.AddRange(idDiscriminator, commit2, CancellationToken.None); + + var commit3 = await ChangeLogItem(idDiscriminator); + result = await repo.AddRange(idDiscriminator, commit3, CancellationToken.None); //act - var result = await repo.ClearAndAddRange(idDiscriminator, commit, CancellationToken.None); + var commit4 = await ChangeLogItem(idDiscriminator); + var items = await repo.GetGtDate(idDiscriminator, DateTimeOffset.UtcNow.AddDays(-1), CancellationToken.None); + commit4.ChangeLogItems = items; + result = await repo.ClearAndAddRange(idDiscriminator, commit4, CancellationToken.None); //assert - Assert.Equal(2, result); + //добавлены 3 записи и 3 коммита к ним, + //добавлена 1 новая запись и 1 коммит к ней + Assert.Equal(8, result); + + var paginationRequest = new PaginationRequest(); + var items2 = await repo.GetByDate(idDiscriminator, DateTimeOffset.UtcNow.AddMinutes(-10), paginationRequest, CancellationToken.None); }