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

import org.litesoft.GWT.client.*;
import org.litesoft.GWT.eventbus.client.eventpackages.*;
import org.litesoft.GWT.eventbus.client.nonpublic.*;

import java.util.*;

public class DecendantManager {
    private WindowNameClientIdCodec mWindowNameClientIdCodec;

    public DecendantManager( WindowNameClientIdCodec pWindowNameClientIdCodec ) {
        mWindowNameClientIdCodec = pWindowNameClientIdCodec;
    }

    public void addEventListenersForNewClient( EventSubscriptionCollector pCollector ) {
        pCollector.subscribe( new NotificationReDecendantPackageListener() );
        pCollector.subscribe( new CloseDecendantClientsPackageListener() );
    }

    private Set<Integer> mDecendants = new HashSet<Integer>();

    public boolean anyDecendants() {
        return !mDecendants.isEmpty();
    }

    public int decendants() {
        return mDecendants.size();
    }

    private void addDecendant( int pClientId ) {
        //noinspection UnnecessaryBoxing,unchecked
        mDecendants.add( pClientId );
    }

    private void removeDecendant( int pClientId ) {
        mDecendants.remove( pClientId );
    }

    public void closeAllDecendants() {
        //noinspection ForLoopReplaceableByForEach
        for ( Iterator<Integer> it = mDecendants.iterator(); it.hasNext(); ) {
            //noinspection UnnecessaryUnboxing
            closeDecendant( it.next() );
        }
    }

    public void closeDecendant( int pDecendantClientId ) {
        String encodedClientId = ClientIdCodec.encode( pDecendantClientId );
        String name = mWindowNameClientIdCodec.createWindowName( encodedClientId );
        UtilsGwt.closeWindow( name );
    }

    public void decendantToFront( int pDecendantClientId ) {
        String encodedClientId = ClientIdCodec.encode( pDecendantClientId );
        String name = mWindowNameClientIdCodec.createWindowName( encodedClientId );
        UtilsGwt.windowToFront( name );
    }

    private class NotificationReDecendantPackageListener implements EventPackageSubscriber {
        public String subscribeWith() {
            return NotificationReDecendantEventPackage.SubscribeWith;
        }

        public void packageReceivedVia( EventPackage pEventPackage, EventBus pEventBus ) {
            NotificationReDecendantEventPackage event = (NotificationReDecendantEventPackage) pEventPackage;
            if ( event.isAdd() ) {
                addDecendant( event.getClientId() );
            } else {
                removeDecendant( event.getClientId() );
            }
        }
    }

    private class CloseDecendantClientsPackageListener implements EventPackageSubscriber {
        public String subscribeWith() {
            return CloseDecendantClientsEventPackage.SubscribeWith;
        }

        public void packageReceivedVia( EventPackage pEventPackage, EventBus pEventBus ) {
            closeAllDecendants();
        }
    }
}