using System;
using System.Threading;
using NetworkCommsDotNet;
using NetworkCommsDotNet.Connections;
using NetworkCommsDotNet.Connections.TCP;
using NetworkCommsDotNet.DPSBase;
using NetworkCommsDotNet.DPSBase.SevenZipLZMACompressor;
using NLog;
using P2PES.Slave.Properties;

namespace P2PES.Slave {
    internal class Program {
        private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
        private static TCPConnection _client;

        private static void Main(string[] args) {
            NetworkComms.DefaultSendReceiveOptions = new SendReceiveOptions<ProtobufSerializer, LZMACompressor>();
            NetworkComms.AppendGlobalConnectionEstablishHandler(HandleConnectionEstablish);
            NetworkComms.AppendGlobalConnectionCloseHandler(HandleConnectionShutdown);
            NetworkComms.AppendGlobalIncomingPacketHandler<string>("Ping", HandleIncomingPing);

            ConnectToServer();

            Logger.Info("Press any key to close client...");
            Console.ReadKey(true);
        }

        private static void HandleIncomingPing(PacketHeader packetheader, Connection connection, string incomingobject) {
            Logger.Info("Recieved Ping from server...");
        }

        private static void ConnectToServer() {
            try {
                var connectionInfo = new ConnectionInfo(Settings.Default.ServerAddress, Settings.Default.ServerPort);
                _client = TCPConnection.GetConnection(connectionInfo);
            }
            catch { /* Might be a false positive. */ }
        }

        private static void HandleConnectionShutdown(Connection connection) {
            Logger.Error("Connection Lost...");

            ConnectToServer();
        }

        private static void HandleConnectionEstablish(Connection connection) {
            Logger.Info("Connection Established...");
        }
    }
}