2 * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.controller.config.yang.test.impl;
10 import com.google.common.collect.Lists;
12 import org.junit.Before;
13 import org.junit.Test;
14 import org.opendaylight.controller.config.api.IdentityAttributeRef;
15 import org.opendaylight.controller.config.api.jmx.CommitStatus;
16 import org.opendaylight.controller.config.api.jmx.ObjectNameUtil;
17 import org.opendaylight.controller.config.manager.impl.AbstractConfigTest;
18 import org.opendaylight.controller.config.manager.impl.factoriesresolver.HardcodedModuleFactoriesResolver;
19 import org.opendaylight.controller.config.util.ConfigTransactionJMXClient;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.config.test.types.rev131127.TestIdentity1;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.config.test.types.rev131127.TestIdentity2;
22 import org.opendaylight.yangtools.yang.data.impl.codec.CodecRegistry;
23 import org.opendaylight.yangtools.yang.data.impl.codec.IdentityCodec;
25 import javax.management.InstanceAlreadyExistsException;
26 import javax.management.ObjectName;
28 import java.util.ArrayList;
29 import java.util.Collections;
30 import java.util.List;
32 import static org.junit.Assert.assertEquals;
33 import static org.junit.Assert.assertNotNull;
34 import static org.junit.Assert.assertTrue;
35 import static org.junit.Assert.fail;
36 import static org.mockito.Mockito.doReturn;
37 import static org.mockito.Mockito.mock;
39 public class NetconfTestImplModuleTest extends AbstractConfigTest {
41 public static final String TESTING_DEP_PREFIX = "testing-dep";
42 private NetconfTestImplModuleFactory factory;
43 private final String instanceName = "n1";
48 factory = new NetconfTestImplModuleFactory();
49 super.initConfigTransactionManagerImpl(new HardcodedModuleFactoriesResolver(mockedContext,factory,
50 new DepTestImplModuleFactory(), new IdentityTestModuleFactory()));
54 protected CodecRegistry getCodecRegistry() {
55 final IdentityCodec<?> codec = mock(IdentityCodec.class);
56 doReturn(TestIdentity1.class).when(codec).deserialize(TestIdentity1.QNAME);
57 doReturn(TestIdentity2.class).when(codec).deserialize(TestIdentity2.QNAME);
59 final CodecRegistry ret = super.getCodecRegistry();
60 doReturn(codec).when(ret).getIdentityCodec();
65 public void testIdentities() throws Exception {
66 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
68 ObjectName nameCreated = transaction.createModule(IdentityTestModuleFactory.NAME, instanceName);
69 IdentityTestModuleMXBean mxBean = transaction.newMXBeanProxy(nameCreated, IdentityTestModuleMXBean.class);
71 final IdentitiesContainer c = new IdentitiesContainer();
72 c.setAfi(new IdentityAttributeRef(TestIdentity2.QNAME.toString()));
73 mxBean.setIdentitiesContainer(c);
78 public void testDependencyList() throws Exception {
79 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
81 ObjectName on = createInstance(transaction, instanceName, 4);
82 transaction.validateConfig();
83 CommitStatus status1 = transaction.commit();
85 assertBeanCount(1, factory.getImplementationName());
86 assertBeanCount(4 + 1, DepTestImplModuleFactory.NAME);
87 assertStatus(status1, 1 + 4 + 1, 0, 0);
89 transaction = configRegistryClient.createTransaction();
91 NetconfTestImplModuleMXBean proxy = transaction.newMXBeanProxy(ObjectNameUtil.withoutTransactionName(on),
92 NetconfTestImplModuleMXBean.class);
93 proxy.getComplexList();
94 List<ObjectName> testingDeps = proxy.getTestingDeps();
95 ObjectName testingDep = proxy.getTestingDep();
97 assertEquals(TESTING_DEP_PREFIX, ObjectNameUtil.getInstanceName(testingDep));
98 assertTestingDeps(testingDeps, 4);
100 transaction.abortConfig();
102 // check that reuse logic works - equals on list of dependencies.
103 transaction = configRegistryClient.createTransaction();
104 CommitStatus status2 = transaction.commit();
105 assertStatus(status2, 0, 0, 6);
107 // replace single dependency
108 transaction = configRegistryClient.createTransaction();
109 String instanceName1 = TESTING_DEP_PREFIX + 1;
110 transaction.destroyModule(DepTestImplModuleFactory.NAME, instanceName1);
111 transaction.createModule(DepTestImplModuleFactory.NAME, instanceName1);
112 CommitStatus status3 = transaction.commit();
113 assertStatus(status3, 1, 1, 4);
118 public void testNullCheckInListOfDependencies() throws Exception {
119 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
121 ObjectName on = createInstance(transaction, instanceName, 4);
122 NetconfTestImplModuleMXBean proxy = transaction.newMXBeanProxy(on, NetconfTestImplModuleMXBean.class);
124 proxy.setTestingDeps(null);
126 }catch(RuntimeException e) {
127 Throwable cause = e.getCause();
128 assertNotNull(cause);
129 assertTrue("Invalid type " + cause, cause instanceof IllegalArgumentException);
130 assertEquals("Null not supported", cause.getMessage());
132 proxy.setTestingDeps(Collections.<ObjectName>emptyList());
135 private void assertTestingDeps(List<ObjectName> testingDeps, int i) {
136 assertEquals(i, testingDeps.size());
139 for (ObjectName testingDep : testingDeps) {
140 assertEquals(TESTING_DEP_PREFIX + Integer.toString(c++), ObjectNameUtil.getInstanceName(testingDep));
145 private ObjectName createInstance(ConfigTransactionJMXClient transaction, String instanceName, int depsCount)
146 throws InstanceAlreadyExistsException {
147 ObjectName nameCreated = transaction.createModule(factory.getImplementationName(), instanceName);
148 NetconfTestImplModuleMXBean mxBean = transaction.newMXBeanProxy(nameCreated, NetconfTestImplModuleMXBean.class);
150 ObjectName dep = transaction.createModule(DepTestImplModuleFactory.NAME, TESTING_DEP_PREFIX);
151 mxBean.setTestingDep(dep);
153 ArrayList<ObjectName> testingDeps = Lists.newArrayList();
154 for (int i = 0; i < depsCount; i++) {
155 dep = transaction.createModule(DepTestImplModuleFactory.NAME, TESTING_DEP_PREFIX + Integer.toString(i + 1));
156 testingDeps.add(dep);
158 mxBean.setTestingDeps(testingDeps);