package org.opendaylight.controller.northbound.integrationtest; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.osgi.framework.ServiceReference; import org.osgi.framework.Bundle; import javax.inject.Inject; import org.junit.Assert; import org.junit.Test; import org.junit.Before; import org.junit.runner.RunWith; import org.ops4j.pax.exam.junit.PaxExam; import org.osgi.framework.BundleContext; import static org.junit.Assert.*; import org.ops4j.pax.exam.junit.Configuration; import static org.ops4j.pax.exam.CoreOptions.*; import org.ops4j.pax.exam.Option; import org.ops4j.pax.exam.util.PathUtils; import java.io.BufferedReader; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.net.HttpURLConnection; import java.net.URL; import java.nio.charset.Charset; import java.util.Arrays; import org.apache.commons.codec.binary.Base64; import org.codehaus.jettison.json.JSONArray; import org.codehaus.jettison.json.JSONException; import org.codehaus.jettison.json.JSONObject; import org.codehaus.jettison.json.JSONTokener; import org.opendaylight.controller.hosttracker.IfIptoHost; import org.opendaylight.controller.sal.core.ConstructionException; import org.opendaylight.controller.sal.core.Node; import org.opendaylight.controller.sal.core.NodeConnector; import org.opendaylight.controller.sal.core.UpdateType; import org.opendaylight.controller.switchmanager.IInventoryListener; import org.opendaylight.controller.usermanager.IUserManager; @RunWith(PaxExam.class) public class NorthboundIT { private Logger log = LoggerFactory .getLogger(NorthboundIT.class); // get the OSGI bundle context @Inject private BundleContext bc; private IUserManager users = null; private IInventoryListener invtoryListener = null; private String stateToString(int state) { switch (state) { case Bundle.ACTIVE: return "ACTIVE"; case Bundle.INSTALLED: return "INSTALLED"; case Bundle.RESOLVED: return "RESOLVED"; case Bundle.UNINSTALLED: return "UNINSTALLED"; default: return "Not CONVERTED"; } } @Before public void areWeReady() { assertNotNull(bc); boolean debugit = false; Bundle b[] = bc.getBundles(); for (int i = 0; i < b.length; i++) { int state = b[i].getState(); if (state != Bundle.ACTIVE && state != Bundle.RESOLVED) { log.debug("Bundle:" + b[i].getSymbolicName() + " state:" + stateToString(state)); debugit = true; } } if (debugit) { log.debug("Do some debugging because some bundle is " + "unresolved"); } // Assert if true, if false we are good to go! assertFalse(debugit); ServiceReference r = bc.getServiceReference(IUserManager.class .getName()); if (r != null) { this.users = (IUserManager) bc.getService(r); } // If UserManager is null, cannot login to run tests. assertNotNull(this.users); r = bc.getServiceReference(IfIptoHost.class.getName()); if (r != null) { this.invtoryListener = (IInventoryListener) bc.getService(r); } // If inventoryListener is null, cannot run hosttracker tests. assertNotNull(this.invtoryListener); } // static variable to pass response code from getJsonResult() private static Integer httpResponseCode = null; private String getJsonResult(String restUrl) { return getJsonResult(restUrl, "GET", null); } private String getJsonResult(String restUrl, String method) { return getJsonResult(restUrl, method, null); } private String getJsonResult(String restUrl, String method, String body) { // initialize response code to indicate error httpResponseCode = 400; try { URL url = new URL(restUrl); this.users.getAuthorizationList(); this.users.authenticate("admin", "admin"); String authString = "admin:admin"; byte[] authEncBytes = Base64.encodeBase64(authString.getBytes()); String authStringEnc = new String(authEncBytes); HttpURLConnection connection = (HttpURLConnection) url .openConnection(); connection.setRequestMethod(method); connection.setRequestProperty("Authorization", "Basic " + authStringEnc); connection.setRequestProperty("Content-Type", "application/json"); connection.setRequestProperty("Accept", "application/json"); if (body != null) { connection.setDoOutput(true); OutputStreamWriter wr = new OutputStreamWriter( connection.getOutputStream()); wr.write(body); wr.flush(); } connection.connect(); connection.getContentType(); // Response code for success should be 2xx httpResponseCode = connection.getResponseCode(); if (httpResponseCode > 299) return httpResponseCode.toString(); InputStream is = connection.getInputStream(); BufferedReader rd = new BufferedReader(new InputStreamReader(is, Charset.forName("UTF-8"))); StringBuilder sb = new StringBuilder(); int cp; while ((cp = rd.read()) != -1) { sb.append((char) cp); } is.close(); connection.disconnect(); return sb.toString(); } catch (Exception e) { return null; } } @Test public void testStatistics() { String actionTypes[] = { "drop", "loopback", "flood", "floodAll", "controller", "swPath", "hwPath", "output", "setDlSrc", "setDlDst", "setDlType", "setVlanId", "setVlanPcp", "setVlanCfi", "popVlan", "pushVlan", "setNwSrc", "setNwDst", "setNwTos", "setTpSrc", "setTpDst" }; System.out.println("Starting Statistics JAXB client."); String baseURL = "http://127.0.0.1:8080/controller/nb/v2/statistics/default/"; try { String result = getJsonResult(baseURL + "flowstats"); JSONTokener jt = new JSONTokener(result); JSONObject json = new JSONObject(jt); JSONObject flowStatistics = getJsonInstance(json, "flowStatistics", 0xCAFE); JSONObject node = flowStatistics.getJSONObject("node"); // test that node was returned properly Assert.assertTrue(node.getInt("@id") == 0xCAFE); Assert.assertTrue(node.getString("@type").equals("STUB")); // test that flow statistics results are correct JSONArray flowStats = flowStatistics.getJSONArray("flowStat"); for (int i = 0; i < flowStats.length(); i++) { JSONObject flowStat = flowStats.getJSONObject(i); testFlowStat(flowStat, actionTypes[i]); } // for /controller/nb/v2/statistics/default/portstats result = getJsonResult(baseURL + "portstats"); jt = new JSONTokener(result); json = new JSONObject(jt); JSONObject portStatistics = getJsonInstance(json, "portStatistics", 0xCAFE); JSONObject node2 = portStatistics.getJSONObject("node"); // test that node was returned properly Assert.assertTrue(node2.getInt("@id") == 0xCAFE); Assert.assertTrue(node2.getString("@type").equals("STUB")); // test that port statistic results are correct JSONObject portStat = portStatistics.getJSONObject("portStat"); Assert.assertTrue(portStat.getInt("receivePackets") == 250); Assert.assertTrue(portStat.getInt("transmitPackets") == 500); Assert.assertTrue(portStat.getInt("receiveBytes") == 1000); Assert.assertTrue(portStat.getInt("transmitBytes") == 5000); Assert.assertTrue(portStat.getInt("receiveDrops") == 2); Assert.assertTrue(portStat.getInt("transmitDrops") == 50); Assert.assertTrue(portStat.getInt("receiveErrors") == 3); Assert.assertTrue(portStat.getInt("transmitErrors") == 10); Assert.assertTrue(portStat.getInt("receiveFrameError") == 5); Assert.assertTrue(portStat.getInt("receiveOverRunError") == 6); Assert.assertTrue(portStat.getInt("receiveCrcError") == 1); Assert.assertTrue(portStat.getInt("collisionCount") == 4); // test for getting one specific node's stats result = getJsonResult(baseURL + "flowstats/STUB/51966"); jt = new JSONTokener(result); json = new JSONObject(jt); node = json.getJSONObject("node"); // test that node was returned properly Assert.assertTrue(node.getInt("@id") == 0xCAFE); Assert.assertTrue(node.getString("@type").equals("STUB")); // test that flow statistics results are correct flowStats = json.getJSONArray("flowStat"); for (int i = 0; i < flowStats.length(); i++) { JSONObject flowStat = flowStats.getJSONObject(i); testFlowStat(flowStat, actionTypes[i]); } result = getJsonResult(baseURL + "portstats/STUB/51966"); jt = new JSONTokener(result); json = new JSONObject(jt); node2 = json.getJSONObject("node"); // test that node was returned properly Assert.assertTrue(node2.getInt("@id") == 0xCAFE); Assert.assertTrue(node2.getString("@type").equals("STUB")); // test that port statistic results are correct portStat = json.getJSONObject("portStat"); Assert.assertTrue(portStat.getInt("receivePackets") == 250); Assert.assertTrue(portStat.getInt("transmitPackets") == 500); Assert.assertTrue(portStat.getInt("receiveBytes") == 1000); Assert.assertTrue(portStat.getInt("transmitBytes") == 5000); Assert.assertTrue(portStat.getInt("receiveDrops") == 2); Assert.assertTrue(portStat.getInt("transmitDrops") == 50); Assert.assertTrue(portStat.getInt("receiveErrors") == 3); Assert.assertTrue(portStat.getInt("transmitErrors") == 10); Assert.assertTrue(portStat.getInt("receiveFrameError") == 5); Assert.assertTrue(portStat.getInt("receiveOverRunError") == 6); Assert.assertTrue(portStat.getInt("receiveCrcError") == 1); Assert.assertTrue(portStat.getInt("collisionCount") == 4); } catch (Exception e) { // Got an unexpected exception Assert.assertTrue(false); } } private void testFlowStat(JSONObject flowStat, String actionType) { try { Assert.assertTrue(flowStat.getInt("tableId") == 1); Assert.assertTrue(flowStat.getInt("durationSeconds") == 40); Assert.assertTrue(flowStat.getInt("durationNanoseconds") == 400); Assert.assertTrue(flowStat.getInt("packetCount") == 200); Assert.assertTrue(flowStat.getInt("byteCount") == 100); // test that flow information is correct JSONObject flow = flowStat.getJSONObject("flow"); Assert.assertTrue(flow.getInt("priority") == 3500); Assert.assertTrue(flow.getInt("idleTimeout") == 1000); Assert.assertTrue(flow.getInt("hardTimeout") == 2000); Assert.assertTrue(flow.getInt("id") == 12345); JSONObject match = (flow.getJSONObject("match") .getJSONObject("matchField")); Assert.assertTrue(match.getString("type").equals("NW_DST")); Assert.assertTrue(match.getString("value").equals("1.1.1.1")); JSONObject act = flow.getJSONObject("actions"); Assert.assertTrue(act.getString("@type").equals(actionType)); if (act.getString("@type").equals("output")) { JSONObject port = act.getJSONObject("port"); JSONObject port_node = port.getJSONObject("node"); Assert.assertTrue(port.getInt("@id") == 51966); Assert.assertTrue(port.getString("@type").equals("STUB")); Assert.assertTrue(port_node.getInt("@id") == 51966); Assert.assertTrue(port_node.getString("@type").equals("STUB")); } if (act.getString("@type").equals("setDlSrc")) { byte srcMatch[] = { (byte) 5, (byte) 4, (byte) 3, (byte) 2, (byte) 1 }; String src = act.getString("address"); byte srcBytes[] = new byte[5]; srcBytes[0] = Byte.parseByte(src.substring(0, 2)); srcBytes[1] = Byte.parseByte(src.substring(2, 4)); srcBytes[2] = Byte.parseByte(src.substring(4, 6)); srcBytes[3] = Byte.parseByte(src.substring(6, 8)); srcBytes[4] = Byte.parseByte(src.substring(8, 10)); Assert.assertTrue(Arrays.equals(srcBytes, srcMatch)); } if (act.getString("@type").equals("setDlDst")) { byte dstMatch[] = { (byte) 1, (byte) 2, (byte) 3, (byte) 4, (byte) 5 }; String dst = act.getString("address"); byte dstBytes[] = new byte[5]; dstBytes[0] = Byte.parseByte(dst.substring(0, 2)); dstBytes[1] = Byte.parseByte(dst.substring(2, 4)); dstBytes[2] = Byte.parseByte(dst.substring(4, 6)); dstBytes[3] = Byte.parseByte(dst.substring(6, 8)); dstBytes[4] = Byte.parseByte(dst.substring(8, 10)); Assert.assertTrue(Arrays.equals(dstBytes, dstMatch)); } if (act.getString("@type").equals("setDlType")) Assert.assertTrue(act.getInt("dlType") == 10); if (act.getString("@type").equals("setVlanId")) Assert.assertTrue(act.getInt("vlanId") == 2); if (act.getString("@type").equals("setVlanPcp")) Assert.assertTrue(act.getInt("pcp") == 3); if (act.getString("@type").equals("setVlanCfi")) Assert.assertTrue(act.getInt("cfi") == 1); if (act.getString("@type").equals("setNwSrc")) Assert.assertTrue(act.getString("address").equals("2.2.2.2")); if (act.getString("@type").equals("setNwDst")) Assert.assertTrue(act.getString("address").equals("1.1.1.1")); if (act.getString("@type").equals("pushVlan")) { int head = act.getInt("VlanHeader"); // parsing vlan header int id = head & 0xfff; int cfi = (head >> 12) & 0x1; int pcp = (head >> 13) & 0x7; int tag = (head >> 16) & 0xffff; Assert.assertTrue(id == 1234); Assert.assertTrue(cfi == 1); Assert.assertTrue(pcp == 1); Assert.assertTrue(tag == 0x8100); } if (act.getString("@type").equals("setNwTos")) Assert.assertTrue(act.getInt("tos") == 16); if (act.getString("@type").equals("setTpSrc")) Assert.assertTrue(act.getInt("port") == 4201); if (act.getString("@type").equals("setTpDst")) Assert.assertTrue(act.getInt("port") == 8080); } catch (Exception e) { Assert.assertTrue(false); } } @Test public void testFlowProgrammer() { try { String baseURL = "http://127.0.0.1:8080/controller/nb/v2/flow/default/"; // Attempt to get a flow that doesn't exit. Should return 404 // status. String result = getJsonResult(baseURL + "STUB/51966/test1", "GET"); Assert.assertTrue(result.equals("404")); // test add flow1 String fc = "{\"dynamic\":\"false\", \"name\":\"test1\", \"node\":{\"@id\":\"51966\",\"@type\":\"STUB\"}, \"actions\":[\"DROP\"]}"; result = getJsonResult(baseURL + "STUB/51966/test1", "POST", fc); Assert.assertTrue(httpResponseCode == 201); // test get returns flow that was added. result = getJsonResult(baseURL + "STUB/51966/test1", "GET"); // check that result came out fine. Assert.assertTrue(httpResponseCode == 200); JSONTokener jt = new JSONTokener(result); JSONObject json = new JSONObject(jt); Assert.assertTrue(json.getString("name").equals("test1")); Assert.assertTrue(json.getString("actions").equals("DROP")); Assert.assertTrue(json.getString("installInHw").equals("true")); JSONObject node = json.getJSONObject("node"); Assert.assertTrue(node.getString("@type").equals("STUB")); Assert.assertTrue(node.getString("@id").equals("51966")); // test adding same flow again fails due to repeat name..return 409 // code result = getJsonResult(baseURL + "STUB/51966/test1", "POST", fc); Assert.assertTrue(result.equals("409")); fc = "{\"dynamic\":\"false\", \"name\":\"test2\", \"node\":{\"@id\":\"51966\",\"@type\":\"STUB\"}, \"actions\":[\"DROP\"]}"; result = getJsonResult(baseURL + "STUB/51966/test2", "POST", fc); // test should return 500 for error due to same flow being added. Assert.assertTrue(result.equals("500")); // add second flow that's different fc = "{\"dynamic\":\"false\", \"name\":\"test2\", \"nwSrc\":\"1.1.1.1\", \"node\":{\"@id\":\"51966\",\"@type\":\"STUB\"}, \"actions\":[\"DROP\"]}"; result = getJsonResult(baseURL + "STUB/51966/test2", "POST", fc); Assert.assertTrue(httpResponseCode == 201); // check that request returns both flows given node. result = getJsonResult(baseURL + "STUB/51966/", "GET"); jt = new JSONTokener(result); json = new JSONObject(jt); Assert.assertTrue(json.get("flowConfig") instanceof JSONArray); JSONArray ja = json.getJSONArray("flowConfig"); Integer count = ja.length(); Assert.assertTrue(count == 2); // check that request returns both flows given just container. result = getJsonResult(baseURL); jt = new JSONTokener(result); json = new JSONObject(jt); Assert.assertTrue(json.get("flowConfig") instanceof JSONArray); ja = json.getJSONArray("flowConfig"); count = ja.length(); Assert.assertTrue(count == 2); // delete a flow, check that it's no longer in list. result = getJsonResult(baseURL + "STUB/51966/test2", "DELETE"); Assert.assertTrue(httpResponseCode == 200); result = getJsonResult(baseURL + "STUB/51966/test2", "GET"); Assert.assertTrue(result.equals("404")); } catch (Exception e) { Assert.assertTrue(false); } } // method to extract a JSONObject with specified node ID from a JSONObject // that may contain an array of JSONObjects // This is specifically written for statistics manager northbound REST // interface // array_name should be either "flowStatistics" or "portStatistics" private JSONObject getJsonInstance(JSONObject json, String array_name, Integer nodeId) throws JSONException { JSONObject result = null; if (json.get(array_name) instanceof JSONArray) { JSONArray json_array = json.getJSONArray(array_name); for (int i = 0; i < json_array.length(); i++) { result = json_array.getJSONObject(i); Integer nid = result.getJSONObject("node").getInt("@id"); if (nid.equals(nodeId)) break; } } else { result = json.getJSONObject(array_name); Integer nid = result.getJSONObject("node").getInt("@id"); if (!nid.equals(nodeId)) result = null; } return result; } // a class to construct query parameter for HTTP request private class QueryParameter { StringBuilder queryString = null; // constructor QueryParameter(String key, String value) { queryString = new StringBuilder(); queryString.append("?").append(key).append("=").append(value); } // method to add more query parameter QueryParameter add(String key, String value) { this.queryString.append("&").append(key).append("=").append(value); return this; } // method to get the query parameter string String getString() { return this.queryString.toString(); } } @Test public void testHostTracker() { System.out.println("Starting HostTracker JAXB client."); // setup 2 host models for @POST method // 1st host String networkAddress_1 = "192.168.0.8"; String dataLayerAddress_1 = "11:22:33:44:55:66"; String nodeType_1 = "STUB"; Integer nodeId_1 = 3366; String nodeConnectorType_1 = "STUB"; Integer nodeConnectorId_1 = 12; String vlan_1 = "4"; // 2nd host String networkAddress_2 = "10.1.1.1"; String dataLayerAddress_2 = "1A:2B:3C:4D:5E:6F"; String nodeType_2 = "STUB"; Integer nodeId_2 = 4477; String nodeConnectorType_2 = "STUB"; Integer nodeConnectorId_2 = 34; String vlan_2 = "0"; String baseURL = "http://127.0.0.1:8080/controller/nb/v2/host/default"; // test POST method: addHost() try { String queryParameter = new QueryParameter("dataLayerAddress", dataLayerAddress_1).add("nodeType", nodeType_1) .add("nodeId", nodeId_1.toString()) .add("nodeConnectorType", nodeConnectorType_1) .add("nodeConnectorId", nodeConnectorId_1.toString()) .add("vlan", vlan_1).getString(); String result = getJsonResult(baseURL + "/" + networkAddress_1 + queryParameter, "POST"); Assert.assertTrue(httpResponseCode.intValue() == (Integer) 201); // vlan is not passed through query parameter but should be // defaulted to "0" queryParameter = new QueryParameter("dataLayerAddress", dataLayerAddress_2).add("nodeType", nodeType_2) .add("nodeId", nodeId_2.toString()) .add("nodeConnectorType", nodeConnectorType_2) .add("nodeConnectorId", nodeConnectorId_2.toString()) .getString(); result = getJsonResult(baseURL + "/" + networkAddress_2 + queryParameter, "POST"); Assert.assertTrue(httpResponseCode.intValue() == (Integer) 201); } catch (Exception e) { // Got an unexpected exception Assert.assertTrue(false); } // define variables for decoding returned strings String networkAddress; JSONObject host_jo, dl_jo, nc_jo, node_jo; // the two hosts should be in inactive host DB // test GET method: getInactiveHosts() try { String result = getJsonResult(baseURL + "/inactive", "GET"); Assert.assertTrue(httpResponseCode.intValue() == (Integer) 200); JSONTokener jt = new JSONTokener(result); JSONObject json = new JSONObject(jt); // there should be at least two hosts in the DB Assert.assertTrue(json.get("host") instanceof JSONArray); JSONArray ja = json.getJSONArray("host"); Integer count = ja.length(); Assert.assertTrue(count == 2); for (int i = 0; i < count; i++) { host_jo = ja.getJSONObject(i); dl_jo = host_jo.getJSONObject("dataLayerAddress"); nc_jo = host_jo.getJSONObject("nodeConnector"); node_jo = nc_jo.getJSONObject("node"); networkAddress = host_jo.getString("networkAddress"); if (networkAddress.equalsIgnoreCase(networkAddress_1)) { Assert.assertTrue(dl_jo.getString("macAddress") .equalsIgnoreCase(dataLayerAddress_1)); Assert.assertTrue(nc_jo.getString("@type") .equalsIgnoreCase(nodeConnectorType_1)); Assert.assertTrue(Integer.parseInt(nc_jo.getString("@id")) == nodeConnectorId_1); Assert.assertTrue(node_jo.getString("@type") .equalsIgnoreCase(nodeType_1)); Assert.assertTrue(Integer.parseInt(node_jo.getString("@id")) == nodeId_1); Assert.assertTrue(host_jo.getString("vlan") .equalsIgnoreCase(vlan_1)); } else if (networkAddress.equalsIgnoreCase(networkAddress_2)) { Assert.assertTrue(dl_jo.getString("macAddress") .equalsIgnoreCase(dataLayerAddress_2)); Assert.assertTrue(nc_jo.getString("@type") .equalsIgnoreCase(nodeConnectorType_2)); Assert.assertTrue(Integer.parseInt(nc_jo.getString("@id")) == nodeConnectorId_2); Assert.assertTrue(node_jo.getString("@type") .equalsIgnoreCase(nodeType_2)); Assert.assertTrue(Integer.parseInt(node_jo.getString("@id")) == nodeId_2); Assert.assertTrue(host_jo.getString("vlan") .equalsIgnoreCase(vlan_2)); } else { Assert.assertTrue(false); } } } catch (Exception e) { // Got an unexpected exception Assert.assertTrue(false); } // test GET method: getActiveHosts() - no host expected try { String result = getJsonResult(baseURL, "GET"); Assert.assertTrue(httpResponseCode.intValue() == (Integer) 200); JSONTokener jt = new JSONTokener(result); JSONObject json = new JSONObject(jt); Assert.assertFalse(hostInJson(json, networkAddress_1)); Assert.assertFalse(hostInJson(json, networkAddress_2)); } catch (Exception e) { // Got an unexpected exception Assert.assertTrue(false); } // put the 1st host into active host DB Node nd; NodeConnector ndc; try { nd = new Node(nodeType_1, nodeId_1); ndc = new NodeConnector(nodeConnectorType_1, nodeConnectorId_1, nd); this.invtoryListener.notifyNodeConnector(ndc, UpdateType.ADDED, null); } catch (ConstructionException e) { ndc = null; nd = null; } // verify the host shows up in active host DB try { String result = getJsonResult(baseURL, "GET"); Assert.assertTrue(httpResponseCode.intValue() == (Integer) 200); JSONTokener jt = new JSONTokener(result); JSONObject json = new JSONObject(jt); Assert.assertTrue(hostInJson(json, networkAddress_1)); } catch (Exception e) { // Got an unexpected exception Assert.assertTrue(false); } // test GET method for getHostDetails() try { String result = getJsonResult(baseURL + "/" + networkAddress_1, "GET"); Assert.assertTrue(httpResponseCode.intValue() == (Integer) 200); JSONTokener jt = new JSONTokener(result); JSONObject json = new JSONObject(jt); Assert.assertFalse(json.length() == 0); dl_jo = json.getJSONObject("dataLayerAddress"); nc_jo = json.getJSONObject("nodeConnector"); node_jo = nc_jo.getJSONObject("node"); Assert.assertTrue(json.getString("networkAddress") .equalsIgnoreCase(networkAddress_1)); Assert.assertTrue(dl_jo.getString("macAddress").equalsIgnoreCase( dataLayerAddress_1)); Assert.assertTrue(nc_jo.getString("@type").equalsIgnoreCase( nodeConnectorType_1)); Assert.assertTrue(Integer.parseInt(nc_jo.getString("@id")) == nodeConnectorId_1); Assert.assertTrue(node_jo.getString("@type").equalsIgnoreCase( nodeType_1)); Assert.assertTrue(Integer.parseInt(node_jo.getString("@id")) == nodeId_1); Assert.assertTrue(json.getString("vlan").equalsIgnoreCase(vlan_1)); } catch (Exception e) { // Got an unexpected exception Assert.assertTrue(false); } // test DELETE method for deleteFlow() try { String result = getJsonResult(baseURL + "/" + networkAddress_1, "DELETE"); Assert.assertTrue(httpResponseCode.intValue() == (Integer) 200); } catch (Exception e) { // Got an unexpected exception Assert.assertTrue(false); } // verify host_1 removed from active host DB // test GET method: getActiveHosts() - no host expected try { String result = getJsonResult(baseURL, "GET"); Assert.assertTrue(httpResponseCode.intValue() == (Integer) 200); JSONTokener jt = new JSONTokener(result); JSONObject json = new JSONObject(jt); Assert.assertFalse(hostInJson(json, networkAddress_1)); } catch (Exception e) { // Got an unexpected exception Assert.assertTrue(false); } } private Boolean hostInJson(JSONObject json, String hostIp) throws JSONException { // input JSONObject may be empty if (json.length() == 0) { return false; } if (json.get("host") instanceof JSONArray) { JSONArray ja = json.getJSONArray("host"); for (int i = 0; i < ja.length(); i++) { String na = ja.getJSONObject(i).getString("networkAddress"); if (na.equalsIgnoreCase(hostIp)) return true; } return false; } else { String na = json.getJSONObject("host").getString("networkAddress"); return (na.equalsIgnoreCase(hostIp)) ? true : false; } } // Configure the OSGi container @Configuration public Option[] config() { return options( // systemProperty("logback.configurationFile").value( "file:" + PathUtils.getBaseDir() + "/src/test/resources/logback.xml"), // To start OSGi console for inspection remotely systemProperty("osgi.console").value("2401"), systemProperty("org.eclipse.gemini.web.tomcat.config.path") .value(PathUtils.getBaseDir() + "/src/test/resources/tomcat-server.xml"), // setting default level. Jersey bundles will need to be started // earlier. systemProperty("osgi.bundles.defaultStartLevel").value("4"), // Set the systemPackages (used by clustering) systemPackages("sun.reflect", "sun.reflect.misc", "sun.misc"), mavenBundle("javax.servlet", "servlet-api", "2.5"), mavenBundle("org.slf4j", "jcl-over-slf4j", "1.7.2"), mavenBundle("org.slf4j", "slf4j-api", "1.7.2"), mavenBundle("org.slf4j", "log4j-over-slf4j", "1.7.2"), mavenBundle("ch.qos.logback", "logback-core", "1.0.9"), mavenBundle("ch.qos.logback", "logback-classic", "1.0.9"), mavenBundle("org.apache.commons", "commons-lang3", "3.1"), mavenBundle("org.apache.felix", "org.apache.felix.dependencymanager", "3.1.0"), // the plugin stub to get data for the tests mavenBundle("org.opendaylight.controller", "protocol_plugins.stub", "0.4.0-SNAPSHOT"), // List all the opendaylight modules mavenBundle("org.opendaylight.controller", "security", "0.4.0-SNAPSHOT").noStart(), mavenBundle("org.opendaylight.controller", "sal", "0.5.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "sal.implementation", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "statisticsmanager", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "statisticsmanager.implementation", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "containermanager", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "containermanager.implementation", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "forwardingrulesmanager", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "forwardingrulesmanager.implementation", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "arphandler", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "clustering.services", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "clustering.services-implementation", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "switchmanager", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "switchmanager.implementation", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "configuration", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "configuration.implementation", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "hosttracker", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "hosttracker.implementation", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "arphandler", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "routing.dijkstra_implementation", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "topologymanager", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "usermanager", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "logging.bridge", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "clustering.test", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "forwarding.staticrouting", "0.4.0-SNAPSHOT"), // Northbound bundles mavenBundle("org.opendaylight.controller", "commons.northbound", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "forwarding.staticrouting.northbound", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "statistics.northbound", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "topology.northbound", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "hosttracker.northbound", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "switchmanager.northbound", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "flowprogrammer.northbound", "0.4.0-SNAPSHOT"), mavenBundle("org.opendaylight.controller", "subnets.northbound", "0.4.0-SNAPSHOT"), mavenBundle("org.codehaus.jackson", "jackson-mapper-asl", "1.9.8"), mavenBundle("org.codehaus.jackson", "jackson-core-asl", "1.9.8"), mavenBundle("org.codehaus.jackson", "jackson-jaxrs", "1.9.8"), mavenBundle("org.codehaus.jettison", "jettison", "1.3.3"), mavenBundle("commons-io", "commons-io", "2.3"), mavenBundle("commons-fileupload", "commons-fileupload", "1.2.2"), mavenBundle("equinoxSDK381", "javax.servlet", "3.0.0.v201112011016"), mavenBundle("equinoxSDK381", "javax.servlet.jsp", "2.2.0.v201112011158"), mavenBundle("equinoxSDK381", "org.eclipse.equinox.ds", "1.4.0.v20120522-1841"), mavenBundle("orbit", "javax.xml.rpc", "1.1.0.v201005080400"), mavenBundle("equinoxSDK381", "org.eclipse.equinox.util", "1.0.400.v20120522-2049"), mavenBundle("equinoxSDK381", "org.eclipse.osgi.services", "3.3.100.v20120522-1822"), mavenBundle("equinoxSDK381", "org.apache.felix.gogo.command", "0.8.0.v201108120515"), mavenBundle("equinoxSDK381", "org.apache.felix.gogo.runtime", "0.8.0.v201108120515"), mavenBundle("equinoxSDK381", "org.apache.felix.gogo.shell", "0.8.0.v201110170705"), mavenBundle("equinoxSDK381", "org.eclipse.equinox.cm", "1.0.400.v20120522-1841"), mavenBundle("equinoxSDK381", "org.eclipse.equinox.console", "1.0.0.v20120522-1841"), mavenBundle("equinoxSDK381", "org.eclipse.equinox.launcher", "1.3.0.v20120522-1813"), mavenBundle("geminiweb", "org.eclipse.gemini.web.core", "2.2.0.RELEASE"), mavenBundle("geminiweb", "org.eclipse.gemini.web.extender", "2.2.0.RELEASE"), mavenBundle("geminiweb", "org.eclipse.gemini.web.tomcat", "2.2.0.RELEASE"), mavenBundle("geminiweb", "org.eclipse.virgo.kernel.equinox.extensions", "3.6.0.RELEASE").noStart(), mavenBundle("geminiweb", "org.eclipse.virgo.util.common", "3.6.0.RELEASE"), mavenBundle("geminiweb", "org.eclipse.virgo.util.io", "3.6.0.RELEASE"), mavenBundle("geminiweb", "org.eclipse.virgo.util.math", "3.6.0.RELEASE"), mavenBundle("geminiweb", "org.eclipse.virgo.util.osgi", "3.6.0.RELEASE"), mavenBundle("geminiweb", "org.eclipse.virgo.util.osgi.manifest", "3.6.0.RELEASE"), mavenBundle("geminiweb", "org.eclipse.virgo.util.parser.manifest", "3.6.0.RELEASE"), mavenBundle("org.apache.felix", "org.apache.felix.dependencymanager", "3.1.0"), mavenBundle("org.apache.felix", "org.apache.felix.dependencymanager.shell", "3.0.1"), mavenBundle("com.google.code.gson", "gson", "2.1"), mavenBundle("org.jboss.spec.javax.transaction", "jboss-transaction-api_1.1_spec", "1.0.1.Final"), mavenBundle("org.apache.felix", "org.apache.felix.fileinstall", "3.1.6"), mavenBundle("org.apache.commons", "commons-lang3", "3.1"), mavenBundle("commons-codec", "commons-codec"), mavenBundle("virgomirror", "org.eclipse.jdt.core.compiler.batch", "3.8.0.I20120518-2145"), mavenBundle("eclipselink", "javax.persistence", "2.0.4.v201112161009"), mavenBundle("orbit", "javax.activation", "1.1.0.v201211130549"), mavenBundle("orbit", "javax.annotation", "1.1.0.v201209060031"), mavenBundle("orbit", "javax.ejb", "3.1.1.v201204261316"), mavenBundle("orbit", "javax.el", "2.2.0.v201108011116"), mavenBundle("orbit", "javax.mail.glassfish", "1.4.1.v201108011116"), mavenBundle("orbit", "javax.xml.rpc", "1.1.0.v201005080400"), mavenBundle("orbit", "org.apache.catalina", "7.0.32.v201211201336"), // these are bundle fragments that can't be started on its own mavenBundle("orbit", "org.apache.catalina.ha", "7.0.32.v201211201952").noStart(), mavenBundle("orbit", "org.apache.catalina.tribes", "7.0.32.v201211201952").noStart(), mavenBundle("orbit", "org.apache.coyote", "7.0.32.v201211201952").noStart(), mavenBundle("orbit", "org.apache.jasper", "7.0.32.v201211201952").noStart(), mavenBundle("orbit", "org.apache.el", "7.0.32.v201211081135"), mavenBundle("orbit", "org.apache.juli.extras", "7.0.32.v201211081135"), mavenBundle("orbit", "org.apache.tomcat.api", "7.0.32.v201211081135"), mavenBundle("orbit", "org.apache.tomcat.util", "7.0.32.v201211201952").noStart(), mavenBundle("orbit", "javax.servlet.jsp.jstl", "1.2.0.v201105211821"), mavenBundle("orbit", "javax.servlet.jsp.jstl.impl", "1.2.0.v201210211230"), mavenBundle("org.ops4j.pax.exam", "pax-exam-container-native"), mavenBundle("org.ops4j.pax.exam", "pax-exam-junit4"), mavenBundle("org.ops4j.pax.exam", "pax-exam-link-mvn"), mavenBundle("org.ops4j.pax.url", "pax-url-aether"), mavenBundle("org.springframework", "org.springframework.asm", "3.1.3.RELEASE"), mavenBundle("org.springframework", "org.springframework.aop", "3.1.3.RELEASE"), mavenBundle("org.springframework", "org.springframework.context", "3.1.3.RELEASE"), mavenBundle("org.springframework", "org.springframework.context.support", "3.1.3.RELEASE"), mavenBundle("org.springframework", "org.springframework.core", "3.1.3.RELEASE"), mavenBundle("org.springframework", "org.springframework.beans", "3.1.3.RELEASE"), mavenBundle("org.springframework", "org.springframework.expression", "3.1.3.RELEASE"), mavenBundle("org.springframework", "org.springframework.web", "3.1.3.RELEASE"), mavenBundle("org.aopalliance", "com.springsource.org.aopalliance", "1.0.0"), mavenBundle("org.springframework", "org.springframework.web.servlet", "3.1.3.RELEASE"), mavenBundle("org.springframework.security", "spring-security-config", "3.1.3.RELEASE"), mavenBundle("org.springframework.security", "spring-security-core", "3.1.3.RELEASE"), mavenBundle("org.springframework.security", "spring-security-web", "3.1.3.RELEASE"), mavenBundle("org.springframework.security", "spring-security-taglibs", "3.1.3.RELEASE"), mavenBundle("org.springframework", "org.springframework.transaction", "3.1.3.RELEASE"), mavenBundle("org.ow2.chameleon.management", "chameleon-mbeans", "1.0.0"), mavenBundle("org.opendaylight.controller.thirdparty", "net.sf.jung2", "2.0.1-SNAPSHOT"), mavenBundle("org.opendaylight.controller.thirdparty", "com.sun.jersey.jersey-servlet", "1.17-SNAPSHOT"), // Jersey needs to be started before the northbound application // bundles, using a lower start level mavenBundle("com.sun.jersey", "jersey-client", "1.17"), mavenBundle("com.sun.jersey", "jersey-server", "1.17") .startLevel(2), mavenBundle("com.sun.jersey", "jersey-core", "1.17") .startLevel(2), mavenBundle("com.sun.jersey", "jersey-json", "1.17") .startLevel(2), junitBundles()); } }