using System.ComponentModel.DataAnnotations;
using NSubstitute;
using RackPeek.Domain.Helpers;
using RackPeek.Domain.Resources.Hardware;
using RackPeek.Domain.Resources.Hardware.Servers.Nics;
using RackPeek.Domain.Resources.Models;

namespace Tests.HardwareResources;

public class UpdateNicUseCaseTests
{
    [Fact]
    public async Task ExecuteAsync_Updates_nic_when_index_valid()
    {
        var repo = Substitute.For<IHardwareRepository>();
        var server = new Server
        {
            Name = "node01",
            Nics = new List<Nic>
            {
                new() { Type = "10GBase-T", Speed = 10000, Ports = 2 }
            }
        };

        repo.GetByNameAsync("node01").Returns(server);

        var sut = new UpdateNicUseCase(repo);

        await sut.ExecuteAsync("node01", 0, "SFP+", 10000, 1);

        Assert.Equal("sfp+", server.Nics[0].Type);
        Assert.Equal(10000, server.Nics[0].Speed!.Value);
        Assert.Equal(1, server.Nics[0].Ports!.Value);

        await repo.Received(1).UpdateAsync(Arg.Any<Server>());
    }

    [Fact]
    public async Task ExecuteAsync_Throws_when_index_out_of_range()
    {
        var repo = Substitute.For<IHardwareRepository>();
        var server = new Server
        {
            Name = "node01",
            Nics = new List<Nic> { new() }
        };

        repo.GetByNameAsync("node01").Returns(server);

        var sut = new UpdateNicUseCase(repo);

        await Assert.ThrowsAsync<ValidationException>(() =>
            sut.ExecuteAsync("node01", 1, "SFP+", 10000, 1));

        await repo.DidNotReceive().UpdateAsync(Arg.Any<Server>());
    }

    [Fact]
    public async Task ExecuteAsync_Does_nothing_when_server_not_found()
    {
        var repo = Substitute.For<IHardwareRepository>();

        repo.GetByNameAsync("node01")
            .Returns((Hardware?)null);

        var sut = new UpdateNicUseCase(repo);

        var ex = await Assert.ThrowsAsync<NotFoundException>(() =>
            sut.ExecuteAsync("node01", 0, "SFP+", 10000, 1)
        );

        await repo.DidNotReceive().UpdateAsync(Arg.Any<Server>());
    }
}