package org.pcmm.test; import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; import java.net.InetAddress; import java.net.UnknownHostException; import org.pcmm.PCMMGlobalConfig; import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Test; import org.pcmm.rcd.ICMTS; import org.pcmm.rcd.IPCMMPolicyServer; import org.pcmm.rcd.IPCMMPolicyServer.IPSCMTSClient; import org.pcmm.rcd.impl.CMTS; import org.pcmm.rcd.impl.PCMMPolicyServer; public class PCMMWorkflowTest { /** * CMTS emulator, when testing with a real CMTS this should be set to null * and shoudln't be started */ private static ICMTS cmts; /** * CMTS host address, when testing with a real CMTS this should be CMTS * address */ private static InetAddress host; private static IPCMMPolicyServer server; private static IPSCMTSClient client; private static boolean real_cmts = false; //@BeforeClass public static void setUpBeforeClass() throws Exception { // comment this when using real CMTS // ################################### if (real_cmts == true) { cmts = null; } else { cmts = new CMTS(); cmts.startServer(); } // ################################### server = new PCMMPolicyServer(); try { if (real_cmts == true) { // this should be set to the cmts host ex : host = InetAddress.getByName(PCMMGlobalConfig.DefaultCMTS); host = InetAddress.getByName("10.200.90.3"); // InetAddress.getByName("my-cmts-host-name"); } else { host = InetAddress.getLocalHost(); } assertNotNull(host); } catch (UnknownHostException uhe) { fail("could not get host address "); } setupConnection(); } //@AfterClass public static void tearDownAfterClass() throws Exception { tearDown(); if (cmts != null) cmts.stopServer(); } // @Before public static void setupConnection() { client = server.requestCMTSConnection(host); assertNotNull(client); //System.out.println("MM minor version = MM major version :: CMTS exhausted all protocol selection attempts Major = " + client.getVersionInfo().getMajorVersionNB() + " Minor = " + client.getVersionInfo().getMinorVersionNB()); } // @After public static void tearDown() throws Exception { assertNotNull(client); assertTrue("Client disconnection failed", client.disconnect()); } //@Test public void testGateSet() { assertNotNull(client); assertTrue("Gate-Set failed", client.gateSet()); } //@Test public void testGateDelete() { assertNotNull(client); assertTrue("Gate-Delete failed", client.gateDelete()); } //@Test public void testGateInfo() { assertNotNull(client); assertTrue("Gate-Info failed", client.gateInfo()); } //@Test public void testGateSynchronize() { assertNotNull(client); assertTrue("Gate-Synchronize failed", client.gateSynchronize()); } }