MonitoraggioApiServiceImpl.java
/*
* GovWay - A customizable API Gateway
* https://govway.org
*
* Copyright (c) 2005-2024 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.core.monitor.rs.server.api.impl;
import java.sql.Connection;
import java.util.List;
import java.util.UUID;
import org.apache.commons.lang3.BooleanUtils;
import org.joda.time.DateTime;
import org.openspcoop2.core.monitor.rs.server.api.MonitoraggioApi;
import org.openspcoop2.core.monitor.rs.server.api.impl.utils.Converter;
import org.openspcoop2.core.monitor.rs.server.api.impl.utils.Enums;
import org.openspcoop2.core.monitor.rs.server.api.impl.utils.MonitoraggioEnv;
import org.openspcoop2.core.monitor.rs.server.api.impl.utils.ReportisticaHelper;
import org.openspcoop2.core.monitor.rs.server.api.impl.utils.SearchFormUtilities;
import org.openspcoop2.core.monitor.rs.server.api.impl.utils.TransazioniHelper;
import org.openspcoop2.core.monitor.rs.server.config.DBManager;
import org.openspcoop2.core.monitor.rs.server.config.LoggerProperties;
import org.openspcoop2.core.monitor.rs.server.config.ServerProperties;
import org.openspcoop2.core.monitor.rs.server.model.DetailTransazione;
import org.openspcoop2.core.monitor.rs.server.model.EsitoTransazioneFullSearchEnum;
import org.openspcoop2.core.monitor.rs.server.model.EsitoTransazioneSimpleSearchEnum;
import org.openspcoop2.core.monitor.rs.server.model.Evento;
import org.openspcoop2.core.monitor.rs.server.model.FiltroEsito;
import org.openspcoop2.core.monitor.rs.server.model.FiltroRicercaRuoloTransazioneEnum;
import org.openspcoop2.core.monitor.rs.server.model.FiltroTemporale;
import org.openspcoop2.core.monitor.rs.server.model.ListaEventi;
import org.openspcoop2.core.monitor.rs.server.model.ListaTransazioni;
import org.openspcoop2.core.monitor.rs.server.model.RicercaIdApplicativo;
import org.openspcoop2.core.monitor.rs.server.model.RicercaIntervalloTemporale;
import org.openspcoop2.core.monitor.rs.server.model.TipoIdApplicativoEnum;
import org.openspcoop2.core.monitor.rs.server.model.TipoMessaggioEnum;
import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
import org.openspcoop2.utils.service.BaseImpl;
import org.openspcoop2.utils.service.authorization.AuthorizationConfig;
import org.openspcoop2.utils.service.authorization.AuthorizationManager;
import org.openspcoop2.utils.service.beans.DiagnosticoSeveritaEnum;
import org.openspcoop2.utils.service.beans.FiltroRicercaId;
import org.openspcoop2.utils.service.beans.ProfiloEnum;
import org.openspcoop2.utils.service.beans.utils.BaseHelper;
import org.openspcoop2.utils.service.beans.utils.ListaUtils;
import org.openspcoop2.utils.service.context.IContext;
import org.openspcoop2.utils.service.fault.jaxrs.FaultCode;
import org.openspcoop2.web.monitor.core.constants.CaseSensitiveMatch;
import org.openspcoop2.web.monitor.core.constants.TipoMatch;
import org.openspcoop2.web.monitor.eventi.bean.EventiSearchForm;
import org.openspcoop2.web.monitor.eventi.bean.EventoBean;
import org.openspcoop2.web.monitor.eventi.dao.EventiService;
import org.openspcoop2.web.monitor.transazioni.bean.TransazioneBean;
import org.openspcoop2.web.monitor.transazioni.bean.TransazioniSearchForm;
import org.openspcoop2.web.monitor.transazioni.dao.TransazioniService;
/**
* MonitoraggioApiServiceImpl
*
* @author $Author$
* @version $Rev$, $Date$
*/
public class MonitoraggioApiServiceImpl extends BaseImpl implements MonitoraggioApi {
public MonitoraggioApiServiceImpl(){
super(org.slf4j.LoggerFactory.getLogger(MonitoraggioApiServiceImpl.class));
}
private AuthorizationConfig getAuthorizationConfig() throws Exception{
return new AuthorizationConfig(ServerProperties.getInstance().getProperties());
}
/**
* Ricerca di Eventi
*
* Questa operazione consente di effettuare una ricerca nell'archivio degli eventi specificando i criteri di filtraggio
*
*/
@Override
public ListaEventi findAllEventi(DateTime dataInizio, DateTime dataFine, Integer offset, Integer limit, DiagnosticoSeveritaEnum severita, String tipo, String codice, String origine, Boolean ricercaEsatta, Boolean caseSensitive) {
IContext context = this.getContext();
try {
context.getLogger().info("Invocazione in corso ...");
AuthorizationManager.authorize(context, getAuthorizationConfig());
context.getLogger().debug("Autorizzazione completata con successo");
DBManager dbManager = DBManager.getInstance();
Connection connection = null;
try {
connection = dbManager.getConnectionTracce();
ServiceManagerProperties smp = dbManager.getServiceManagerPropertiesTracce();
EventiService eventiService = new EventiService(connection, true, smp, LoggerProperties.getLoggerDAO());
ServerProperties serverProperties = ServerProperties.getInstance();
SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
EventiSearchForm search = searchFormUtilities.getEventiSearchForm(context, dataInizio, dataFine);
search.setCodice(codice);
search.setTipo(tipo);
search.setSeverita(BaseHelper.evalnull( () -> Enums.toTipoSeverita.get(severita).toString()));
search.setCaseSensitiveType( (BooleanUtils.isTrue(caseSensitive) ? CaseSensitiveMatch.SENSITIVE : CaseSensitiveMatch.INSENSITIVE).toString() );
search.setMatchingType( (BooleanUtils.isTrue(ricercaEsatta) ? TipoMatch.EQUALS : TipoMatch.LIKE ).toString());
search.setIdConfigurazione(origine);
eventiService.setSearch(search);
List<EventoBean> listEventiDB = eventiService.findAll(Converter.toOffset(offset), Converter.toLimit(limit));
ListaEventi ret = ListaUtils.costruisciLista(
context.getUriInfo(),
Converter.toOffset(offset), Converter.toLimit(limit),
listEventiDB!=null ? listEventiDB.size() : 0,
ListaEventi.class
);
if ( serverProperties.isFindall404() && (listEventiDB==null || listEventiDB.isEmpty()) )
throw FaultCode.NOT_FOUND.toException("Nessun evento trovato corrispondente ai criteri di ricerca");
if(listEventiDB!=null && !listEventiDB.isEmpty()) {
listEventiDB.forEach( eventoDB ->
{
try {
ret.addItemsItem( Converter.toEvento(eventoDB, this.log) );
} catch (Exception e) {
throw new RuntimeException(e.getMessage(),e);
}
}
);
}
context.getLogger().info("Invocazione completata con successo");
return ret;
}
finally {
dbManager.releaseConnectionTracce(connection);
}
}
catch(javax.ws.rs.WebApplicationException e) {
context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
throw e;
}
catch(Throwable e) {
context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
throw FaultCode.ERRORE_INTERNO.toException(e);
}
}
/**
* Ricerca delle transazioni in base all'identificativo dell'applicativo
*
* Permette di recuperare i dettagli delle transazioni, gestite su GovWay, ricercandole in base all'identificativo dell'applicativo
*
*/
@Override
public ListaTransazioni findAllTransazioniByIdApplicativo(TipoIdApplicativoEnum tipoIdentificativo, String id, ProfiloEnum profilo, String soggetto, Integer offset, Integer limit, String sort) {
IContext context = this.getContext();
try {
context.getLogger().info("Invocazione in corso ...");
AuthorizationManager.authorize(context, getAuthorizationConfig());
context.getLogger().debug("Autorizzazione completata con successo");
SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
TransazioniSearchForm search = searchFormUtilities.getIdApplicativoBaseSearchForm(context, profilo, soggetto);
MonitoraggioEnv env = new MonitoraggioEnv(context, profilo, soggetto, this.log);
search.setIdCorrelazioneApplicativa(id);
switch (tipoIdentificativo) {
case RICHIESTA:
search.setTipoIdMessaggio(org.openspcoop2.web.monitor.core.constants.TipoMessaggio.Richiesta.name());
break;
case RISPOSTA:
search.setTipoIdMessaggio(org.openspcoop2.web.monitor.core.constants.TipoMessaggio.Risposta.name());
break;
}
ListaTransazioni ret = TransazioniHelper.searchTransazioni(search, offset, limit, sort, env);
context.getLogger().info("Invocazione completata con successo");
return ret;
}
catch(javax.ws.rs.WebApplicationException e) {
context.getLogger().error("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
throw e;
}
catch(Throwable e) {
context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
throw FaultCode.ERRORE_INTERNO.toException(e);
}
}
/**
* Ricerca completa delle transazioni per intervallo temporale
*
* Permette di recuperare i dettagli delle transazioni, gestite su GovWay, limitando i risultati di ricerca ad un intervallo di date
*
*/
@Override
public ListaTransazioni findAllTransazioniByFullSearch(RicercaIntervalloTemporale body, ProfiloEnum profilo, String soggetto) {
IContext context = this.getContext();
try {
context.getLogger().info("Invocazione in corso ...");
AuthorizationManager.authorize(context, getAuthorizationConfig());
context.getLogger().debug("Autorizzazione completata con successo");
BaseHelper.throwIfNull(body);
MonitoraggioEnv env = new MonitoraggioEnv(context, profilo, soggetto, this.log);
ListaTransazioni ret = TransazioniHelper.findAllTransazioni(body, env);
context.getLogger().info("Invocazione completata con successo");
return ret;
}
catch(javax.ws.rs.WebApplicationException e) {
context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
throw e;
}
catch(Throwable e) {
context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
throw FaultCode.ERRORE_INTERNO.toException(e);
}
}
/**
* Ricerca completa delle transazioni in base all'identificativo applicativo
*
* Permette di recuperare i dettagli delle transazioni, gestite su GovWay, ricercandole in base all'identificativo applicativo e i parametri di filtro completi
*
*/
@Override
public ListaTransazioni findAllTransazioniByIdApplicativoFullSearch(RicercaIdApplicativo body, ProfiloEnum profilo, String soggetto) {
IContext context = this.getContext();
try {
context.getLogger().info("Invocazione in corso ...");
AuthorizationManager.authorize(context, getAuthorizationConfig());
context.getLogger().debug("Autorizzazione completata con successo");
BaseHelper.throwIfNull(body);
MonitoraggioEnv env = new MonitoraggioEnv(context, profilo, soggetto, this.log);
ListaTransazioni ret = TransazioniHelper.findAllTransazioniByIdApplicativo(body, env);
context.getLogger().info("Invocazione completata con successo");
return ret;
}
catch(javax.ws.rs.WebApplicationException e) {
context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
throw e;
}
catch(Throwable e) {
context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
throw FaultCode.ERRORE_INTERNO.toException(e);
}
}
/**
* Ricerca semplificata delle transazioni in base all'identificativo applicativo
*
* Permette di recuperare i dettagli delle transazioni, gestite su GovWay, ricercandole in base all'identificativo applicativo e i parametri di filtro di uso più comune
*
*/
@Override
public ListaTransazioni findAllTransazioniByIdApplicativoSimpleSearch(DateTime dataInizio, DateTime dataFine,
FiltroRicercaRuoloTransazioneEnum tipo, String idApplicativo, ProfiloEnum profilo, String soggetto,
Integer offset, Integer limit, String sort, String idCluster, String soggettoRemoto,
String soggettoErogatore, String tag, String uriApiImplementata,
String nomeServizio, String tipoServizio, Integer versioneServizio,
String azione, EsitoTransazioneSimpleSearchEnum esito, Boolean escludiScartate,
Boolean ricercaEsatta, Boolean caseSensitive) {
IContext context = this.getContext();
try {
context.getLogger().info("Invocazione in corso ...");
AuthorizationManager.authorize(context, getAuthorizationConfig());
context.getLogger().debug("Autorizzazione completata con successo");
MonitoraggioEnv env = new MonitoraggioEnv(context, profilo, soggetto, this.log);
RicercaIdApplicativo bodyRicerca = new RicercaIdApplicativo();
bodyRicerca.setTipo(tipo);
bodyRicerca.setApi(ReportisticaHelper.parseFiltroApiMap(tipo, nomeServizio, tipoServizio, versioneServizio, soggettoRemoto, soggettoErogatore,
env, uriApiImplementata));
FiltroTemporale iTemporale = new FiltroTemporale();
iTemporale.setDataInizio(dataInizio);
iTemporale.setDataFine(dataFine);
bodyRicerca.setIntervalloTemporale(iTemporale);
FiltroRicercaId filtroId = new FiltroRicercaId();
filtroId.setId(idApplicativo);
filtroId.setCaseSensitive(caseSensitive);
filtroId.setRicercaEsatta(ricercaEsatta);
bodyRicerca.setIdApplicativo(filtroId);
bodyRicerca.setIdCluster(idCluster);
bodyRicerca.setTag(tag);
bodyRicerca.setAzione(azione);
bodyRicerca.setLimit(limit);
bodyRicerca.setOffset(offset);
bodyRicerca.setSort(sort);
if (esito != null || escludiScartate!=null) {
FiltroEsito filtroEsito = new FiltroEsito();
if(esito!=null) {
filtroEsito.setTipo(EsitoTransazioneFullSearchEnum.valueOf(esito.name()));
}
else {
filtroEsito.setTipo(EsitoTransazioneFullSearchEnum.QUALSIASI);
}
if(escludiScartate!=null) {
filtroEsito.setEscludiScartate(escludiScartate);
}
bodyRicerca.setEsito(filtroEsito);
}
ListaTransazioni ret = TransazioniHelper.findAllTransazioniByIdApplicativo(bodyRicerca, env);
context.getLogger().info("Invocazione completata con successo");
return ret;
}
catch(javax.ws.rs.WebApplicationException e) {
context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
throw e;
}
catch(Throwable e) {
context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
throw FaultCode.ERRORE_INTERNO.toException(e);
}
}
/**
* Ricerca semplificata delle transazioni in base all'identificativo
* messaggio
*
* Permette di recuperare i dettagli delle transazioni, gestite su GovWay,
* ricercandole in base all'identificativo messaggio
*
*/
@Override
public ListaTransazioni findAllTransazioniByIdMessaggio(TipoMessaggioEnum tipoMessaggio, String id,
ProfiloEnum profilo, String soggetto, Integer offset, Integer limit, String sort) {
IContext context = this.getContext();
try {
context.getLogger().info("Invocazione in corso ...");
AuthorizationManager.authorize(context, getAuthorizationConfig());
context.getLogger().debug("Autorizzazione completata con successo");
SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
TransazioniSearchForm search = searchFormUtilities.getIdMessaggioSearchForm(context, profilo, soggetto);
MonitoraggioEnv env = new MonitoraggioEnv(context, profilo, soggetto, this.log);
search.setIdEgov(id);
switch (tipoMessaggio) {
case RICHIESTA:
search.setTipoIdMessaggio(org.openspcoop2.web.monitor.core.constants.TipoMessaggio.Richiesta.name());
break;
case RISPOSTA:
search.setTipoIdMessaggio(org.openspcoop2.web.monitor.core.constants.TipoMessaggio.Risposta.name());
break;
case CONVERSAZIONE:
search.setTipoIdMessaggio(org.openspcoop2.web.monitor.core.constants.TipoMessaggio.Collaborazione.name());
break;
case RIFERIMENTO_RICHIESTA:
search.setTipoIdMessaggio(org.openspcoop2.web.monitor.core.constants.TipoMessaggio.RiferimentoRichiesta.name());
break;
}
ListaTransazioni ret = TransazioniHelper.searchTransazioni(search, offset, limit, sort, env);
context.getLogger().info("Invocazione completata con successo");
return ret;
} catch (javax.ws.rs.WebApplicationException e) {
context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s", e, e.getMessage());
throw e;
} catch (Throwable e) {
context.getLogger().error("Invocazione terminata con errore: %s", e, e.getMessage());
throw FaultCode.ERRORE_INTERNO.toException(e);
}
}
/**
* Ricerca semplificata delle transazioni in base ai parametri di uso più comune
*
* Permette di recuperare i dettagli delle transazioni, gestite su GovWay,
* ricercandole in base a parametri di filtro di uso più comune
*
*/
@Override
public ListaTransazioni findAllTransazioniBySimpleSearch(DateTime dataInizio, DateTime dataFine,
FiltroRicercaRuoloTransazioneEnum tipo, ProfiloEnum profilo, String soggetto, Integer offset, Integer limit,
String sort, String idCluster, String soggettoRemoto, String soggettoErogatore, String tag, String uriApiImplementata,
String nomeServizio, String tipoServizio, Integer versioneServizio, String azione,
EsitoTransazioneSimpleSearchEnum esito,Boolean escludiScartate) {
IContext context = this.getContext();
try {
context.getLogger().info("Invocazione in corso ...");
AuthorizationManager.authorize(context, getAuthorizationConfig());
context.getLogger().debug("Autorizzazione completata con successo");
MonitoraggioEnv env = new MonitoraggioEnv(context, profilo, soggetto, this.log);
RicercaIntervalloTemporale bodyRicerca = new RicercaIntervalloTemporale();
FiltroTemporale intervalloTemporale = new FiltroTemporale();
intervalloTemporale.setDataFine(dataFine);
intervalloTemporale.setDataInizio(dataInizio);
bodyRicerca.setIntervalloTemporale(intervalloTemporale);
bodyRicerca.setTipo(tipo);
bodyRicerca.setIdCluster(idCluster);
bodyRicerca.setTag(tag);
bodyRicerca.setAzione(azione);
bodyRicerca.setSort(sort);
bodyRicerca.setLimit(limit);
bodyRicerca.setOffset(offset);
if (esito != null || escludiScartate!=null) {
FiltroEsito filtroEsito = new FiltroEsito();
if(esito!=null) {
filtroEsito.setTipo(EsitoTransazioneFullSearchEnum.valueOf(esito.name()));
}
else {
filtroEsito.setTipo(EsitoTransazioneFullSearchEnum.QUALSIASI);
}
if(escludiScartate!=null) {
filtroEsito.setEscludiScartate(escludiScartate);
}
bodyRicerca.setEsito(filtroEsito);
}
bodyRicerca.setApi(ReportisticaHelper.parseFiltroApiMap(tipo, nomeServizio, tipoServizio, versioneServizio,
soggettoRemoto,soggettoErogatore,
env, uriApiImplementata));
ListaTransazioni ret = TransazioniHelper.findAllTransazioni(bodyRicerca, env);
context.getLogger().info("Invocazione completata con successo");
return ret;
} catch (javax.ws.rs.WebApplicationException e) {
context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s", e, e.getMessage());
throw e;
} catch (Throwable e) {
context.getLogger().error("Invocazione terminata con errore: %s", e, e.getMessage());
throw FaultCode.ERRORE_INTERNO.toException(e);
}
}
/**
* Dettaglio di un evento
*
* Permette di recuperare il dettaglio di un evento in base al suo identificativo
*
*/
@Override
public Evento getEvento(Long id) {
IContext context = this.getContext();
try {
context.getLogger().info("Invocazione in corso ...");
AuthorizationManager.authorize(context, getAuthorizationConfig());
context.getLogger().debug("Autorizzazione completata con successo");
if(id==null) {
FaultCode.RICHIESTA_NON_VALIDA.throwException("Id undefined");
}
DBManager dbManager = DBManager.getInstance();
Connection connection = null;
try {
connection = dbManager.getConnectionTracce();
ServiceManagerProperties smp = dbManager.getServiceManagerPropertiesTracce();
EventiService eventiService = new EventiService(connection, true, smp, LoggerProperties.getLoggerDAO());
EventoBean eventoDB = eventiService.findById(id);
if(eventoDB==null) {
FaultCode.NOT_FOUND.throwException("Evento con id '"+id+"' non esistente");
}
Evento evento = Converter.toEvento(eventoDB, this.log);
context.getLogger().info("Invocazione completata con successo");
return evento;
}
finally {
dbManager.releaseConnectionTracce(connection);
}
}
catch(javax.ws.rs.WebApplicationException e) {
context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
throw e;
}
catch(Throwable e) {
context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
throw FaultCode.ERRORE_INTERNO.toException(e);
}
}
/**
* Dettaglio della transazione
*
* Questa operazione consente di ottenere il dettaglio di una transazione
*
*/
@Override
public DetailTransazione getTransazione(UUID id) {
IContext context = this.getContext();
try {
context.getLogger().info("Invocazione in corso ...");
AuthorizationManager.authorize(context, getAuthorizationConfig());
context.getLogger().debug("Autorizzazione completata con successo");
String idSearch = null;
if(id==null) {
FaultCode.RICHIESTA_NON_VALIDA.throwException("Id undefined");
}
else {
idSearch = id.toString();
}
DBManager dbManager = DBManager.getInstance();
Connection connection = null;
try {
connection = dbManager.getConnectionTracce();
ServiceManagerProperties smp = dbManager.getServiceManagerPropertiesTracce();
TransazioniService transazioniService = new TransazioniService(connection, true, smp, LoggerProperties.getLoggerDAO());
TransazioneBean transazioneDB = transazioniService.findByIdTransazione(idSearch);
if(transazioneDB==null) {
FaultCode.NOT_FOUND.throwException("Traccia con id '"+id+"' non esistente");
}
DetailTransazione transazione = org.openspcoop2.core.monitor.rs.server.api.impl.utils.Converter.toTransazioneExt(transazioneDB, transazioniService,
connection, smp,
this.log);
context.getLogger().info("Invocazione completata con successo");
return transazione;
}
finally {
dbManager.releaseConnectionTracce(connection);
}
}
catch(javax.ws.rs.WebApplicationException e) {
context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
throw e;
}
catch(Throwable e) {
context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
throw FaultCode.ERRORE_INTERNO.toException(e);
}
}
}