persistence/DD.Persistence.IntegrationTests/Controllers/ChangeLogControllerTest.cs

using DD.Persistence.Client;
using DD.Persistence.Client.Clients;
using DD.Persistence.Client.Clients.Interfaces;
using DD.Persistence.Client.Clients.Interfaces.Refit;
using DD.Persistence.Database.Entity;
using DD.Persistence.Models;
using DD.Persistence.Models.Requests;
using Mapster;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using Xunit;

namespace DD.Persistence.IntegrationTests.Controllers;
public class ChangeLogControllerTest : BaseIntegrationTest
{
    private readonly IChangeLogClient client;
    private readonly PaginationRequest paginationRequest;
    private static readonly Random generatorRandomDigits = new();

    public ChangeLogControllerTest(WebAppFactoryFixture factory) : base(factory)
    {
        var refitClientFactory = scope.ServiceProvider
            .GetRequiredService<IRefitClientFactory<IRefitChangeLogClient>>();
        var logger = scope.ServiceProvider.GetRequiredService<ILogger<ChangeLogClient>>();

        client = scope.ServiceProvider
            .GetRequiredService<IChangeLogClient>();

        paginationRequest = new PaginationRequest()
        {
            Skip = 0,
            Take = 10,
            SortSettings = String.Empty,
        };
    }

    [Fact]
    public async Task ClearAndInsertRange_InNotEmptyDb()
    {
        // arrange
        var insertedCount = 10;
        var newEntitiesData = await CreateAndReturnNewDtos(insertedCount, (-15, -1));
        var idDiscriminator = newEntitiesData.Item1;
        var dtos = newEntitiesData.Item2;

        //act
        var result = await client.ClearAndAddRange(idDiscriminator, dtos, "Добавление новых элементов и очистка старых", CancellationToken.None);

        // assert
        Assert.Equal(insertedCount * 2, result);
    }

    [Fact]
    public async Task AddRange_returns_success()
    {
        // arrange
        var count = 3;
        var idDiscriminator = Guid.NewGuid();
        var dtos = Generate(count);
        var comment = "Создаю 3 элемента";

        // act
        var result = await client.AddRange(idDiscriminator, dtos, comment, CancellationToken.None);

        // assert
        Assert.Equal(count, result);
    }

    [Fact]
    public async Task Update_returns_success()
    {
        //arrange
        dbContext.CleanupDbSet<ChangeLog>();

        var idDiscriminator = Guid.NewGuid();
        var dtos = Generate(1);
        var dto = dtos.FirstOrDefault()!;
        var comment = "Создаю 1 элемент";
        var result = await client.AddRange(idDiscriminator, [dto], comment, CancellationToken.None);

        var entity = dbContext.ChangeLog
            .Where(x => x.DiscriminatorId == idDiscriminator)
            .FirstOrDefault();
        dto = entity.Adapt<ChangeLogValuesDto>();

        // act
        comment = "Обновляю 1 элемент";
        result = await client.UpdateRange([dto], comment, CancellationToken.None);

        // assert
        Assert.Equal(2, result);

        var dateBegin = DateTimeOffset.UtcNow.AddDays(-1);
        var dateEnd = DateTimeOffset.UtcNow.AddDays(1);

        var changeLogResult = await client.GetChangeLogForInterval(idDiscriminator, dateBegin, dateEnd, new CancellationToken());
        Assert.NotNull(changeLogResult);

        var obsoleteDto = changeLogResult
            .Where(e => e.Obsolete.HasValue)
            .FirstOrDefault();

        var activeDto = changeLogResult
            .Where(e => !e.Obsolete.HasValue)
            .FirstOrDefault();

        if (obsoleteDto == null || activeDto == null)
        {
            Assert.Fail();
            return;
        }

        Assert.Equal(activeDto.Id, obsoleteDto.IdNext);

    }

    [Fact]
    public async Task UpdateRange_returns_success()
    {
        var count = 2;
        var idDiscriminator = Guid.NewGuid();
        var dtos = Generate(count);
        var comment = "Создаю 3 элемента";

        // act
        var result = await client.AddRange(idDiscriminator, dtos, comment, CancellationToken.None);
        var paginatedResult = await client.GetByDate(idDiscriminator, DateTimeOffset.UtcNow.AddDays(1), paginationRequest, CancellationToken.None);
        // act
        comment = "Обновляю 3 элемента";
        result = await client.UpdateRange(paginatedResult.Items, comment, CancellationToken.None);

        // assert
        Assert.Equal(count * 2, result);
    }

    [Fact]
    public async Task DeleteRange_returns_success()
    {
        // arrange
        var insertedCount = 10;
        var newEntitiesData = await CreateAndReturnNewDtos(insertedCount, (-15, -1));
        var idDiscriminator = newEntitiesData.Item1;
        var dtos = newEntitiesData.Item2;

        // act
        var ids = dtos.Select(e => e.Id);
        var result = await client.DeleteRange(ids, "Удаление нескольких записей", CancellationToken.None);

        // assert
        Assert.Equal(insertedCount, result);
    }

    [Fact]
    public async Task GetDatesRange_returns_success()
    {
        //arrange
        var changeLogItems = await CreateAndReturnNewEntities(3, (-15, -1));
        var idDiscriminator = changeLogItems.Item1;
        var entities = changeLogItems.Item2.OrderBy(c => c.Creation);

        // act
        var result = await client.GetDatesRange(idDiscriminator, CancellationToken.None);

        // assert
        Assert.NotNull(result);

        var minDate = entities.First().Creation;
        var maxDate = entities.Last().Creation;

        var expectedMinDate = minDate.ToUniversalTime().ToString();
        var actualMinDate = result.From.ToUniversalTime().ToString();
        Assert.Equal(expectedMinDate, actualMinDate);

        var expectedMaxDate = maxDate.ToUniversalTime().ToString();
        var actualMaxDate = result.To.ToUniversalTime().ToString();
        Assert.Equal(expectedMaxDate, actualMaxDate);
    }

