Should not allow nodes to have same node name
[controller.git] / opendaylight / configuration / integrationtest / src / test / java / org / opendaylight / controller / configuration / internal / ConfigurationIT.java
1 package org.opendaylight.controller.configuration.internal;
2
3 import static org.junit.Assert.assertFalse;
4 import static org.junit.Assert.assertNotNull;
5 import static org.ops4j.pax.exam.CoreOptions.junitBundles;
6 import static org.ops4j.pax.exam.CoreOptions.mavenBundle;
7 import static org.ops4j.pax.exam.CoreOptions.options;
8 import static org.ops4j.pax.exam.CoreOptions.systemPackages;
9 import static org.ops4j.pax.exam.CoreOptions.systemProperty;
10
11 import java.io.File;
12
13 import javax.inject.Inject;
14
15 import org.junit.Assert;
16 import org.junit.Before;
17 import org.junit.Test;
18 import org.junit.runner.RunWith;
19 import org.opendaylight.controller.clustering.services.IClusterServices;
20 import org.opendaylight.controller.configuration.IConfigurationService;
21 import org.opendaylight.controller.sal.utils.GlobalConstants;
22 import org.opendaylight.controller.sal.utils.Status;
23 import org.opendaylight.controller.sal.utils.StatusCode;
24 import org.ops4j.pax.exam.Option;
25 import org.ops4j.pax.exam.junit.Configuration;
26 import org.ops4j.pax.exam.junit.PaxExam;
27 import org.ops4j.pax.exam.util.PathUtils;
28 import org.osgi.framework.Bundle;
29 import org.osgi.framework.BundleContext;
30 import org.osgi.framework.ServiceReference;
31 import org.slf4j.Logger;
32 import org.slf4j.LoggerFactory;
33
34 @RunWith(PaxExam.class)
35 public class ConfigurationIT {
36     private final Logger logger = LoggerFactory
37             .getLogger(ConfigurationIT.class);
38     // get the OSGI bundle context
39     @Inject
40     private BundleContext bc;
41     private IClusterServices clusterService = null;
42     private IConfigurationService configService = null;
43
44     // Configure the OSGi container
45     @Configuration
46     public Option[] config() {
47         return options(
48                 systemProperty("logback.configurationFile").value(
49                         "file:" + PathUtils.getBaseDir()
50                                 + "/src/test/resources/logback.xml"),
51                 // To start OSGi console for inspection remotely
52                 systemProperty("osgi.console").value("2401"),
53                 // Set the systemPackages (used by clustering)
54                 systemPackages("sun.reflect", "sun.reflect.misc", "sun.misc"),
55                 // List framework bundles
56                 mavenBundle("equinoxSDK381", "org.eclipse.equinox.console",
57                         "1.0.0.v20120522-1841"),
58                 mavenBundle("equinoxSDK381", "org.eclipse.equinox.util",
59                         "1.0.400.v20120522-2049"),
60                 mavenBundle("equinoxSDK381", "org.eclipse.osgi.services",
61                         "3.3.100.v20120522-1822"),
62                 mavenBundle("equinoxSDK381", "org.eclipse.equinox.ds",
63                         "1.4.0.v20120522-1841"),
64                 mavenBundle("equinoxSDK381", "org.apache.felix.gogo.command",
65                         "0.8.0.v201108120515"),
66                 mavenBundle("equinoxSDK381", "org.apache.felix.gogo.runtime",
67                         "0.8.0.v201108120515"),
68                 mavenBundle("equinoxSDK381", "org.apache.felix.gogo.shell",
69                         "0.8.0.v201110170705"),
70                 // List logger bundles
71                 mavenBundle("org.slf4j", "slf4j-api", "1.7.2"),
72                 mavenBundle("org.slf4j", "log4j-over-slf4j", "1.7.2"),
73                 mavenBundle("ch.qos.logback", "logback-core", "1.0.9"),
74                 mavenBundle("ch.qos.logback", "logback-classic", "1.0.9"),
75                 mavenBundle("org.apache.commons", "commons-lang3", "3.1"),
76                 mavenBundle("org.jboss.spec.javax.transaction",
77                         "jboss-transaction-api_1.1_spec", "1.0.1.Final"),
78                 mavenBundle("eclipselink", "javax.resource").versionAsInProject(),
79                 mavenBundle("org.apache.felix",
80                         "org.apache.felix.dependencymanager", "3.1.0"),
81                 // List all the bundles on which the test case depends
82                 mavenBundle("org.opendaylight.controller", "sal",
83                         "0.5.0-SNAPSHOT"), // SAL connects the protocols
84                                            // plug-ins to other stuff
85                 mavenBundle("org.opendaylight.controller",
86                         "sal.implementation", "0.4.0-SNAPSHOT"),
87                 mavenBundle("org.opendaylight.controller",
88                         "protocol_plugins.stub", "0.4.0-SNAPSHOT"),
89                 // needed bundles by switchmanager
90                 mavenBundle("org.opendaylight.controller", "containermanager",
91                         "0.4.0-SNAPSHOT"),
92                 mavenBundle("org.opendaylight.controller",
93                         "containermanager.implementation", "0.4.0-SNAPSHOT"),
94                 // needed bundles by configuration
95                 mavenBundle("org.opendaylight.controller",
96                         "clustering.services", "0.4.0-SNAPSHOT"), // what are
97                                                                   // the
98                                                                   // clustering
99                                                                   // services
100                                                                   // for
101                 mavenBundle("org.opendaylight.controller", "clustering.stub",
102                         "0.4.0-SNAPSHOT"),
103                 mavenBundle("org.opendaylight.controller",
104                         "clustering.services-implementation", "0.4.0-SNAPSHOT"),
105                 mavenBundle("org.opendaylight.controller", "configuration",
106                         "0.4.0-SNAPSHOT"),
107                 mavenBundle("org.opendaylight.controller",
108                         "configuration.implementation", "0.4.0-SNAPSHOT"),
109                 junitBundles());
110     }
111
112     private String stateToString(int state) {
113         switch (state) {
114         case Bundle.ACTIVE:
115             return "ACTIVE";
116         case Bundle.INSTALLED:
117             return "INSTALLED";
118         case Bundle.RESOLVED:
119             return "RESOLVED";
120         case Bundle.UNINSTALLED:
121             return "UNINSTALLED";
122         default:
123             return "Not CONVERTED";
124         }
125     }
126
127     @Before
128     public void areWeReadyForClustering() {
129         assertNotNull(bc);
130         boolean debugit = false;
131         Bundle b[] = bc.getBundles();
132         for (int i = 0; i < b.length; i++) {
133             int state = b[i].getState();
134             if (state != Bundle.ACTIVE && state != Bundle.RESOLVED) {
135                 logger.debug("Bundle:" + b[i].getSymbolicName() + " state:"
136                         + stateToString(state));
137                 debugit = true;
138             }
139         }
140         if (debugit) {
141             logger.debug("Do some debugging because some bundle is unresolved");
142         }
143
144         // Assert if true, if false we are good to go!
145         assertFalse(debugit);
146         ServiceReference r = bc.getServiceReference(IClusterServices.class
147                 .getName());
148         if (r != null) {
149             this.clusterService = (IClusterServices) bc.getService(r);
150         }
151         // If StatisticsManager is null, cannot run tests.
152         assertNotNull(this.clusterService);
153
154     }
155
156     @Before
157     public void areWeReadyForConfiguration() {
158         assertNotNull(bc);
159         boolean debugit = false;
160         Bundle b[] = bc.getBundles();
161         for (int i = 0; i < b.length; i++) {
162             int state = b[i].getState();
163             if (state != Bundle.ACTIVE && state != Bundle.RESOLVED) {
164                 logger.debug("Bundle:" + b[i].getSymbolicName() + " state:"
165                         + stateToString(state));
166                 debugit = true;
167             }
168         }
169         if (debugit) {
170             logger.debug("Do some debugging because some bundle is unresolved");
171         }
172
173         // Assert if true, if false we are good to go!
174         assertFalse(debugit);
175         ServiceReference r = bc.getServiceReference(IConfigurationService.class
176                 .getName());
177         if (r != null) {
178             this.configService = (IConfigurationService) bc.getService(r);
179         }
180         // If StatisticsManager is null, cannot run tests.
181         assertNotNull(this.configService);
182
183     }
184
185     @Test
186     public void saveConfiguration() {
187         File f = new File(GlobalConstants.STARTUPHOME.toString());
188         boolean success = f.exists();
189         if (!success) {
190             success = f.mkdirs();
191         }
192         if(success){
193             Status status = new Status(StatusCode.SUCCESS, null);
194             if (this.configService != null) {
195                 status = this.configService.saveConfigurations();
196             }
197             if (status.getCode().equals(StatusCode.SUCCESS)) {
198                 Assert.assertTrue("Successfully saved config for "
199                         + configService.getClass().getSimpleName(), status
200                         .getCode().equals(StatusCode.SUCCESS));
201             } else {
202                 Assert.assertFalse("Failed to save config for "
203                         + configService.getClass().getSimpleName(), status
204                         .getCode().equals(StatusCode.INTERNALERROR));
205             }
206         }
207     }
208
209 }