// Copyright (c) Microsoft. All rights reserved.

using System.Collections.Concurrent;
using Microsoft.Extensions.Logging;

namespace Microsoft.Agents.AI.DurableTask.IntegrationTests.Logging;

internal sealed class TestLoggerProvider(ITestOutputHelper output) : ILoggerProvider
{
    private readonly ITestOutputHelper _output = output ?? throw new ArgumentNullException(nameof(output));
    private readonly ConcurrentDictionary<string, TestLogger> _loggers = new(StringComparer.OrdinalIgnoreCase);

    public bool TryGetLogs(string category, out IReadOnlyCollection<LogEntry> logs)
    {
        if (this._loggers.TryGetValue(category, out TestLogger? logger))
        {
            logs = logger.GetLogs();
            return true;
        }

        logs = [];
        return false;
    }

    public IReadOnlyCollection<LogEntry> GetAllLogs()
    {
        return this._loggers.Values
            .OfType<TestLogger>()
            .SelectMany(logger => logger.GetLogs())
            .ToList()
            .AsReadOnly();
    }

    public void Clear()
    {
        foreach (TestLogger logger in this._loggers.Values.OfType<TestLogger>())
        {
            logger.ClearLogs();
        }
    }

    ILogger ILoggerProvider.CreateLogger(string categoryName)
    {
        return this._loggers.GetOrAdd(categoryName, _ => new TestLogger(categoryName, this._output));
    }

    void IDisposable.Dispose()
    {
        // no-op
    }
}