// This Source Code is in the Public Domain per: http://litesoft.org/License.txt
package org.litesoft.peertopeer.nonpublic.server;

import java.io.*;
import java.net.*;

import org.litesoft.commonfoundation.typeutils.*;
import org.litesoft.logger.*;
import org.litesoft.peertopeer.nonpublic.peermanagement.*;

public class PeerServer implements P2PConstants
{
    public static final Logger LOGGER = LoggerFactory.getLogger( PeerServer.class );

    private ServerSocket mServerSocket = null;

    public InetAddress getOurServerAddress()
            throws IOException
    {
        return InetAddress.getLocalHost();
    }

    public int getOurServerPort()
            throws IOException
    {
        return getSocket().getLocalPort();
    }

    private synchronized ServerSocket getSocket()
            throws IOException
    {
        for ( int i = BASE_SERVER_PORT; mServerSocket == null; i++ )
        {
            try
            {
                mServerSocket = new ServerSocket( i );
            }
            catch ( BindException e )
            {
                // Expected...
            }
        }
        return mServerSocket;
    }

    public void start( PeerConnectionHandlerFactory pConnectionHandlerFactory )
    {
        Objects.assertNotNull( "PeerConnectionHandlerFactory", pConnectionHandlerFactory );

        OurServer zServer = new OurServer( getClass().getName(), pConnectionHandlerFactory );
        zServer.start();
        zServer.waitForRunning();
    }

    private class OurServer extends Thread
    {
        private final PeerConnectionHandlerFactory mConnectionHandlerFactory;

        public OurServer( String pName, PeerConnectionHandlerFactory pConnectionHandlerFactory )
        {
            super( pName );
            mConnectionHandlerFactory = pConnectionHandlerFactory;
            setDaemon( true );
        }

        public synchronized void waitForRunning()
        {
            while ( !mRunning )
            {
                try
                {
                    wait();
                }
                catch ( InterruptedException e )
                {
                    // Whatever...
                }
            }
        }

        private boolean mRunning = false;

        private synchronized void notifyRunning()
        {
            mRunning = true;
            notifyAll();
        }

        @Override
        public void run()
        {
            notifyRunning();
            System.out.println( "Accepting Peer connections on port: " + mServerSocket.getLocalPort() );
            //noinspection InfiniteLoopStatement
            while ( true )
            {
                try
                {
                    Socket zSocket = mServerSocket.accept();
                    mConnectionHandlerFactory.handleNewConnectionWithPossiblePeer( zSocket );
                }
                catch ( IOException e )
                {
                    LOGGER.error.log( e );
                }
            }
        }
    }
}