// This Source Code is in the Public Domain per: http://litesoft.org/License.txt
package org.litesoft.orsup.nonpublic;

import java.io.*;
import java.sql.*;

import org.litesoft.orsup.base.*;
import org.litesoft.orsup.transact.*;

public class TransCommitEntry
{
    private PersistentObjectImpl mParticipant;
    private int mChangeNumber = PersistentObjectImpl.INITIAL_CHANGE_NUMBER - 1;
    private Serializable mExtraPOinfo = null;

    public TransCommitEntry( PersistentObjectImpl pParticipant )
    {
        mParticipant = pParticipant;
    }

    public void updateChangeNumber()
    {
        mChangeNumber = mParticipant.getChangeNumber();
    }

    public boolean hasChanged()
    {
        return (mChangeNumber != mParticipant.getChangeNumber());
    }

    public boolean checkShouldProcess_AboutToCommit( CA_LinkListNode pCommitAugmentors, Timestamp pTransactionTimeStamp )
    {
        if ( !hasChanged() )
        {
            return false;
        }
        for ( CA_LinkListNode zCA = pCommitAugmentors; zCA != null; zCA = zCA.getNext() )
        {
            zCA.getCommitAugmentor().pre_aboutToCommitAugment( mParticipant, pTransactionTimeStamp );
        }
        mExtraPOinfo = mParticipant.aboutToCommit( pTransactionTimeStamp );
        for ( CA_LinkListNode zCA = pCommitAugmentors; zCA != null; zCA = zCA.getNext() )
        {
            zCA.getCommitAugmentor().post_aboutToCommitAugment( mParticipant, pTransactionTimeStamp );
        }
        MetaDataForPOinternalExtension md = (MetaDataForPOinternalExtension) mParticipant.getMetaDataForPO();
        boolean notTossing = !mParticipant.willTossFromTransactionCommit();
        // Note: the Change Propagation probably does NOT propagate beyond one hop!
        if ( notTossing )
        {
            for ( AbstractAttributeAccessorSCDtoOne toOne : //
                    md.getToOneAccessorSCDsThatFlagPeerChange() )
            {
                PersistentObjectImpl.BackDoor.changeToManyDueToOne( mParticipant, toOne );
            }
        }
        if ( notTossing || mParticipant.isForcedChangeNotification() )
        {
            for ( AbstractAttributeAccessorSCDtoOne toOne : //
                    md.getToOneAccessorSCDsThatFlagPeerChangeNotification() )
            {
                PersistentObjectImpl.BackDoor.changeNotifyToManyDueToOne( mParticipant, toOne );
            }
        }
        updateChangeNumber();
        return true;
    }

    public void augment( HistoryAugmentor pHistoryAugmentor, Timestamp pTransactionTimeStamp )
    {
        pHistoryAugmentor.historize( mParticipant, pTransactionTimeStamp );
    }

    public PersistentObjectImpl getParticipant()
    {
        return mParticipant;
    }

    public Serializable getExtraPOinfo()
    {
        return mExtraPOinfo;
    }

    @Override
    public boolean equals( Object o )
    {
        return (this == o) || //
               ((o instanceof TransCommitEntry) && equals( (TransCommitEntry) o ));
    }

    public boolean equals( TransCommitEntry them )
    {
        return (this == them) || //
               ((them != null) //
                && this.mParticipant.equals( them.mParticipant ) //
               );
    }

    @Override
    public int hashCode()
    {
        return mParticipant.hashCode();
    }
}