package org.litesoft.bo.views;

import org.litesoft.bo.views.caching.*;
import org.litesoft.bo.views.communication.*;

public abstract class TypedVoDataProvider<T extends IViewObject> extends VoDataProvider<T> implements CacheInvalidCallBack
{
    protected TypedVoDataProvider( VoMetaData<T> pMetaData )
    {
        super( pMetaData );
    }

    protected CScomm getCScomm()
    {
        checkOnPolling();
        return CScomm.getInstance();
    }

    public void requestTemporalTriggerPoll()
    {
        getCScomm().requestTemporalTriggerPoll();
    }

    public void requestRow( ObjectURL pObjectURL, FetchRowDataProviderCallBack<T> pCallBack )
    {
        requestRow( null, pObjectURL, pCallBack );
    }

    protected void requestRow( CacheID pCacheID, ObjectURL pObjectURL, FetchRowDataProviderCallBack<T> pCallBack )
    {
        getCScomm().requestRowByObjectURL( this, pCacheID, new VOCSrequestRowByObjectURL( getForViewObjectRegisteredName(), pObjectURL ), pCallBack );
    }

    public void requestRows( ObjectURL[] pObjectURLs, FetchRowsDataProviderCallBack<T> pCallBack )
    {
        requestRows( null, pObjectURLs, pCallBack );
    }

    protected void requestRows( CacheID pCacheID, ObjectURL[] pObjectURLs, FetchRowsDataProviderCallBack<T> pCallBack )
    {
        getCScomm().requestRowsByObjectURLs( this, pCacheID, new VOCSrequestRowsByObjectURLs( getForViewObjectRegisteredName(), pObjectURLs ), pCallBack );
    }

    public void requestRows( BoAccessorFilters pFilters, FetchRowsDataProviderCallBack<T> pCallBack )
    {
        requestRows( null, pFilters, pCallBack );
    }

    protected void requestRows( CacheID pCacheID, BoAccessorFilters pFilters, Integer pMaxToReturn, FetchRowsDataProviderCallBack<T> pCallBack )
    {
        getCScomm().requestRowsByFilters( this, pCacheID, new VOCSrequestRowsByFilters( getForViewObjectRegisteredName(), pFilters, pMaxToReturn ), pCallBack );
    }

    protected void requestRows( CacheID pCacheID, BoAccessorFilters pFilters, FetchRowsDataProviderCallBack<T> pCallBack )
    {
        requestRows( pCacheID, pFilters, getMaxRowsToFetch(), pCallBack );
    }

    protected Integer getMaxRowsToFetch()
    {
        return 100;
    }

    public void requestAllRows( FetchRowsDataProviderCallBack<T> pCallBack )
    {
        requestRows( null, (BoAccessorFilters) null, pCallBack );
    }

    public void commit( TransactionSet pTransactionSet, CommitCallBack<T> pCallBack, ObjectURL... pReturnOnSuccess )
    {
        commit( null, pTransactionSet, pCallBack, pReturnOnSuccess );
    }

    protected void commit( CacheID pCacheID, TransactionSet pTransactionSet, CommitCallBack<T> pCallBack, ObjectURL... pReturnOnSuccess )
    {
        getCScomm().requestCommit( this, pCacheID, new VOCSrequestCommit( getForViewObjectRegisteredName(), pTransactionSet, pReturnOnSuccess ), pCallBack );
    }

    protected String getForViewObjectRegisteredName()
    {
        return mMetaData.getViewObjectClass().getName();
    }
}