package net.lorichon;

import java.io.IOException;
import java.net.ServerSocket;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.logging.Handler;
import java.util.logging.Level;
import java.util.logging.LogRecord;
import java.util.logging.Logger;

import net.lorichon.client.Client;

/**
 * The main representation of the server. The server takes in packets and sends out packets
 * to all connected clients as well as setting db information and logging stuff.
 * @author Dan
 *
 */
public final class Server {
    public static final int m_maxReceivableBytes = 1024;
    public ConcurrentLinkedQueue<Client> m_connections = new ConcurrentLinkedQueue<Client>();
    private static final Logger log = Logger.getLogger("LorichonServer");
    private static Server m_server;
    private ServerSocket m_serverSocket;
    private boolean m_keepAlive = true;
    public static void handleServerException(String msg) {
        ExceptionManager.handleException(Error.ERROR_SOCKET_CLOSED, msg);
        try {
            m_server.m_serverSocket.close();
            m_server.m_keepAlive = false;
        } catch (IOException e) {}
    }

    public static void main(String[] args) throws IOException {
        log.addHandler(new Handler() {

            @Override
            public void close() throws SecurityException {
            }

            @Override
            public void flush() {
            }

            @Override
            public void publish(LogRecord arg0) {
                System.out.println(arg0.getMessage());
            }});
        log.setUseParentHandlers(false);
        log.info("Starting up server...");


        m_server = new Server();
        m_server.m_serverSocket = new ServerSocket(7464);

        log.info("Accepting connections on 7464...");


        // Main logic loop.
        while(m_server.m_keepAlive) {
            try {
                Client c = new Client(m_server.m_serverSocket.accept());
                ThreadManager.execute(new Client(m_server.m_serverSocket.accept()));
                m_server.m_connections.add(c);
            } catch(Exception e) {} // ignore the exception for adding this.
        }

        m_server.m_serverSocket.close();
        System.exit(0);
    }

    public static void log(Level l, String msg) {
        log.log(l, msg);
    }
}