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() {
        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);
        }
    }
}
}