Initial commit

.gitignore

@@ -0,0 +1,15 @@
+# JetBrains
+.idea/
+*.iml
+*.iws
+
+# Visual Studio Code
+.vscode/
+.history
+
+# Mac
+.DS_Store
+
+# .NET
+libs/
+obj/

AzLink/AzLink.cs

@@ -0,0 +1,232 @@
+using Newtonsoft.Json;
+using Oxide.Core.Libraries;
+using Oxide.Core.Libraries.Covalence;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+
+namespace Oxide.Plugins;
+
+[Info("AzLink", "Azuriom", AzLinkVersion)]
+[Description("Link your Azuriom website with an Oxide server.")]
+class AzLink : CovalencePlugin
+{
+    private const string AzLinkVersion = "0.1.0";
+
+    private DateTime lastSent = DateTime.MinValue;
+    private DateTime lastFullSent = DateTime.MinValue;
+
+    private void Init()
+    {
+        timer.Every(60, TryFetch);
+    }
+
+    protected override void LoadDefaultConfig()
+    {
+        Log("Creating a new configuration file.");
+
+        Config["URL"] = null;
+        Config["SiteKey"] = null;
+    }
+
+    [Command("azlink.setup"), Permission("azlink.setup")]
+    private void SetupCommand(IPlayer player, string command, string[] args)
+    {
+        if (args.Length < 2)
+        {
+            player.Reply(
+                "You must first add this server in your Azuriom admin dashboard, in the 'Servers' section.");
+            return;
+        }
+
+        Config["URL"] = args[0];
+        Config["SiteKey"] = args[1];
+
+        PingWebsite(() =>
+        {
+            player.Reply("Linked to the website successfully.");
+            SaveConfig();
+        }, code => player.Reply($"An error occurred, code {code}"));
+    }
+
+    [Command("azlink.status"), Permission("azlink.status")]
+    private void StatusCommand(IPlayer player, string command, string[] args)
+    {
+        if (Config["URL"] == null)
+        {
+            player.Reply("AzLink is not configured yet, use the 'setup' subcommand first.");
+            return;
+        }
+
+        PingWebsite(() => player.Reply("Connected to the website successfully."),
+            code => player.Reply($"An error occurred, code {code}"));
+
+        player.Reply("Connected to the website successfully.");
+    }
+
+    [Command("azlink.fetch"), Permission("azlink.fetch")]
+    private void FetchCommand(IPlayer player, string command, string[] args)
+    {
+        if (Config["URL"] == null)
+        {
+            player.Reply("AzLink is not configured yet, use the 'setup' subcommand first.");
+            return;
+        }
+
+        RunFetch(res =>
+        {
+            DispatchCommands(res.Commands);
+
+            player.Reply("Data has been fetched successfully.");
+        }, code => player.Reply($"An error occurred, code {code}"), true);
+    }
+
+    private void TryFetch()
+    {
+        var url = (string?)Config["URL"];
+        var siteKey = (string?)Config["SiteKey"];
+        var now = DateTime.Now;
+
+        if (url == null || siteKey == null)
+        {
+            return;
+        }
+
+        if ((now - lastSent).Seconds < 15)
+        {
+            return;
+        }
+
+        lastSent = now;
+
+        var sendFull = now.Minute % 15 == 0 && (now - lastFullSent).Seconds > 60;
+
+        if (sendFull)
+        {
+            lastFullSent = now;
+        }
+
+        RunFetch(res => DispatchCommands(res.Commands),
+            code => LogError("Unable to send data to the website (code {0})", code), sendFull);
+    }
+
+    private void RunFetch(Action<FetchResponse> callback, Action<int> errorHandler, bool sendFullData)
+    {
+        var url = (string)Config["URL"];
+        var body = JsonConvert.SerializeObject(GetServerData(sendFullData));
+
+        webrequest.Enqueue($"{url}/api/azlink", body, (code, response) =>
+        {
+            if (code is < 200 or >= 300)
+            {
+                errorHandler(code);
+                return;
+            }
+
+            callback(JsonConvert.DeserializeObject<FetchResponse>(response));
+        }, this, RequestMethod.POST, GetRequestHeaders());
+    }
+
+    private void PingWebsite(Action onSuccess, Action<int> errorHandler)
+    {
+        var url = (string?)Config["URL"];
+        var siteKey = (string?)Config["SiteKey"];
+
+        if (url == null || siteKey == null)
+        {
+            throw new ApplicationException("AzLink is not configured yet.");
+        }
+
+        webrequest.Enqueue($"{url}/api/azlink", null, (code, _) =>
+        {
+            if (code is < 200 or >= 300)
+            {
+                errorHandler(code);
+                return;
+            }
+
+            onSuccess();
+        }, this, RequestMethod.GET, GetRequestHeaders());
+    }
+
+    private void DispatchCommands(ICollection<PendingCommand> commands)
+    {
+        if (commands.Count == 0)
+        {
+            return;
+        }
+
+        foreach (var info in commands)
+        {
+            var player = players.FindPlayerById(info.UserId);
+            var name = player?.Name ?? info.UserName;
+
+            foreach (var command in info.Values)
+            {
+                var cmd = command.Replace("{player}", name)
+                    .Replace("{steam_id}", info.UserId);
+
+                Log("Dispatching command to {0} ({1}): {2}", name, info.UserId, cmd);
+
+                server.Command(cmd);
+            }
+        }
+
+        Log("Dispatched commands to {0} players.", commands.Count);
+    }
+
+    private Dictionary<string, object> GetServerData(bool includeFullData)
+    {
+        var online = players.Connected.Select(player => new Dictionary<string, string>
+        {
+            { "name", player.Name }, { "uid", player.Id }
+        });
+        var data = new Dictionary<string, object>
+        {
+            {
+                "platform", new Dictionary<string, string>()
+                {
+                    { "type", "OXIDE" },
+                    { "name", $"Oxide - {game}" },
+                    { "version", server.Version },
+                }
+            },
+            { "version", AzLinkVersion },
+            { "players", online },
+            { "maxPlayers", server.MaxPlayers },
+            { "full", includeFullData }
+        };
+
+        if (includeFullData)
+        {
+            data.Add("ram", GC.GetTotalMemory(false) / 1024 / 1024);
+        }
+
+        return data;
+    }
+
+    private Dictionary<string, string> GetRequestHeaders()
+    {
+        return new Dictionary<string, string>
+        {
+            { "Azuriom-Link-Token", (string)Config["SiteKey"] },
+            { "Accept", "application/json" },
+            { "Content-type", "application/json" },
+            { "User-Agent", "AzLink Oxide v" + AzLinkVersion },
+        };
+    }
+}
+
+class FetchResponse
+{
+    [JsonProperty("commands")] public List<PendingCommand> Commands { get; set; }
+}
+
+class PendingCommand
+{
+    [JsonProperty("uid")] public string UserId { get; set; }
+
+    [JsonProperty("name")] public string UserName { get; set; }
+
+    [JsonProperty("values")] public List<string> Values { get; set; }
+}

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2023 Azuriom
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,10 @@
+# AzLink-GMod
+
+[![Latest release](https://img.shields.io/github/v/release/Azuriom/AzLink-Oxide?style=flat-square)](https://github.com/Azuriom/AzLink-Oxide/releases)
+[![Chat](https://img.shields.io/discord/625774284823986183?color=5865f2&label=Discord&logo=discord&logoColor=fff&style=flat-square)](https://azuriom.com/discord)
+
+AzLink-Oxide is an [Oxide](https://umod.org/games) (uMod) plugin to link a Rust or 7 Days to Die server with Azuriom.
+
+## Download
+
+You can download the plugin on [Azuriom's website](https://azuriom.com/azlink) or in the [GitHub releases](https://github.com/Azuriom/AzLink-Oxide/releases).