+++ /dev/null
-package compbio.ws.server;\r
-\r
-import static org.testng.Assert.assertNotNull;\r
-import static org.testng.Assert.assertTrue;\r
-import static org.testng.Assert.fail;\r
-\r
-import java.io.File;\r
-import java.io.FileInputStream;\r
-import java.io.FileNotFoundException;\r
-import java.io.IOException;\r
-import java.net.ConnectException;\r
-import java.util.Arrays;\r
-import java.util.List;\r
-import java.util.Set;\r
-\r
-import javax.xml.ws.WebServiceException;\r
-\r
-import org.testng.annotations.Test;\r
-\r
-import compbio.data.msa.MsaWS;\r
-import compbio.data.sequence.FastaSequence;\r
-import compbio.data.sequence.SequenceUtil;\r
-import compbio.metadata.AllTestSuit;\r
-import compbio.metadata.ChunkHolder;\r
-import compbio.metadata.JobStatus;\r
-import compbio.metadata.JobSubmissionException;\r
-import compbio.metadata.ResultNotAvailableException;\r
-import compbio.ws.client.Jws2Client;\r
-import compbio.ws.client.Services;\r
-import compbio.ws.client.WSTesterTester;\r
-\r
-public class RegistryWSTester {\r
-\r
- @Test(groups = {AllTestSuit.test_group_webservices,\r
- AllTestSuit.test_group_windows_only})\r
- public void testGetSupportedServices() {\r
- try {\r
- compbio.data.msa.RegistryWS reg = Jws2Client\r
- .connectToRegistry(WSTesterTester.SERVER);\r
- System.out.println(reg.getSupportedServices());\r
- Set<Services> supserv = reg.getSupportedServices();\r
- assertTrue(supserv.containsAll(Arrays.asList(new Services[]{\r
- Services.AAConWS, Services.ClustalOWS, Services.IUPredWS,\r
- Services.MuscleWS, Services.ClustalWS, Services.JronnWS})));\r
- } catch (ConnectException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (WebServiceException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- }\r
- }\r
- @Test(groups = {AllTestSuit.test_group_webservices})\r
- public void testTestService() {\r
- compbio.data.msa.RegistryWS reg = null;\r
- try {\r
- reg = Jws2Client.connectToRegistry(WSTesterTester.SERVER);\r
- assertNotNull(reg.testService(Services.AAConWS));\r
- } catch (ConnectException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (WebServiceException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- }\r
- }\r
-\r
- @Test(dependsOnMethods = {"testTestService"}, groups = {AllTestSuit.test_group_webservices})\r
- public void testIsOperating() {\r
- try {\r
- compbio.data.msa.RegistryWS reg = Jws2Client\r
- .connectToRegistry(WSTesterTester.SERVER);\r
- assertTrue(reg.isOperating(Services.AAConWS));\r
- } catch (ConnectException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (WebServiceException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- }\r
- }\r
-\r
- @Test(dependsOnMethods = {"testTestService"}, groups = {AllTestSuit.test_group_webservices})\r
- public void testGetLastTestedOn() {\r
- try {\r
- compbio.data.msa.RegistryWS reg = Jws2Client\r
- .connectToRegistry(WSTesterTester.SERVER);\r
- assertNotNull(reg.getLastTestedOn(Services.AAConWS));\r
- } catch (ConnectException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (WebServiceException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- }\r
- }\r
-\r
- @Test(dependsOnMethods = {"testTestService"}, groups = {AllTestSuit.test_group_webservices})\r
- public void testGetLastTested() {\r
- try {\r
- Thread.sleep(1000);\r
- } catch (InterruptedException e) {\r
- e.printStackTrace();\r
- fail(e.getMessage());\r
- }\r
- try {\r
- compbio.data.msa.RegistryWS reg = Jws2Client\r
- .connectToRegistry(WSTesterTester.SERVER);\r
- System.out.println(reg.getLastTested(Services.AAConWS));\r
- assertTrue(reg.getLastTested(Services.AAConWS) > 0);\r
- } catch (ConnectException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (WebServiceException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- }\r
- }\r
-\r
- @Test(groups = {AllTestSuit.test_group_webservices})\r
- public void testTestAllServices() {\r
- try {\r
- compbio.data.msa.RegistryWS reg = Jws2Client\r
- .connectToRegistry(WSTesterTester.SERVER);\r
- System.out.println(reg.testAllServices());\r
- } catch (ConnectException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (WebServiceException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- }\r
- }\r
-\r
- @Test(groups = {AllTestSuit.test_group_webservices})\r
- public void testProgressReporting() {\r
- MsaWS service = null;\r
- try {\r
- service = (MsaWS) Jws2Client.connect(\r
- "http://www.compbio.dundee.ac.uk/jabaws",\r
- // "http://webserv1.cluster.lifesci.dundee.ac.uk:8089/jabaws",\r
- Services.ProbconsWS);\r
- File input = new File(AllTestSuit.TEST_DATA_PATH_ABSOLUTE\r
- + "200x500Protein.fasta");\r
- assertTrue(input.exists());\r
- List<FastaSequence> fs = SequenceUtil\r
- .readFasta(new FileInputStream(input));\r
- String jobId = service.align(fs);\r
- Thread.sleep(5000);\r
- ChunkHolder pos = null;\r
- while (service.getJobStatus(jobId) == JobStatus.RUNNING) {\r
- if (pos == null) {\r
- pos = service.pullExecStatistics(jobId, 0);\r
- } else {\r
- pos = service.pullExecStatistics(jobId,\r
- pos.getNextPosition());\r
- }\r
- Thread.sleep(10);\r
- System.out.print(pos.getChunk());\r
- }\r
- System.out.println();\r
- System.out.println(service.getResult(jobId));\r
- } catch (ConnectException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (WebServiceException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (ResultNotAvailableException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (FileNotFoundException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (IOException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (JobSubmissionException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (InterruptedException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- }\r
- }\r
-\r
- @Test(groups = {AllTestSuit.test_group_webservices})\r
- public void testPullRunningJob() {\r
- MsaWS service = null;\r
- try {\r
- service = (MsaWS) Jws2Client.connect(\r
- "http://webserv1.cluster.lifesci.dundee.ac.uk:8089/jabaws",\r
- Services.ProbconsWS);\r
- String jobId = "@Probcons#158079030012566";\r
- ChunkHolder pos = null;\r
- while (service.getJobStatus(jobId) == JobStatus.RUNNING) {\r
- if (pos == null) {\r
- pos = service.pullExecStatistics(jobId, 0);\r
- } else {\r
- pos = service.pullExecStatistics(jobId,\r
- pos.getNextPosition());\r
- }\r
- Thread.sleep(10);\r
- System.out.print(pos.getChunk());\r
- }\r
- System.out.println();\r
- System.out.println(service.getResult(jobId));\r
- } catch (ConnectException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (WebServiceException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (ResultNotAvailableException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- } catch (InterruptedException e) {\r
- e.printStackTrace();\r
- fail(e.getLocalizedMessage());\r
- }\r
- }\r
-}\r