Utilities.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.pdd.core;

  22. import org.openspcoop2.core.id.IDAccordo;
  23. import org.openspcoop2.core.id.IDServizio;
  24. import org.openspcoop2.core.id.IDSoggetto;
  25. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  26. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  27. import org.openspcoop2.core.registry.Resource;
  28. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  29. import org.openspcoop2.message.OpenSPCoop2Message;
  30. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  31. import org.openspcoop2.message.constants.MessageRole;
  32. import org.openspcoop2.pdd.config.ClassNameProperties;
  33. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  34. import org.openspcoop2.pdd.services.connector.ConnectorException;
  35. import org.openspcoop2.protocol.registry.RegistroServiziManager;
  36. import org.openspcoop2.protocol.sdk.Busta;
  37. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  38. import org.openspcoop2.protocol.sdk.ProtocolException;
  39. import org.openspcoop2.protocol.sdk.Trasmissione;
  40. import org.openspcoop2.protocol.sdk.state.IState;
  41. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  42. import org.openspcoop2.utils.date.DateEngineType;
  43. import org.openspcoop2.utils.id.IDUtilities;
  44. import org.openspcoop2.utils.resources.Loader;
  45. import org.openspcoop2.utils.rest.api.ApiOperation;
  46. import org.openspcoop2.utils.transport.http.HttpRequestMethod;
  47. import org.slf4j.Logger;

  49. /**
  50.  * Utilities PdD
  51.  *
  52.  * @author Poli Andrea (apoli@link.it)
  53.  * @author $Author$
  54.  * @version $Rev$, $Date$
  55.  */
  56. public class Utilities {

  58.     public static void refreshIdentificativiPorta(Busta busta,IDSoggetto idSoggettoDefault,RegistroServiziManager registroServiziManager,IProtocolFactory<?> protocolFactory, RequestInfo requestInfo){
  59.         if(busta==null) {
  60.             return;
  61.         }
  62.         if(busta.getMittente()!=null && busta.getTipoMittente()!=null && busta.getIdentificativoPortaMittente()==null){
  63.             try{
  64.                 if(idSoggettoDefault.getTipo().equals(busta.getTipoMittente()) &&
  65.                         idSoggettoDefault.getNome().equals(busta.getMittente())){
  66.                     busta.setIdentificativoPortaMittente(idSoggettoDefault.getCodicePorta());
  67.                 }
  68.                 else{
  69.                     busta.setIdentificativoPortaMittente(registroServiziManager.getDominio(new IDSoggetto(busta.getTipoMittente(), busta.getMittente()), null, protocolFactory, requestInfo));
  70.                 }
  71.             }catch(Exception e){}
  72.         }
  73.         if(busta.getDestinatario()!=null && busta.getTipoDestinatario()!=null && busta.getIdentificativoPortaDestinatario()==null){
  74.             try{
  75.                 if(idSoggettoDefault.getTipo().equals(busta.getTipoDestinatario()) &&
  76.                         idSoggettoDefault.getNome().equals(busta.getDestinatario())){
  77.                     busta.setIdentificativoPortaDestinatario(idSoggettoDefault.getCodicePorta());
  78.                 }
  79.                 else{
  80.                     busta.setIdentificativoPortaDestinatario(registroServiziManager.getDominio(new IDSoggetto(busta.getTipoDestinatario(), busta.getDestinatario()), null, protocolFactory, requestInfo));
  81.                 }
  82.             }catch(Exception e){}
  83.         }
  84.         for (int i = 0; i < busta.sizeListaTrasmissioni(); i++) {
  85.             Trasmissione tr = busta.getTrasmissione(i);
  86.             if(tr.getOrigine()!=null && tr.getTipoOrigine()!=null && tr.getIdentificativoPortaOrigine()==null){
  87.                 try{
  88.                     if(idSoggettoDefault.getTipo().equals(tr.getTipoOrigine()) &&
  89.                             idSoggettoDefault.getNome().equals(tr.getOrigine())){
  90.                         tr.setIdentificativoPortaOrigine(idSoggettoDefault.getCodicePorta());
  91.                     }
  92.                     else{
  93.                         tr.setIdentificativoPortaOrigine(registroServiziManager.getDominio(new IDSoggetto(tr.getTipoOrigine(), tr.getOrigine()), null, protocolFactory, requestInfo));
  94.                     }
  95.                 }catch(Exception e){}
  96.             }
  97.             if(tr.getDestinazione()!=null && tr.getTipoDestinazione()!=null && tr.getIdentificativoPortaDestinazione()==null){
  98.                 try{
  99.                     if(idSoggettoDefault.getTipo().equals(tr.getTipoDestinazione()) &&
  100.                             idSoggettoDefault.getNome().equals(tr.getDestinazione())){
  101.                         tr.setIdentificativoPortaDestinazione(idSoggettoDefault.getCodicePorta());
  102.                     }
  103.                     else{
  104.                         tr.setIdentificativoPortaDestinazione(registroServiziManager.getDominio(new IDSoggetto(tr.getTipoDestinazione(), tr.getDestinazione()), null, protocolFactory, requestInfo));
  105.                     }
  106.                 }catch(Exception e){}
  107.             }
  108.         }
  109.     }

  111.     
  112.     private static OpenSPCoop2MessageFactory _factory = OpenSPCoop2MessageFactory.getDefaultMessageFactory();
  113.     public static OpenSPCoop2MessageFactory getOpenspcoop2MessageFactory(Logger log, RequestInfo requestInfo, MessageRole role) throws ConnectorException{
  114.         return getOpenspcoop2MessageFactory(log, null, requestInfo, role);
  115.     }
  116.     public static OpenSPCoop2MessageFactory getOpenspcoop2MessageFactory(Logger log, OpenSPCoop2Message requestMessage, RequestInfo requestInfo, MessageRole role) throws ConnectorException{
  117.         OpenSPCoop2MessageFactory useFactory = _factory;
  118.         if(requestMessage!=null && requestMessage.getFactory()!=null) {
  119.             useFactory = requestMessage.getFactory();
  120.         }
  121.         else {
  122.             if(requestInfo!=null && requestInfo.getMessageFactory()!=null) {
  123.                 String classNameMessageFactory = ClassNameProperties.getInstance().getOpenSPCoop2MessageFactory(requestInfo.getMessageFactory());
  124.                 if(classNameMessageFactory==null) {
  125.                     throw new ConnectorException("MessageFactory '"+requestInfo.getMessageFactory()+"' not found");
  126.                 }
  127.                 try {
  128.                     useFactory = (OpenSPCoop2MessageFactory) Loader.getInstance().newInstance(classNameMessageFactory);
  129.                 }catch(Exception e){
  130.                     throw new ConnectorException(e.getMessage(),e);
  131.                 }   
  132.             }
  133.         }
  134.         log.debug("MessageEngineFactory ["+role+"] ["+useFactory.getClass().getName()+"]");
  135.         return useFactory;
  136.     }
  137.     
  138.     public static String generateIDDateTime(String format, int syncMs, String clusterIdSeparator, boolean clusterIdAsPrefix) throws ProtocolException {
  139.         return _generateIDDateTime(IDUtilities.generateDateTime(format, syncMs), clusterIdSeparator, clusterIdAsPrefix);
  140.     }
  141.     public static String generateIDDateTime(DateEngineType type, String format, int syncMs, String clusterIdSeparator, boolean clusterIdAsPrefix) throws ProtocolException {
  142.         return _generateIDDateTime(IDUtilities.generateDateTime(type, format, syncMs), clusterIdSeparator, clusterIdAsPrefix);
  143.     }
  144.     public static String generateIDDateTime_ISO_8601_TZ(String format, int syncMs, String clusterIdSeparator, boolean clusterIdAsPrefix) throws ProtocolException {
  145.         return _generateIDDateTime(IDUtilities.generateDateTime_ISO_8601_TZ(format, syncMs), clusterIdSeparator, clusterIdAsPrefix);
  146.     }
  147.     public static String generateIDDateTime_ISO_8601_TZ(DateEngineType type, String format, int syncMs, String clusterIdSeparator, boolean clusterIdAsPrefix) throws ProtocolException {
  148.         return _generateIDDateTime(IDUtilities.generateDateTime_ISO_8601_TZ(type, format, syncMs), clusterIdSeparator, clusterIdAsPrefix);
  149.     }
  150.     private static String _generateIDDateTime(String timeId, String clusterIdSeparator, boolean clusterIdAsPrefix) throws ProtocolException {
  151.         Integer prefix = null;
  152.         String prefixSop2 = OpenSPCoop2Properties.getInstance().getClusterIdNumerico();
  153.         if(prefixSop2!=null) {
  154.             prefix = Integer.valueOf(prefixSop2);
  155.         }
  156.         String prefixS = "00";
  157.         if(prefix!=null) {
  158.             if(prefix<10) {
  159.                 prefixS = "0"+prefix.intValue();
  160.             }
  161.             else {
  162.                 prefixS = ""+prefix.intValue();
  163.             }
  164.         }
  165.         if(clusterIdAsPrefix) {
  166.             return prefixS + clusterIdSeparator + timeId;
  167.         }
  168.         else {
  169.             return timeId + clusterIdSeparator + prefixS;
  170.         }
  171.     }
  172.     
  173.     
  174.     /* *********** INDIVIDUAZIONE RISORSA REST ************ */
  175.     
  176.     private static final String SPECIAL = "*";
  177.     
  178.     public static String [] parseResourceRest(String element) {
  179.         
  180.         String check = element.toLowerCase();
  181.         
  182.         String checkMethod = SPECIAL+" ";
  183.         if(check.startsWith(checkMethod) && check.length()>checkMethod.length()) {
  184.             String [] tmp = new String[2];
  185.             tmp[0] = SPECIAL;
  186.             tmp[1] = check.substring(checkMethod.length());
  187.             return tmp;
  188.         }
  189.         
  190.         HttpRequestMethod [] methods = HttpRequestMethod.values();
  191.         if(methods!=null && methods.length>0) {
  192.             for (HttpRequestMethod httpRequestMethod : methods) {
  193.                 checkMethod = httpRequestMethod.name().toLowerCase()+" ";
  194.                 if(check.startsWith(checkMethod) && check.length()>checkMethod.length()) {
  195.                     String [] tmp = new String[2];
  196.                     tmp[0] = httpRequestMethod.name();
  197.                     tmp[1] = check.substring(checkMethod.length());
  198.                     return tmp;
  199.                 }
  200.             }
  201.         }
  202.         
  203.         return null;
  204.         
  205.     }
  206.     
  207.     public static boolean isRestResourceMatch(String [] parseResourceRest, Resource restResource) {
  208.         boolean isResourceRest = false;
  209.         String metodo = parseResourceRest[0];
  210.         String path = parseResourceRest[1];
  211.         if(SPECIAL.equals(metodo) || 
  212.                 (restResource.getMethod()!=null && metodo.toLowerCase().equals(restResource.getMethod().name().toLowerCase())) || 
  213.                 (restResource.getMethod()==null) // qualsiasi
  214.                 ) {
  215.             if(path.equals(SPECIAL)) {
  216.                 isResourceRest = true;
  217.             }
  218.             else if(restResource.getPath()!=null){
  219.                 String resourcePathNormalized = ApiOperation.normalizePath(restResource.getPath());
  220.                 resourcePathNormalized = resourcePathNormalized.trim().toLowerCase();
  221.                 path = ApiOperation.normalizePath(path);
  222.                 path = path.trim().toLowerCase();
  223.                 if(path.endsWith(SPECIAL)) {
  224.                     String prefix = path.substring(0, path.length()-1);
  225.                     if(resourcePathNormalized.startsWith(prefix)) {
  226.                         isResourceRest = true;
  227.                     }
  228.                 }
  229.                 else if(path.equals(resourcePathNormalized)) {
  230.                     isResourceRest = true;
  231.                 }
  232.             }                   
  233.         }
  234.         return isResourceRest;
  235.     }
  236.     
  237.     public static Resource getRestResource(Logger log, IState state, IDServizio idServizio, RequestInfo requestInfo) {
  238.         if(idServizio!=null && idServizio.getAzione()!=null && !"".equals(idServizio.getAzione())) {
  239.             RegistroServiziManager registroServiziManager = RegistroServiziManager.getInstance(state);
  240.             try {
  241.                 AccordoServizioParteSpecifica asps = registroServiziManager.getAccordoServizioParteSpecifica(idServizio, null, false, requestInfo);
  242.                 if(asps.getAccordoServizioParteComune()!=null && !"".equals(asps.getAccordoServizioParteComune())) {
  243.                     IDAccordo idAccordo = IDAccordoFactory.getInstance().getIDAccordoFromUri(asps.getAccordoServizioParteComune());
  244.                     AccordoServizioParteComune as = registroServiziManager.getAccordoServizioParteComune(idAccordo, null, false, false, requestInfo);
  245.                     for (Resource resourceCheck : as.getResourceList()) {
  246.                         if(resourceCheck.getNome().equals(idServizio.getAzione())){
  247.                             return resourceCheck;
  248.                         }
  249.                     }
  250.                 }
  251.             }catch(Throwable e) {
  252.                 log.error(e.getMessage(),e);
  253.             }
  254.         }
  255.         return null;
  256.     }
  257. }
Created with JaCoCo 0.8.8.202204050719