VeloeGameServerDataCollector/VeloeMonitorDataCollector/DatabaseConnectors/SignalRConnector.cs

using Microsoft.Extensions.Configuration;
using MinecraftStatus;
using VeloeMonitorDataCollector.Dependencies;
using VeloeMonitorDataCollector.Models;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.AspNetCore.SignalR;
using System.Text.Json;
using Serilog;

namespace VeloeMonitorDataCollector.DatabaseConnectors
{
    internal class SignalRConnector : IDataSendable
    {
        WebApplication app;
        public SignalRConnector(in IConfigurationSection section, in Serilog.ILogger logger)
        {
            string url = section["url"];

            if (string.IsNullOrEmpty(url))
                url = "http://*:5000";

            var builder = WebApplication.CreateBuilder();

            builder.WebHost.UseUrls(url);

            builder.Services.AddSignalR();
            builder.Services.AddSingleton<DataSender>();

            builder.Host.UseSerilog(logger);

            app = builder.Build();

            app.MapHub<DataHub>("/hubs/data");

            app.RunAsync();
        }

        public bool CheckGameServer(in string name, in string type)
        {
            return true;
        }

        public bool CheckHardware(in Dictionary<string, float> input)
        {
            return true;
        }

        public void Close()
        {
            app.StopAsync();
        }

        public void SendGamespy3(in Gs3Status.Status data, in string name)
        {
            app.Services.GetService<DataSender>().SendGamespy3(data, name);
        }

        public void SendHardware(in Dictionary<string, float> data)
        {
            app.Services.GetService<DataSender>().SendHardware(data);
        }

        public void SendMinecraft(in McStatus data, in string name)
        {
            app.Services.GetService<DataSender>().SendMinecraft(data, name);
        }

        public void SendSteam(in SteamData data, in string name)
        {
            app.Services.GetService<DataSender>().SendSteam(data, name);
        }
    }

    public class DataSender
    {
        IHubContext<DataHub> _hubContext;
        Serilog.ILogger _logger;
        public DataSender(IHubContext<DataHub> hubContext, ILogger logger)
        {
            _hubContext = hubContext; 
            _logger = logger;
        }

        public void SendGamespy3(in Gs3Status.Status data, in string name)
        {
            _hubContext.Clients.Groups(name).SendAsync($"Update{name}",JsonSerializer.Serialize(data));
        }

        public void SendHardware(in Dictionary<string, float> data)
        {
            _hubContext.Clients.Groups("hardware").SendAsync($"Update", JsonSerializer.Serialize(data));
        }

        public void SendMinecraft(in McStatus data, in string name)
        {
            _hubContext.Clients.Groups(name).SendAsync($"Update{name}", JsonSerializer.Serialize(data));
        }

        public void SendSteam(in SteamData data, in string name)
        {
            _hubContext.Clients.Groups(name).SendAsync($"Update{name}", JsonSerializer.Serialize(data));
        }
    }

    public class DataHub : Hub
    {
        public async Task SendMessage(string user, string message)
        {

            await Clients.All.SendAsync("ReceiveMessage", user, message);
        }

        public async Task ConnectToGroup(string groupName)
        {
            await Groups.AddToGroupAsync(Context.ConnectionId, groupName);
        }

        public async Task DisconnectFromGroup(string groupName)
        {
            await Groups.RemoveFromGroupAsync(Context.ConnectionId, groupName);
        }
    }
}