Importer.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.protocol.engine.archive;

  23. import org.openspcoop2.core.config.driver.db.DriverConfigurazioneDB;
  24. import org.openspcoop2.core.registry.driver.db.DriverRegistroServiziDB;
  25. import org.openspcoop2.protocol.basic.registry.ConfigIntegrationReader;
  26. import org.openspcoop2.protocol.basic.registry.RegistryReader;
  27. import org.openspcoop2.protocol.engine.ProtocolFactoryManager;
  28. import org.openspcoop2.protocol.sdk.ConfigurazionePdD;
  29. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  30. import org.openspcoop2.protocol.sdk.archive.Archive;
  31. import org.openspcoop2.protocol.sdk.archive.ArchiveEsitoImport;
  32. import org.openspcoop2.protocol.sdk.archive.ArchiveMode;
  33. import org.openspcoop2.protocol.sdk.archive.ArchiveModeType;
  34. import org.openspcoop2.protocol.sdk.archive.IArchive;
  35. import org.openspcoop2.utils.LoggerWrapperFactory;
  36. import org.openspcoop2.utils.resources.FileSystemUtilities;
  37. import org.openspcoop2.utils.resources.Loader;
  38. import org.slf4j.Logger;

  40. /**
  41.  *  Importer
  42.  *
  43.  * @author Poli Andrea (apoli@link.it)
  44.  * @author $Author$
  45.  * @version $Rev$, $Date$
  46.  */
  47. public class Importer {

  49.     public static void main(String[] args) throws Exception {
  50.         
  51.         Logger log = LoggerWrapperFactory.getLogger(Importer.class);
  52.         
  53.         // Lettura file
  54.         String archiveFile = args[0];
  55.         byte[] archiveBytes = FileSystemUtilities.readBytesFromFile(archiveFile);
  56.         
  57.         // Protocollo
  58.         String protocollo = args[1];
  59.         
  60.         // Mode
  61.         String mode = args[2]; // es. cnipa, openspcoop
  62.         ArchiveMode archiveMode = new ArchiveMode(mode);
  63.         
  64.         // tipoArchivio
  65.         String type = args[3]; // es. *, apc, aps ...
  66.         ArchiveModeType archiveModeType = new ArchiveModeType(type);
  67.         
  68.         // validateDocuments
  69.         boolean validateDocuments = Boolean.parseBoolean(args[4]); 
  70.         
  71.         // userLogin
  72.         String userLogin = args[5];
  73.         
  74.         // nomePddOperativa
  75.         String nomePddOperativa = args[6];
  76.         
  77.         // tipoPddDefault
  78.         String tipoPddDefault = args[7];
  79.         
  80.         // updateAbilitato
  81.         boolean updateAbilitato = Boolean.parseBoolean(args[8]); 
  82.         boolean importPolicyConfig = Boolean.parseBoolean(args[9]); 
  83.         boolean importPluginConfig = Boolean.parseBoolean(args[10]);
  84.         boolean checkExistsPluginConfig = Boolean.parseBoolean(args[11]);
  85.         boolean importConfig = Boolean.parseBoolean(args[12]); 

  87.         // other
  88.         boolean isShowCorrelazioneAsincronaInAccordi = true;
  89.         boolean isShowGestioneWorkflowStatoDocumenti = true;
  90.         boolean isShowAccordiColonnaAzioni = true;
  91.         boolean isAbilitatoControlloUnicitaImplementazioneAccordoPerSoggetto = false;
  92.         boolean isAbilitatoControlloUnicitaImplementazionePortTypePerSoggetto = false;
  93.         boolean isSoggettiApplicativiCredenzialiBasicPermitSameCredentials = false;
  94.         boolean isSoggettiApplicativiCredenzialiSslPermitSameCredentials = false;
  95.         boolean isSoggettiApplicativiCredenzialiPrincipalPermitSameCredentials = false;
  96.         
  97.         // Inizializzazione ProtocolFactoryManager
  98.         ConfigurazionePdD configPdD = new ConfigurazionePdD();
  99.         configPdD.setLoader(new Loader());
  100.         configPdD.setLog(log);
  101.         ProtocolFactoryManager.initializeSingleProtocol(log, configPdD, protocollo);
  102.         
  103.         
  104.         // Inizializzo Reader
  105.         DriverRegistroServiziDB driverRegistroServizi = null; 
  106.         DriverConfigurazioneDB driverConfigurazione = null;
  107.         org.openspcoop2.core.plugins.dao.jdbc.JDBCServiceManager serviceManagerPlugins = null;
  108.         org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManagerControlloTraffico = null;
  109.         org.openspcoop2.core.allarmi.dao.jdbc.JDBCServiceManager serviceManagerAllarmi = null;
  110.         // TODO INIT
  111.         RegistryReader archiveRegistryReader = new RegistryReader(driverRegistroServizi,log);
  112.         ConfigIntegrationReader archiveConfigIntegrationReader = new ConfigIntegrationReader(driverConfigurazione,log);
  113.         
  114.         
  115.         // trasformazione in archivio openspcoop2
  116.         IProtocolFactory<?> pf = ProtocolFactoryManager.getInstance().getProtocolFactoryByName(protocollo);
  117.         IArchive archiveEngine = pf.createArchive();
  118.         Archive archive = archiveEngine.importArchive(archiveBytes, archiveMode, archiveModeType, archiveRegistryReader, archiveConfigIntegrationReader, validateDocuments,null);
  119.         
  120.         
  121.         // validazione
  122.         ArchiveValidator validator = new ArchiveValidator(archiveRegistryReader);
  123.         ImportInformationMissingCollection importInformationMissingCollection = new ImportInformationMissingCollection();
  124.         validator.validateArchive(archive, protocollo, validateDocuments, importInformationMissingCollection, userLogin, 
  125.                 isShowCorrelazioneAsincronaInAccordi, false);
  126.         // TODO: Gestore correttamente le eccezioni
  127.         
  128.         
  129.         // Import
  130.         ArchiveEngine importerEngine = new ArchiveEngine(driverRegistroServizi, driverConfigurazione, 
  131.                 serviceManagerPlugins,
  132.                 serviceManagerControlloTraffico, 
  133.                 serviceManagerAllarmi);
  134.         ImporterArchiveUtils importerArchiveUtils = 
  135.                 new ImporterArchiveUtils(importerEngine, log, userLogin, nomePddOperativa, tipoPddDefault,
  136.                         isShowGestioneWorkflowStatoDocumenti, updateAbilitato,
  137.                         importPolicyConfig, 
  138.                         importPluginConfig, checkExistsPluginConfig,
  139.                         importConfig);
  140.         ArchiveEsitoImport result = importerArchiveUtils.importArchive(archive, userLogin, 
  141.                 isShowAccordiColonnaAzioni,
  142.                 isAbilitatoControlloUnicitaImplementazioneAccordoPerSoggetto, 
  143.                 isAbilitatoControlloUnicitaImplementazionePortTypePerSoggetto,
  144.                 isSoggettiApplicativiCredenzialiBasicPermitSameCredentials,
  145.                 isSoggettiApplicativiCredenzialiSslPermitSameCredentials,
  146.                 isSoggettiApplicativiCredenzialiPrincipalPermitSameCredentials);
  147.         String resultAsString = archiveEngine.toString(result, archiveMode);
  148.         log.info(resultAsString);
  149.         

  151.     }

  153. }
Created with JaCoCo 0.8.8.202204050719