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

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

import java.util.*;

public class PeerInterestManager {
    private Set mPeerInterests = new HashSet();
    private String mEBform;

    public PeerInterestManager( String pEBform ) {
        mEBform = pEBform;
    }

    public synchronized boolean isPeerInterested( EventPackage pPackage ) {
        return (pPackage instanceof AlwaysSendToPeer) || //
               ((pPackage instanceof ChannelEventPackage) &&
                mPeerInterests.contains( pPackage.getTargetName() ));
    }

    public synchronized void add( Set pPeerInterests ) {
        if ( !pPeerInterests.isEmpty() ) {
            mPeerInterests.addAll( pPeerInterests );
        }
    }

    public synchronized void remove( Set pPeerInterests ) {
        if ( !pPeerInterests.isEmpty() ) {
            mPeerInterests.removeAll( pPeerInterests );
        }
    }

    public synchronized void clear() {
        mPeerInterests.clear();
    }

    public String toString() {
        return mEBform;
    }
}