ValidazioneSintattica.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.basic.validator;

  23. import java.util.Date;

  25. import org.openspcoop2.core.constants.TipoPdD;
  26. import org.openspcoop2.core.id.IDSoggetto;
  27. import org.openspcoop2.message.OpenSPCoop2Message;
  28. import org.openspcoop2.message.constants.ServiceBinding;
  29. import org.openspcoop2.protocol.basic.BasicStateComponentFactory;
  30. import org.openspcoop2.protocol.sdk.Busta;
  31. import org.openspcoop2.protocol.sdk.BustaRawContent;
  32. import org.openspcoop2.protocol.sdk.Context;
  33. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  34. import org.openspcoop2.protocol.sdk.ProtocolException;
  35. import org.openspcoop2.protocol.sdk.Trasmissione;
  36. import org.openspcoop2.protocol.sdk.builder.IBustaBuilder;
  37. import org.openspcoop2.protocol.sdk.builder.ProprietaManifestAttachments;
  38. import org.openspcoop2.protocol.sdk.constants.ErroriCooperazione;
  39. import org.openspcoop2.protocol.sdk.constants.ProfiloDiCollaborazione;
  40. import org.openspcoop2.protocol.sdk.constants.RuoloMessaggio;
  41. import org.openspcoop2.protocol.sdk.constants.TipoOraRegistrazione;
  42. import org.openspcoop2.protocol.sdk.state.IState;
  43. import org.openspcoop2.protocol.sdk.validator.ProprietaValidazioneErrori;
  44. import org.openspcoop2.protocol.sdk.validator.ValidazioneSintatticaResult;
  45. import org.openspcoop2.utils.date.DateManager;

  47. /**
  48.  * ValidazioneSintattica
  49.  * 
  50.  * @author Nardi Lorenzo (apoli@link.it)
  51.  * @author $Author$
  52.  * @version $Rev$, $Date$
  53.  * 
  54.  */
  55. public class ValidazioneSintattica<BustaRawType> extends BasicStateComponentFactory implements
  56.         org.openspcoop2.protocol.sdk.validator.IValidazioneSintattica<BustaRawType> {

  58.     private IBustaBuilder<BustaRawType> bustaBuilder = null;
  59.     protected Context context;
  60.         
  61.     public ValidazioneSintattica(IProtocolFactory<BustaRawType> factory,IState state) throws ProtocolException{
  62.         super(factory,state);
  63.         this.bustaBuilder = factory.createBustaBuilder(state);
  64.     }

  66.     @Override
  67.     public void setContext(Context context) {
  68.         this.context = context;
  69.     }
  70.     
  71.     @Override
  72.     public ValidazioneSintatticaResult<BustaRawType> validaRichiesta(OpenSPCoop2Message msg, Busta datiBustaLettiURLMappingProperties, ProprietaValidazioneErrori proprietaValidazioneErrori) throws ProtocolException{
  73.         
  74.         Busta busta = null;
  75.         if(datiBustaLettiURLMappingProperties!=null)
  76.             busta = datiBustaLettiURLMappingProperties; 
  77.         else
  78.             busta = new Busta(this.protocolFactory.getProtocol());
  79.         
  80.         Date oraRegistrazione = DateManager.getDate();
  81.         busta.setOraRegistrazione(oraRegistrazione);
  82.         if(busta.getTipoOraRegistrazione()==null){
  83.             busta.setTipoOraRegistrazione(TipoOraRegistrazione.LOCALE,this.protocolFactory.createTraduttore().toString(busta.getTipoOraRegistrazione()));
  84.         }
  85.         if(busta.sizeListaTrasmissioni()>0){
  86.             for (Trasmissione trasmissione : busta.getListaTrasmissioni()) {
  87.                 if(trasmissione.getOraRegistrazione()==null){
  88.                     trasmissione.setOraRegistrazione(oraRegistrazione);
  89.                 }
  90.                 if(trasmissione.getTempo()==null){
  91.                     trasmissione.setTempo(TipoOraRegistrazione.LOCALE,this.protocolFactory.createTraduttore().toString(busta.getTipoOraRegistrazione()));
  92.                 }
  93.             }
  94.         }
  95.         
  96.         return new ValidazioneSintatticaResult<BustaRawType>(null, null, null, busta, null, null, null, true);
  97.     }
  98.     
  99.     @Override
  100.     public ValidazioneSintatticaResult<BustaRawType> validaRisposta(OpenSPCoop2Message msg, Busta bustaRichiesta, 
  101.             ProprietaValidazioneErrori proprietaValidazioneErrori) throws ProtocolException{
  102.         
  103.         Busta bustaRisposta = bustaRichiesta.invertiBusta(bustaRichiesta.getTipoOraRegistrazione(), bustaRichiesta.getTipoOraRegistrazioneValue());
  104.         bustaRisposta.setRiferimentoMessaggio(bustaRichiesta.getID());
  105.         bustaRisposta.setProfiloDiCollaborazione(bustaRichiesta.getProfiloDiCollaborazione(), bustaRichiesta.getProfiloDiCollaborazioneValue());
  106.         bustaRisposta.setTipoServizio(bustaRichiesta.getTipoServizio());
  107.         bustaRisposta.setServizio(bustaRichiesta.getServizio());
  108.         bustaRisposta.setVersioneServizio(bustaRichiesta.getVersioneServizio());
  109.         bustaRisposta.setAzione(bustaRichiesta.getAzione());
  110.         // estraggo l'identificativo di transazione dalla richiesta, eliminandone la data iniziale se il protocollo la supporta
  111.         String idSenzaData = null;
  112.         try{
  113.             Date d = this.bustaBuilder.extractDateFromID(bustaRichiesta.getID());
  114.             if(d!=null){
  115.                 String [] split = bustaRichiesta.getID().split("-");
  116.                 idSenzaData = bustaRichiesta.getID().substring((split[0].length()+1));
  117.             }
  118.             else{
  119.                 idSenzaData = bustaRichiesta.getID();
  120.             }
  121.         }catch(Exception e){
  122.             throw new ProtocolException("Identificativo di richiesta in un formato errato, estrazione della data non riuscita: "+e.getMessage(),e);
  123.         }
  124.         bustaRisposta.setID(this.bustaBuilder.newID(new IDSoggetto(bustaRisposta.getTipoMittente(), bustaRisposta.getMittente(), bustaRisposta.getIdentificativoPortaMittente()),
  125.                 idSenzaData, RuoloMessaggio.RISPOSTA));
  126.         bustaRisposta.setInoltro(bustaRichiesta.getInoltro(), bustaRichiesta.getInoltroValue());
  127.         bustaRisposta.setCollaborazione(bustaRichiesta.getCollaborazione());
  128.         
  129.         // Se e' presente UNA lista trasmissione la inverto
  130.         if(bustaRichiesta.sizeListaTrasmissioni()==1){
  131.             bustaRisposta.addTrasmissione(bustaRichiesta.getTrasmissione(0).invertiTrasmissione(bustaRichiesta.getTipoOraRegistrazione(), bustaRichiesta.getTipoOraRegistrazioneValue()));
  132.         }
  133.         
  134.         boolean hasFault = false;
  135.         try {
  136.             if(msg!=null && ServiceBinding.SOAP.equals(msg.getServiceBinding())){
  137.                 hasFault = msg.castAsSoap().hasSOAPFault();
  138.             }
  139.         } catch (Exception e) {
  140.             throw new ProtocolException(e); 
  141.         }
  142.         
  143.         /*
  144.          * ONEWAY:
  145.          * Se e' un errore di cooperazione, ovvero isBustaErrore > e' una busta
  146.          * Se non e' un errore di cooperazione, non e' imbustato
  147.          * 
  148.          * SINCRONO:
  149.          * E' sempre imbustato 
  150.          */
  151.         
  152.         if(hasFault) {
  153.             ValidatoreErrori validatoreErrori = new ValidatoreErrori(this.protocolFactory,this.state);
  154.             if(bustaRisposta.getProfiloDiCollaborazione().equals(ProfiloDiCollaborazione.ONEWAY))
  155.                 if(validatoreErrori.isBustaErrore(bustaRichiesta, msg, proprietaValidazioneErrori)) {
  156.                     return new ValidazioneSintatticaResult<BustaRawType>(null, null, null, bustaRisposta, null, null, null, true);
  157.                 }
  158.                 else {
  159.                     return new ValidazioneSintatticaResult<BustaRawType>(null, null, null, null, ErroriCooperazione.ERRORE_GENERICO_PROCESSAMENTO_MESSAGGIO.
  160.                             getErroreProcessamento("Analizzato un messaggio fault"), bustaRisposta, null, false);
  161.                 }
  162.                 
  163.             if(bustaRisposta.getProfiloDiCollaborazione().equals(ProfiloDiCollaborazione.SINCRONO))
  164.                 if(validatoreErrori.isBustaErrore(bustaRichiesta, msg, proprietaValidazioneErrori)) {
  165.                     return new ValidazioneSintatticaResult<BustaRawType>(null, null, null, bustaRisposta, ErroriCooperazione.ERRORE_GENERICO_PROCESSAMENTO_MESSAGGIO.
  166.                             getErroreProcessamento("Analizzato un messaggio fault"), bustaRisposta, null, true);
  167.                 }
  168.                 else {
  169.                     return new ValidazioneSintatticaResult<BustaRawType>(null, null, null, bustaRisposta, null, null, null, true);
  170.                 }
  171.         }
  172.         return new ValidazioneSintatticaResult<BustaRawType>(null, null, null, bustaRisposta, null, null, null, true);
  173.         
  174.     }
  175.     
  176.     @Override
  177.     public boolean verifyProtocolPresence(TipoPdD tipoPdD, ProfiloDiCollaborazione profilo, RuoloMessaggio ruoloMessaggio,
  178.             OpenSPCoop2Message msg) throws ProtocolException{
  179.         if(TipoPdD.DELEGATA.equals(tipoPdD)){
  180.             if(RuoloMessaggio.RICHIESTA.equals(ruoloMessaggio)){
  181.                 return false;
  182.             }else{
  183.                 return !ProfiloDiCollaborazione.ONEWAY.equals(profilo);
  184.             }
  185.         }
  186.         else if(TipoPdD.APPLICATIVA.equals(tipoPdD)){
  187.             if(RuoloMessaggio.RICHIESTA.equals(ruoloMessaggio)){
  188.                 return true;
  189.             }else{
  190.                 return false;
  191.             }
  192.         }
  193.         else if(TipoPdD.ROUTER.equals(tipoPdD)){
  194.             if(RuoloMessaggio.RICHIESTA.equals(ruoloMessaggio)){
  195.                 return true;
  196.             }else{
  197.                 return !ProfiloDiCollaborazione.ONEWAY.equals(profilo);
  198.             }
  199.         }
  200.         else{
  201.             throw new ProtocolException("TipoPdD ["+tipoPdD+"] non gestito");
  202.         }
  203.     }

  205.     @Override
  206.     public ValidazioneSintatticaResult<BustaRawType> validazioneFault(OpenSPCoop2Message msg) {
  207.         return null;
  208.     }

  210.     @Override
  211.     public ValidazioneSintatticaResult<BustaRawType> validazioneManifestAttachments(
  212.             OpenSPCoop2Message msg,
  213.             ProprietaManifestAttachments proprietaManifestAttachments) {
  214.         return null;
  215.     }

  217.     @Override
  218.     public BustaRawContent<BustaRawType> getBustaRawContent_senzaControlli(
  219.             OpenSPCoop2Message msg) throws ProtocolException {
  220.         return null;
  221.     }

  223.     @Override
  224.     public Busta getBusta_senzaControlli(OpenSPCoop2Message msg) throws ProtocolException{
  225.         return null;
  226.     }

  228. }
Created with JaCoCo 0.8.8.202204050719