Subversion Repositories bacoAlunos

/*

BERSERK - a BusinEss Runtime and SEcurity Resources Kit

Copyright (C) 2003 Goncalo Luiz

This library is free software; you can redistribute it and/or

modify it under the terms of the GNU Lesser General Public

License as published by the Free Software Foundation; either

version 2.1 of the License, or (at your option) any later version.

This library is distributed in the hope that it will be useful,

but WITHOUT ANY WARRANTY; without even the implied warranty of

MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU

Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public

License along with this library; if not, write to the Free Software

Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA

To contact Goncalo Luiz use the following e-mail address (use an @ instead of the _):

gedl_mega.ist.utl.pt

*/

package pt.utl.ist.berserk.logic.serviceManager;

/**

 * @author Jorge Martins

 * @version revision by Goncalo Luiz (gedl \AT/ rnl \DOT/  ist \DOT/ utl \DOT/ pt) at June the 15th, 2004

 **/

import pt.utl.ist.berserk.BerserkConfiguration;

import pt.utl.ist.berserk.ServiceRequest;

import pt.utl.ist.berserk.ServiceResponse;

import pt.utl.ist.berserk.logic.filterManager.FilteringResult;

import pt.utl.ist.berserk.logic.filterManager.IFilterBroker;

import pt.utl.ist.berserk.logic.serviceManager.exceptions.ExecutedFilterException;

import pt.utl.ist.berserk.logic.serviceManager.exceptions.FilterChainFailedException;

import pt.utl.ist.berserk.logic.serviceManager.exceptions.ServiceManagerException;

import pt.utl.ist.berserk.storage.ITransactionBroker;

import pt.utl.ist.berserk.storage.exceptions.StorageException;

import java.util.ArrayList;

public class TransactionalServiceInvoker extends ServiceInvoker

{

    public static boolean debug = false;

    //TODO HIPOTESE DE TER AQUI UMA VERIFICACAO DE TRANSACAO CONTIDA

    //PROBLEMA E QUE TEMOS DE USAR A THREAD SE POR ALGUMA RAZAO MUDAMOS DE TRANSACTION BROKER

    //TUDO ESTRAGADO

    //NAO DA ISTO É UM SINGLETON boolean alreadyActive = false;

    //TIVEMOS DE TER COMO VAR LOCAL UMA VEZ QUE O InVOCADOR E NUCLEAR

        public final static TransactionalServiceInvoker invocador = new TransactionalServiceInvoker();

    public final 5+0%2Fdocs%2Fapi+Object">Object invoke(

                5+0%2Fdocs%2Fapi+Object">Object requester,

                IService service,

                1.5.0/docs/api/java/lang/String.html">String methodName,

                5+0%2Fdocs%2Fapi+Object">Object arguments[],

                1.5.0/docs/api/java/lang/String.html">String names[],

