OldThink/Content.Server/SensorMonitoring/SensorMonitoringConsoleComponent.cs

using Content.Shared.SensorMonitoring;
using Robust.Server.Player;
using Robust.Shared.Collections;
using Robust.Shared.Players;

namespace Content.Server.SensorMonitoring;

[RegisterComponent]
public sealed partial class SensorMonitoringConsoleComponent : Component
{
    /// <summary>
    /// Used to assign network IDs for sensors and sensor streams.
    /// </summary>
    public int IdCounter;

    /// <summary>
    /// If enabled, additional data streams are shown intended to only be visible for debugging.
    /// </summary>
    [ViewVariables(VVAccess.ReadWrite)]
    [DataField("debugStreams")]
    public bool DebugStreams = false;

    [ViewVariables(VVAccess.ReadWrite)]
    public Dictionary<EntityUid, SensorData> Sensors = new();

    [DataField("retentionTime")]
    public TimeSpan RetentionTime = TimeSpan.FromMinutes(1);

    // UI update tracking stuff.
    public HashSet<ICommonSession> InitialUIStateSent = new();
    public TimeSpan LastUIUpdate;
    public ValueList<int> RemovedSensors;

    public sealed class SensorData
    {
        [ViewVariables(VVAccess.ReadWrite)]
        public int NetId;

        [ViewVariables(VVAccess.ReadWrite)]
        public SensorDeviceType DeviceType;

        [ViewVariables(VVAccess.ReadWrite)]
        public Dictionary<string, SensorStream> Streams = new();
    }

    public sealed class SensorStream
    {
        [ViewVariables(VVAccess.ReadWrite)]
        public int NetId;

        [ViewVariables(VVAccess.ReadWrite)]
        public SensorUnit Unit;

        // Queue<T> is a ring buffer internally, and we can still iterate over it.
        // I don't wanna write a ring buffer myself, so this is pretty convenient!
        [ViewVariables]
        public Queue<SensorSample> Samples = new();
    }

    public sealed class ViewingPlayer
    {

    }
}