/*
 * Copyright (c) 2016 Brocade Communication Systems and others.  All rights reserved.
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
 * and is available at http://www.eclipse.org/legal/epl-v10.html
 */

package org.opendaylight.netconf.callhome.mount;

import java.io.IOException;
import java.io.File;
import java.net.InetSocketAddress;
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.netconf.callhome.protocol.CallHomeAuthorizationProvider;
import org.opendaylight.netconf.callhome.protocol.NetconfCallHomeServer;
import org.opendaylight.netconf.callhome.protocol.NetconfCallHomeServerBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class IetfZeroTouchCallHomeServerProvider implements AutoCloseable {
    private static final Logger LOG = LoggerFactory.getLogger(IetfZeroTouchCallHomeServerProvider.class);
    private static final String appName = "CallHomeServer";

    private final DataBroker dataBroker;
    private final CallHomeMountDispatcher mountDispacher;

    protected NetconfCallHomeServer server;


    private static final String CALL_HOME_PORT_KEY = "DefaultCallHomePort";

    private final CallHomeAuthProviderImpl authProvider;


    static String configurationPath = "etc"+File.pathSeparator+"ztp-callhome-config.cfg";

    private int port = 0; // 0 = use default in NetconfCallHomeBuilder

    public IetfZeroTouchCallHomeServerProvider(DataBroker dataBroker, CallHomeMountDispatcher mountDispacher) {
        this.dataBroker = dataBroker;
        this.mountDispacher = mountDispacher;
        this.authProvider = new CallHomeAuthProviderImpl(dataBroker);
    }

    public void init() {
        // Register itself as a listener to changes in Devices subtree
        try {
            LOG.info("Initializing provider for {}", appName);
            loadConfigurableValues(configurationPath);
            initializeServer();
            LOG.info("Initialization complete for {}", appName);
        } catch (IndexOutOfBoundsException | Configuration.ConfigurationException e) {
            LOG.error("Unable to successfully initialize", e);
        }
    }

    void loadConfigurableValues(String configurationPath) throws Configuration.ConfigurationException {
        try {
            Configuration configuration = new Configuration(configurationPath);
            port = configuration.getAsPort(CALL_HOME_PORT_KEY);
        } catch (Exception e) {
            LOG.error("Problem trying to load configuration values from {}", configurationPath, e);
        }
    }

    private CallHomeAuthorizationProvider getCallHomeAuthorization() {
        return authProvider;
    }

    private void initializeServer() {
        LOG.info("Initializing Call Home server instance");
        CallHomeAuthorizationProvider auth =  getCallHomeAuthorization();
        NetconfCallHomeServerBuilder builder = new NetconfCallHomeServerBuilder(auth, mountDispacher);

        if (port > 0)
            builder.setBindAddress(new InetSocketAddress(port));
        server = builder.build();
        try {
            server.bind();
            mountDispacher.createTopology();
            LOG.info("Initialization complete for Call Home server instance");
        } catch (IOException e) {
            throw new IllegalStateException("Unable to create Call Home Server.",e);
        }
    }

    @Override
    public void close() throws Exception {
        authProvider.close();
        if (server != null) {
            server.close();
        }

        LOG.info("Successfully closed provider for {}", appName);
    }

}