ErogazioniGruppiApiServiceImpl.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.gruppi;

  22. import java.util.ArrayList;
  23. import java.util.Arrays;
  24. import java.util.List;

  26. import org.apache.commons.lang.StringEscapeUtils;
  27. import org.apache.commons.lang3.StringUtils;
  28. import org.openspcoop2.core.commons.Filtri;
  29. import org.openspcoop2.core.commons.Liste;
  30. import org.openspcoop2.core.config.PortaApplicativa;
  31. import org.openspcoop2.core.config.constants.TipoAutenticazionePrincipal;
  32. import org.openspcoop2.core.config.rs.server.api.ErogazioniGruppiApi;
  33. import org.openspcoop2.core.config.rs.server.api.impl.Enums;
  34. import org.openspcoop2.core.config.rs.server.api.impl.Helper;
  35. import org.openspcoop2.core.config.rs.server.api.impl.IdServizio;
  36. import org.openspcoop2.core.config.rs.server.api.impl.erogazioni.ErogazioniApiHelper;
  37. import org.openspcoop2.core.config.rs.server.api.impl.erogazioni.ErogazioniEnv;
  38. import org.openspcoop2.core.config.rs.server.config.ServerProperties;
  39. import org.openspcoop2.core.config.rs.server.model.ApiDescrizione;
  40. import org.openspcoop2.core.config.rs.server.model.Gruppo;
  41. import org.openspcoop2.core.config.rs.server.model.GruppoAzioni;
  42. import org.openspcoop2.core.config.rs.server.model.GruppoEreditaConfigurazione;
  43. import org.openspcoop2.core.config.rs.server.model.GruppoItem;
  44. import org.openspcoop2.core.config.rs.server.model.GruppoNome;
  45. import org.openspcoop2.core.config.rs.server.model.GruppoNuovaConfigurazione;
  46. import org.openspcoop2.core.config.rs.server.model.ListaGruppi;
  47. import org.openspcoop2.core.config.rs.server.model.ModalitaConfigurazioneGruppoEnum;
  48. import org.openspcoop2.core.id.IDPortaApplicativa;
  49. import org.openspcoop2.core.mapping.MappingErogazionePortaApplicativa;
  50. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  51. import org.openspcoop2.utils.BooleanNullable;
  52. import org.openspcoop2.utils.service.BaseImpl;
  53. import org.openspcoop2.utils.service.authorization.AuthorizationConfig;
  54. import org.openspcoop2.utils.service.authorization.AuthorizationManager;
  55. import org.openspcoop2.utils.service.beans.ProfiloEnum;
  56. import org.openspcoop2.utils.service.beans.utils.BaseHelper;
  57. import org.openspcoop2.utils.service.beans.utils.ListaUtils;
  58. import org.openspcoop2.utils.service.context.IContext;
  59. import org.openspcoop2.utils.service.fault.jaxrs.FaultCode;
  60. import org.openspcoop2.web.ctrlstat.core.ConsoleSearch;
  61. import org.openspcoop2.web.ctrlstat.costanti.CostantiControlStation;
  62. import org.openspcoop2.web.ctrlstat.servlet.aps.AccordiServizioParteSpecificaPorteApplicativeMappingInfo;
  63. import org.openspcoop2.web.ctrlstat.servlet.aps.AccordiServizioParteSpecificaUtilities;
  64. import org.openspcoop2.web.ctrlstat.servlet.connettori.ConnettoriCostanti;
  65. import org.openspcoop2.web.ctrlstat.servlet.pa.PorteApplicativeUtilities;
  66. import org.openspcoop2.web.lib.mvc.ServletUtils;
  67. import org.openspcoop2.web.lib.mvc.TipoOperazione;

  69. /**
  70.  * ErogazioniGruppiApiServiceImpl
  71.  * 
  72.  * @author $Author$
  73.  * @version $Rev$, $Date$
  74.  * 
  75.  */
  76. public class ErogazioniGruppiApiServiceImpl extends BaseImpl implements ErogazioniGruppiApi {

  78.     public ErogazioniGruppiApiServiceImpl(){
  79.         super(org.slf4j.LoggerFactory.getLogger(ErogazioniGruppiApiServiceImpl.class));
  80.     }

  82.     private AuthorizationConfig getAuthorizationConfig() throws Exception{
  83.         return new AuthorizationConfig(ServerProperties.getInstance().getProperties());
  84.     }

  86.     /**
  87.      * Aggiunta di azioni o risorse dell'API al gruppo
  88.      *
  89.      * Questa operazione consente di aggiungere azioni o risorse dell'API al gruppo
  90.      *
  91.      */
  92.     @Override
  93.     public void addErogazioneGruppoAzioni(GruppoAzioni body, String nome, Integer versione, String nomeGruppo, ProfiloEnum profilo, String soggetto, String tipoServizio) {
  94.         IContext context = this.getContext();
  95.         try {

  97.             context.getLogger().info("Invocazione in corso ...");
  98.             
  99.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  100.             context.getLogger().debug("Autorizzazione completata con successo");
  101.             
  102.             BaseHelper.throwIfNull(body);
  103.             
  104.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  105.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfErogazione(tipoServizio, nome, versione, env.idSoggetto.toIDSoggetto(), env), "Erogazione");
  106.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps), asps.getId());
  107.             final IDPortaApplicativa idPa = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getIDGruppoPA(nomeGruppo, idAsps, env.apsCore), "Gruppo per l'erogazione scelta");
  108.             final PortaApplicativa pa = env.paCore.getPortaApplicativa(idPa);
  109.                         
  110.             List<String> azioniOccupate = ErogazioniApiHelper.getAzioniOccupateErogazione(idAsps, env.apsCore, env.paCore);
  111.                     
  112.             ErogazioniApiHelper.checkAzioniAdd( 
  113.                     body.getAzioni(),
  114.                     azioniOccupate,
  115.                     env.apcCore.getAzioni(asps, env.apcCore.getAccordoServizioSintetico(asps.getIdAccordo()), false, false, null)
  116.                 );
  117.             
  118.             env.requestWrapper.overrideParameterValues(CostantiControlStation.PARAMETRO_AZIONI, body.getAzioni().toArray(new String[0]));
  119.         
  120.             List<MappingErogazionePortaApplicativa> listaMappingErogazione = env.apsCore.mappingServiziPorteAppList(idAsps,asps.getId(), null);
  121.             if (!env.paHelper.porteAppAzioneCheckData(TipoOperazione.ADD,azioniOccupate,listaMappingErogazione)) {
  122.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException(StringEscapeUtils.unescapeHtml(env.pd.getMessage()));
  123.             }
  124.             
  125.             // aggiungo azione nel db
  126.             for(String azione: body.getAzioni()) {
  127.                 pa.getAzione().addAzioneDelegata(azione);
  128.             }

  130.             env.paCore.performUpdateOperation(env.userLogin, false, pa);

  132.             context.getLogger().info("Invocazione completata con successo");        
  133.      
  134.             // Bug Fix: altrimenti viene generato 204
  135.             context.getServletResponse().setStatus(201);
  136.         }
  137.         catch(javax.ws.rs.WebApplicationException e) {
  138.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  139.             throw e;
  140.         }
  141.         catch(Throwable e) {
  142.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  143.             throw FaultCode.ERRORE_INTERNO.toException(e);
  144.         }
  145.     }
  146.     
  147.     /**
  148.      * Creazione di un gruppo di azioni o risorse dell'API erogata
  149.      *
  150.      * Questa operazione consente di creare un gruppo di azioni o risorse dell'API erogata
  151.      *
  152.      */
  153.     @Override
  154.     public void createErogazioneGruppo(Gruppo body, String nome, Integer versione, ProfiloEnum profilo, String soggetto, String tipoServizio) {
  155.         IContext context = this.getContext();
  156.         try {
  157.             context.getLogger().info("Invocazione in corso ...");     

  159.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  160.             context.getLogger().debug("Autorizzazione completata con successo");     
  161.             
  162.             BaseHelper.throwIfNull(body);

  164.             
  165.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  166.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfErogazione(tipoServizio, nome, versione, env.idSoggetto.toIDSoggetto(), env), "Erogazione");
  167.             IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps), asps.getId());
  168.     
  169.             String mappingPadre = null;
  170.             String erogazioneAutenticazione = null;
  171.             String erogazioneAutenticazioneOpzionale = null;
  172.             TipoAutenticazionePrincipal erogazioneAutenticazionePrincipal = null;
  173.             List<String> erogazioneAutenticazioneParametroList = null;
  174.             
  175.             if ( body.getConfigurazione().getModalita() == ModalitaConfigurazioneGruppoEnum.NUOVA ) {
  176.                 
  177.                 final GruppoNuovaConfigurazione confNuova = ErogazioniApiHelper.deserializeModalitaConfGruppo(body.getConfigurazione().getModalita(), body.getConfigurazione());
  178.                 
  179.                 if(confNuova.getAutenticazione()!=null) {
  180.                     erogazioneAutenticazione = Enums.toTipoAutenticazione(confNuova.getAutenticazione().getTipo()).toString();
  181.                     BooleanNullable autenticazioneOpzionaleNullable = ErogazioniApiHelper.getAutenticazioneOpzionale(confNuova.getAutenticazione()); // gestisce authn se null
  182.                     erogazioneAutenticazioneOpzionale = ServletUtils.boolToCheckBoxStatus(autenticazioneOpzionaleNullable!=null ? autenticazioneOpzionaleNullable.getValue() : null);
  183.                     erogazioneAutenticazionePrincipal = ErogazioniApiHelper.getTipoAutenticazionePrincipal(confNuova.getAutenticazione()); 
  184.                     erogazioneAutenticazioneParametroList = ErogazioniApiHelper.getAutenticazioneParametroList(env, confNuova.getAutenticazione().getTipo(), confNuova.getAutenticazione());
  185.                 }
  186.             }
  187.             
  188.             else if ( body.getConfigurazione().getModalita() == ModalitaConfigurazioneGruppoEnum.EREDITA ) {
  189.                 
  190.                 GruppoEreditaConfigurazione confEredita = ErogazioniApiHelper.deserializeModalitaConfGruppo(body.getConfigurazione().getModalita(), body.getConfigurazione());
  191.                 List<MappingErogazionePortaApplicativa> mappings = ErogazioniApiHelper.getMappingGruppiPA( confEredita.getNome(), idAsps, env.apsCore);
  192.                 if ( mappings.isEmpty() ) {
  193.                     throw FaultCode.RICHIESTA_NON_VALIDA.toException("Il gruppo " + confEredita.getNome() + " da cui ereditare è inesistente");
  194.                 }
  195.                 mappingPadre = mappings.get(0).getNome();       
  196.             }
  197.                         
  198.             final AccordiServizioParteSpecificaPorteApplicativeMappingInfo mappingInfo = AccordiServizioParteSpecificaUtilities.getMappingInfo(mappingPadre, asps, env.apsCore);
  199.             final MappingErogazionePortaApplicativa mappingSelezionato = mappingInfo.getMappingSelezionato();
  200.             final MappingErogazionePortaApplicativa mappingDefault = mappingInfo.getMappingDefault();
  201.             final List<String> azioniOccupate = mappingInfo.getAzioniOccupate();
  202.             
  203.             if ( mappingDefault == null )
  204.                 throw FaultCode.NOT_FOUND.toException("Nessuna erogazione trovata");
  205.             
  206.             if ( mappingSelezionato == null )
  207.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException("Gruppo scelto non trovato");
  208.                         
  209.             ErogazioniApiHelper.checkAzioniAdd( 
  210.                     body.getAzioni(),
  211.                     azioniOccupate,
  212.                     env.apcCore.getAzioni(asps, env.apcCore.getAccordoServizioSintetico(asps.getIdAccordo()), false, false, null)
  213.                 );
  214.             
  215.             if (!env.apsHelper.configurazioneErogazioneCheckData(
  216.                     TipoOperazione.ADD, 
  217.                     mappingInfo.getNomeNuovaConfigurazione(),                   
  218.                     body.getNome(), 
  219.                     body.getAzioni().toArray(new String[0]),
  220.                     asps, 
  221.                     azioniOccupate,
  222.                     body.getConfigurazione().getModalita().toString(),                  // modeCreazione
  223.                     null,                                           // Come da codice console,
  224.                     env.isSupportatoAutenticazioneSoggetti,
  225.                     mappingInfo
  226.                 )) {
  227.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException(StringEscapeUtils.unescapeHtml(env.pd.getMessage()));
  228.             }
  229.             
  230.             
  231.             AccordiServizioParteSpecificaUtilities.addAccordoServizioParteSpecificaPorteApplicative(
  232.                     mappingDefault,
  233.                     mappingSelezionato,
  234.                     mappingInfo.getNomeNuovaConfigurazione(),
  235.                     body.getNome(),             // nomeGruppo
  236.                     body.getAzioni().toArray(new String[0]),    // azioni
  237.                     body.getConfigurazione().getModalita().toString(),              // modeCreazione
  238.                     body.getConfigurazione().getModalita().toString(),              // modeCreazioneConnettore Forse c'è un bug nella console, qui viene passato "eredita", nella console viene trattato come una checkbox
  239.                     null,                           // endpointtype,
  240.                     null,                           // tipoconn,
  241.                     null,                           // autenticazioneHttp,  // RECHECK
  242.                     null,                           // connettoreDebug,
  243.                     null,                           // url,
  244.                     null,                           // nomeCodaJms,
  245.                     null,                           // tipoJms, 
  246.                     null,                           // initcont, 
  247.                     null,                           // urlpgk, 
  248.                     null,                           // provurl, 
  249.                     null,                           // connfact, 
  250.                     null,                           // tipoSendas, 
  251.                     null,                           // user,    RECHECK
  252.                     null,                           // password, RECHECK
  253.                     null,                           // httpsurl, 
  254.                     null,                           // httpstipologia, 
  255.                     false,                          // httpshostverify,
  256.                     ConnettoriCostanti.DEFAULT_CONNETTORE_HTTPS_TRUST_VERIFY_CERTS, // httpsTrustVerifyCert
  257.                     null,                           // httpspath, 
  258.                     null,                           // httpstipo, 
  259.                     null,                           // httpspwd,
  260.                     null,                           // httpsalgoritmo, 
  261.                     false,                          // httpsstato,
  262.                     null,                           // httpskeystore,
  263.                     null,                           // httpspwdprivatekeytrust, 
  264.                     null,                           // httpspathkey,
  265.                     null,                           // httpstipokey, 
  266.                     null,                           // httpspwdkey,
  267.                     null,                           // httpspwdprivatekey, 
  268.                     null,                           // httpsalgoritmokey,
  269.                     null,                           // httpsKeyAlias
  270.                     null,                           // httpsTrustStoreCRLs
  271.                     null,                           // httpsTrustStoreOCSPPolicy
  272.                     null,                           // httpsKeyStoreBYOKPolicy
  273.                     null,                           // proxy_enabled, 
  274.                     null,                           // proxy_hostname, 
  275.                     null,                           // proxy_port, 
  276.                     null,                           // proxy_username, 
  277.                     null,                           // proxy_password,
  278.                     null,                           // tempiRisposta_enabled, 
  279.                     null,                           // tempiRisposta_connectionTimeout,
  280.                     null,                           // tempiRisposta_readTimeout, 
  281.                     null,                           // tempiRisposta_tempoMedioRisposta,
  282.                     "no",                           // opzioniAvanzate,
  283.                     null,                           // transfer_mode, 
  284.                     null,                           // transfer_mode_chunk_size, 
  285.                     null,                           // redirect_mode, 
  286.                     null,                           // redirect_max_hop,
  287.                     null,                           // requestOutputFileName,
  288.                     null,                           // requestOutputFileName_permissions,
  289.                     null,                           // requestOutputFileNameHeaders,
  290.                     null,                           // requestOutputFileNameHeaders_permissions,
  291.                     null,                           // requestOutputParentDirCreateIfNotExists,
  292.                     null,                           // requestOutputOverwriteIfExists,
  293.                     null,                           // responseInputMode,
  294.                     null,                           // responseInputFileName,
  295.                     null,                           // responseInputFileNameHeaders, 
  296.                     null,                           // responseInputDeleteAfterRead, 
  297.                     null,                           // responseInputWaitTime,
  298.                     false,                          // autenticazioneToken,
  299.                     null,                           // tokenPolicy,
  300.                     null,                           // listExtendedConnettore
  301.                     erogazioneAutenticazione,
  302.                     erogazioneAutenticazioneOpzionale,
  303.                     erogazioneAutenticazionePrincipal,
  304.                     erogazioneAutenticazioneParametroList,
  305.                     "disabilitato",                 // erogazioneAutorizzazione
  306.                     null,                           // erogazioneAutorizzazioneAutenticati, 
  307.                     null,                           // erogazioneAutorizzazioneRuoli, 
  308.                     null,                           // erogazioneAutorizzazioneRuoliTipologia, 
  309.                     null,                           // erogazioneAutorizzazioneRuoliMatch,
  310.                     null,                           // nomeSA, 
  311.                     null,                           // erogazioneRuolo, 
  312.                     null,                           // erogazioneSoggettoAutenticato, 
  313.                     null,                           //  autorizzazioneAutenticatiToken, 
  314.                     null,                           //  autorizzazioneRuoliToken, 
  315.                     null,                           //  autorizzazioneRuoliTipologiaToken, 
  316.                     null,                           //  autorizzazioneRuoliMatchToken,
  317.                     null,                           // autorizzazione_tokenOptions,
  318.                     null,                           // autorizzazioneScope,
  319.                     null,                           // scope, 
  320.                     null,                           // autorizzazioneScopeMatch,
  321.                     null,                           // allegatoXacmlPolicy,
  322.                     "disabilitato",                 // gestioneToken
  323.                     null,                           // gestioneTokenPolicy,  
  324.                     null,                           // gestioneTokenOpzionale,  
  325.                     null,                           // gestioneTokenValidazioneInput, 
  326.                     null,                           // gestioneTokenIntrospection, 
  327.                     null,                           // gestioneTokenUserInfo, 
  328.                     null,                           // gestioneTokenTokenForward,
  329.                     null,                           // autenticazioneTokenIssuer, 
  330.                     null,                           // autenticazioneTokenClientId,
  331.                     null,                           // autenticazioneTokenSubject, 
  332.                     null,                           // autenticazioneTokenUsername, 
  333.                     null,                           // autenticazioneTokenEMail,
  334.                     asps, 
  335.                     env.tipo_protocollo, 
  336.                     env.userLogin,
  337.                     env.apsCore,
  338.                     env.apsHelper,
  339.                     null, // nomeSAServer
  340.                     null, // identificazioneAttributiStato
  341.                     null, //String [] attributeAuthoritySelezionate
  342.                     null, // attributeAuthorityAttributi
  343.                     null, // apiKeyHeader
  344.                     null, // apiKey,
  345.                     null, // appIdHeader,
  346.                     null, // appId,
  347.                     null // connettoreStatusParams
  348.                 );

  350.                 
  351.             context.getLogger().info("Invocazione completata con successo");
  352.         
  353.      
  354.             // Bug Fix: altrimenti viene generato 204
  355.             context.getServletResponse().setStatus(201);
  356.         }
  357.         catch(javax.ws.rs.WebApplicationException e) {
  358.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  359.             throw e;
  360.         }
  361.         catch(Throwable e) {
  362.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  363.             throw FaultCode.ERRORE_INTERNO.toException(e);
  364.         }
  365.     }
  366.     
  367.     /**
  368.      * Elimina il gruppo identificato dal nome
  369.      *
  370.      * Questa operazione consente di eliminare il gruppo identificato dal nome
  371.      *
  372.      */
  373.     @Override
  374.     public void deleteErogazioneGruppo(String nome, Integer versione, String nomeGruppo, ProfiloEnum profilo, String soggetto, String tipoServizio) {
  375.         IContext context = this.getContext();
  376.         try {
  377.             context.getLogger().info("Invocazione in corso ...");     

  379.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  380.             context.getLogger().debug("Autorizzazione completata con successo");
  381.             
  382.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  383.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfErogazione(tipoServizio, nome, versione, env.idSoggetto.toIDSoggetto(), env), "Erogazione");
  384.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps),asps.getId());
  385.             
  386.             final IDPortaApplicativa idPortaApplicativa = ErogazioniApiHelper.getIDGruppoPA(nomeGruppo, idAsps, env.apsCore);
  387.                 
  388.             if (env.delete_404 && idPortaApplicativa == null) 
  389.                 throw FaultCode.NOT_FOUND.toException("Gruppo con nome " + nomeGruppo + "non trovato per l'erogazione scelta");

  391.             else if ( idPortaApplicativa != null) {
  392.         
  393.                 StringBuilder inUsoMessage = new StringBuilder();
  394.                 AccordiServizioParteSpecificaUtilities.deleteAccordoServizioParteSpecificaPorteApplicative(idPortaApplicativa, idAsps, env.userLogin, env.apsCore, env.apsHelper, inUsoMessage);
  395.                 
  396.                 if (inUsoMessage.length() > 0) {
  397.                     throw FaultCode.RICHIESTA_NON_VALIDA.toException(StringEscapeUtils.unescapeHtml(inUsoMessage.toString()));
  398.                 }
  399.             }
  400.             context.getLogger().info("Invocazione completata con successo");
  401.      
  402.         }
  403.         catch(javax.ws.rs.WebApplicationException e) {
  404.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  405.             throw e;
  406.         }
  407.         catch(Throwable e) {
  408.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  409.             throw FaultCode.ERRORE_INTERNO.toException(e);
  410.         }
  411.     }
  412.     
  413.     /**
  414.      * Elimina l'azione o la risorsa dell'API associata al gruppo
  415.      *
  416.      * Questa operazione consente di eliminare l'azione o la risorsa dell'API associate al gruppo
  417.      *
  418.      */
  419.     @Override
  420.     public void deleteErogazioneGruppoAzione(String nome, Integer versione, String nomeGruppo, String nomeAzione, ProfiloEnum profilo, String soggetto, String tipoServizio) {
  421.         IContext context = this.getContext();
  422.         try {
  423.             context.getLogger().info("Invocazione in corso ...");     

  425.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  426.             context.getLogger().debug("Autorizzazione completata con successo");
  427.             
  428.             
  429.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  430.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfErogazione(tipoServizio, nome, versione, env.idSoggetto.toIDSoggetto(), env), "Erogazione");
  431.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps), asps.getId());
  432.             final IDPortaApplicativa idPa = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getIDGruppoPA(nomeGruppo, idAsps, env.apsCore), "Gruppo per l'erogazione scelta");
  433.             final PortaApplicativa pa = env.paCore.getPortaApplicativa(idPa);
  434.             
  435.             if ( BaseHelper.findFirst( pa.getAzione().getAzioneDelegataList(), a -> a.equals(nomeAzione)).isPresent() ) {
  436.                 StringBuilder inUsoMessage = new StringBuilder();
  437.                 
  438.                 PorteApplicativeUtilities.deletePortaApplicativaAzioni(pa, env.paCore, env.paHelper, inUsoMessage, "\n",
  439.                         new ArrayList<>(Arrays.asList(nomeAzione)), env.userLogin);
  440.                 
  441.                 if (inUsoMessage.length() > 0)
  442.                     throw FaultCode.RICHIESTA_NON_VALIDA.toException(StringEscapeUtils.unescapeHtml(inUsoMessage.toString()));
  443.                 
  444.             } else if ( env.delete_404 ) {
  445.                 throw FaultCode.NOT_FOUND.toException("Azione " + nomeAzione + " non presente nel gruppo " + nomeGruppo);
  446.             }
  447.                                             
  448.             context.getLogger().info("Invocazione completata con successo");
  449.         
  450.      
  451.         }
  452.         catch(javax.ws.rs.WebApplicationException e) {
  453.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  454.             throw e;
  455.         }
  456.         catch(Throwable e) {
  457.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  458.             throw FaultCode.ERRORE_INTERNO.toException(e);
  459.         }
  460.     }
  461.     
  462.     /**
  463.      * Ricerca i gruppi in cui sono stati classificate le azioni o le risorse dell'API
  464.      *
  465.      * Elenca i gruppi in cui sono stati classificate le azioni o le risorse dell'API
  466.      *
  467.      */
  468.     @Override
  469.     public ListaGruppi findAllErogazioneGruppi(String nome, Integer versione, ProfiloEnum profilo, String soggetto, String tipoServizio, Integer limit, Integer offset, String azione) {
  470.         IContext context = this.getContext();
  471.         try {
  472.             context.getLogger().info("Invocazione in corso ...");     

  474.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  475.             context.getLogger().debug("Autorizzazione completata con successo");
  476.             
  477.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  478.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfErogazione(tipoServizio, nome, versione, env.idSoggetto.toIDSoggetto(), env), "Erogazione");
  479.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps), asps.getId());
  480.             final int idLista = Liste.CONFIGURAZIONE_EROGAZIONE;
  481.             
  482.             final ConsoleSearch ricerca = Helper.setupRicercaPaginata(null, limit, offset, idLista, env.idSoggetto.toIDSoggetto(), env.tipo_protocollo);
  483.             
  484.             if (!StringUtils.isEmpty(azione))
  485.                 ricerca.addFilter(idLista, Filtri.FILTRO_AZIONE, azione);
  486.             
  487.             List<MappingErogazionePortaApplicativa> mappings = env.apsCore.mappingServiziPorteAppList(idAsps, ricerca);
  488.             
  489.             if ( env.findall_404 && mappings.isEmpty() ) {
  490.                 throw FaultCode.NOT_FOUND.toException("Nessuna porta associata al servizio: " + idAsps.toString());
  491.             }
  492.             
  493.             ListaGruppi ret = ListaUtils.costruisciListaPaginata(context.getUriInfo(), 
  494.                     ricerca.getIndexIniziale(idLista),
  495.                     ricerca.getPageSize(idLista), 
  496.                     ricerca.getNumEntries(idLista), ListaGruppi.class);
  497.             
  498.             for (MappingErogazionePortaApplicativa m : mappings) {
  499.                 final PortaApplicativa pd = env.paCore.getPortaApplicativa(m.getIdPortaApplicativa());
  500.                 
  501.                 GruppoItem g = new GruppoItem();
  502.                 g.setAzioni(pd.getAzione().getAzioneDelegataList());
  503.                 g.setNome(m.getDescrizione());
  504.                 g.setPredefinito(m.isDefault());
  505.                 
  506.                 ret.addItemsItem(g);            
  507.             }
  508.                        
  509.         
  510.             context.getLogger().info("Invocazione completata con successo");
  511.             return ret;
  512.      
  513.         }
  514.         catch(javax.ws.rs.WebApplicationException e) {
  515.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  516.             throw e;
  517.         }
  518.         catch(Throwable e) {
  519.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  520.             throw FaultCode.ERRORE_INTERNO.toException(e);
  521.         }
  522.     }
  523.     
  524.     /**
  525.      * Restituisce la descrizione del gruppo
  526.      *
  527.      * Questa operazione consente di ottenere la descrizione del gruppo
  528.      *
  529.      */
  530.     @Override
  531.     public ApiDescrizione getErogazioneDescrizioneGruppo(String nome, Integer versione, String nomeGruppo, ProfiloEnum profilo, String soggetto, String tipoServizio) {
  532.         IContext context = this.getContext();
  533.         try {
  534.             context.getLogger().info("Invocazione in corso ...");     

  536.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  537.             context.getLogger().debug("Autorizzazione completata con successo");     
  538.                         
  539.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  540.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfErogazione(tipoServizio, nome, versione, env.idSoggetto.toIDSoggetto(), env), "Erogazione");
  541.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps), asps.getId());
  542.             
  543.             final IDPortaApplicativa idPa = BaseHelper.supplyOrNotFound( 
  544.                     () -> ErogazioniApiHelper.getIDGruppoPA(nomeGruppo, idAsps, env.apsCore)
  545.                     , "Gruppo per l'erogazione scelta"
  546.                 );
  547.             
  548.             final PortaApplicativa pa = BaseHelper.supplyOrNotFound( 
  549.                     () -> env.paCore.getPortaApplicativa(idPa)
  550.                     , "Gruppo per l'erogazione scelta"
  551.                 );
  552.             
  553.             ApiDescrizione descr = new ApiDescrizione();
  554.             descr.setDescrizione(pa.getDescrizione());
  555.             
  556.             context.getLogger().info("Invocazione completata con successo");
  557.             return descr;
  558.      
  559.         }
  560.         catch(javax.ws.rs.WebApplicationException e) {
  561.             context.getLogger().error("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  562.             throw e;
  563.         }
  564.         catch(Throwable e) {
  565.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  566.             throw FaultCode.ERRORE_INTERNO.toException(e);
  567.         }
  568.     }

  570.     /**
  571.      * Restituisce azioni/risorse associate al gruppo identificato dal nome
  572.      *
  573.      * Questa operazione consente di ottenere le azioni associate al gruppo identificato dal nome
  574.      *
  575.      */
  576.     @Override
  577.     public GruppoAzioni getErogazioneGruppoAzioni(String nome, Integer versione, String nomeGruppo, ProfiloEnum profilo, String soggetto, String tipoServizio) {
  578.         IContext context = this.getContext();
  579.         try {
  580.             context.getLogger().info("Invocazione in corso ...");     

  582.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  583.             context.getLogger().debug("Autorizzazione completata con successo");
  584.             
  585.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  586.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfErogazione(tipoServizio, nome, versione, env.idSoggetto.toIDSoggetto(), env), "Erogazione");
  587.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps), asps.getId());
  588.             
  589.             final IDPortaApplicativa idPa = BaseHelper.supplyOrNotFound( 
  590.                     () -> ErogazioniApiHelper.getIDGruppoPA(nomeGruppo, idAsps, env.apsCore)
  591.                     , "Gruppo per l'erogazione scelta"
  592.                 );
  593.             
  594.             final PortaApplicativa pa = BaseHelper.supplyOrNotFound( 
  595.                     () -> env.paCore.getPortaApplicativa(idPa)
  596.                     , "Gruppo per l'erogazione scelta"
  597.                 );
  598.             
  599.             GruppoAzioni ret = new GruppoAzioni();
  600.             ret.setAzioni(pa.getAzione().getAzioneDelegataList());
  601.             context.getLogger().info("Invocazione completata con successo");
  602.             
  603.             return ret;
  604.      
  605.         }
  606.         catch(javax.ws.rs.WebApplicationException e) {
  607.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  608.             throw e;
  609.         }
  610.         catch(Throwable e) {
  611.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  612.             throw FaultCode.ERRORE_INTERNO.toException(e);
  613.         }
  614.     }

  616.     /**
  617.      * Consente di modificare la descrizione del gruppo
  618.      *
  619.      * Questa operazione consente di aggiornare la descrizione del gruppo
  620.      *
  621.      */
  622.     @Override
  623.     public void updateErogazioneDescrizioneGruppo(ApiDescrizione body, String nome, Integer versione, String nomeGruppo, ProfiloEnum profilo, String soggetto, String tipoServizio) {
  624.         IContext context = this.getContext();
  625.         try {
  626.             context.getLogger().info("Invocazione in corso ...");     

  628.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  629.             context.getLogger().debug("Autorizzazione completata con successo");     
  630.                         
  631.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  632.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfErogazione(tipoServizio, nome, versione, env.idSoggetto.toIDSoggetto(), env), "Erogazione");
  633.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps), asps.getId());
  634.             
  635.             final IDPortaApplicativa idPa = BaseHelper.supplyOrNotFound( 
  636.                     () -> ErogazioniApiHelper.getIDGruppoPA(nomeGruppo, idAsps, env.apsCore)
  637.                     , "Gruppo per l'erogazione scelta"
  638.                 );
  639.             
  640.             final PortaApplicativa pa = BaseHelper.supplyOrNotFound( 
  641.                     () -> env.paCore.getPortaApplicativa(idPa)
  642.                     , "Gruppo per l'erogazione scelta"
  643.                 );        
  644.             
  645.             pa.setDescrizione(body.getDescrizione());
  646.             
  647.             env.paCore.performUpdateOperation(env.userLogin, false, pa);
  648.             
  649.             context.getLogger().info("Invocazione completata con successo");
  650.         
  651.         }
  652.         catch(javax.ws.rs.WebApplicationException e) {
  653.             context.getLogger().error("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  654.             throw e;
  655.         }
  656.         catch(Throwable e) {
  657.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  658.             throw FaultCode.ERRORE_INTERNO.toException(e);
  659.         }
  660.     }
  661.     
  662.     /**
  663.      * Consente di modificare il nome del gruppo
  664.      *
  665.      * Questa operazione consente di aggiornare il nome di un gruppo
  666.      *
  667.      */
  668.     @Override
  669.     public void updateErogazioneGruppoNome(GruppoNome body, String nome, Integer versione, String nomeGruppo, ProfiloEnum profilo, String soggetto, String tipoServizio) {
  670.         IContext context = this.getContext();
  671.         try {
  672.             context.getLogger().info("Invocazione in corso ...");     

  674.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  675.             context.getLogger().debug("Autorizzazione completata con successo");
  676.             
  677.             BaseHelper.throwIfNull(body);
  678.                         
  679.             // PorteApplicativeConfigurazioneChange
  680.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  681.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfErogazione(tipoServizio, nome, versione, env.idSoggetto.toIDSoggetto(), env), "Erogazione");
  682.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps),asps.getId());
  683.             final List<MappingErogazionePortaApplicativa> listaMapping = env.apsCore.mappingServiziPorteAppList(idAsps,idAsps.getId(), null);
  684.             final List<String> mappingUtilizzati = ErogazioniApiHelper.getDescrizioniMappingPA(listaMapping);
  685.             
  686.             BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getIDGruppoPA(nomeGruppo, idAsps, env.apsCore), "Gruppo per l'erogazione scelta");
  687.             
  688.             if (mappingUtilizzati.stream().filter( m -> m.equalsIgnoreCase(body.getNome())).findFirst().isPresent()) {
  689.                 throw FaultCode.CONFLITTO.toException(CostantiControlStation.MESSAGGIO_ERRORE_NOME_GRUPPO_GIA_PRESENTE);
  690.             }
  691.             
  692.             if (! env.paHelper.configurazioneCambiaNomeCheck(TipoOperazione.OTHER, body.getNome(), mappingUtilizzati,false)) {
  693.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException(StringEscapeUtils.unescapeHtml(env.pd.getMessage()));
  694.             }
  695.             
  696.             final MappingErogazionePortaApplicativa mappingErogazionePortaApplicativa = AccordiServizioParteSpecificaUtilities.getMappingPAFilterByDescription(
  697.                      listaMapping, 
  698.                      nomeGruppo
  699.                     );
  700.             
  701.             mappingErogazionePortaApplicativa.setDescrizione(body.getNome());
  702.             
  703.             env.paCore.aggiornaDescrizioneMappingErogazionePortaApplicativa( mappingErogazionePortaApplicativa, env.userLogin );
  704.                                 
  705.             context.getLogger().info("Invocazione completata con successo");
  706.         
  707.      
  708.         }
  709.         catch(javax.ws.rs.WebApplicationException e) {
  710.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  711.             throw e;
  712.         }
  713.         catch(Throwable e) {
  714.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  715.             throw FaultCode.ERRORE_INTERNO.toException(e);
  716.         }
  717.     }
  718.     
  719. }
Created with JaCoCo 0.8.8.202204050719