webservices/compbio/ws/server/WSUtil.java

   1 /* Copyright (c) 2011 Peter Troshin\r
   2  *  \r
   3  *  JAva Bioinformatics Analysis Web Services (JABAWS) @version: 2.0     \r
   4  * \r
   5  *  This library is free software; you can redistribute it and/or modify it under the terms of the\r
   6  *  Apache License version 2 as published by the Apache Software Foundation\r
   7  * \r
   8  *  This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without\r
   9  *  even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the Apache \r
  10  *  License for more details.\r
  11  * \r
  12  *  A copy of the license is in apache_license.txt. It is also available here:\r
  13  * @see: http://www.apache.org/licenses/LICENSE-2.0.txt\r
  14  * \r
  15  * Any republication or derived work distributed in source code form\r
  16  * must include this copyright and license notice.\r
  17  */\r
  18 package compbio.ws.server;\r
  19 \r
  20 import java.security.InvalidParameterException;\r
  21 import java.util.ArrayList;\r
  22 import java.util.HashSet;\r
  23 import java.util.List;\r
  24 import java.util.Set;\r
  25 \r
  26 import org.apache.log4j.Logger;\r
  27 \r
  28 import compbio.data.sequence.FastaSequence;\r
  29 import compbio.data.sequence.ScoreManager;\r
  30 import compbio.engine.AsyncExecutor;\r
  31 import compbio.engine.Configurator;\r
  32 import compbio.engine.ProgressGetter;\r
  33 import compbio.engine.client.ConfiguredExecutable;\r
  34 import compbio.metadata.ChunkHolder;\r
  35 import compbio.metadata.JobStatus;\r
  36 import compbio.metadata.JobSubmissionException;\r
  37 import compbio.metadata.Limit;\r
  38 import compbio.metadata.LimitExceededException;\r
  39 import compbio.metadata.Option;\r
  40 import compbio.metadata.ResultNotAvailableException;\r
  41 import compbio.ws.client.Services;\r
  42 import compbio.ws.client.ServicesUtil;\r
  43 \r
  44 public final class WSUtil {\r
  45 \r
  46         public static final void validateJobId(String jobId)\r
  47                         throws InvalidParameterException {\r
  48                 if (!compbio.engine.client.Util.isValidJobId(jobId)) {\r
  49                         throw new InvalidParameterException(\r
  50                                         "JobId is not provided or cannot be recognised! Given value: "\r
  51                                                         + jobId);\r
  52                 }\r
  53         }\r
  54 \r
  55         public static final void validateFastaInput(List<FastaSequence> sequences)\r
  56                         throws JobSubmissionException {\r
  57                 if (sequences == null || sequences.isEmpty()) {\r
  58                         throw new JobSubmissionException(\r
  59                                         "List of fasta sequences required but not provided! ");\r
  60                 }\r
  61                 Set<String> names = new HashSet<String>();\r
  62                 for (FastaSequence fs : sequences) {\r
  63                         boolean unique = names.add(fs.getId());\r
  64                         if (!unique) {\r
  65                                 throw new JobSubmissionException(\r
  66                                                 "Input sequences must have unique names! \n"\r
  67                                                                 + "Sequence " + fs.getId() + " is a duplicate!");\r
  68                         }\r
  69                         if (fs.getLength() == 0) {\r
  70                                 throw new JobSubmissionException(\r
  71                                                 "Sequence must not be empty! Sequence: " + fs.getId()\r
  72                                                                 + " was empty");\r
  73                         }\r
  74                 }\r
  75         }\r
  76 \r
  77         public static JobStatus getJobStatus(String jobId) {\r
  78                 AsyncExecutor asyncEngine = Configurator.getAsyncEngine(jobId);\r
  79                 return asyncEngine.getJobStatus(jobId);\r
  80         }\r
  81 \r
  82         public static ChunkHolder pullFile(String file, long position) {\r
  83                 return ProgressGetter.pull(file, position);\r
  84         }\r
  85 \r
  86         public static byte getProgress(String jobId) {\r
  87                 throw new UnsupportedOperationException();\r
  88         }\r
  89 \r
  90         public static AsyncExecutor getEngine(ConfiguredExecutable<?> confClustal) {\r
  91                 assert confClustal != null;\r
  92                 return Configurator.getAsyncEngine(confClustal);\r
  93         }\r
  94 \r
  95         public static boolean cancelJob(String jobId) {\r
  96                 AsyncExecutor asyncEngine = Configurator.getAsyncEngine(jobId);\r
  97                 return asyncEngine.cancelJob(jobId);\r
  98         }\r
  99 \r
 100         public static <T> String align(List<FastaSequence> sequences,\r
 101                         ConfiguredExecutable<T> confExec, Logger logger,\r
 102                         String callingMethod, Limit<T> limit)\r
 103                         throws LimitExceededException, JobSubmissionException {\r
 104 \r
 105                 if (limit != null && limit.isExceeded(sequences)) {\r
 106                         throw LimitExceededException.newLimitExceeded(limit, sequences);\r
 107                 }\r
 108                 compbio.runner.Util.writeInput(sequences, confExec);\r
 109                 AsyncExecutor engine = Configurator.getAsyncEngine(confExec);\r
 110                 String jobId = engine.submitJob(confExec);\r
 111                 reportUsage(confExec, logger);\r
 112                 return jobId;\r
 113         }\r
 114         \r
 115 \r
 116         static <T> void reportUsage(ConfiguredExecutable<T> confExec, Logger logger) {\r
 117                 if (GAUtils.IS_GA_ENABLED) {\r
 118                         Services service = ServicesUtil.getServiceByRunner(confExec.getExecutable().getClass());\r
 119                         GAUtils.reportUsage(service);\r
 120                         logger.info("Reporting GA usage for " + service);\r
 121                 }\r
 122         }\r
 123 \r
 124         public static <T> String analize(List<FastaSequence> sequences,\r
 125                         ConfiguredExecutable<T> confExec, Logger log, String method,\r
 126                         Limit<T> limit) throws JobSubmissionException {\r
 127                 if (limit != null && limit.isExceeded(sequences)) {\r
 128                         throw LimitExceededException.newLimitExceeded(limit, sequences);\r
 129                 }\r
 130                 compbio.runner.Util.writeInput(sequences, confExec);\r
 131                 AsyncExecutor engine = Configurator.getAsyncEngine(confExec);\r
 132                 String jobId = engine.submitJob(confExec);\r
 133                 reportUsage(confExec, log);\r
 134                 return jobId;\r
 135         }\r
 136 \r
 137         // Same as analize(...) but RNAalifold takes clustal input not fasta\r
 138         // An if condition in the above method might be a better solution but \r
 139         // you need a way of finding out the type of confExec at runtime\r
 140         \r
 141         public static <T> String fold(List<FastaSequence> sequences,\r
 142                         ConfiguredExecutable<T> confExec, Logger log, String method,\r
 143                         Limit<T> limit) throws JobSubmissionException {\r
 144                 if (limit != null && limit.isExceeded(sequences)) {\r
 145                         throw LimitExceededException.newLimitExceeded(limit, sequences);\r
 146                 }\r
 147                 compbio.runner.Util.writeClustalInput(sequences, confExec, '-');\r
 148                 AsyncExecutor engine = Configurator.getAsyncEngine(confExec);\r
 149                 String jobId = engine.submitJob(confExec);\r
 150                 reportUsage(confExec, log);\r
 151                 return jobId;\r
 152         }\r
 153 \r
 154         /*\r
 155          * TODO Rewrite using purely CommandBuilder. This is breaking encapsulation\r
 156          */\r
 157         public static final <T> List<String> getCommands(List<Option<T>> options,\r
 158                         String keyValueSeparator) {\r
 159                 List<String> oList = new ArrayList<String>();\r
 160                 for (Option<T> o : options) {\r
 161                         oList.add(o.toCommand(keyValueSeparator));\r
 162                 }\r
 163                 return oList;\r
 164         }\r
 165 \r
 166         public static void validateAAConInput(List<FastaSequence> sequences)\r
 167                         throws JobSubmissionException {\r
 168                 validateFastaInput(sequences);\r
 169                 int len = 0;\r
 170                 for (FastaSequence fs : sequences) {\r
 171                         if (len == 0) {\r
 172                                 len = fs.getLength();\r
 173                                 continue;\r
 174                         }\r
 175                         if (fs.getLength() != len) {\r
 176                                 throw new JobSubmissionException(\r
 177                                                 "All sequences must be of the same length. Please align the sequences " + \r
 178                                                 " prior to submission! The first sequence length is : " + len + \r
 179                                                 " but the sequence '" + fs.getId() + "' length is " + fs.getLength());\r
 180                         }\r
 181                 }\r
 182         }\r
 183 \r
 184         public static void validateJpredInput(List<FastaSequence> sequences)\r
 185                         throws JobSubmissionException {\r
 186                 validateFastaInput(sequences);\r
 187                 int len = 0;\r
 188                 for (FastaSequence fs : sequences) {\r
 189                         if (len == 0) {\r
 190                                 len = fs.getLength();\r
 191                                 continue;\r
 192                         }\r
 193                         if (fs.getLength() != len) {\r
 194                                 System.out.println("FASTA rec: id = " + fs.getId() + ": seq = " + fs.getSequence());\r
 195                                 throw new JobSubmissionException(\r
 196                                                 "All sequences must be of the same length. Please align the sequences " + \r
 197                                                 " prior to submission! The first sequence length is : " + len + \r
 198                                                 " but the sequence '" + fs.getId() + "' length is " + fs.getLength());\r
 199                         }\r
 200                 }\r
 201         }\r
 202 \r
 203         public static <T> ScoreManager getAnnotation(String jobId, Logger log)\r
 204                         throws ResultNotAvailableException {\r
 205                 WSUtil.validateJobId(jobId);\r
 206                 AsyncExecutor asyncEngine = Configurator.getAsyncEngine(jobId);\r
 207                 ConfiguredExecutable<T> aacon = (ConfiguredExecutable<T>) asyncEngine.getResults(jobId);\r
 208                 ScoreManager mas = aacon.getResults();\r
 209                 log.trace(jobId + " getConservation : " + mas);\r
 210                 return mas;\r
 211         }\r
 212 \r
 213 }\r