using ColorControl.Shared.Contracts;
using Newtonsoft.Json;
using System.IO.Pipes;
using System.Security.Principal;

namespace ColorControl.Shared.Common
{
    public static class PipeUtils
    {
        private static readonly NLog.Logger Logger = NLog.LogManager.GetCurrentClassLogger();

        public static string SendMessage(string message, int timeout = 2000)
        {
            var pipeClient = new NamedPipeClientStream(".", "testpipe", PipeDirection.InOut, PipeOptions.None, TokenImpersonationLevel.None);
            try
            {
                pipeClient.Connect(timeout);
                try
                {
                    var ss = new StreamString(pipeClient);

                    ss.WriteString(message);

                    var result = ss.ReadString();

                    return result;
                }
                finally
                {
                    pipeClient.Close();
                }
            }
            catch (Exception ex)
            {
                Logger.Error(ex, "PipeUtils.SendMessage");

                return null;
            }
        }

        public static SvcResultMessage SendMessage(SvcMessage message, int timeout = 2000)
        {
            var messageJson = JsonConvert.SerializeObject(message);

            var resultJson = SendMessage(messageJson, timeout);

            if (resultJson == null)
            {
                return null;
            }

            var resultMessage = JsonConvert.DeserializeObject<SvcResultMessage>(resultJson);

            return resultMessage;
        }

        public static SvcResultMessage SendMessage(SvcMessageType messageType)
        {
            var message = new SvcMessage { MessageType = messageType };

            return SendMessage(message);
        }

        public static bool? SendRpcMessage(string command)
        {
            var message = new SvcMessage { MessageType = SvcMessageType.ExecuteRpc, Data = command };

            var messageJson = JsonConvert.SerializeObject(message);

            var resultJson = SendMessage(messageJson);

            if (resultJson == null)
            {
                return null;
            }

            var resultMessage = JsonConvert.DeserializeObject<SvcResultMessage>(resultJson);

            return resultMessage.Result;
        }
    }
}