package org.litesoft.GWT.eventbus.client;

import java.util.*;

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

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();
        }
    }
}