ConnettoreAPIHelper.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.core.config.rs.server.api.impl.erogazioni;

import java.util.HashMap;
import java.util.Map;

import org.openspcoop2.core.config.Connettore;
import org.openspcoop2.core.config.ServizioApplicativo;
import org.openspcoop2.core.config.constants.StatoFunzionalita;
import org.openspcoop2.core.config.rs.server.model.ConnettoreEnum;
import org.openspcoop2.core.config.rs.server.model.ConnettoreErogazione;
import org.openspcoop2.core.config.rs.server.model.ConnettoreFruizione;
import org.openspcoop2.core.config.rs.server.model.OneOfApplicativoServerConnettore;
import org.openspcoop2.core.config.rs.server.model.OneOfConnettoreErogazioneConnettore;
import org.openspcoop2.core.config.rs.server.model.OneOfConnettoreFruizioneConnettore;
import org.openspcoop2.core.constants.TipiConnettore;

/**
 * ConnettoreAPIHelper
 * 
 * @author $Author$
 * @version $Rev$, $Date$
 * 
 */
public class ConnettoreAPIHelper {

    public static String getUrlConnettore(ServizioApplicativo sa, boolean isRidefinito) throws Exception {
        if(isRidefinito) {
            return "Connettori ridefiniti nei gruppi";
        }

        return getUrlConnettore(sa.getInvocazioneServizio().getConnettore().getProperties(), sa.getInvocazioneServizio().getConnettore().getTipo(), sa.getInvocazioneServizio().getConnettore().getCustom(), sa.getInvocazioneServizio().getGetMessage().equals(StatoFunzionalita.ABILITATO));
    }

    private static String getUrlConnettore(Map<String, String> properties, String tipo, Boolean custom, boolean isMessageBox) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(tipo, custom, isMessageBox);
        
