ConnettorePluginApiHelper.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.ArrayList;
  23. import java.util.Arrays;
  24. import java.util.List;
  25. import java.util.Map;
  26. import java.util.Map.Entry;

  28. import org.openspcoop2.core.commons.Filtri;
  29. import org.openspcoop2.core.commons.Liste;
  30. import org.openspcoop2.core.config.rs.server.model.ConnettoreEnum;
  31. import org.openspcoop2.core.config.rs.server.model.ConnettorePlugin;
  32. import org.openspcoop2.core.config.rs.server.model.OneOfApplicativoServerConnettore;
  33. import org.openspcoop2.core.config.rs.server.model.OneOfConnettoreErogazioneConnettore;
  34. import org.openspcoop2.core.config.rs.server.model.OneOfConnettoreFruizioneConnettore;
  35. import org.openspcoop2.core.constants.CostantiDB;
  36. import org.openspcoop2.core.constants.TipiConnettore;
  37. import org.openspcoop2.core.plugins.Plugin;
  38. import org.openspcoop2.core.plugins.constants.TipoPlugin;
  39. import org.openspcoop2.core.registry.Connettore;
  40. import org.openspcoop2.utils.service.fault.jaxrs.FaultCode;
  41. import org.openspcoop2.web.ctrlstat.core.ConsoleSearch;
  42. import org.openspcoop2.web.ctrlstat.servlet.config.ConfigurazioneCore;
  43. import org.openspcoop2.web.ctrlstat.servlet.connettori.ConnettoriCostanti;
  44. import org.openspcoop2.web.lib.mvc.ServletUtils;

  46. /**
  47.  * ConnettorePluginApiHelper
  48.  * 
  49.  * @author $Author$
  50.  * @version $Rev$, $Date$
  51.  * 
  52.  */
  53. public class ConnettorePluginApiHelper extends AbstractConnettoreApiHelper<ConnettorePlugin> {

  55.     @Override
  56.     protected ConnettorePlugin getConnettore(OneOfConnettoreErogazioneConnettore conn) throws Exception {
  57.         return (ConnettorePlugin) conn;
  58.     }

  60.     @Override
  61.     protected ConnettorePlugin getConnettore(OneOfConnettoreFruizioneConnettore conn) throws Exception {
  62.         return (ConnettorePlugin) conn;
  63.     }

  65.     @Override
  66.     protected ConnettorePlugin getConnettore(OneOfApplicativoServerConnettore conn) throws Exception {
  67.         return (ConnettorePlugin) conn;
  68.     }

  70.     @Override
  71.     public boolean connettoreCheckData(ConnettorePlugin conn, ErogazioniEnv env, boolean erogazione) throws Exception {
  72.         ConsoleSearch ricerca = new ConsoleSearch(true);
  73.         ricerca.addFilter(Liste.CONFIGURAZIONE_PLUGINS_CLASSI,  Filtri.FILTRO_TIPO_PLUGIN_CLASSI, TipoPlugin.CONNETTORE.toString());

  75.         ConfigurazioneCore confCore = new ConfigurazioneCore(env.stationCore);

  77.         List<Plugin> listaTmp = confCore.pluginsClassiList(ricerca);

  79.         if(!listaTmp.stream().anyMatch(p -> p.getTipo().equals(conn.getPlugin()))) {
  80.             throw FaultCode.RICHIESTA_NON_VALIDA.toException("Tipo plugin ["+conn.getPlugin()+"] non trovato");
  81.         }
  82.         
  83.         
  84.         return env.saHelper.endPointCheckData(
  85.                 null,
  86.                 env.tipo_protocollo,
  87.                 erogazione,
  88.                 TipiConnettore.CUSTOM.getNome(),
  89.                 null,
  90.                 null,   // nome
  91.                 null,   // tipo
  92.                 null,   // httpConf.getUsername()
  93.                 null,   // httpConf.getPassword()
  94.                 null,   // this.initcont, 
  95.                 null,   // this.urlpgk,
  96.                 null,   // provurl jms,
  97.                 null,   // connfact, 
  98.                 null,   // sendas, 
  99.                 null,                                                   // this.httpsurl,
  100.                 null,   // httpsConf.getTipologia().toString(), 
  101.                 false,      // this.httpshostverify,
  102.                 ConnettoriCostanti.DEFAULT_CONNETTORE_HTTPS_TRUST_VERIFY_CERTS, // httpsTrustVerifyCert
  103.                 null,   // this.httpspath
  104.                 null,   // this.httpstipo,
  105.                 null,   // this.httpspwd,
  106.                 null,   // this.httpsalgoritmo
  107.                 false, 
  108.                 null,
  109.                 "",                                                                     // httpspwdprivatekeytrust, 
  110.                 null,   // pathkey
  111.                 null,   // this.httpstipokey
  112.                 null,   // this.httpspwdkey 
  113.                 null,   // this.httpspwdprivatekey,  
  114.                 null,   // this.httpsalgoritmokey, 
  115.                 null,   // httpsKeyAlias
  116.                 null,   // httpsTrustStoreCRLs
  117.                 null,   // httpsTrustStoreOCSPPolicy
  118.                 null,   // httpsKeyStoreBYOKPolicy
  119.                 conn.getPlugin(),                                                               //  tipoconn (personalizzato)
  120.                 ServletUtils.boolToCheckBoxStatus(false),                                           //autenticazioneHttp,
  121.                 ServletUtils.boolToCheckBoxStatus(false),   
  122.                 null,   // evalnull( () -> proxy.getHostname() ),
  123.                 null,   // evalnull( () -> proxy.getPorta().toString() ),
  124.                 null,   // evalnull( () -> proxy.getUsername() ),
  125.                 null,   // evalnull( () -> proxy.getPassword() ),
  126.                 ServletUtils.boolToCheckBoxStatus(false), //ServletUtils.boolToCheckBoxStatus( tempiRisposta_enabled ), 
  127.                 null,   // evalnull( () -> timeoutConf.getConnectionTimeout().toString()),  // this.tempiRisposta_connectionTimeout, 
  128.                 null,   // evalnull( () -> timeoutConf.getConnectionReadTimeout().toString()), //null,  // this.tempiRisposta_readTimeout, 
  129.                 null,   // evalnull( () -> timeoutConf.getTempoMedioRisposta().toString()), // this.tempiRisposta_tempoMedioRisposta,
  130.                 "no",   // this.opzioniAvanzate, 
  131.                 "",     // this.transfer_mode, 
  132.                 "",     // this.transfer_mode_chunk_size, 
  133.                 "",     // this.redirect_mode, 
  134.                 "",     // this.redirect_max_hop,
  135.                 null,   // this.requestOutputFileName,
  136.                 null,   // this.requestOutputFileName_permissions
  137.                 null,   // this.requestOutputFileNameHeaders,
  138.                 null,   // this.requestOutputFileNameHeaders_permissions
  139.                 null,   // this.requestOutputParentDirCreateIfNotExists,
  140.                 null,   // this.requestOutputOverwriteIfExists,
  141.                 null,   // this.responseInputMode, 
  142.                 null,   // this.responseInputFileName, 
  143.                 null,   // this.responseInputFileNameHeaders, 
  144.                 null,   // this.responseInputDeleteAfterRead, 
  145.                 null,   // this.responseInputWaitTime,
  146.                 false, // autenticazioneToken
  147.                 null, // tokenPolicy
  148.                 null, // autenticazioneApiKey
  149.                 false, // useOAS3Names
  150.                 false, // useAppId
  151.                 null, // apiKeyHeader
  152.                 null, // apiKey,
  153.                 null, // appIdHeader,
  154.                 null, // appId,
  155.                 null, // listExtendedConnettore
  156.                 false, // erogazioneServizioApplicativoServerEnabled, 
  157.                 null // erogazioneServizioApplicativoServer
  158.             );
  159.         
  160.     }

  162.     @Override
  163.     public Connettore fillConnettoreRegistro(org.openspcoop2.core.registry.Connettore regConnettore,
  164.             ErogazioniEnv env,
  165.             ConnettorePlugin conn,
  166.             String oldConnT) throws Exception {
  167.         env.apsHelper.fillConnettore(
  168.                 regConnettore, 
  169.                 conn.isDebug() != null && conn.isDebug() ? "true" : "false",                // this.connettoreDebug,
  170.                 TipiConnettore.CUSTOM.getNome(),            // endpointtype
  171.                 oldConnT,                       // oldConnT
  172.                 conn.getPlugin(),                       // tipoConn Personalizzato
  173.                 null, // this.url,
  174.                 null,   // this.nome,
  175.                 null,   // this.tipo,
  176.                 null,
  177.                 null,
  178.                 null,   // this.initcont, 
  179.                 null,   // this.urlpgk,
  180.                 null, // this.url, 
  181.                 null,   // this.connfact,
  182.                 null,   // this.sendas,
  183.                 null, // this.httpsurl, 
  184.                 null,               // this.httpstipologia
  185.                 false,  // this.httpshostverify,
  186.                 ConnettoriCostanti.DEFAULT_CONNETTORE_HTTPS_TRUST_VERIFY_CERTS, // httpsTrustVerifyCert
  187.                 null,               // this.httpspath
  188.                 null,   // this.httpstipo,
  189.                 null,           // this.httpspwd,
  190.                 null,                   // this.httpsalgoritmo
  191.                 false,
  192.                 null,           // this.httpskeystore, 
  193.                 "",                                                                 //  this.httpspwdprivatekeytrust
  194.                 null,               // pathkey
  195.                 null,       // this.httpstipokey
  196.                 null,           // this.httpspwdkey 
  197.                 null,               // this.httpspwdprivatekey,  
  198.                 null,               // this.httpsalgoritmokey,
  199.                 null,                   // httpsKeyAlias
  200.                 null,                   // httpsTrustStoreCRLs
  201.                 null,                   // httpsTrustStoreOCSPPolicy
  202.                 null,                   // httpsKeyStoreBYOKPolicy
  203.             
  204.                 ServletUtils.boolToCheckBoxStatus( false ), 
  205.                 null,
  206.                 null,
  207.                 null,
  208.                 null,
  209.                 
  210.                 ServletUtils.boolToCheckBoxStatus( false ), 
  211.                 null,   // this.tempiRisposta_connectionTimeout, 
  212.                 null, //null,   // this.tempiRisposta_readTimeout, 
  213.                 null,   // this.tempiRisposta_tempoMedioRisposta,
  214.                 "no",   // this.opzioniAvanzate, 
  215.                 "",     // this.transfer_mode, 
  216.                 "",     // this.transfer_mode_chunk_size, 
  217.                 "",     // this.redirect_mode, 
  218.                 "",     // this.redirect_max_hop,
  219.                 null,   // this.requestOutputFileName,
  220.                 null,   // this.requestOutputFileName_permissions
  221.                 null,   // this.requestOutputFileNameHeaders,
  222.                 null,   // this.requestOutputFileNameHeaders_permissions
  223.                 null,   // this.requestOutputParentDirCreateIfNotExists,
  224.                 null,   // this.requestOutputOverwriteIfExists,
  225.                 null,   // this.responseInputMode, 
  226.                 null,   // this.responseInputFileName, 
  227.                 null,   // this.responseInputFileNameHeaders, 
  228.                 null,   // this.responseInputDeleteAfterRead, 
  229.                 null,   // this.responseInputWaitTime,
  230.                 null,   // tokenPolicy
  231.                 null, null, // apiKeyHeader,  apiKeyValue
  232.                 null, null, // appIdHeader, appIdValue
  233.                 null, // connettoreStatusParams
  234.                 null // listExtendedConnettore
  235.                 );
  236.         
  237.         if(conn.getProprieta() != null) {
  238.             for(org.openspcoop2.core.config.rs.server.model.Proprieta prop: conn.getProprieta()) {
  239.                 org.openspcoop2.core.registry.Property property = new org.openspcoop2.core.registry.Property();
  240.                 property.setNome(prop.getNome());
  241.                 property.setValore(prop.getValore());
  242.                 regConnettore.addProperty(property);
  243.             }
  244.         }       

  246.         return regConnettore;
  247.     }

  249.     @Override
  250.     public org.openspcoop2.core.config.Connettore buildConnettoreConfigurazione(
  251.             org.openspcoop2.core.config.Connettore regConnettore, ErogazioniEnv env, ConnettorePlugin conn,
  252.             String oldConnT) throws Exception {

  254.         env.apsHelper.fillConnettore(
  255.                 regConnettore, 
  256.                 conn.isDebug() != null && conn.isDebug() ? "true" : "false",                // this.connettoreDebug,
  257.                         TipiConnettore.CUSTOM.getNome(),            // endpointtype
  258.                         oldConnT,                       // oldConnT
  259.                         conn.getPlugin(),                       // tipoConn Personalizzato
  260.                         null, // this.url,
  261.                         null,   // this.nome,
  262.                         null,   // this.tipo,
  263.                         null,
  264.                         null,
  265.                         null,   // this.initcont, 
  266.                         null,   // this.urlpgk,
  267.                         null, // this.url, 
  268.                         null,   // this.connfact,
  269.                         null,   // this.sendas,
  270.                         null, // this.httpsurl, 
  271.                         null,               // this.httpstipologia
  272.                         false,  // this.httpshostverify,
  273.                         ConnettoriCostanti.DEFAULT_CONNETTORE_HTTPS_TRUST_VERIFY_CERTS, // httpsTrustVerifyCert
  274.                         null,               // this.httpspath
  275.                         null,   // this.httpstipo,
  276.                         null,           // this.httpspwd,
  277.                         null,                   // this.httpsalgoritmo
  278.                         false,
  279.                         null,           // this.httpskeystore, 
  280.                         "",                                                                 //  this.httpspwdprivatekeytrust
  281.                         null,               // pathkey
  282.                         null,       // this.httpstipokey
  283.                         null,           // this.httpspwdkey 
  284.                         null,               // this.httpspwdprivatekey,  
  285.                         null,               // this.httpsalgoritmokey,
  286.                         null,                   // httpsKeyAlias
  287.                         null,                   // httpsTrustStoreCRLs
  288.                         null,                   // httpsTrustStoreOCSPPolicy
  289.                         null,                   // httpsKeyStoreBYOKPolicy

  291.                         ServletUtils.boolToCheckBoxStatus( false ), 
  292.                         null,
  293.                         null,
  294.                         null,
  295.                         null,

  297.                         ServletUtils.boolToCheckBoxStatus( false ), 
  298.                         null,   // this.tempiRisposta_connectionTimeout, 
  299.                         null, //null,   // this.tempiRisposta_readTimeout, 
  300.                         null,   // this.tempiRisposta_tempoMedioRisposta,
  301.                         "no",   // this.opzioniAvanzate, 
  302.                         "",     // this.transfer_mode, 
  303.                         "",     // this.transfer_mode_chunk_size, 
  304.                         "",     // this.redirect_mode, 
  305.                         "",     // this.redirect_max_hop,
  306.                         null,   // this.requestOutputFileName,
  307.                         null,   // this.requestOutputFileName_permissions
  308.                         null,   // this.requestOutputFileNameHeaders,
  309.                         null,   // this.requestOutputFileNameHeaders_permissions
  310.                         null,   // this.requestOutputParentDirCreateIfNotExists,
  311.                         null,   // this.requestOutputOverwriteIfExists,
  312.                         null,   // this.responseInputMode, 
  313.                         null,   // this.responseInputFileName, 
  314.                         null,   // this.responseInputFileNameHeaders, 
  315.                         null,   // this.responseInputDeleteAfterRead, 
  316.                         null,   // this.responseInputWaitTime,
  317.                         null,   // tokenPolicy
  318.                         null, null, // apiKeyHeader,  apiKeyValue
  319.                         null, null, // appIdHeader, appIdValue
  320.                         null, // connettoreStatusParams
  321.                         null // listExtendedConnettore
  322.                         );  

  324.         
  325.         if(conn.getProprieta() != null) {
  326.             for(org.openspcoop2.core.config.rs.server.model.Proprieta prop: conn.getProprieta()) {
  327.                 org.openspcoop2.core.config.Property property = new org.openspcoop2.core.config.Property();
  328.                 property.setNome(prop.getNome());
  329.                 property.setValore(prop.getValore());
  330.                 regConnettore.addProperty(property);
  331.             }
  332.         }       

  334.         return regConnettore;
  335.     }

  337.     @Override
  338.     public ConnettorePlugin buildConnettore(Map<String, String> props, String tipo) {
  339.         ConnettorePlugin c = new ConnettorePlugin();
  340.         
  341.         c.setTipo(ConnettoreEnum.PLUGIN);
  342.         c.setDebug(Boolean.parseBoolean(props.get(CostantiDB.CONNETTORE_DEBUG)));
  343.         
  344.         c.setPlugin(tipo);
  345.         
  346.         List<String> propsExclude = Arrays.asList(CostantiDB.CONNETTORE_DEBUG);
  347.         
  348.         List<org.openspcoop2.core.config.rs.server.model.Proprieta> propLst = new ArrayList<>();

  350.         for(Entry<String, String> prop: props.entrySet()) {
  351.             if(!propsExclude.contains(prop.getKey())) {
  352.                 org.openspcoop2.core.config.rs.server.model.Proprieta p = new org.openspcoop2.core.config.rs.server.model.Proprieta();
  353.                 p.setNome(prop.getKey());
  354.                 p.setValore(prop.getValue());
  355.                 propLst.add(p);
  356.             }
  357.         }
  358.         
  359.         c.setProprieta(propLst);
  360.         return c;
  361.     }

  363.     @Override
  364.     public String getUrlConnettore(Map<String, String> props, String tipoConnettore) throws Exception {
  365.         return "[plugin] " + tipoConnettore;
  366.     }

  368. }
Created with JaCoCo 0.8.8.202204050719