// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.
 
using BenchmarkDotNet.Attributes;
using Microsoft.AspNetCore.SignalR.Microbenchmarks.Shared;
using Microsoft.AspNetCore.SignalR.Protocol;
using Microsoft.Extensions.Logging.Abstractions;
 
namespace Microsoft.AspNetCore.SignalR.Microbenchmarks;
 
public class DefaultHubLifetimeManagerBenchmark
{
    private DefaultHubLifetimeManager<Hub> _hubLifetimeManager;
    private List<string> _connectionIds;
    private List<string> _subsetConnectionIds;
    private List<string> _groupNames;
    private List<string> _userIdentifiers;
 
    [Params(true, false)]
    public bool ForceAsync { get; set; }
 
    [GlobalSetup]
    public void GlobalSetup()
    {
        _hubLifetimeManager = new DefaultHubLifetimeManager<Hub>(NullLogger<DefaultHubLifetimeManager<Hub>>.Instance);
        _connectionIds = new List<string>();
        _subsetConnectionIds = new List<string>();
        _groupNames = new List<string>();
        _userIdentifiers = new List<string>();
 
        var jsonHubProtocol = new NewtonsoftJsonHubProtocol();
 
        for (int i = 0; i < 100; i++)
        {
            string connectionId = "connection-" + i;
            string groupName = "group-" + i % 10;
            string userIdentifier = "user-" + i % 20;
            AddUnique(_connectionIds, connectionId);
            AddUnique(_groupNames, groupName);
            AddUnique(_userIdentifiers, userIdentifier);
            if (i % 3 == 0)
            {
                _subsetConnectionIds.Add(connectionId);
            }
 
            var connectionContext = new TestConnectionContext
            {
                ConnectionId = connectionId,
                Transport = new TestDuplexPipe(ForceAsync)
            };
            var contextOptions = new HubConnectionContextOptions()
            {
                KeepAliveInterval = TimeSpan.Zero,
            };
            var hubConnectionContext = new HubConnectionContext(connectionContext, contextOptions, NullLoggerFactory.Instance);
            hubConnectionContext.UserIdentifier = userIdentifier;
            hubConnectionContext.Protocol = jsonHubProtocol;
 
            _hubLifetimeManager.OnConnectedAsync(hubConnectionContext).GetAwaiter().GetResult();
            _hubLifetimeManager.AddToGroupAsync(connectionId, groupName);
        }
    }
 
    private void AddUnique(List<string> list, string connectionId)
    {
        if (!list.Contains(connectionId))
        {
            list.Add(connectionId);
        }
    }
 
    [Benchmark]
    public Task SendAllAsync()
    {
        return _hubLifetimeManager.SendAllAsync("MethodName", Array.Empty<object>());
    }
 
    [Benchmark]
    public Task SendGroupAsync()
    {
        return _hubLifetimeManager.SendGroupAsync(_groupNames[0], "MethodName", Array.Empty<object>());
    }
 
    [Benchmark]
    public Task SendGroupsAsync()
    {
        return _hubLifetimeManager.SendGroupsAsync(_groupNames, "MethodName", Array.Empty<object>());
    }
 
    [Benchmark]
    public Task SendGroupExceptAsync()
    {
        return _hubLifetimeManager.SendGroupExceptAsync(_groupNames[0], "MethodName", Array.Empty<object>(), _subsetConnectionIds);
    }
 
    [Benchmark]
    public Task SendAllExceptAsync()
    {
        return _hubLifetimeManager.SendAllExceptAsync("MethodName", Array.Empty<object>(), _subsetConnectionIds);
    }
 
    [Benchmark]
    public Task SendConnectionAsync()
    {
        return _hubLifetimeManager.SendConnectionAsync(_connectionIds[0], "MethodName", Array.Empty<object>());
    }
 
    [Benchmark]
    public Task SendConnectionsAsync()
    {
        return _hubLifetimeManager.SendConnectionsAsync(_subsetConnectionIds, "MethodName", Array.Empty<object>());
    }
 
    [Benchmark]
    public Task SendUserAsync()
    {
        return _hubLifetimeManager.SendUserAsync(_userIdentifiers[0], "MethodName", Array.Empty<object>());
    }
 
    [Benchmark]
    public Task SendUsersAsync()
    {
        return _hubLifetimeManager.SendUsersAsync(_userIdentifiers, "MethodName", Array.Empty<object>());
    }
}