SoggettiApiServiceImpl.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.soggetti;

  22. import java.util.List;

  24. import org.apache.commons.lang.StringEscapeUtils;
  25. import org.apache.commons.lang.StringUtils;
  26. import org.openspcoop2.core.commons.Filtri;
  27. import org.openspcoop2.core.commons.Liste;
  28. import org.openspcoop2.core.config.rs.server.api.SoggettiApi;
  29. import org.openspcoop2.core.config.rs.server.api.impl.ApiKeyInfo;
  30. import org.openspcoop2.core.config.rs.server.api.impl.Helper;
  31. import org.openspcoop2.core.config.rs.server.config.ServerProperties;
  32. import org.openspcoop2.core.config.rs.server.model.AuthenticationApiKey;
  33. import org.openspcoop2.core.config.rs.server.model.AuthenticationHttpBasic;
  34. import org.openspcoop2.core.config.rs.server.model.BaseCredenziali;
  35. import org.openspcoop2.core.config.rs.server.model.DominioEnum;
  36. import org.openspcoop2.core.config.rs.server.model.ListaSoggetti;
  37. import org.openspcoop2.core.config.rs.server.model.ModalitaAccessoEnum;
  38. import org.openspcoop2.core.config.rs.server.model.OneOfBaseCredenzialiCredenziali;
  39. import org.openspcoop2.core.config.rs.server.model.Soggetto;
  40. import org.openspcoop2.core.id.IDSoggetto;
  41. import org.openspcoop2.core.registry.CredenzialiSoggetto;
  42. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  43. import org.openspcoop2.protocol.engine.ProtocolFactoryManager;
  44. import org.openspcoop2.protocol.sdk.constants.ConsoleOperationType;
  45. import org.openspcoop2.protocol.sdk.properties.ProtocolProperties;
  46. import org.openspcoop2.protocol.sdk.properties.ProtocolPropertiesUtils;
  47. import org.openspcoop2.utils.UtilsException;
  48. import org.openspcoop2.utils.service.BaseImpl;
  49. import org.openspcoop2.utils.service.authorization.AuthorizationConfig;
  50. import org.openspcoop2.utils.service.authorization.AuthorizationManager;
  51. import org.openspcoop2.utils.service.beans.ProfiloEnum;
  52. import org.openspcoop2.utils.service.beans.utils.BaseHelper;
  53. import org.openspcoop2.utils.service.beans.utils.ListaUtils;
  54. import org.openspcoop2.utils.service.context.IContext;
  55. import org.openspcoop2.utils.service.fault.jaxrs.FaultCode;
  56. import org.openspcoop2.web.ctrlstat.core.ConsoleSearch;
  57. import org.openspcoop2.web.ctrlstat.dao.SoggettoCtrlStat;
  58. import org.openspcoop2.web.ctrlstat.servlet.soggetti.SoggettiUtilities;
  59. import org.openspcoop2.web.lib.mvc.TipoOperazione;


  62. /**
  63.  * SoggettiApiServiceImpl
  64.  * 
  65.  * @author $Author$
  66.  * @version $Rev$, $Date$
  67.  * 
  68.  */
  69. public class SoggettiApiServiceImpl extends BaseImpl implements SoggettiApi {

  71.     public SoggettiApiServiceImpl(){
  72.         super(org.slf4j.LoggerFactory.getLogger(SoggettiApiServiceImpl.class));
  73.     }

  75.     private AuthorizationConfig getAuthorizationConfig() throws UtilsException{
  76.         return new AuthorizationConfig(ServerProperties.getInstance().getProperties());
  77.     }

  79.     /**
  80.      * Creazione di un soggetto
  81.      *
  82.      * Questa operazione consente di creare un soggetto
  83.      *
  84.      */
  85.     @Override
  86.     public void createSoggetto(Soggetto body, ProfiloEnum profilo) {
  87.         IContext context = this.getContext();
  88.         try {
  89.             context.getLogger().info("Invocazione in corso ...");     

  91.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  92.             context.getLogger().debug("Autorizzazione completata con successo");

  94.             if (profilo == null)
  95.                 profilo = Helper.getProfiloDefault();
  96.             
  97.             SoggettiEnv env = new SoggettiEnv(context.getServletRequest(),  profilo, context);

  99.             /**if (profilo == null)
  100.                 profilo = Helper.getProfiloDefault();*/
  101.             
  102.             Soggetto soggetto = null;
  103.             try{
  104.                 soggetto = body;
  105.                 
  106.                 if ( soggetto.getCredenziali() != null && soggetto.getCredenziali().getModalitaAccesso() != null ) {
  107.                     soggetto.setCredenziali(Helper.translateCredenziali(soggetto.getCredenziali(), true));
  108.                 }
  109.                 
  110.             }
  111.             catch(javax.ws.rs.WebApplicationException e) {
  112.                 throw e;
  113.             }
  114.             catch(Exception e) {
  115.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException(e);
  116.             }
  117.             
  118.             String protocollo = env.protocolFactory.getProtocol();
  119.             String tipoSoggetto = ProtocolFactoryManager.getInstance().getDefaultOrganizationTypes().get(protocollo);
  120.             IDSoggetto idSoggetto = new IDSoggetto(tipoSoggetto,soggetto.getNome());
  121.         
  122.             SoggettiApiHelper.validateCredentials(soggetto.getCredenziali());
  123.             
  124.             ApiKeyInfo keyInfo = null;
  125.             if ( soggetto.getCredenziali() != null && soggetto.getCredenziali().getModalitaAccesso() != null ) {
  126.                 keyInfo = SoggettiApiHelper.createApiKey(soggetto.getCredenziali(), idSoggetto, env.soggettiCore, protocollo);
  127.                 boolean updateKey = false;
  128.                 SoggettiApiHelper.overrideAuthParams(env.soggettiHelper, soggetto, env.requestWrapper,
  129.                         keyInfo, updateKey);
  130.             }
  131.             
  132.             org.openspcoop2.core.registry.Soggetto soggettoRegistro = SoggettiApiHelper.soggettoApiToRegistro(soggetto, env, keyInfo);
  133.             
  134.             ProtocolProperties protocolProperties = null;
  135.             if(profilo != null) {
  136.                 protocolProperties = SoggettiApiHelper.getProtocolProperties(body, profilo, soggettoRegistro, env);
  137.     
  138.                 if(protocolProperties != null) {
  139.                     soggettoRegistro.setProtocolPropertyList(ProtocolPropertiesUtils.toProtocolPropertiesRegistry(protocolProperties, ConsoleOperationType.ADD, null));
  140.                 }
  141.             }
  142.             
  143.             
  144.             IDSoggetto idSogg = new IDSoggetto();
  145.             idSogg.setNome(soggettoRegistro.getNome());
  146.             idSogg.setTipo(soggettoRegistro.getTipo());
  147.             idSogg.setCodicePorta(soggettoRegistro.getIdentificativoPorta());
  148.             
  149.             if (env.soggettiCore.existsSoggetto(idSogg))
  150.                 throw FaultCode.CONFLITTO.toException("Esiste già un soggetto con il nome e il tipo scelti");
  151.             if (env.soggettiCore.existsSoggetto(soggettoRegistro.getCodiceIpa()))
  152.                 throw FaultCode.CONFLITTO.toException("Esiste già un soggetto con codice IPA " + soggettoRegistro.getCodiceIpa());
  153.             
  154.             boolean isOk = env.soggettiHelper.soggettiCheckData(
  155.                     TipoOperazione.ADD,
  156.                     null,
  157.                     env.tipo_soggetto, 
  158.                     soggettoRegistro.getNome(),
  159.                     soggettoRegistro.getCodiceIpa(),
  160.                     null,   //pd_url_prefix_rewriter,
  161.                     null,   //pa_url_prefix_rewriter,
  162.                     null, false, soggettoRegistro.getDescrizione(), soggettoRegistro.getPortaDominio());
  163.             
  164.             if (!isOk)
  165.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException(StringEscapeUtils.unescapeHtml(env.pd.getMessage()));
  166.     
  167.             // Dal debug isRouter è sempre false.
  168.             org.openspcoop2.core.config.Soggetto soggettoConfig = SoggettiApiHelper.soggettoRegistroToConfig(soggettoRegistro,new org.openspcoop2.core.config.Soggetto(),false);
  169.             SoggettoCtrlStat sog = new SoggettoCtrlStat(soggettoRegistro, soggettoConfig);
  170.             
  171.             env.soggettiCore.performCreateOperation(env.userLogin, false, sog);     
  172.         
  173.             context.getLogger().info("Invocazione completata con successo");   
  174.             
  175.             if(keyInfo!=null) {
  176.                 context.getServletResponse().setHeader(ApiKeyInfo.API_KEY, keyInfo.getApiKey());
  177.                 if(keyInfo.isMultipleApiKeys()) {
  178.                     context.getServletResponse().setHeader(ApiKeyInfo.APP_ID, keyInfo.getAppId());
  179.                 }
  180.             }
  181.             
  182.             // Bug Fix: altrimenti viene generato 204
  183.             context.getServletResponse().setStatus(201);
  184.         }
  185.         catch(javax.ws.rs.WebApplicationException e) {
  186.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  187.             throw e;
  188.         }
  189.         catch(Throwable e) {
  190.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  191.             throw FaultCode.ERRORE_INTERNO.toException(e);
  192.         }
  193.     }


  196.     
  197.     /**
  198.      * Elimina un soggetto
  199.      *
  200.      * Questa operazione consente di eliminare un soggetto identificato dal nome
  201.      *
  202.      */
  203.     @Override
  204.     public void deleteSoggetto(String nome, ProfiloEnum profilo) {
  205.         IContext context = this.getContext();
  206.         try {
  207.             context.getLogger().info("Invocazione in corso ...");     

  209.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  210.             context.getLogger().debug("Autorizzazione completata con successo");
  211.             
  212.             if (profilo == null)
  213.                 profilo = Helper.getProfiloDefault();
  214.             
  215.             SoggettiEnv env = new SoggettiEnv(context.getServletRequest(), profilo, context);
  216.             IDSoggetto idSogg = new IDSoggetto(env.tipo_soggetto, nome);
  217.             
  218.             org.openspcoop2.core.registry.Soggetto soggettoRegistro = BaseHelper.evalnull(() -> env.soggettiCore.getSoggettoRegistro(idSogg) );
  219.             org.openspcoop2.core.config.Soggetto soggettoConfig = BaseHelper.evalnull(() -> env.soggettiCore.getSoggetto(soggettoRegistro.getId() ));
  220.             
  221.             if  ( soggettoRegistro != null && soggettoConfig != null ) {

  223.                 StringBuilder inUsoMessage = new StringBuilder();
  224.                 SoggettiUtilities.deleteSoggetto(
  225.                         soggettoRegistro,
  226.                         soggettoConfig,
  227.                         env.userLogin,
  228.                         env.soggettiCore,
  229.                         env.soggettiHelper, 
  230.                         inUsoMessage,
  231.                         "\n"
  232.                     );
  233.                 if (inUsoMessage.length() > 0)
  234.                     throw FaultCode.RICHIESTA_NON_VALIDA.toException(StringEscapeUtils.escapeHtml(inUsoMessage.toString()));
  235.             }
  236.             else if (env.delete_404) {
  237.                 throw FaultCode.NOT_FOUND.toException("Nessun soggetto corrisponde al nome e il profilo indicati");
  238.             }
  239.                     
  240.             context.getLogger().info("Invocazione completata con successo");     
  241.         }
  242.         
  243.         catch(javax.ws.rs.WebApplicationException e) {
  244.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  245.             throw e;
  246.         }
  247.         catch(Throwable e) {
  248.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  249.             throw FaultCode.ERRORE_INTERNO.toException(e);
  250.         }
  251.     }
  252.     
  253.     /**
  254.      * Ricerca soggetti
  255.      *
  256.      * Elenca i soggetti registrati
  257.      *
  258.      */
  259.     @Override
  260.     public ListaSoggetti findAllSoggetti(ProfiloEnum profilo, String q, Integer limit, Integer offset, DominioEnum dominio, String ruolo, ModalitaAccessoEnum tipoCredenziali, Boolean profiloQualsiasi) {
  261.         IContext context = this.getContext();
  262.         try {
  263.             context.getLogger().info("Invocazione in corso ...");     

  265.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  266.             context.getLogger().debug("Autorizzazione completata con successo");
  267.             
  268.             if (profilo == null)
  269.                 profilo = Helper.getProfiloDefault();
  270.             
  271.             SoggettiEnv env = new SoggettiEnv(context.getServletRequest(), profilo, context);                        
  272.             int idLista = Liste.SOGGETTI;
  273.             ConsoleSearch ricerca = Helper.setupRicercaPaginata(q, limit, offset, idLista, env.idSoggetto.toIDSoggetto(), env.tipo_protocollo);
  274.             
  275.             if(profiloQualsiasi!=null && profiloQualsiasi) {
  276.                 ricerca.clearFilter(idLista, Filtri.FILTRO_PROTOCOLLO);
  277.             }
  278.             
  279.             if (dominio != null)
  280.                 ricerca.addFilter(idLista, Filtri.FILTRO_DOMINIO, dominio.toString());
  281.             if (ruolo != null && ruolo.trim().length() > 0)
  282.                 ricerca.addFilter(idLista, Filtri.FILTRO_RUOLO, ruolo.trim());
  283.             if(tipoCredenziali!=null) {
  284.                 String filtro = Helper.tipoAuthFromModalitaAccesso.get(tipoCredenziali);
  285.                 if(filtro!=null && !"".equals(filtro)) {
  286.                     ricerca.addFilter(idLista, Filtri.FILTRO_TIPO_CREDENZIALI, filtro);
  287.                 }
  288.             }
  289.             
  290.             List<org.openspcoop2.core.registry.Soggetto> soggetti = env.soggettiCore.soggettiRegistroList(null, ricerca);
  291.             
  292.             if ( soggetti.size() == 0 && env.findall_404 )
  293.                 throw FaultCode.NOT_FOUND.toException("Nessun soggetto corrisponde ai criteri di ricerca specificati");
  294.             
  295.             final ListaSoggetti ret = ListaUtils.costruisciListaPaginata(
  296.                     context.getUriInfo(),
  297.                     ricerca.getIndexIniziale(idLista),
  298.                     ricerca.getPageSize(idLista), 
  299.                     ricerca.getNumEntries(idLista), 
  300.                     ListaSoggetti.class
  301.                 ); 
  302.             
  303.             soggetti.forEach( s -> {
  304.                 ret.addItemsItem(SoggettiApiHelper.soggettoRegistroToItem(s,env.pddCore,env.soggettiCore));
  305.             });
  306.             
  307.             context.getLogger().info("Invocazione completata con successo");
  308.             return ret;
  309.      
  310.         }
  311.         catch(javax.ws.rs.WebApplicationException e) {
  312.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  313.             throw e;
  314.         }
  315.         catch(Throwable e) {
  316.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  317.             throw FaultCode.ERRORE_INTERNO.toException(e);
  318.         }
  319.     }
  320.     
  321.     /**
  322.      * Restituisce il dettaglio di un soggetto
  323.      *
  324.      * Questa operazione consente di ottenere il dettaglio di un soggetto identificato dal nome
  325.      * 
  326.      *
  327.      */
  328.     @Override
  329.     public Soggetto getSoggetto(String nome, ProfiloEnum profilo) {
  330.         IContext context = this.getContext();
  331.         try {
  332.             context.getLogger().info("Invocazione in corso ...");     

  334.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  335.             context.getLogger().debug("Autorizzazione completata con successo");     
  336.             
  337.             if (profilo == null)
  338.                 profilo = Helper.getProfiloDefault();
  339.             
  340.             SoggettiEnv env = new SoggettiEnv(context.getServletRequest(), profilo, context);           
  341.             IDSoggetto idSogg = new IDSoggetto(env.tipo_soggetto,nome);
  342.             
  343.             org.openspcoop2.core.registry.Soggetto soggettoReg = BaseHelper.supplyOrNotFound( () -> env.soggettiCore.getSoggettoRegistro(idSogg), "Soggetto " + idSogg.toString() );
  344.             
  345.             Soggetto soggettoApi = BaseHelper.supplyOrNotFound( () -> SoggettiApiHelper.soggettoRegistroToApi(soggettoReg, env.pddCore,env.soggettiCore), "Soggetto " + idSogg.toString());
  346.             
  347.             if (soggettoApi == null)
  348.                 throw FaultCode.NOT_FOUND.toException("Nessun soggetto trovato corrisponde al nome " + nome + " e profilo " + profilo.toString());
  349.                      
  350.             SoggettiApiHelper.populateProtocolInfo(soggettoReg, soggettoApi, env, profilo);
  351.         
  352.             context.getLogger().info("Invocazione completata con successo");
  353.             return soggettoApi;
  354.      
  355.         }
  356.         catch(javax.ws.rs.WebApplicationException e) {
  357.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  358.             throw e;
  359.         }
  360.         catch(Throwable e) {
  361.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  362.             throw FaultCode.ERRORE_INTERNO.toException(e);
  363.         }
  364.     }
  365.     
  366.     /**
  367.      * Modifica i dati di un soggetto
  368.      *
  369.      * Questa operazione consente di aggiornare le credenziali associate ad un soggetto identificato dal nome
  370.      *
  371.      */
  372.     @Override
  373.     public void updateCredenzialiSoggetto(BaseCredenziali body, String nome, ProfiloEnum profilo) {
  374.         IContext context = this.getContext();
  375.         try {
  376.             context.getLogger().info("Invocazione in corso ...");     

  378.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  379.             context.getLogger().debug("Autorizzazione completata con successo");
  380.             
  381.             if (profilo == null)
  382.                 profilo = Helper.getProfiloDefault();
  383.             
  384.             SoggettiApiHelper.validateCredentials(body.getCredenziali());
  385.             
  386.             OneOfBaseCredenzialiCredenziali credenziali = null;
  387.             try{
  388.                 credenziali = Helper.translateCredenziali(body.getCredenziali(), true); // metto true, come se fosse create per obbligare la password basic
  389.             }
  390.             catch(javax.ws.rs.WebApplicationException e) {
  391.                 throw e;
  392.             }
  393.             catch(Throwable e) {
  394.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException(e);
  395.             }

  397.             final SoggettiEnv env = new SoggettiEnv(context.getServletRequest(), profilo, context);
  398.             
  399.             final IDSoggetto idSogg = new IDSoggetto(env.tipo_soggetto,nome);           
  400.             org.openspcoop2.core.registry.Soggetto oldSoggetto = null; 
  401.             try {
  402.                 oldSoggetto = env.soggettiCore.getSoggettoRegistro(idSogg);
  403.             } catch (Exception e) {         
  404.             }
  405.             if (oldSoggetto == null)
  406.                 throw FaultCode.NOT_FOUND.toException("Nessun soggetto trovato corrisponde al nome " + nome + " e profilo " + profilo.toString());
  407.             
  408.             ApiKeyInfo keyInfo = SoggettiApiHelper.createApiKey(credenziali, idSogg, env.soggettiCore, env.protocolFactory.getProtocol());
  409.             boolean updateKey = true;
  410.             
  411.             SoggettiApiHelper.overrideAuthParams(env.soggettiHelper, credenziali, env.requestWrapper,
  412.                     keyInfo, updateKey);
  413.                         
  414.             final org.openspcoop2.core.registry.Soggetto newSoggetto = env.soggettiCore.getSoggettoRegistro(idSogg);
  415.             
  416.             try {
  417.                 List<CredenzialiSoggetto> newCredenziali = Helper.apiCredenzialiToGovwayCred(
  418.                             body.getCredenziali(),
  419.                             body.getCredenziali().getModalitaAccesso(),
  420.                             CredenzialiSoggetto.class,
  421.                             org.openspcoop2.core.registry.constants.CredenzialeTipo.class,
  422.                             keyInfo
  423.                 );      
  424.                 newSoggetto.getCredenzialiList().clear();
  425.                 newSoggetto.getCredenzialiList().addAll(newCredenziali);
  426.             }catch(Exception e) {
  427.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  428.             }
  429.                         
  430.             boolean isOk = env.soggettiHelper.soggettiCheckData(
  431.                     TipoOperazione.CHANGE,
  432.                     oldSoggetto.getId().toString(),
  433.                     env.tipo_soggetto, 
  434.                     newSoggetto.getNome(), 
  435.                     newSoggetto.getCodiceIpa(),
  436.                     null,  // this.pd_url_prefix_rewriter, 
  437.                     null, // this.pa_url_prefix_rewriter,
  438.                     oldSoggetto,
  439.                     false,  //IsSupportatoAutenticazione
  440.                     newSoggetto.getDescrizione(),
  441.                     newSoggetto.getPortaDominio()
  442.                 );
  443.             
  444.             if (!isOk)
  445.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException(StringEscapeUtils.unescapeHtml(env.pd.getMessage()));
  446.             
  447.             newSoggetto.setOldIDSoggettoForUpdate(new IDSoggetto(oldSoggetto.getTipo(), oldSoggetto.getNome()));
  448.             env.soggettiCore.performUpdateOperation(env.userLogin, false, newSoggetto);

  450.             if(keyInfo!=null) {
  451.                 context.getServletResponse().setHeader(ApiKeyInfo.API_KEY, keyInfo.getApiKey());
  452.                 if(keyInfo.isMultipleApiKeys()) {
  453.                     context.getServletResponse().setHeader(ApiKeyInfo.APP_ID, keyInfo.getAppId());
  454.                 }
  455.             }
  456.             
  457.             context.getLogger().info("Invocazione completata con successo");
  458.              
  459.         }
  460.         catch(javax.ws.rs.WebApplicationException e) {
  461.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  462.             throw e;
  463.         }
  464.         catch(Throwable e) {
  465.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  466.             throw FaultCode.ERRORE_INTERNO.toException(e);
  467.         }
  468.     }
  469.     
  470.     @Override
  471.     public void updateSoggetto(Soggetto body, String nome, ProfiloEnum profilo) {
  472.         IContext context = this.getContext();
  473.         try {
  474.             context.getLogger().info("Invocazione in corso ...");     

  476.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  477.             context.getLogger().debug("Autorizzazione completata con successo");
  478.             
  479.             if (profilo == null)
  480.                 profilo = Helper.getProfiloDefault();
  481.             
  482.             SoggettiApiHelper.validateCredentials(body.getCredenziali());
  483.             
  484.             Soggetto soggetto = null;
  485.             try{
  486.                 soggetto = (Soggetto) body;
  487.                 soggetto.setCredenziali(Helper.translateCredenziali(soggetto.getCredenziali(), false));
  488.             }
  489.             catch(javax.ws.rs.WebApplicationException e) {
  490.                 throw e;
  491.             }
  492.             catch(Throwable e) {
  493.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException(e);
  494.             }

  496.             final SoggettiEnv env = new SoggettiEnv(context.getServletRequest(), profilo, context);
  497.             
  498.             final IDSoggetto idSogg = new IDSoggetto(env.tipo_soggetto,nome);
  499.             org.openspcoop2.core.registry.Soggetto oldSoggetto = null; 
  500.             try {
  501.                 oldSoggetto = env.soggettiCore.getSoggettoRegistro(idSogg);
  502.             } catch (Exception e) {         
  503.             }
  504.             if (oldSoggetto == null)
  505.                 throw FaultCode.NOT_FOUND.toException("Nessun soggetto trovato corrisponde al nome " + nome + " e profilo " + profilo.toString());
  506.             
  507.             ApiKeyInfo keyInfo = SoggettiApiHelper.getApiKey(oldSoggetto, false);
  508.             boolean updateKey = false;
  509.             
  510.             SoggettiApiHelper.overrideAuthParams(env.soggettiHelper, soggetto, env.requestWrapper,
  511.                     keyInfo, updateKey);
  512.                         
  513.             SoggettoCtrlStat oldSoggettoCtrlStat = env.soggettiCore.getSoggettoCtrlStat(oldSoggetto.getId());
  514.             
  515.             final org.openspcoop2.core.registry.Soggetto newSoggetto = env.soggettiCore.getSoggettoRegistro(idSogg);
  516.             
  517.             SoggettiApiHelper.convert(body, newSoggetto, env, keyInfo);
  518.             
  519.             if(body.getCredenziali()!=null && body.getCredenziali().getModalitaAccesso()!=null) {
  520.                 if(ModalitaAccessoEnum.HTTP_BASIC.equals(body.getCredenziali().getModalitaAccesso())) {
  521.                     AuthenticationHttpBasic httpBasic = (AuthenticationHttpBasic) body.getCredenziali();
  522.                     if(httpBasic.getPassword()==null || StringUtils.isEmpty(httpBasic.getPassword())) {
  523.                         // password in update non è obbligatoria
  524.                         boolean set = false;
  525.                         if(oldSoggetto.sizeCredenzialiList()>0) {
  526.                             CredenzialiSoggetto cImageDB = oldSoggetto.getCredenziali(0);
  527.                             CredenzialiSoggetto cTmp = newSoggetto.getCredenziali(0);
  528.                             if(cImageDB!=null && cTmp!=null) {
  529.                                 cTmp.setPassword(cImageDB.getPassword());
  530.                                 cTmp.setCertificateStrictVerification(cImageDB.isCertificateStrictVerification());
  531.                                 set = true;
  532.                             }
  533.                         }
  534.                         if(!set) {
  535.                             throw FaultCode.RICHIESTA_NON_VALIDA.toException("Tipo di autenticazione '"+body.getCredenziali().getModalitaAccesso()+"'; indicare la password");
  536.                         }
  537.                     }
  538.                 }
  539.                 else if(ModalitaAccessoEnum.API_KEY.equals(body.getCredenziali().getModalitaAccesso())) {
  540.                     AuthenticationApiKey apiKeyCred = (AuthenticationApiKey) body.getCredenziali();
  541.                     boolean appId = Helper.isAppId(apiKeyCred.isAppId());
  542.                     if(appId != keyInfo.isMultipleApiKeys()) {
  543.                         throw FaultCode.RICHIESTA_NON_VALIDA.toException("Tipo di autenticazione '"+body.getCredenziali().getModalitaAccesso()+"'; modifica del tipo (appId) non consentita");
  544.                     }
  545.                 }
  546.             }
  547.             
  548.             ProtocolProperties protocolProperties = null;
  549.             if(profilo != null) {
  550.                 protocolProperties = SoggettiApiHelper.getProtocolProperties(body, profilo, newSoggetto, env);
  551.     
  552.                 if(protocolProperties != null) {
  553.                     newSoggetto.setProtocolPropertyList(ProtocolPropertiesUtils.toProtocolPropertiesRegistry(protocolProperties, ConsoleOperationType.ADD, null));
  554.                 }
  555.             }
  556.             
  557.             boolean isOk = env.soggettiHelper.soggettiCheckData(
  558.                     TipoOperazione.CHANGE,
  559.                     oldSoggetto.getId().toString(),
  560.                     env.tipo_soggetto, 
  561.                     newSoggetto.getNome(), 
  562.                     newSoggetto.getCodiceIpa(),
  563.                     null,  // this.pd_url_prefix_rewriter, 
  564.                     null, // this.pa_url_prefix_rewriter,
  565.                     oldSoggetto,
  566.                     false,  //IsSupportatoAutenticazione
  567.                     newSoggetto.getDescrizione(),
  568.                     newSoggetto.getPortaDominio()
  569.                 );
  570.             
  571.             if (!isOk)
  572.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException(StringEscapeUtils.unescapeHtml(env.pd.getMessage()));
  573.             
  574.             org.openspcoop2.core.config.Soggetto soggettoConfig = SoggettiApiHelper.soggettoRegistroToConfig(newSoggetto,oldSoggettoCtrlStat.getSoggettoConf(),false);
  575.             newSoggetto.setOldIDSoggettoForUpdate(new IDSoggetto(oldSoggetto.getTipo(), oldSoggetto.getNome()));
  576.             soggettoConfig.setOldIDSoggettoForUpdate(new IDSoggetto(oldSoggetto.getTipo(), oldSoggetto.getNome()));

  578.             SoggettoCtrlStat sog = new SoggettoCtrlStat(newSoggetto, soggettoConfig);
  579.             
  580.             sog.setOldNomeForUpdate(oldSoggetto.getNome());
  581.             sog.setOldTipoForUpdate(oldSoggetto.getTipo());

  583.             // eseguo l'aggiornamento
  584.             List<Object> listOggettiDaAggiornare = SoggettiUtilities.getOggettiDaAggiornare(
  585.                     env.soggettiCore, 
  586.                     oldSoggetto.getNome(),
  587.                     newSoggetto.getNome(),
  588.                     oldSoggetto.getTipo(),
  589.                     newSoggetto.getTipo(),
  590.                     sog)
  591.                 ;
  592.             env.soggettiCore.performUpdateOperation(env.userLogin, false, listOggettiDaAggiornare.toArray());

  594.             context.getLogger().info("Invocazione completata con successo");
  595.              
  596.         }
  597.         catch(javax.ws.rs.WebApplicationException e) {
  598.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  599.             throw e;
  600.         }
  601.         catch(Throwable e) {
  602.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  603.             throw FaultCode.ERRORE_INTERNO.toException(e);
  604.         }
  605.     }
  606.     
  607. }
Created with JaCoCo 0.8.8.202204050719