ConnettoreFileApiHelper.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.List;
  23. import java.util.Map;

  25. import org.openspcoop2.core.config.constants.CostantiConfigurazione;
  26. import org.openspcoop2.core.config.constants.StatoFunzionalita;
  27. import org.openspcoop2.core.config.rs.server.model.ConnettoreEnum;
  28. import org.openspcoop2.core.config.rs.server.model.ConnettoreFile;
  29. import org.openspcoop2.core.config.rs.server.model.ConnettoreFileRichiesta;
  30. import org.openspcoop2.core.config.rs.server.model.ConnettoreFileRisposta;
  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.CostantiDB;
  35. import org.openspcoop2.core.constants.TipiConnettore;
  36. import org.openspcoop2.core.registry.Connettore;
  37. import org.openspcoop2.web.ctrlstat.costanti.ConnettoreServletType;
  38. import org.openspcoop2.web.ctrlstat.plugins.ExtendedConnettore;
  39. import org.openspcoop2.web.ctrlstat.plugins.servlet.ServletExtendedConnettoreUtils;
  40. import org.openspcoop2.web.ctrlstat.servlet.connettori.ConnettoriCostanti;
  41. import org.openspcoop2.web.lib.mvc.ServletUtils;

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

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

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

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

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


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

  78.         String responseInputMode = conn.getRisposta() != null ? StatoFunzionalita.ABILITATO.toString() : StatoFunzionalita.DISABILITATO.toString();
  79.         
  80.         String responseInputFileName = null;
  81.         String responseInputFileNameHeaders = null;
  82.         boolean responseInputDeleteAfterRead = false;
  83.         String responseInputWaitTime = null;
  84.         
  85.         if(conn.getRisposta() != null) {
  86.             responseInputFileName = conn.getRisposta().getFile();
  87.             responseInputFileNameHeaders = conn.getRisposta().getFileHeaders();
  88.             responseInputDeleteAfterRead = conn.getRisposta().isDeleteAfterRead();
  89.             responseInputWaitTime = conn.getRisposta().getWaitIfNotExistsMs() != null ? conn.getRisposta().getWaitIfNotExistsMs() + "" : null;
  90.         }
  91.         
  92.         String createParentDir = conn.getRichiesta().isCreateParentDir() != null ? ServletUtils.boolToCheckBoxStatus(conn.getRichiesta().isCreateParentDir()) : ServletUtils.boolToCheckBoxStatus(false);
  93.         String overwriteIfExists = conn.getRichiesta().isOverwriteIfExists() != null ? ServletUtils.boolToCheckBoxStatus(conn.getRichiesta().isOverwriteIfExists()) : ServletUtils.boolToCheckBoxStatus(false);
  94.         
  95.         return env.saHelper.endPointCheckData(
  96.                 null,
  97.                 env.tipo_protocollo,
  98.                 erogazione,
  99.                 endpointtype,
  100.                 null,
  101.                 null,   // nome
  102.                 null,   // tipo
  103.                 null,   // httpConf.getUsername()
  104.                 null,   // httpConf.getPassword()
  105.                 null,   // this.initcont, 
  106.                 null,   // this.urlpgk,
  107.                 null,   // provurl jms,
  108.                 null,   // connfact, 
  109.                 null,   // sendas, 
  110.                 null,                                                   // this.httpsurl,
  111.                 null,   // httpsConf.getTipologia().toString(), 
  112.                 false,      // this.httpshostverify,
  113.                 ConnettoriCostanti.DEFAULT_CONNETTORE_HTTPS_TRUST_VERIFY_CERTS, // httpsTrustVerifyCert
  114.                 null,   // this.httpspath
  115.                 null,   // this.httpstipo,
  116.                 null,   // this.httpspwd,
  117.                 null,   // this.httpsalgoritmo
  118.                 false, 
  119.                 null,
  120.                 "",                                                                     // httpspwdprivatekeytrust, 
  121.                 null,   // pathkey
  122.                 null,   // this.httpstipokey
  123.                 null,   // this.httpspwdkey 
  124.                 null,   // this.httpspwdprivatekey,  
  125.                 null,   // this.httpsalgoritmokey, 
  126.                 null,   // httpsKeyAlias
  127.                 null,   // httpsTrustStoreCRLs
  128.                 null,   // httpsTrustStoreOCSPPolicy
  129.                 null,   // httpsKeyStoreBYOKPolicy
  130.                 null,                                                               //  tipoconn (personalizzato)
  131.                 ServletUtils.boolToCheckBoxStatus(false),                                           //autenticazioneHttp,
  132.                 ServletUtils.boolToCheckBoxStatus(false),   
  133.                 null,   // evalnull( () -> proxy.getHostname() ),
  134.                 null,   // evalnull( () -> proxy.getPorta().toString() ),
  135.                 null,   // evalnull( () -> proxy.getUsername() ),
  136.                 null,   // evalnull( () -> proxy.getPassword() ),
  137.                 ServletUtils.boolToCheckBoxStatus(false), //ServletUtils.boolToCheckBoxStatus( tempiRisposta_enabled ), 
  138.                 null,   // evalnull( () -> timeoutConf.getConnectionTimeout().toString()),  // this.tempiRisposta_connectionTimeout, 
  139.                 null,   // evalnull( () -> timeoutConf.getConnectionReadTimeout().toString()), //null,  // this.tempiRisposta_readTimeout, 
  140.                 null,   // evalnull( () -> timeoutConf.getTempoMedioRisposta().toString()), // this.tempiRisposta_tempoMedioRisposta,
  141.                 "no",   // this.opzioniAvanzate, 
  142.                 "",     // this.transfer_mode, 
  143.                 "",     // this.transfer_mode_chunk_size, 
  144.                 "",     // this.redirect_mode, 
  145.                 "",     // this.redirect_max_hop,
  146.                 conn.getRichiesta().getFile(),  // this.requestOutputFileName,
  147.                 conn.getRichiesta().getFilePermissions(),   // this.requestOutputFileName_permissions
  148.                 conn.getRichiesta().getFileHeaders(),   // this.requestOutputFileNameHeaders,
  149.                 conn.getRichiesta().getFileHeadersPermissions(),   // this.requestOutputFileNameHeaders_permissions
  150.                 createParentDir,
  151.                 overwriteIfExists,
  152.                 responseInputMode,  // this.responseInputMode, 
  153.                 responseInputFileName,  // this.responseInputFileName, 
  154.                 responseInputFileNameHeaders,   // this.responseInputFileNameHeaders, 
  155.                 ServletUtils.boolToCheckBoxStatus(responseInputDeleteAfterRead),    // this.responseInputDeleteAfterRead, 
  156.                 responseInputWaitTime,  // this.responseInputWaitTime,
  157.                 false, // autenticazioneToken
  158.                 null, // tokenPolicy
  159.                 null, // autenticazioneApiKey
  160.                 false, // useOAS3Names
  161.                 false, // useAppId
  162.                 null, // apiKeyHeader
  163.                 null, // apiKey,
  164.                 null, // appIdHeader,
  165.                 null, // appId,
  166.                 listExtendedConnettore, // listExtendedConnettore
  167.                 false, // erogazioneServizioApplicativoServerEnabled, 
  168.                 null // erogazioneServizioApplicativoServer
  169.             );

  171.     }

  173.     @Override
  174.     public Connettore fillConnettoreRegistro(org.openspcoop2.core.registry.Connettore regConnettore,
  175.             ErogazioniEnv env,
  176.             ConnettoreFile conn,
  177.             String oldConnT) throws Exception {
  178.         final String endpointtype = TipiConnettore.FILE.getNome();
  179.         
  180.         org.openspcoop2.core.registry.Connettore conTmp = null;
  181.         List<ExtendedConnettore> listExtendedConnettore = 
  182.                 ServletExtendedConnettoreUtils.getExtendedConnettore(conTmp, ConnettoreServletType.ACCORDO_SERVIZIO_PARTE_SPECIFICA_ADD, env.apsHelper, 
  183.                         null, false, endpointtype);

  185.         String responseInputMode = conn.getRisposta() != null ? StatoFunzionalita.ABILITATO.toString() : StatoFunzionalita.DISABILITATO.toString();
  186.         
  187.         String responseInputFileName = null;
  188.         String responseInputFileNameHeaders = null;
  189.         boolean responseInputDeleteAfterRead = false;
  190.         String responseInputWaitTime = null;
  191.         
  192.         if(conn.getRisposta() != null) {
  193.             responseInputFileName = conn.getRisposta().getFile();
  194.             responseInputFileNameHeaders = conn.getRisposta().getFileHeaders();
  195.             responseInputDeleteAfterRead = conn.getRisposta().isDeleteAfterRead();
  196.             responseInputWaitTime = conn.getRisposta().getWaitIfNotExistsMs() != null ? conn.getRisposta().getWaitIfNotExistsMs() + "" : null;
  197.         }
  198.         
  199.         
  200.         String createParentDir = conn.getRichiesta().isCreateParentDir() != null ? ServletUtils.boolToCheckBoxStatus(conn.getRichiesta().isCreateParentDir()) : ServletUtils.boolToCheckBoxStatus(false);
  201.         String overwriteIfExists = conn.getRichiesta().isOverwriteIfExists() != null ? ServletUtils.boolToCheckBoxStatus(conn.getRichiesta().isOverwriteIfExists()) : ServletUtils.boolToCheckBoxStatus(false);

  203.         env.apsHelper.fillConnettore(
  204.                 regConnettore, 
  205.                 conn.isDebug() != null && conn.isDebug() ? "true" : "false",                // this.connettoreDebug,
  206.                 endpointtype,           // endpointtype
  207.                 oldConnT,           // oldConnT
  208.                 "",                     // tipoConn Personalizzato
  209.                 null, // this.url,
  210.                 null,   // this.nome,
  211.                 null,   // this.tipo,
  212.                 null, 
  213.                 null, 
  214.                 null,   // this.initcont, 
  215.                 null,   // this.urlpgk,
  216.                 null,   // this.url, 
  217.                 null,   // this.connfact,
  218.                 null,   // this.sendas,
  219.                 null,                                               // this.httpsurl, 
  220.                 null,  //this.httpstipologia
  221.                 false,  // this.httpshostverify,
  222.                 ConnettoriCostanti.DEFAULT_CONNETTORE_HTTPS_TRUST_VERIFY_CERTS, // httpsTrustVerifyCert
  223.                 null,  // this.httpspath
  224.                 null,  //this.httpstipo,
  225.                 null,  //this.httpspwd,
  226.                 null,  // this.httpsalgoritmo
  227.                 false,
  228.                 null, // this.httpskeystore, 
  229.                 "",                                                                 //  this.httpspwdprivatekeytrust
  230.                 null,  //pathkey
  231.                 null,  //this.httpstipokey
  232.                 null,  //this.httpspwdkey 
  233.                 null,  //this.httpspwdprivatekey,  
  234.                 null,  //this.httpsalgoritmokey,
  235.                 null,  //httpsKeyAlias
  236.                 null,  //httpsTrustStoreCRLs
  237.                 null,  //httpsTrustStoreOCSPPolicy
  238.                 null,  //httpsKeyStoreBYOKPolicy
  239.             
  240.                 ServletUtils.boolToCheckBoxStatus( false ), 
  241.                 null,
  242.                 null,
  243.                 null,
  244.                 null,
  245.                 ServletUtils.boolToCheckBoxStatus( false ), 
  246.                 null,
  247.                 null,
  248.                 null,
  249.                 "no",   // this.opzioniAvanzate, 
  250.                 "",     // this.transfer_mode, 
  251.                 "",     // this.transfer_mode_chunk_size, 
  252.                 "",     // this.redirect_mode, 
  253.                 "",     // this.redirect_max_hop,
  254.                 conn.getRichiesta().getFile(),  // this.requestOutputFileName,
  255.                 conn.getRichiesta().getFilePermissions(),   // this.requestOutputFileName_permissions
  256.                 conn.getRichiesta().getFileHeaders(),   // this.requestOutputFileNameHeaders,
  257.                 conn.getRichiesta().getFileHeadersPermissions(),   // this.requestOutputFileNameHeaders_permissions
  258.                 createParentDir,    // this.requestOutputParentDirCreateIfNotExists,
  259.                 overwriteIfExists,  // this.requestOutputOverwriteIfExists,
  260.                 responseInputMode,  // this.responseInputMode, 
  261.                 responseInputFileName,  // this.responseInputFileName, 
  262.                 responseInputFileNameHeaders,   // this.responseInputFileNameHeaders, 
  263.                 ServletUtils.boolToCheckBoxStatus(responseInputDeleteAfterRead),    // this.responseInputDeleteAfterRead, 
  264.                 responseInputWaitTime,  // this.responseInputWaitTime,
  265.                 null,   // tokenPolicy
  266.                 null, null, // apiKeyHeader,  apiKeyValue
  267.                 null, null, // appIdHeader, appIdValue
  268.                 null, // connettoreStatusParams
  269.                 listExtendedConnettore);    
  270.         return regConnettore;
  271.     }

  273.     @Override
  274.     public org.openspcoop2.core.config.Connettore buildConnettoreConfigurazione(
  275.             org.openspcoop2.core.config.Connettore regConnettore, ErogazioniEnv env, ConnettoreFile conn,
  276.             String oldConnType) throws Exception {

  278.         final String endpointtype = TipiConnettore.FILE.getNome();
  279.         
  280.         org.openspcoop2.core.registry.Connettore conTmp = null;
  281.         List<ExtendedConnettore> listExtendedConnettore = 
  282.                 ServletExtendedConnettoreUtils.getExtendedConnettore(conTmp, ConnettoreServletType.ACCORDO_SERVIZIO_PARTE_SPECIFICA_ADD, env.apsHelper, 
  283.                         null, false, endpointtype);

  285.         String responseInputMode = conn.getRisposta() != null ? StatoFunzionalita.ABILITATO.toString() : StatoFunzionalita.DISABILITATO.toString();
  286.         
  287.         String responseInputFileName = null;
  288.         String responseInputFileNameHeaders = null;
  289.         boolean responseInputDeleteAfterRead = false;
  290.         String responseInputWaitTime = null;
  291.         
  292.         if(conn.getRisposta() != null) {
  293.             responseInputFileName = conn.getRisposta().getFile();
  294.             responseInputFileNameHeaders = conn.getRisposta().getFileHeaders();
  295.             responseInputDeleteAfterRead = conn.getRisposta().isDeleteAfterRead();
  296.             responseInputWaitTime = conn.getRisposta().getWaitIfNotExistsMs() != null ? conn.getRisposta().getWaitIfNotExistsMs() + "" : null;
  297.         }
  298.         
  299.         
  300.         String createParentDir = conn.getRichiesta().isCreateParentDir() != null ? ServletUtils.boolToCheckBoxStatus(conn.getRichiesta().isCreateParentDir()) : ServletUtils.boolToCheckBoxStatus(false);
  301.         String overwriteIfExists = conn.getRichiesta().isOverwriteIfExists() != null ? ServletUtils.boolToCheckBoxStatus(conn.getRichiesta().isOverwriteIfExists()) : ServletUtils.boolToCheckBoxStatus(false);

  303.         env.apsHelper.fillConnettore(
  304.                 regConnettore, 
  305.                 conn.isDebug() != null && conn.isDebug() ? "true" : "false",                // this.connettoreDebug,
  306.                 endpointtype,           // endpointtype
  307.                 oldConnType,            // oldConnT
  308.                 "",                     // tipoConn Personalizzato
  309.                 null, // this.url,
  310.                 null,   // this.nome,
  311.                 null,   // this.tipo,
  312.                 null, 
  313.                 null, 
  314.                 null,   // this.initcont, 
  315.                 null,   // this.urlpgk,
  316.                 null,   // this.url, 
  317.                 null,   // this.connfact,
  318.                 null,   // this.sendas,
  319.                 null,                                               // this.httpsurl, 
  320.                 null,  //this.httpstipologia
  321.                 false,  // this.httpshostverify,
  322.                 ConnettoriCostanti.DEFAULT_CONNETTORE_HTTPS_TRUST_VERIFY_CERTS, // httpsTrustVerifyCert
  323.                 null,  // this.httpspath
  324.                 null,  //this.httpstipo,
  325.                 null,  //this.httpspwd,
  326.                 null,  // this.httpsalgoritmo
  327.                 false,
  328.                 null, // this.httpskeystore, 
  329.                 "",                                                                 //  this.httpspwdprivatekeytrust
  330.                 null,  //pathkey
  331.                 null,  //this.httpstipokey
  332.                 null,  //this.httpspwdkey 
  333.                 null,  //this.httpspwdprivatekey,  
  334.                 null,  //this.httpsalgoritmokey,
  335.                 null,  //httpsKeyAlias
  336.                 null,  //httpsTrustStoreCRLs
  337.                 null,  //httpsTrustStoreOCSPPolicy
  338.                 null,  //httpsKeyStoreBYOKPolicy
  339.             
  340.                 ServletUtils.boolToCheckBoxStatus( false ), 
  341.                 null,
  342.                 null,
  343.                 null,
  344.                 null,
  345.                 ServletUtils.boolToCheckBoxStatus( false ), 
  346.                 null,
  347.                 null,
  348.                 null,
  349.                 "no",   // this.opzioniAvanzate, 
  350.                 "",     // this.transfer_mode, 
  351.                 "",     // this.transfer_mode_chunk_size, 
  352.                 "",     // this.redirect_mode, 
  353.                 "",     // this.redirect_max_hop,
  354.                 conn.getRichiesta().getFile(),  // this.requestOutputFileName,
  355.                 conn.getRichiesta().getFilePermissions(),   // this.requestOutputFileName_permissions
  356.                 conn.getRichiesta().getFileHeaders(),   // this.requestOutputFileNameHeaders,
  357.                 conn.getRichiesta().getFileHeadersPermissions(),   // this.requestOutputFileNameHeaders_permissions
  358.                 createParentDir,    // this.requestOutputParentDirCreateIfNotExists,
  359.                 overwriteIfExists,  // this.requestOutputOverwriteIfExists,
  360.                 responseInputMode,  // this.responseInputMode, 
  361.                 responseInputFileName,  // this.responseInputFileName, 
  362.                 responseInputFileNameHeaders,   // this.responseInputFileNameHeaders, 
  363.                 ServletUtils.boolToCheckBoxStatus(responseInputDeleteAfterRead),    // this.responseInputDeleteAfterRead, 
  364.                 responseInputWaitTime,  // this.responseInputWaitTime,
  365.                 null,   // tokenPolicy
  366.                 null, null, // apiKeyHeader,  apiKeyValue
  367.                 null, null, // appIdHeader, appIdValue
  368.                 null, // connettoreStatusParams
  369.                 listExtendedConnettore);    
  370.         return regConnettore;
  371.     }

  373.     @Override
  374.     public ConnettoreFile buildConnettore(Map<String, String> props, String tipo) {
  375.         ConnettoreFile c = new ConnettoreFile();

  377.         c.setTipo(ConnettoreEnum.FILE);
  378.         c.setDebug(Boolean.parseBoolean(props.get(CostantiDB.CONNETTORE_DEBUG)));

  380.         ConnettoreFileRichiesta richiesta = new ConnettoreFileRichiesta();

  382.         richiesta.setFile(props.get(CostantiDB.CONNETTORE_FILE_RESPONSE_INPUT_FILE));
  383.         richiesta.setFileHeaders(props.get(CostantiDB.CONNETTORE_FILE_RESPONSE_INPUT_FILE_HEADERS));
  384.         String requestOutputFileName = props.get(CostantiDB.CONNETTORE_FILE_REQUEST_OUTPUT_FILE);   
  385.         String requestOutputFileName_permissions = props.get(CostantiDB.CONNETTORE_FILE_REQUEST_OUTPUT_FILE_PERMISSIONS);   
  386.         String requestOutputFileNameHeaders = props.get(CostantiDB.CONNETTORE_FILE_REQUEST_OUTPUT_FILE_HEADERS);    
  387.         String requestOutputFileNameHeaders_permissions = props.get(CostantiDB.CONNETTORE_FILE_REQUEST_OUTPUT_FILE_HEADERS_PERMISSIONS);    
  388.         String v = props.get(CostantiDB.CONNETTORE_FILE_REQUEST_OUTPUT_AUTO_CREATE_DIR);
  389.         boolean requestOutputParentDirCreateIfNotExists = false;        
  390.         if(v!=null && !"".equals(v)){
  391.             if("true".equalsIgnoreCase(v) || CostantiConfigurazione.ABILITATO.getValue().equalsIgnoreCase(v) ){
  392.                 requestOutputParentDirCreateIfNotExists = true;
  393.             }
  394.         }                   
  395.         v = props.get(CostantiDB.CONNETTORE_FILE_REQUEST_OUTPUT_OVERWRITE_FILE);
  396.         boolean requestOutputOverwriteIfExists = false;
  397.         if(v!=null && !"".equals(v)){
  398.             if("true".equalsIgnoreCase(v) || CostantiConfigurazione.ABILITATO.getValue().equalsIgnoreCase(v) ){
  399.                 requestOutputOverwriteIfExists = true;
  400.             }
  401.         }   

  403.         v = props.get(CostantiDB.CONNETTORE_FILE_RESPONSE_INPUT_MODE);
  404.         boolean responseInputMode = false;
  405.         if(v!=null && !"".equals(v)){
  406.             if("true".equalsIgnoreCase(v) || CostantiConfigurazione.ABILITATO.getValue().equalsIgnoreCase(v) ){
  407.                 responseInputMode = true;
  408.             }
  409.         }

  411.         richiesta.setFile(requestOutputFileName);
  412.         richiesta.setFilePermissions(requestOutputFileName_permissions);
  413.         richiesta.setFileHeaders(requestOutputFileNameHeaders);
  414.         richiesta.setFileHeadersPermissions(requestOutputFileNameHeaders_permissions);
  415.         richiesta.setCreateParentDir(requestOutputParentDirCreateIfNotExists);
  416.         richiesta.setOverwriteIfExists(requestOutputOverwriteIfExists);

  418.         c.setRichiesta(richiesta);


  421.         if(responseInputMode){
  422.             boolean responseInputDeleteAfterRead = false;
  423.             String responseInputFileName = props.get(CostantiDB.CONNETTORE_FILE_RESPONSE_INPUT_FILE);
  424.             String responseInputFileNameHeaders = props.get(CostantiDB.CONNETTORE_FILE_RESPONSE_INPUT_FILE_HEADERS);
  425.             v = props.get(CostantiDB.CONNETTORE_FILE_RESPONSE_INPUT_FILE_DELETE_AFTER_READ);
  426.             if(v!=null && !"".equals(v)){
  427.                 if("true".equalsIgnoreCase(v) || CostantiConfigurazione.ABILITATO.getValue().equalsIgnoreCase(v) ){
  428.                     responseInputDeleteAfterRead = true;
  429.                 }
  430.             }                       
  431.             String responseInputWaitTime = props.get(CostantiDB.CONNETTORE_FILE_RESPONSE_INPUT_WAIT_TIME);

  433.             ConnettoreFileRisposta risposta = new ConnettoreFileRisposta();

  435.             risposta.setFile(responseInputFileName);
  436.             risposta.setFileHeaders(responseInputFileNameHeaders);

  438.             if(responseInputWaitTime != null && !responseInputWaitTime.isEmpty()) {
  439.                 risposta.setWaitIfNotExistsMs(Integer.parseInt(responseInputWaitTime));
  440.             }
  441.             risposta.setDeleteAfterRead(responseInputDeleteAfterRead);

  443.             c.setRisposta(risposta);
  444.         }

  446.         return c;
  447.     }

  449.     @Override
  450.     public String getUrlConnettore(Map<String, String> properties, String tipoConnettore) throws Exception {
  451.         return "[file] " + properties.get(CostantiDB.CONNETTORE_FILE_REQUEST_OUTPUT_FILE);
  452.     }

  454. }
Created with JaCoCo 0.8.8.202204050719