package org.litesoft.GWT.eventbus.client;

import org.litesoft.GWT.eventbus.client.nonpublic.*;
import org.litesoft.core.delayed.*;
import org.litesoft.core.util.*;

/**
 * A simple, non-distributed implementation of an event bus.
 */
public abstract class AbstractSimpleEventBus extends EventBus
{
    protected final SubscriptionManager mSubscriptionManager;

    protected AbstractSimpleEventBus( TimedRunner pTimedRunner,
                                      UnexpectedEventPackageHandler pUnexpectedHandler )
    {
        super( "Simple", 0, pTimedRunner, pUnexpectedHandler );
        mSubscriptionManager = new SubscriptionManager( getForm() );
    }

    protected void LLdispose( String pWhy )
    {
        mSubscriptionManager.clear();
        super.LLdispose( pWhy );
    }

    protected void LLpublishNonNullNotDisposedExpectingResponse( EventPackage pPackage )
    {
        String sourceName = pPackage.getSourceName();
        if ( null == mSubscriptionManager.getListenersFor( sourceName ) )
        {
            throw new IllegalArgumentException(
                    "No Subscribers for '" + sourceName + "' in Event: " + pPackage );
        }
        LLpublish( pPackage );
    }

    protected synchronized void LLsubscribeAndPublish( EventSubscriptionStructure[] pSubscriptions,
                                                       EventPackage[] pPackages )
    {
        for ( int i = 0; i < pSubscriptions.length; i++ )
        {
            EventSubscriptionStructure structure = pSubscriptions[i];
            if ( structure != null )
            {
                mSubscriptionManager.subscribe( structure.getSubscribeWith(), structure.getEventListener() );
            }
        }
        for ( int i = 0; i < pPackages.length; i++ )
        {
            EventPackage eventPackage = pPackages[i];
            if ( eventPackage != null )
            {
                LLpublish( eventPackage );
            }
        }
    }

    private void LLpublish( EventPackage pPackage )
    {
        EventPackageListener[] listeners = mSubscriptionManager.getListenersFor( pPackage.getTargetName() );
        if ( listeners != null )
        {
            //noinspection ForLoopReplaceableByForEach
            for ( int i = 0; i < listeners.length; i++ )
            {
                EventPackageListener zListener = listeners[i];
                try
                {
                    zListener.packageReceivedVia( pPackage, this );
                }
                catch ( RuntimeException e )
                {
                    handleUnexpectedException( UtilsCommon.justClassNameOf( zListener ), e );
                }
            }
        }
    }

    protected synchronized void LLunsubscribe( EventSubscriptionStructure[] pSubscriptions )
    {
        for ( int i = 0; i < pSubscriptions.length; i++ )
        {
            EventSubscriptionStructure structure = pSubscriptions[i];
            if ( structure != null )
            {
                mSubscriptionManager.unsubscribe( structure.getSubscribeWith(),
                                                  structure.getEventListener() );
            }
        }
    }

    public EventBus getEventBus( int pClientIdNumber )
    {
        return this;
    }
}