package org.litesoft.bo.views.server;

import java.util.*;

import org.litesoft.bo.views.*;
import org.litesoft.bo.views.communication.*;
import org.litesoft.core.simpletypes.*;
import org.litesoft.core.util.*;

public abstract class AbstractServerRequestRowOrRowsVoDataProvider<T extends IViewObject> extends AbstractFunctionalServerVoDataProvider<T>
{
    protected AbstractServerRequestRowOrRowsVoDataProvider( VoMetaData<T> pVOMetaData )
    {
        super( pVOMetaData );
    }

    public final SCresult requestRowByObjectURL( ObjectURL pObjectURL )
            throws PersistenceException
    {
        T zVO = getVOby( pObjectURL );
        return VOSC.result( zVO );
    }

    public final SCresult requestRowsByObjectURLs( ObjectURL... pObjectURLs )
            throws PersistenceException
    {
        return process( getMatchingVOs( pObjectURLs ) );
    }

    public final SCresult requestRowsByFilters( BoAccessorFilters pFilters, Integer pMaxToReturn )
            throws PersistenceException
    {
        return process( getMatchingVOs( UtilsCommon.assertNotNegative( "MaxToReturn", pMaxToReturn ), toFilterArray( pFilters ) ) );
    }

    public SCresult process( SizedIterator<T> zIterator )
            throws PersistenceException
    {
        return (zIterator.size() != null) ? // zIterator's size is ONLY set if the Max Size was exceeded
               VOSC.result( zIterator.size() ) : //
               VOSC.result( convert( zIterator ) );
    }

    public Collection<T> convert( Iterator<T> pIterator )
    {
        try
        {
            ArrayList<T> zList = new ArrayList<T>();
            while ( pIterator.hasNext() )
            {
                zList.add( pIterator.next() );
            }
            return zList;
        }
        finally
        {
            if ( pIterator instanceof Disposable )
            {
                ((Disposable) pIterator).dispose();
            }
        }
    }

    private static SSMap[] toFilterArray( BoAccessorFilters pFilters )
    {
        return (pFilters == null) || pFilters.isEmpty() ? SSMap.EMPTY_ARRAY : new SSMap[]{pFilters.getFilters()};
    }
}