using TIBCO.Rendezvous;
 
namespace TIBRVSender
{
    internal class Program
    {
        private static Transport? _transport;
 
        private static string _daemonAddress = string.Empty;    // Remote의 daemon을 쓴다면 주소 정해줌, 로컬이면 tcp 입력
        private static int _daemonPort = 0;     // Remote의 daemon을 쓴다면 정해줌, 로컬이면 7500 (Auto-Start)
 
        // Demo params
        private static List<string> _demoSubjects = new();
        private static List<string> _demoFields = new();
 
        static void Main(string[] args)
        {
            SetupDemo();
 
            Console.WriteLine("Connect to daemon");
 
            if (Connect()) Console.WriteLine("Ready to send");
            else
            {
                Console.WriteLine("Failed to connect");
                return;
            }
 
            while (true)
            {
                Console.WriteLine("Input X to exit");
                Console.WriteLine("Input demo message");
                var sendMessage = Console.ReadLine();
                if (!string.IsNullOrWhiteSpace(sendMessage))
                {
                    if (sendMessage.ToUpper() == "X")
                    {
                        Disconnect();
                        return;
                    }
                    else
                    {
                        SendMessage(sendMessage);
                    }
                }
            }
        }
 
        static bool Connect()
        {
            TIBCO.Rendezvous.Environment.Open();
 
            // Check connect
            try
            {
                _transport = new NetTransport(":0", ";", $"{_daemonAddress}:{_daemonPort}");
            }
            catch (RendezvousException e)
            {
                Console.WriteLine($"Create transport error - {e.Message}");
                return false;
            }
            return true;
        }
 
        static bool Disconnect()
        {
            _transport?.Destroy();
            _transport = null;
            TIBCO.Rendezvous.Environment.Close();
            Console.WriteLine("Disconnected");
            return true;
        }
 
        static void SendMessage(string sendMessage)
        {
            foreach (var subject in _demoSubjects)
            {
                Message message = new();
                message.SendSubject = subject;
                foreach (var field in _demoFields) message.AddField(field, sendMessage);
 
                try
                {
                    _transport?.Send(message);
                    Console.WriteLine($"TIBRV Send - Subject : {message.SendSubject}");
                    Console.WriteLine($"TIBRV Send - message : {message}");
                }
                catch (RendezvousException e)
                {
                    Console.WriteLine($"Failed to send a message - {e.Message}");
                }
            }
        }
 
        static void SetupDemo()
        {
            _daemonAddress = "tcp";
            _daemonPort = 7500;
 
            for (int i = 0; i < 3; i++)
            {
                _demoSubjects.Add($"Demo{i}");
                _demoFields.Add($"Field{i}");
            }
        }
    }
}