/*
 * 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.util;

import com.google.common.collect.Sets;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import javax.management.InstanceNotFoundException;
import javax.management.ObjectName;
import org.opendaylight.controller.config.api.ConflictingVersionException;
import org.opendaylight.controller.config.api.ModuleIdentifier;
import org.opendaylight.controller.config.api.ValidationException;
import org.opendaylight.controller.config.api.jmx.CommitStatus;
import org.opendaylight.controller.config.api.jmx.ConfigRegistryMXBean;
import org.opendaylight.controller.config.api.jmx.ObjectNameUtil;

public class TestingConfigRegistry implements ConfigRegistryMXBean {

    static final ObjectName conf1, conf2, conf3, run1, run2, run3;
    public static String check;
    public static boolean checkBool;
    private Map<String, ObjectName> map = new HashMap<>();

    public static final String moduleName1 = "moduleA";
    public static final String moduleName2 = "moduleB";
    public static final String instName1 = "instA";
    public static final String instName2 = "instB";
    public static final String refName1 = "refA";
    public static final String refName2 = "refB";
    public static final String serviceQName1 = "qnameA";
    public static final String serviceQName2 = "qnameB";

    static {
        conf1 = ObjectNameUtil.createON(ObjectNameUtil.ON_DOMAIN
                + ":type=Module," + ObjectNameUtil.MODULE_FACTORY_NAME_KEY
                + "=" + moduleName1 + "," + ObjectNameUtil.SERVICE_QNAME_KEY
                + "=" + serviceQName1 + "," + ObjectNameUtil.REF_NAME_KEY
                + "=" + refName1);
        conf2 = ObjectNameUtil.createON(ObjectNameUtil.ON_DOMAIN
                + ":type=Module," + ObjectNameUtil.MODULE_FACTORY_NAME_KEY
                + "=" + moduleName1 + "," + ObjectNameUtil.INSTANCE_NAME_KEY
                + "=" + instName1 + "," + ObjectNameUtil.SERVICE_QNAME_KEY
                + "=" + serviceQName2 + "," + ObjectNameUtil.REF_NAME_KEY
                + "=" + refName1);
        conf3 = ObjectNameUtil.createON(ObjectNameUtil.ON_DOMAIN
                + ":type=Module," + ObjectNameUtil.MODULE_FACTORY_NAME_KEY
                + "=" + moduleName2 + "," + ObjectNameUtil.INSTANCE_NAME_KEY
                + "=" + instName2);
        run1 = ObjectNameUtil.createON(ObjectNameUtil.ON_DOMAIN
                + ":type=RuntimeBean," + ObjectNameUtil.MODULE_FACTORY_NAME_KEY
                + "=" + moduleName1);
        run2 = ObjectNameUtil.createON(ObjectNameUtil.ON_DOMAIN
                + ":type=RuntimeBean," + ObjectNameUtil.MODULE_FACTORY_NAME_KEY
                + "=" + moduleName1 + "," + ObjectNameUtil.INSTANCE_NAME_KEY
                + "=" + instName1);
        run3 = ObjectNameUtil.createON(ObjectNameUtil.ON_DOMAIN
                + ":type=RuntimeBean," + ObjectNameUtil.MODULE_FACTORY_NAME_KEY
                + "=" + moduleName2 + "," + ObjectNameUtil.INSTANCE_NAME_KEY
                + "=" + instName2);

        check = null;
        checkBool = false;

    }

    @Override
    public ObjectName beginConfig() {
        return conf2;
    }

    @Override
    public CommitStatus commitConfig(final ObjectName transactonControllerON)
            throws ConflictingVersionException, ValidationException {
        if (transactonControllerON == null) {
            Exception e = new RuntimeException("message");
            throw ValidationException.createForSingleException(
                    new ModuleIdentifier("moduleName", "instanceName"), e);
        }
        return null;
    }

    @Override
    public List<ObjectName> getOpenConfigs() {
        return null;
    }

    @Override
    public boolean isHealthy() {
        return false;
    }

    @Override
    public Set<String> getAvailableModuleNames() {
        return null;
    }

    @Override
    public Set<ObjectName> lookupConfigBeans() {
        return Sets.newHashSet(conf1, conf2, conf3);
    }

    @Override
    public Set<ObjectName> lookupConfigBeans(final String moduleName) {
        if (moduleName.equals(moduleName1)) {
            return Sets.newHashSet(conf1, conf2);
        } else if (moduleName.equals(moduleName2)) {
            return Sets.newHashSet(conf3);
        } else {
            return null;
        }
    }

    @Override
    public Set<ObjectName> lookupConfigBeans(final String moduleName,
            final String instanceName) {
        if (moduleName.equals(moduleName1) && instanceName.equals(instName1)) {
            return Sets.newHashSet(conf2);
        } else if (moduleName.equals(moduleName2)
                && instanceName.equals(instName2)) {
            return Sets.newHashSet(conf3);
        } else {
            return null;
        }
    }

    @Override
    public ObjectName lookupConfigBean(final String moduleName, final String instanceName)
            throws InstanceNotFoundException {
        if (moduleName.equals(InstanceNotFoundException.class.getSimpleName())) {
            throw new InstanceNotFoundException();
        }
        return conf3;
    }

    @Override
    public Set<ObjectName> lookupRuntimeBeans() {
        return Sets.<ObjectName> newHashSet(run1, run2, run3);
    }

    @Override
    public Set<ObjectName> lookupRuntimeBeans(final String moduleName,
            final String instanceName) {
        if (moduleName.equals(moduleName1) && instanceName.equals(instName1)) {
            return Sets.<ObjectName> newHashSet(run2);
        } else if (moduleName.equals(moduleName2)
                && instanceName.equals(instName2)) {
            return Sets.<ObjectName> newHashSet(run3);
        } else {
            return Sets.<ObjectName> newHashSet();
        }
    }

    @Override
    public void checkConfigBeanExists(final ObjectName objectName) throws InstanceNotFoundException {
        Set<ObjectName> configBeans = Sets.<ObjectName> newHashSet(run1, run2, run3);
        if(configBeans.size()>0){
            checkBool = true;
        }
    }

    @Override
    public ObjectName lookupConfigBeanByServiceInterfaceName(final String serviceInterfaceQName, final String refName) {
        if (serviceInterfaceQName.equals(serviceQName1) && refName.equals(refName1)) {
            return conf1;
        }
        else{
            return null;
        }
    }

    @Override
    public Map<String, Map<String, ObjectName>> getServiceMapping() {
        return null;
    }

    @Override
    public Map<String, ObjectName> lookupServiceReferencesByServiceInterfaceName(final String serviceInterfaceQName) {

        if(serviceInterfaceQName.equals(serviceQName1)){
            map.put("conf1", conf1);
        }
        else if(serviceInterfaceQName.equals(serviceQName2)){
            map.put("conf2", conf2);
        }
        else{
            map.put("conf3", conf3);
        }
        return map;
    }

    @Override
    public Set<String> lookupServiceInterfaceNames(final ObjectName objectName) throws InstanceNotFoundException {
        return Sets.<String> newHashSet(serviceQName1, serviceQName2);
    }

    @Override
    public String getServiceInterfaceName(final String namespace, final String localName) {
        return null;
    }

    @Override
    public Set<String> getAvailableModuleFactoryQNames() {
        return Sets.<String> newHashSet(moduleName1, moduleName2);
    }

    @Override
    public ObjectName getServiceReference(final String serviceInterfaceQName, final String refName) throws InstanceNotFoundException {
        return conf1;
    }

    @Override
    public void checkServiceReferenceExists(final ObjectName objectName) throws InstanceNotFoundException {
        throw new UnsupportedOperationException();
    }
}