        if(helper == null) return null;
        return helper.getUrlConnettore(properties, tipo);
    }

    private static String CUSTOM_KEY = "CUSTOM";
    private static Map<String, IConnettoreApiHelper> helpers;
    private static Map<ConnettoreEnum, IConnettoreApiHelper> helpersByEnum;
    
    private static synchronized void initHelper() {
        if(helpers== null) {
            helpers = new HashMap<>();
            ConnettoreHTTPApiHelper connHttpApiHelper = new ConnettoreHTTPApiHelper();
            helpers.put(TipiConnettore.HTTP.toString(), connHttpApiHelper);
            helpers.put(TipiConnettore.HTTPS.toString(), connHttpApiHelper);
            helpers.put(TipiConnettore.FILE.toString(), new ConnettoreFileApiHelper());
            helpers.put(TipiConnettore.JMS.toString(), new ConnettoreJmsApiHelper());
            helpers.put(TipiConnettore.NULL.toString(), new ConnettoreNullApiHelper());
            helpers.put(TipiConnettore.NULLECHO.toString(), new ConnettoreEchoApiHelper());
            helpers.put(TipiConnettore.STATUS.toString(), new ConnettoreStatusApiHelper());
            helpers.put(TipiConnettore.DISABILITATO.toString(), new ConnettoreMessageBoxApiHelper());
            helpers.put(CUSTOM_KEY, new ConnettorePluginApiHelper());
        }
    }
    
    private static IConnettoreApiHelper getHelper(String tipo, Boolean custom, boolean isMessageBox) throws Exception {
        
        if(helpers== null) {
            initHelper();
        }
        
        if(helpers.containsKey(tipo)) {
            
            IConnettoreApiHelper iConnettoreApiHelper = helpers.get(tipo);
            if(iConnettoreApiHelper instanceof ConnettoreMessageBoxApiHelper && !isMessageBox) {
                return null; //Connettore disabilitato
            }
            return iConnettoreApiHelper;
        } else if(custom && helpers.containsKey(CUSTOM_KEY)) {
            return helpers.get(CUSTOM_KEY);
        } else {
            return null;
//          throw new Exception("Connettore tipo ["+tipo+"] custom ["+custom+"] non supportato");
        }
    }

    private static synchronized void initHelperByEnum() {
        if(helpersByEnum== null) {
            helpersByEnum = new HashMap<>();
            helpersByEnum.put(ConnettoreEnum.HTTP, new ConnettoreHTTPApiHelper());
            helpersByEnum.put(ConnettoreEnum.FILE, new ConnettoreFileApiHelper());
            helpersByEnum.put(ConnettoreEnum.JMS, new ConnettoreJmsApiHelper());
            helpersByEnum.put(ConnettoreEnum.NULL, new ConnettoreNullApiHelper());
            helpersByEnum.put(ConnettoreEnum.ECHO, new ConnettoreEchoApiHelper());
            helpersByEnum.put(ConnettoreEnum.STATUS, new ConnettoreStatusApiHelper());
            helpersByEnum.put(ConnettoreEnum.PLUGIN, new ConnettorePluginApiHelper());
            helpersByEnum.put(ConnettoreEnum.MESSAGE_BOX, new ConnettoreMessageBoxApiHelper());
        }
    }
    
    private static IConnettoreApiHelper getHelper(ConnettoreEnum tipo) throws Exception {
        
        if(helpersByEnum== null) {
            initHelperByEnum();
        }
        
        if(helpersByEnum.containsKey(tipo)) {
            return helpersByEnum.get(tipo);
        } else {
            throw new Exception("Connettore tipo ["+tipo+"] non supportato");
        }
    }

    public static String getUrlConnettore(org.openspcoop2.core.registry.Connettore connettore, boolean isRidefinito) throws Exception {
        if(isRidefinito) {
            return "Connettori ridefiniti nei gruppi";
        }

        if(connettore == null) return null;
        
        boolean isMessageBox = false; //FRUIZIONI NO MSG BOX
        return getUrlConnettore(connettore.getProperties(), connettore.getTipo(), connettore.getCustom(), isMessageBox);
    }

    public static final ConnettoreErogazione buildConnettoreErogazione(ServizioApplicativo sa) throws Exception {
        ConnettoreErogazione connettoreErogazione = new ConnettoreErogazione();
        connettoreErogazione.setConnettore(ConnettoreAPIHelper.getConnettoreErogazione(sa));
        return connettoreErogazione;
    }
    public static final ConnettoreFruizione buildConnettoreFruizione(org.openspcoop2.core.registry.Connettore connettore) throws Exception {
        ConnettoreFruizione connettoreFruizione = new ConnettoreFruizione();
        connettoreFruizione.setConnettore(ConnettoreAPIHelper.getConnettoreFruizione(connettore));
        return connettoreFruizione;
    }

    private static OneOfConnettoreFruizioneConnettore getConnettoreFruizione(
            org.openspcoop2.core.registry.Connettore connettore) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(connettore.getTipo(), connettore.getCustom(), false); //MessageBox disabilitato in fruizioni
        
        if(helper == null) return null;
        return helper.buildConnettoreFruizione(connettore.getProperties(), connettore.getTipo());
    }

    private static OneOfConnettoreErogazioneConnettore getConnettoreErogazione(ServizioApplicativo sa) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(sa.getInvocazioneServizio().getConnettore().getTipo(), sa.getInvocazioneServizio().getConnettore().getCustom(), sa.getInvocazioneServizio().getGetMessage().equals(StatoFunzionalita.ABILITATO));
        
        if(helper == null) return null;
        return helper.buildConnettoreErogazione(sa);
    }

    public static OneOfApplicativoServerConnettore getConnettoreApplicativoServer(ServizioApplicativo sa) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(sa.getInvocazioneServizio().getConnettore().getTipo(), sa.getInvocazioneServizio().getConnettore().getCustom(), sa.getInvocazioneServizio().getGetMessage().equals(StatoFunzionalita.ABILITATO));
        
        if(helper == null) return null;
        return helper.buildConnettoreApplicativoServer(sa);
    }

    public static boolean connettoreCheckData(OneOfApplicativoServerConnettore connettore, ErogazioniEnv erogEnv, boolean erogazione) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(connettore.getTipo());
        
        if(helper == null) return true;
        return helper.connettoreCheckData(connettore, erogEnv, erogazione);
    }

    public static boolean connettoreCheckData(OneOfConnettoreErogazioneConnettore connettore, ErogazioniEnv erogEnv, boolean erogazione) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(connettore.getTipo()); 
        
        if(helper == null) return true;
        return helper.connettoreCheckData(connettore, erogEnv, erogazione);
    }

    public static boolean connettoreCheckData(OneOfConnettoreFruizioneConnettore connettore, ErogazioniEnv erogEnv, boolean erogazione) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(connettore.getTipo());
        
        if(helper == null) return true;
        return helper.connettoreCheckData(connettore, erogEnv, erogazione);
    }

    public static void fillConnettoreConfigurazione(ServizioApplicativo sa, ErogazioniEnv erogEnv, OneOfApplicativoServerConnettore connettore, String oldConnT) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(connettore.getTipo());
        
        if(helper == null) return;
        helper.buildConnettoreConfigurazione(sa, erogEnv, connettore, oldConnT);
    }

    public static void fillConnettoreConfigurazione(ServizioApplicativo sa, ErogazioniEnv erogEnv, OneOfConnettoreErogazioneConnettore connettore, String oldConnT) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(connettore.getTipo());
        
        if(helper == null) return;
        helper.buildConnettoreConfigurazione(sa, erogEnv, connettore, oldConnT);
    }

    public static void fillConnettoreConfigurazione(Connettore connis, ErogazioniEnv erogEnv, OneOfConnettoreFruizioneConnettore connettore, String oldConnT) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(connettore.getTipo());
        
        if(helper == null) return;
        helper.buildConnettoreConfigurazione(connis, erogEnv, connettore, oldConnT);
    }

    public static void fillConnettoreRegistro(org.openspcoop2.core.registry.Connettore connis, ErogazioniEnv erogEnv, OneOfApplicativoServerConnettore connettore, String oldConnT) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(connettore.getTipo());
        
        if(helper == null) return;
        helper.fillConnettoreRegistro(connis, erogEnv, connettore, oldConnT);
    }

    public static void fillConnettoreRegistro(org.openspcoop2.core.registry.Connettore connis, ErogazioniEnv erogEnv, OneOfConnettoreErogazioneConnettore connettore, String oldConnT) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(connettore.getTipo());
        
        if(helper == null) return;
        helper.fillConnettoreRegistro(connis, erogEnv, connettore, oldConnT);
    }

    public static void fillConnettoreRegistro(org.openspcoop2.core.registry.Connettore connis, ErogazioniEnv erogEnv, OneOfConnettoreFruizioneConnettore connettore, String oldConnT) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(connettore.getTipo());
        
        if(helper == null) return;
        helper.fillConnettoreRegistro(connis, erogEnv, connettore, oldConnT);
    }

    public static org.openspcoop2.core.registry.Connettore buildConnettoreRegistro(ErogazioniEnv erogEnv, OneOfApplicativoServerConnettore connettore) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(connettore.getTipo());
        
        if(helper == null) return null;
        return helper.buildConnettoreRegistro(erogEnv, connettore);
    }

    public static org.openspcoop2.core.registry.Connettore buildConnettoreRegistro(ErogazioniEnv erogEnv, OneOfConnettoreErogazioneConnettore connettore) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(connettore.getTipo());
        
        if(helper == null) return null;
        return helper.buildConnettoreRegistro(erogEnv, connettore);
    }

    public static org.openspcoop2.core.registry.Connettore buildConnettoreRegistro(ErogazioniEnv erogEnv, OneOfConnettoreFruizioneConnettore connettore) throws Exception {
        IConnettoreApiHelper helper = ConnettoreAPIHelper.getHelper(connettore.getTipo());
        
        if(helper == null) return null;
        return helper.buildConnettoreRegistro(erogEnv, connettore);
    }

}