ConnettoreUtilities.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.  */

  21. package org.openspcoop2.pdd.core.controllo_traffico;

  23. import java.util.Iterator;
  24. import java.util.Map;

  26. import org.openspcoop2.core.config.AccessoConfigurazionePdD;
  27. import org.openspcoop2.core.config.Connettore;
  28. import org.openspcoop2.core.config.PortaApplicativa;
  29. import org.openspcoop2.core.config.ServizioApplicativo;
  30. import org.openspcoop2.core.config.constants.CostantiConfigurazione;
  31. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  32. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  33. import org.openspcoop2.core.constants.CostantiConnettori;
  34. import org.openspcoop2.core.constants.TipoPdD;
  35. import org.openspcoop2.core.controllo_traffico.ConfigurazioneGenerale;
  36. import org.openspcoop2.core.controllo_traffico.beans.DatiTransazione;
  37. import org.openspcoop2.core.id.IDPortaApplicativa;
  38. import org.openspcoop2.core.id.IDServizioApplicativo;
  39. import org.openspcoop2.core.id.IDSoggetto;
  40. import org.openspcoop2.pdd.config.ConfigurazionePdDManager;
  41. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  42. import org.openspcoop2.pdd.core.handlers.InRequestProtocolContext;
  43. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  44. import org.openspcoop2.protocol.sdk.state.RequestInfo;

  46. /**     
  47.  * ConnettoreUtilities
  48.  *
  49.  * @author Poli Andrea (poli@link.it)
  50.  * @author $Author$
  51.  * @version $Rev$, $Date$
  52.  */
  53. public class ConnettoreUtilities {
  54.     
  55.     private ConnettoreUtilities() {}

  57.     public static DatiTempiRisposta readDatiGlobaliTimeout(ConfigurazionePdDManager configPdDManager, TipoPdD tipoPdD, RequestInfo requestInfo, OpenSPCoop2Properties properties) throws DriverConfigurazioneException {
  58.         // Prelevo la configurazione del Controllo del Traffico
  59.         
  60.         AccessoConfigurazionePdD accessoConfigurazione = null;
  61.         try {
  62.             accessoConfigurazione = properties.getAccessoConfigurazionePdD();
  63.         }catch(Exception e) {
  64.             throw new DriverConfigurazioneException(e.getMessage(),e);
  65.         }
  66.         
  67.         ConfigurazioneGenerale configurazioneGenerale = null;
  68.         if(accessoConfigurazione!=null && CostantiConfigurazione.CONFIGURAZIONE_DB.equalsIgnoreCase(accessoConfigurazione.getTipo())) {
  69.             try {
  70.                 configurazioneGenerale = configPdDManager.getConfigurazioneControlloTraffico(requestInfo);
  71.             }catch(DriverConfigurazioneNotFound notFound) {
  72.                 // ignore
  73.             }
  74.         }
  75.         
  76.         if(TipoPdD.DELEGATA.equals(tipoPdD)){
  77.             return readDatiGlobaliTimeoutFruizione(configurazioneGenerale, properties);
  78.         }
  79.         else{
  80.             return readDatiGlobaliTimeoutErogazione(configurazioneGenerale, properties);
  81.         }
  82.     
  83.     }
  84.     private static DatiTempiRisposta readDatiGlobaliTimeoutFruizione(ConfigurazioneGenerale configurazioneGenerale, OpenSPCoop2Properties properties) {
  85.         DatiTempiRisposta datiTempiRisposta = new DatiTempiRisposta();
  86.         if(configurazioneGenerale!=null && configurazioneGenerale.getTempiRispostaFruizione()!=null) {
  87.             if(configurazioneGenerale.getTempiRispostaFruizione().getConnectionTimeout()!=null) {
  88.                 datiTempiRisposta.setConnectionTimeout(configurazioneGenerale.getTempiRispostaFruizione().getConnectionTimeout());
  89.             }
  90.             else {
  91.                 datiTempiRisposta.setConnectionTimeout(properties.getConnectionTimeout_inoltroBuste());
  92.             }
  93.             if(configurazioneGenerale.getTempiRispostaFruizione().getReadTimeout()!=null) {
  94.                 datiTempiRisposta.setReadConnectionTimeout(configurazioneGenerale.getTempiRispostaFruizione().getReadTimeout());
  95.             }
  96.             else {
  97.                 datiTempiRisposta.setReadConnectionTimeout(properties.getReadConnectionTimeout_inoltroBuste());
  98.             }
  99.         }
  100.         else {
  101.             datiTempiRisposta.setConnectionTimeout(properties.getConnectionTimeout_inoltroBuste());
  102.             datiTempiRisposta.setReadConnectionTimeout(properties.getReadConnectionTimeout_inoltroBuste());
  103.         }
  104.         return datiTempiRisposta;
  105.     }
  106.     private static DatiTempiRisposta readDatiGlobaliTimeoutErogazione(ConfigurazioneGenerale configurazioneGenerale, OpenSPCoop2Properties properties) {
  107.         DatiTempiRisposta datiTempiRisposta = new DatiTempiRisposta();
  108.         if(configurazioneGenerale!=null && configurazioneGenerale.getTempiRispostaErogazione()!=null) {
  109.             if(configurazioneGenerale.getTempiRispostaErogazione().getConnectionTimeout()!=null) {
  110.                 datiTempiRisposta.setConnectionTimeout(configurazioneGenerale.getTempiRispostaErogazione().getConnectionTimeout());
  111.             }
  112.             else {
  113.                 datiTempiRisposta.setConnectionTimeout(properties.getConnectionTimeout_consegnaContenutiApplicativi());
  114.             }
  115.             if(configurazioneGenerale.getTempiRispostaErogazione().getReadTimeout()!=null) {
  116.                 datiTempiRisposta.setReadConnectionTimeout(configurazioneGenerale.getTempiRispostaErogazione().getReadTimeout());
  117.             }
  118.             else {
  119.                 datiTempiRisposta.setReadConnectionTimeout(properties.getReadConnectionTimeout_consegnaContenutiApplicativi());
  120.             }
  121.         }
  122.         else {
  123.             datiTempiRisposta.setConnectionTimeout(properties.getConnectionTimeout_consegnaContenutiApplicativi());
  124.             datiTempiRisposta.setReadConnectionTimeout(properties.getReadConnectionTimeout_consegnaContenutiApplicativi());
  125.         }
  126.         return datiTempiRisposta;
  127.     }
  128.     
  129.     public static DatiTempiRisposta readDatiTempiRisposta(TipoPdD tipoPdD, RequestInfo requestInfo) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  130.         // Prelevo la configurazione del Controllo del Traffico
  131.         ConfigurazionePdDManager configPdDManager = ConfigurazionePdDManager.getInstance();
  132.         ConfigurazioneGenerale configurazioneGenerale = configPdDManager.getConfigurazioneControlloTraffico(requestInfo);       
  133.         
  134.         
  135.         // Imposto i valori di default
  136.         DatiTempiRisposta datiTempiRisposta = new DatiTempiRisposta();
  137.         if(TipoPdD.DELEGATA.equals(tipoPdD)){
  138.             datiTempiRisposta.setConnectionTimeout(configurazioneGenerale.getTempiRispostaFruizione().getConnectionTimeout());
  139.             datiTempiRisposta.setReadConnectionTimeout(configurazioneGenerale.getTempiRispostaFruizione().getReadTimeout());
  140.             datiTempiRisposta.setAvgResponseTime(configurazioneGenerale.getTempiRispostaFruizione().getTempoMedioRisposta());
  141.         }
  142.         else{
  143.             datiTempiRisposta.setConnectionTimeout(configurazioneGenerale.getTempiRispostaErogazione().getConnectionTimeout());
  144.             datiTempiRisposta.setReadConnectionTimeout(configurazioneGenerale.getTempiRispostaErogazione().getReadTimeout());
  145.             datiTempiRisposta.setAvgResponseTime(configurazioneGenerale.getTempiRispostaErogazione().getTempoMedioRisposta());
  146.         }
  147.     
  148.         return datiTempiRisposta;
  149.     }
  150.     
  151.     public static void mergeTempiRisposta(DatiTempiRisposta datiTempiRisposta, Map<String, String> properties){
  152.         // Leggo i valori se fossero ridefiniti sul connettore
  153.         if(properties!=null && properties.size()>0){
  154.             
  155.             Integer connectionTimeout = null; 
  156.             Integer readTimeout = null; 
  157.             Integer avgResponseTime = null; 
  158.             Iterator<String> keys = properties.keySet().iterator();
  159.             while (keys.hasNext()) {
  160.                 String key = keys.next();
  161.                 if(key.equals(CostantiConnettori.CONNETTORE_CONNECTION_TIMEOUT)){
  162.                     connectionTimeout = Integer.parseInt(properties.get(key));
  163.                 }
  164.                 else if(key.endsWith(CostantiConnettori.CONNETTORE_READ_CONNECTION_TIMEOUT)){
  165.                     readTimeout = Integer.parseInt(properties.get(key));
  166.                 }
  167.                 else if(key.endsWith(CostantiConnettori.CONNETTORE_TEMPO_MEDIO_RISPOSTA)){
  168.                     avgResponseTime = Integer.parseInt(properties.get(key));
  169.                 }
  170.             }
  171.             if(connectionTimeout!=null){
  172.                 datiTempiRisposta.setConnectionTimeout(connectionTimeout);
  173.             }
  174.             if(readTimeout!=null){
  175.                 datiTempiRisposta.setReadConnectionTimeout(readTimeout);
  176.             }
  177.             if(avgResponseTime!=null){
  178.                 datiTempiRisposta.setAvgResponseTime(avgResponseTime);
  179.             }
  180.         }
  181.         
  182.     }
  183.     
  184.     public static DatiTempiRisposta getDatiTempiRisposta(InRequestProtocolContext context, DatiTransazione datiTransazione, RequestInfo requestInfo) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  185.         
  186.         DatiTempiRisposta datiTempiRisposta = readDatiTempiRisposta(context.getTipoPorta(), requestInfo);
  187.         
  188.         ConfigurazionePdDManager configPdDManager = ConfigurazionePdDManager.getInstance();
  189.         
  190.         if(TipoPdD.DELEGATA.equals(context.getTipoPorta())){
  191.             
  192.             setDatiTempiRispostaFruizione(configPdDManager, datiTempiRisposta,
  193.                     context, datiTransazione, requestInfo);
  194.             
  195.         }
  196.         else{
  197.             
  198.             setDatiTempiRispostaErogazione(configPdDManager, datiTempiRisposta,
  199.                     context, requestInfo);
  200.             
  201.         }
  202.         
  203.         return datiTempiRisposta;
  204.         
  205.     }
  206.     
  207.     private static void setDatiTempiRispostaFruizione(ConfigurazionePdDManager configPdDManager, DatiTempiRisposta datiTempiRisposta,
  208.             InRequestProtocolContext context, DatiTransazione datiTransazione, RequestInfo requestInfo) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  209.         try{
  210.             Connettore connettore = configPdDManager.getForwardRoute(datiTransazione.getSoggettoFruitore(),datiTransazione.getIdServizio(),false, requestInfo);
  211.             mergeTempiRisposta(datiTempiRisposta, connettore.getProperties());
  212.         }catch(Exception e){
  213.             // registro solamente l'errore su log.
  214.             // sicuramente avverrà un errore durante la gestione del messaggio
  215.             try{
  216.                 OpenSPCoop2Logger.getLoggerOpenSPCoopControlloTraffico(OpenSPCoop2Properties.getInstance().isControlloTrafficoDebug()).error(e.getMessage(),e);
  217.             }catch(Exception eLogger){
  218.                 context.getLogCore().error(e.getMessage(),e);
  219.             }
  220.         }
  221.     }
  222.     
  223.     private static void setDatiTempiRispostaErogazione(ConfigurazionePdDManager configPdDManager, DatiTempiRisposta datiTempiRisposta,
  224.             InRequestProtocolContext context, RequestInfo requestInfo) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  225.         try{
  226.             if(context.getIntegrazione()!=null && context.getIntegrazione().getIdPA()!=null) {
  227.                 IDPortaApplicativa idPA = context.getIntegrazione().getIdPA();
  228.                 PortaApplicativa pa = configPdDManager.getPortaApplicativa(idPA, requestInfo);
  229.                 if(pa.sizeServizioApplicativoList()>0) {
  230.                     IDServizioApplicativo idSA = new IDServizioApplicativo();
  231.                     idSA.setIdSoggettoProprietario(new IDSoggetto(pa.getTipoSoggettoProprietario(), pa.getNomeSoggettoProprietario()));
  232.                     idSA.setNome(pa.getServizioApplicativo(0).getNome()); // uso il primo
  233.                             
  234.                     ServizioApplicativo sa = configPdDManager.getServizioApplicativo(idSA, requestInfo);
  235.                     setConnettoreDatiTempiRispostaErogazione(context, sa, datiTempiRisposta);
  236.                 }
  237.             }
  238.         }catch(Exception e){
  239.             // registro solamente l'errore su log.
  240.             // sicuramente avverrà un errore durante la gestione del messaggio
  241.             try{
  242.                 OpenSPCoop2Logger.getLoggerOpenSPCoopControlloTraffico(OpenSPCoop2Properties.getInstance().isControlloTrafficoDebug()).error(e.getMessage(),e);
  243.             }catch(Exception eLogger){
  244.                 context.getLogCore().error(e.getMessage(),e);
  245.             }
  246.         }
  247.     }
  248.     private static void setConnettoreDatiTempiRispostaErogazione(InRequestProtocolContext context, ServizioApplicativo sa, DatiTempiRisposta datiTempiRisposta) {
  249.         
  250.         Connettore connettore = null;
  251.         
  252.         String scenarioCooperazione = context.getProtocollo().getScenarioCooperazione();
  253.         if(scenarioCooperazione!=null){
  254.             if(org.openspcoop2.protocol.engine.constants.Costanti.SCENARIO_CONSEGNA_CONTENUTI_APPLICATIVI.equals(scenarioCooperazione) ||
  255.                     org.openspcoop2.protocol.engine.constants.Costanti.SCENARIO_ASINCRONO_SIMMETRICO_CONSEGNA_RISPOSTA.equals(scenarioCooperazione) ||
  256.                     org.openspcoop2.protocol.engine.constants.Costanti.SCENARIO_ASINCRONO_ASIMMETRICO_POLLING.equals(scenarioCooperazione) ){
  257.                 if(sa.getRispostaAsincrona()!=null){
  258.                     connettore = sa.getRispostaAsincrona().getConnettore();
  259.                 }
  260.             }else{
  261.                 if(sa.getInvocazioneServizio()!=null){
  262.                     connettore = sa.getInvocazioneServizio().getConnettore();
  263.                 }
  264.             }
  265.         }
  266.         
  267.         if(connettore!=null){
  268.             mergeTempiRisposta(datiTempiRisposta, connettore.getProperties());
  269.         }
  270.         
  271.     }
  272. }
Created with JaCoCo 0.8.8.202204050719