FruizioniGruppiApiServiceImpl.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.fruizioni.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.PortaDelegata;
  31. import org.openspcoop2.core.config.constants.TipoAutenticazionePrincipal;
  32. import org.openspcoop2.core.config.rs.server.api.FruizioniGruppiApi;
  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.IDPortaDelegata;
  49. import org.openspcoop2.core.id.IDSoggetto;
  50. import org.openspcoop2.core.mapping.MappingFruizionePortaDelegata;
  51. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  52. import org.openspcoop2.utils.BooleanNullable;
  53. import org.openspcoop2.utils.service.BaseImpl;
  54. import org.openspcoop2.utils.service.authorization.AuthorizationConfig;
  55. import org.openspcoop2.utils.service.authorization.AuthorizationManager;
  56. import org.openspcoop2.utils.service.beans.ProfiloEnum;
  57. import org.openspcoop2.utils.service.beans.utils.BaseHelper;
  58. import org.openspcoop2.utils.service.beans.utils.ListaUtils;
  59. import org.openspcoop2.utils.service.context.IContext;
  60. import org.openspcoop2.utils.service.fault.jaxrs.FaultCode;
  61. import org.openspcoop2.web.ctrlstat.core.ConsoleSearch;
  62. import org.openspcoop2.web.ctrlstat.costanti.CostantiControlStation;
  63. import org.openspcoop2.web.ctrlstat.servlet.aps.AccordiServizioParteSpecificaFruitoriPorteDelegateMappingInfo;
  64. import org.openspcoop2.web.ctrlstat.servlet.aps.AccordiServizioParteSpecificaUtilities;
  65. import org.openspcoop2.web.ctrlstat.servlet.connettori.ConnettoriCostanti;
  66. import org.openspcoop2.web.ctrlstat.servlet.pd.PorteDelegateUtilities;
  67. import org.openspcoop2.web.lib.mvc.ServletUtils;
  68. import org.openspcoop2.web.lib.mvc.TipoOperazione;

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

  79.     public FruizioniGruppiApiServiceImpl(){
  80.         super(org.slf4j.LoggerFactory.getLogger(FruizioniGruppiApiServiceImpl.class));
  81.     }

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

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

  100.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  101.             context.getLogger().debug("Autorizzazione completata con successo");
  102.             
  103.             BaseHelper.throwIfNull(body);
  104.             
  105.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);

  107.             final IDSoggetto idErogatore = new IDSoggetto(env.tipo_soggetto, erogatore);
  108.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfFruizione(tipoServizio, nome, versione, idErogatore, env.idSoggetto.toIDSoggetto(), env), "Fruizione");
  109.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps), asps.getId());

  111.             final IDPortaDelegata idPd = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getIDGruppoPD(nomeGruppo, env.idSoggetto.toIDSoggetto(), idAsps, env.apsCore), "Gruppo per la fruizione scelta");
  112.             final PortaDelegata pd = env.pdCore.getPortaDelegata(idPd);
  113.                         
  114.             List<String> azioniOccupate = ErogazioniApiHelper.getAzioniOccupateFruizione(idAsps, env.idSoggetto.toIDSoggetto(), env.apsCore, env.pdCore);
  115.             
  116.             ErogazioniApiHelper.checkAzioniAdd( 
  117.                     body.getAzioni(),
  118.                     azioniOccupate,
  119.                     env.apcCore.getAzioni(asps, env.apcCore.getAccordoServizioSintetico(asps.getIdAccordo()), false, false, null)
  120.                 );
  121.             
  122.             
  123.             env.requestWrapper.overrideParameterValues(CostantiControlStation.PARAMETRO_AZIONI, body.getAzioni().toArray(new String[0]));
  124.         
  125.             long idFruizione = env.apsCore.getIdFruizioneAccordoServizioParteSpecifica(env.idSoggetto.toIDSoggetto(), idAsps);
  126.             List<MappingFruizionePortaDelegata> listaMappingFruizione = env.apsCore.serviziFruitoriMappingList(idFruizione, env.idSoggetto.toIDSoggetto(), idAsps, null);
  127.             if (!env.paHelper.porteDelAzioneCheckData(TipoOperazione.ADD,azioniOccupate,listaMappingFruizione)) {
  128.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException(StringEscapeUtils.unescapeHtml(env.pd.getMessage()));
  129.             }
  130.             
  131.             // aggiungo azione nel db
  132.             for(String azione: body.getAzioni()) {
  133.                 pd.getAzione().addAzioneDelegata(azione);
  134.             }

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

  166.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  167.             context.getLogger().debug("Autorizzazione completata con successo");
  168.             
  169.             ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  170.             
  171.             final IDSoggetto idErogatore = new IDSoggetto(env.tipo_soggetto, erogatore);
  172.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfFruizione(tipoServizio, nome, versione, idErogatore, env.idSoggetto.toIDSoggetto(),  env), "Fruizione");
  173.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps), asps.getId());

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


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

  380.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  381.             context.getLogger().debug("Autorizzazione completata con successo");     
  382.                         
  383.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  384.             final IDSoggetto idErogatore = new IDSoggetto(env.tipo_soggetto, erogatore);
  385.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfFruizione(tipoServizio, nome, versione, idErogatore, env.idSoggetto.toIDSoggetto(), env), "Fruizione");
  386.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps),asps.getId());
  387.             
  388.             // ricevo come parametro l'id della pa associata al mapping da cancellare
  389.             final IDPortaDelegata idPortaDelegata = ErogazioniApiHelper.getIDGruppoPD(nomeGruppo, env.idSoggetto.toIDSoggetto(), idAsps, env.apsCore);
  390.             
  391.             if ( idPortaDelegata != null ) {
  392.             
  393.                 StringBuilder inUsoMessage = new StringBuilder();
  394.                 AccordiServizioParteSpecificaUtilities.deleteAccordoServizioParteSpecificaFruitoriPorteDelegate(
  395.                         new ArrayList<IDPortaDelegata>(Arrays.asList(idPortaDelegata)), 
  396.                         asps, env.idSoggetto.toIDSoggetto(), 
  397.                         env.userLogin, 
  398.                         env.apsCore, 
  399.                         env.apsHelper, 
  400.                         inUsoMessage
  401.                     );
  402.                 
  403.                 if (inUsoMessage.length() > 0)
  404.                     throw FaultCode.RICHIESTA_NON_VALIDA.toException(StringEscapeUtils.unescapeHtml(inUsoMessage.toString()));
  405.             } else if ( env.delete_404 ) {
  406.                 throw FaultCode.NOT_FOUND.toException("Gruppo " + nomeGruppo + " non associato alla fruizione");
  407.             }
  408.             context.getLogger().info("Invocazione completata con successo");
  409.         
  410.      
  411.         }
  412.         catch(javax.ws.rs.WebApplicationException e) {
  413.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  414.             throw e;
  415.         }
  416.         catch(Throwable e) {
  417.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  418.             throw FaultCode.ERRORE_INTERNO.toException(e);
  419.         }
  420.     }
  421.     
  422.     /**
  423.      * Elimina l'azione o la risorsa dell'API associatia al gruppo
  424.      *
  425.      * Questa operazione consente di eliminare l'azione o la risorsa dell'API associata al gruppo
  426.      *
  427.      */
  428.     @Override
  429.     public void deleteFruizioneGruppoAzione(String erogatore, String nome, Integer versione, String nomeGruppo, String nomeAzione, ProfiloEnum profilo, String soggetto, String tipoServizio) {
  430.         IContext context = this.getContext();
  431.         try {
  432.             context.getLogger().info("Invocazione in corso ...");     

  434.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  435.             context.getLogger().debug("Autorizzazione completata con successo");
  436.             
  437.             
  438.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  439.             final IDSoggetto idErogatore = new IDSoggetto(env.tipo_soggetto, erogatore);
  440.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfFruizione(tipoServizio, nome, versione, idErogatore, env.idSoggetto.toIDSoggetto(), env), "Fruizione");
  441.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps),asps.getId());
  442.             final IDPortaDelegata idPd = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getIDGruppoPD(nomeGruppo, env.idSoggetto.toIDSoggetto(), idAsps, env.apsCore), "Gruppo per la fruizione scelta");
  443.             final PortaDelegata pd = env.pdCore.getPortaDelegata(idPd);
  444.             
  445.             if ( BaseHelper.findFirst( pd.getAzione().getAzioneDelegataList(), a -> a.equals(nomeAzione)).isPresent() ) {
  446.                         
  447.                 StringBuilder inUsoMessage = new StringBuilder();
  448.                 
  449.                 PorteDelegateUtilities.deletePortaDelegataAzioni(pd, asps, env.pdCore, env.pdHelper, inUsoMessage, new ArrayList<>(Arrays.asList(nomeAzione)), env.userLogin);
  450.                 
  451.                 if (inUsoMessage.length() > 0)
  452.                     throw FaultCode.RICHIESTA_NON_VALIDA.toException(StringEscapeUtils.unescapeHtml(inUsoMessage.toString()));
  453.             } else if ( env.delete_404 ) {
  454.                 throw FaultCode.NOT_FOUND.toException("Azione " + nomeAzione + " non associata al gruppo " + nomeGruppo );
  455.             }
  456.             
  457.             context.getLogger().info("Invocazione completata con successo");
  458.         
  459.      
  460.         }
  461.         catch(javax.ws.rs.WebApplicationException e) {
  462.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  463.             throw e;
  464.         }
  465.         catch(Throwable e) {
  466.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  467.             throw FaultCode.ERRORE_INTERNO.toException(e);
  468.         }
  469.     }
  470.     
  471.     /**
  472.      * Ricerca i gruppi in cui sono stati classificate le azioni o le risorse dell'API
  473.      *
  474.      * Elenca i gruppi in cui sono stati classificate le azioni o le risorse dell'API
  475.      *
  476.      */
  477.     @Override
  478.     public ListaGruppi findAllFruizioneGruppi(String erogatore, String nome, Integer versione, ProfiloEnum profilo, String soggetto, String tipoServizio, Integer limit, Integer offset, String azione) {
  479.         IContext context = this.getContext();
  480.         try {
  481.             context.getLogger().info("Invocazione in corso ...");     

  483.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  484.             context.getLogger().debug("Autorizzazione completata con successo");
  485.             
  486.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  487.             final IDSoggetto idErogatore = new IDSoggetto(env.tipo_soggetto, erogatore);
  488.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfFruizione(tipoServizio, nome, versione, idErogatore, env.idSoggetto.toIDSoggetto(), env), "Fruizione");
  489.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps),asps.getId());
  490.             
  491.             final int idLista = Liste.CONFIGURAZIONE_FRUIZIONE;
  492.             final ConsoleSearch ricerca = Helper.setupRicercaPaginata(null, limit, offset, idLista, env.idSoggetto.toIDSoggetto(), env.tipo_protocollo);
  493.             
  494.             if (!StringUtils.isEmpty(azione))
  495.                 ricerca.addFilter(idLista, Filtri.FILTRO_AZIONE, azione);
  496.             
  497.             List<MappingFruizionePortaDelegata> mappings = env.apsCore.serviziFruitoriMappingList(env.idSoggetto.toIDSoggetto(), idAsps, ricerca);
  498.             
  499.             if ( env.findall_404 && mappings.isEmpty() ) {
  500.                 throw FaultCode.NOT_FOUND.toException("Nessun gruppo associato alla fruizione");
  501.             }
  502.             
  503.             ListaGruppi ret = ListaUtils.costruisciListaPaginata(context.getUriInfo(), 
  504.                     ricerca.getIndexIniziale(idLista),
  505.                     ricerca.getPageSize(idLista), 
  506.                     ricerca.getNumEntries(idLista), ListaGruppi.class);
  507.             
  508.             for (MappingFruizionePortaDelegata m : mappings) {
  509.                 final PortaDelegata pd = env.pdCore.getPortaDelegata(m.getIdPortaDelegata());
  510.                 
  511.                 GruppoItem g = new GruppoItem();
  512.                 g.setAzioni(pd.getAzione().getAzioneDelegataList());
  513.                 g.setNome(m.getDescrizione());
  514.                 g.setPredefinito(m.isDefault());
  515.                 
  516.                 ret.addItemsItem(g);            
  517.             }
  518.             
  519.             context.getLogger().info("Invocazione completata con successo");
  520.             return ret;
  521.      
  522.         }
  523.         catch(javax.ws.rs.WebApplicationException e) {
  524.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  525.             throw e;
  526.         }
  527.         catch(Throwable e) {
  528.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  529.             throw FaultCode.ERRORE_INTERNO.toException(e);
  530.         }
  531.     }

  533.     /**
  534.      * Restituisce la descrizione del gruppo
  535.      *
  536.      * Questa operazione consente di ottenere la descrizione del gruppo
  537.      *
  538.      */
  539.     @Override
  540.     public ApiDescrizione getFruizioneDescrizioneGruppo(String erogatore, String nome, Integer versione, String nomeGruppo, ProfiloEnum profilo, String soggetto, String tipoServizio) {
  541.         IContext context = this.getContext();
  542.         try {
  543.             context.getLogger().info("Invocazione in corso ...");     

  545.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  546.             context.getLogger().debug("Autorizzazione completata con successo");     
  547.                         
  548.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  549.             final IDSoggetto idErogatore = new IDSoggetto(env.tipo_soggetto, erogatore);
  550.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfFruizione(tipoServizio, nome, versione, idErogatore, env.idSoggetto.toIDSoggetto(), env), "Fruizione");
  551.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps),asps.getId());
  552.             
  553.             // ricevo come parametro l'id della pa associata al mapping da cancellare
  554.             final IDPortaDelegata idPortaDelegata = BaseHelper.supplyOrNotFound( 
  555.                     () -> ErogazioniApiHelper.getIDGruppoPD(nomeGruppo, env.idSoggetto.toIDSoggetto(), idAsps, env.apsCore)
  556.                     , "Gruppo per la fruizione scelta"
  557.                 );
  558.             final PortaDelegata pd = BaseHelper.supplyOrNotFound(
  559.                     () -> env.pdCore.getPortaDelegata(idPortaDelegata)
  560.                     , "Gruppo per la fruizione scelta"
  561.                 );  
  562.             
  563.             ApiDescrizione descr = new ApiDescrizione();
  564.             descr.setDescrizione(pd.getDescrizione());
  565.             
  566.             context.getLogger().info("Invocazione completata con successo");
  567.             return descr;
  568.      
  569.         }
  570.         catch(javax.ws.rs.WebApplicationException e) {
  571.             context.getLogger().error("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  572.             throw e;
  573.         }
  574.         catch(Throwable e) {
  575.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  576.             throw FaultCode.ERRORE_INTERNO.toException(e);
  577.         }
  578.     }
  579.     
  580.     /**
  581.      * Restituisce azioni/risorse associate al gruppo identificato dal nome
  582.      *
  583.      * Questa operazione consente di ottenere le azioni associate al gruppo identificato dal nome
  584.      *
  585.      */
  586.     @Override
  587.     public GruppoAzioni getFruizioneGruppoAzioni(String erogatore, String nome, Integer versione, String nomeGruppo, ProfiloEnum profilo, String soggetto, String tipoServizio) {
  588.         IContext context = this.getContext();
  589.         try {
  590.             context.getLogger().info("Invocazione in corso ...");     

  592.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  593.             context.getLogger().debug("Autorizzazione completata con successo");
  594.             
  595.             
  596.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  597.             final IDSoggetto idErogatore = new IDSoggetto(env.tipo_soggetto, erogatore);
  598.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfFruizione(tipoServizio, nome, versione, idErogatore, env.idSoggetto.toIDSoggetto(), env), "Fruizione");
  599.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps),asps.getId());
  600.             
  601.             // ricevo come parametro l'id della pa associata al mapping da cancellare
  602.             final IDPortaDelegata idPortaDelegata = BaseHelper.supplyOrNotFound( 
  603.                     () -> ErogazioniApiHelper.getIDGruppoPD(nomeGruppo, env.idSoggetto.toIDSoggetto(), idAsps, env.apsCore)
  604.                     , "Gruppo per la fruizione scelta"
  605.                 );
  606.             final PortaDelegata pd = BaseHelper.supplyOrNotFound(
  607.                     () -> env.pdCore.getPortaDelegata(idPortaDelegata)
  608.                     , "Gruppo per la fruizione scelta"
  609.                 );
  610.             
  611.             
  612.             GruppoAzioni ret = new GruppoAzioni();
  613.             ret.setAzioni(pd.getAzione().getAzioneDelegataList());
  614.             context.getLogger().info("Invocazione completata con successo");
  615.             
  616.             return ret;
  617.      
  618.         }
  619.         catch(javax.ws.rs.WebApplicationException e) {
  620.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  621.             throw e;
  622.         }
  623.         catch(Throwable e) {
  624.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  625.             throw FaultCode.ERRORE_INTERNO.toException(e);
  626.         }
  627.     }

  629.     /**
  630.      * Consente di modificare la descrizione del gruppo
  631.      *
  632.      * Questa operazione consente di aggiornare la descrizione del gruppo
  633.      *
  634.      */
  635.     @Override
  636.     public void updateFruizioneDescrizioneGruppo(ApiDescrizione body, String erogatore, String nome, Integer versione, String nomeGruppo, ProfiloEnum profilo, String soggetto, String tipoServizio) {
  637.         IContext context = this.getContext();
  638.         try {
  639.             context.getLogger().info("Invocazione in corso ...");     

  641.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  642.             context.getLogger().debug("Autorizzazione completata con successo");     
  643.                         
  644.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  645.             final IDSoggetto idErogatore = new IDSoggetto(env.tipo_soggetto, erogatore);
  646.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfFruizione(tipoServizio, nome, versione, idErogatore, env.idSoggetto.toIDSoggetto(), env), "Fruizione");
  647.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps),asps.getId());
  648.             
  649.             // ricevo come parametro l'id della pa associata al mapping da cancellare
  650.             final IDPortaDelegata idPortaDelegata = BaseHelper.supplyOrNotFound( 
  651.                     () -> ErogazioniApiHelper.getIDGruppoPD(nomeGruppo, env.idSoggetto.toIDSoggetto(), idAsps, env.apsCore)
  652.                     , "Gruppo per la fruizione scelta"
  653.                 );
  654.             final PortaDelegata pd = BaseHelper.supplyOrNotFound(
  655.                     () -> env.pdCore.getPortaDelegata(idPortaDelegata)
  656.                     , "Gruppo per la fruizione scelta"
  657.                 );  
  658.         
  659.             pd.setDescrizione(body.getDescrizione());

  661.             env.pdCore.performUpdateOperation(env.userLogin, false, pd);
  662.             
  663.             context.getLogger().info("Invocazione completata con successo");
  664.         
  665.         }
  666.         catch(javax.ws.rs.WebApplicationException e) {
  667.             context.getLogger().error("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  668.             throw e;
  669.         }
  670.         catch(Throwable e) {
  671.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  672.             throw FaultCode.ERRORE_INTERNO.toException(e);
  673.         }
  674.     }
  675.     
  676.     /**
  677.      * Consente di modificare il nome del gruppo
  678.      *
  679.      * Questa operazione consente di aggiornare il nome di un gruppo
  680.      *
  681.      */
  682.     @Override
  683.     public void updateFruizioneGruppoNome(GruppoNome body, String erogatore, String nome, Integer versione, String nomeGruppo, ProfiloEnum profilo, String soggetto, String tipoServizio) {
  684.         IContext context = this.getContext();
  685.         try {
  686.             context.getLogger().info("Invocazione in corso ...");     

  688.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  689.             context.getLogger().debug("Autorizzazione completata con successo");
  690.             
  691.               
  692.             final ErogazioniEnv env = new ErogazioniEnv(context.getServletRequest(), profilo, soggetto, context);
  693.             final IDSoggetto idErogatore = new IDSoggetto(env.tipo_soggetto, erogatore);
  694.             final AccordoServizioParteSpecifica asps = BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getServizioIfFruizione(tipoServizio, nome, versione, idErogatore, env.idSoggetto.toIDSoggetto(), env), "Fruizione");
  695.             final IdServizio idAsps = new IdServizio(env.idServizioFactory.getIDServizioFromAccordo(asps),asps.getId());
  696.             final List<MappingFruizionePortaDelegata> listaMapping = env.apsCore.serviziFruitoriMappingList(env.idSoggetto.toIDSoggetto(), idAsps, null);

  698.             final List<String> mappingUtilizzati = ErogazioniApiHelper.getDescrizioniMappingPD(listaMapping);
  699.             
  700.             BaseHelper.supplyOrNotFound( () -> ErogazioniApiHelper.getIDGruppoPD(nomeGruppo, env.idSoggetto.toIDSoggetto(),  idAsps, env.apsCore), "Gruppo per la fruizione scelta");
  701.             
  702.             if (mappingUtilizzati.stream().filter( m -> m.equalsIgnoreCase(body.getNome())).findFirst().isPresent()) {
  703.                 throw FaultCode.CONFLITTO.toException(CostantiControlStation.MESSAGGIO_ERRORE_NOME_GRUPPO_GIA_PRESENTE);
  704.             }
  705.             
  706.             if (! env.paHelper.configurazioneCambiaNomeCheck(TipoOperazione.OTHER, body.getNome(), mappingUtilizzati,true)) {
  707.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException(StringEscapeUtils.unescapeHtml(env.pd.getMessage()));
  708.             }
  709.             
  710.             final MappingFruizionePortaDelegata mapping= AccordiServizioParteSpecificaUtilities.getMappingPDFilterByDescription(
  711.                      listaMapping, 
  712.                      nomeGruppo
  713.                     );
  714.             
  715.             mapping.setDescrizione(body.getNome());
  716.             
  717.             env.pdCore.aggiornaDescrizioneMappingFruizionePortaDelegata( mapping, env.userLogin );
  718.                                     
  719.         
  720.             context.getLogger().info("Invocazione completata con successo");
  721.         
  722.      
  723.         }
  724.         catch(javax.ws.rs.WebApplicationException e) {
  725.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  726.             throw e;
  727.         }
  728.         catch(Throwable e) {
  729.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  730.             throw FaultCode.ERRORE_INTERNO.toException(e);
  731.         }
  732.     }
  733.     
  734. }
Created with JaCoCo 0.8.8.202204050719