                IFilterBroker broker)

                throws ServiceManagerException, 1.5.0/docs/api/java/lang/Throwable.html">Throwable

        {

                boolean passedPre = false;

                boolean passedPost = false;

                ServiceRequest request = new ServiceRequest(requester, arguments,names,service,methodName);

                ServiceResponse response = new ServiceResponse();

                FilteringResult filteringResult = null;

                ITransactionBroker tb = BerserkConfiguration.getApplicationTransactionBroker();

        boolean alreadyActive = tb.isTransactionActive();

                try

                {

            if(debug)

                1.5.0/docs/api/java/lang/System.html">System.out.println("THREAD:" + 1.5.0/docs/api/java/lang/Thread.html">Thread.currentThread().getId()  + "Starting transaction for service: " + service.getClass().getName() + " method:" + methodName);

            if(!alreadyActive)

            {

                            tb.beginTransaction();

            }

            else

            {

                1.5.0/docs/api/java/lang/System.html">System.out.println("THREAD:" + 1.5.0/docs/api/java/lang/Thread.html">Thread.currentThread().getId()  + "AVISO : ESTA A CHAMAR UM SERVICO TRANSACIONAL DENTRO DE UMA TRANSACAO, VAMOS MANTER A MESMA TRASACAO");

                1.5.0/docs/api/java/lang/System.html">System.out.println(">>>>>>TRANSACTION WARNING BUT NO PROBLEM: AVISO: Já existia uma transação activa e foi iniciada outra neste momento sem fechar a anterior ");

                1.5.0/docs/api/java/lang/System.html">System.out.println("Servico chamado: " + service.getClass().getName());

                1.5.0/docs/api/java/lang/System.html">System.out.println("Metodo chamado: " + methodName);

                1.5.0/docs/api/java/lang/System.html">System.out.println("Requester: " + requester);

                1.5.0/docs/api/java/lang/System.html">System.out.println("Arguments: " + arguments);

                1.5.0/docs/api/java/lang/System.html">System.out.println("ArgNames: " + names);

                for (1.5.0/docs/api/java/lang/StackTraceElement.html">StackTraceElement ste : 1.5.0/docs/api/java/lang/Thread.html">Thread.currentThread().getStackTrace()) {

                    1.5.0/docs/api/java/lang/System.html">System.out.println("\t" + ste);

                }

            }

                        try

                        {

                            filteringResult = broker.executePreFiltering(request, response);

                            passedPre = filteringResult.isSuccess();

                        }

                        catch (1.5.0/docs/api/java/lang/Exception.html">Exception e)

                        {

                                throw new ExecutedFilterException(

                                        "a not 'FilterException' exception occured while executing pre filter chain",

                                        e);

                        }

                        if (passedPre)

                        {

                                response.setReturnObject(doInvocation(request.getService(), methodName, request.getArguments()));

                        }

                        else

                        {

                                throw new FilterChainFailedException(

                                                "failed to execute postFiltering on service" + service.getClass(),filteringResult);

                        }

                        try

                        {

                            filteringResult = broker.executePostFiltering(request, response);

                            passedPost = filteringResult.isSuccess();

                        }

                        catch (1.5.0/docs/api/java/lang/Exception.html">Exception e)

                        {

                                throw new ExecutedFilterException(

                                        "a not 'FilterException' exception occured while executing pre filter chain",

                                        e);

                        }

                        if (passedPost)

                        {

                                //the sucessfull case

                if(!alreadyActive)

                {

                    if(debug)

                        1.5.0/docs/api/java/lang/System.html">System.out.println("THREAD:" + 1.5.0/docs/api/java/lang/Thread.html">Thread.currentThread().getId()  + "COMMITING transaction for service: " + service.getClass().getName() + " method:" + methodName);

                                    tb.commitTransaction();

                }

                                return response.getReturnObject();

                        }

                        else

                        {

                                throw new FilterChainFailedException(

                                "failed to execute postFiltering on service" + service.getClass(),filteringResult);

                        }

                }

                catch (FilterChainFailedException ex)

                {

                        //ok let this exception go up

                        try

                        {

                                //if we get here, something went wrong with the executing service. we should roll back all changes

                if(!alreadyActive)

                                    tb.abortTransaction();

                        }

                        catch (StorageException e)

                        {

                                throw new ServiceManagerException("Storage Exception while aborting transaction",e);

                        }

                        throw ex;

                }

                catch (ExecutedFilterException ex)

                {

                        //ok let this exception go up

                        try

                        {

                                //if we get here, something went wrong with the executing service. we should roll back all changes

                if(!alreadyActive)

                                    tb.abortTransaction();

                        }

                        catch (StorageException e)

                        {

                            throw new ServiceManagerException("Storage Exception while aborting transaction",e);

                        }

                        throw ex;

                }

                catch (StorageException ex)

                {

                        try

                        {

                                //if we get here, something went wrong with the executing service. we should roll back all changes

                if(!alreadyActive)

                                    tb.abortTransaction();

                        }

                        catch (StorageException e)

                        {

                            throw new ServiceManagerException("Storage Exception while aborting transaction",e);

                        }

                        throw new ServiceManagerException("Storage exception while executing transactional service",ex);

                }

                catch (1.5.0/docs/api/java/lang/Throwable.html">Throwable ex)

                {

                        //ok let this exception go up

                        try

                        {

                                //if we get here, something went wrong with the executing service. we should roll back all changes

                if(!alreadyActive)

                    tb.abortTransaction();

                        }

                        catch (StorageException e)

                        {

                            throw new ServiceManagerException("Storage Exception while aborting transaction",e);

                        }

                        throw ex;

                }

        }

    public final 5+0%2Fdocs%2Fapi+Object">Object checkFilters(

            5+0%2Fdocs%2Fapi+Object">Object requester,

            IService service,

            1.5.0/docs/api/java/lang/String.html">String methodName,

            5+0%2Fdocs%2Fapi+Object">Object arguments[],

            1.5.0/docs/api/java/lang/String.html">String names[],

            IFilterBroker broker)

            throws ServiceManagerException, 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        boolean passedPre = false;

        ServiceRequest request = new ServiceRequest(requester, arguments,names,service,methodName);

        request.setExcludeChains(new ArrayList<String>());

        request.getExcludeChains().add("Logger");

        ServiceResponse response = new ServiceResponse();

        FilteringResult filteringResult = null;

        ITransactionBroker tb = BerserkConfiguration.getApplicationTransactionBroker();

        boolean alreadyActive = tb.isTransactionActive();

        try

        {

            if(debug)

                1.5.0/docs/api/java/lang/System.html">System.out.println("THREAD:" + 1.5.0/docs/api/java/lang/Thread.html">Thread.currentThread().getId()  + ": Starting transaction for service: " + service.getClass().getName() + " method:" + methodName);

            if(!alreadyActive)

            {

                tb.beginTransaction();

            }

            else

            {

                1.5.0/docs/api/java/lang/System.html">System.out.println("THREAD:" + 1.5.0/docs/api/java/lang/Thread.html">Thread.currentThread().getId()  +" AVISO : ESTA A CHAMAR UM SERVICO TRANSACIONAL DENTRO DE UMA TRANSACAO, VAMOS MANTER A MESMA TRASACAO");

                1.5.0/docs/api/java/lang/System.html">System.out.println(">>>>>>TRANSACTION WARNING BUT NO PROBLEM: AVISO: Já existia uma transação activa e foi iniciada outra neste momento sem fechar a anterior ");

                for (1.5.0/docs/api/java/lang/StackTraceElement.html">StackTraceElement ste : 1.5.0/docs/api/java/lang/Thread.html">Thread.currentThread().getStackTrace()) {

                    1.5.0/docs/api/java/lang/System.html">System.out.println("\t" + ste);

                }

            }

            try

            {

                filteringResult = broker.executePreFiltering(request, response);

                passedPre = filteringResult.isSuccess();

            }

            catch (1.5.0/docs/api/java/lang/Exception.html">Exception e)

            {

                throw new ExecutedFilterException(

                        "a not 'FilterException' exception occured while executing pre filter chain",

                        e);

            }

            if (passedPre)

            {

                if(!alreadyActive)

                {

                    if(debug)

                        1.5.0/docs/api/java/lang/System.html">System.out.println("THREAD:" + 1.5.0/docs/api/java/lang/Thread.html">Thread.currentThread().getId()  + "Commiting transaction for service: " + service.getClass().getName() + " method:" + methodName);

                    tb.commitTransaction();

                }

                return true;

            }

            else

            {

                throw new FilterChainFailedException(

                        "failed to execute postFiltering on service" + service.getClass(),filteringResult);

            }

        }

        catch (FilterChainFailedException ex)

        {

            //ok let this exception go up

            try

            {

                //if we get here, something went wrong with the executing service. we should roll back all changes

                if(!alreadyActive)

                    tb.abortTransaction();

            }

            catch (StorageException e)

            {

                throw new ServiceManagerException("Storage Exception while aborting transaction",e);

            }

            throw ex;

        }

        catch (ExecutedFilterException ex)

        {

            //ok let this exception go up

            try

            {

                //if we get here, something went wrong with the executing service. we should roll back all changes

                if(!alreadyActive)

                    tb.abortTransaction();

            }

            catch (StorageException e)

            {

                throw new ServiceManagerException("Storage Exception while aborting transaction",e);

            }

            throw ex;

        }

        catch (StorageException ex)

        {

            try

            {

                //if we get here, something went wrong with the executing service. we should roll back all changes

                if(!alreadyActive)

                    tb.abortTransaction();

            }

            catch (StorageException e)

            {

                throw new ServiceManagerException("Storage Exception while aborting transaction",e);

            }

            throw new ServiceManagerException("Storage exception while executing transactional service",ex);

        }

        catch (1.5.0/docs/api/java/lang/Throwable.html">Throwable ex)

        {

            //ok let this exception go up

            try

            {

                //if we get here, something went wrong with the executing service. we should roll back all changes

                if(!alreadyActive)

                    tb.abortTransaction();

            }

            catch (StorageException e)

            {

                throw new ServiceManagerException("Storage Exception while aborting transaction",e);

            }

            throw ex;

        }

    }

}