Merge pull request #143 from daud-io/firebase

Firebase
daud-io · Mar 3, 2019 · 20f4d11 · 20f4d11
2 parents d65f0d3 + 08725b8
commit 20f4d11
Show file tree

Hide file tree

Showing 13 changed files with 140 additions and 17 deletions.
diff --git a/Game.Engine/Auditing/AuditEventBase.cs b/Game.Engine/Auditing/AuditEventBase.cs
@@ -0,0 +1,9 @@
+namespace Game.Engine.Auditing
+{
+    public class AuditEventBase
+    {
+        public string Type { get => this.GetType().Name; }
+        public string PublicURL { get; set; }
+        public string WorldKey { get; set; }
+    }
+}
diff --git a/Game.Engine/Auditing/AuditEventDeath.cs b/Game.Engine/Auditing/AuditEventDeath.cs
@@ -0,0 +1,21 @@
+namespace Game.Engine.Auditing
+{
+    using Game.Engine.Core;
+
+    public class AuditEventDeath : AuditEventBase
+    {
+        public long GameTime { get; set; }
+        public AuditModelPlayer Killer { get; set; }
+        public AuditModelPlayer Victim { get; set; }
+
+        public AuditEventDeath(Player killer, Player victim, Fleet fleet)
+        {
+            GameTime = fleet?.World.Time ?? 0;
+            PublicURL = fleet?.World?.GameConfiguration?.PublicURL;
+            WorldKey = fleet?.World?.WorldKey;
+
+            Killer = new AuditModelPlayer(killer);
+            Victim = new AuditModelPlayer(victim);
+        }
+    }
+}
diff --git a/Game.Engine/Auditing/AuditEventSpawn.cs b/Game.Engine/Auditing/AuditEventSpawn.cs
@@ -0,0 +1,18 @@
+namespace Game.Engine.Auditing
+{
+    using Game.Engine.Core;
+
+    public class AuditEventSpawn : AuditEventBase
+    {
+        public long GameTime { get; set; }
+        public AuditModelPlayer Player { get; set; }
+
+        public AuditEventSpawn(Player player)
+        {
+            GameTime = player?.World?.Time ?? 0;
+            PublicURL = player?.World?.GameConfiguration?.PublicURL;
+            WorldKey = player?.World?.WorldKey;
+            Player = new AuditModelPlayer(player);
+        }
+    }
+}
diff --git a/Game.Engine/Auditing/AuditModelPlayer.cs b/Game.Engine/Auditing/AuditModelPlayer.cs
@@ -0,0 +1,33 @@
+namespace Game.Engine.Auditing
+{
+    using Game.Engine.Core;
+
+    public class AuditModelPlayer
+    {
+        public ulong LoginID { get; }
+        public string LoginName { get; set; }
+        public uint FleetID { get; set; }
+        public string FleetName { get; set; }
+        public int FleetSize { get; set; }
+        public int Score { get; set; }
+        public long AliveSince { get; set; }
+        public int ComboCounter { get; set; }
+        public uint Latency { get; set; }
+
+        public AuditModelPlayer(Player player)
+        {
+            if (player == null)
+                return;
+
+            this.LoginID = player.LoginID;
+            this.LoginName = player.LoginName;
+            this.FleetID = player.Fleet?.ID ?? 0;
+            this.FleetName = player.Name;
+            this.FleetSize = player.Fleet?.Ships?.Count ?? 0;
+            this.Score = player.Score;
+            this.AliveSince = player.AliveSince;
+            this.ComboCounter = player.ComboCounter;
+            this.Latency = player.Connection?.Latency ?? 0;
+        }
+    }
+}
diff --git a/Game.Engine/Auditing/OnDeath.cs b/Game.Engine/Auditing/OnDeath.cs
@@ -0,0 +1,11 @@
+namespace Game.Engine.Auditing
+{
+    public class OnDeath
+    {
+#pragma warning disable IDE1006 // Naming Styles
+        public string token { get; set; }
+        public string name { get; set; }
+        public string killedBy { get; set; }
+#pragma warning restore IDE1006 // Naming Styles
+    }
+}
diff --git a/Game.Engine/Auditing/RemoteEventLog.cs b/Game.Engine/Auditing/RemoteEventLog.cs
@@ -1,5 +1,7 @@
-namespace Game.Engine.Core.Auditing
+namespace Game.Engine.Auditing
 {
+    using Firebase.Database;
+    using Newtonsoft.Json;
     using System;
     using System.Collections.Generic;
     using System.Net.Http;
@@ -8,22 +10,38 @@
 
     public static class RemoteEventLog
     {
-        private static readonly Timer Heartbeat = null;
+        private static Timer Heartbeat = null;
         private static readonly HttpClient HttpClient = new HttpClient();
-        private static readonly Queue<object> queue = new Queue<object>();
+        private static Queue<object> queue = new Queue<object>();
         private static readonly int POST_TIMER_MS = 1000;
+        private static FirebaseClient Firebase;
+        private static GameConfiguration GameConfiguration;
+        private static bool Initialized = false;
 
-        static RemoteEventLog()
+        public static void Initialize(GameConfiguration gameConfiguration)
         {
+            GameConfiguration = gameConfiguration;
+
             Heartbeat = new Timer((state) =>
             {
                 PostData().Wait();
             }, null, 0, POST_TIMER_MS);
+
+
+            if (gameConfiguration.FirebaseAuthKey != null)
+                Firebase = new FirebaseClient(
+                    gameConfiguration.FirebaseUrl,
+                    new FirebaseOptions
+                    {
+                        AuthTokenAsyncFactory = () => Task.FromResult(gameConfiguration.FirebaseAuthKey)
+                    });
+            Initialized = true;
         }
 
         public static void SendEvent(object message)
         {
-            queue.Enqueue(message);
+            if (Initialized)
+                queue.Enqueue(message);
         }
 
         private async static Task PostData()
@@ -33,16 +51,15 @@ private async static Task PostData()
                 while (queue.Count > 0)
                 {
                     var message = queue.Dequeue();
-
-                    var response = await HttpClient.PostAsJsonAsync("https://daud-discord.glitch.me/", message);
-
-                    if (response.IsSuccessStatusCode)
+                    if (message is OnDeath)
                     {
-                        // cool
+                        if (GameConfiguration.DuelBotURL != null)
+                            await HttpClient.PostAsJsonAsync(GameConfiguration.DuelBotURL, message);
                     }
                     else
                     {
-                        //
+                        if (Firebase != null)
+                            await Firebase.Child("events").PostAsync(JsonConvert.SerializeObject(message));
                     }
                 }
             }

diff --git a/Game.Engine/Core/Player.cs b/Game.Engine/Core/Player.cs
@@ -2,7 +2,7 @@
 {
     using Game.API.Common;
     using Game.API.Common.Models;
-    using Game.Engine.Core.Auditing;
+    using Game.Engine.Auditing;
     using Game.Engine.Core.Weapons;
     using Game.Engine.Networking;
     using Newtonsoft.Json;
@@ -14,8 +14,6 @@
 
     public class Player : IActor
     {
-        private static readonly HttpClient HttpClient = new HttpClient();
-
         public World World = null;
         public Fleet Fleet = null;
 
@@ -96,6 +94,8 @@ public virtual void CreateDestroy()
                 Fleet.SpawnLocation = SpawnLocation;
                 Fleet.Init(World);
 
+                RemoteEventLog.SendEvent(new AuditEventSpawn(this));
+
                 if (World.Hook.GearheadName != null && this.Name == World.Hook.GearheadName)
                 {
                     Fleet.BaseWeapon = new FleetWeaponRobot();
@@ -149,6 +149,7 @@ public void Init(World world)
         }
 
         public string Name { get; set; }
+        public ulong LoginID { get; set; }
 
         public static List<Player> GetTeam(World world, string color)
         {
@@ -301,7 +302,7 @@ protected virtual void OnDeath(Player player = null)
                 Connection.SpectatingFleet = player.Fleet;
 
             if (!string.IsNullOrEmpty(this.Token) && !string.IsNullOrEmpty(player?.Token))
-                RemoteEventLog.SendEvent(new
+                RemoteEventLog.SendEvent(new OnDeath
                 {
                     token = this.Token,
                     name = this.Name,

diff --git a/Game.Engine/Core/Scoring/DefaultScoring.cs b/Game.Engine/Core/Scoring/DefaultScoring.cs
@@ -117,6 +117,8 @@ public override void FleetDied(Player killer, Player victim, Fleet fleet)
                     victim.MaxCombo = 0;
                 }
             }
+
+            base.FleetDied(killer, victim, fleet);
         }
     }
 }
diff --git a/Game.Engine/Core/Scoring/ScoringBase.cs b/Game.Engine/Core/Scoring/ScoringBase.cs
@@ -1,4 +1,6 @@
-namespace Game.Engine.Core.Scoring
+using Game.Engine.Auditing;
+
+namespace Game.Engine.Core.Scoring
 {
     public abstract class ScoringBase
     {
@@ -9,7 +11,7 @@ public virtual void ShipDied(Player killer, Player victim, Ship ship)
 
         public virtual void FleetDied(Player killer, Player victim, Fleet fleet)
         {
-
+            RemoteEventLog.SendEvent(new AuditEventDeath(killer, victim, fleet));
         }
     }
 }
diff --git a/Game.Engine/Core/SystemActors/Authenticator.cs b/Game.Engine/Core/SystemActors/Authenticator.cs
@@ -46,6 +46,7 @@ protected override void CycleThink()
                                     }
 
                                     player.LoginName = user.Nickname;
+                                    player.LoginID = user.Id;
                                     player.Roles = playerRoles;
                                     player.OnAuthenticated();
                                 }

