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



  23. package org.openspcoop2.pdd.core.autorizzazione;

  25. import java.io.File;
  26. import java.io.Serializable;
  27. import java.net.URL;
  28. import java.util.ArrayList;
  29. import java.util.Collections;
  30. import java.util.Iterator;
  31. import java.util.List;
  32. import java.util.Map;

  34. import javax.servlet.http.HttpServletRequest;

  36. import org.openspcoop2.core.config.ServizioApplicativo;
  37. import org.openspcoop2.core.config.constants.TipoAutenticazione;
  38. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  39. import org.openspcoop2.core.id.IDRuolo;
  40. import org.openspcoop2.core.id.IDServizio;
  41. import org.openspcoop2.core.id.IDServizioApplicativo;
  42. import org.openspcoop2.core.id.IDSoggetto;
  43. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  44. import org.openspcoop2.core.registry.Documento;
  45. import org.openspcoop2.core.registry.Ruolo;
  46. import org.openspcoop2.core.registry.constants.RuoloContesto;
  47. import org.openspcoop2.core.registry.constants.RuoloTipologia;
  48. import org.openspcoop2.core.registry.constants.TipiDocumentoSicurezza;
  49. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  50. import org.openspcoop2.core.registry.driver.FiltroRicercaRuoli;
  51. import org.openspcoop2.pdd.config.ConfigurazionePdDManager;
  52. import org.openspcoop2.pdd.core.PdDContext;
  53. import org.openspcoop2.pdd.core.autorizzazione.container.AutorizzazioneHttpServletRequest;
  54. import org.openspcoop2.pdd.core.autorizzazione.pa.DatiInvocazionePortaApplicativa;
  55. import org.openspcoop2.pdd.core.autorizzazione.pd.DatiInvocazionePortaDelegata;
  56. import org.openspcoop2.pdd.core.token.EsitoGestioneToken;
  57. import org.openspcoop2.pdd.core.token.InformazioniToken;
  58. import org.openspcoop2.pdd.core.token.InformazioniTokenUserInfo;
  59. import org.openspcoop2.pdd.core.token.TokenUtilities;
  60. import org.openspcoop2.pdd.core.token.attribute_authority.InformazioniAttributi;
  61. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  62. import org.openspcoop2.protocol.registry.RegistroServiziManager;
  63. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  64. import org.openspcoop2.protocol.sdk.state.URLProtocolContext;
  65. import org.openspcoop2.utils.MapKey;
  66. import org.openspcoop2.utils.json.JSONUtils;
  67. import org.openspcoop2.utils.resources.FileSystemUtilities;
  68. import org.openspcoop2.utils.transport.http.HttpUtilities;
  69. import org.openspcoop2.utils.xacml.CachedMapBasedSimplePolicyRepository;
  70. import org.openspcoop2.utils.xacml.MarshallUtilities;
  71. import org.openspcoop2.utils.xacml.PolicyDecisionPoint;
  72. import org.openspcoop2.utils.xacml.PolicyException;
  73. import org.openspcoop2.utils.xacml.XacmlRequest;
  74. import org.slf4j.Logger;


  77. /**
  78.  * XACMLPolicyUtilities
  79.  *
  80.  * @author Andrea Poli (apoli@link.it)
  81.  * @author $Author$
  82.  * @version $Rev$, $Date$
  83.  */
  84. public class XACMLPolicyUtilities {

  86.     private static PolicyDecisionPoint pdp;
  87.     private static synchronized void initPdD(Logger log) throws PolicyException{
  88.         if(XACMLPolicyUtilities.pdp == null) {
  89.             XACMLPolicyUtilities.pdp = new PolicyDecisionPoint(log);
  90.         }
  91.     }   
  92.     public static PolicyDecisionPoint getPolicyDecisionPoint(Logger log) throws PolicyException{
  93.         if(XACMLPolicyUtilities.pdp == null) {
  94.             XACMLPolicyUtilities.initPdD(log);
  95.         }
  96.         return XACMLPolicyUtilities.pdp;
  97.     }

  99.     // Workaround: Serve nel caso di Porta Delegata per poter utilizzare una policy differente da quella utilizzata nell'erogazione
  100.     private static final String  NOME_POLICY_FRUIZIONE = "fruizioneXacmlPolicy.xml";

  102.     public static void loadPolicy(String xacmlPolicyPorta, IDServizio idServizio, String key, 
  103.             boolean portaDelegata,IDSoggetto fruitore, // fruitore is null se non e' portaDelegata
  104.             Logger log) throws PolicyException{
  105.         byte[] policy = null; 
  106.         if(xacmlPolicyPorta!=null) {
  107.             policy = xacmlPolicyPorta.getBytes();
  108.         }
  109.         else {
  110.             @SuppressWarnings("unused")
  111.             String nomePolicy = null;
  112.             int numeroPolicy = 0;
  113.             @SuppressWarnings("unused")
  114.             boolean numeroPolicyFruizione = false;
  115.             try{
  116.                 AccordoServizioParteSpecifica asps = RegistroServiziManager.getInstance().getAccordoServizioParteSpecifica(idServizio, null, true, null); // requestInfo non serve poichè devono essere caricati gli allegati
  117.                 for (int i = 0; i < asps.sizeSpecificaSicurezzaList(); i++) {
  118.                     Documento d = asps.getSpecificaSicurezza(i);
  119.                     if(TipiDocumentoSicurezza.XACML_POLICY.getNome().equals(d.getTipo())){
  120.     
  121.                         if(policy == null || (portaDelegata && (fruitore.getNome()+"_"+NOME_POLICY_FRUIZIONE).equals(d.getFile()))){
  122.                             if(NOME_POLICY_FRUIZIONE.equals(d.getFile())){
  123.                                 numeroPolicyFruizione = true;
  124.                             }
  125.                             else{
  126.                                 numeroPolicy++;
  127.                             }
  128.                             if(d.getByteContenuto()!=null){
  129.                                 policy = d.getByteContenuto();
  130.                                 nomePolicy = d.getFile();
  131.                             }
  132.                             else if(d.getFile()!=null){
  133.                                 if(d.getFile().startsWith("http://") || d.getFile().startsWith("file://")){
  134.                                     URL url = new URL(d.getFile());
  135.                                     policy = HttpUtilities.requestHTTPFile(url.toString());
  136.                                 }
  137.                                 else{
  138.                                     File f = new File(d.getFile());
  139.                                     policy = FileSystemUtilities.readBytesFromFile(f);
  140.                                 }
  141.                             }
  142.                         }
  143.                     }
  144.                 }
  145.                 if(numeroPolicy>1){
  146.                     throw new PolicyException("Piu di una xacml policy trovata per il servizio "+idServizio.toString());
  147.                 }
  148.             }catch(Exception e){
  149.                 throw new PolicyException("Errore durante la ricerca delle policies xacml per il servizio "+idServizio.toString()+": "+e.getMessage(),e);
  150.             }
  151.             if(policy== null){
  152.                 throw new PolicyException("Nessuna xacml policy trovata trovata per il servizio "+idServizio.toString());
  153.             }
  154.         }

  156.         try{
  157.             // Caricamento in PdP vedendo che la policy non sia gia stata caricata ....
  158.             XACMLPolicyUtilities.getPolicyDecisionPoint(log).addPolicy(MarshallUtilities.unmarshallPolicy(policy), key);
  159.         }catch(Exception e){
  160.             throw new PolicyException("Errore durante il caricamento della xacml policy sul PdD (servizio "+idServizio.toString()+"): "+e.getMessage(),e);
  161.         }
  162.     }

  164.     public static XacmlRequest newXacmlRequest(IProtocolFactory<?> protocolFactory, AbstractDatiInvocazione datiInvocazione, 
  165.             boolean checkRuoloRegistro, boolean checkRuoloEsterno,
  166.             String policyKey) throws AutorizzazioneException{

  168.         XacmlRequest xacmlRequest = new XacmlRequest();
  169.         URLProtocolContext urlProtocolContext = null;
  170.         if(datiInvocazione.getInfoConnettoreIngresso()==null ||
  171.                 datiInvocazione.getInfoConnettoreIngresso().getUrlProtocolContext()==null){
  172.             throw new AutorizzazioneException("UrlProtocolContext non disponibile; risorsa richiesta dall'autorizzazione");
  173.         }
  174.         urlProtocolContext = datiInvocazione.getInfoConnettoreIngresso().getUrlProtocolContext();

  176.         if(datiInvocazione.getIdServizio()==null || 
  177.                 datiInvocazione.getIdServizio().getSoggettoErogatore()==null ||
  178.                 datiInvocazione.getIdServizio().getSoggettoErogatore().getTipo()==null ||
  179.                 datiInvocazione.getIdServizio().getSoggettoErogatore().getNome()==null ||
  180.                 datiInvocazione.getIdServizio().getTipo()==null ||
  181.                 datiInvocazione.getIdServizio().getNome() == null){
  182.             throw new AutorizzazioneException("DatiServizio non disponibile; risorsa richiesta dall'autorizzazione");
  183.         }
  184.         String tipoSoggettoErogatore = datiInvocazione.getIdServizio().getSoggettoErogatore().getTipo();
  185.         String nomeSoggettoErogatore = datiInvocazione.getIdServizio().getSoggettoErogatore().getNome();
  186.         String tipoServizio = datiInvocazione.getIdServizio().getTipo();
  187.         String nomeServizio = datiInvocazione.getIdServizio().getNome();
  188.         String azione = datiInvocazione.getIdServizio().getAzione() != null ? datiInvocazione.getIdServizio().getAzione() : "";

  190.         DatiInvocazionePortaDelegata datiPD = null;
  191.         if(datiInvocazione instanceof DatiInvocazionePortaDelegata){
  192.             datiPD = (DatiInvocazionePortaDelegata) datiInvocazione;
  193.         }

  195.         DatiInvocazionePortaApplicativa datiPA = null;
  196.         if(datiInvocazione instanceof DatiInvocazionePortaApplicativa){
  197.             datiPA = (DatiInvocazionePortaApplicativa) datiInvocazione;
  198.         }
  199.     
  200.         PdDContext pddContext = datiInvocazione.getPddContext();
  201.         
  202.         InformazioniToken informazioniTokenNormalizzate = null;
  203.         InformazioniTokenUserInfo informazioniTokenUserInfoNormalizzate = null;
  204.         Map<String, Serializable> jwtClaims = null;
  205.         Map<String, Serializable> introspectionClaims = null;
  206.         Map<String, Serializable> userInfoClaims = null;
  207.         Object oInformazioniTokenNormalizzate = pddContext.getObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_INFORMAZIONI_NORMALIZZATE);
  208.         if(oInformazioniTokenNormalizzate!=null) {
  209.             informazioniTokenNormalizzate = (InformazioniToken) oInformazioniTokenNormalizzate;
  210.             informazioniTokenUserInfoNormalizzate = informazioniTokenNormalizzate.getUserInfo();
  211.         }
  212.         Object oTmp = pddContext.getObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_ESITO_VALIDAZIONE);
  213.         if(oTmp!=null) {
  214.             EsitoGestioneToken esito = (EsitoGestioneToken) oTmp;
  215.             if(esito.getInformazioniToken()!=null &&
  216.                     esito.getInformazioniToken().getClaims()!=null &&
  217.                     esito.getInformazioniToken().getClaims().size()>0) {
  218.                 jwtClaims = esito.getInformazioniToken().getClaims();
  219.             }
  220.         }
  221.         oTmp = pddContext.getObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_ESITO_INTROSPECTION);
  222.         if(oTmp!=null) {
  223.             EsitoGestioneToken esito = (EsitoGestioneToken) oTmp;
  224.             if(esito.getInformazioniToken()!=null &&
  225.                     esito.getInformazioniToken().getClaims()!=null &&
  226.                     esito.getInformazioniToken().getClaims().size()>0) {
  227.                 introspectionClaims = esito.getInformazioniToken().getClaims();
  228.             }
  229.         }
  230.         oTmp = pddContext.getObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_ESITO_USER_INFO);
  231.         if(oTmp!=null) {
  232.             EsitoGestioneToken esito = (EsitoGestioneToken) oTmp;
  233.             if(esito.getInformazioniToken()!=null &&
  234.                     esito.getInformazioniToken().getClaims()!=null &&
  235.                     esito.getInformazioniToken().getClaims().size()>0) {
  236.                 userInfoClaims = esito.getInformazioniToken().getClaims();
  237.             }
  238.         }
  239.         List<String> tokenRoles = null;
  240.         if(informazioniTokenNormalizzate!=null) {
  241.             tokenRoles = informazioniTokenNormalizzate.getRoles();
  242.         }
  243.         
  244.         List<String> attributeNames = null;
  245.         Map<String, Serializable> attributes = null;
  246.         boolean multipleAA = false;
  247.         InformazioniAttributi informazioniAttributiNormalizzati = null;
  248.         Object oInformazioniAttributiNormalizzati = pddContext.getObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_ATTRIBUTI_INFORMAZIONI_NORMALIZZATE);
  249.         if(oInformazioniAttributiNormalizzati!=null) {
  250.             informazioniAttributiNormalizzati = (InformazioniAttributi) oInformazioniAttributiNormalizzati;
  251.         }
  252.         if(informazioniAttributiNormalizzati!=null) {
  253.             attributeNames = informazioniAttributiNormalizzati.getAttributesNames();
  254.             attributes = informazioniAttributiNormalizzati.getAttributes();
  255.             multipleAA = informazioniAttributiNormalizzati.isMultipleAttributeAuthorities()!=null && 
  256.                     informazioniAttributiNormalizzati.isMultipleAttributeAuthorities().getValue()!=null && 
  257.                     informazioniAttributiNormalizzati.isMultipleAttributeAuthorities().getValue();
  258.         }

  260.         Map<String, String> apiImplConfig = readConfig(pddContext, org.openspcoop2.core.constants.Costanti.PROPRIETA_CONFIGURAZIONE);
  261.         Map<String, String> applicativoConfig = readConfig(pddContext, org.openspcoop2.core.constants.Costanti.PROPRIETA_APPLICATIVO);
  262.         Map<String, String> soggettoFruitoreConfig = readConfig(pddContext, org.openspcoop2.core.constants.Costanti.PROPRIETA_SOGGETTO_FRUITORE);
  263.         Map<String, String> soggettoErogatoreConfig = readConfig(pddContext, org.openspcoop2.core.constants.Costanti.PROPRIETA_SOGGETTO_EROGATORE);
  264.                         
  265.         HttpServletRequest httpServletRequest = null;
  266.         if(checkRuoloEsterno){
  267.             if(datiInvocazione.getInfoConnettoreIngresso().getUrlProtocolContext().getHttpServletRequest()==null){
  268.                 if(tokenRoles==null) {
  269.                     throw new AutorizzazioneException("HttpServletRequest non disponibile; risorsa richiesta dall'autorizzazione");
  270.                 }
  271.             }
  272.             httpServletRequest = datiInvocazione.getInfoConnettoreIngresso().getUrlProtocolContext().getHttpServletRequest();
  273.         }

  275.         


  278.         // Action

  280.         String azioneId = urlProtocolContext.getRequestURI();
  281.         xacmlRequest.addAction(azioneId); // namespace standard xacml

  283.         xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_PROVIDER_ATTRIBUTE_ID, tipoSoggettoErogatore+"/"+nomeSoggettoErogatore); 
  284.         if(soggettoErogatoreConfig!=null && !soggettoErogatoreConfig.isEmpty()) {
  285.             Iterator<String> keys = soggettoErogatoreConfig.keySet().iterator();
  286.             while (keys.hasNext()) {
  287.                 String key = (String) keys.next();
  288.                 String value = soggettoErogatoreConfig.get(key);
  289.                 xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_PROVIDER_CONFIG_ATTRIBUTE_PREFIX+key, value);
  290.             }
  291.         }

  293.         xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_SERVICE_ATTRIBUTE_ID, tipoServizio+"/"+nomeServizio);  
  294.         if(apiImplConfig!=null && !apiImplConfig.isEmpty()) {
  295.             Iterator<String> keys = apiImplConfig.keySet().iterator();
  296.             while (keys.hasNext()) {
  297.                 String key = (String) keys.next();
  298.                 String value = apiImplConfig.get(key);
  299.                 xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_SERVICE_CONFIG_ATTRIBUTE_PREFIX+key, value);
  300.             }
  301.         }

  303.         if(azione!=null){
  304.             xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_ACTION_ATTRIBUTE_ID, azione);
  305.         }

  307.         xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_URL_ATTRIBUTE_ID, urlProtocolContext.getRequestURI());       

  309.         if(urlProtocolContext.getParameters()!=null && urlProtocolContext.getParameters().size()>0){
  310.             Iterator<String> keys = urlProtocolContext.getParameters().keySet().iterator();
  311.             while (keys.hasNext()) {
  312.                 String key = (String) keys.next();
  313.                 List<String> values = urlProtocolContext.getParameterValues(key);
  314.                 if(key!=null && !key.contains(" ") && values!=null && !values.isEmpty()){
  315.                     if(values.size()==1) {
  316.                         xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_URL_PARAMETER_ATTRIBUTE_ID+key, values.get(0));
  317.                     }
  318.                     else {
  319.                         xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_URL_PARAMETER_ATTRIBUTE_ID+key, values);
  320.                     }
  321.                 }
  322.             }
  323.         }

  325.         if(urlProtocolContext.getHeaders()!=null && urlProtocolContext.getHeaders().size()>0){
  326.             Iterator<String> keys = urlProtocolContext.getHeaders().keySet().iterator();
  327.             while (keys.hasNext()) {
  328.                 String key = (String) keys.next();
  329.                 List<String> values = urlProtocolContext.getHeaderValues(key);
  330.                 if(key!=null && !key.contains(" ") && values!=null && !values.isEmpty()){
  331.                     if(values.size()==1) {
  332.                         xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_TRANSPORT_HEADER_ATTRIBUTE_ID+key, values.get(0));
  333.                     }
  334.                     else {
  335.                         xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_TRANSPORT_HEADER_ATTRIBUTE_ID+key, values);
  336.                     }
  337.                 }
  338.             }
  339.         }

  341.         if(urlProtocolContext.getFunction()!=null){
  342.             xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_PDD_SERVICE_ATTRIBUTE_ID, urlProtocolContext.getFunction());     
  343.         }

  345.         if(datiInvocazione.getInfoConnettoreIngresso().getSoapAction()!=null){
  346.             xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_SOAP_ACTION_ATTRIBUTE_ID, datiInvocazione.getInfoConnettoreIngresso().getSoapAction());      
  347.         }

  349.         if(protocolFactory!=null){
  350.             xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_PROTOCOL_ATTRIBUTE_ID, protocolFactory.getProtocol());       
  351.         }
  352.         
  353.         if(informazioniTokenNormalizzate!=null) {
  354.             if(informazioniTokenNormalizzate.getAud()!=null) {
  355.                 xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_TOKEN_AUDIENCE_ATTRIBUTE_ID, informazioniTokenNormalizzate.getAud());
  356.             }
  357.             if(informazioniTokenNormalizzate.getScopes()!=null && informazioniTokenNormalizzate.getScopes().size()>0) {
  358.                 xacmlRequest.addActionAttribute(XACMLCostanti.XACML_REQUEST_ACTION_TOKEN_SCOPE_ATTRIBUTE_ID, informazioniTokenNormalizzate.getScopes());
  359.             }
  360.         }
  361.         
  362.         if(jwtClaims!=null && jwtClaims.size()>0) {
  363.             Iterator<?> it = jwtClaims.keySet().iterator();
  364.             while (it.hasNext()) {
  365.                 String key = (String) it.next();
  366.                 Object value = jwtClaims.get(key);
  367.                 key = normalizeKeyClaim(key);
  368.                 setActionAttribute(xacmlRequest, value, 
  369.                         XACMLCostanti.XACML_REQUEST_ACTION_TOKEN_JWT_CLAIMS_PREFIX+key);
  370.             }
  371.         }
  372.         
  373.         if(introspectionClaims!=null && introspectionClaims.size()>0) {
  374.             Iterator<?> it = introspectionClaims.keySet().iterator();
  375.             while (it.hasNext()) {
  376.                 String key = (String) it.next();
  377.                 Object value = introspectionClaims.get(key);
  378.                 key = normalizeKeyClaim(key);
  379.                 setActionAttribute(xacmlRequest, value, 
  380.                         XACMLCostanti.XACML_REQUEST_ACTION_TOKEN_INTROSPECTION_CLAIMS_PREFIX+key);
  381.             }
  382.         }

  384.         

  386.         // Subject

  388.         String nomeServizioApplicativo = null;
  389.         IDSoggetto soggettoFruitore = null;
  390.         if(datiPD!=null){
  391.             if(datiPD.getIdServizioApplicativo()!=null){
  392.                 nomeServizioApplicativo = datiPD.getIdServizioApplicativo().getNome();
  393.                 soggettoFruitore = datiPD.getIdServizioApplicativo().getIdSoggettoProprietario();
  394.             }
  395.             else if(datiPD.getIdPD()!=null && datiPD.getIdPD().getIdentificativiFruizione()!=null &&
  396.                     datiPD.getIdPD().getIdentificativiFruizione().getSoggettoFruitore()!=null){
  397.                 soggettoFruitore = datiPD.getIdPD().getIdentificativiFruizione().getSoggettoFruitore();
  398.             }
  399.         }
  400.         else if(datiPA!=null){
  401.             if(datiPA.getIdSoggettoFruitore()!=null){
  402.                 soggettoFruitore = datiPA.getIdSoggettoFruitore();
  403.             }
  404.             if(datiPA.getIdentitaServizioApplicativoFruitore()!=null){
  405.                 nomeServizioApplicativo = datiPA.getIdentitaServizioApplicativoFruitore().getNome();
  406.                 if(soggettoFruitore==null){
  407.                     soggettoFruitore = datiPA.getIdentitaServizioApplicativoFruitore().getIdSoggettoProprietario();
  408.                 }
  409.             }
  410.         }
  411.         
  412.         String credential = null;
  413.         TipoAutenticazione autenticazione = null;
  414.         if(datiPD!=null){
  415.             if(datiPD.getPd()!=null){
  416.                 autenticazione = TipoAutenticazione.toEnumConstant(datiPD.getPd().getAutenticazione());
  417.             }
  418.         }
  419.         else if(datiPA!=null){
  420.             if(datiPA.getPa()!=null){
  421.                 autenticazione = TipoAutenticazione.toEnumConstant(datiPA.getPa().getAutenticazione());
  422.             }
  423.         }
  424.         if(datiInvocazione.getInfoConnettoreIngresso().getCredenziali()!=null){
  425.             
  426.             if(autenticazione!=null){
  427.                 if(TipoAutenticazione.BASIC.equals(autenticazione)){
  428.                     if(datiInvocazione.getInfoConnettoreIngresso().getCredenziali().getUsername()!=null){
  429.                         credential = datiInvocazione.getInfoConnettoreIngresso().getCredenziali().getUsername();
  430.                     }
  431.                 }
  432.                 else if(TipoAutenticazione.SSL.equals(autenticazione)){
  433.                     if(datiInvocazione.getInfoConnettoreIngresso().getCredenziali().getSubject()!=null){
  434.                         credential = datiInvocazione.getInfoConnettoreIngresso().getCredenziali().getSubject();
  435.                     }
  436.                 }
  437.                 else if(TipoAutenticazione.PRINCIPAL.equals(autenticazione)){
  438.                     if(datiInvocazione.getInfoConnettoreIngresso().getCredenziali().getPrincipal()!=null){
  439.                         credential = datiInvocazione.getInfoConnettoreIngresso().getCredenziali().getPrincipal();
  440.                     }
  441.                 }
  442.             }
  443.                         
  444.             if(credential == null){
  445.                 if(datiInvocazione.getInfoConnettoreIngresso().getCredenziali().getPrincipal()!=null){
  446.                     credential = datiInvocazione.getInfoConnettoreIngresso().getCredenziali().getPrincipal();
  447.                 }
  448.                 else if(datiInvocazione.getInfoConnettoreIngresso().getCredenziali().getSubject()!=null){
  449.                     credential = datiInvocazione.getInfoConnettoreIngresso().getCredenziali().getSubject();
  450.                 }
  451.                 else if(datiInvocazione.getInfoConnettoreIngresso().getCredenziali().getUsername()!=null){
  452.                     credential = datiInvocazione.getInfoConnettoreIngresso().getCredenziali().getUsername();
  453.                 }
  454.             }
  455.         }
  456.         
  457.         List<String> roles = new ArrayList<>();
  458.         if(checkRuoloRegistro){
  459.             if(datiPD!=null){
  460.                 if(datiPD.getServizioApplicativo()==null && !checkRuoloEsterno &&
  461.                         informazioniTokenNormalizzate==null){
  462.                     throw new AutorizzazioneException("Identità servizio applicativo non disponibile; tale informazione è richiesta dall'autorizzazione");
  463.                 }
  464.                 if(datiPD.getServizioApplicativo()!=null) {
  465.                     if(datiPD.getServizioApplicativo().getInvocazionePorta()!=null && 
  466.                             datiPD.getServizioApplicativo().getInvocazionePorta().getRuoli()!=null &&
  467.                             datiPD.getServizioApplicativo().getInvocazionePorta().getRuoli().sizeRuoloList()>0){
  468.                         for (int i = 0; i < datiPD.getServizioApplicativo().getInvocazionePorta().getRuoli().sizeRuoloList(); i++) {
  469.                             roles.add(datiPD.getServizioApplicativo().getInvocazionePorta().getRuoli().getRuolo(i).getNome());
  470.                         }
  471.                     }
  472.                 }
  473.             }
  474.             else if(datiPA!=null){
  475.                 if(datiPA.getSoggettoFruitore()==null && !checkRuoloEsterno &&
  476.                         informazioniTokenNormalizzate==null){
  477.                     throw new AutorizzazioneException("Identità soggetto fruitore non disponibile; tale informazione è richiesta dall'autorizzazione");
  478.                 }
  479.                 if(datiPA.getSoggettoFruitore()!=null) {
  480.                     if(datiPA.getSoggettoFruitore().getRuoli()!=null &&
  481.                             datiPA.getSoggettoFruitore().getRuoli().sizeRuoloList()>0){
  482.                         for (int i = 0; i < datiPA.getSoggettoFruitore().getRuoli().sizeRuoloList(); i++) {
  483.                             roles.add(datiPA.getSoggettoFruitore().getRuoli().getRuolo(i).getNome());
  484.                         }
  485.                     }
  486.                 }
  487.             }
  488.         }
  489.         if(checkRuoloEsterno){
  490.             try{
  491.                 FiltroRicercaRuoli filtroRicerca = new FiltroRicercaRuoli();
  492.                 if(datiPD!=null){
  493.                     filtroRicerca.setContesto(RuoloContesto.PORTA_DELEGATA);
  494.                 }
  495.                 else if(datiPA!=null){
  496.                     filtroRicerca.setContesto(RuoloContesto.PORTA_APPLICATIVA);
  497.                 }
  498.                 filtroRicerca.setTipologia(RuoloTipologia.ESTERNO);
  499.                 RegistroServiziManager registroServiziManager = RegistroServiziManager.getInstance(datiInvocazione.getState());
  500.                 List<IDRuolo> list = registroServiziManager.getAllIdRuoli(filtroRicerca, null);
  501.                 if(list==null || list.size()<=0){
  502.                     throw new DriverRegistroServiziNotFound();
  503.                 }
  504.                 for (IDRuolo idRuolo : list) {
  505.                     String nomeRuoloDaVerificare = idRuolo.getNome();
  506.                     try {
  507.                         Ruolo ruoloRegistro = registroServiziManager.getRuolo(idRuolo.getNome(), null, datiInvocazione.getRequestInfo());
  508.                         if(ruoloRegistro.getNomeEsterno()!=null && !"".equals(ruoloRegistro.getNomeEsterno())) {
  509.                             nomeRuoloDaVerificare = ruoloRegistro.getNomeEsterno();
  510.                         }
  511.                     }catch(Exception e) {
  512.                         throw new Exception("Recupero del ruolo '"+idRuolo.getNome()+"' fallito: "+e.getMessage(),e);
  513.                     }
  514.                     if(httpServletRequest.isUserInRole(nomeRuoloDaVerificare)){
  515.                         roles.add(idRuolo.getNome()); // nella xacml policy comunque inserisco l'identificativo del ruolo nel registro della PdD
  516.                     }
  517.                 }
  518.                 if(tokenRoles!=null && tokenRoles.size()>0) {
  519.                     roles.addAll(tokenRoles);
  520.                 }
  521.             }
  522.             catch(DriverRegistroServiziNotFound notFound){
  523.                 if(!checkRuoloRegistro) {
  524.                     throw new AutorizzazioneException("Non sono stati registrati ruoli utilizzabili con un'autorizzazione esterna");
  525.                 }
  526.             }
  527.             catch(Exception e){
  528.                 throw new AutorizzazioneException("E' avvenuto un errore durante la ricerca dei ruoli: "+e.getMessage(),e);
  529.             }
  530.         }
  531.         
  532.         oTmp = pddContext.getObject(org.openspcoop2.core.constants.Costanti.ID_APPLICATIVO_TOKEN);
  533.         IDServizioApplicativo idApplicativoToken = null;
  534.         Map<String, String> applicativoTokenConfig = null;
  535.         Map<String, String> soggettoProprietarioApplicativoTokenConfig = null;
  536.         List<String> applicativoTokenRoles = new ArrayList<>();
  537.         if(oTmp!=null && oTmp instanceof IDServizioApplicativo) {
  538.             idApplicativoToken = (IDServizioApplicativo) oTmp;
  539.             applicativoTokenConfig = readConfig(pddContext, org.openspcoop2.core.constants.Costanti.PROPRIETA_APPLICATIVO_TOKEN);
  540.             soggettoProprietarioApplicativoTokenConfig = readConfig(pddContext, org.openspcoop2.core.constants.Costanti.PROPRIETA_SOGGETTO_PROPRIETARIO_APPLICATIVO_TOKEN);
  541.             
  542.             ServizioApplicativo saToken = null;
  543.             if(checkRuoloRegistro || checkRuoloEsterno) {
  544.                 try {
  545.                     saToken = ConfigurazionePdDManager.getInstance().getServizioApplicativo(idApplicativoToken, datiInvocazione.getRequestInfo());
  546.                 }catch(DriverConfigurazioneNotFound notFound) {}
  547.                 catch(Exception e){
  548.                     throw new AutorizzazioneException("E' avvenuto un errore durante la ricerca dell'applicativo token '"+idApplicativoToken+"': "+e.getMessage(),e);
  549.                 }
  550.             }
  551.             if(checkRuoloRegistro){
  552.                 if(saToken!=null) {
  553.                     if(saToken.getInvocazionePorta()!=null && 
  554.                             saToken.getInvocazionePorta().getRuoli()!=null &&
  555.                                     saToken.getInvocazionePorta().getRuoli().sizeRuoloList()>0){
  556.                         for (int i = 0; i < saToken.getInvocazionePorta().getRuoli().sizeRuoloList(); i++) {
  557.                             applicativoTokenRoles.add(saToken.getInvocazionePorta().getRuoli().getRuolo(i).getNome());
  558.                         }
  559.                     }
  560.                 }
  561.             }
  562.         }
  563.         if(checkRuoloEsterno && informazioniTokenNormalizzate!=null && tokenRoles!=null &&
  564.                 !tokenRoles.isEmpty()){
  565.             try{
  566.                 FiltroRicercaRuoli filtroRicerca = new FiltroRicercaRuoli();
  567.                 if(datiPD!=null){
  568.                     filtroRicerca.setContesto(RuoloContesto.PORTA_DELEGATA);
  569.                 }
  570.                 else if(datiPA!=null){
  571.                     filtroRicerca.setContesto(RuoloContesto.PORTA_APPLICATIVA);
  572.                 }
  573.                 filtroRicerca.setTipologia(RuoloTipologia.ESTERNO);
  574.                 RegistroServiziManager registroServiziManager = RegistroServiziManager.getInstance(datiInvocazione.getState());
  575.                 List<IDRuolo> list = registroServiziManager.getAllIdRuoli(filtroRicerca, null);
  576.                 if(list==null || list.size()<=0){
  577.                     throw new DriverRegistroServiziNotFound();
  578.                 }
  579.                 for (IDRuolo idRuolo : list) {
  580.                     String nomeRuoloDaVerificare = idRuolo.getNome();
  581.                     try {
  582.                         Ruolo ruoloRegistro = registroServiziManager.getRuolo(idRuolo.getNome(), null, datiInvocazione.getRequestInfo());
  583.                         if(ruoloRegistro.getNomeEsterno()!=null && !"".equals(ruoloRegistro.getNomeEsterno())) {
  584.                             nomeRuoloDaVerificare = ruoloRegistro.getNomeEsterno();
  585.                         }
  586.                     }catch(Exception e) {
  587.                         throw new Exception("Recupero del ruolo '"+idRuolo.getNome()+"' fallito: "+e.getMessage(),e);
  588.                     }
  589.                     if(informazioniTokenNormalizzate.getRoles().contains(nomeRuoloDaVerificare)) {
  590.                         applicativoTokenRoles.add(idRuolo.getNome()); // nella xacml policy comunque inserisco l'identificativo del ruolo nel registro della PdD
  591.                     }
  592.                 }
  593.                 for (String role : tokenRoles) {
  594.                     if(!applicativoTokenRoles.contains(role)) {
  595.                         applicativoTokenRoles.addAll(tokenRoles); // inserisco anche i nomi originali
  596.                     }
  597.                 }
  598.             }
  599.             catch(DriverRegistroServiziNotFound notFound){
  600.                 if(!checkRuoloRegistro) {
  601.                     throw new AutorizzazioneException("Non sono stati registrati ruoli utilizzabili con un'autorizzazione esterna");
  602.                 }
  603.             }
  604.             catch(Exception e){
  605.                 throw new AutorizzazioneException("E' avvenuto un errore durante la ricerca dei ruoli: "+e.getMessage(),e);
  606.             }
  607.         }

  609.         if(soggettoFruitore!=null){
  610.             String subjectId = soggettoFruitore.toString();
  611.             if(nomeServizioApplicativo!=null){
  612.                 subjectId = nomeServizioApplicativo + "." +subjectId;
  613.             }
  614.             xacmlRequest.addSubject(subjectId); // namespace standard xacml
  615.         }
  616.         else if(credential!=null){
  617.             String subjectId = credential;
  618.             xacmlRequest.addSubject(subjectId); // namespace standard xacml
  619.         }

  621.         if(soggettoFruitore!=null){
  622.             xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_ORGANIZATION_ATTRIBUTE_ID, soggettoFruitore.toString());
  623.         }
  624.         if(soggettoFruitoreConfig!=null && !soggettoFruitoreConfig.isEmpty()) {
  625.             Iterator<String> keys = soggettoFruitoreConfig.keySet().iterator();
  626.             while (keys.hasNext()) {
  627.                 String key = (String) keys.next();
  628.                 String value = soggettoFruitoreConfig.get(key);
  629.                 xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_ORGANIZATION_CONFIG_ATTRIBUTE_PREFIX+key, value);
  630.             }
  631.         }
  632.         
  633.         if(nomeServizioApplicativo!=null){
  634.             xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_CLIENT_ATTRIBUTE_ID, nomeServizioApplicativo);
  635.         }
  636.         if(applicativoConfig!=null && !applicativoConfig.isEmpty()) {
  637.             Iterator<String> keys = applicativoConfig.keySet().iterator();
  638.             while (keys.hasNext()) {
  639.                 String key = (String) keys.next();
  640.                 String value = applicativoConfig.get(key);
  641.                 xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_CLIENT_CONFIG_ATTRIBUTE_PREFIX+key, value);
  642.             }
  643.         }
  644.         
  645.         if(credential!=null){
  646.             xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_CREDENTIAL_ATTRIBUTE_ID, credential);
  647.         }
  648.         
  649.         if(roles!=null && roles.size()>0){
  650.             xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_ROLE_ATTRIBUTE_ID, roles);
  651.         }
  652.                 
  653.         if(informazioniTokenUserInfoNormalizzate!=null) {
  654.             if(informazioniTokenUserInfoNormalizzate.getFullName()!=null) {
  655.                 xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_USER_INFO_FULL_NAME_ATTRIBUTE_ID, informazioniTokenUserInfoNormalizzate.getFullName());
  656.             }
  657.             if(informazioniTokenUserInfoNormalizzate.getFirstName()!=null) {
  658.                 xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_USER_INFO_FIRST_NAME_ATTRIBUTE_ID, informazioniTokenUserInfoNormalizzate.getFirstName());
  659.             }
  660.             if(informazioniTokenUserInfoNormalizzate.getMiddleName()!=null) {
  661.                 xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_USER_INFO_MIDDLE_NAME_ATTRIBUTE_ID, informazioniTokenUserInfoNormalizzate.getMiddleName());
  662.             }
  663.             if(informazioniTokenUserInfoNormalizzate.getFamilyName()!=null) {
  664.                 xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_USER_INFO_FAMILY_NAME_ATTRIBUTE_ID, informazioniTokenUserInfoNormalizzate.getFamilyName());
  665.             }
  666.             if(informazioniTokenUserInfoNormalizzate.getEMail()!=null) {
  667.                 xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_USER_INFO_EMAIL_NAME_ATTRIBUTE_ID, informazioniTokenUserInfoNormalizzate.getEMail());
  668.             }
  669.         }
  670.         if(informazioniTokenNormalizzate!=null) {
  671.             if(informazioniTokenNormalizzate.getIss()!=null) {
  672.                 xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_TOKEN_ISSUER_ATTRIBUTE_ID, informazioniTokenNormalizzate.getIss());
  673.             }
  674.             if(informazioniTokenNormalizzate.getSub()!=null) {
  675.                 xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_TOKEN_SUBJECT_ATTRIBUTE_ID, informazioniTokenNormalizzate.getSub());
  676.             }
  677.             if(informazioniTokenNormalizzate.getUsername()!=null) {
  678.                 xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_TOKEN_USERNAME_ATTRIBUTE_ID, informazioniTokenNormalizzate.getUsername());
  679.             }
  680.             if(informazioniTokenNormalizzate.getClientId()!=null) {
  681.                 xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_TOKEN_CLIENT_ID_ATTRIBUTE_ID, informazioniTokenNormalizzate.getClientId());
  682.             }
  683.         }
  684.         
  685.         if(userInfoClaims!=null && userInfoClaims.size()>0) {
  686.             Iterator<?> it = userInfoClaims.keySet().iterator();
  687.             while (it.hasNext()) {
  688.                 String key = (String) it.next();
  689.                 Object value = userInfoClaims.get(key);
  690.                 key = normalizeKeyClaim(key);
  691.                 setSubjectAttribute(xacmlRequest, value, 
  692.                         XACMLCostanti.XACML_REQUEST_SUBJECT_TOKEN_USERINFO_CLAIMS_PREFIX+key);
  693.             }
  694.         }
  695.         
  696.         if(attributeNames!=null && !attributeNames.isEmpty()) {
  697.             setSubjectAttribute(xacmlRequest, attributeNames, 
  698.                     XACMLCostanti.XACML_REQUEST_SUBJECT_ATTRIBUTE_ATTRIBUTE_NAMES_ID);
  699.         }
  700.         if(attributes!=null && attributes.size()>0){
  701.             addAttributes(xacmlRequest, attributes, multipleAA);
  702.         }
  703.         
  704.         if(idApplicativoToken!=null) {
  705.             if(idApplicativoToken.getNome()!=null) {
  706.                 xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_TOKEN_CLIENT_APPLICATION_ATTRIBUTE_ID, idApplicativoToken.getNome());
  707.             }
  708.             if(applicativoTokenConfig!=null && !applicativoTokenConfig.isEmpty()) {
  709.                 Iterator<String> keys = applicativoTokenConfig.keySet().iterator();
  710.                 while (keys.hasNext()) {
  711.                     String key = (String) keys.next();
  712.                     String value = applicativoTokenConfig.get(key);
  713.                     xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_TOKEN_CLIENT_CONFIG_ATTRIBUTE_PREFIX+key, value);
  714.                 }
  715.             }
  716.             
  717.             if(idApplicativoToken.getIdSoggettoProprietario()!=null) {
  718.                 xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_TOKEN_CLIENT_ORGANIZATION_ATTRIBUTE_ID, idApplicativoToken.getIdSoggettoProprietario().toString());
  719.             }
  720.             if(soggettoProprietarioApplicativoTokenConfig!=null && !soggettoProprietarioApplicativoTokenConfig.isEmpty()) {
  721.                 Iterator<String> keys = soggettoProprietarioApplicativoTokenConfig.keySet().iterator();
  722.                 while (keys.hasNext()) {
  723.                     String key = (String) keys.next();
  724.                     String value = soggettoProprietarioApplicativoTokenConfig.get(key);
  725.                     xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_TOKEN_CLIENT_ORGANIZATION_CONFIG_ATTRIBUTE_PREFIX+key, value);
  726.                 }
  727.             }
  728.             
  729.         }
  730.         
  731.         if(applicativoTokenRoles!=null && applicativoTokenRoles.size()>0){
  732.             xacmlRequest.addSubjectAttribute(XACMLCostanti.XACML_REQUEST_SUBJECT_TOKEN_CLIENT_ROLE_ATTRIBUTE_ID, applicativoTokenRoles);
  733.         }

  735.         
  736.         
  737.         // Environment
  738.         
  739.         xacmlRequest.createEnvironment();
  740.         
  741.         
  742.         
  743.         // Resource
  744.         
  745.         //solo in caso di pdp locale inizializzo la resource __resource_id___ con il nome del servizio in modo da consentire l'identificazione della policy
  746.         
  747.         xacmlRequest.addResourceAttribute(CachedMapBasedSimplePolicyRepository.RESOURCE_ATTRIBUTE_ID_TO_MATCH, policyKey);
  748.         
  749.         
  750.         // Fill XAML
  751.         if(httpServletRequest!=null && httpServletRequest instanceof AutorizzazioneHttpServletRequest) {
  752.             AutorizzazioneHttpServletRequest authHttpServletRequest = (AutorizzazioneHttpServletRequest) httpServletRequest;
  753.             authHttpServletRequest.fillXacmlRequest(xacmlRequest);
  754.         }
  755.         
  756.         return xacmlRequest;


  759.     }
  760.     
  761.     @SuppressWarnings("unchecked")
  762.     private static Map<String,String> readConfig(PdDContext pddContext, MapKey<String> pName){
  763.         Object o = pddContext.getObject(pName);
  764.         if(o!=null && o instanceof Map<?, ?>) {
  765.             return (Map<String, String>) o;
  766.         }
  767.         return null;
  768.     }
  769.     
  770.     private static void addAttributes(XacmlRequest xacmlRequest, Map<String, Serializable> attributesParam, boolean multipleAA) {
  771.         if(attributesParam!=null && !attributesParam.isEmpty()) {
  772.             String logAA = "";
  773.             if(multipleAA) {
  774.                 // informazioni normalizzate, devo scendere di un livello, senno al primo degli attributi ci sono le attribute authority
  775.                 for (String attrAuthName : attributesParam.keySet()) {
  776.                     Object o = attributesParam.get(attrAuthName);
  777.                     if(o instanceof Map) {
  778.                         try {
  779.                             List<String> attributesNames = new ArrayList<>();
  780.                             @SuppressWarnings("unchecked")
  781.                             Map<String, Serializable> attributes = (Map<String, Serializable>) o;
  782.                             if(attributes!=null && !attributes.isEmpty()) {
  783.                                 for (String attrName : attributes.keySet()) {
  784.                                     if(!attributesNames.contains(attrName)) {
  785.                                         attributesNames.add(attrName);
  786.                                     }
  787.                                 }
  788.                             }
  789.                             Collections.sort(attributesNames);
  790.                             String xacmlIdPrefix = XACMLCostanti.XACML_REQUEST_SUBJECT_ATTRIBUTE_AUTHORITY_ATTRIBUTE_PREFIX+
  791.                                     attrAuthName+
  792.                                     XACMLCostanti._XACML_REQUEST_SUBJECT_ATTRIBUTE_ATTRIBUTE_PREFIX;
  793.                             JSONUtils jsonUtils = JSONUtils.getInstance();
  794.                             logAA = " (A.A. "+attrAuthName+")";
  795.                             for (String attributeName : attributesNames) {
  796.                                 addAttribute(xacmlRequest, xacmlIdPrefix, attributes, attributeName,
  797.                                         jsonUtils, logAA);
  798.                             }
  799.                         }catch(Throwable t) {
  800.                             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("addAttributes failed (A.A. "+attrAuthName+"): "+t.getMessage(),t);
  801.                         }
  802.                     }
  803.                 }
  804.                 
  805.             }
  806.             else {
  807.                 List<String> attributesNames = new ArrayList<>();
  808.                 for (String attrName : attributesParam.keySet()) {
  809.                     attributesNames.add(attrName);
  810.                 }
  811.                 Collections.sort(attributesNames);
  812.                 String xacmlIdPrefix = XACMLCostanti.XACML_REQUEST_SUBJECT_ATTRIBUTE_ATTRIBUTE_PREFIX;
  813.                 JSONUtils jsonUtils = JSONUtils.getInstance();
  814.                 for (String attributeName : attributesNames) {
  815.                     addAttribute(xacmlRequest, xacmlIdPrefix, attributesParam, attributeName,
  816.                             jsonUtils, logAA);
  817.                 }
  818.             }
  819.         }
  820.     }
  821.     private static void addAttribute(XacmlRequest xacmlRequest, String xacmlIdPrefix, Map<String, Serializable> attributes, String attributeName,
  822.             JSONUtils jsonUtils, String logAA) {
  823.         Object oValue = attributes.get(attributeName);
  824.         if(oValue!=null) {
  825.             try {
  826.                 String key = normalizeKeyClaim(attributeName);
  827.                 setSubjectAttribute(xacmlRequest, oValue, 
  828.                         xacmlIdPrefix+key);
  829.                 
  830. //              //System.out.println("TIPO: "+oValue.getClass().getName());
  831. //              if(oValue instanceof String) {
  832. //                  String value = (String) oValue;
  833. //                  xacmlRequest.addSubjectAttribute(xacmlIdPrefix+attributeName, value);
  834. //              }
  835. //              else if(oValue instanceof List<?>) {
  836. //                  List<?> list = (List<?>) oValue;
  837. //                  if(list!=null && !list.isEmpty()) {
  838. //                      List<String> lValues = new ArrayList<>();
  839. //                      for (Object object : list) {
  840. //                          if(object!=null && object instanceof String) {
  841. //                              lValues.add((String)object);
  842. //                          }
  843. //                      }
  844. //                      if(!lValues.isEmpty()) {
  845. //                          xacmlRequest.addSubjectAttribute(xacmlIdPrefix+attributeName, lValues);
  846. //                      }
  847. //                  }
  848. //              }
  849. //              else {
  850. //                  throw new Exception("type '"+oValue.getClass().getName()+"' unmanaged");
  851. //              }
  852.             }catch(Throwable t) {
  853.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("addAttribute '"+attributeName+"' failed"+logAA+": "+t.getMessage(),t);
  854.             }
  855.         }
  856.     }
  857.     
  858.     private static String normalizeKeyClaim(String keyParam) {
  859.         String key = keyParam;
  860.         while(key.contains(".")) {
  861.             key = key.replace(".", ":");
  862.         }
  863.         return key;
  864.     }
  865.     
  866.     private static void setActionAttribute(XacmlRequest xacmlRequest, Object value, String claim) {
  867.         setAttribute(xacmlRequest, value, claim, true);
  868.     }
  869.     private static void setSubjectAttribute(XacmlRequest xacmlRequest, Object value, String claim) {
  870.         setAttribute(xacmlRequest, value, claim, false);
  871.     }
  872.     private static void setAttribute(XacmlRequest xacmlRequest, Object value, String claim, boolean action) {
  873.         if(value!=null) {
  874.             List<String> l = TokenUtilities.getClaimValues(value);
  875.             if(l!=null && !l.isEmpty()) {
  876.                 if(l.size()>1) {
  877.                     if(action) {
  878.                         xacmlRequest.addActionAttribute(claim, l);
  879.                     }
  880.                     else {
  881.                         xacmlRequest.addSubjectAttribute(claim, l);
  882.                     }
  883.                 }
  884.                 else {
  885.                     if(action) {
  886.                         xacmlRequest.addActionAttribute(claim, l.get(0));
  887.                     }
  888.                     else {
  889.                         xacmlRequest.addSubjectAttribute(claim, l.get(0));
  890.                     }
  891.                 }
  892.             }
  893.         }
  894.     }

  896. }
Created with JaCoCo 0.8.8.202204050719