using System;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Threading.Tasks;
using Christie_net.codegear;

namespace Christie_net.daemon {
public class AcceptThread {
    private TcpListener listener;
    public int counter = 0;
    public CodeGearManager cgm;

    public AcceptThread(TcpListener listener, CodeGearManager cgm) {
        this.listener = listener;
        this.cgm = cgm;
    }

    public void Run() {
        while (true) {
            try {
                TcpClient client = null;
                client = listener.AcceptTcpClient();
                client.NoDelay = true;

                IPEndPoint endPoint = (IPEndPoint) client.Client.RemoteEndPoint;
                IPAddress ipAddress = endPoint.Address;
                IPHostEntry hostEntry = Dns.GetHostEntry(ipAddress);
                Console.WriteLine("Accept " + hostEntry.HostName + ":" + endPoint.Port);

                Connection connection = new Connection(client.Client, cgm);
                Console.WriteLine("connection:" + connection.GetInfoString());
                string key = "accept" + counter;

                IncomingTcpConnection incoming = new IncomingTcpConnection(connection);
                Task.Factory.StartNew(() => incoming.Run());

                cgm.SetAccept(key, incoming);

                OutboundTcpConnection outbound = new OutboundTcpConnection(connection);
                Task.Factory.StartNew(() => outbound.Run());
                counter++;
            } catch (Exception e) {
                Console.WriteLine(e.StackTrace);
            }
        }
    }
}
}