/*
 * Copyright (c) 2013 Cisco Systems, Inc. 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.controller.config.yangjmxgenerator.plugin.ftl;

import static com.google.common.base.Preconditions.checkArgument;
import static com.google.common.base.Preconditions.checkState;
import static java.lang.String.format;

import java.io.Closeable;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
import java.util.concurrent.atomic.AtomicInteger;

import org.opendaylight.controller.config.api.runtime.HierarchicalRuntimeBeanRegistration;
import org.opendaylight.controller.config.api.runtime.RootRuntimeBeanRegistrator;
import org.opendaylight.controller.config.yangjmxgenerator.RuntimeBeanEntry;
import org.opendaylight.controller.config.yangjmxgenerator.plugin.ftl.model.Annotation;
import org.opendaylight.controller.config.yangjmxgenerator.plugin.ftl.model.Annotation.Parameter;
import org.opendaylight.controller.config.yangjmxgenerator.plugin.ftl.model.Field;
import org.opendaylight.controller.config.yangjmxgenerator.plugin.ftl.model.MethodDefinition;
import org.opendaylight.controller.config.yangjmxgenerator.plugin.util.FullyQualifiedNameHelper;

import com.google.common.annotations.VisibleForTesting;
import com.google.common.collect.Lists;

public class RuntimeRegistratorFtlTemplate extends GeneralClassTemplate {

    private RuntimeRegistratorFtlTemplate(RuntimeBeanEntry runtimeBeanEntry,
            String name, List<Field> fields, List<MethodDefinition> methods) {
        // TODO header
        super(null, runtimeBeanEntry.getPackageName(), name, Collections
                .<String> emptyList(), Arrays.asList(Closeable.class
                .getCanonicalName()), fields, methods);
    }

    public static RuntimeBeanEntry findRoot(
            Collection<RuntimeBeanEntry> runtimeBeanEntries) {
        RuntimeBeanEntry result = null;
        for (RuntimeBeanEntry rb : runtimeBeanEntries) {
            if (rb.isRoot()) {
                if (result != null) {
                    throw new IllegalArgumentException(
                            "More than one root runtime bean found");
                }
                result = rb;
            }
        }
        if (result != null) {
            return result;
        }
        throw new IllegalArgumentException("No root runtime bean found");
    }

    private static String constructConstructorBody(
            List<Field> constructorParameters) {
        StringBuffer constructorBody = new StringBuffer();
        for (Field field : constructorParameters) {
            constructorBody.append("this.");
            constructorBody.append(field.getName());
            constructorBody.append("=");
            constructorBody.append(field.getName());
            constructorBody.append(";\n");
        }
        return constructorBody.toString();
    }

    // TODO Move to factory
    /**
     * Get registrator and n registration ftls where n is equal to total number
     * of runtime beans in hierarchy.
     */
    public static Map<String, FtlTemplate> create(RuntimeBeanEntry rootRB) {
        checkArgument(rootRB.isRoot(), "RuntimeBeanEntry must be root");
        String registratorName = getJavaNameOfRuntimeRegistrator(rootRB);
        List<MethodDefinition> methods = new ArrayList<>();
        Field rootRuntimeBeanRegistratorField = new Field(
                Lists.newArrayList("final"),
                RootRuntimeBeanRegistrator.class.getName(),
                "rootRuntimeBeanRegistrator");
        List<Field> constructorParameters = Lists
                .newArrayList(rootRuntimeBeanRegistratorField);
        String constructorBody = constructConstructorBody(constructorParameters);
        MethodDefinition constructor = MethodDefinition.createConstructor(
                registratorName, constructorParameters, constructorBody);
        methods.add(constructor);

        LinkedHashMap<String, RuntimeRegistratorFtlTemplate> RuntimeRegistratorFtlTemplates = createRegistrationHierarchy(
                rootRB, Collections.<String> emptySet());
        RuntimeRegistratorFtlTemplate rootFtlFile = RuntimeRegistratorFtlTemplates
                .values().iterator().next();

        {// add register(rootruntimemxbean)
            String fullyQualifiedNameOfMXBean = FullyQualifiedNameHelper
                    .getFullyQualifiedName(rootRB.getPackageName(), rootRB.getJavaNameOfRuntimeMXBean());
            String childRegistratorFQN = rootFtlFile.getFullyQualifiedName();
            Field rbParameter = new Field(fullyQualifiedNameOfMXBean, "rb");
            StringBuilder registerBody = new StringBuilder();
            registerBody.append(format("%s %s = this.%s.registerRoot(%s);\n",
                    HierarchicalRuntimeBeanRegistration.class
                            .getCanonicalName(), hierachchicalRegistration
                            .getName(), rootRuntimeBeanRegistratorField
                            .getName(), rbParameter.getName()));
            registerBody.append(format("return new %s(%s);\n",
                    rootFtlFile.getFullyQualifiedName(),
                    hierachchicalRegistration.getName()));

            MethodDefinition registerMethod = new MethodDefinition(
                    childRegistratorFQN, "register",
                    Arrays.asList(rbParameter), registerBody.toString());
            methods.add(registerMethod);
        }

        MethodDefinition closeRegistrator = createCloseMethodToCloseField(rootRuntimeBeanRegistratorField);
        methods.add(closeRegistrator);

        // TODO add header
        GeneralClassTemplate registrator = new GeneralClassTemplate(null,
                rootRB.getPackageName(), registratorName,
                Collections.<String> emptyList(), Arrays.asList(Closeable.class
                        .getCanonicalName()), constructorParameters, methods);

        checkState(RuntimeRegistratorFtlTemplates.containsKey(registrator
                .getTypeDeclaration().getName()) == false, "Name conflict: "
                + registrator.getTypeDeclaration().getName());
        Map<String, FtlTemplate> result = new HashMap<>();
        result.putAll(RuntimeRegistratorFtlTemplates);
        result.put(registrator.getTypeDeclaration().getName(), registrator);
        return result;
    }

    private static Field hierachchicalRegistration = new Field(
            Lists.newArrayList("final"),
            HierarchicalRuntimeBeanRegistration.class.getCanonicalName(),
            "registration");

    // TODO move to factory + RuntimeBeanEntry
    /**
     * Create ftls representing registrations. First registration is represents
     * parent.
     *
     * @return map containing java class name as key, instance representing the
     *         java file as value.
     */
    private static LinkedHashMap<String, RuntimeRegistratorFtlTemplate> createRegistrationHierarchy(
            RuntimeBeanEntry parent, Set<String> occupiedKeys) {
        LinkedHashMap<String, RuntimeRegistratorFtlTemplate> unorderedResult = new LinkedHashMap<>();
        List<MethodDefinition> methods = new ArrayList<>();

        // hierarchy of ON is created as follows:
        // root RB: <domain>, type=RuntimeBean
        // 1st RB in hierarchy: <domain>, type=RuntimeBean, <java name of leaf
        // list>: key or counter
        // n-th RB in hierarchy has same ON as n-1, with added <java name of
        // leaf list>: key or counter
        if (occupiedKeys.contains(parent.getJavaNamePrefix())) {
            throw new IllegalArgumentException(
                    "Name conflict in runtime bean hierarchy - java name found more than "
                            + "once. Consider using java-name extension. Conflicting name: "
                            + parent.getJavaNamePrefix());
        }
        Set<String> currentOccupiedKeys = new HashSet<>(occupiedKeys);
        currentOccupiedKeys.add(parent.getJavaNamePrefix());

        Field registratorsMapField = new Field(Arrays.asList("final"),
                TypeHelper.getGenericType(Map.class, String.class,
                        AtomicInteger.class), "unkeyedMap", "new "
                        + TypeHelper.getGenericType(HashMap.class,
                                String.class, AtomicInteger.class) + "()");

        // create register methods for children
        for (RuntimeBeanEntry child : parent.getChildren()) {
            checkArgument(parent.getPackageName()
                    .equals(child.getPackageName()), "Invalid package name");

            // call itself recursively to generate child
            // registrators/registrations
            LinkedHashMap<String, RuntimeRegistratorFtlTemplate> childRegistratorMap = createRegistrationHierarchy(
                    child, currentOccupiedKeys);
            for (Entry<String, RuntimeRegistratorFtlTemplate> entry : childRegistratorMap
                    .entrySet()) {
                if (unorderedResult.containsKey(entry.getKey())) {
                    throw new IllegalStateException(
                            "Conflicting name found while generating runtime registration:"
                                    + entry.getKey());
                }
                unorderedResult.put(entry.getKey(), entry.getValue());
            }

            if (!childRegistratorMap.isEmpty()) {
                // first entry is the direct descendant according to the create
                // contract
                RuntimeRegistratorFtlTemplate childRegistrator = childRegistratorMap
                        .values().iterator().next();
                StringBuilder body = new StringBuilder();
                String key, value;
                key = child.getJavaNamePrefix();
                body.append(format(
                        "String key = \"%s\"; //TODO: check for conflicts\n",
                        key));

                if (child.getKeyJavaName().isPresent()) {
                    value = "bean.get" + child.getKeyJavaName().get() + "()";
                    value = "String.valueOf(" + value + ")";
                } else {
                    body.append("java.util.concurrent.atomic.AtomicInteger counter = unkeyedMap.get(key);\n"
                            + "if (counter==null){\n"
                            + "counter = new java.util.concurrent.atomic.AtomicInteger();\n"
                            + "unkeyedMap.put(key, counter);\n" + "}\n");
                    value = "String.valueOf(counter.incrementAndGet())";
                }
                body.append(format("String value = %s;\n", value));
                body.append(format("%s r = %s.register(key, value, bean);\n",
                        HierarchicalRuntimeBeanRegistration.class
                                .getCanonicalName(), hierachchicalRegistration
                                .getName()));
                body.append(format("return new %s(r);",
                        childRegistrator.getFullyQualifiedName()));

                Field param = new Field(Lists.newArrayList("final"),
                        child.getJavaNameOfRuntimeMXBean(), "bean");
                MethodDefinition register = new MethodDefinition(
                        Arrays.asList("synchronized"),
                        childRegistrator.getFullyQualifiedName(), "register",
                        Arrays.asList(param), Collections.<String> emptyList(),
                        Collections.<Annotation> emptyList(), body.toString());
                methods.add(register);

            }
        }

        // create parent registration
        String createdName = getJavaNameOfRuntimeRegistration(parent.getJavaNamePrefix());

        List<Field> constructorParameters = Arrays
                .asList(hierachchicalRegistration);
        String constructorBody = constructConstructorBody(constructorParameters);

        MethodDefinition constructor = MethodDefinition.createConstructor(
                createdName, constructorParameters, constructorBody);

        MethodDefinition closeRegistrator = createCloseMethodToCloseField(hierachchicalRegistration);
        methods.add(closeRegistrator);
        methods.add(constructor);
        List<Field> privateFields = Lists.newArrayList(registratorsMapField);
        privateFields.addAll(constructorParameters);

        RuntimeRegistratorFtlTemplate created = new RuntimeRegistratorFtlTemplate(
                parent, createdName, privateFields, methods);

        LinkedHashMap<String, RuntimeRegistratorFtlTemplate> result = new LinkedHashMap<>();
        result.put(created.getTypeDeclaration().getName(), created);
        checkState(unorderedResult.containsKey(created.getTypeDeclaration()
                .getName()) == false, "Naming conflict: "
                + created.getTypeDeclaration().getName());
        result.putAll(unorderedResult);
        return result;
    }

    private static MethodDefinition createCloseMethodToCloseField(Field field) {
        String body = field.getName() + ".close();";
        // TODO Thrown exception breaks build
        // return new MethodDefinition(Collections.<String> emptyList(), "void",
        // "close", Collections.<Field> emptyList(),
        // Arrays.asList(IOException.class.getCanonicalName()),
        // Collections.<Annotation> emptyList(), body);
        List<Annotation> annotations = Lists.newArrayList(new Annotation(
                "Override", Collections.<Parameter> emptyList()));
        return new MethodDefinition(Collections.<String> emptyList(), "void",
                "close", Collections.<Field> emptyList(),
                Collections.<String> emptyList(), annotations, body);
    }

    @VisibleForTesting
    public static String getJavaNameOfRuntimeRegistration(String javaNamePrefix) {
        return javaNamePrefix + "RuntimeRegistration";
    }

    public static String getJavaNameOfRuntimeRegistrator(RuntimeBeanEntry rootRB) {
        checkArgument(rootRB.isRoot(), "RuntimeBeanEntry must be root");
        return rootRB.getJavaNamePrefix() + "RuntimeRegistrator";
    }
}