Suit sensor and crew monitoring (#5521)

Co-authored-by: Paul Ritter <ritter.paul1@googlemail.com>
Co-authored-by: metalgearsloth <comedian_vs_clown@hotmail.com>

Content.Server/Medical/CrewMonitoring/CrewMonitoringConsoleSystem.cs

@@ -0,0 +1,89 @@
+using System.Linq;
+using Content.Server.DeviceNetwork.Systems;
+using Content.Server.Medical.SuitSensors;
+using Content.Server.UserInterface;
+using Content.Shared.Medical.CrewMonitoring;
+using Robust.Shared.GameObjects;
+using Robust.Shared.IoC;
+using Robust.Shared.Timing;
+
+namespace Content.Server.Medical.CrewMonitoring
+{
+    public class CrewMonitoringConsoleSystem : EntitySystem
+    {
+        [Dependency] private readonly SuitSensorSystem _sensors = default!;
+        [Dependency] private readonly IGameTiming _gameTiming = default!;
+
+        private const float UpdateRate = 3f;
+        private float _updateDif;
+
+        public override void Initialize()
+        {
+            base.Initialize();
+            SubscribeLocalEvent<CrewMonitoringConsoleComponent, ComponentRemove>(OnRemove);
+            SubscribeLocalEvent<CrewMonitoringConsoleComponent, PacketSentEvent>(OnPacketReceived);
+        }
+
+        public override void Update(float frameTime)
+        {
+            base.Update(frameTime);
+
+            // check update rate
+            _updateDif += frameTime;
+            if (_updateDif < UpdateRate)
+                return;
+            _updateDif = 0f;
+
+            var consoles = EntityManager.EntityQuery<CrewMonitoringConsoleComponent>();
+            foreach (var console in consoles)
+            {
+                UpdateTimeouts(console.Owner, console);
+                UpdateUserInterface(console.Owner, console);
+            }
+        }
+
+        private void OnRemove(EntityUid uid, CrewMonitoringConsoleComponent component, ComponentRemove args)
+        {
+            component.ConnectedSensors.Clear();
+        }
+
+        private void OnPacketReceived(EntityUid uid, CrewMonitoringConsoleComponent component, PacketSentEvent args)
+        {
+            var suitSensor = _sensors.PacketToSuitSensor(args.Data);
+            if (suitSensor == null)
+                return;
+
+            suitSensor.Timestamp = _gameTiming.CurTime;
+            component.ConnectedSensors[args.SenderAddress] = suitSensor;
+        }
+
+        private void UpdateUserInterface(EntityUid uid, CrewMonitoringConsoleComponent? component = null)
+        {
+            if (!Resolve(uid, ref component))
+                return;
+
+            var ui = component.Owner.GetUIOrNull(CrewMonitoringUIKey.Key);
+            if (ui == null)
+                return;
+
+            // update all sensors info
+            var allSensors = component.ConnectedSensors.Values.ToList();
+            var uiState = new CrewMonitoringState(allSensors);
+            ui.SetState(uiState);
+        }
+
+        private void UpdateTimeouts(EntityUid uid, CrewMonitoringConsoleComponent? component = null)
+        {
+            if (!Resolve(uid, ref component))
+                return;
+
+            foreach (var (address, sensor) in component.ConnectedSensors)
+            {
+                // if too many time passed - sensor just dropped connection
+                var dif = _gameTiming.CurTime - sensor.Timestamp;
+                if (dif.Seconds > component.SensorTimeout)
+                    component.ConnectedSensors.Remove(address);
+            }
+        }
+    }
+}