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

import java.util.*;

import org.litesoft.GWT.client.rpc.*;
import org.litesoft.bo.views.*;
import org.litesoft.bo.views.caching.*;
import org.litesoft.bo.views.communication.*;
import org.litesoft.bo.views.server.*;
import org.litesoft.commonfoundation.exceptions.*;
import org.litesoft.core.*;

public abstract class AbstractVoServerApp extends AbstractServerApp implements VoService  // don't forget this!
{
    private ServerVoDataProviderMap mDPmap;

    protected AbstractVoServerApp( String pAppName, VoCacheManager pCacheManager, ServerVoDataProviderMapFactory pFactory )
    {
        super( pAppName );
        ServletSessionHelper.initialize( pCacheManager );
        ServerContext.getMasterServerStore().set( ServerVoDataProviderMap.class, mDPmap = pFactory.createServerVoDataProviderMap() );
    }

    @Override
    public final SCpayload process( CSpayload pPayload )
    {
        ContextID zContextID = ServletSessionHelper.callInit( getThreadLocalRequest().getSession( true ) );

        try
        {
            AbstractCSrequestVOtype zRequest = (AbstractCSrequestVOtype) pPayload.getCSrequest();
            if ( zRequest == null )
            {
                return new SCpayload( new VOSCresponseError( "" ), getTemporalTriggers() ); // Simple Poll
            }
            String zViewObjectRegisteredName = zRequest.getForViewObjectRegisteredName();

            ServerVoDataProvider<IViewObject> zDataProvider = mDPmap.get( zViewObjectRegisteredName );

            if ( zDataProvider == null )
            {
                throw new IllegalStateException( "No DataProvider for '" + zViewObjectRegisteredName + "'" );
            }

            SCresult zResult = zRequest.process( mDPmap, zDataProvider );

            CacheID zCacheID = pPayload.getResponseCacheID();
            if ( zCacheID != null )
            {
                if ( zResult.getReadObjectClassName() != null )
                {
                    ServletSessionHelper.getCacheManager().addType( zContextID, zCacheID, zResult.getReadObjectClassName() );
                }
                else if ( zResult.getReadObjectURL() != null )
                {
                    ServletSessionHelper.getCacheManager().addInstance( zContextID, zCacheID, zResult.getReadObjectURL() );
                }
            }
            List<ObjectURL> zChangedObjectURLs = zResult.getChangedObjectURLs();

            CacheID[] zCacheIDs = ServletSessionHelper.getCacheManager().invalidate( zContextID, zChangedObjectURLs );

            return new SCpayload( zResult.getSCresponse(), getTemporalTriggers(), zCacheIDs );
        }
        catch ( SessionExpiredException e )
        {
            return new SCpayload( new SecuritySCresponse( true, e.getMessage() ), getTemporalTriggers() );
        }
        catch ( SecurityException e )
        {
            return new SCpayload( new SecuritySCresponse( false, e.getMessage() ), getTemporalTriggers() );
        }
        catch ( RuntimeException e )
        {
            if ( e instanceof DisplayableException )
            {
                DisplayableException zDisplayable = (DisplayableException) e;
                return new SCpayload( new VOSCresponseError( resolve( zDisplayable.getToResolveIdentifier(), zDisplayable.getParams() ) ), getTemporalTriggers() );
            }
            getLogger().warn().log( e );
            throw e;
        }
        finally
        {
            ServletSessionHelper.callFini();
        }
    }

    protected synchronized TemporalTrigger[] getTemporalTriggers()
    {
        if ( mTemporalTriggerAccessors.isEmpty() )
        {
            return null;
        }
        TemporalTrigger[] rv = new TemporalTrigger[mTemporalTriggerAccessors.size()];
        for ( int i = 0; i < mTemporalTriggerAccessors.size(); i++ )
        {
            rv[i] = mTemporalTriggerAccessors.get( i ).getTrigger();
        }
        return rv;
    }

    private List<TemporalTriggerAccessor> mTemporalTriggerAccessors = new ArrayList<TemporalTriggerAccessor>();

    public synchronized void add( TemporalTriggerAccessor pTemporalTriggerAccessor )
    {
        if ( pTemporalTriggerAccessor != null )
        {
            mTemporalTriggerAccessors.add( pTemporalTriggerAccessor );
        }
    }

    abstract protected String resolve( String pIdentifier, String[] pParams );
}