using System;
using System.Diagnostics;
using Microsoft.Extensions.Logging;
using MongoDB.Bson;
using MongoDB.Driver.Core.Events;

namespace Dpz.Core.MongodbAccess;

internal class MongoLogEvents : IEventSubscriber
{
    private readonly ILogger _logger;
    private readonly ReflectionEventSubscriber _subscriber;

    private readonly Guid _category = Guid.NewGuid();

    private Stopwatch _watch = new();

    public MongoLogEvents(ILogger logger)
    {
        _logger = logger;
        _subscriber = new ReflectionEventSubscriber(this);
    }

    public bool TryGetEventHandler<TEvent>(out Action<TEvent> handler)
    {
        return _subscriber.TryGetEventHandler(out handler);
    }

    public void Handle(CommandStartedEvent e)
    {
        _watch = Stopwatch.StartNew();
        _logger.LogInformation("{Category} command:{Json}", _category, e.ToJson());
    }

    public void Handle(CommandSucceededEvent e)
    {
        _watch.Stop();
        _logger.LogInformation(
            "{Category} execution time:{Times} ms",
            _category,
            _watch.ElapsedMilliseconds
        );
    }
}