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

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

import org.litesoft.peertopeer.nonpublic.*;
import org.litesoft.peertopeer.nonpublic.broadcastdiscovery.*;
import org.litesoft.peertopeer.nonpublic.peermanagement.*;
import org.litesoft.peertopeer.nonpublic.server.*;
import org.litesoft.util.*;

public class PeerManager
{
    public PeerManager( String pOurName, String pAppGroupID, String pAppGroupVersion, AppGroupVersionCompatibilityChecker pCompatibilityChecker )
    {
        if ( pOurName == null )
        {
            pOurName = Utils.getLocalHostName();
        }
        mBroadcastMessageManager = new BroadcastMessageManager( pOurName, pAppGroupID, pAppGroupVersion, //
                                                                pCompatibilityChecker );
    }

    /**
     * Adds the specified Handler.
     * If pHandler is not null and not already in the list, then it returns 'true', otherwise 'false'.
     *
     * @return <tt>true</tt> if added.
     */
    public boolean addHandler( MessageFromPeerHandler pHandler )
    {
        return mHandlerManager.addHandler( pHandler );
    }

    /**
     * Removes the specified Handler.
     * If pHandler is not null and currently in the list, then it returns 'true', otherwise 'false'.
     *
     * @return <tt>true</tt> if removed.
     */
    public boolean removeHandler( MessageFromPeerHandler pHandler )
    {
        return mHandlerManager.removeHandler( pHandler );
    }

    public synchronized PeerManager start( boolean pOKtoRunIfIncompatibleVersionAlreadyRunning )
            throws IOException
    {
        mBroadcastMessageManager.assert_joinGroup_notCalled();

        mConnectionManager = new PeerConnectionManager( mHandlerManager, this, pOKtoRunIfIncompatibleVersionAlreadyRunning );
        PeerConnectionHandlerFactory zHandlerFactory = new PeerConnectionHandlerFactory( mConnectionManager );
        PeerServer zPeerServer = new PeerServer();

        String zOurName = mBroadcastMessageManager.getOurName();
        InetAddress zOurServerAddress = zPeerServer.getOurServerAddress();
        int zOurServerPort = zPeerServer.getOurServerPort();

        mConnectionManager.setOurConnectionInfo( zOurName, zOurServerAddress, zOurServerPort );

        zPeerServer.start( zHandlerFactory );

        mConnectionManager.aboutToJoinGroup();
        mBroadcastMessageManager.joinGroup( zOurServerPort, zHandlerFactory );
        mConnectionManager.waitForPeers();
        return this;
    }

    public synchronized void sendToPeers( Serializable pMessageToPeers )
    {
        if ( mConnectionManager != null )
        {
            mConnectionManager.sendToPeers( pMessageToPeers );
        }
    }

    private final BroadcastMessageManager mBroadcastMessageManager;
    private PeerConnectionManager mConnectionManager = null;
    private final MessageFromPeerHandlerManager mHandlerManager = new MessageFromPeerHandlerManager();
}