ProprietaOggettoRegistro.java
- /*
- * GovWay - A customizable API Gateway
- * https://govway.org
- *
- * Copyright (c) 2005-2025 Link.it srl (https://link.it).
- *
- * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU General Public License version 3, as published by
- * the Free Software Foundation.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program. If not, see <http://www.gnu.org/licenses/>.
- *
- */
- package org.openspcoop2.web.ctrlstat.servlet.utils;
- import java.io.ByteArrayOutputStream;
- import java.io.IOException;
- import java.util.ArrayList;
- import java.util.Date;
- import java.util.HashMap;
- import java.util.List;
- import java.util.Map;
- import javax.servlet.ServletException;
- import javax.servlet.ServletOutputStream;
- import javax.servlet.http.HttpServlet;
- import javax.servlet.http.HttpServletRequest;
- import javax.servlet.http.HttpServletResponse;
- import javax.servlet.http.HttpSession;
- import org.apache.commons.io.IOUtils;
- import org.apache.commons.lang.StringUtils;
- import org.openspcoop2.core.commons.CoreException;
- import org.openspcoop2.core.config.GenericProperties;
- import org.openspcoop2.core.config.PortaApplicativa;
- import org.openspcoop2.core.config.PortaApplicativaServizioApplicativo;
- import org.openspcoop2.core.config.PortaDelegata;
- import org.openspcoop2.core.config.ServizioApplicativo;
- import org.openspcoop2.core.id.IDAccordo;
- import org.openspcoop2.core.id.IDGenericProperties;
- import org.openspcoop2.core.id.IDGruppo;
- import org.openspcoop2.core.id.IDPortaApplicativa;
- import org.openspcoop2.core.id.IDPortaDelegata;
- import org.openspcoop2.core.id.IDRuolo;
- import org.openspcoop2.core.id.IDScope;
- import org.openspcoop2.core.id.IDServizio;
- import org.openspcoop2.core.id.IDServizioApplicativo;
- import org.openspcoop2.core.id.IDSoggetto;
- import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
- import org.openspcoop2.core.registry.Fruitore;
- import org.openspcoop2.core.registry.Gruppo;
- import org.openspcoop2.core.registry.ProprietaOggetto;
- import org.openspcoop2.core.registry.Ruolo;
- import org.openspcoop2.core.registry.Scope;
- import org.openspcoop2.core.registry.Soggetto;
- import org.openspcoop2.core.registry.beans.AccordoServizioParteComuneSintetico;
- import org.openspcoop2.core.registry.driver.IDServizioFactory;
- import org.openspcoop2.utils.json.JSONUtils;
- import org.openspcoop2.utils.transport.http.HttpConstants;
- import org.openspcoop2.utils.transport.http.HttpRequestMethod;
- import org.openspcoop2.web.ctrlstat.core.ControlStationCore;
- import org.openspcoop2.web.ctrlstat.costanti.CostantiControlStation;
- import org.openspcoop2.web.ctrlstat.costanti.InUsoType;
- import org.openspcoop2.web.ctrlstat.servlet.ConsoleHelper;
- import org.openspcoop2.web.ctrlstat.servlet.apc.AccordiServizioParteComuneCore;
- import org.openspcoop2.web.ctrlstat.servlet.aps.AccordiServizioParteSpecificaCore;
- import org.openspcoop2.web.ctrlstat.servlet.archivi.ArchiviCore;
- import org.openspcoop2.web.ctrlstat.servlet.archivi.ExporterUtils;
- import org.openspcoop2.web.ctrlstat.servlet.config.ConfigurazioneCore;
- import org.openspcoop2.web.ctrlstat.servlet.gruppi.GruppiCore;
- import org.openspcoop2.web.ctrlstat.servlet.pa.PorteApplicativeCore;
- import org.openspcoop2.web.ctrlstat.servlet.pd.PorteDelegateCore;
- import org.openspcoop2.web.ctrlstat.servlet.ruoli.RuoliCore;
- import org.openspcoop2.web.ctrlstat.servlet.sa.ServiziApplicativiCore;
- import org.openspcoop2.web.ctrlstat.servlet.sa.ServiziApplicativiCostanti;
- import org.openspcoop2.web.ctrlstat.servlet.scope.ScopeCore;
- import org.openspcoop2.web.ctrlstat.servlet.soggetti.SoggettiCore;
- import org.openspcoop2.web.lib.mvc.PageData;
- /**
- * InformazioniUtilizzoOggettoRegistro
- *
- * @author Andrea Poli (apoli@link.it)
- * @author $Author$
- * @version $Rev$, $Date$
- *
- */
- public class ProprietaOggettoRegistro extends HttpServlet{
- /**
- *
- */
- private static final long serialVersionUID = 1L;
- @Override
- protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
- this.processRequest(req, resp);
- }
- @Override
- protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
- ByteArrayOutputStream baos = new ByteArrayOutputStream();
- try {
- IOUtils.copy(req.getInputStream(), baos);
- }catch(Exception e){
- ControlStationCore.logError("Errore durante la ricerca delle informazioni oggetto: "+e.getMessage(), e);
- return;
- }
- this.processRequest(req, resp);
- }
- private void processRequest(HttpServletRequest request, HttpServletResponse response) {
- try(ByteArrayOutputStream baosPayload = new ByteArrayOutputStream();){
- HttpRequestMethod httpRequestMethod = HttpRequestMethod.valueOf(request.getMethod().toUpperCase());
- if(httpRequestMethod.equals(HttpRequestMethod.POST)) { // copia del payload
- IOUtils.copy(request.getInputStream(), baosPayload);
- }
- HttpSession session = request.getSession(true);
- PageData pd = new PageData();
- UtilsHelper registroHelper = new UtilsHelper(request, pd, session);
- ArchiviCore archiviCore = new ArchiviCore();
- AccordiServizioParteComuneCore apcCore = new AccordiServizioParteComuneCore(archiviCore);
- AccordiServizioParteSpecificaCore apsCore = new AccordiServizioParteSpecificaCore(archiviCore);
- SoggettiCore soggettiCore = new SoggettiCore(archiviCore);
- ServiziApplicativiCore saCore = new ServiziApplicativiCore(archiviCore);
- RuoliCore ruoliCore = new RuoliCore(archiviCore);
- ScopeCore scopeCore = new ScopeCore(archiviCore);
- ConfigurazioneCore confCore = new ConfigurazioneCore(archiviCore);
- GruppiCore gruppiCore = new GruppiCore(archiviCore);
- PorteApplicativeCore paCore = new PorteApplicativeCore(archiviCore);
- PorteDelegateCore pdCore = new PorteDelegateCore(archiviCore);
- String identificativoOggetto = registroHelper.getParameter(UtilsCostanti.PARAMETRO_PROPRIETA_OGGETTO_ID_OGGETTO);
- String tipoOggetto = registroHelper.getParameter(UtilsCostanti.PARAMETRO_PROPRIETA_OGGETTO_TIPO_OGGETTO);
- String tipoRisposta = registroHelper.getParameter(UtilsCostanti.PARAMETRO_PROPRIETA_OGGETTO_TIPO_RISPOSTA);
- InUsoType inUsoType = InUsoType.valueOf(tipoOggetto);
-
- ExporterUtils exporterUtils = new ExporterUtils(archiviCore);
- List<?> identificativi = null;
- List<String> risultatiRicerca = new ArrayList<>();
- switch (inUsoType) {
- case ACCORDO_SERVIZIO_PARTE_COMUNE:
- identificativi = exporterUtils.getIdsAccordiServizioParteComune(identificativoOggetto);
- for (Object object : identificativi) {
- IDAccordo idAccordo = (IDAccordo)object;
- AccordoServizioParteComuneSintetico as = apcCore.getAccordoServizioSintetico(idAccordo);
- risultatiRicerca.add(this.getProprieta(as.getProprietaOggetto(), as.getDescrizione()));
- }
- break;
- case SERVIZIO_APPLICATIVO:
- identificativi = exporterUtils.getIdsServiziApplicativi(identificativoOggetto);
- for (Object object : identificativi) {
- IDServizioApplicativo idServizioApplicativo = (IDServizioApplicativo)object;
- ServizioApplicativo sa = saCore.getServizioApplicativo(idServizioApplicativo);
- risultatiRicerca.add(this.getProprieta(sa.getProprietaOggetto(), sa.getDescrizione()));
- }
- break;
- case SOGGETTO:
- identificativi = exporterUtils.getIdsSoggetti(identificativoOggetto);
- for (Object object : identificativi) {
- IDSoggetto idSoggetto = (IDSoggetto)object;
- Soggetto soggetto = soggettiCore.getSoggettoRegistro(idSoggetto);
- risultatiRicerca.add(this.getProprieta(soggetto.getProprietaOggetto(), soggetto.getDescrizione()));
- }
- break;
- case RUOLO:
- identificativi = exporterUtils.getIdsRuoli(identificativoOggetto);
- for (Object object : identificativi) {
- IDRuolo idRuolo = (IDRuolo)object;
- Ruolo ruolo = ruoliCore.getRuolo(idRuolo.getNome());
- risultatiRicerca.add(this.getProprieta(ruolo.getProprietaOggetto(), ruolo.getDescrizione()));
- }
- break;
- case SCOPE:
- identificativi = exporterUtils.getIdsScope(identificativoOggetto);
- for (Object object : identificativi) {
- IDScope idScope = (IDScope)object;
- Scope scope = scopeCore.getScope(idScope.getNome());
- risultatiRicerca.add(this.getProprieta(scope.getProprietaOggetto(), scope.getDescrizione()));
- }
- break;
- case GRUPPO:
- identificativi = exporterUtils.getIdsGruppi(identificativoOggetto);
- for (Object object : identificativi) {
- IDGruppo idGruppo = (IDGruppo)object;
- Gruppo gruppo = gruppiCore.getGruppo(idGruppo.getNome());
- risultatiRicerca.add(this.getProprieta(gruppo.getProprietaOggetto(), gruppo.getDescrizione()));
- }
- break;
- case TOKEN_POLICY:
- identificativi = exporterUtils.getIdsTokenPolicy(identificativoOggetto);
- for (Object object : identificativi) {
- IDGenericProperties idGP = (IDGenericProperties)object;
- GenericProperties gp = confCore.getGenericProperties(idGP.getNome(), idGP.getTipologia(), false);
- risultatiRicerca.add(this.getProprieta(gp.getProprietaOggetto(), gp.getDescrizione()));
- }
- break;
- case ATTRIBUTE_AUTHORITY:
- identificativi = exporterUtils.getIdsAttributeAuthority(identificativoOggetto);
- for (Object object : identificativi) {
- IDGenericProperties idGP = (IDGenericProperties)object;
- GenericProperties gp = confCore.getGenericProperties(idGP.getNome(), idGP.getTipologia(), false);
- risultatiRicerca.add(this.getProprieta(gp.getProprietaOggetto(), gp.getDescrizione()));
- }
- break;
- case EROGAZIONE:{
- String uriAPSerogata = identificativoOggetto;
- IDServizio idServizio = IDServizioFactory.getInstance().getIDServizioFromUri(uriAPSerogata);
- AccordoServizioParteSpecifica as = apsCore.getAccordoServizioParteSpecifica(idServizio);
- ProprietaOggetto p = as.getProprietaOggetto();
- p = mergeProprietaOggetto(p, idServizio, paCore, saCore, registroHelper);
- risultatiRicerca.add(this.getProprieta(p, as.getDescrizione()));
- break;
- }
- case FRUIZIONE:{
- String uriAPSfruita = identificativoOggetto;
- if(uriAPSfruita.contains("@")) {
- String tipoNomeFruitore = uriAPSfruita.split("@")[1];
- uriAPSfruita = uriAPSfruita.split("@")[0];
- IDSoggetto idSoggettoFruitore = new IDSoggetto(tipoNomeFruitore.split("/")[0], tipoNomeFruitore.split("/")[1]);
- IDServizio idServizio = IDServizioFactory.getInstance().getIDServizioFromUri(uriAPSfruita);
- AccordoServizioParteSpecifica as = apsCore.getAccordoServizioParteSpecifica(idServizio);
- for (Fruitore fruitore : as.getFruitoreList()) {
- if(idSoggettoFruitore.getTipo().equals(fruitore.getTipo()) && idSoggettoFruitore.getNome().equals(fruitore.getNome())) {
- ProprietaOggetto p = fruitore.getProprietaOggetto();
- p = mergeProprietaOggetto(p, idServizio, idSoggettoFruitore, pdCore, registroHelper);
- risultatiRicerca.add(this.getProprieta(p,fruitore.getDescrizione()));
- break;
- }
- }
- }
- else {
- risultatiRicerca.add("Internal Error: informazione fruitore non presente");
- }
- break;
- }
- case RISORSA:
- case PORT_TYPE:
- case OPERAZIONE:
- case CANALE:
- case ACCORDO_COOPERAZIONE:
- case ACCORDO_SERVIZIO_COMPOSTO:
- case ACCORDO_SERVIZIO_PARTE_SPECIFICA:
- case EROGAZIONE_INFO:
- case FRUITORE:
- case FRUIZIONE_INFO:
- case PDD:
- case PORTA_APPLICATIVA:
- case PORTA_DELEGATA:
- case RATE_LIMITING_POLICY:
- case PLUGIN_CLASSE:
- throw new CoreException("TipoOggetto non gestito.");
- }
- ServletOutputStream outputStream = response.getOutputStream();
-
- if(tipoRisposta.equalsIgnoreCase(UtilsCostanti.VALUE_PARAMETRO_PROPRIETA_OGGETTO_TIPO_RISPOSTA_JSON)) {
- response.setContentType(HttpConstants.CONTENT_TYPE_JSON);
- JSONUtils jsonUtils = JSONUtils.getInstance(true);
- Map<String, Object> mapResult = new HashMap<>();
- mapResult.put(UtilsCostanti.KEY_JSON_RISPOSTA_USO, risultatiRicerca);
- jsonUtils.writeTo(mapResult, outputStream);
- } else if(tipoRisposta.equalsIgnoreCase(UtilsCostanti.VALUE_PARAMETRO_PROPRIETA_OGGETTO_TIPO_RISPOSTA_TEXT)) {
- response.setContentType(HttpConstants.CONTENT_TYPE_PLAIN);
- outputStream.write(StringUtils.join(risultatiRicerca.toArray(new String[1])).getBytes());
- } else {
- throw new CoreException("TipoRiposta non gestito.");
- }
-
- }catch(Exception e){
- ControlStationCore.logError("Errore durante la ricerca delle informazioni oggetto: "+e.getMessage(), e);
- }
- }
-
- public static ProprietaOggetto mergeProprietaOggetto(ProprietaOggetto p, IDServizio idServizio, PorteApplicativeCore paCore, ServiziApplicativiCore saCore,
- ConsoleHelper consoleHelper) {
- /** Devo considerare tutte le porte */
- List<IDPortaApplicativa> listPA = getIDPorteApplicativeAssociateSafe(paCore, idServizio);
- if(listPA!=null && !listPA.isEmpty()) {
- for (IDPortaApplicativa idPA : listPA) {
- if(idPA!=null) {
- PortaApplicativa pa = getPASafe(paCore, idPA);
- if(pa!=null) {
- p = mergeProprietaOggetto(p, idServizio, pa, saCore, consoleHelper);
- }
- }
- }
- }
- return p;
- }
- private static ProprietaOggetto mergeProprietaOggetto(ProprietaOggetto p, IDServizio idServizio, PortaApplicativa pa, ServiziApplicativiCore saCore,
- ConsoleHelper consoleHelper) {
- if(pa!=null) {
- boolean consideraDataCreazioneComeDataModifica = true;
- p = consoleHelper.mergeProprietaOggetto(p, pa.getProprietaOggetto(), consideraDataCreazioneComeDataModifica);
- if(pa.sizeServizioApplicativoList()>0) {
- for (PortaApplicativaServizioApplicativo pasa : pa.getServizioApplicativoList()) {
- IDServizioApplicativo idSA = new IDServizioApplicativo();
- idSA.setIdSoggettoProprietario(idServizio.getSoggettoErogatore());
- idSA.setNome(pasa.getNome());
- ServizioApplicativo sa = getSASafe(saCore, idSA);
- if(sa!=null && !ServiziApplicativiCostanti.VALUE_SERVIZI_APPLICATIVI_TIPO_SERVER.equals(sa.getTipo())) {
- p = consoleHelper.mergeProprietaOggetto(p, sa.getProprietaOggetto(), !consideraDataCreazioneComeDataModifica);
- }
- }
- }
- }
- return p;
- }
-
- public static ProprietaOggetto mergeProprietaOggetto(ProprietaOggetto p, IDServizio idServizio, IDSoggetto idSoggettoFruitore, PorteDelegateCore pdCore,
- ConsoleHelper consoleHelper) {
- /** Devo considerare tutte le porte */
- List<IDPortaDelegata> listPD = getIDPorteDelegateAssociateSafe(pdCore, idServizio, idSoggettoFruitore);
- if(listPD!=null && !listPD.isEmpty()) {
- for (IDPortaDelegata idPD : listPD) {
- if(idPD!=null) {
- PortaDelegata pd = getPDSafe(pdCore, idPD);
- if(pd!=null) {
- p = mergeProprietaOggetto(p, idServizio, idSoggettoFruitore, pd, consoleHelper);
- }
- }
- }
- }
- return p;
- }
- private static ProprietaOggetto mergeProprietaOggetto(ProprietaOggetto p, IDServizio idServizio, IDSoggetto idSoggettoFruitore, PortaDelegata pd,
- ConsoleHelper consoleHelper) {
- if(idServizio!=null && idSoggettoFruitore!=null) {
- // lascio i parametri per eventuali altri merge
- }
- if(pd!=null) {
- boolean consideraDataCreazioneComeDataModifica = true;
- p = consoleHelper.mergeProprietaOggetto(p, pd.getProprietaOggetto(), consideraDataCreazioneComeDataModifica);
- }
- return p;
- }
-
- private static List<IDPortaApplicativa> getIDPorteApplicativeAssociateSafe(PorteApplicativeCore paCore, IDServizio idServizio) {
- List<IDPortaApplicativa> l = null;
- try {
- l = paCore.getIDPorteApplicativeAssociate(idServizio);
- }catch(Exception e){
- ControlStationCore.logError("Errore durante il recupero delle porte applicative associate al servizio '"+idServizio+"': "+e.getMessage(), e);
- }
- return l;
- }
- private static List<IDPortaDelegata> getIDPorteDelegateAssociateSafe(PorteDelegateCore pdCore, IDServizio idServizio, IDSoggetto idFruitore) {
- List<IDPortaDelegata> l = null;
- try {
- l = pdCore.getIDPorteDelegateAssociate(idServizio, idFruitore);
- }catch(Exception e){
- ControlStationCore.logError("Errore durante il recupero delle porte delegate associate al servizio '"+idServizio+"': "+e.getMessage(), e);
- }
- return l;
- }
- private static PortaApplicativa getPASafe(PorteApplicativeCore paCore, IDPortaApplicativa idPA) {
- try {
- return paCore.getPortaApplicativa(idPA);
- }catch(Exception e){
- ControlStationCore.logError("Errore durante il recupero della porta applicativa '"+idPA+"': "+e.getMessage(), e);
- }
- return null;
- }
- private static PortaDelegata getPDSafe(PorteDelegateCore pdCore, IDPortaDelegata idPD) {
- try {
- return pdCore.getPortaDelegata(idPD);
- }catch(Exception e){
- ControlStationCore.logError("Errore durante il recupero della porta delegata '"+idPD+"': "+e.getMessage(), e);
- }
- return null;
- }
- private static ServizioApplicativo getSASafe(ServiziApplicativiCore saCore, IDServizioApplicativo idSA) {
- try {
- return saCore.getServizioApplicativo(idSA);
- }catch(Exception e){
- ControlStationCore.logError("Errore durante il recupero dell'applicativo '"+idSA+"': "+e.getMessage(), e);
- }
- return null;
- }
- public static org.openspcoop2.core.config.ProprietaOggetto getProprietaOggettoSafe(PorteApplicativeCore paCore, IDPortaApplicativa idPA) {
- try {
- return paCore.getProprietaOggetto(idPA);
- }catch(Exception e){
- ControlStationCore.logError("Errore durante il recupero della porta applicativa '"+idPA+"': "+e.getMessage(), e);
- }
- return null;
- }
- public static org.openspcoop2.core.config.ProprietaOggetto getProprietaOggettoSafe(PorteDelegateCore pdCore, IDPortaDelegata idPD) {
- try {
- return pdCore.getProprietaOggetto(idPD);
- }catch(Exception e){
- ControlStationCore.logError("Errore durante il recupero della porta delegata '"+idPD+"': "+e.getMessage(), e);
- }
- return null;
- }
- public static org.openspcoop2.core.config.ProprietaOggetto getProprietaOggettoSafe(ServiziApplicativiCore saCore, IDServizioApplicativo idSA) {
- try {
- return saCore.getProprietaOggetto(idSA);
- }catch(Exception e){
- ControlStationCore.logError("Errore durante il recupero dell'applicativo '"+idSA+"': "+e.getMessage(), e);
- }
- return null;
- }
-
- private String getProprieta(org.openspcoop2.core.registry.beans.ProprietaOggettoSintetico p,
- String descrizione) {
- return getProprieta(p!=null ? p.getUtenteRichiedente() : null,
- p!=null ? p.getDataCreazione() : null,
- p!=null ? p.getUtenteUltimaModifica() : null,
- p!=null ? p.getDataUltimaModifica() : null,
- descrizione);
- }
- private String getProprieta(org.openspcoop2.core.registry.ProprietaOggetto p,
- String descrizione) {
- return getProprieta(p!=null ? p.getUtenteRichiedente() : null,
- p!=null ? p.getDataCreazione() : null,
- p!=null ? p.getUtenteUltimaModifica() : null,
- p!=null ? p.getDataUltimaModifica() : null,
- descrizione);
- }
- private String getProprieta(org.openspcoop2.core.config.ProprietaOggetto p,
- String descrizione) {
- return getProprieta(p!=null ? p.getUtenteRichiedente() : null,
- p!=null ? p.getDataCreazione() : null,
- p!=null ? p.getUtenteUltimaModifica() : null,
- p!=null ? p.getDataUltimaModifica() : null,
- descrizione);
- }
- private String getProprieta(String utenteRichiedente, Date dataCreazione,
- String utenteUtimaModifica, Date dataUtimaModifica,
- String descrizione) {
- StringBuilder sb = new StringBuilder();
- if(dataCreazione!=null) {
- String dataMs = CostantiControlStation.formatDateMs(dataCreazione);
- sb.append(CostantiControlStation.LABEL_DATA_CREAZIONE).append(": ").append(dataMs);
- }
- if(utenteRichiedente!=null) {
- if(sb.length()>0) {
- sb.append("\n");
- }
- sb.append(CostantiControlStation.LABEL_UTENTE_RICHIEDENTE).append(": ").append(utenteRichiedente);
- }
- if(dataUtimaModifica!=null) {
- String dataMs = CostantiControlStation.formatDateMs(dataUtimaModifica);
- if(sb.length()>0) {
- sb.append("\n\n");
- }
- sb.append(CostantiControlStation.LABEL_DATA_ULTIMA_MODIFICA).append(": ").append(dataMs);
- }
- if(utenteUtimaModifica!=null) {
- if(sb.length()>0) {
- sb.append("\n");
- }
- sb.append(CostantiControlStation.LABEL_UTENTE_ULTIMA_MODIFICA).append(": ").append(utenteUtimaModifica);
- }
-
- if(descrizione!=null && StringUtils.isNotEmpty(descrizione)) {
- if(sb.length()>0) {
- sb.append("\n\n");
- }
- sb.append(CostantiControlStation.LABEL_PROPRIETA_DESCRIZIONE).append(": \n");
- sb.append(descrizione);
- }
-
- if(sb.length()<=0) {
- sb.append("Nessuna proprietà disponibile");
- }
- return sb.toString();
- }
- }