/*
 * Copyright (c) 2018 Orange and/or its affiliates.
 *
 * 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.
 */
package io.fd.honeycomb.transportpce.device.tools;

import java.io.BufferedWriter;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.Writer;
import java.util.Optional;

import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.terminal.device.rev170708.terminal.device.top.TerminalDevice;
import org.opendaylight.yangtools.yang.binding.DataObject;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import io.fd.honeycomb.transportpce.binding.converter.XMLDataObjectConverter;
import io.fd.honeycomb.transportpce.test.common.DataStoreContext;

/**
 * Factory for creating the default device from the XML stored in classpath.
 *
 * @authors Gilles THOUENON and Christophe BETOULE ( gilles.thouenon@orange.com,
 *          christophe.betoule@orange.com )
 */
public class DefaultOcTerminalDeviceFactory {

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

    /**
     * Returns a new instance of {@link TerminalDevice} from the loaded XML stored in
     * File.
     *
     * @return {@link TerminalDevice}
     */
    public TerminalDevice createDefaultTerminalDevice(DataStoreContext dataStoreContextUtil, File oc_terminal_device_data) {
        TerminalDevice result = null;
        if (oc_terminal_device_data.exists()) {
            String oper = oc_terminal_device_data.getName();
            LOG.info("file '{}' exists at location : {}", oper, oc_terminal_device_data.getAbsolutePath());
            InputStream targetStream;
            try {
                targetStream = new FileInputStream(oc_terminal_device_data);
                Optional<NormalizedNode<?, ?>> transformIntoNormalizedNode = null;
                transformIntoNormalizedNode = XMLDataObjectConverter.createWithDataStoreUtil(dataStoreContextUtil)
                        .transformIntoNormalizedNode(targetStream);
                if (!transformIntoNormalizedNode.isPresent()) {
                    throw new IllegalStateException(
                            String.format("Could not transform the input %s into normalized nodes", oper));
                }
                Optional<DataObject> dataObject = XMLDataObjectConverter.createWithDataStoreUtil(dataStoreContextUtil)
                        .getDataObject(transformIntoNormalizedNode.get(), TerminalDevice.QNAME);
                if (!dataObject.isPresent()) {
                    LOG.warn("Could not transform normalized nodes into data object");
                    return null;
                }
                result = (TerminalDevice) dataObject.get();
            } catch (FileNotFoundException e) {
                LOG.error("File not found : {} at {}", e.getMessage(), e.getLocalizedMessage());
            } catch (IllegalStateException e) {
                LOG.warn("Could not transform the input OcTerminalDevice into normalized nodes");
                return null;
            }
        } else {
            LOG.info("xml file not existed at : '{}'", oc_terminal_device_data.getAbsolutePath());
        }
        return result;
    }

    /**
     * Returns a new instance of {@link TerminalDevice} from the loaded XML stored in
     * String.
     *
     * @return {@link TerminalDevice}
     */
    public TerminalDevice createDefaultTerminalDevice(DataStoreContext dataStoreContextUtil, String oc_terminal_device_data) {
        TerminalDevice result = null;
        if (oc_terminal_device_data != null) {
            LOG.info("openconfig-terminal-device data string is ok ");
            InputStream targetStream;
            try {
                targetStream = new ByteArrayInputStream(oc_terminal_device_data.getBytes());
                Optional<NormalizedNode<?, ?>> transformIntoNormalizedNode = null;
                transformIntoNormalizedNode = XMLDataObjectConverter.createWithDataStoreUtil(dataStoreContextUtil)
                        .transformIntoNormalizedNode(targetStream);
                if (!transformIntoNormalizedNode.isPresent()) {
                    throw new IllegalStateException(
                            String.format("Could not transform the input %s into normalized nodes"));
                }
                Optional<DataObject> dataObject = XMLDataObjectConverter.createWithDataStoreUtil(dataStoreContextUtil)
                        .getDataObject(transformIntoNormalizedNode.get(), TerminalDevice.QNAME);
                if (!dataObject.isPresent()) {
                    LOG.warn("Could not transform normalized nodes into data object");
                }
                result = (TerminalDevice) dataObject.get();
            } catch (IllegalStateException e) {
                LOG.warn("Could not transform the input OcTerminalDevice into normalized nodes");
                return null;
            }
        } else {
            LOG.info("openconfig-terminal-device data string is null!");
        }
        return result;
    }

    /**
     * create an XML String from an instance of {@link TerminalDevice}.
     *
     */
    public void createXMLFromTerminalDevice(DataStoreContext dataStoreContextUtil, TerminalDevice terminalDevice, String output) {
        if (terminalDevice != null) {
            Optional<NormalizedNode<?, ?>> transformIntoNormalizedNode = null;
            transformIntoNormalizedNode = XMLDataObjectConverter.createWithDataStoreUtil(dataStoreContextUtil)
                    .toNormalizedNodes(terminalDevice, TerminalDevice.class);
            if (!transformIntoNormalizedNode.isPresent()) {
                throw new IllegalStateException(
                        String.format("Could not transform the input %s into normalized nodes", terminalDevice));
            }
            XMLDataObjectConverter createWithDataStoreUtil = XMLDataObjectConverter
                    .createWithDataStoreUtil(dataStoreContextUtil);
            Writer writerFromDataObject = createWithDataStoreUtil.writerFromDataObject(terminalDevice, TerminalDevice.class,
                    createWithDataStoreUtil.dataContainer());
            try {
                BufferedWriter writer = new BufferedWriter(new FileWriter(output));
                writer.write(writerFromDataObject.toString());
                writer.close();
            } catch (IOException e) {
                LOG.error("Bufferwriter error ");
            }
            LOG.info("openconfig-terminal-device xml : {}", writerFromDataObject.toString());
        }
    }
}