package com.megatim.fdxconsultation.service.impl.camel;

import com.megatim.fdxcommons.model.camel.BrokerProperties;
import com.megatim.fdxcommons.model.camel.FileProperties;
import java.io.IOException;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.annotation.PostConstruct;
import javax.ejb.Singleton;
import javax.ejb.Startup;
import javax.enterprise.event.Observes;
import javax.inject.Inject;
import org.apache.camel.cdi.CdiCamelConfiguration;
import org.apache.camel.cdi.CdiCamelContext;
import org.apache.camel.component.rabbitmq.RabbitMQComponent;

@Singleton
@Startup
public class CamelBootstrap {

    @Inject
    private CdiCamelContext camelContext;

    @PostConstruct
    public void init() {
        try {
            FileProperties fileProperties = new FileProperties(com.megatim.fdxcommons.tools.context.AppContext.BROKER_FILE_PATH);

            // Add RabbitMQ Component with connection details
            RabbitMQComponent rabbitMQComponent = new RabbitMQComponent();
            rabbitMQComponent.setHostname(brokerHostName(fileProperties));
            rabbitMQComponent.setPortNumber(brokerPortNumber(fileProperties));
            rabbitMQComponent.setUsername(brokerUserName(fileProperties));
            rabbitMQComponent.setPassword(brokerPassword(fileProperties));

            camelContext.addComponent("rabbitmq", rabbitMQComponent);

            camelContext.start();
        } catch (IOException ex) {
            Logger.getLogger(CamelBootstrap.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
        }
    }

    public static void configuration(@Observes CdiCamelConfiguration configuration) {

        System.out.println("<-------------------------------------------------------------------------------------------->");
        System.out.println("<-------------------------------------------------------------------------------------------->");
        System.out.println("<-------------------------------------------------------------------------------------------->");
        System.out.println("<-------------------------------------------------------------------------------------------->");
        System.out.println("<-------------------------------------------------------------------------------------------->");

        System.out.println("INSIDE CONFIGURE OF ROUTE");

        System.out.println("<-------------------------------------------------------------------------------------------->");
        System.out.println("<-------------------------------------------------------------------------------------------->");
        System.out.println("<-------------------------------------------------------------------------------------------->");
        System.out.println("<-------------------------------------------------------------------------------------------->");

//        configuration.autoConfigureRoutes(false);
        configuration.autoStartContexts(false);
    }

    private String brokerHostName(FileProperties fileProperties) throws IOException {
        return fileProperties.properties().getProperty(BrokerProperties.HOSTNAME);
    }

    private int brokerPortNumber(FileProperties fileProperties) throws IOException {
        return Integer.parseInt(fileProperties.properties().getProperty(BrokerProperties.PORT_NUMBER));
    }

    private String brokerUserName(FileProperties fileProperties) throws IOException {
        return fileProperties.properties().getProperty(BrokerProperties.USER_NAME);
    }

    private String brokerPassword(FileProperties fileProperties) throws IOException {
        return fileProperties.properties().getProperty(BrokerProperties.PASSWORD);
    }
}