diff --git a/Game.Engine/Game.Engine.csproj b/Game.Engine/Game.Engine.csproj
@@ -8,6 +8,7 @@
   <ItemGroup>
     <PackageReference Include="ACMESharpCore" Version="2.0.0.49-beta1" />
     <PackageReference Include="Docker.DotNet" Version="3.125.2" />
+    <PackageReference Include="FirebaseDatabase.net" Version="4.0.1" />
     <PackageReference Include="KdSoft.FlatBuffers" Version="1.9.3" />
     <PackageReference Include="Nito.AsyncEx" Version="5.0.0-pre-05" />
     <PackageReference Include="RBush" Version="2.0.31" />

diff --git a/Game.Engine/GameConfiguration.cs b/Game.Engine/GameConfiguration.cs
@@ -25,5 +25,10 @@ public class GameConfiguration
         public bool LetsEncryptEnabled { get; set; }
 
         public string PublicURL { get; set; }
+
+        public string FirebaseAuthKey { get; set; }
+        public string FirebaseUrl { get; set; }
+
+        public string DuelBotURL { get; set; } = "https://daud-discord.glitch.me/";
     }
 }
diff --git a/Game.Engine/Startup.cs b/Game.Engine/Startup.cs
@@ -5,6 +5,7 @@
     using Game.API.Authentication;
     using Game.API.Client;
     using Game.API.Common.Security;
+    using Game.Engine.Auditing;
     using Game.Engine.Authentication;
     using Game.Engine.ChatBot;
     using Game.Engine.Core;
@@ -121,6 +122,7 @@ GameConfiguration config
             });
             app.UseGameWebsocketHandler();
 
+            RemoteEventLog.Initialize(config);
             Worlds.Initialize(config);
 
             if (config.RegistryEnabled)
-Original file line number
+Diff line change
@@ Expand Up @@
                         victim.MaxCombo = 0;
                     }
                 }
+                base.FleetDied(killer, victim, fleet);
             }
         }
     }