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

  21. package org.openspcoop2.protocol.engine.utils;

  23. import java.util.ArrayList;
  24. import java.util.Collections;
  25. import java.util.HashMap;
  26. import java.util.LinkedHashMap;
  27. import java.util.List;
  28. import java.util.Map;

  30. import org.openspcoop2.core.commons.CoreException;
  31. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  32. import org.openspcoop2.core.constants.CostantiDB;
  33. import org.openspcoop2.core.id.IDServizio;
  34. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  35. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  36. import org.openspcoop2.core.registry.Operation;
  37. import org.openspcoop2.core.registry.PortType;
  38. import org.openspcoop2.core.registry.ProtocolProperty;
  39. import org.openspcoop2.core.registry.Resource;
  40. import org.openspcoop2.core.registry.beans.AccordoServizioParteComuneSintetico;
  41. import org.openspcoop2.core.registry.beans.PortTypeSintetico;
  42. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  43. import org.slf4j.Logger;


  46. /**
  47.  * AzioniUtils
  48.  *
  49.  * @author Poli Andrea (apoli@link.it)
  50.  * @author $Author$
  51.  * @version $Rev$, $Date$
  52.  */
  53. public class AzioniUtils {
  54.     
  55.     private AzioniUtils() {}

  57.     public static List<String> getAzioni(AccordoServizioParteSpecifica asps,AccordoServizioParteComuneSintetico aspc, 
  58.             boolean addTrattinoSelezioneNonEffettuata, boolean throwException, List<String> filtraAzioniUtilizzate,
  59.             String defaultValueAzioneRisorsaNonSelezionata, Logger log) throws DriverConfigurazioneException{
  60.         String nomeMetodo = "getAzioni";
  61.         try {
  62.             // Prendo le azioni associate al servizio
  63.             List<String> azioniList = null;
  64.             try {
  65.                 if(aspc!=null) {
  66.                     org.openspcoop2.core.registry.constants.ServiceBinding sb = aspc.getServiceBinding();
  67.                     switch (sb) {
  68.                     case SOAP:
  69.                         if (asps != null) {
  70.                             
  71.                             IDServizio idServizio = IDServizioFactory.getInstance().getIDServizioFromAccordo(asps);
  72.                             
  73.                             if(asps.getPortType()!=null){
  74.                                 // Bisogna prendere le operations del port type
  75.                                 PortTypeSintetico pt = null;
  76.                                 for (int i = 0; i < aspc.getPortType().size(); i++) {
  77.                                     if(aspc.getPortType().get(i).getNome().equals(asps.getPortType())){
  78.                                         pt = aspc.getPortType().get(i);
  79.                                         break;
  80.                                     }
  81.                                 }
  82.                                 if(pt==null){
  83.                                     throw new CoreException("Servizio ["+idServizio.toString()+"] possiede il port type ["+asps.getPortType()+"] che non risulta essere registrato nell'accordo di servizio ["+asps.getAccordoServizioParteComune()+"]");
  84.                                 }
  85.                                 if(!pt.getAzione().isEmpty()){
  86.                                     azioniList = new ArrayList<>();
  87.                                     for (int i = 0; i < pt.getAzione().size(); i++) {
  88.                                         if(filtraAzioniUtilizzate==null || !filtraAzioniUtilizzate.contains(pt.getAzione().get(i).getNome())) {
  89.                                             azioniList.add(pt.getAzione().get(i).getNome());
  90.                                         }
  91.                                     }
  92.                                 }
  93.                             }else{
  94.                                 if(!aspc.getAzione().isEmpty()){
  95.                                     azioniList = new ArrayList<>();
  96.                                     for (int i = 0; i < aspc.getAzione().size(); i++) {
  97.                                         if(filtraAzioniUtilizzate==null || !filtraAzioniUtilizzate.contains(aspc.getAzione().get(i).getNome())) {
  98.                                             azioniList.add(aspc.getAzione().get(i).getNome());
  99.                                         }
  100.                                     }
  101.                                 }
  102.                             }               
  103.                         }
  104.                         break;

  106.                     case REST:
  107.                         if(!aspc.getResource().isEmpty()){
  108.                             azioniList = new ArrayList<>();
  109.                             for (int i = 0; i < aspc.getResource().size(); i++) {
  110.                                 if(filtraAzioniUtilizzate==null || !filtraAzioniUtilizzate.contains(aspc.getResource().get(i).getNome())) {
  111.                                     azioniList.add(aspc.getResource().get(i).getNome());
  112.                                 }
  113.                             }
  114.                         }
  115.                         break;
  116.                     }
  117.                     
  118.                 }
  119.             } catch (Exception e) {
  120.                 if(throwException) {
  121.                     throw e;
  122.                 }
  123.             }
  124.             
  125.             List<String> azioniListReturn = null;
  126.             if(azioniList!=null && !azioniList.isEmpty()) {
  127.                 Collections.sort(azioniList);
  128.                 
  129.                 azioniListReturn = new ArrayList<>();
  130.                 if(addTrattinoSelezioneNonEffettuata) {
  131.                     azioniListReturn.add(defaultValueAzioneRisorsaNonSelezionata);
  132.                 }
  133.                 azioniListReturn.addAll(azioniList);
  134.             }
  135.                 
  136.             return azioniListReturn;
  137.             
  138.         } catch (Exception e) {
  139.             log.error("["+nomeMetodo + "] Exception :" + e.getMessage(), e);
  140.             throw new DriverConfigurazioneException("[" + nomeMetodo + "] Error :" + e.getMessage(),e);
  141.         }
  142.         
  143.     }
  144.     
  145.     public static Map<String,String> getMapAzioni(AccordoServizioParteSpecifica asps,AccordoServizioParteComuneSintetico aspc, 
  146.             boolean addTrattinoSelezioneNonEffettuata, boolean throwException, List<String> filtraAzioniUtilizzate, 
  147.             boolean sortByLabel, boolean sortFirstByPath, // per soap questi due parametri sono  ininfluenti
  148.             String defaultValueAzioneRisorsaNonSelezionata, String defaultLabelAzioneRisorsaNonSelezionata, Logger log
  149.             ) throws DriverConfigurazioneException{
  150.         String nomeMetodo = "getAzioni";
  151.         try {
  152.             // Prendo le azioni associate al servizio
  153.             Map<String,String> azioniMap = null; // <id,label>
  154.             List<String> sortList = null;
  155.             Map<String,String> sortMap = null; // <sort,id>
  156.             try {
  157.                 if(aspc!=null) {
  158.                     org.openspcoop2.core.registry.constants.ServiceBinding sb = aspc.getServiceBinding();
  159.                     switch (sb) {
  160.                     case SOAP:
  161.                         if (asps != null) {
  162.                             
  163.                             IDServizio idServizio = IDServizioFactory.getInstance().getIDServizioFromAccordo(asps);
  164.                             
  165.                             if(asps.getPortType()!=null){
  166.                                 // Bisogna prendere le operations del port type
  167.                                 PortTypeSintetico pt = null;
  168.                                 for (int i = 0; i < aspc.getPortType().size(); i++) {
  169.                                     if(aspc.getPortType().get(i).getNome().equals(asps.getPortType())){
  170.                                         pt = aspc.getPortType().get(i);
  171.                                         break;
  172.                                     }
  173.                                 }
  174.                                 if(pt==null){
  175.                                     throw new CoreException("Servizio ["+idServizio.toString()+"] possiede il port type ["+asps.getPortType()+"] che non risulta essere registrato nell'accordo di servizio ["+asps.getAccordoServizioParteComune()+"]");
  176.                                 }
  177.                                 if(!pt.getAzione().isEmpty()){
  178.                                     azioniMap = new HashMap<>();
  179.                                     sortList = new ArrayList<>();
  180.                                     for (int i = 0; i < pt.getAzione().size(); i++) {
  181.                                         if(filtraAzioniUtilizzate==null || !filtraAzioniUtilizzate.contains(pt.getAzione().get(i).getNome())) {
  182.                                             sortList.add(pt.getAzione().get(i).getNome());
  183.                                             azioniMap.put(pt.getAzione().get(i).getNome(),pt.getAzione().get(i).getNome());
  184.                                         }
  185.                                     }
  186.                                 }
  187.                             }else{
  188.                                 if(!aspc.getAzione().isEmpty()){
  189.                                     azioniMap = new HashMap<>();
  190.                                     sortList = new ArrayList<>();
  191.                                     for (int i = 0; i < aspc.getAzione().size(); i++) {
  192.                                         if(filtraAzioniUtilizzate==null || !filtraAzioniUtilizzate.contains(aspc.getAzione().get(i).getNome())) {
  193.                                             sortList.add(aspc.getAzione().get(i).getNome());
  194.                                             azioniMap.put(aspc.getAzione().get(i).getNome(),aspc.getAzione().get(i).getNome());
  195.                                         }
  196.                                     }
  197.                                 }
  198.                             }               
  199.                         }
  200.                         break;

  202.                     case REST:
  203.                         if(!aspc.getResource().isEmpty()){
  204.                             azioniMap = new HashMap<>();
  205.                             sortList = new ArrayList<>();
  206.                             if(sortByLabel) {
  207.                                 sortMap = new HashMap<>();
  208.                             }
  209.                             for (int i = 0; i < aspc.getResource().size(); i++) {
  210.                                 if(filtraAzioniUtilizzate==null || !filtraAzioniUtilizzate.contains(aspc.getResource().get(i).getNome())) {
  211.                                     if(sortByLabel) {
  212.                                         String sortLabelId = null;
  213.                                         if(!sortFirstByPath) {
  214.                                             sortLabelId = NamingUtils.getLabelResource(aspc.getResource().get(i));
  215.                                         }
  216.                                         else {
  217.                                             String path = aspc.getResource().get(i).getPath()!=null ? aspc.getResource().get(i).getPath() : CostantiDB.API_RESOURCE_PATH_ALL_VALUE;
  218.                                             String method = aspc.getResource().get(i).getMethod()!=null ? aspc.getResource().get(i).getMethod().getValue() : CostantiDB.API_RESOURCE_HTTP_METHOD_ALL_VALUE;
  219.                                             sortLabelId = path+" "+method;
  220.                                         }
  221.                                         sortList.add(sortLabelId);
  222.                                         sortMap.put(sortLabelId, aspc.getResource().get(i).getNome());
  223.                                     }
  224.                                     else {
  225.                                         sortList.add(aspc.getResource().get(i).getNome());
  226.                                     }
  227.                                     azioniMap.put(aspc.getResource().get(i).getNome(),NamingUtils.getLabelResource(aspc.getResource().get(i)));
  228.                                 }
  229.                             }
  230.                         }
  231.                         break;
  232.                     }
  233.                     
  234.                 }
  235.             } catch (Exception e) {
  236.                 if(throwException) {
  237.                     throw e;
  238.                 }
  239.             }
  240.             
  241.             Map<String, String> mapAzioniReturn = new LinkedHashMap<>();
  242.             if(sortList!=null && !sortList.isEmpty()) {
  243.                 Collections.sort(sortList);
  244.                 
  245.                 if(addTrattinoSelezioneNonEffettuata) {
  246.                     mapAzioniReturn.put(defaultValueAzioneRisorsaNonSelezionata,defaultLabelAzioneRisorsaNonSelezionata);
  247.                 }
  248.                 
  249.                 if(sortMap!=null) {
  250.                     for (String idSort : sortList) { 
  251.                         String id  = sortMap.get(idSort);
  252.                         mapAzioniReturn.put(id, azioniMap.get(id));
  253.                     }
  254.                 }
  255.                 else {
  256.                     for (String id : sortList) { // nelle sortList ci sono gli id
  257.                         mapAzioniReturn.put(id, azioniMap.get(id));
  258.                     }
  259.                 }
  260.             }
  261.                 
  262.             return mapAzioniReturn;
  263.             
  264.         } catch (Exception e) {
  265.             log.error("[ControlStationCore::" + nomeMetodo + "] Exception :" + e.getMessage(), e);
  266.             throw new DriverConfigurazioneException("[ControlStationCore::" + nomeMetodo + "] Error :" + e.getMessage(),e);
  267.         }
  268.     }
  269.     
  270.     public static Map<String,String> getAzioniConLabel(AccordoServizioParteSpecifica asps,AccordoServizioParteComuneSintetico aspc, 
  271.             boolean addTrattinoSelezioneNonEffettuata, boolean throwException, List<String> filtraAzioniUtilizzate,
  272.             String defaultValueAzioneRisorsaNonSelezionata, String defaultLabelAzioneRisorsaNonSelezionata, Logger log) throws DriverConfigurazioneException {
  273.         return getMapAzioni(asps, aspc, addTrattinoSelezioneNonEffettuata, throwException, filtraAzioniUtilizzate,
  274.                 true, true,
  275.                 defaultValueAzioneRisorsaNonSelezionata, defaultLabelAzioneRisorsaNonSelezionata, log);
  276.     }
  277.     
  278.     
  279.     
  280.     public static String getProtocolPropertyStringValue(AccordoServizioParteComune aspc, String idPortType, String idAzione, String propertyName) {
  281.         if(idPortType!=null) {
  282.             for (PortType pt : aspc.getPortTypeList()) {
  283.                 if(pt.getNome().equals(idPortType)) {
  284.                     for (Operation op : pt.getAzioneList()) {
  285.                         if(op.getNome().equals(idAzione)) {
  286.                             for (ProtocolProperty pp : op.getProtocolPropertyList()) {
  287.                                 if(pp.getName().equals(propertyName)) {
  288.                                     return pp.getValue();
  289.                                 }
  290.                             }
  291.                             break;
  292.                         }
  293.                     }
  294.                     break;
  295.                 }
  296.             }
  297.         }
  298.         else {
  299.             for (Resource resource : aspc.getResourceList()) {
  300.                 if(resource.getNome().equals(idAzione)) {
  301.                     for (ProtocolProperty pp : resource.getProtocolPropertyList()) {
  302.                         if(pp.getName().equals(propertyName)) {
  303.                             return pp.getValue();
  304.                         }
  305.                     }
  306.                     break;
  307.                 }
  308.             }
  309.         }
  310.         return null;
  311.     }
  312.     
  313. }
Created with JaCoCo 0.8.8.202204050719