/*-
 * ============LICENSE_START=======================================================
 * ONAP : CCSDK
 * ================================================================================
 * Copyright (C) 2017 AT&T Intellectual Property. All rights
 *                         reserved.
 * ================================================================================
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 * ============LICENSE_END=========================================================
 */

package org.onap.ccsdk.sli.core.sli.provider;

import java.io.File;
import java.io.FileInputStream;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.LinkedList;
import java.util.Map;
import java.util.Properties;
import org.onap.ccsdk.sli.core.sli.ConfigurationException;
import org.onap.ccsdk.sli.core.sli.SvcLogicAdaptor;
import org.onap.ccsdk.sli.core.sli.SvcLogicException;
import org.onap.ccsdk.sli.core.sli.SvcLogicStore;
import org.onap.ccsdk.sli.core.sli.SvcLogicStoreFactory;
import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleContext;
import org.osgi.framework.ServiceReference;
import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


public class SvcLogicActivator implements BundleActivator {

    private static final String SVCLOGIC_PROP_VAR = "SDNC_SLI_PROPERTIES";
    private static final String SDNC_CONFIG_DIR = "SDNC_CONFIG_DIR";

    private static final Map<String, SvcLogicNodeExecutor> BUILTIN_NODES = new HashMap<String, SvcLogicNodeExecutor>() {
        {
            put("block", new BlockNodeExecutor());
            put("call", new CallNodeExecutor());
            put("configure", new ConfigureNodeExecutor());
            put("delete", new DeleteNodeExecutor());
            put("execute", new ExecuteNodeExecutor());
            put("exists", new ExistsNodeExecutor());
            put("for", new ForNodeExecutor());
            put("get-resource", new GetResourceNodeExecutor());
            put("is-available", new IsAvailableNodeExecutor());
            put("notify", new NotifyNodeExecutor());
            put("record", new RecordNodeExecutor());
            put("release", new ReleaseNodeExecutor());
            put("reserve", new ReserveNodeExecutor());
            put("return", new ReturnNodeExecutor());
            put("save", new SaveNodeExecutor());
            put("set", new SetNodeExecutor());
            put("switch", new SwitchNodeExecutor());
            put("update", new UpdateNodeExecutor());
            put("break", new BreakNodeExecutor());

        }
    };

    private static final Logger LOG = LoggerFactory.getLogger(SvcLogicActivator.class);

    private static LinkedList<ServiceRegistration> registrations = new LinkedList<>();

    private static HashMap<String, SvcLogicAdaptor> adaptorMap;

    private static Properties props;

    private static BundleContext bundleCtx;

    private static SvcLogicService svcLogicServiceImpl;

    @Override
    public void start(BundleContext ctx) throws Exception {

        LOG.info("Activating SLI");

        synchronized (SvcLogicActivator.class) {
            bundleCtx = ctx;
            props = new Properties();
        }

        // Read properties
        String propPath = System.getenv(SVCLOGIC_PROP_VAR);

        if (propPath == null) {
            String propDir = System.getenv(SDNC_CONFIG_DIR);
            if (propDir == null) {

                propDir = "/opt/sdnc/data/properties";
            }
            propPath = propDir + "/svclogic.properties";
            LOG.warn("Environment variable {} unset - defaulting to {}", SVCLOGIC_PROP_VAR, propPath);
        }

        File propFile = new File(propPath);

        if (!propFile.exists()) {
            throw new ConfigurationException("Missing configuration properties file : " + propFile);
        }

        try {
            props.load(new FileInputStream(propFile));
        } catch (Exception e) {
            throw new ConfigurationException("Could not load properties file " + propPath, e);

        }

        synchronized (SvcLogicActivator.class) {
            if (registrations == null) {
                registrations = new LinkedList<>();
            }
            // Advertise SvcLogicService
            svcLogicServiceImpl = new SvcLogicServiceImpl();
        }

        LOG.info("SLI: Registering service {} in bundle {}", SvcLogicService.NAME, ctx.getBundle().getSymbolicName());
        ServiceRegistration reg = ctx.registerService(SvcLogicService.NAME, svcLogicServiceImpl, null);
        registrations.add(reg);

        // Initialize SvcLogicStore
        try {
            SvcLogicStore store = getStore();
        } catch (ConfigurationException e) {
            LOG.warn("Could not initialize SvcLogicScore", e);
        }

        LOG.info("SLI - done registering services");
    }

    @Override
    public void stop(BundleContext ctx) throws Exception {

        if (registrations != null) {
            for (ServiceRegistration reg : registrations) {
                ServiceReference regRef = reg.getReference();
                reg.unregister();
            }
            synchronized (SvcLogicActivator.class) {
                registrations = null;
            }
        }
    }

    public static SvcLogicStore getStore() throws SvcLogicException {
        // Create and initialize SvcLogicStore object - used to access
        // saved service logic.

        SvcLogicStore store;

        try {
            store = SvcLogicStoreFactory.getSvcLogicStore(props);
        } catch (Exception e) {
            throw new ConfigurationException("Could not get service logic store", e);

        }

        try {
            store.init(props);
        } catch (Exception e) {
            throw new ConfigurationException("Could not get service logic store", e);
        }

        return(store);
    }


}