InformazioniUtilizzoOggettoRegistro.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.web.ctrlstat.servlet.utils;

  22. import java.io.ByteArrayOutputStream;
  23. import java.io.IOException;
  24. import java.util.ArrayList;
  25. import java.util.HashMap;
  26. import java.util.List;
  27. import java.util.Map;

  29. import javax.servlet.ServletException;
  30. import javax.servlet.ServletOutputStream;
  31. import javax.servlet.http.HttpServlet;
  32. import javax.servlet.http.HttpServletRequest;
  33. import javax.servlet.http.HttpServletResponse;
  34. import javax.servlet.http.HttpSession;

  36. import org.apache.commons.io.IOUtils;
  37. import org.apache.commons.lang.StringUtils;
  38. import org.openspcoop2.core.commons.CoreException;
  39. import org.openspcoop2.core.config.CanaleConfigurazione;
  40. import org.openspcoop2.core.controllo_traffico.IdPolicy;
  41. import org.openspcoop2.core.id.IDAccordo;
  42. import org.openspcoop2.core.id.IDGenericProperties;
  43. import org.openspcoop2.core.id.IDGruppo;
  44. import org.openspcoop2.core.id.IDPortType;
  45. import org.openspcoop2.core.id.IDPortTypeAzione;
  46. import org.openspcoop2.core.id.IDResource;
  47. import org.openspcoop2.core.id.IDRuolo;
  48. import org.openspcoop2.core.id.IDScope;
  49. import org.openspcoop2.core.id.IDServizio;
  50. import org.openspcoop2.core.id.IDServizioApplicativo;
  51. import org.openspcoop2.core.id.IDSoggetto;
  52. import org.openspcoop2.core.registry.Soggetto;
  53. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  54. import org.openspcoop2.core.plugins.IdPlugin;
  55. import org.openspcoop2.utils.json.JSONUtils;
  56. import org.openspcoop2.utils.transport.http.HttpConstants;
  57. import org.openspcoop2.utils.transport.http.HttpRequestMethod;
  58. import org.openspcoop2.web.ctrlstat.core.ControlStationCore;
  59. import org.openspcoop2.web.ctrlstat.costanti.InUsoType;
  60. import org.openspcoop2.web.ctrlstat.servlet.apc.AccordiServizioParteComuneCore;
  61. import org.openspcoop2.web.ctrlstat.servlet.aps.erogazioni.ErogazioniDetailsUtilities;
  62. import org.openspcoop2.web.ctrlstat.servlet.archivi.ArchiviCore;
  63. import org.openspcoop2.web.ctrlstat.servlet.archivi.ExporterUtils;
  64. import org.openspcoop2.web.ctrlstat.servlet.config.ConfigurazioneCore;
  65. import org.openspcoop2.web.ctrlstat.servlet.gruppi.GruppiCore;
  66. import org.openspcoop2.web.ctrlstat.servlet.ruoli.RuoliCore;
  67. import org.openspcoop2.web.ctrlstat.servlet.sa.ServiziApplicativiCore;
  68. import org.openspcoop2.web.ctrlstat.servlet.scope.ScopeCore;
  69. import org.openspcoop2.web.ctrlstat.servlet.soggetti.SoggettiCore;
  70. import org.openspcoop2.web.lib.mvc.PageData;

  72. /**
  73.  * InformazioniUtilizzoOggettoRegistro
  74.  * 
  75.  * @author Andrea Poli (apoli@link.it)
  76.  * @author $Author$
  77.  * @version $Rev$, $Date$
  78.  *
  79.  */
  80. public class InformazioniUtilizzoOggettoRegistro extends HttpServlet{

  82.     /**
  83.      * 
  84.      */
  85.     private static final long serialVersionUID = 1L;

  87.     @Override
  88.     protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
  89.         this.processRequest(req, resp);
  90.     }

  92.     @Override
  93.     protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {

  95.         ByteArrayOutputStream baos = new ByteArrayOutputStream();
  96.         try {
  97.             IOUtils.copy(req.getInputStream(), baos);
  98.         }catch(Exception e){
  99.             ControlStationCore.logError("Errore durante la ricerca delle informazioni oggetto: "+e.getMessage(), e);
  100.             return;
  101.         }           

  103.         this.processRequest(req, resp);
  104.     }

  106.     private void processRequest(HttpServletRequest request, HttpServletResponse response) {
  107.         try(ByteArrayOutputStream baosPayload = new ByteArrayOutputStream();){
  108.             HttpRequestMethod httpRequestMethod = HttpRequestMethod.valueOf(request.getMethod().toUpperCase()); 

  110.             if(httpRequestMethod.equals(HttpRequestMethod.POST)) { // copia del payload
  111.                 IOUtils.copy(request.getInputStream(), baosPayload);
  112.             }

  114.             HttpSession session = request.getSession(true);
  115.             PageData pd = new PageData();
  116.             UtilsHelper registroHelper = new UtilsHelper(request, pd, session);
  117.             ArchiviCore archiviCore = new ArchiviCore();
  118.             AccordiServizioParteComuneCore apcCore = new AccordiServizioParteComuneCore(archiviCore);
  119.             SoggettiCore soggettiCore = new SoggettiCore(archiviCore);
  120.             ServiziApplicativiCore saCore = new ServiziApplicativiCore(archiviCore);
  121.             RuoliCore ruoliCore = new RuoliCore(archiviCore);
  122.             ScopeCore scopeCore = new ScopeCore(archiviCore);
  123.             ConfigurazioneCore confCore = new ConfigurazioneCore(archiviCore);
  124.             GruppiCore gruppiCore = new GruppiCore(archiviCore);

  126.             String identificativoOggetto = registroHelper.getParameter(UtilsCostanti.PARAMETRO_INFORMAZIONI_UTILIZZO_OGGETTO_ID_OGGETTO); 
  127.             String tipoOggetto = registroHelper.getParameter(UtilsCostanti.PARAMETRO_INFORMAZIONI_UTILIZZO_OGGETTO_TIPO_OGGETTO); 
  128.             String tipoRisposta = registroHelper.getParameter(UtilsCostanti.PARAMETRO_INFORMAZIONI_UTILIZZO_OGGETTO_TIPO_RISPOSTA); 

  130.             InUsoType inUsoType = InUsoType.valueOf(tipoOggetto);
  131.             
  132.             ExporterUtils exporterUtils = new ExporterUtils(archiviCore);
  133.             List<?> identificativi = null; 
  134.             List<String> risultatiRicerca = new ArrayList<>();
  135.             switch (inUsoType) {
  136.             case ACCORDO_SERVIZIO_PARTE_COMUNE:
  137.                 identificativi = exporterUtils.getIdsAccordiServizioParteComune(identificativoOggetto);
  138.                 for (Object object : identificativi) {
  139.                     IDAccordo idAccordo = (IDAccordo)object;
  140.                     risultatiRicerca.add(apcCore.getDettagliAccordoInUso(idAccordo));
  141.                 }
  142.                 break;
  143.             case RISORSA:
  144.                 identificativi = exporterUtils.getIdsAccordiServizioParteComuneRisorsa(identificativoOggetto);
  145.                 for (Object object : identificativi) {
  146.                     IDResource idRisorsa = (IDResource)object;
  147.                     risultatiRicerca.add(apcCore.getDettagliRisorsaInUso(idRisorsa));
  148.                 }
  149.                 break;
  150.             case PORT_TYPE:
  151.                 identificativi = exporterUtils.getIdsAccordiServizioParteComunePortType(identificativoOggetto);
  152.                 for (Object object : identificativi) {
  153.                     IDPortType idPT = (IDPortType)object;
  154.                     risultatiRicerca.add(apcCore.getDettagliPortTypeInUso(idPT));
  155.                 }
  156.                 break;
  157.             case OPERAZIONE:
  158.                 identificativi = exporterUtils.getIdsAccordiServizioParteComuneOperazione(identificativoOggetto);
  159.                 for (Object object : identificativi) {
  160.                     IDPortTypeAzione idOperazione = (IDPortTypeAzione)object;
  161.                     risultatiRicerca.add(apcCore.getDettagliOperazioneInUso(idOperazione));
  162.                 }
  163.                 break;
  164.             case SERVIZIO_APPLICATIVO:
  165.                 identificativi = exporterUtils.getIdsServiziApplicativi(identificativoOggetto);
  166.                 for (Object object : identificativi) {
  167.                     IDServizioApplicativo idServizioApplicativo = (IDServizioApplicativo)object;
  168.                     boolean verificaRuoli = true;
  169.                     risultatiRicerca.add(saCore.getDettagliServizioApplicativoInUso(idServizioApplicativo, verificaRuoli));
  170.                 }
  171.                 break;
  172.             case SOGGETTO:
  173.                 identificativi = exporterUtils.getIdsSoggetti(identificativoOggetto);
  174.                 for (Object object : identificativi) {
  175.                     IDSoggetto idSoggetto = (IDSoggetto)object;
  176.                     Soggetto soggetto = new Soggetto();
  177.                     soggetto.setTipo(idSoggetto.getTipo());
  178.                     soggetto.setNome(idSoggetto.getNome());
  179.                     soggetto.setIdentificativoPorta(idSoggetto.getCodicePorta());
  180.                     boolean verificaRuoli = true;
  181.                     risultatiRicerca.add(soggettiCore.getDettagliSoggettoInUso(soggetto, verificaRuoli));
  182.                 }
  183.                 break;
  184.             case RUOLO:
  185.                 identificativi = exporterUtils.getIdsRuoli(identificativoOggetto);
  186.                 for (Object object : identificativi) {
  187.                     IDRuolo idRuolo = (IDRuolo)object;
  188.                     risultatiRicerca.add(ruoliCore.getDettagliRuoloInUso(idRuolo));
  189.                 }
  190.                 break;
  191.             case SCOPE:
  192.                 identificativi = exporterUtils.getIdsScope(identificativoOggetto);
  193.                 for (Object object : identificativi) {
  194.                     IDScope idScope = (IDScope)object;
  195.                     risultatiRicerca.add(scopeCore.getDettagliScopeInUso(idScope));
  196.                 }
  197.                 break;
  198.             case CANALE:
  199.                 identificativi = exporterUtils.getIdsCanali(identificativoOggetto);
  200.                 for (Object object : identificativi) {
  201.                     CanaleConfigurazione canale = (CanaleConfigurazione)object;
  202.                     risultatiRicerca.add(confCore.getDettagliCanaleInUso(canale));
  203.                 }
  204.                 break;
  205.             case GRUPPO:
  206.                 identificativi = exporterUtils.getIdsGruppi(identificativoOggetto);
  207.                 for (Object object : identificativi) {
  208.                     IDGruppo idGruppo = (IDGruppo)object;
  209.                     risultatiRicerca.add(gruppiCore.getDettagliGruppoInUso(idGruppo));
  210.                 }
  211.                 break;
  212.             case TOKEN_POLICY:
  213.                 identificativi = exporterUtils.getIdsTokenPolicy(identificativoOggetto);
  214.                 for (Object object : identificativi) {
  215.                     IDGenericProperties idGP = (IDGenericProperties)object;
  216.                     risultatiRicerca.add(confCore.getDettagliTokenPolicyInUso(idGP));
  217.                 }
  218.                 break;
  219.             case ATTRIBUTE_AUTHORITY:
  220.                 identificativi = exporterUtils.getIdsAttributeAuthority(identificativoOggetto);
  221.                 for (Object object : identificativi) {
  222.                     IDGenericProperties idGP = (IDGenericProperties)object;
  223.                     risultatiRicerca.add(confCore.getDettagliTokenPolicyInUso(idGP));
  224.                 }
  225.                 break;
  226.             case RATE_LIMITING_POLICY:
  227.                 identificativi = exporterUtils.getIdsControlloTrafficoConfigPolicy(identificativoOggetto);
  228.                 for (Object object : identificativi) {
  229.                     IdPolicy idRP = (IdPolicy)object;
  230.                     risultatiRicerca.add(confCore.getDettagliRateLimitingPolicyInUso(idRP));
  231.                 }
  232.                 break;
  233.             case PLUGIN_CLASSE:
  234.                 identificativi = exporterUtils.getIdsPluginClassi(identificativoOggetto);
  235.                 for (Object object : identificativi) {
  236.                     IdPlugin idPlugin = (IdPlugin)object;
  237.                     risultatiRicerca.add(confCore.getDettagliPluginClasseInUso(idPlugin));
  238.                 }
  239.                 break;
  240.             case EROGAZIONE_INFO:{
  241.                 String uriAPSerogata = identificativoOggetto;
  242.                 IDServizio idServizio = IDServizioFactory.getInstance().getIDServizioFromUri(uriAPSerogata);
  243.                 risultatiRicerca.add(ErogazioniDetailsUtilities.getDetailsErogazione(idServizio, soggettiCore, registroHelper));
  244.                 break;
  245.             }
  246.             case FRUIZIONE_INFO:{
  247.                 String uriAPSfruita = identificativoOggetto;
  248.                 if(uriAPSfruita.contains("@")) {
  249.                     String tipoNomeFruitore = uriAPSfruita.split("@")[1];
  250.                     uriAPSfruita = uriAPSfruita.split("@")[0];
  251.                     IDSoggetto idSoggettoFruitore = new IDSoggetto(tipoNomeFruitore.split("/")[0], tipoNomeFruitore.split("/")[1]);
  252.                     IDServizio idServizio = IDServizioFactory.getInstance().getIDServizioFromUri(uriAPSfruita);
  253.                     risultatiRicerca.add(ErogazioniDetailsUtilities.getDetailsFruizione(idServizio, idSoggettoFruitore, soggettiCore, registroHelper));
  254.                 }
  255.                 else {
  256.                     risultatiRicerca.add("Internal Error: informazione fruitore non presente");
  257.                 }
  258.                 break;
  259.             }
  260.             case ACCORDO_COOPERAZIONE:
  261.             case ACCORDO_SERVIZIO_COMPOSTO:
  262.             case ACCORDO_SERVIZIO_PARTE_SPECIFICA:
  263.             case EROGAZIONE:
  264.             case FRUITORE:
  265.             case FRUIZIONE:
  266.             case PDD:
  267.             case PORTA_APPLICATIVA:
  268.             case PORTA_DELEGATA:
  269.                 throw new CoreException("TipoOggetto non gestito.");
  270.             }

  272.             ServletOutputStream outputStream = response.getOutputStream();
  273.             
  274.             if(tipoRisposta.equalsIgnoreCase(UtilsCostanti.VALUE_PARAMETRO_INFORMAZIONI_UTILIZZO_OGGETTO_TIPO_RISPOSTA_JSON)) {
  275.                 response.setContentType(HttpConstants.CONTENT_TYPE_JSON);
  276.                 JSONUtils jsonUtils = JSONUtils.getInstance(true);
  277.                 Map<String, Object> mapResult = new HashMap<>();
  278.                 mapResult.put(UtilsCostanti.KEY_JSON_RISPOSTA_USO, risultatiRicerca);
  279.                 jsonUtils.writeTo(mapResult, outputStream);
  280.             } else if(tipoRisposta.equalsIgnoreCase(UtilsCostanti.VALUE_PARAMETRO_INFORMAZIONI_UTILIZZO_OGGETTO_TIPO_RISPOSTA_TEXT)) {
  281.                 response.setContentType(HttpConstants.CONTENT_TYPE_PLAIN);
  282.                 outputStream.write(StringUtils.join(risultatiRicerca.toArray(new String[1])).getBytes());
  283.             } else {
  284.                 throw new CoreException("TipoRiposta non gestito.");
  285.             }
  286.             

  288.         }catch(Exception e){
  289.             ControlStationCore.logError("Errore durante la ricerca delle informazioni oggetto: "+e.getMessage(), e);
  290.         }
  291.     }
  292. }
Created with JaCoCo 0.8.8.202204050719