    [Fact]
    public async Task GetByDate_returns_success()
    {
        // arrange
        dbContext.CleanupDbSet<ChangeLog>();

        //создаем записи
        var count = 5;
        var changeLogItems = await CreateAndReturnNewDtos(count, (-15, -1));
        var idDiscriminator = changeLogItems.Item1;
        var entities = changeLogItems.Item2;

        //удаляем все созданные записи за исключением первой и второй
        //даты 2-х оставшихся записей должны вернуться в методе GetByDate
        var ids = entities.Select(e => e.Id);
        var idsToDelete = ids.Skip(2);

        var deletedCount = await client.DeleteRange(idsToDelete, "Удаление нескольких записей", CancellationToken.None);

        var moment = DateTimeOffset.UtcNow.AddDays(16);
        var result = await client.GetByDate(idDiscriminator, moment, paginationRequest, new CancellationToken());

        Assert.NotNull(result);

        var restEntities = entities.Where(e => !idsToDelete.Contains(e.Id));
        Assert.Equal(restEntities.Count(), result.Count);

        var actualIds = restEntities.Select(e => e.Id);
        var expectedIds = result.Items.Select(e => e.Id);
        Assert.Equivalent(expectedIds, actualIds);
    }

    [Theory]
    [InlineData(5, -15, -5, -20, 20, 10)]
    [InlineData(5, -15, -10, -16, 9, 10)]
    public async Task GetChangeLogForInterval_returns_success(
        int insertedCount,
        int daysBeforeNowChangeLog,
        int daysAfterNowChangeLog,
        int daysBeforeNowFilter,
        int daysAfterNowFilter,
        int changeLogCount)
    {
        // arrange
        dbContext.CleanupDbSet<ChangeLog>();

        //создаем записи
        var count = insertedCount;
        var daysRange = (daysBeforeNowChangeLog, daysAfterNowChangeLog);
        var changeLogItems = await CreateAndReturnNewDtos(count, daysRange);
        var idDiscriminator = changeLogItems.Item1;
        var dtos = changeLogItems.Item2;

        await client.UpdateRange(dtos, "Обновляем несколько записей", CancellationToken.None);

        //act
        var dateBegin = DateTimeOffset.UtcNow.AddDays(daysBeforeNowFilter);
        var dateEnd = DateTimeOffset.UtcNow.AddDays(daysAfterNowFilter);
        var result = await client.GetChangeLogForInterval(idDiscriminator, dateBegin, dateEnd, CancellationToken.None);

        //assert
        Assert.NotNull(result);
        Assert.Equal(changeLogCount, result.Count());
    }


    private static IEnumerable<ChangeLogValuesDto> Generate(int count)
    {
        for (int i = 0; i < count; i++)
            yield return new ChangeLogValuesDto()
            {
                Value = new Dictionary<string, object>()
                {
                    { "Key", 1 }
                },
                Id = Guid.NewGuid()
            };

    }

    private async Task<(Guid, IEnumerable<ChangeLogValuesDto>)> CreateAndReturnNewDtos(int count, (int, int) daysRange)
    {
        var minDayCount = daysRange.Item1;
        var maxDayCount = daysRange.Item2;

        Guid idDiscriminator = Guid.NewGuid();
        var dtos = Generate(count);
        var entities = dtos.Select(d =>
        {
            var entity = d.Adapt<ChangeLog>();
            entity.DiscriminatorId = idDiscriminator;
            entity.Creation = DateTimeOffset.UtcNow.AddDays(generatorRandomDigits.Next(minDayCount, maxDayCount));

            return entity;
        }).ToArray();

        dtos = entities.Select(e => e.Adapt<ChangeLogValuesDto>());

        // act
        var result = await client.AddRange(idDiscriminator, dtos, "Добавление элементов", CancellationToken.None);
        var paginatedResult = await client.GetByDate(idDiscriminator, DateTimeOffset.UtcNow.AddDays(1), paginationRequest, CancellationToken.None);
        return (idDiscriminator, paginatedResult.Items);
    }

    private async Task<(Guid, IEnumerable<ChangeLog>)> CreateAndReturnNewEntities(int count, (int, int) daysRange)
    {
        var commit = new ChangeLogCommit()
        {
            Comment = "Комментарий к коммиту",
            Creation = DateTimeOffset.UtcNow,
            Id = Guid.NewGuid(),
        };
        dbContext.ChangeLogCommit.Add(commit);
        await dbContext.SaveChangesAsync();

        var minDayCount = daysRange.Item1;
        var maxDayCount = daysRange.Item2;

        Guid idDiscriminator = Guid.NewGuid();
        var dtos = Generate(count);
        var entities = dtos.Select(d =>
        {
            var entity = d.Adapt<ChangeLog>();
            entity.DiscriminatorId = idDiscriminator;
            entity.Creation = DateTimeOffset.UtcNow.AddDays(generatorRandomDigits.Next(minDayCount, maxDayCount));
            entity.IdCreatedCommit = commit.Id;

            return entity;
        }).ToArray();

        dbContext.ChangeLog.AddRange(entities);
        await dbContext.SaveChangesAsync();

        return (idDiscriminator, entities);
    }
}