persistence/Persistence.IntegrationTests/Controllers/ChangeLogControllerTest.cs

using Mapster;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.DependencyInjection;
using Persistence.Client;
using Persistence.Client.Clients;
using Persistence.Database.Model;
using Persistence.Models;
using Persistence.Models.Requests;
using System.Net;
using Xunit;

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

    public ChangeLogControllerTest(WebAppFactoryFixture factory) : base(factory)
    {
        var persistenceClientFactory = scope.ServiceProvider
            .GetRequiredService<PersistenceClientFactory>();

        client = persistenceClientFactory.GetClient<IChangeLogClient>();
    }

    [Fact]
    public async Task ClearAndInsertRange()
    {
        // arrange
        var idDiscriminator = Guid.NewGuid();
        var dtos = Generate(2, DateTimeOffset.UtcNow);

        // act
        var result = await client.ClearAndInsertRange(idDiscriminator, dtos);

        // assert
        Assert.Equal(HttpStatusCode.OK, result.StatusCode);
        Assert.Equal(2, result.Content);
    }

    [Fact]
    public async Task Add_returns_success()
    {
        // arrange
        var count = 1;
        var idDiscriminator = Guid.NewGuid();
        var dtos = Generate(count, DateTimeOffset.UtcNow);
        var dto = dtos.FirstOrDefault()!;

        // act
        var result = await client.Add(idDiscriminator, dto);

        // assert
        Assert.Equal(HttpStatusCode.OK, result.StatusCode);
        Assert.Equal(count, result.Content);
    }

    [Fact]
    public async Task AddRange_returns_success()
    {
        // arrange
        var count = 3;
        var idDiscriminator = Guid.NewGuid();
        var dtos = Generate(count, DateTimeOffset.UtcNow);

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

        // assert
        Assert.Equal(HttpStatusCode.OK, result.StatusCode);
        Assert.Equal(count, result.Content);
    }

    [Fact]
    public async Task Update_returns_success()
    {
        // arrange
        var idDiscriminator = Guid.NewGuid();
        var dtos = Generate(1, DateTimeOffset.UtcNow);
        var dto = dtos.FirstOrDefault()!;
        var entity = dto.Adapt<ChangeLog>();
        dbContext.ChangeLog.Add(entity);
        dbContext.SaveChanges();

        dto.Id = entity.Id;
        dto.DepthStart = dto.DepthStart + 10;
        dto.DepthEnd = dto.DepthEnd + 10;

        // act
        var result = await client.Update(idDiscriminator, dto);

        // assert
        Assert.Equal(HttpStatusCode.OK, result.StatusCode);
        Assert.Equal(2, result.Content);

        //var entities = dbContext.ChangeLog
        //    .Where(e => e.IdDiscriminator == idDiscriminator)
        //    .ToArray();
        //var obsoleteEntity = entities
        //    .Where(e => e.Obsolete.HasValue)
        //    .FirstOrDefault();

        //var activeEntity = entities
        //    .Where(e => !e.Obsolete.HasValue)
        //    .FirstOrDefault();

        //if (obsoleteEntity == null || activeEntity == null)
        //{
        //    Assert.Fail();
        //    return;
        //}

        //Assert.Equal(activeEntity.IdNext, obsoleteEntity.Id);

    }

    [Fact]
    public async Task UpdateRange_returns_success()
    {
        // arrange
        var count = 2;
        var idDiscriminator = Guid.NewGuid();
        var dtos = Generate(count, DateTimeOffset.UtcNow);
        var entities = dtos.Select(d => d.Adapt<ChangeLog>()).ToArray();
        dbContext.ChangeLog.AddRange(entities);
        dbContext.SaveChanges();

        dtos = entities.Select(c => new DataWithWellDepthAndSectionDto()
        {
            DepthEnd = c.DepthEnd + 10,
            DepthStart = c.DepthStart + 10,
            Id = c.Id,
            IdSection = c.IdSection,
            Value = c.Value
        }).ToArray();

        // act
        var result = await client.UpdateRange(idDiscriminator, dtos);

        // assert
        Assert.Equal(HttpStatusCode.OK, result.StatusCode);
        Assert.Equal(count * 2, result.Content);
    }

    [Fact]
    public async Task Delete_returns_success()
    {
        // arrange
        var dtos = Generate(1, DateTimeOffset.UtcNow);
        var dto = dtos.FirstOrDefault()!;
        var entity = dto.Adapt<ChangeLog>();
        dbContext.ChangeLog.Add(entity);
        dbContext.SaveChanges();

        // act
        var result = await client.Delete(entity.Id);

        // assert
        Assert.Equal(HttpStatusCode.OK, result.StatusCode);
        Assert.Equal(1, result.Content);
    }

    [Fact]
    public async Task DeleteRange_returns_success()
    {
        // arrange
        var count = 10;
        var dtos = Generate(count, DateTimeOffset.UtcNow);
        var entities = dtos.Select(d => d.Adapt<ChangeLog>()).ToArray();
        dbContext.ChangeLog.AddRange(entities);
        dbContext.SaveChanges();

        // act
        var ids = entities.Select(e => e.Id);
        var result = await client.DeleteRange(ids);

        // assert
        Assert.Equal(HttpStatusCode.OK, result.StatusCode);
        Assert.Equal(count, result.Content);
    }

    [Fact]
    public async Task GetDatesRange_returns_success()
    {
        // arrange
        var changeLogItems = CreateChangeLogItems(3, (-15, 15));
        var idDiscriminator = changeLogItems.Item1;
        var entities = changeLogItems.Item2;

        var orderedEntities = entities.OrderBy(e => e.Creation);
        var minDate = orderedEntities.First().Creation;
        var maxDate = orderedEntities.Last().Creation;

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

        // assert
        Assert.Equal(HttpStatusCode.OK, result.StatusCode);
        Assert.NotNull(result.Content);

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

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

    [Fact]
    public async Task GetByDate_returns_success()
    {
        // arrange
        //создаем записи
        var count = 5;
        var changeLogItems = CreateChangeLogItems(count, (-15, 15));
        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);

        var request = new SectionPartRequest()
        {
            Skip = 0,
            Take = 10,
            SortSettings = String.Empty,
        };

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

        Assert.Equal(HttpStatusCode.OK, result.StatusCode);
        Assert.NotNull(result.Content);

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

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

    [Theory]
    [InlineData(5, -15, 15, -20, 20, 10)]
    [InlineData(5, -15, -10, -16, -9, 5)]
    public async Task GetChangeLogForDate_returns_success(
        int insertedCount,
        int leftCreationFromCurrentDate,
        int rightCreationFromCurrentDate,
        int leftPointFromCurrentDate,
        int rightPointFromCurrentDate,
        int changeLogCount)
    {
        // arrange
        //создаем записи
        var count = insertedCount;
        var daysRange = (leftCreationFromCurrentDate, rightCreationFromCurrentDate);
        var changeLogItems = CreateChangeLogItems(count, daysRange);
        var idDiscriminator = changeLogItems.Item1;
        var entities = changeLogItems.Item2;

        foreach (var entity in entities)
        {
            entity.DepthEnd = entity.DepthEnd + 10;
        }
        var dtos = entities.Select(e => e.Adapt<DataWithWellDepthAndSectionDto>()).ToArray();
        await client.UpdateRange(idDiscriminator, dtos);

        //act
        var dateBegin = DateTimeOffset.UtcNow.AddDays(leftPointFromCurrentDate);
        var dateEnd = DateTimeOffset.UtcNow.AddDays(rightPointFromCurrentDate);
        var result = await client.GetChangeLogForDate(idDiscriminator, dateBegin, dateEnd);

        //assert
        Assert.Equal(HttpStatusCode.OK, result.StatusCode);
        Assert.NotNull(result.Content);
        Assert.Equal(changeLogCount, result.Content.Count());
    }


    private static IEnumerable<DataWithWellDepthAndSectionDto> Generate(int count, DateTimeOffset from)
    {
        for (int i = 0; i < count; i++)
            yield return new DataWithWellDepthAndSectionDto()
            {
                Value = new Dictionary<string, object>()
                {
                    { "Key", 1 }
                },
                DepthStart = generatorRandomDigits.Next(1, 5),
                DepthEnd = generatorRandomDigits.Next(5, 15),
                Id = Guid.NewGuid(),
                IdSection = Guid.NewGuid()
            };

    }

    private (Guid, ChangeLog[]) CreateChangeLogItems(int count, (int, int) daysRange)
    {
        var minDayCount = daysRange.Item1;
        var maxDayCount = daysRange.Item2;

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

            return entity;
        }).ToArray();
        dbContext.ChangeLog.AddRange(entities);
        dbContext.SaveChanges();

        return (idDiscriminator, entities);
    }
}