package christie.daemon;

import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.nio.channels.ServerSocketChannel;

public class ChristieDaemon {

    private int localPort;
    private AcceptThread acceptThread;
    public CodeGearManager cgm;

    public ChristieDaemon(int localPort, CodeGearManager cgm) {
        this.localPort = localPort;
        this.cgm = cgm;
    }

    public void listen() {
        try {
            ServerSocketChannel ssChannel = ServerSocketChannel.open();
            ServerSocket ss = ssChannel.socket();
            ss.setReuseAddress(true);

            // listen on any address ipv4/ipv6
            InetSocketAddress a = new InetSocketAddress("::", localPort);

            System.out.println("ChristieDaemon.listen: bind to " + a);
            ss.bind(a);
            acceptThread = new AcceptThread(ss, "ACCEPT" + localPort, cgm);
            acceptThread.start();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}