TopicParameters.cs

Go to the documentation of this file.

using System;
 
using Newtonsoft.Json;
 
using Tgstation.Server.Host.Components.Session;
 
namespace Tgstation.Server.Host.Components.Interop.Topic
{
    class TopicParameters : DMApiParameters
    {
        public TopicCommandType? CommandType { get; }
 
        public ChatCommand? ChatCommand { get; }
 
        public EventNotification? EventNotification { get; }
 
        public ushort? NewPort { get; }
 
        public RebootState? NewRebootState { get; }
 
        public string? NewInstanceName { get; }
 
        public string? BroadcastMessage { get; }
 
        public ChatUpdate? ChatUpdate { get; }
 
        public Version? NewServerVersion { get; }
 
        public ChunkData? Chunk { get; }
 
        public string? EventId { get; set; }
 
        [JsonIgnore]
        public bool IsPriority => CommandType switch
        {
            TopicCommandType.EventNotification
            or TopicCommandType.ChangePort
            or TopicCommandType.ChangeRebootState
            or TopicCommandType.InstanceRenamed
            or TopicCommandType.ChatChannelsUpdate
            or TopicCommandType.Broadcast
            or TopicCommandType.CompleteEvent
            or TopicCommandType.ServerRestarted => true,
            TopicCommandType.ChatCommand
            or TopicCommandType.HealthCheck
            or TopicCommandType.ReceiveChunk => false,
            TopicCommandType.SendChunk => throw new InvalidOperationException("SendChunk topic priority should be based on the original TopicParameters!"),
            _ => throw new InvalidOperationException($"Invalid value for {nameof(CommandType)}: {CommandType}"),
        };
 
        public static TopicParameters CreateInstanceRenamedTopicParameters(string newInstanceName)
            => new(
                newInstanceName ?? throw new ArgumentNullException(nameof(newInstanceName)),
                TopicCommandType.InstanceRenamed);
 
        public static TopicParameters CreateBroadcastParameters(string broadcastMessage)
            => new(
                broadcastMessage ?? throw new ArgumentNullException(nameof(broadcastMessage)),
                TopicCommandType.Broadcast);
 
        public TopicParameters(ChatCommand chatCommand)
            : this(TopicCommandType.ChatCommand)
        {
            ChatCommand = chatCommand ?? throw new ArgumentNullException(nameof(chatCommand));
        }
 
        public TopicParameters(EventNotification eventNotification)
            : this(TopicCommandType.EventNotification)
        {
            EventNotification = eventNotification ?? throw new ArgumentNullException(nameof(eventNotification));
        }
 
        public TopicParameters(ushort newPort)
            : this(TopicCommandType.ChangePort)
        {
            NewPort = newPort;
        }
 
        public TopicParameters(RebootState newRebootState)
            : this(TopicCommandType.ChangeRebootState)
        {
            NewRebootState = newRebootState;
        }
 
        public TopicParameters(ChatUpdate channelsUpdate)
            : this(TopicCommandType.ChatChannelsUpdate)
        {
            ChatUpdate = channelsUpdate ?? throw new ArgumentNullException(nameof(channelsUpdate));
        }
 
        public TopicParameters(Version newServerVersion, ushort serverPort)
            : this(TopicCommandType.ServerRestarted)
        {
            NewServerVersion = newServerVersion ?? throw new ArgumentNullException(nameof(newServerVersion));
            NewPort = serverPort;
        }
 
        public TopicParameters(ChunkData chunk)
            : this(TopicCommandType.SendChunk)
        {
            Chunk = chunk ?? throw new ArgumentNullException(nameof(chunk));
        }
 
        public TopicParameters(Guid eventId)
            : this(TopicCommandType.CompleteEvent)
        {
            EventId = eventId.ToString();
        }
 
        public TopicParameters()
            : this(TopicCommandType.HealthCheck)
        {
        }
 
        protected TopicParameters(TopicCommandType commandType)
            : base(String.Empty) // access identifier gets set before send
        {
            CommandType = commandType;
        }
 
        TopicParameters(string stringCommand, TopicCommandType stringCommandType)
            : this(stringCommandType)
        {
#pragma warning disable IDE0010 // Add missing cases
            switch (stringCommandType)
            {
                case TopicCommandType.InstanceRenamed:
                    NewInstanceName = stringCommand;
                    break;
                case TopicCommandType.Broadcast:
                    BroadcastMessage = stringCommand;
                    break;
                default:
                    throw new InvalidOperationException($"Invalid string TopicCommandType: {stringCommandType}");
            }
#pragma warning restore IDE0010 // Add missing cases
        }
    }
}