using RackPeek.Domain.Persistence;

namespace RackPeek.Domain.Resources.Services.UseCases;

public record ServiceReport(
    IReadOnlyList<ServiceReportRow> Services
);

public record ServiceReportRow(
    string Name,
    string? Ip,
    int? Port,
    string? Protocol,
    string? Url,
    List<string>? RunsOnSystemHost,
    List<string>? RunsOnPhysicalHost
);

public class ServiceReportUseCase(IResourceCollection repository) : IUseCase {
    public async Task<ServiceReport> ExecuteAsync() {
        IReadOnlyList<Service> services = await repository.GetAllOfTypeAsync<Service>();

        var rows = services.Select(async s => {
            var runsOnPhysicalHost = new List<string>();
            if (s.RunsOn is not null)
                foreach (var system in s.RunsOn) {
                    Resource? systemResource = await repository.GetByNameAsync(system);
                    if (systemResource?.RunsOn is not null)
                        foreach (var parent in systemResource.RunsOn)
                            if (!runsOnPhysicalHost.Contains(parent))
                                runsOnPhysicalHost.Add(parent);
                }

            return new ServiceReportRow(
                s.Name,
                s.Network?.Ip,
                s.Network?.Port,
                s.Network?.Protocol,
                s.Network?.Url,
                s.RunsOn,
                runsOnPhysicalHost
            );
        }).ToList();

        ServiceReportRow[] result = await Task.WhenAll(rows);
        return new ServiceReport(result);
    }
}