package org.litesoft.orsup.base;

import java.io.*;

import org.litesoft.changemanagement.*;
import org.litesoft.core.*;
import org.litesoft.orsup.transact.*;
import org.litesoft.util.*;

public class CacheMaintainer implements TransactionCommitListener
{
    public static void create( Finder pFinder, CacheMaintenanceListener pListener )
    {
        Utils.assertNotNull( "Finder", pFinder );
        Utils.assertNotNull( "Listener", pListener );
        CacheMaintainer zMaintainer = new CacheMaintainer( pListener, pFinder.getNextSequenceNumber( "CacheMaintainer" ) );
        pFinder.getTransactionCommitListenerManager().addListener( zMaintainer );
        zMaintainer.registerForChangesFromClusterPeers();
    }

    private void registerForChangesFromClusterPeers()
    {
        getMasterCLM().addListener( new MyChangeListener(), mListener.getClass() );
    }

    private void sendChangesToClusterPeers( Serializable pCacheUpdate )
    {
        String zName = mListener.getClass().getName();
        ServerStateChange zChange = new ServerStateChange( ServerStateChange.Action.UPDATED, //
                                                           zName, // ChangedObjectTypeName
                                                           mOurID, // ChangedObjectUniqueKey
                                                           null, // ChangedObjectDisplayValue
                                                           pCacheUpdate );
        getMasterCLM().notifyAllRemoteListeners( new ServerStateChangeSet( mOurID, // SourceUniqueID
                                                                           zName, // SourceClassname
                                                                           zChange ) );
    }

    private ChangeListenerManager getMasterCLM()
    {
        DataStore zMasterDataStore = ServerContext.getMasterServerStore().get( DataStore.class );
        Utils.assertNotNull( "MasterDataStore", zMasterDataStore );
        return zMasterDataStore.getChangeListenerManager();
    }

    private CacheMaintainer( CacheMaintenanceListener pListener, Long pOurID )
    {
        mListener = pListener;
        mOurID = pOurID;
    }

    private CacheMaintenanceListener mListener;
    private Long mOurID;

    public TransactionSuccessfulCommitCallBack aboutToCommit( PersistentObject[] pCommitParticipants )
    {
        Serializable zResult = mListener.aboutToCommit( pCommitParticipants );
        return (zResult != null) ? new MyCallBack( zResult ) : null;
    }

    private class MyCallBack implements TransactionSuccessfulCommitCallBack
    {
        private Serializable mResult;

        public MyCallBack( Serializable pResult )
        {
            mResult = pResult;
        }

        public void commitSucceeded()
        {
            sendChangesToClusterPeers( mResult );
            mListener.updateCache( mResult );
        }
    }

    private class MyChangeListener implements ServerStateChangedListener
    {
        public void serverStateChanged( ServerStateChangeSet pServerStateChangeSet )
        {
            for ( ServerStateChange zChange : pServerStateChangeSet.getChanges() )
            {
                mListener.updateCache( (Serializable) zChange.getExtraInfo() );
            }
        }
    }
}