// This Source Code is in the Public Domain per: http://unlicense.org
package org.litesoft.GWT.eventbus.client.nonpublic;

import org.litesoft.GWT.client.*;
import org.litesoft.GWT.eventbus.client.*;
import org.litesoft.GWT.eventbus.client.rpc.*;
import org.litesoft.logger.*;

import com.google.gwt.user.client.*;

public class ClientEventBus extends AbstractPeerSupportingEventBus
{
    public ClientEventBus( int pClientIdNumber )
    {
        super( "Client", pClientIdNumber, TimedRunnableManager.INSTANCE,
               AlertUnexpectedEventPackageHandler.INSTANCE );
    }

    public void initialize( ChannelServiceAsync pChannelServiceAsync, int pPollSecs, Logger pLogger )
    {
        if ( pLogger == null )
        {
            pLogger = createLogger();
        }
        ClientSideRemotePeerService zPeerService = new ClientSideRemotePeerService( this, //
                                                                                    pChannelServiceAsync, //
                                                                                    pPollSecs );
        initialize( pLogger, new StatePeerSupportingEventBusSuspended( pLogger, this, zPeerService ) );
    }

    public void release()
    {
        switchFromSuspendedToRegular().releaseCollected();
    }

    public void pollNow()
    {
        /*
         * Deferred execution. Works around a Safari bug where calling from a
         * nested iframe somehow corrupts the RPC endpoint url. (It's not so
         * much the delay as the context that this is called from).
         */
        DeferredCommand.addCommand( new Command()
        {
            public void execute()
            {
                publish( PingEventPackage.INSTANCE );
            }
        } );
    }

    // todo: Client -> Server of Exception 'e':  mEventBus.getTypeNameOf(e), + ":" + e.getMessage()
}