Mercurial > repos > yufei-luo > s_mart
comparison commons/launcher/LaunchNucmer.py @ 18:94ab73e8a190
Uploaded
| author | m-zytnicki |
|---|---|
| date | Mon, 29 Apr 2013 03:20:15 -0400 |
| parents | |
| children |
comparison
equal
deleted
inserted
replaced
| 17:b0e8584489e6 | 18:94ab73e8a190 |
|---|---|
| 1 #! /usr/bin/env python | |
| 2 | |
| 3 # Copyright INRA (Institut National de la Recherche Agronomique) | |
| 4 # http://www.inra.fr | |
| 5 # http://urgi.versailles.inra.fr | |
| 6 # | |
| 7 # This software is governed by the CeCILL license under French law and | |
| 8 # abiding by the rules of distribution of free software. You can use, | |
| 9 # modify and/ or redistribute the software under the terms of the CeCILL | |
| 10 # license as circulated by CEA, CNRS and INRIA at the following URL | |
| 11 # "http://www.cecill.info". | |
| 12 # | |
| 13 # As a counterpart to the access to the source code and rights to copy, | |
| 14 # modify and redistribute granted by the license, users are provided only | |
| 15 # with a limited warranty and the software's author, the holder of the | |
| 16 # economic rights, and the successive licensors have only limited | |
| 17 # liability. | |
| 18 # | |
| 19 # In this respect, the user's attention is drawn to the risks associated | |
| 20 # with loading, using, modifying and/or developing or reproducing the | |
| 21 # software by the user in light of its specific status of free software, | |
| 22 # that may mean that it is complicated to manipulate, and that also | |
| 23 # therefore means that it is reserved for developers and experienced | |
| 24 # professionals having in-depth computer knowledge. Users are therefore | |
| 25 # encouraged to load and test the software's suitability as regards their | |
| 26 # requirements in conditions enabling the security of their systems and/or | |
| 27 # data to be ensured and, more generally, to use and operate it in the | |
| 28 # same conditions as regards security. | |
| 29 # | |
| 30 # The fact that you are presently reading this means that you have had | |
| 31 # knowledge of the CeCILL license and that you accept its terms. | |
| 32 | |
| 33 from commons.core.checker.CheckerUtils import CheckerUtils | |
| 34 from commons.core.utils.FileUtils import FileUtils | |
| 35 from commons.core.utils.RepetOptionParser import RepetOptionParser | |
| 36 import subprocess | |
| 37 from commons.core.LoggerFactory import LoggerFactory | |
| 38 import os | |
| 39 | |
| 40 LOG_DEPTH = "repet.tools" | |
| 41 | |
| 42 class LaunchNucmer(object): | |
| 43 | |
| 44 def __init__(self,queryFileName="", refFileName ="", prefix = None, genCoords=False, showCoords = False, mum=False, maxGaps=90, minMatch=20, nooptimize=False,mincluster=65, minIdentity=50, minLength=100, verbosity=0): | |
| 45 self._queryFileName = queryFileName | |
| 46 self._refFileName = refFileName | |
| 47 self._prefix = prefix | |
| 48 self._genCoords = genCoords | |
| 49 self._showCoords = showCoords | |
| 50 self._mum = mum | |
| 51 self._maxgaps = maxGaps | |
| 52 self._minMatch = minMatch | |
| 53 self._nooptimize = nooptimize | |
| 54 self._mincluster = mincluster | |
| 55 self._minIdentity = minIdentity | |
| 56 self._minLength = minLength | |
| 57 self.verbosity = verbosity | |
| 58 self._log = LoggerFactory.createLogger("%s.%s" % (LOG_DEPTH, self.__class__.__name__), self.verbosity) | |
| 59 | |
| 60 def setMincluster(self, value): | |
| 61 self._mincluster = value | |
| 62 def getMincluster(self): | |
| 63 return self._mincluster | |
| 64 | |
| 65 mincluster = property(getMincluster, setMincluster) | |
| 66 | |
| 67 def setAttributesFromCmdLine(self): | |
| 68 description = "LaunchNucmer runs the Nucmer program (part of the mummer package) ." | |
| 69 parser = RepetOptionParser(description = description) | |
| 70 parser.add_option("-q", "--query", dest="queryFileName", default = "", action="store", type="string", help="input query file [compulsory] [format: fasta]") | |
| 71 parser.add_option("-r", "--ref", dest="refFileName", default = "", action="store", type="string", help="input ref file [compulsory] [format: fasta]") | |
| 72 parser.add_option("-p", "--prefix", dest="prefix", default = None, action="store", type="string", help="prefix name [optional]") | |
| 73 parser.add_option("-o","--gencoords", dest="genCoords",action="store_true", help="generate coords file with minimal option (show-coords -r) [optional] ") | |
| 74 parser.add_option("-s","--showcoords", dest="showCoords",action="store_true", help="generate coords file with: show-coords -r -c -l -d -I 50 -L 100 -T [optional] ") | |
| 75 parser.add_option("-m", "--mum", dest="mum", action="store_true", help="Use anchor matches that are unique in both the reference and query [optional] ") | |
| 76 parser.add_option("-g", "--maxgaps", dest="maxgaps", default = 90, action="store", type="int", help="Maximum gap between two adjacent matches in a cluster (default 90) [optional] ") | |
| 77 parser.add_option("-l", "--minmatch", dest="minMatch", default = 20, action="store", type="int", help="Minimum length of an maximal exact match (default 20) [optional] ") | |
| 78 parser.add_option("-n", "--nooptimize", dest="nooptimize", action="store_true", help="nooptimize (default --optimize) [optional] ") | |
| 79 parser.add_option("-j", "--mincluster", dest="mincluster", default = 65, action="store", type="int", help="Minimum length of a cluster of matches (default 65) [optional] ") | |
| 80 | |
| 81 parser.add_option("-i", "--minIdentity", dest="minIdentity", default = 50, action="store", type="int", help="Minimum identity for show_coords (default 50) [optional] ") | |
| 82 parser.add_option("-u", "--minLength", dest="minLength", default = 100, action="store", type="int", help="Minimum alignment length for show_coords (default 100) [optional] ") | |
| 83 parser.add_option("-v", "--verbosity", dest="verbosity", default = 0, action="store", type="int", help="verbosity [optional] ") | |
| 84 | |
| 85 (self._options, args) = parser.parse_args() | |
| 86 self._setAttributesFromOptions(self._options) | |
| 87 | |
| 88 def _setAttributesFromOptions(self, options): | |
| 89 self._queryFileName = options.queryFileName | |
| 90 self._refFileName = options.refFileName | |
| 91 self._prefix = options.prefix | |
| 92 self._genCoords = options.genCoords | |
| 93 self._showCoords = options.showCoords | |
| 94 self._mum = options.mum | |
| 95 self._maxgaps = options.maxgaps | |
| 96 self._minMatch = options.minMatch | |
| 97 self._nooptimize = options.nooptimize | |
| 98 self._mincluster = options.mincluster | |
| 99 | |
| 100 self._minIdentity = options.minIdentity | |
| 101 self._minLength = options.minLength | |
| 102 | |
| 103 self.verbosity = options.verbosity | |
| 104 | |
| 105 def _logAndRaise(self, errorMsg): | |
| 106 self._log.error(errorMsg) | |
| 107 raise Exception(errorMsg) | |
| 108 | |
| 109 def checkOptions(self): | |
| 110 if self._queryFileName != "": | |
| 111 if not FileUtils.isRessourceExists(self._queryFileName): | |
| 112 self._logAndRaise("ERROR: Query file: %s does not exist!" % self._queryFileName) | |
| 113 else: | |
| 114 self._logAndRaise("ERROR: No specified --query option!") | |
| 115 | |
| 116 if self._refFileName != "": | |
| 117 if not FileUtils.isRessourceExists(self._refFileName): | |
| 118 self._logAndRaise("ERROR: Ref file does not exist!"% self._refFileName) | |
| 119 else: | |
| 120 self._logAndRaise("ERROR: No specified --ref option!") | |
| 121 | |
| 122 def run(self): | |
| 123 LoggerFactory.setLevel(self._log, self.verbosity) | |
| 124 if not CheckerUtils.isExecutableInUserPath("nucmer") : | |
| 125 self._logAndRaise("ERROR: nucmer must be in your path") | |
| 126 self.checkOptions() | |
| 127 | |
| 128 genCoords = "" | |
| 129 if self._genCoords: | |
| 130 genCoords = "-o" | |
| 131 mum = "" | |
| 132 if self._mum: | |
| 133 mum = "--mum" | |
| 134 nooptimize = "--optimize" | |
| 135 if self._nooptimize: | |
| 136 nooptimize = "--nooptimize" | |
| 137 prefix = "" | |
| 138 if self._prefix is not None: | |
| 139 prefix = "--prefix=%s" %(self._prefix) | |
| 140 cmd = "nucmer %s %s %s %s %s -g=%d -l=%d %s -c=%d" % (self._refFileName,self._queryFileName, prefix, genCoords, mum, self._maxgaps, self._minMatch, nooptimize, self._mincluster) | |
| 141 self._log.debug("Running nucmer with following commands : %s" %cmd) | |
| 142 cmd = cmd.split() | |
| 143 process = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE) | |
| 144 process.wait() | |
| 145 | |
| 146 if self._showCoords: | |
| 147 #use of os.system because redirect on process is broken in python < 3.0 | |
| 148 cmd = "show-coords -r -c -l -d -I %d -L %d -T %s.delta > %s.coords" % (self._minIdentity, self._minLength, self._prefix, self._prefix) | |
| 149 self._log.debug("Running show-coords with following commands : %s" %cmd) | |
| 150 os.system(cmd) | |
| 151 | |
| 152 | |
| 153 return process.returncode | |
| 154 | |
| 155 if __name__ == "__main__": | |
| 156 iLaunchNucmer = LaunchNucmer() | |
| 157 iLaunchNucmer.setAttributesFromCmdLine() | |
| 158 iLaunchNucmer.run() |
