ConnettoreJmsApiHelper.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 static org.openspcoop2.utils.service.beans.utils.BaseHelper.evalnull;

  24. import java.util.List;
  25. import java.util.Map;

  27. import org.openspcoop2.core.config.rs.server.model.ConnettoreEnum;
  28. import org.openspcoop2.core.config.rs.server.model.ConnettoreJms;
  29. import org.openspcoop2.core.config.rs.server.model.ConnettoreJmsSendAsEnum;
  30. import org.openspcoop2.core.config.rs.server.model.ConnettoreJmsTipoEnum;
  31. import org.openspcoop2.core.config.rs.server.model.OneOfApplicativoServerConnettore;
  32. import org.openspcoop2.core.config.rs.server.model.OneOfConnettoreErogazioneConnettore;
  33. import org.openspcoop2.core.config.rs.server.model.OneOfConnettoreFruizioneConnettore;
  34. import org.openspcoop2.core.constants.CostantiConnettori;
  35. import org.openspcoop2.core.constants.CostantiDB;
  36. import org.openspcoop2.core.constants.TipiConnettore;
  37. import org.openspcoop2.core.registry.Connettore;
  38. import org.openspcoop2.web.ctrlstat.costanti.ConnettoreServletType;
  39. import org.openspcoop2.web.ctrlstat.plugins.ExtendedConnettore;
  40. import org.openspcoop2.web.ctrlstat.plugins.servlet.ServletExtendedConnettoreUtils;
  41. import org.openspcoop2.web.ctrlstat.servlet.connettori.ConnettoriCostanti;
  42. import org.openspcoop2.web.lib.mvc.ServletUtils;

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

  53.     @Override
  54.     protected ConnettoreJms getConnettore(OneOfConnettoreErogazioneConnettore conn) throws Exception {
  55.         return (ConnettoreJms) conn;
  56.     }

  58.     @Override
  59.     protected ConnettoreJms getConnettore(OneOfConnettoreFruizioneConnettore conn) throws Exception {
  60.         return (ConnettoreJms) conn;
  61.     }

  63.     @Override
  64.     protected ConnettoreJms getConnettore(OneOfApplicativoServerConnettore conn) throws Exception {
  65.         return (ConnettoreJms) conn;
  66.     }

  68.     @Override
  69.     public boolean connettoreCheckData(ConnettoreJms conn, ErogazioniEnv env, boolean erogazione) throws Exception {


  72.         final String endpointtype = TipiConnettore.JMS.getNome();
  73.         
  74.         org.openspcoop2.core.registry.Connettore conTmp = null;
  75.         List<ExtendedConnettore> listExtendedConnettore = 
  76.                 ServletExtendedConnettoreUtils.getExtendedConnettore(conTmp, ConnettoreServletType.ACCORDO_SERVIZIO_PARTE_SPECIFICA_ADD, env.apsHelper, 
  77.                         null, false, endpointtype);

  79.         String sendAs = conn.getSendAs().equals(ConnettoreJmsSendAsEnum.BYTES) ? CostantiConnettori.CONNETTORE_JMS_SEND_AS_BYTES_MESSAGE : CostantiConnettori.CONNETTORE_JMS_SEND_AS_TEXT_MESSAGE;
  80.         return env.saHelper.endPointCheckData(
  81.                 null,
  82.                 env.tipo_protocollo,
  83.                 erogazione,
  84.                 endpointtype,
  85.                 null,
  86.                 conn.getNome(), // this.nome,
  87.                 conn.getTipoCoda().toString(),  // this.tipo,
  88.                 conn.getUtente(), 
  89.                 conn.getPassword(), 
  90.                 conn.getJndiInitialContext(),   // this.initcont, 
  91.                 conn.getJndiUrlPgkPrefixes(),   // this.urlpgk,
  92.                 conn.getJndiProviderUrl(),   // this.url, 
  93.                 conn.getConnectionFactory(),    // this.connfact,
  94.                 sendAs, // this.sendas
  95.                 null,                                                   // this.httpsurl,
  96.                 null,   // httpsConf.getTipologia().toString(), 
  97.                 false,      // this.httpshostverify,
  98.                 ConnettoriCostanti.DEFAULT_CONNETTORE_HTTPS_TRUST_VERIFY_CERTS, // httpsTrustVerifyCert
  99.                 null,   // this.httpspath
  100.                 null,   // this.httpstipo,
  101.                 null,   // this.httpspwd,
  102.                 null,   // this.httpsalgoritmo
  103.                 false, 
  104.                 null,
  105.                 "",                                                                     // httpspwdprivatekeytrust, 
  106.                 null,   // pathkey
  107.                 null,   // this.httpstipokey
  108.                 null,   // this.httpspwdkey 
  109.                 null,   // this.httpspwdprivatekey,  
  110.                 null,   // this.httpsalgoritmokey, 
  111.                 null,   // httpsKeyAlias
  112.                 null,   // httpsTrustStoreCRLs
  113.                 null,   // httpsTrustStoreOCSPPolicy
  114.                 null,   // httpsKeyStoreBYOKPolicy
  115.                 null,                                                               //  tipoconn (personalizzato)
  116.                 ServletUtils.boolToCheckBoxStatus(false),                                           //autenticazioneHttp,
  117.                 ServletUtils.boolToCheckBoxStatus(false),   
  118.                 null,   // evalnull( () -> proxy.getHostname() ),
  119.                 null,   // evalnull( () -> proxy.getPorta().toString() ),
  120.                 null,   // evalnull( () -> proxy.getUsername() ),
  121.                 null,   // evalnull( () -> proxy.getPassword() ),
  122.                 ServletUtils.boolToCheckBoxStatus(false), //ServletUtils.boolToCheckBoxStatus( tempiRisposta_enabled ), 
  123.                 null,   // evalnull( () -> timeoutConf.getConnectionTimeout().toString()),  // this.tempiRisposta_connectionTimeout, 
  124.                 null,   // evalnull( () -> timeoutConf.getConnectionReadTimeout().toString()), //null,  // this.tempiRisposta_readTimeout, 
  125.                 null,   // evalnull( () -> timeoutConf.getTempoMedioRisposta().toString()), // this.tempiRisposta_tempoMedioRisposta,
  126.                 "no",   // this.opzioniAvanzate, 
  127.                 "",     // this.transfer_mode, 
  128.                 "",     // this.transfer_mode_chunk_size, 
  129.                 "",     // this.redirect_mode, 
  130.                 "",     // this.redirect_max_hop,
  131.                 null,   // requestOutputFileName,
  132.                 null,   // this.requestOutputFileName_permissions
  133.                 null,   // this.requestOutputFileNameHeaders,
  134.                 null,   // this.requestOutputFileNameHeaders_permissions
  135.                 null,   // requestOutputParentDirCreateIfNotExists, 
  136.                 null,   // requestOutputOverwriteIfExists,
  137.                 null,   // responseInputMode,
  138.                 null,   // responseInputFileName,
  139.                 null,   // responseInputFileNameHeaders,
  140.                 null,   // responseInputDeleteAfterRead,
  141.                 null,   // responseInputWaitTime,
  142.                 false, // autenticazioneToken
  143.                 null, // tokenPolicy
  144.                 null, // autenticazioneApiKey
  145.                 false, // useOAS3Names
  146.                 false, // useAppId
  147.                 null, // apiKeyHeader
  148.                 null, // apiKey,
  149.                 null, // appIdHeader,
  150.                 null, // appId,
  151.                 listExtendedConnettore, // listExtendedConnettore
  152.                 false, // erogazioneServizioApplicativoServerEnabled, 
  153.                 null // erogazioneServizioApplicativoServer
  154.             );
  155.     }

  157.     @Override
  158.     public Connettore fillConnettoreRegistro(org.openspcoop2.core.registry.Connettore regConnettore,
  159.             ErogazioniEnv env,
  160.             ConnettoreJms conn,
  161.             String oldConnT) throws Exception {
  162.         final String endpointtype = TipiConnettore.JMS.getNome();
  163.         
  164.         org.openspcoop2.core.registry.Connettore conTmp = null;
  165.         List<ExtendedConnettore> listExtendedConnettore = 
  166.                 ServletExtendedConnettoreUtils.getExtendedConnettore(conTmp, ConnettoreServletType.ACCORDO_SERVIZIO_PARTE_SPECIFICA_ADD, env.apsHelper, 
  167.                         null, false, endpointtype);


  170.         String sendAs = conn.getSendAs().equals(ConnettoreJmsSendAsEnum.BYTES) ? CostantiConnettori.CONNETTORE_JMS_SEND_AS_BYTES_MESSAGE : CostantiConnettori.CONNETTORE_JMS_SEND_AS_TEXT_MESSAGE;

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

  243.     @Override
  244.     public org.openspcoop2.core.config.Connettore buildConnettoreConfigurazione(
  245.             org.openspcoop2.core.config.Connettore regConnettore, ErogazioniEnv env, ConnettoreJms conn,
  246.             String oldConnType) throws Exception {

  248.         final String endpointtype = TipiConnettore.JMS.getNome();
  249.         
  250.         org.openspcoop2.core.registry.Connettore conTmp = null;
  251.         List<ExtendedConnettore> listExtendedConnettore = 
  252.                 ServletExtendedConnettoreUtils.getExtendedConnettore(conTmp, ConnettoreServletType.ACCORDO_SERVIZIO_PARTE_SPECIFICA_ADD, env.apsHelper, 
  253.                         null, false, endpointtype);


  256.         String sendAs = conn.getSendAs().equals(ConnettoreJmsSendAsEnum.BYTES) ? CostantiConnettori.CONNETTORE_JMS_SEND_AS_BYTES_MESSAGE : CostantiConnettori.CONNETTORE_JMS_SEND_AS_TEXT_MESSAGE;

  258.         env.apsHelper.fillConnettore(
  259.                 regConnettore, 
  260.                 conn.isDebug() != null && conn.isDebug() ? "true" : "false",                // this.connettoreDebug,
  261.                 endpointtype,           // endpointtype
  262.                 oldConnType,            // oldConnT
  263.                 "",                     // tipoConn Personalizzato
  264.                 null, // this.url,
  265.                 conn.getNome(), // this.nome,
  266.                 conn.getTipoCoda().toString(),  // this.tipo,
  267.                 conn.getUtente(), 
  268.                 conn.getPassword(), 
  269.                 conn.getJndiInitialContext(),   // this.initcont, 
  270.                 conn.getJndiUrlPgkPrefixes(),   // this.urlpgk,
  271.                 conn.getJndiProviderUrl(),   // this.url, 
  272.                 conn.getConnectionFactory(),    // this.connfact,
  273.                 sendAs, // this.sendas
  274.                 null,                                               // this.httpsurl, 
  275.                 null,  //this.httpstipologia
  276.                 false,  // this.httpshostverify,
  277.                 ConnettoriCostanti.DEFAULT_CONNETTORE_HTTPS_TRUST_VERIFY_CERTS, // httpsTrustVerifyCert
  278.                 null,  // this.httpspath
  279.                 null,  //this.httpstipo,
  280.                 null,  //this.httpspwd,
  281.                 null,  // this.httpsalgoritmo
  282.                 false,
  283.                 null, // this.httpskeystore, 
  284.                 "",                                                                 //  this.httpspwdprivatekeytrust
  285.                 null,  //pathkey
  286.                 null,  //this.httpstipokey
  287.                 null,  //this.httpspwdkey 
  288.                 null,  //this.httpspwdprivatekey,  
  289.                 null,  //this.httpsalgoritmokey,
  290.                 null,  //httpsKeyAlias
  291.                 null,  //httpsTrustStoreCRLs
  292.                 null,  //httpsTrustStoreOCSPPolicy
  293.                 null,  //httpsKeyStoreBYOKPolicy
  294.             
  295.                 ServletUtils.boolToCheckBoxStatus( false ), 
  296.                 null,
  297.                 null,
  298.                 null,
  299.                 null,
  300.                 ServletUtils.boolToCheckBoxStatus( false ), 
  301.                 null,
  302.                 null,
  303.                 null,
  304.                 "no",   // this.opzioniAvanzate, 
  305.                 "",     // this.transfer_mode, 
  306.                 "",     // this.transfer_mode_chunk_size, 
  307.                 "",     // this.redirect_mode, 
  308.                 "",     // this.redirect_max_hop,
  309.                 null,   // this.requestOutputFileName,
  310.                 null,   // this.requestOutputFileName_permissions
  311.                 null,   // this.requestOutputFileNameHeaders,
  312.                 null,   // this.requestOutputFileNameHeaders_permissions
  313.                 null,   // this.requestOutputParentDirCreateIfNotExists,
  314.                 null,   // this.requestOutputOverwriteIfExists,
  315.                 null,   // this.responseInputMode, 
  316.                 null,   // this.responseInputFileName, 
  317.                 null,   // this.responseInputFileNameHeaders, 
  318.                 null,   // this.responseInputDeleteAfterRead, 
  319.                 null,   // this.responseInputWaitTime,
  320.                 null,   // tokenPolicy
  321.                 null, null, // apiKeyHeader,  apiKeyValue
  322.                 null, null, // appIdHeader, appIdValue
  323.                 
  324.                 null, // connettoreStatusParams
  325.                 listExtendedConnettore);        
  326.         return regConnettore;
  327.     }

  329.     @Override
  330.     public ConnettoreJms buildConnettore(Map<String, String> props, String tipo) {
  331.         ConnettoreJms c = new ConnettoreJms();
  332.         
  333.         c.setTipo(ConnettoreEnum.JMS);
  334.         c.setDebug(Boolean.parseBoolean(props.get(CostantiDB.CONNETTORE_DEBUG)));
  335.         
  336.         c.setNome(props.get(CostantiDB.CONNETTORE_HTTP_LOCATION));
  337.         c.setTipoCoda(ConnettoreJmsTipoEnum.fromValue(props.get(CostantiDB.CONNETTORE_JMS_TIPO)));
  338.         String jmsSendAs = props.get(CostantiDB.CONNETTORE_JMS_SEND_AS);
  339.         if(jmsSendAs.equals(CostantiConnettori.CONNETTORE_JMS_SEND_AS_BYTES_MESSAGE)) {
  340.             c.setSendAs(ConnettoreJmsSendAsEnum.BYTES);
  341.         } else if(jmsSendAs.equals(CostantiConnettori.CONNETTORE_JMS_SEND_AS_TEXT_MESSAGE)) {
  342.             c.setSendAs(ConnettoreJmsSendAsEnum.TEXT);
  343.         }
  344.         c.setConnectionFactory(props.get(CostantiDB.CONNETTORE_JMS_CONNECTION_FACTORY));
  345.         
  346.         c.setUtente(evalnull( () -> props.get(CostantiDB.CONNETTORE_USER)));
  347.         c.setPassword(evalnull( () -> props.get(CostantiDB.CONNETTORE_PWD)));

  349.         c.setJndiInitialContext(props.get(CostantiDB.CONNETTORE_JMS_CONTEXT_JAVA_NAMING_FACTORY_INITIAL));
  350.         c.setJndiUrlPgkPrefixes(props.get(CostantiDB.CONNETTORE_JMS_CONTEXT_JAVA_NAMING_FACTORY_URL_PKG));
  351.         c.setJndiProviderUrl(props.get(CostantiDB.CONNETTORE_JMS_CONTEXT_JAVA_NAMING_PROVIDER_URL));
  352.         
  353.         return c;
  354.     }

  356.     @Override
  357.     public String getUrlConnettore(Map<String, String> properties, String tipoConnettore) throws Exception {
  358.         return "[jms] " + properties.get(CostantiDB.CONNETTORE_HTTP_LOCATION);
  359.     }

  361. }
Created with JaCoCo 0.8.8.202204050719