namespace Dpz.Core.Web.Library;

[Obsolete]
public class ChatCurrentConnections
{
    /// <summary>
    /// 在线用户
    /// </summary>
    private static readonly Dictionary<string, VmUserInfo> ConnectionUsers = new Dictionary<string, VmUserInfo>();

    private static readonly object LockObj = new object();

    private static ChatCurrentConnections? _instance;

    private ChatCurrentConnections() { }

    public static ChatCurrentConnections GetInstance()
    {
        if (_instance != null) return _instance;
        lock (LockObj)
        {
            _instance = new ChatCurrentConnections();
            return _instance;
        }
    }

    public VmUserInfo this[string index] => ConnectionUsers[index];

    public void Add(string connectionId, VmUserInfo user)
    {
        lock (LockObj)
        {
            if (ConnectionUsers.ContainsKey(connectionId))
            {
                ConnectionUsers.Add(connectionId, user);
            }
            else
            {
                ConnectionUsers[connectionId] = user;
            }
        }
    }

    public VmUserInfo? Get(string connectionId)
    {
        if (!ConnectionUsers.TryGetValue(connectionId, out var user))
        {
            return null;
        }
        return user;
    }

    public void Remove(string connectionId)
    {
        if (ConnectionUsers.ContainsKey(connectionId))
        {
            //ConnectionUsers.Values.Any(x => x.Id == this[connectionId].Id)
            lock (LockObj)
            {
                ConnectionUsers.Remove(connectionId);
            }
        }
    }

    public List<VmUserInfo> GetAllOnlineUsers()
    {
        lock (LockObj)
        {
            return ConnectionUsers.Select(x => x.Value).ToList();
        }
    }
}