ConnettoreMessageBoxApiHelper.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.core.config.rs.server.api.impl.erogazioni;

  22. import java.util.Map;

  24. import org.openspcoop2.core.config.Credenziali;
  25. import org.openspcoop2.core.config.InvocazionePorta;
  26. import org.openspcoop2.core.config.ServizioApplicativo;
  27. import org.openspcoop2.core.config.constants.CostantiConfigurazione;
  28. import org.openspcoop2.core.config.constants.CredenzialeTipo;
  29. import org.openspcoop2.core.config.constants.StatoFunzionalita;
  30. import org.openspcoop2.core.config.rs.server.model.ConnettoreConfigurazioneHttpBasic;
  31. import org.openspcoop2.core.config.rs.server.model.ConnettoreEnum;
  32. import org.openspcoop2.core.config.rs.server.model.ConnettoreMessageBox;
  33. import org.openspcoop2.core.config.rs.server.model.OneOfApplicativoServerConnettore;
  34. import org.openspcoop2.core.config.rs.server.model.OneOfConnettoreErogazioneConnettore;
  35. import org.openspcoop2.core.config.rs.server.model.OneOfConnettoreFruizioneConnettore;
  36. import org.openspcoop2.core.constants.TipiConnettore;
  37. import org.openspcoop2.core.registry.Connettore;
  38. import org.openspcoop2.utils.service.fault.jaxrs.FaultCode;
  39. import org.openspcoop2.web.ctrlstat.servlet.connettori.ConnettoriCostanti;
  40. import org.openspcoop2.web.ctrlstat.servlet.sa.ServiziApplicativiCostanti;
  41. import org.openspcoop2.web.lib.mvc.ServletUtils;

  43. /**
  44.  * ConnettoreMessageBoxApiHelper
  45.  * 
  46.  * @author $Author$
  47.  * @version $Rev$, $Date$
  48.  * 
  49.  */
  50. public class ConnettoreMessageBoxApiHelper extends AbstractConnettoreApiHelper<ConnettoreMessageBox> {

  52.     @Override
  53.     public boolean connettoreCheckData(ConnettoreMessageBox conn, ErogazioniEnv env, boolean erogazione) throws Exception {
  54.         return true;
  55.     }

  57.     @Override
  58.     protected org.openspcoop2.core.config.Connettore buildConnettoreConfigurazione(ServizioApplicativo sa, ErogazioniEnv env, ConnettoreMessageBox connettore, String oldConnT) throws Exception {
  59.         
  60.         Credenziali credenziali = new Credenziali();
  61.         credenziali.setTipo(CredenzialeTipo.BASIC);
  62.         credenziali.setUser(connettore.getAutenticazioneHttp().getUsername());
  63.         credenziali.setPassword(connettore.getAutenticazioneHttp().getPassword());
  64.         if(sa.getInvocazionePorta() == null) {
  65.             sa.setInvocazionePorta(new InvocazionePorta());
  66.         }
  67.         sa.getInvocazionePorta().addCredenziali(credenziali);
  68.         sa.getInvocazioneServizio().setGetMessage(StatoFunzionalita.ABILITATO);
  69.         
  70.         String protocollo = env.soggettiCore.getProtocolloAssociatoTipoSoggetto(sa.getTipoSoggettoProprietario());

  72.         env.requestWrapper.overrideParameter(ServiziApplicativiCostanti.PARAMETRO_SERVIZI_APPLICATIVI_MESSAGE_BOX, CostantiConfigurazione.ABILITATO.toString());
  73.         env.requestWrapper.overrideParameter(ConnettoriCostanti.PARAMETRO_CREDENZIALI_AUTENTICAZIONE_USERNAME, connettore.getAutenticazioneHttp().getUsername());
  74.         env.requestWrapper.overrideParameter(ConnettoriCostanti.PARAMETRO_CREDENZIALI_AUTENTICAZIONE_PASSWORD, connettore.getAutenticazioneHttp().getPassword());
  75.         env.requestWrapper.overrideParameter(ServiziApplicativiCostanti.PARAMETRO_SERVIZI_APPLICATIVI_SBUSTAMENTO_SOAP, CostantiConfigurazione.DISABILITATO.toString());
  76.         env.requestWrapper.overrideParameter(ServiziApplicativiCostanti.PARAMETRO_SERVIZI_APPLICATIVI_SBUSTAMENTO_INFO_PROTOCOLLO_RICHIESTA, CostantiConfigurazione.DISABILITATO.toString());
  77.         env.requestWrapper.overrideParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_ENDPOINT_TYPE, TipiConnettore.DISABILITATO.getNome());

  79.         boolean ok = env.saHelper.servizioApplicativoEndPointCheckData(protocollo, null, sa);
  80.         
  81.         if(!ok) {
  82.             throw FaultCode.RICHIESTA_NON_VALIDA.toException(env.saHelper.getPd().getMessage());
  83.         }
  84.         return super.buildConnettoreConfigurazione(sa, env, connettore, oldConnT);
  85.     }
  86.     
  87.     @Override
  88.     public Connettore fillConnettoreRegistro(org.openspcoop2.core.registry.Connettore regConnettore,
  89.             ErogazioniEnv env,
  90.             ConnettoreMessageBox conn,
  91.             String oldConnT) throws Exception {
  92.         env.apsHelper.fillConnettore(
  93.                 regConnettore, 
  94.                 "false",                // this.connettoreDebug,
  95.                 TipiConnettore.DISABILITATO.getNome(),          // endpointtype
  96.                 oldConnT,                       // oldConnT
  97.                 "",                     // tipoConn Personalizzato
  98.                 null, // this.url,
  99.                 null,   // this.nome,
  100.                 null,   // this.tipo,
  101.                 null,
  102.                 null,
  103.                 null,   // this.initcont, 
  104.                 null,   // this.urlpgk,
  105.                 null, // this.url, 
  106.                 null,   // this.connfact,
  107.                 null,   // this.sendas,
  108.                 null, // this.httpsurl, 
  109.                 null,               // this.httpstipologia
  110.                 false,  // this.httpshostverify,
  111.                 ConnettoriCostanti.DEFAULT_CONNETTORE_HTTPS_TRUST_VERIFY_CERTS, // httpsTrustVerifyCert
  112.                 null,               // this.httpspath
  113.                 null,   // this.httpstipo,
  114.                 null,           // this.httpspwd,
  115.                 null,                   // this.httpsalgoritmo
  116.                 false,
  117.                 null,           // this.httpskeystore, 
  118.                 "",                                                                 //  this.httpspwdprivatekeytrust
  119.                 null,               // pathkey
  120.                 null,       // this.httpstipokey
  121.                 null,           // this.httpspwdkey 
  122.                 null,               // this.httpspwdprivatekey,  
  123.                 null,               // this.httpsalgoritmokey,
  124.                 null,                   // httpsKeyAlias
  125.                 null,                   // httpsTrustStoreCRLs
  126.                 null,                   // httpsTrustStoreOCSPPolicy
  127.                 null,                   // httpsKeyStoreBYOKPolicy
  128.             
  129.                 ServletUtils.boolToCheckBoxStatus( false ), 
  130.                 null,
  131.                 null,
  132.                 null,
  133.                 null,
  134.                 
  135.                 ServletUtils.boolToCheckBoxStatus( false ), 
  136.                 null,   // this.tempiRisposta_connectionTimeout, 
  137.                 null, //null,   // this.tempiRisposta_readTimeout, 
  138.                 null,   // this.tempiRisposta_tempoMedioRisposta,
  139.                 "no",   // this.opzioniAvanzate, 
  140.                 "",     // this.transfer_mode, 
  141.                 "",     // this.transfer_mode_chunk_size, 
  142.                 "",     // this.redirect_mode, 
  143.                 "",     // this.redirect_max_hop,
  144.                 null,   // this.requestOutputFileName,
  145.                 null,   // this.requestOutputFileName_permissions
  146.                 null,   // this.requestOutputFileNameHeaders,
  147.                 null,   // this.requestOutputFileNameHeaders_permissions
  148.                 null,   // this.requestOutputParentDirCreateIfNotExists,
  149.                 null,   // this.requestOutputOverwriteIfExists,
  150.                 null,   // this.responseInputMode, 
  151.                 null,   // this.responseInputFileName, 
  152.                 null,   // this.responseInputFileNameHeaders, 
  153.                 null,   // this.responseInputDeleteAfterRead, 
  154.                 null,   // this.responseInputWaitTime,
  155.                 null,   // tokenPolicy
  156.                 null, null, // apiKeyHeader,  apiKeyValue
  157.                 null, null, // appIdHeader, appIdValue
  158.                 
  159.                 null, // connettoreStatusParams
  160.                 null // listExtendedConnettore
  161.                 );      
  162.         return regConnettore;
  163.     }

  165.     @Override
  166.     public org.openspcoop2.core.config.Connettore buildConnettoreConfigurazione(
  167.             org.openspcoop2.core.config.Connettore regConnettore, ErogazioniEnv env, ConnettoreMessageBox conn,
  168.             String oldConnType) throws Exception {

  170.         env.apsHelper.fillConnettore(
  171.                 regConnettore, 
  172.                 "false",                // this.connettoreDebug,
  173.                 TipiConnettore.DISABILITATO.getNome(),          // endpointtype
  174.                 oldConnType,                        // oldConnT
  175.                 "",                     // tipoConn Personalizzato
  176.                 null, // this.url,
  177.                 null,   // this.nome,
  178.                 null,   // this.tipo,
  179.                 null,
  180.                 null,
  181.                 null,   // this.initcont, 
  182.                 null,   // this.urlpgk,
  183.                 null, // this.url, 
  184.                 null,   // this.connfact,
  185.                 null,   // this.sendas,
  186.                 null, // this.httpsurl, 
  187.                 null,               // this.httpstipologia
  188.                 false,  // this.httpshostverify,
  189.                 ConnettoriCostanti.DEFAULT_CONNETTORE_HTTPS_TRUST_VERIFY_CERTS, // httpsTrustVerifyCert
  190.                 null,               // this.httpspath
  191.                 null,   // this.httpstipo,
  192.                 null,           // this.httpspwd,
  193.                 null,                   // this.httpsalgoritmo
  194.                 false,
  195.                 null,           // this.httpskeystore, 
  196.                 "",                                                                 //  this.httpspwdprivatekeytrust
  197.                 null,               // pathkey
  198.                 null,       // this.httpstipokey
  199.                 null,           // this.httpspwdkey 
  200.                 null,               // this.httpspwdprivatekey,  
  201.                 null,               // this.httpsalgoritmokey,
  202.                 null,                   // httpsKeyAlias
  203.                 null,                   // httpsTrustStoreCRLs
  204.                 null,                   // httpsTrustStoreOCSPPolicy
  205.                 null,                   // httpsKeyStoreBYOKPolicy
  206.             
  207.                 ServletUtils.boolToCheckBoxStatus( false ), 
  208.                 null,
  209.                 null,
  210.                 null,
  211.                 null,
  212.                 
  213.                 ServletUtils.boolToCheckBoxStatus( false ), 
  214.                 null,   // this.tempiRisposta_connectionTimeout, 
  215.                 null, //null,   // this.tempiRisposta_readTimeout, 
  216.                 null,   // this.tempiRisposta_tempoMedioRisposta,
  217.                 "no",   // this.opzioniAvanzate, 
  218.                 "",     // this.transfer_mode, 
  219.                 "",     // this.transfer_mode_chunk_size, 
  220.                 "",     // this.redirect_mode, 
  221.                 "",     // this.redirect_max_hop,
  222.                 null,   // this.requestOutputFileName,
  223.                 null,   // this.requestOutputFileName_permissions
  224.                 null,   // this.requestOutputFileNameHeaders,
  225.                 null,   // this.requestOutputFileNameHeaders_permissions
  226.                 null,   // this.requestOutputParentDirCreateIfNotExists,
  227.                 null,   // this.requestOutputOverwriteIfExists,
  228.                 null,   // this.responseInputMode, 
  229.                 null,   // this.responseInputFileName, 
  230.                 null,   // this.responseInputFileNameHeaders, 
  231.                 null,   // this.responseInputDeleteAfterRead, 
  232.                 null,   // this.responseInputWaitTime,
  233.                 null,   // tokenPolicy
  234.                 null, null, // apiKeyHeader,  apiKeyValue
  235.                 null, null, // appIdHeader, appIdValue
  236.                 
  237.                 null, // connettoreStatusParams
  238.                 null // listExtendedConnettore
  239.                 );      
  240.         return regConnettore;
  241.     }

  243.     @Override
  244.     protected ConnettoreMessageBox buildConnettore(ServizioApplicativo sa) {
  245.         ConnettoreMessageBox c = new ConnettoreMessageBox();
  246.         
  247.         c.setTipo(ConnettoreEnum.MESSAGE_BOX);
  248.         
  249.         ConnettoreConfigurazioneHttpBasic autenticazioneHttp = new ConnettoreConfigurazioneHttpBasic();
  250.         
  251.         if(sa.getInvocazionePorta().getCredenzialiList().size() > 0) {
  252.             autenticazioneHttp.setUsername(sa.getInvocazionePorta().getCredenziali(0).getUser());
  253.             autenticazioneHttp.setPassword(sa.getInvocazionePorta().getCredenziali(0).getPassword());
  254.         }
  255.         
  256.         c.setAutenticazioneHttp(autenticazioneHttp);
  257.         return c;
  258.     }

  260.     @Override
  261.     public ConnettoreMessageBox buildConnettore(Map<String, String> props, String tipo) {
  262.         //non utilizzabile
  263.         return null; //TODO eccezione
  264.     }

  266.     @Override
  267.     public String getUrlConnettore(Map<String, String> props, String tipoConnettore) throws Exception {
  268.         return "disabilitato [MessageBox]";
  269.     }

  271.     @Override
  272.     protected ConnettoreMessageBox getConnettore(OneOfConnettoreErogazioneConnettore conn) throws Exception {
  273.         return (ConnettoreMessageBox) conn;
  274.     }

  276.     @Override
  277.     protected ConnettoreMessageBox getConnettore(OneOfConnettoreFruizioneConnettore conn) throws Exception {
  278.         return (ConnettoreMessageBox) conn;
  279.     }

  281.     @Override
  282.     protected ConnettoreMessageBox getConnettore(OneOfApplicativoServerConnettore conn) throws Exception {
  283.         return (ConnettoreMessageBox) conn;
  284.     }

  286. }
Created with JaCoCo 0.8.8.202204050719