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

  23. import java.io.ByteArrayOutputStream;
  24. import java.io.File;
  25. import java.util.List;
  26. import java.util.Map;

  28. import org.openspcoop2.core.config.Proprieta;
  29. import org.openspcoop2.core.id.IDPortaApplicativa;
  30. import org.openspcoop2.core.id.IDPortaDelegata;
  31. import org.openspcoop2.message.OpenSPCoop2Message;
  32. import org.openspcoop2.pdd.config.ConfigurazionePdDManager;
  33. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  34. import org.openspcoop2.pdd.core.dynamic.DynamicUtils;
  35. import org.openspcoop2.pdd.core.dynamic.Template;
  36. import org.openspcoop2.pdd.core.trasformazioni.TipoTrasformazione;
  37. import org.openspcoop2.protocol.sdk.Busta;
  38. import org.openspcoop2.protocol.sdk.Context;
  39. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  40. import org.slf4j.Logger;

  42. /**
  43.  * Classe contenenti utilities per le integrazioni gestite tramite template di trasformazione.
  44.  *
  45.  * @author Poli Andrea (apoli@link.it)
  46.  * @author $Author$
  47.  * @version $Rev$, $Date$
  48.  */
  49. public class UtilitiesTemplate {

  51.     private String tipoHeaderIntegrazione;
  52.     private OpenSPCoop2Message msg;
  53.     private Context context;
  54.     private Busta busta;
  55.     private Logger log;
  56.     private TipoTrasformazione tipoTrasformazione;
  57.     private Template template;
  58.     
  59.     public UtilitiesTemplate(String tipoHeaderIntegrazione, HeaderIntegrazione integrazione,
  60.             OutRequestPDMessage inRequestPDMessage, Context context, Logger log) throws HeaderIntegrazioneException {
  61.         try {
  62.             init(tipoHeaderIntegrazione, inRequestPDMessage.getMessage(), context, inRequestPDMessage.getBustaRichiesta(), log);
  63.             
  64.             IDPortaDelegata idPD = null;
  65.             if(inRequestPDMessage.getPortaDelegata()!=null) {
  66.                 idPD = new IDPortaDelegata();
  67.                 idPD.setNome(inRequestPDMessage.getPortaDelegata().getNome());
  68.             }
  69.             
  70.             List<Proprieta> proprieta = null;
  71.             if(inRequestPDMessage.getPortaDelegata()!=null && inRequestPDMessage.getPortaDelegata().getProprietaList()!=null) {
  72.                 proprieta = inRequestPDMessage.getPortaDelegata().getProprietaList();
  73.             }
  74.             init(proprieta, true, true,
  75.                     null, idPD);
  76.             
  77.         }catch(Exception e) {
  78.             throw new HeaderIntegrazioneException(e.getMessage(),e);
  79.         }
  80.     }
  81.     public UtilitiesTemplate(String tipoHeaderIntegrazione, HeaderIntegrazione integrazione,
  82.             OutResponsePDMessage inResponsePDMessage, Context context, Logger log) throws HeaderIntegrazioneException {
  83.         try {
  84.             init(tipoHeaderIntegrazione, inResponsePDMessage.getMessage(), context, inResponsePDMessage.getBustaRichiesta(), log);
  85.             
  86.             IDPortaDelegata idPD = null;
  87.             if(inResponsePDMessage.getPortaDelegata()!=null) {
  88.                 idPD = new IDPortaDelegata();
  89.                 idPD.setNome(inResponsePDMessage.getPortaDelegata().getNome());
  90.             }
  91.             
  92.             List<Proprieta> proprieta = null;
  93.             if(inResponsePDMessage.getPortaDelegata()!=null && inResponsePDMessage.getPortaDelegata().getProprietaList()!=null) {
  94.                 proprieta = inResponsePDMessage.getPortaDelegata().getProprietaList();
  95.             }
  96.             init(proprieta, true, false,
  97.                     null, idPD);
  98.             
  99.         }catch(Exception e) {
  100.             throw new HeaderIntegrazioneException(e.getMessage(),e);
  101.         }
  102.     }
  103.     public UtilitiesTemplate(String tipoHeaderIntegrazione, HeaderIntegrazione integrazione,
  104.             OutRequestPAMessage inRequestPAMessage, Context context, Logger log) throws HeaderIntegrazioneException {
  105.         try {
  106.             init(tipoHeaderIntegrazione, inRequestPAMessage.getMessage(), context, inRequestPAMessage.getBustaRichiesta(), log);
  107.             
  108.             IDPortaApplicativa idPA = null;
  109.             if(inRequestPAMessage.getPortaApplicativa()!=null) {
  110.                 idPA = new IDPortaApplicativa();
  111.                 idPA.setNome(inRequestPAMessage.getPortaApplicativa().getNome());
  112.             }
  113.             
  114.             List<Proprieta> proprieta = null;
  115.             if(inRequestPAMessage.getPortaApplicativa()!=null && inRequestPAMessage.getPortaApplicativa().getProprietaList()!=null) {
  116.                 proprieta = inRequestPAMessage.getPortaApplicativa().getProprietaList();
  117.             }
  118.             init(proprieta, false, true,
  119.                     idPA, null);
  120.             
  121.         }catch(Exception e) {
  122.             throw new HeaderIntegrazioneException(e.getMessage(),e);
  123.         }
  124.     }
  125.     public UtilitiesTemplate(String tipoHeaderIntegrazione, HeaderIntegrazione integrazione,
  126.             OutResponsePAMessage inResponsePAMessage, Context context, Logger log) throws HeaderIntegrazioneException {
  127.         try {
  128.             init(tipoHeaderIntegrazione, inResponsePAMessage.getMessage(), context, inResponsePAMessage.getBustaRichiesta(), log);
  129.             
  130.             IDPortaApplicativa idPA = null;
  131.             if(inResponsePAMessage.getPortaApplicativa()!=null) {
  132.                 idPA = new IDPortaApplicativa();
  133.                 idPA.setNome(inResponsePAMessage.getPortaApplicativa().getNome());
  134.             }
  135.             
  136.             List<Proprieta> proprieta = null;
  137.             if(inResponsePAMessage.getPortaApplicativa()!=null && inResponsePAMessage.getPortaApplicativa().getProprietaList()!=null) {
  138.                 proprieta = inResponsePAMessage.getPortaApplicativa().getProprietaList();
  139.             }
  140.             init(proprieta, false, false,
  141.                     idPA, null);
  142.             
  143.         }catch(Exception e) {
  144.             throw new HeaderIntegrazioneException(e.getMessage(),e);
  145.         }
  146.     }
  147.     
  148.     private void init(String tipoHeaderIntegrazione, OpenSPCoop2Message msg, Context context, Busta busta, Logger log){
  149.         this.tipoHeaderIntegrazione = tipoHeaderIntegrazione;
  150.         this.msg = msg;
  151.         this.context = context;
  152.         this.busta = busta;
  153.         this.log = log;
  154.     }
  155.     private void init(List<Proprieta> proprieta, boolean portaDelegata, boolean request,
  156.             IDPortaApplicativa idPA, IDPortaDelegata idPD) throws HeaderIntegrazioneException {
  157.         try {
  158.             OpenSPCoop2Properties properties = OpenSPCoop2Properties.getInstance();
  159.             TipoTrasformazione tipoTrasformazione = null;
  160.             String file = null;
  161.             if(portaDelegata) {
  162.                 if(request) {
  163.                     tipoTrasformazione = properties.getIntegrazioneTemplatePortaDelegataRequestTipo();
  164.                     file = properties.getIntegrazioneTemplatePortaDelegataRequestFile();
  165.                 }
  166.                 else {
  167.                     tipoTrasformazione = properties.getIntegrazioneTemplatePortaDelegataResponseTipo();
  168.                     file = properties.getIntegrazioneTemplatePortaDelegataResponseFile();
  169.                 }
  170.             }
  171.             else {
  172.                 if(request) {
  173.                     tipoTrasformazione = properties.getIntegrazioneTemplatePortaApplicativaRequestTipo();
  174.                     file = properties.getIntegrazioneTemplatePortaApplicativaRequestFile();
  175.                 }
  176.                 else {
  177.                     tipoTrasformazione = properties.getIntegrazioneTemplatePortaApplicativaResponseTipo();
  178.                     file = properties.getIntegrazioneTemplatePortaApplicativaResponseFile();
  179.                 }
  180.             }
  181.             
  182.             boolean fileDefinedInPorta = false;
  183.             
  184.             if(proprieta!=null && !proprieta.isEmpty()) {
  185.                 
  186.                 String tipoTrasformazionePropertyName = request ? properties.getIntegrazioneTemplateRequestPropertyTipo() : properties.getIntegrazioneTemplateResponsePropertyTipo();
  187.                 String fileTrasformazionePropertyName = request ? properties.getIntegrazioneTemplateRequestPropertyFile() : properties.getIntegrazioneTemplateResponsePropertyFile();
  188.                 
  189.                 for (Proprieta p : proprieta) {
  190.                     if(tipoTrasformazionePropertyName.equalsIgnoreCase(p.getNome())) {
  191.                         tipoTrasformazione = convert(p.getValore());
  192.                     }
  193.                     if(fileTrasformazionePropertyName.equalsIgnoreCase(p.getNome())) {
  194.                         file = p.getValore();
  195.                         fileDefinedInPorta = true;
  196.                     }
  197.                 }
  198.             }

  200.             this.tipoTrasformazione = tipoTrasformazione;
  201.             if(this.tipoTrasformazione==null) {
  202.                 throw new Exception("Tipo del template non definito");
  203.             }
  204.             
  205.             if(file==null) {
  206.                 throw new Exception("Template file non definito");
  207.             }
  208.             File fFile = new File(file);
  209.             /*
  210.             ContentFile cFile = ConfigurazionePdDManager.getInstance().getContentFile(fFile);
  211.             if(!cFile.isExists()) {
  212.                 throw new Exception("Template file '"+fFile.getAbsolutePath()+"' not exists");
  213.             }
  214.             byte [] template = cFile.getContent();
  215.             if(template==null || template.length<=0) {
  216.                 throw new Exception("Template '"+fFile.getAbsolutePath()+"' is empty");
  217.             }
  218.             */
  219.             
  220.             RequestInfo requestInfo = null;
  221.             if(this.context!=null && this.context.containsKey(org.openspcoop2.core.constants.Costanti.REQUEST_INFO)) {
  222.                 requestInfo = (RequestInfo) this.context.getObject(org.openspcoop2.core.constants.Costanti.REQUEST_INFO);
  223.             }
  224.             
  225.             ConfigurazionePdDManager configurazionePdDManager = ConfigurazionePdDManager.getInstance();
  226.             if(fileDefinedInPorta) {
  227.                 if(portaDelegata) {
  228.                     this.template = configurazionePdDManager.getTemplateIntegrazione(idPD, fFile, requestInfo);
  229.                 }
  230.                 else {
  231.                     this.template = configurazionePdDManager.getTemplateIntegrazione(idPA, fFile, requestInfo);
  232.                 }
  233.             }
  234.             else {
  235.                 this.template = configurazionePdDManager.getTemplateIntegrazione(fFile, requestInfo);
  236.             }
  237.             
  238.         }catch(Exception e) {
  239.             throw new HeaderIntegrazioneException(e.getMessage(),e);
  240.         }
  241.     }

  243.     public static TipoTrasformazione convert(String tipo) throws HeaderIntegrazioneException {
  244.         try {
  245.             TipoTrasformazione tipoT = TipoTrasformazione.toEnumConstant(tipo, true);
  246.             if(!tipoT.isTemplateFreemarker() &&
  247.                     !tipoT.isTemplateVelocity()) {
  248.                 throw new Exception("Tipo '"+tipo+"' non supportato");
  249.             }
  250.             return tipoT;
  251.         }catch(Exception e) {
  252.             throw new HeaderIntegrazioneException(e.getMessage(),e);
  253.         }
  254.     }

  256.         
  257.     public void process(boolean request) throws HeaderIntegrazioneException {
  258.         try {
  259.             if(this.msg==null) {
  260.                 return;
  261.             }
  262.             
  263.             boolean bufferMessage_readOnly =  OpenSPCoop2Properties.getInstance().isReadByPathBufferEnabled();
  264.             Map<String, Object> dynamicMapRequest = DynamicUtils.buildDynamicMap(this.msg, this.context, this.busta, this.log,
  265.                     bufferMessage_readOnly);
  266.             Map<String, Object> dynamicMapResponse = null;
  267.             if(!request) {
  268.                 dynamicMapResponse = DynamicUtils.buildDynamicMapResponse(this.msg, this.context, this.busta, this.log,
  269.                         bufferMessage_readOnly,
  270.                         dynamicMapRequest);
  271.             }
  272.             
  273.             Map<String, Object> dynamicMap = request ? dynamicMapRequest : dynamicMapResponse;
  274.             
  275.             if(this.tipoTrasformazione==null) {
  276.                 throw new Exception("Tipo di trasformazione non definita");
  277.             }
  278.             if(this.template==null) {
  279.                 throw new Exception("Template non definito");
  280.             }
  281.             
  282.             switch (this.tipoTrasformazione) {
  283.             case FREEMARKER_TEMPLATE:
  284.             case CONTEXT_FREEMARKER_TEMPLATE:
  285.             case FREEMARKER_TEMPLATE_ZIP:
  286.             
  287.                 this.log.debug("trasformazione '"+this.tipoHeaderIntegrazione+"' ["+this.tipoTrasformazione+"], risoluzione template ...");
  288.                 ByteArrayOutputStream bout = new ByteArrayOutputStream();
  289.                 if(TipoTrasformazione.FREEMARKER_TEMPLATE.equals(this.tipoTrasformazione) || TipoTrasformazione.CONTEXT_FREEMARKER_TEMPLATE.equals(this.tipoTrasformazione)) {
  290.                     DynamicUtils.convertFreeMarkerTemplate(this.template, dynamicMap, bout);
  291.                 }
  292.                 else {
  293.                     DynamicUtils.convertZipFreeMarkerTemplate(this.template.getZipTemplate(), dynamicMap, bout);
  294.                 }
  295.                 bout.flush();
  296.                 bout.close();
  297.                 this.log.debug("trasformazione '"+this.tipoHeaderIntegrazione+"' ["+this.tipoTrasformazione+"], risoluzione template completata");
  298.                 // ignoro il contenuto della trasformazione. Questo handler serve solamente a modificare il messaggio in transito
  299.                 
  300.                 break;
  301.                 
  302.             case VELOCITY_TEMPLATE:
  303.             case CONTEXT_VELOCITY_TEMPLATE:
  304.             case VELOCITY_TEMPLATE_ZIP:

  306.                             
  307.                 this.log.debug("trasformazione '"+this.tipoHeaderIntegrazione+"' ["+this.tipoTrasformazione+"], risoluzione template ...");
  308.                 bout = new ByteArrayOutputStream();
  309.                 if(TipoTrasformazione.VELOCITY_TEMPLATE.equals(this.tipoTrasformazione) || TipoTrasformazione.CONTEXT_VELOCITY_TEMPLATE.equals(this.tipoTrasformazione)) {
  310.                     DynamicUtils.convertVelocityTemplate(this.template, dynamicMap, bout);
  311.                 }
  312.                 else {
  313.                     DynamicUtils.convertZipVelocityTemplate(this.template.getZipTemplate(), dynamicMap, bout);  
  314.                 }
  315.                 bout.flush();
  316.                 bout.close();
  317.                 this.log.debug("trasformazione '"+this.tipoHeaderIntegrazione+"' ["+this.tipoTrasformazione+"], risoluzione template completata");
  318.                 // ignoro il contenuto della trasformazione. Questo handler serve solamente a modificare il messaggio in transito
  319.                 
  320.                 break;

  322.             default:
  323.                 throw new Exception("Trasformazione '"+this.tipoHeaderIntegrazione+"' definita con un tipo '"+this.tipoTrasformazione+"' non supportato");
  324.             }
  325.             
  326.         }catch(Exception e) {
  327.             throw new HeaderIntegrazioneException(e.getMessage(),e);
  328.         }
  329.     }
  330. }
Created with JaCoCo 0.8.8.202204050719