OutRequestHandler.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it).
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */
  20. package org.openspcoop2.pdd.core.handlers.transazioni;

  22. import java.util.Date;

  24. import org.apache.commons.lang.StringUtils;
  25. import org.openspcoop2.core.constants.Costanti;
  26. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  27. import org.openspcoop2.pdd.core.CostantiPdD;
  28. import org.openspcoop2.pdd.core.handlers.HandlerException;
  29. import org.openspcoop2.pdd.core.handlers.OutRequestContext;
  30. import org.openspcoop2.pdd.core.transazioni.OutRequestStatefulObject;
  31. import org.openspcoop2.pdd.core.transazioni.RepositoryGestioneStateful;
  32. import org.openspcoop2.pdd.core.transazioni.Transaction;
  33. import org.openspcoop2.pdd.core.transazioni.TransactionContext;
  34. import org.openspcoop2.pdd.core.transazioni.TransactionDeletedException;
  35. import org.openspcoop2.pdd.core.transazioni.TransactionNotExistsException;
  36. import org.openspcoop2.pdd.core.transazioni.TransactionStatefulNotSupportedException;
  37. import org.openspcoop2.utils.transport.http.HttpRequestMethod;

  39. /**     
  40.  * OutRequestHandler
  41.  *
  42.  * @author Poli Andrea (poli@link.it)
  43.  * @author $Author$
  44.  * @version $Rev$, $Date$
  45.  */
  46. public class OutRequestHandler extends LastPositionHandler implements  org.openspcoop2.pdd.core.handlers.OutRequestHandler{

  48.     @Override
  49.     public void invoke(OutRequestContext context) throws HandlerException {

  51.         OpenSPCoop2Properties op2Properties = OpenSPCoop2Properties.getInstance();
  52.         if(op2Properties.isTransazioniEnabled()==false) {
  53.             return;
  54.         }
  55.         
  56.         String idTransazione = (String) context.getPddContext().getObject(Costanti.ID_TRANSAZIONE);
  57.         
  58.         //System.out.println("------------- OutRequestHandler ("+idTransazione+")("+context.getTipoPorta().getTipo()+") -------------------");
  59.         
  60.         
  61.         
  62.         if(context.getTransazioneApplicativoServer()!=null) {
  63.             
  64.             try{
  65.             
  66.                 context.getTransazioneApplicativoServer().setDataUscitaRichiesta(context.getDataElaborazioneMessaggio());
  67.                 
  68.                 if(context.getConnettore()!=null){
  69.                     context.getTransazioneApplicativoServer().setLocationConnettore(context.getConnettore().getLocation());
  70.                 }
  71.                 
  72.             }catch(Exception e){
  73.                 throw new HandlerException("Errore durante il processamento delle informazioni relative alla consegna per l'applicativo '"+context.getTransazioneApplicativoServer().getServizioApplicativoErogatore()+"': "+e.getMessage(),e);
  74.             }
  75.             
  76.         }
  77.         else {
  78.         
  79.         
  80.             //if(context.getIntegrazione()!=null)
  81.             //  System.out.println("GESTIONE STATELESS OutRequestHandler ["+context.getIntegrazione().isGestioneStateless()+"] ["+context.getTipoPorta()+"]");
  82.             if(context.getIntegrazione()!=null && 
  83.                     context.getIntegrazione().isGestioneStateless()!=null &&
  84.                     !context.getIntegrazione().isGestioneStateless()){
  85.                 if(op2Properties.isTransazioniStatefulEnabled()==false){
  86.                     throw new HandlerException("Gestione delle transazioni stateful non abilita");
  87.                 }
  88.             }
  89.             
  90.             boolean gestioneStateful = false;
  91.             Transaction tr = null;
  92.             try{
  93.                 tr = TransactionContext.getTransaction(idTransazione);
  94.             }catch(TransactionNotExistsException e){
  95.                 gestioneStateful = true;
  96.             }
  97.                     
  98.             try{
  99.             
  100.                 OutRequestStatefulObject sObject = null;
  101.                 
  102.                 if(tr==null && gestioneStateful){
  103.                     
  104.                     sObject = new OutRequestStatefulObject();
  105.                     
  106.                     //System.out.println("@@@@@REPOSITORY@@@@@ OutRequestHandler ID TRANSAZIONE ["+idTransazione+"] GESTIONE COMPLETA");
  107.                                     
  108.                     Date dataElaborazioneMessaggio = context.getDataElaborazioneMessaggio();
  109.                     // INEFFICIENTE: RepositoryGestioneStateful.addDataUscitaRichiesta(idTransazione, dataElaborazioneMessaggio);
  110.                     sObject.setDataUscitaRichiesta(dataElaborazioneMessaggio);
  111.                                     
  112.                     if(context.getProtocollo()!=null){
  113.                         // INEFFICIENTE: RepositoryGestioneStateful.addScenarioCooperazione(idTransazione, context.getProtocollo().getScenarioCooperazione());
  114.                         sObject.setScenarioCooperazione(context.getProtocollo().getScenarioCooperazione());
  115.                     }
  116.                     
  117.                     if(context.getConnettore()!=null){
  118.                         
  119.                         // INEFFICIENTE: RepositoryGestioneStateful.addTipoConnettore(idTransazione, context.getConnettore().getTipoConnettore());
  120.                         sObject.setTipoConnettore(context.getConnettore().getTipoConnettore());
  121.                         
  122.                         // INEFFICIENTE: RepositoryGestioneStateful.addLocation(idTransazione, context.getConnettore().getLocation());
  123.                         sObject.setLocation(context.getConnettore().getLocation());
  124.                         
  125.                     }
  126.                     
  127.                     if(context.getIntegrazione()!=null){
  128.                         
  129.                         // INEFFICIENTE: RepositoryGestioneStateful.addServizioApplicativoErogatore(context.getIntegrazione().getServizioApplicativoErogatore(i));
  130.                         for (int i = 0; i < context.getIntegrazione().sizeServiziApplicativiErogatori(); i++) {
  131.                             sObject.addServizioApplicativoErogatore(context.getIntegrazione().getServizioApplicativoErogatore(i));  
  132.                         }
  133.                         
  134.                     }
  135.                     
  136.                 }
  137.                 
  138.                 else{
  139.                 
  140.                     if(tr==null) {
  141.                         throw new HandlerException("Transaction is null");
  142.                     }
  143.                     
  144.                     Date dataElaborazioneMessaggio = context.getDataElaborazioneMessaggio();
  145.                     try{
  146.                         tr.setDataUscitaRichiesta(dataElaborazioneMessaggio);
  147.                         //System.out.println("SET DATA ("+dataElaborazioneMessaggio.toString()+")");
  148.                     }catch(TransactionDeletedException e){
  149.                         //System.out.println("@@@@@REPOSITORY@@@@@ OutRequestHandler SET DATA ("+dataElaborazioneMessaggio.toString()+")");
  150.                         // INEFFICIENTE: RepositoryGestioneStateful.addDataUscitaRichiesta(idTransazione, dataElaborazioneMessaggio);
  151.                         if(sObject==null)
  152.                             sObject = new OutRequestStatefulObject();
  153.                         sObject.setDataUscitaRichiesta(dataElaborazioneMessaggio);
  154.                     }
  155.                     
  156.                     try{
  157.                         if(context.getProtocollo()!=null){
  158.                             //System.out.println("SET SCENARIO ["+context.getProtocollo().getScenarioCooperazione()+"]");
  159.                             tr.setScenarioCooperazione(context.getProtocollo().getScenarioCooperazione());
  160.                         }
  161.                     }catch(TransactionDeletedException e){
  162.                         //System.out.println("@@@@@REPOSITORY@@@@@ OutRequestHandler SET SCENARIO ["+context.getProtocollo().getScenarioCooperazione()+"]");
  163.                         // INEFFICIENTE: RepositoryGestioneStateful.addScenarioCooperazione(idTransazione, context.getProtocollo().getScenarioCooperazione());
  164.                         if(sObject==null)
  165.                             sObject = new OutRequestStatefulObject();
  166.                         sObject.setScenarioCooperazione(context.getProtocollo().getScenarioCooperazione());
  167.                     }
  168.                     
  169.                     if(context.getConnettore()!=null){
  170.                         
  171.                         try{
  172.                             //System.out.println("SET TIPO CONNETTORE ["+context.getConnettore().getTipoConnettore()+"]");
  173.                             tr.setTipoConnettore(context.getConnettore().getTipoConnettore());
  174.                         }catch(TransactionDeletedException e){
  175.                             //System.out.println("@@@@@REPOSITORY@@@@@ OutRequestHandler SET TIPO CONNETTORE ["+context.getConnettore().getTipoConnettore()+"]");
  176.                             // INEFFICIENTE: RepositoryGestioneStateful.addTipoConnettore(idTransazione, context.getConnettore().getTipoConnettore());
  177.                             if(sObject==null)
  178.                                 sObject = new OutRequestStatefulObject();
  179.                             sObject.setTipoConnettore(context.getConnettore().getTipoConnettore());
  180.                         }
  181.                         
  182.                         try{
  183.                             //System.out.println("SET LOCATION ["+context.getConnettore().getLocation()+"]");
  184.                             String connettoreRequestUrl = null;
  185.                             String connettoreRequestMethod = null;
  186.                             if(context.getPddContext()!=null) {
  187.                                 if(context.getPddContext().containsKey(CostantiPdD.CONNETTORE_REQUEST_URL)) {
  188.                                     connettoreRequestUrl = (String) context.getPddContext().getObject(CostantiPdD.CONNETTORE_REQUEST_URL);
  189.                                 }
  190.                                 if(context.getPddContext().containsKey(CostantiPdD.CONNETTORE_REQUEST_METHOD)) {
  191.                                     Object o = context.getPddContext().getObject(CostantiPdD.CONNETTORE_REQUEST_METHOD);
  192.                                     if(o instanceof String) {
  193.                                         connettoreRequestMethod = (String) o;
  194.                                     }
  195.                                     else if(o instanceof HttpRequestMethod) {
  196.                                         HttpRequestMethod oConnettoreRequestMethod = (HttpRequestMethod) o;
  197.                                         connettoreRequestMethod = oConnettoreRequestMethod.name();
  198.                                     }
  199.                                 }
  200.                             }
  201.                             if(!StringUtils.isEmpty(connettoreRequestUrl) && !StringUtils.isEmpty(connettoreRequestMethod)) {
  202.                                 tr.setLocation(CostantiPdD.getConnettoreRequest(connettoreRequestUrl, connettoreRequestMethod));
  203.                             }
  204.                             else {
  205.                                 tr.setLocation(context.getConnettore().getLocation());
  206.                             }
  207.                         }catch(TransactionDeletedException e){
  208.                             //System.out.println("@@@@@REPOSITORY@@@@@ OutRequestHandler SET LOCATION ["+context.getConnettore().getLocation()+"]");
  209.                             // INEFFICIENTE: RepositoryGestioneStateful.addLocation(idTransazione, context.getConnettore().getLocation());
  210.                             if(sObject==null)
  211.                                 sObject = new OutRequestStatefulObject();
  212.                             sObject.setLocation(context.getConnettore().getLocation());
  213.                         }
  214.                         
  215.                     }
  216.                     
  217.                     if(context.getIntegrazione()!=null){
  218.                         
  219.                         for (int i = 0; i < context.getIntegrazione().sizeServiziApplicativiErogatori(); i++) {
  220.                             try{
  221.                                 //  System.out.println("ADD SERVIZIO APPLICATIVO EROGATORE ["+context.getConnettore().getLocation()+"]");
  222.                                 tr.addServizioApplicativoErogatore(context.getIntegrazione().getServizioApplicativoErogatore(i));
  223.                             }catch(TransactionDeletedException e){
  224.                                 //System.out.println("@@@@@REPOSITORY@@@@@ OutRequestHandler ADD SERVIZIO APPLICATIVO EROGATORE ["+context.getIntegrazione().getServizioApplicativoErogatore(i)+"]");
  225.                                 // INEFFICIENTE: RepositoryGestioneStateful.addServizioApplicativoErogatore(context.getIntegrazione().getServizioApplicativoErogatore(i));
  226.                                 if(sObject==null)
  227.                                     sObject = new OutRequestStatefulObject();
  228.                                 sObject.addServizioApplicativoErogatore(context.getIntegrazione().getServizioApplicativoErogatore(i));  
  229.                             }
  230.                         }
  231.                         
  232.                     }
  233.                 }
  234.                 
  235.                 
  236.                 if(sObject!=null){
  237.                     // Gestione stateful
  238.                     RepositoryGestioneStateful.addOutRequestStatefulObject(context.getProtocolFactory().getProtocol(),idTransazione, sObject);
  239.                 }
  240.                 
  241.             }catch(TransactionStatefulNotSupportedException e){
  242.                 throw new HandlerException("Errore durante il processamento dell'handler: "+e.getMessage(),e);
  243.             }
  244.         }
  245.         
  246.     }


  249. }
Created with JaCoCo 0.8.8.202204050719