// 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.logger.*;

import java.util.*;

public class SavedEventsExpectingResponseTracker {
    private Map mPendingAckPeerInterestToEvents = new HashMap();
    private Logger mLogger;

    public SavedEventsExpectingResponseTracker( Logger pLogger ) {
        mLogger = pLogger;
    }

    private void LLadd( EventPackage pPackage ) {
        String name = pPackage.getSourceName();
        EventPackage[] newList, curList = (EventPackage[]) mPendingAckPeerInterestToEvents.get( name );
        if ( curList == null ) {
            newList = new EventPackage[]{pPackage};
        } else {
            newList = new EventPackage[curList.length + 1];
            int i = 0;
            for (; i < curList.length; i++ ) {
                newList[i] = curList[i];
            }
            newList[i] = pPackage;
        }
        mPendingAckPeerInterestToEvents.put( name, newList );
    }

    public void add( EventPackage pPackage ) {
        mLogger.trace.log( "(EventExpectingResponse):", pPackage );
        LLadd( pPackage );
    }

    public void clear() {
        mPendingAckPeerInterestToEvents.clear();
    }

    public EventPackage[] getAndReleaseEventsFor( String pName ) {
        return (EventPackage[]) mPendingAckPeerInterestToEvents.remove( pName );
    }
}