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

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

  26. import org.openspcoop2.core.config.rs.server.model.ConnettoreEnum;
  27. import org.openspcoop2.core.config.rs.server.model.ConnettoreStatus;
  28. import org.openspcoop2.core.config.rs.server.model.ConnettoreStatusVerificaStatistica;
  29. import org.openspcoop2.core.config.rs.server.model.OneOfApplicativoServerConnettore;
  30. import org.openspcoop2.core.config.rs.server.model.OneOfConnettoreErogazioneConnettore;
  31. import org.openspcoop2.core.config.rs.server.model.OneOfConnettoreFruizioneConnettore;
  32. import org.openspcoop2.core.config.rs.server.model.TipoPeriodoStatisticoEnum;
  33. import org.openspcoop2.core.config.rs.server.model.TipoRispostaStatusEnum;
  34. import org.openspcoop2.core.constants.CostantiDB;
  35. import org.openspcoop2.core.constants.TipiConnettore;
  36. import org.openspcoop2.core.registry.Connettore;
  37. import org.openspcoop2.web.ctrlstat.servlet.connettori.ConnettoreStatusParams;
  38. import org.openspcoop2.web.ctrlstat.servlet.connettori.ConnettoriCostanti;
  39. import org.openspcoop2.web.lib.mvc.ServletUtils;

  41. /**
  42.  * ConnettoreStatusApiHelper
  43.  * 
  44.  * @author Tommaso Burlon (tommaso.burlon@link.it)
  45.  * @author $Author$
  46.  * @version $Rev$, $Date$
  47.  */
  48. public class ConnettoreStatusApiHelper extends AbstractConnettoreApiHelper<ConnettoreStatus> {

  50.     @Override
  51.     protected boolean connettoreCheckData(ConnettoreStatus conn, ErogazioniEnv env, boolean erogazione) throws Exception { 
  52.         return !ConnettoreStatusParams.check(env.apsHelper, null, null).getParsingErrors();
  53.     }

  55.     @Override
  56.     public Connettore fillConnettoreRegistro(org.openspcoop2.core.registry.Connettore regConnettore,
  57.             ErogazioniEnv env,
  58.             ConnettoreStatus conn,
  59.             String oldConnT) throws Exception {
  60.         
  61.         ConnettoreStatusParams params = new ConnettoreStatusParams()
  62.                 .statusResponseType(conn.getRisposta().toString())
  63.                 .testConnectivity(conn.isVerificaConnettivita())
  64.                 .testStatistics(false);
  65.         
  66.         if (conn.getVerificaStatistica() != null) {
  67.             params.testStatistics(true);
  68.             params.periodValue(conn.getVerificaStatistica().getIntervallo());
  69.             params.period(conn.getVerificaStatistica().getFrequenza().toString());
  70.             params.statLifetime(conn.getVerificaStatistica().getCacheLifeTime());
  71.         }
  72.         
  73.         env.apsHelper.fillConnettore(
  74.                 regConnettore, 
  75.                 conn.isDebug() == Boolean.TRUE ? "true" : "false",              // this.connettoreDebug,
  76.                 TipiConnettore.STATUS.getNome(),            // endpointtype
  77.                 oldConnT,                       // oldConnT
  78.                 "",                     // tipoConn Personalizzato
  79.                 null, // this.url,
  80.                 null,   // this.nome,
  81.                 null,   // this.tipo,
  82.                 null,
  83.                 null,
  84.                 null,   // this.initcont, 
  85.                 null,   // this.urlpgk,
  86.                 null, // this.url, 
  87.                 null,   // this.connfact,
  88.                 null,   // this.sendas,
  89.                 null, // this.httpsurl, 
  90.                 null,               // this.httpstipologia
  91.                 false,  // this.httpshostverify,
  92.                 ConnettoriCostanti.DEFAULT_CONNETTORE_HTTPS_TRUST_VERIFY_CERTS, // httpsTrustVerifyCert
  93.                 null,               // this.httpspath
  94.                 null,   // this.httpstipo,
  95.                 null,           // this.httpspwd,
  96.                 null,                   // this.httpsalgoritmo
  97.                 false,
  98.                 null,           // this.httpskeystore, 
  99.                 "",                                                                 //  this.httpspwdprivatekeytrust
  100.                 null,               // pathkey
  101.                 null,       // this.httpstipokey
  102.                 null,           // this.httpspwdkey 
  103.                 null,               // this.httpspwdprivatekey,  
  104.                 null,               // this.httpsalgoritmokey,
  105.                 null,                   // httpsKeyAlias
  106.                 null,                   // httpsTrustStoreCRLs
  107.                 null,                   // httpsTrustStoreOCSPPolicy
  108.                 null,                   // httpsKeyStoreBYOKPolicy
  109.             
  110.                 ServletUtils.boolToCheckBoxStatus( false ), 
  111.                 null,
  112.                 null,
  113.                 null,
  114.                 null,
  115.                 
  116.                 ServletUtils.boolToCheckBoxStatus( false ), 
  117.                 null,   // this.tempiRisposta_connectionTimeout, 
  118.                 null, //null,   // this.tempiRisposta_readTimeout, 
  119.                 null,   // this.tempiRisposta_tempoMedioRisposta,
  120.                 "no",   // this.opzioniAvanzate, 
  121.                 "",     // this.transfer_mode, 
  122.                 "",     // this.transfer_mode_chunk_size, 
  123.                 "",     // this.redirect_mode, 
  124.                 "",     // this.redirect_max_hop,
  125.                 null,   // this.requestOutputFileName,
  126.                 null,   // this.requestOutputFileName_permissions
  127.                 null,   // this.requestOutputFileNameHeaders,
  128.                 null,   // this.requestOutputFileNameHeaders_permissions
  129.                 null,   // this.requestOutputParentDirCreateIfNotExists,
  130.                 null,   // this.requestOutputOverwriteIfExists,
  131.                 null,   // this.responseInputMode, 
  132.                 null,   // this.responseInputFileName, 
  133.                 null,   // this.responseInputFileNameHeaders, 
  134.                 null,   // this.responseInputDeleteAfterRead, 
  135.                 null,   // this.responseInputWaitTime,
  136.                 null,   // tokenPolicy
  137.                 null, null, // apiKeyHeader,  apiKeyValue
  138.                 null, null, // appIdHeader, appIdValue
  139.                 params, // connettoreStatusParams
  140.                 null // listExtendedConnettore
  141.                 );
  142.         
  143.         return regConnettore;
  144.     }

  146.     @Override
  147.     public org.openspcoop2.core.config.Connettore buildConnettoreConfigurazione(
  148.             org.openspcoop2.core.config.Connettore regConnettore, ErogazioniEnv env, ConnettoreStatus conn,
  149.             String oldConnType) throws Exception {

  151.         ConnettoreStatusParams params = new ConnettoreStatusParams()
  152.                 .statusResponseType(conn.getRisposta().toString())
  153.                 .testConnectivity(conn.isVerificaConnettivita())
  154.                 .testStatistics(false);
  155.         
  156.         if (conn.getVerificaStatistica() != null) {
  157.             params.testStatistics(true);
  158.             params.periodValue(conn.getVerificaStatistica().getIntervallo());
  159.             params.period(conn.getVerificaStatistica().getFrequenza().toString());
  160.             params.statLifetime(conn.getVerificaStatistica().getCacheLifeTime());
  161.         }
  162.         
  163.         env.apsHelper.fillConnettore(
  164.                 regConnettore, 
  165.                 conn.isDebug() == Boolean.TRUE ? "true" : "false",              // this.connettoreDebug,
  166.                 TipiConnettore.STATUS.getNome(),            // endpointtype
  167.                 oldConnType,                        // oldConnT
  168.                 "",                     // tipoConn Personalizzato
  169.                 null, // this.url,
  170.                 null,   // this.nome,
  171.                 null,   // this.tipo,
  172.                 null,
  173.                 null,
  174.                 null,   // this.initcont, 
  175.                 null,   // this.urlpgk,
  176.                 null, // this.url, 
  177.                 null,   // this.connfact,
  178.                 null,   // this.sendas,
  179.                 null, // this.httpsurl, 
  180.                 null,               // this.httpstipologia
  181.                 false,  // this.httpshostverify,
  182.                 ConnettoriCostanti.DEFAULT_CONNETTORE_HTTPS_TRUST_VERIFY_CERTS, // httpsTrustVerifyCert
  183.                 null,               // this.httpspath
  184.                 null,   // this.httpstipo,
  185.                 null,           // this.httpspwd,
  186.                 null,                   // this.httpsalgoritmo
  187.                 false,
  188.                 null,           // this.httpskeystore, 
  189.                 "",                                                                 //  this.httpspwdprivatekeytrust
  190.                 null,               // pathkey
  191.                 null,       // this.httpstipokey
  192.                 null,           // this.httpspwdkey 
  193.                 null,               // this.httpspwdprivatekey,  
  194.                 null,               // this.httpsalgoritmokey,
  195.                 null,                   // httpsKeyAlias
  196.                 null,                   // httpsTrustStoreCRLs
  197.                 null,                   // httpsTrustStoreOCSPPolicy
  198.                 null,                   // httpsKeyStoreBYOKPolicy
  199.             
  200.                 ServletUtils.boolToCheckBoxStatus( false ), 
  201.                 null,
  202.                 null,
  203.                 null,
  204.                 null,
  205.                 
  206.                 ServletUtils.boolToCheckBoxStatus( false ), 
  207.                 null,   // this.tempiRisposta_connectionTimeout,
  208.                 null, //null,   // this.tempiRisposta_readTimeout, 
  209.                 null,   // this.tempiRisposta_tempoMedioRisposta,
  210.                 "no",   // this.opzioniAvanzate, 
  211.                 "",     // this.transfer_mode, 
  212.                 "",     // this.transfer_mode_chunk_size, 
  213.                 "",     // this.redirect_mode, 
  214.                 "",     // this.redirect_max_hop,
  215.                 null,   // this.requestOutputFileName,
  216.                 null,   // this.requestOutputFileName_permissions
  217.                 null,   // this.requestOutputFileNameHeaders,
  218.                 null,   // this.requestOutputFileNameHeaders_permissions
  219.                 null,   // this.requestOutputParentDirCreateIfNotExists,
  220.                 null,   // this.requestOutputOverwriteIfExists,
  221.                 null,   // this.responseInputMode, 
  222.                 null,   // this.responseInputFileName, 
  223.                 null,   // this.responseInputFileNameHeaders, 
  224.                 null,   // this.responseInputDeleteAfterRead, 
  225.                 null,   // this.responseInputWaitTime,
  226.                 null,   // tokenPolicy
  227.                 null, null, // apiKeyHeader,  apiKeyValue
  228.                 null, null, // appIdHeader, appIdValue
  229.                 params, // connettoreStatusParams
  230.                 null // listExtendedConnettore
  231.                 );      
  232.         return regConnettore;
  233.     }

  235.     @Override
  236.     public ConnettoreStatus buildConnettore(Map<String, String> props, String tipo) {
  237.         String verificaConnettivita = props.get(CostantiDB.CONNETTORE_STATUS_TEST_CONNECTIVITY);
  238.         String statusResponseType = props.get(CostantiDB.CONNETTORE_STATUS_RESPONSE_TYPE);
  239.         String period = props.get(CostantiDB.CONNETTORE_STATUS_STATISTICAL_PERIOD);
  240.         String periodValue = props.get(CostantiDB.CONNETTORE_STATUS_STATISTICAL_PERIOD_VALUE);
  241.         String cacheLifetime = props.get(CostantiDB.CONNETTORE_STATUS_STAT_LIFETIME);
  242.         String debug = props.get(CostantiDB.CONNETTORE_DEBUG);
  243.         
  244.         ConnettoreStatusVerificaStatistica verificaStatistica = null;
  245.         
  246.         if (period != null) {
  247.             verificaStatistica = new ConnettoreStatusVerificaStatistica()
  248.                     .intervallo(Integer.valueOf(periodValue))
  249.                     .frequenza(TipoPeriodoStatisticoEnum.fromValue(period))
  250.                     .cacheLifeTime(cacheLifetime == null ? null : Integer.valueOf(cacheLifetime));
  251.         }
  252.         
  253.         return new ConnettoreStatus()
  254.                 .tipo(ConnettoreEnum.STATUS)
  255.                 .risposta(TipoRispostaStatusEnum.fromValue(statusResponseType))
  256.                 .debug(Objects.requireNonNullElse(debug, Boolean.FALSE).equals(Boolean.TRUE))
  257.                 .verificaConnettivita(Objects.requireNonNullElse(verificaConnettivita, Boolean.FALSE).equals(Boolean.TRUE))
  258.                 .verificaStatistica(verificaStatistica);
  259.     }

  261.     @Override
  262.     public String getUrlConnettore(Map<String, String> props, String tipoConnettore) throws Exception {
  263.         return "[status] govway://status";
  264.     }

  266.     @Override
  267.     protected ConnettoreStatus getConnettore(OneOfConnettoreErogazioneConnettore conn) throws Exception {
  268.         return (ConnettoreStatus) conn;
  269.     }

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

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

  281. }
Created with JaCoCo 0.8.8.202204050719