//     $Revision: 1.1.2.1 $
package com.kabira.snippets.store;

import com.kabira.platform.Transaction;
import com.kabira.platform.annotation.Managed;
import com.kabira.platform.swbuiltin.TransactionNotifier;
import com.kabira.store.Record;

/**
 * Secondary store transaction management
 * <p>
 * <h2> Target Nodes</h2>
 * <ul>
 * <li> <b>domainnode</b> = A
 * </ul>
 */
public class TransactionManagement
{
    @Managed
    private static class A
    {
        A(boolean error)
        {
            this.error = error;
        }
        final boolean error;
    };

    private static class RecordNotifier extends Record<A>
    {
        RecordNotifier()
        {
            super(A.class);
        }

        @Override
        public void created(A a)
        {
            System.out.println("INFO: Object created");

            //
            //    Create transaction notifier to transactionally manage
            //    external store
            //
            new TransactionBoundary();

            //
            //    Simulate an error.  Throw an exception to rollback the 
            //    transaction so that shared memory state is restored to 
            //    its value before the transaction was started.
            //
            if (a.error == true)
            {
                System.out.println("INFO:\tRolling back transaction");
                throw new RuntimeException("Simulating external store error");
            }
        }
    }

    private static class TransactionBoundary extends TransactionNotifier
    {

        @Override
        public void onRollback()
        {
            System.out.println("INFO: Transaction "
                + Transaction.getIdentifier()
                + " rolled back.");

            //
            //    Undo any work in an external store
            //
        }

        @Override
        public void onCommit()
        {
            System.out.println("INFO: Transaction "
                + Transaction.getIdentifier()
                + " committed.");

            //
            //    Commit any work in an external store
            //    Commits cannot fail
            //
        }

        @Override
        public void onPrepare()
        {
            System.out.println("INFO: Transaction "
                + Transaction.getIdentifier()
                + " prepared.");

            //
            //    Prepare any work in an external store
            //
        }
    }

    /**
     * Main entry point
     *
     * @param args Not used
     */
    public static void main(final String[] args)
    {
        //
        //    Initialize record notifier
        //
        new Transaction("Initialize")
        {
            @Override
            protected void run()
            {
                new RecordNotifier();
            }
        }.execute();

        //
        //    Create an object with no error
        //
        new Transaction("Create object")
        {
            @Override
            protected void run()
            {
                new A(false);
            }
        }.execute();

        //
        //    Create an object with an error
        //
        new Transaction("Create object with error")
        {
            @Override
            protected void run()
            {
                new A(true);
            }
        }.execute();
    }
}