Add Steam Query, and Rcon as data providers

DiscordPlayerCountBot/Enums/DataProvider.cs

@@ -7,6 +7,7 @@ public enum DataProvider
         SCUM,
         MINECRAFT,
         BATTLEMETRICS,
-        RCONClient
+        RCONClient,
+        SteamQuery
     }
 }

DiscordPlayerCountBot/Providers/Base/ServerInformationProvider.cs

@@ -1,4 +1,5 @@
-using System.Net;
+using SteamServerQuery;
+using System.Net;
 using System.Net.Http;
 
 namespace PlayerCountBot.Providers.Base
@@ -17,7 +18,6 @@ protected void HandleLastException(BotInformation information)
         {
             if (WasLastExecutionAFailure)
             {
-
                 Info($"Bot named: {information.Name} at address: {information.Address} successfully fetched data after failure.");
                 LastException = null;
                 WasLastExecutionAFailure = false;
@@ -76,6 +76,12 @@ protected void HandleException(Exception e)
                 return;
             }
 
+            if(e is SteamException steamException)
+            {
+                Error($"There was an issue speaking with Steam Query Server.", e);
+                return;
+            }
+
             Error($"There was an error speaking with {Label}.", e);
             throw e;
         }

DiscordPlayerCountBot/Providers/RconProvider.cs

@@ -1,5 +1,4 @@
 using DiscordPlayerCountBot.Enums;
-using DiscordPlayerCountBot.Enums;
 using DiscordPlayerCountBot.Exceptions;
 using DiscordPlayerCountBot.Services;
 

DiscordPlayerCountBot/Providers/SteamQueryProvider.cs

@@ -0,0 +1,37 @@
+using DiscordPlayerCountBot.Services.SteamQuery;
+
+namespace PlayerCountBot.Providers
+{
+    [Name("Steam Query")]
+    public class SteamQueryProvider : ServerInformationProvider
+    {
+        public SteamQueryProvider(BotInformation info) : base(info)
+        {
+        }
+
+        public async override Task<BaseViewModel?> GetServerInformation(BotInformation information, Dictionary<string, string> applicationVariables)
+        {
+            var service = new SteamQueryService();
+
+            try
+            {
+                var addressAndPort = information.GetAddressAndPort();
+                var response = await service.GetQueryResponse(addressAndPort.Item1, addressAndPort.Item2);
+
+                if (response == null)
+                {
+                    throw new ApplicationException($" Failed to get a Server Information response from Steam Query.");
+                }
+
+                HandleLastException(information);
+
+                return response;
+            }
+            catch (Exception e)
+            {
+                HandleException(e);
+                return null;
+            }
+        }
+    }
+}

DiscordPlayerCountBot/Services/Rcon/RconService.cs

@@ -7,7 +7,7 @@ namespace DiscordPlayerCountBot.Services
 {
     public class RconService : IRconService
     {
-        private Dictionary<RconServiceType, RconServiceInformation> PlayerCommands = new()
+        private readonly Dictionary<RconServiceType, RconServiceInformation> PlayerCommands = new()
         {
             {RconServiceType.CSGO, new RconServiceInformation("status", new CSGOInformationParser())},
             {RconServiceType.Minecraft, new RconServiceInformation("list", new MinecraftInformationParser()) },

DiscordPlayerCountBot/Services/SteamQuery/ISteamQueryService.cs

@@ -0,0 +1,9 @@
+using DiscordPlayerCountBot.Enums;
+
+namespace DiscordPlayerCountBot.Services.SteamQuery
+{
+    internal interface ISteamQueryService
+    {
+        public Task<BaseViewModel> GetQueryResponse(string address, int port);
+    }
+}

DiscordPlayerCountBot/Services/SteamQuery/SteamQueryService.cs

@@ -0,0 +1,29 @@
+using SteamServerQuery;
+
+namespace DiscordPlayerCountBot.Services.SteamQuery
+{
+    public class SteamQueryService : ISteamQueryService
+    {
+        public async Task<BaseViewModel> GetQueryResponse(string address, int port, string authorizationToken)
+        {
+            var model = new BaseViewModel()
+            {
+                Address = address,
+                Port = port
+            };
+
+            try
+            {
+                var serverInformation = await SteamServer.QueryServerAsync(address, port = 0);
+                model.MaxPlayers = serverInformation.MaxPlayers;
+                model.Players = serverInformation.Players;
+                model.QueuedPlayers = 0;
+            }catch
+            {
+                throw;
+            }
+
+            return model;
+        }
+    }
+}