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

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

/**
 * 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( ClassName.simple( 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;
    }
}