AuditAppender.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.  */


  22. package org.openspcoop2.web.lib.audit.appender;

  24. import java.util.ArrayList;
  25. import java.util.HashMap;
  26. import java.util.Iterator;
  27. import java.util.List;
  28. import java.util.Properties;

  30. import org.openspcoop2.core.config.GenericProperties;
  31. import org.openspcoop2.core.config.MessageSecurityFlow;
  32. import org.openspcoop2.core.config.MessageSecurityFlowParameter;
  33. import org.openspcoop2.core.config.PortaApplicativa;
  34. import org.openspcoop2.core.config.PortaDelegata;
  35. import org.openspcoop2.core.config.Property;
  36. import org.openspcoop2.core.config.ServizioApplicativo;
  37. import org.openspcoop2.core.constants.CostantiConnettori;
  38. import org.openspcoop2.core.constants.CostantiDB;
  39. import org.openspcoop2.core.constants.CostantiProprieta;
  40. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  41. import org.openspcoop2.core.registry.Fruitore;
  42. import org.openspcoop2.core.registry.ProtocolProperty;
  43. import org.openspcoop2.pdd.core.byok.DriverBYOKUtilities;
  44. import org.openspcoop2.utils.UtilsException;
  45. import org.openspcoop2.utils.date.DateManager;
  46. import org.openspcoop2.utils.regexp.RegularExpressionEngine;
  47. import org.openspcoop2.utils.resources.ClassLoaderUtilities;
  48. import org.openspcoop2.utils.serialization.FilteredObject;
  49. import org.openspcoop2.utils.serialization.IDBuilder;
  50. import org.openspcoop2.utils.serialization.SerializationConfig;
  51. import org.openspcoop2.web.lib.audit.AuditException;
  52. import org.openspcoop2.web.lib.audit.costanti.Costanti;
  53. import org.openspcoop2.web.lib.audit.dao.Appender;
  54. import org.openspcoop2.web.lib.audit.dao.Configurazione;
  55. import org.openspcoop2.web.lib.audit.dao.Filtro;
  56. import org.openspcoop2.web.lib.audit.log.Binary;
  57. import org.openspcoop2.web.lib.audit.log.Operation;
  58. import org.openspcoop2.web.lib.audit.log.constants.Stato;
  59. import org.openspcoop2.web.lib.audit.log.constants.Tipologia;

  61. /**
  62.  * Appender per registrare operazione di audit
  63.  * 
  64.  * 
  65.  * @author Andrea Poli (apoli@link.it)
  66.  * @author Stefano Corallo (corallo@link.it)
  67.  * @author Sandra Giangrandi (sandra@link.it)
  68.  * @author $Author$
  69.  * @version $Rev$, $Date$
  70.  * 
  71.  */
  72. public class AuditAppender {

  74.     private static final String AUDIT_DISABILITATO = "Audit engine disabilitato";
  75.     private static final String APPENDER_NON_FORNITI = "Appender non forniti";
  76.     
  77.     /* Configurazione */
  78.     private static Configurazione configurazioneAuditing;
  79.     private static IDBuilder idBuilder;
  80.     private static HashMap<String,IAuditAppender> appenders = new HashMap<>();
  81.     
  82.     public void initializeAudit(Configurazione configurazioneAuditing,
  83.             IDBuilder idBuilder) throws AuditException{
  84.         initializeAuditEngine(configurazioneAuditing, idBuilder);
  85.     }
  86.     
  87.     private static synchronized void initializeAuditEngine(Configurazione configurazioneAuditing,
  88.             IDBuilder idBuilder) throws AuditException{
  89.         
  90.         try{
  91.         
  92.             AuditAppender.appenders.clear();    
  93.             
  94.             AuditAppender.configurazioneAuditing= configurazioneAuditing;
  95.             AuditAppender.idBuilder = idBuilder;
  96.             
  97.             for(int i=0; i<AuditAppender.configurazioneAuditing.sizeAppender(); i++){
  98.                 
  99.                 // Istanzio appender
  100.                 Appender appenderConf = AuditAppender.configurazioneAuditing.getAppender(i);
  101.                 Class<?> c = Class.forName(appenderConf.getClassName());
  102.                 IAuditAppender appender = (IAuditAppender) ClassLoaderUtilities.newInstance(c);
  103.                 
  104.                 // Inizializzo appender
  105.                 Properties propertiesAppender = new Properties();
  106.                 for(int j=0; j<appenderConf.sizeProperties(); j++){
  107.                     propertiesAppender.put(appenderConf.getProperty(j).getName(), 
  108.                             appenderConf.getProperty(j).getValue());
  109.                 }
  110.                 appender.initAppender(appenderConf.getNome(),propertiesAppender);
  111.                 
  112.                 AuditAppender.appenders.put(appenderConf.getNome(),appender);
  113.             }
  114.             
  115.         }catch(Exception e){
  116.             throw new AuditException("InizializzazioneFallita: "+e.getMessage(),e);
  117.         }
  118.     }
  119.     
  120.     public void updateConfigurazioneAuditing(Configurazione configurazioneAuditing) throws AuditException{
  121.         try{
  122.             synchronized(AuditAppender.configurazioneAuditing){
  123.             
  124.                 AuditAppender.configurazioneAuditing = configurazioneAuditing;
  125.                 
  126.                 AuditAppender.appenders.clear();
  127.                 
  128.                 for(int i=0; i<AuditAppender.configurazioneAuditing.sizeAppender(); i++){
  129.                     
  130.                     // Istanzio appender
  131.                     Appender appenderConf = AuditAppender.configurazioneAuditing.getAppender(i);
  132.                     Class<?> c = Class.forName(appenderConf.getClassName());
  133.                     IAuditAppender appender = (IAuditAppender) ClassLoaderUtilities.newInstance(c);
  134.                     
  135.                     // Inizializzo appender
  136.                     Properties propertiesAppender = new Properties();
  137.                     for(int j=0; j<appenderConf.sizeProperties(); j++){
  138.                         propertiesAppender.put(appenderConf.getProperty(j).getName(), 
  139.                                 appenderConf.getProperty(j).getValue());
  140.                     }
  141.                     appender.initAppender(appenderConf.getNome(),propertiesAppender);
  142.                     
  143.                     AuditAppender.appenders.put(appenderConf.getNome(),appender);
  144.                 }
  145.             }
  146.         }catch(Exception e){
  147.             throw new AuditException("AggiornamentoFallito: "+e.getMessage(),e);
  148.         }
  149.     }

  151.     
  152.     
  153.     public IDOperazione registraOperazioneInFaseDiElaborazione(Tipologia tipoOperazione,Object object,String user,String interfaceMsg, boolean registrazioneBinari,
  154.             DriverBYOKUtilities byok) throws AuditException,AuditDisabilitatoException{
  155.         
  156.         if(!AuditAppender.configurazioneAuditing.isAuditEngineEnabled()){
  157.             throw new AuditDisabilitatoException(AUDIT_DISABILITATO);
  158.         }
  159.         
  160.         try{
  161.             
  162.                 
  163.             Operation operation = new Operation();
  164.             operation.setTipologia(tipoOperazione);
  165.             operation.setUtente(user);
  166.             operation.setStato(Stato.REQUESTING);
  167.             operation.setTimeRequest(DateManager.getDate());
  168.             operation.setTimeExecute(DateManager.getDate());
  169.             operation.setInterfaceMsg(interfaceMsg);
  170.             
  171.             if(object!=null){
  172.                 
  173.                 operation.setTipoOggetto(AuditAppender.idBuilder.getSimpleName(object));
  174.                 operation.setObjectId(AuditAppender.idBuilder.toID(object));
  175.                 operation.setObjectOldId(AuditAppender.idBuilder.toOldID(object));
  176.                 operation.setObjectClass(object.getClass().getName());
  177.                 
  178.             }else{
  179.                 throw new AuditException("Object riguardante l'operazione non definito");
  180.             }

  182.             
  183.             // Filtro operazioni
  184.             org.openspcoop2.utils.serialization.Filter listFilter = new org.openspcoop2.utils.serialization.Filter();
  185.             String objectDetails = filtraOperazione(operation,object,listFilter, registrazioneBinari, byok);
  186.             
  187.             if(objectDetails!=null){
  188.                 operation.setObjectDetails(objectDetails);
  189.                 
  190.                 // Aggiunto binaries filtrati
  191.                 for(int i=0; i<listFilter.sizeFilteredObjects(); i++){
  192.                     FilteredObject filteredObject = listFilter.getFilteredObject(i);
  193.                     
  194.                     Binary binary = new Binary();
  195.                     binary.setBinaryId(filteredObject.getId());
  196.                     binary.setChecksum(filteredObject.getChecksum());
  197.                     operation.addBinary(binary);
  198.                 }
  199.             }
  200.                 
  201.             
  202.             // Appender
  203.             IDOperazione idOperazione = new IDOperazione();
  204.             if(AuditAppender.appenders!=null && AuditAppender.appenders.keySet()!=null){
  205.                 Iterator<String> iterator = AuditAppender.appenders.keySet().iterator();
  206.                 while(iterator.hasNext()){
  207.                     
  208.                     String appenderName = iterator.next();
  209.                     IAuditAppender appender =  AuditAppender.appenders.get(appenderName);
  210.                                     
  211.                     Object idOperazioneAppender =  appender.registraOperazioneInFaseDiElaborazione(operation);
  212.                     idOperazione.addIdOperazione(appenderName, idOperazioneAppender);
  213.                 }
  214.                 return idOperazione;
  215.             }
  216.             else{
  217.                 throw new AuditException(APPENDER_NON_FORNITI);
  218.             }
  219.                 
  220.             
  221.         }catch(AuditDisabilitatoException e){
  222.             throw e;
  223.         }catch(Exception e){
  224.             throw new AuditException("registraOperazioneInFaseDiElaborazione error: "+e.getMessage(),e);
  225.         }
  226.         
  227.     }
  228.     
  229.     
  230.     
  231.     public void registraOperazioneAccesso(Tipologia tipoOperazione,String user,String interfaceMsg, boolean registrazioneBinari,
  232.             DriverBYOKUtilities byok) throws AuditException,AuditDisabilitatoException{
  233.         
  234.         if(!AuditAppender.configurazioneAuditing.isAuditEngineEnabled()){
  235.             throw new AuditDisabilitatoException(AUDIT_DISABILITATO);
  236.         }
  237.         
  238.         try{
  239.             
  240.                 
  241.             Operation operation = new Operation();
  242.             operation.setTipologia(tipoOperazione);
  243.             operation.setUtente(user);
  244.             operation.setStato(Stato.COMPLETED);
  245.             operation.setTimeRequest(DateManager.getDate());
  246.             operation.setTimeExecute(DateManager.getDate());
  247.             operation.setInterfaceMsg(interfaceMsg);
  248.                     
  249.             
  250.             // Filtro operazioni
  251.             filtraOperazione(operation, registrazioneBinari, byok);
  252.             
  253.             
  254.             // Appender
  255.             IDOperazione idOperazione = new IDOperazione();
  256.             if(AuditAppender.appenders!=null && AuditAppender.appenders.keySet()!=null){
  257.                 Iterator<String> iterator = AuditAppender.appenders.keySet().iterator();
  258.                 while(iterator.hasNext()){
  259.                     
  260.                     String appenderName = iterator.next();
  261.                     IAuditAppender appender =  AuditAppender.appenders.get(appenderName);
  262.                                     
  263.                     Object idOperazioneAppender =  appender.registraOperazioneInFaseDiElaborazione(operation);
  264.                     idOperazione.addIdOperazione(appenderName, idOperazioneAppender);
  265.                 }
  266.             }
  267.             else{
  268.                 throw new AuditException(APPENDER_NON_FORNITI);
  269.             }
  270.                 
  271.             
  272.         }catch(AuditDisabilitatoException e){
  273.             throw e;
  274.         }catch(Exception e){
  275.             throw new AuditException("registraOperazioneInFaseDiElaborazione error: "+e.getMessage(),e);
  276.         }
  277.         
  278.     }
  279.     
  280.     
  281.     
  282.     public void registraOperazioneCompletataConSuccesso(IDOperazione idOperazione,String interfaceMsg) throws AuditException,AuditDisabilitatoException{
  283.         
  284.         if(!AuditAppender.configurazioneAuditing.isAuditEngineEnabled()){
  285.             throw new AuditDisabilitatoException(AUDIT_DISABILITATO);
  286.         }
  287.         
  288.         try{
  289.             
  290.             if(idOperazione==null){
  291.                 throw new AuditException("Identificativo dell'operazione per cui cambiare stato non fornito");
  292.             }
  293.             
  294.             if(AuditAppender.appenders!=null && AuditAppender.appenders.keySet()!=null){
  295.                 Iterator<String> iterator = AuditAppender.appenders.keySet().iterator();
  296.                 while(iterator.hasNext()){
  297.                     
  298.                     String appenderName = iterator.next();
  299.                     IAuditAppender appender =  AuditAppender.appenders.get(appenderName);
  300.                     Object id = idOperazione.getIdOperazione(appenderName);
  301.                     if(id==null){
  302.                         throw new AuditException("Identificativo dell'operazione per l'appender["+appenderName+"] non fornito");
  303.                     }
  304.                     if(id instanceof Operation){
  305.                         Operation op = (Operation) id;
  306.                         op.setInterfaceMsg(interfaceMsg);
  307.                     }
  308.                     
  309.                     appender.registraOperazioneCompletataConSuccesso(id);
  310.                 }
  311.             }
  312.             else{
  313.                 throw new AuditException(APPENDER_NON_FORNITI);
  314.             }
  315.                 
  316.             
  317.         }catch(Exception e){
  318.             throw new AuditException("registraOperazioneCompletataConSuccesso error: "+e.getMessage(),e);
  319.         }
  320.     }
  321.     
  322.     
  323.     
  324.     
  325.     
  326.     public void registraOperazioneTerminataConErrore(IDOperazione idOperazione,String motivoErrore,String interfaceMsg) throws AuditException,AuditDisabilitatoException{
  327.         
  328.         if(!AuditAppender.configurazioneAuditing.isAuditEngineEnabled()){
  329.             throw new AuditDisabilitatoException(AUDIT_DISABILITATO);
  330.         }
  331.         
  332.         try{
  333.             
  334.             if(idOperazione==null){
  335.                 throw new AuditException("Identificativo dell'operazione per cui cambiare stato non fornito");
  336.             }
  337.                         
  338.             if(AuditAppender.appenders!=null && AuditAppender.appenders.keySet()!=null){
  339.                 Iterator<String> iterator = AuditAppender.appenders.keySet().iterator();
  340.                 while(iterator.hasNext()){
  341.                     
  342.                     String appenderName = iterator.next();
  343.                     IAuditAppender appender =  AuditAppender.appenders.get(appenderName);
  344.                     Object id = idOperazione.getIdOperazione(appenderName);
  345.                     if(id==null){
  346.                         throw new AuditException("Identificativo dell'operazione per l'appender["+appenderName+"] non fornito");
  347.                     }       
  348.                     if(id instanceof Operation){
  349.                         Operation op = (Operation) id;
  350.                         op.setInterfaceMsg(interfaceMsg);
  351.                     }
  352.                                     
  353.                     appender.registraOperazioneTerminataConErrore(id,motivoErrore);
  354.                 }
  355.             }
  356.             else{
  357.                 throw new AuditException(APPENDER_NON_FORNITI);
  358.             }
  359.                 
  360.             
  361.         }catch(Exception e){
  362.             throw new AuditException("registraOperazioneCompletataConSuccesso error: "+e.getMessage(),e);
  363.         }
  364.     }
  365.     
  366.     
  367.     
  368.     
  369.     
  370.     
  371.     
  372.     
  373.     
  374.     
  375.     
  376.     
  377.     
  378.     // -------------- UTILITY -------------------
  379.     
  380.     private String serializeJsonObject(Object o,org.openspcoop2.utils.serialization.Filter listFilter, boolean registrazioneBinari) throws AuditException{
  381.         try{
  382.             if(!registrazioneBinari) {
  383.                 listFilter.addFilterByValue(byte[].class);
  384.             }
  385.             SerializationConfig config = new SerializationConfig();
  386.             config.setFilter(listFilter);
  387.             config.setIdBuilder(AuditAppender.idBuilder);
  388.             config.setPrettyPrint(true);
  389.             // Deprecato
  390. /**         org.openspcoop2.utils.serialization.JSonSerializer serializer = 
  391.                 new org.openspcoop2.utils.serialization.JSonSerializer(config);*/
  392.             org.openspcoop2.utils.serialization.JsonJacksonSerializer serializer = 
  393.                 new org.openspcoop2.utils.serialization.JsonJacksonSerializer(config);
  394.             return  serializer.getObject(o);        
  395.         }catch(Exception e){
  396.             throw new AuditException("serializeJsonObject error: "+e.getMessage(),e);
  397.         }
  398.     }
  399.     
  400.     private String serializeXMLObject(Object o,org.openspcoop2.utils.serialization.Filter listFilter, boolean registrazioneBinari) throws AuditException{
  401.         try{
  402.             if(!registrazioneBinari) {
  403.                 listFilter.addFilterByValue(byte[].class);
  404.             }
  405.             SerializationConfig config = new SerializationConfig();
  406.             config.setFilter(listFilter);
  407.             config.setIdBuilder(AuditAppender.idBuilder);
  408.             config.setPrettyPrint(true);
  409.             org.openspcoop2.utils.serialization.XMLSerializer serializer = 
  410.                 new org.openspcoop2.utils.serialization.XMLSerializer(config);
  411.             return  serializer.getObject(o);        
  412.         }catch(Exception e){
  413.             throw new AuditException("serializeXMLObject error: "+e.getMessage(),e);
  414.         }
  415.     }
  416.     
  417.     private void filtraOperazione(Operation operation, boolean registrazioneBinari,
  418.             DriverBYOKUtilities byok) throws AuditException,AuditDisabilitatoException{
  419.         this.filtraOperazione(operation, null, null, registrazioneBinari,
  420.                 byok);
  421.     }
  422.     private String filtraOperazione(Operation operation,Object object,org.openspcoop2.utils.serialization.Filter listFilter, boolean registrazioneBinari,
  423.             DriverBYOKUtilities byok) throws AuditException,AuditDisabilitatoException{
  424.         
  425.         try{
  426.         
  427.             ArrayList<Filtro> filtri = AuditAppender.configurazioneAuditing.getFiltri();
  428.             boolean auditEnabledDefault = AuditAppender.configurazioneAuditing.isAuditEnabled();
  429.             boolean dumpEnabledDefault = AuditAppender.configurazioneAuditing.isDumpEnabled();
  430.             String objectDetails = null;
  431.             
  432.             for(int i=0; i<filtri.size(); i++){
  433.                 
  434.                 Filtro filtro = filtri.get(i);
  435.                 
  436.                 /**System.out.println("ANALIZZO FILTRO["+i+"]: "+filtro.toString());*/
  437.                 
  438.                 if(filtro.getUsername()==null &&
  439.                         filtro.getTipoOperazione()==null &&
  440.                         filtro.getTipoOggettoInModifica()==null &&
  441.                         filtro.getStatoOperazione()==null &&
  442.                         filtro.getDump()==null){
  443.                     throw new AuditException("Filtro("+i+1+") non valido: nessun meccanismo di filtro definito");
  444.                 }
  445.                 
  446.                 if(filtro.getUsername()!=null &&
  447.                     // Se e' definito un username nel filtro controllo che corrisponda
  448.                     !filtro.getUsername().equals(operation.getUtente())){
  449.                     continue;
  450.                 }
  451.                 
  452.                 if(filtro.getTipoOperazione()!=null &&
  453.                     // Se e' definito un tipo di operazione nel filtro controllo che corrisponda
  454.                     !filtro.getTipoOperazione().equals(operation.getTipologia())){
  455.                     continue;
  456.                 }
  457.                 
  458.                 if(filtro.getTipoOggettoInModifica()!=null &&
  459.                     // Se e' definito un TipoOggettoInModifica nel filtro controllo che corrisponda
  460.                     !filtro.getTipoOggettoInModifica().equals(operation.getTipoOggetto())){
  461.                     continue;
  462.                 }
  463.                 
  464.                 if(filtro.getStatoOperazione()!=null &&
  465.                     // Se e' definito uno stato dell'operazione nel filtro controllo che corrisponda
  466.                     !filtro.getStatoOperazione().equals(operation.getStato())){
  467.                     continue;
  468.                 }
  469.                 
  470.                 if(filtro.getDump()!=null){
  471.                     
  472.                     if(object==null){
  473.                         continue; // Questo filtro per essere matchato deve essere controllato con un oggetto
  474.                     }
  475.                     
  476.                     if(objectDetails==null){
  477.                         // Serializzo l'oggetto
  478.                         objectDetails = this.serialize(object, listFilter, registrazioneBinari, byok);
  479.                     }
  480.                     
  481.                     // Se e' definito un filtro sul contenuto dell'operazione nel filtro controllo che corrisponda
  482.                     if(filtro.isDumpExprRegular()){
  483.                         if(RegularExpressionEngine.getStringMatchPattern(objectDetails, filtro.getDump())==null){
  484.                             continue;
  485.                         }
  486.                     }else{
  487.                         if(!objectDetails.contains(filtro.getDump())){
  488.                             continue;
  489.                         }
  490.                     }
  491.                 }
  492.                                 
  493.                 // Se arriviamo a questo punto significa che l'operazione soddisfa il filtro.
  494.                 if(!filtro.isAuditEnabled()){
  495.                     throw new AuditDisabilitatoException("Audit disabilitato, criterio adottato in base al filtro numero "+(i+1));
  496.                 }
  497.                 if(filtro.isDumpEnabled()){
  498.                     if(object!=null &&
  499.                         // Se non avevo gia' serializzato prima per la ricerca tramite contenuto
  500.                         objectDetails==null){
  501.                         // Serializzo l'oggetto
  502.                         objectDetails = this.serialize(object, listFilter, registrazioneBinari, byok);
  503.                     }
  504.                 }else{
  505.                     if(objectDetails!=null){
  506.                         objectDetails=null; // era stato utilizzato per effettuare filtro sui contenuti ma non deve essere dumpato
  507.                     }
  508.                 }
  509.                                 
  510.                 return objectDetails; // regola matcha
  511.             }
  512.             
  513.             // Se nessun filtro sopra viene matchato, si applica il criterio di default
  514.             if(!auditEnabledDefault){
  515.                 throw new AuditDisabilitatoException("Audit disabilitato nella configurazione generale (Non vi sono filtri che creano eccezioni)");
  516.             }
  517.             if(dumpEnabledDefault){
  518.                 if(object!=null &&
  519.                     // Se non avevo gia' serializzato prima per la ricerca tramite contenuto
  520.                     objectDetails==null){
  521.                     // Serializzo l'oggetto
  522.                     objectDetails = this.serialize(object, listFilter, registrazioneBinari, byok);
  523.                 }
  524.             }else{
  525.                 if(objectDetails!=null){
  526.                     objectDetails=null; // era stato utilizzato per effettuare filtro sui contenuti ma non deve essere dumpato
  527.                 }
  528.             }
  529.             
  530.             return objectDetails;
  531.             
  532.         }catch(AuditDisabilitatoException e){
  533.             throw e;
  534.         }catch(Exception e){
  535.             throw new AuditException("filtraOperazione error: "+e.getMessage(),e);
  536.         }
  537.     }
  538.     
  539.     private Object byok(DriverBYOKUtilities byok, Object object) throws UtilsException {
  540.         if (object instanceof org.openspcoop2.core.config.Soggetto) {
  541.             org.openspcoop2.core.config.Soggetto sCloned = (org.openspcoop2.core.config.Soggetto) ((org.openspcoop2.core.config.Soggetto) object).clone();
  542.             if(sCloned.getConnettore()!=null && !sCloned.getConnettore().isEmpty()) {
  543.                 for (org.openspcoop2.core.config.Connettore connettore : sCloned.getConnettore()) {
  544.                     byokConnettore(byok, connettore);       
  545.                 }
  546.             }
  547.             return sCloned;
  548.         }
  549.         else if (object instanceof org.openspcoop2.core.registry.Soggetto) {
  550.             org.openspcoop2.core.registry.Soggetto sCloned = (org.openspcoop2.core.registry.Soggetto) ((org.openspcoop2.core.registry.Soggetto) object).clone();
  551.             if(sCloned.getConnettore()!=null) {
  552.                 byokConnettore(byok, sCloned.getConnettore());
  553.             }
  554.             return sCloned;
  555.         }
  556.         else if (object instanceof ServizioApplicativo) {
  557.             ServizioApplicativo sCloned = (ServizioApplicativo) ((ServizioApplicativo) object).clone();
  558.             return byok(byok, sCloned);
  559.         }
  560.         else if (object instanceof PortaDelegata) {
  561.             PortaDelegata pdCloned = (PortaDelegata) ((PortaDelegata) object).clone();
  562.             return byok(byok, pdCloned);
  563.         }
  564.         else if (object instanceof PortaApplicativa) {
  565.             PortaApplicativa paCloned = (PortaApplicativa) ((PortaApplicativa) object).clone();
  566.             return byok(byok, paCloned);
  567.         }
  568.         else if(object instanceof GenericProperties) {
  569.             GenericProperties gpCloned = (GenericProperties) ((GenericProperties) object).clone();
  570.             return byok(byok, gpCloned);
  571.         }
  572.         else if(object instanceof AccordoServizioParteSpecifica) {
  573.             AccordoServizioParteSpecifica aspsCloned = (AccordoServizioParteSpecifica) ((AccordoServizioParteSpecifica) object).clone();
  574.             return byok(byok, aspsCloned);
  575.         }
  576.         
  577.         return object;
  578.     }
  579.     private Object byok(DriverBYOKUtilities byok, ServizioApplicativo sCloned) throws UtilsException {
  580.         if(sCloned.getInvocazioneServizio()!=null && sCloned.getInvocazioneServizio().getConnettore()!=null) {
  581.             byokConnettore(byok, sCloned.getInvocazioneServizio().getConnettore());
  582.         }
  583.         if(sCloned.getInvocazioneServizio()!=null && sCloned.getInvocazioneServizio().getAutenticazione()!=null &&
  584.                 org.openspcoop2.core.config.constants.InvocazioneServizioTipoAutenticazione.BASIC.equals(sCloned.getInvocazioneServizio().getAutenticazione()) &&
  585.                 sCloned.getInvocazioneServizio().getCredenziali()!=null) {
  586.             byokCredenzialiConnettore(byok, sCloned.getInvocazioneServizio().getCredenziali());
  587.         }
  588.         if(sCloned.getRispostaAsincrona()!=null && sCloned.getRispostaAsincrona().getConnettore()!=null) {
  589.             byokConnettore(byok, sCloned.getRispostaAsincrona().getConnettore());
  590.         }
  591.         if(sCloned.getRispostaAsincrona()!=null && sCloned.getRispostaAsincrona().getAutenticazione()!=null &&
  592.                 org.openspcoop2.core.config.constants.InvocazioneServizioTipoAutenticazione.BASIC.equals(sCloned.getRispostaAsincrona().getAutenticazione()) &&
  593.                 sCloned.getRispostaAsincrona().getCredenziali()!=null) {
  594.             byokCredenzialiConnettore(byok, sCloned.getRispostaAsincrona().getCredenziali());
  595.         }
  596.         if(sCloned.sizeProtocolPropertyList()>0) {
  597.             for (org.openspcoop2.core.config.ProtocolProperty p : sCloned.getProtocolProperty()) {
  598.                 if(isConfidentialProtocolProperties(p.getName())) {
  599.                     p.setValue(byok.wrap(p.getValue()));
  600.                 }
  601.             }
  602.         }
  603.         return sCloned;
  604.     }
  605.     private void byokCredenzialiConnettore(DriverBYOKUtilities byok, org.openspcoop2.core.config.InvocazioneCredenziali credenziale) throws UtilsException {
  606.         if(credenziale.getPassword()!=null) {
  607.             credenziale.setPassword(byok.wrap(credenziale.getPassword()));
  608.         }
  609.     }
  610.     private void byokConnettore(DriverBYOKUtilities byok, org.openspcoop2.core.config.Connettore connettore) throws UtilsException {
  611.         if(connettore.sizePropertyList()>0) {
  612.             for (org.openspcoop2.core.config.Property p : connettore.getPropertyList()) {
  613.                 if(isConfidentialConnettore(p.getNome())) {
  614.                     p.setValore(byok.wrap(p.getValore()));
  615.                 }
  616.             }
  617.         }   
  618.     }
  619.     private void byokConnettore(DriverBYOKUtilities byok, org.openspcoop2.core.registry.Connettore connettore) throws UtilsException {
  620.         if(connettore.sizePropertyList()>0) {
  621.             for (org.openspcoop2.core.registry.Property p : connettore.getPropertyList()) {
  622.                 if(isConfidentialConnettore(p.getNome())) {
  623.                     p.setValore(byok.wrap(p.getValore()));
  624.                 }
  625.             }
  626.         }   
  627.     }
  628.     private boolean isConfidentialConnettore(String nomeProprieta) {
  629.         for (String nomeProprietaConfidential : CostantiConnettori.getConfidentials()) {
  630.             if(nomeProprieta.equals(nomeProprietaConfidential)) {
  631.                 return true;
  632.             }
  633.         }
  634.         return false;
  635.     }
  636.     private Object byok(DriverBYOKUtilities byok, PortaDelegata pdCloned) throws UtilsException {
  637.         if(pdCloned.getMessageSecurity()!=null) {
  638.             if(pdCloned.getMessageSecurity().getRequestFlow()!=null) {
  639.                 byok(byok, pdCloned.getMessageSecurity().getRequestFlow());
  640.             }
  641.             if(pdCloned.getMessageSecurity().getResponseFlow()!=null) {
  642.                 byok(byok, pdCloned.getMessageSecurity().getResponseFlow());
  643.             }
  644.         }
  645.         return pdCloned;
  646.     }
  647.     private Object byok(DriverBYOKUtilities byok, PortaApplicativa paCloned) throws UtilsException {
  648.         if(paCloned.getMessageSecurity()!=null) {
  649.             if(paCloned.getMessageSecurity().getRequestFlow()!=null) {
  650.                 byok(byok, paCloned.getMessageSecurity().getRequestFlow());
  651.             }
  652.             if(paCloned.getMessageSecurity().getResponseFlow()!=null) {
  653.                 byok(byok, paCloned.getMessageSecurity().getResponseFlow());
  654.             }
  655.         }
  656.         return paCloned;
  657.     }
  658.     private void byok(DriverBYOKUtilities byok, MessageSecurityFlow flow) throws UtilsException {
  659.         if(flow.sizeParameterList()>0) {
  660.             for (MessageSecurityFlowParameter p : flow.getParameterList()) {
  661.                 if(isConfidentialSecurity(p.getNome())) {
  662.                     p.setValore(byok.wrap(p.getValore()));
  663.                 }
  664.             }
  665.         }
  666.     }
  667.     private boolean isConfidentialSecurity(String nomeProprieta) {
  668.         List<String> messageSecurityIds = CostantiProprieta.getMessageSecurityIds();
  669.         if(messageSecurityIds!=null && !messageSecurityIds.isEmpty()) {
  670.             for (String id : messageSecurityIds) {
  671.                 List<String> l =  CostantiProprieta.getMessageSecurityProperties(id);
  672.                 for (String nomeProprietaCheck : l) {
  673.                     if(nomeProprietaCheck.equals(nomeProprieta)) {
  674.                         return true;
  675.                     }
  676.                 }
  677.             }
  678.         }
  679.         return false;
  680.     }
  681.     
  682.     private Object byok(DriverBYOKUtilities byok, GenericProperties gp) throws UtilsException {
  683.         if(gp.sizePropertyList()>0) {
  684.             for (Property p : gp.getPropertyList()) {
  685.                 if(isConfidentialToken(gp.getTipo(), p.getNome())) {
  686.                     p.setValore(byok.wrap(p.getValore()));
  687.                 }
  688.             }
  689.         }
  690.         return gp;
  691.     }
  692.     private boolean isConfidentialToken(String tipo, String nomeProprieta) {
  693.         List<String> l = null;
  694.         if(CostantiProprieta.TOKEN_VALIDATION_ID.equals(tipo)) {
  695.             l = CostantiProprieta.getTokenValidationProperties();
  696.         }
  697.         else if(CostantiProprieta.TOKEN_NEGOZIAZIONE_ID.equals(tipo)) {
  698.             l = CostantiProprieta.getTokenRetrieveProperties();
  699.         }
  700.         else if(CostantiProprieta.ATTRIBUTE_AUTHORITY_ID.equals(tipo)) {
  701.             l = CostantiProprieta.getAttributeAuthorityProperties();
  702.         }
  703.         if(l!=null) {
  704.             for (String nomeProprietaCheck : l) {
  705.                 if(nomeProprietaCheck.equals(nomeProprieta)) {
  706.                     return true;
  707.                 }
  708.             }
  709.         }
  710.         return false;
  711.     }
  712.     private Object byok(DriverBYOKUtilities byok, AccordoServizioParteSpecifica asps) throws UtilsException {
  713.         if(asps.sizeProtocolPropertyList()>0) {
  714.             for (ProtocolProperty p : asps.getProtocolProperty()) {
  715.                 if(isConfidentialProtocolProperties(p.getName())) {
  716.                     p.setValue(byok.wrap(p.getValue()));
  717.                 }
  718.             }
  719.         }
  720.         if(asps.sizeFruitoreList()>0) {
  721.             for (Fruitore fruitore : asps.getFruitoreList()) {
  722.                 byok(byok, fruitore);
  723.             }
  724.         }
  725.         if(asps.getConfigurazioneServizio()!=null && asps.getConfigurazioneServizio().getConnettore()!=null) {
  726.             byokConnettore(byok, asps.getConfigurazioneServizio().getConnettore());
  727.         }
  728.         return asps;
  729.     }
  730.     private Object byok(DriverBYOKUtilities byok, Fruitore fruitore) throws UtilsException {
  731.         if(fruitore.sizeProtocolPropertyList()>0) {
  732.             for (ProtocolProperty p : fruitore.getProtocolProperty()) {
  733.                 if(isConfidentialProtocolProperties(p.getName())) {
  734.                     p.setValue(byok.wrap(p.getValue()));
  735.                 }
  736.             }
  737.         }
  738.         if(fruitore.getConnettore()!=null) {
  739.             byokConnettore(byok, fruitore.getConnettore());
  740.         }
  741.         return fruitore;
  742.     }
  743.     private boolean isConfidentialProtocolProperties(String nomeProprieta) {
  744.         return CostantiDB.MODIPA_KEYSTORE_PASSWORD.equals(nomeProprieta) ||
  745.                 CostantiDB.MODIPA_KEY_PASSWORD.equals(nomeProprieta) ||
  746.                 CostantiDB.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CERTIFICATI_TRUSTSTORE_PASSWORD.equals(nomeProprieta) ||
  747.                 CostantiDB.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_SSL_TRUSTSTORE_PASSWORD.equals(nomeProprieta);
  748.     }
  749.     
  750.     
  751.     private String serialize(Object object,org.openspcoop2.utils.serialization.Filter listFilter, boolean registrazioneBinari,
  752.             DriverBYOKUtilities byok)throws AuditException{
  753.         if(byok!=null) {
  754.             try {
  755.                 object = byok(byok, object);
  756.             }catch(Exception e) {
  757.                 throw new AuditException(e.getMessage(),e);
  758.             }
  759.         }
  760.         if(Costanti.DUMP_JSON_FORMAT.equals(AuditAppender.configurazioneAuditing.getDumpFormat())){
  761.             return this.serializeJsonObject(object, listFilter, registrazioneBinari);
  762.         }
  763.         else if(Costanti.DUMP_XML_FORMAT.equals(AuditAppender.configurazioneAuditing.getDumpFormat())){
  764.             return this.serializeXMLObject(object, listFilter, registrazioneBinari);
  765.         }else {
  766.             throw new AuditException("Tipo di formattazione non conosciuta: "+AuditAppender.configurazioneAuditing.getDumpFormat());
  767.         }
  768.     }
  769. }
Created with JaCoCo 0.8.8.202204050719