Source code for sincei.ParserCommon

import argparse
import os
from deeptools.utilities import smartLabels
from sincei._version import __version__


[docs]def inputOutputOptions(args=None, opts=None, requiredOpts=[], suppress_args=None): parser = argparse.ArgumentParser(add_help=False) group = parser.add_argument_group("Input/Output options") ## inputs if "loomfile" in opts: group.add_argument( "--input", "-i", metavar="LOOM", help="Input file in .loom format", required=True, ) elif "bamfiles" in opts: group.add_argument( "--bamfiles", "-b", metavar="FILE1 FILE2", help="List of indexed bam files separated by spaces.", nargs="+", required=True, ) elif "bamfile" in opts: group.add_argument("--bamfile", "-b", metavar="FILE", help="Indexed BAM file", required=True) if "whitelist" in opts: group.add_argument( "--whitelist", "-w", help="A single-column file containing the whitelist of barcodes to be used", metavar="TXT", default=None, required=True if "whitelist" in requiredOpts else False, ) elif "barcodes" in opts: group.add_argument( "--barcodes", "-bc", help="A single-column file containing barcodes (whitelist) to be used for the analysis.", metavar="TXT", required=True if "barcodes" in requiredOpts else False, ) if "groupInfo" in opts: group.add_argument( "--groupInfo", "-i", help="A 3-column tsv file with Cell grouping information in the " "format: `sample, barcode, group`. Coverages will be " "computed per group.", metavar="TXT file", required=True, ) if "BED" in opts: group.add_argument( "--BED", help=show_or_hide( "Limits the coverage analysis to " "the regions specified in these files.", "BED", suppress_args, ), metavar="FILE1.bed FILE2.bed", nargs="+", required=True if "BED" in requiredOpts else False, ) ## outputs if "outFilePrefix" in opts: group.add_argument( "--outFilePrefix", "-o", help="Output file name prefix.", metavar="FILEPREFIX", type=str, required=True if "outFilePrefix" in requiredOpts else False, ) elif "outFile" in opts: group.add_argument( "--outFile", "-o", type=str, help="The file to write results to. For `scFilterStats`, `scFilterBarcodes` " "and `scJSD`, the output file is a .txt file. For other tools, the output file is " "an updated .loom object with the result of the requested operation. ", required=True if "outFile" in requiredOpts else False, ) return parser
[docs]def otherOptions(args=None): parser = argparse.ArgumentParser(add_help=False) group = parser.add_argument_group("Other options") group.add_argument("--help", "-h", action="help", help="show this help message and exit") group.add_argument("--verbose", "-v", help="Set to see processing messages.", action="store_true") group.add_argument("--version", action="version", version="%(prog)s {}".format(__version__)) return parser
[docs]def plotOptions(args=None): parser = argparse.ArgumentParser(add_help=False) group = parser.add_argument_group("Plot options") group.add_argument( "--plotWidth", default=10, type=float, help="Output plot width (in cm). (Default: %(default)s)", ) group.add_argument( "--plotHeight", default=10, type=float, help="Output plot height (in cm). (Default: %(default)s)", ) group.add_argument( "--plotFileFormat", metavar="FILETYPE", type=str, choices=["png", "pdf", "svg", "eps"], default="png", help="Image format type. If given, this option " "overrides the image format based on the plotFile " "ending. (Default: %(default)s)", ) return parser
## Tools: scBulkCoverage, scCountReads, scFilterStats, scJSD
[docs]def bamOptions(args=None, suppress_args=None, default_opts=None): """ Arguments for tools that operate on BAM files """ parser = argparse.ArgumentParser(add_help=False) group = parser.add_argument_group("BAM processing options") group.add_argument( "--cellTag", "-ct", metavar="STR", help="Name of the BAM tag from which to extract barcodes.", type=str, default="BC", ) group.add_argument( "--groupTag", "-gt", metavar="STR", help=show_or_hide( "In case of a groupped BAM file, such as the one containing Read Group (`RG`) or Sample (`SM`) tag," "it is possible to process group the reads using the provided --groupTag argument. NOTE: In case of such input, " "please ensure that the --labels argument indicates the expected group labels contained in the BAM files. " "The --groupTag along with the --cellTag is then used to identify unique samples (cells) from the input.", "groupTag", suppress_args, ), type=str, default=None, ) group.add_argument( "--numberOfProcessors", "-p", help='Number of processors to use. Type "max/2" to ' 'use half the maximum number of processors or "max" ' "to use all available processors. (Default: %(default)s)", metavar="INT", type=numberOfProcessors, default=1, required=False, ) group.add_argument( "--labels", "-l", metavar="sample1 sample2", help=show_or_hide( "User defined labels instead of default labels from " "file names. Multiple labels have to be separated by a space, e.g. " "--labels sample1 sample2 sample3", "labels", suppress_args, ), nargs="+", ) group.add_argument( "--smartLabels", action="store_true", help=show_or_hide( "Instead of manually specifying labels for the input " "BAM files, this causes sincei to use the file name " "after removing the path and extension.", "smartLabels", suppress_args, ), ) group.add_argument( "--region", "-r", help=show_or_hide( "Region of the genome to limit the operation " "to - this is useful when testing parameters to " "reduce the computing time. The format is " "chr:start:end, for example --region chr10 or --region chr10:456700:891000.", "region", suppress_args, ), metavar="CHR:START:END", required=False, type=genomicRegion, ) group.add_argument( "--blackListFileName", "-bl", help=show_or_hide( "A BED or GTF file containing regions that should be excluded from all analyses. Currently this works by rejecting genomic chunks that happen to overlap an entry. Consequently, for BAM files, if a read partially overlaps a blacklisted region or a fragment spans over it, then the read/fragment might still be considered. Please note that you should adjust the effective genome size, if relevant.", "blackListFileName", suppress_args, ), metavar="BED file", nargs="+", required=False, ) group.add_argument( "--binSize", "-bs", help=show_or_hide( "Size of the bins, in bases, to calculate coverage (Default: %(default)s)", "binSize", suppress_args, ), metavar="INT bp", type=int, default=get_default("binSize", default_opts), ) group.add_argument( "--distanceBetweenBins", metavar="INT", help=show_or_hide( "The gap distance between bins during counting. " "Larger numbers can be used to sample the genome for input files with high coverage " "while smaller values are useful for lower coverage data. Note that if you specify a value that " "results in too few (<1000) reads sampled, the value will be decreased. (Default: %(default)s)", "distanceBetweenBins", suppress_args, ), default=get_default("distanceBetweenBins", default_opts), type=int, ) return parser
## Tools: scBulkCoverage, scCountReads
[docs]def filterOptions(args=None, suppress_args=None): parser = argparse.ArgumentParser(add_help=False) group = parser.add_argument_group("Read Filtering Options") group.add_argument( "--duplicateFilter", help=show_or_hide( "How to filter for duplicates? Different combinations (using start/end/umi) are possible. " "Read start position and read barcode are always considered. Default (None) would consider all reads. " "Note that in case of paired end data, both reads in the fragment are considered (and kept). So if you wish " "to keep only read1, combine this option with samFlagInclude ", "duplicateFilter", suppress_args, ), type=str, choices=["start_bc", "start_bc_umi", "start_end_bc", "start_end_bc_umi"], default=None, ) group.add_argument( "--motifFilter", "-m", metavar="STR", help=show_or_hide( "Check whether a given motif is present in the read and the corresponding reference genome. " "This option checks for the motif at the 5-end of the read and at the 5-overhang in the genome, " "which is useful in identifying reads properly cut by a restriction-enzyme or MNAse. " 'For example, if you want to search for an "A" at the 5\'-end of the read and "TA" at 5\'-overhang, ' "use \"-m 'A,TA'\". Reads not containing the given motif are filtered out. ", "motifFilter", suppress_args, ), type=str, nargs="+", default=None, ) group.add_argument( "--genome2bit", "-g", metavar="STR", help=show_or_hide( "If --motifFilter is provided, please also provide the genome sequence (in 2bit format). ", "genome2bit", suppress_args, ), type=str, default=None, ) group.add_argument( "--GCcontentFilter", "-gc", metavar="STR", help=show_or_hide( "Check whether the GC content of the read falls within the provided range " "Input format must be '<low>,<high>' , where <low> is the lower bound and <high> is the " "upper bound in the fraction of GC (eg. '0.1,0.9' ). " "If the GC content of the reads fall outside the range, they are filtered out. ", "GCcontentFilter", suppress_args, ), type=str, default=None, ) group.add_argument( "--minAlignedFraction", help=show_or_hide( "Minimum fraction of the reads which should be aligned to be counted. This includes " "mismatches tolerated by the aligners, but excludes InDels/Clippings (Default: %(default)s)", "minAlignedFraction", suppress_args, ), metavar="FLOAT", default=None, type=float, required=False, ) return parser
## Tools: scBulkCoverage, scCountReads
[docs]def readOptions(args=None, suppress_args=None): """Common arguments related to BAM files and the interpretation of the read coverage """ parser = argparse.ArgumentParser(add_help=False) group = parser.add_argument_group("Read Processing Options") group.add_argument( "--minMappingQuality", metavar="INT", help=show_or_hide( "If set, only reads that have a mapping " "quality score of at least this are considered.", "minMappingQuality", suppress_args, ), type=int, ) group.add_argument( "--samFlagInclude", help=show_or_hide( "Include reads based on the SAM flag. For example, " "to get only reads that are the first mate, use a flag of 64. " "This is useful to count properly paired reads only once, " "as otherwise the second mate will be also considered for the " "coverage. (Default: %(default)s)", "samFlagInclude", suppress_args, ), metavar="INT", default=None, type=int, required=False, ) group.add_argument( "--samFlagExclude", help=show_or_hide( "Exclude reads based on the SAM flag. For example, " "to get only reads that map to the forward strand, use " "--samFlagExclude 16, where 16 is the SAM flag for reads " "that map to the reverse strand. (Default: %(default)s)", "samFlagExclude", suppress_args, ), metavar="INT", default=None, type=int, required=False, ) group.add_argument( "--minFragmentLength", help=show_or_hide( "The minimum fragment length needed for read/pair " "inclusion. This option is primarily useful " "in ATACseq experiments, for filtering mono- or " "di-nucleosome fragments. (Default: %(default)s)", "minFragmentLength", suppress_args, ), metavar="INT", default=0, type=int, required=False, ) group.add_argument( "--maxFragmentLength", help=show_or_hide( "The maximum fragment length needed for read/pair " "inclusion. (Default: %(default)s)", "maxFragmentLength", suppress_args, ), metavar="INT", default=0, type=int, required=False, ) group.add_argument( "--filterRNAstrand", help=show_or_hide( "Selects RNA-seq reads (single-end or paired-end) originating from genes " "on the given strand. This option assumes a standard dUTP-based library " "preparation (that is, --filterRNAstrand=forward keeps minus-strand reads, " "which originally came from genes on the forward strand using a dUTP-based " "method). Consider using --samExcludeFlag instead for filtering by strand in " "other contexts.", "filterRNAstrand", suppress_args, ), choices=["forward", "reverse"], default=None, ) group.add_argument( "--extendReads", "-e", help=show_or_hide( "This parameter allows the extension of reads to " "fragment size. If set, each read is " "extended, without exception.\n" "*NOTE*: This feature is generally NOT recommended for " "spliced-read data, such as RNA-seq, as it would " "extend reads over skipped regions.\n" "*Single-end*: Requires a user specified value for the " "final fragment length. Reads that already exceed this " "fragment length will not be extended.\n" "*Paired-end*: Reads with mates are always extended to " "match the fragment size defined by the two read mates. " "Unmated reads, mate reads that map too far apart " "(>4x fragment length) or even map to different " "chromosomes are treated like single-end reads. The input " "of a fragment length value is optional. If " "no value is specified, it is estimated from the " "data (mean of the fragment size of all mate reads).\n", "extendReads", suppress_args, ), type=int, nargs="?", const=True, default=False, metavar="INT bp", ) group.add_argument( "--centerReads", help=show_or_hide( "By adding this option, reads are centered with " "respect to the fragment length. For paired-end data, " "the read is centered at the fragment length defined " "by the two ends of the fragment. For single-end data, the " "given fragment length is used. This option is " "useful to get a sharper signal around enriched regions.", "centerReads", suppress_args, ), action="store_true", ) return parser
## helper functions
[docs]def show_or_hide(help, name, arglist): if arglist and name in arglist: return argparse.SUPPRESS else: return help
[docs]def get_default(name, argdict): if argdict and name in argdict.keys(): return argdict[name] else: return None
[docs]def process_args(args=None): if not args.labels: if args.smartLabels: args.labels = smartLabels(args.bamfiles) else: args.labels = args.bamfiles if len(args.bamfiles) != len(args.labels): sys.exit("The number of labels does not match the number of BAM files.") return args
[docs]def genomicRegion(string): # remove whitespaces using split,join trick region = "".join(string.split()) if region == "": return None # remove undesired characters that may be present and # replace - by : # N.B., the syntax for translate() differs between python 2 and 3 try: region = region.translate(None, ",;|!{}()").replace("-", ":") except: region = region.translate({ord(i): None for i in ",;|!{}()"}) if len(region) == 0: raise argparse.ArgumentTypeError("{} is not a valid region".format(string)) return region
[docs]def numberOfProcessors(string): import multiprocessing availProc = multiprocessing.cpu_count() if string == "max/2": # default case # by default half of the available processors are used numberOfProcessors = int(availProc * 0.5) elif string == "max": # use all available processors numberOfProcessors = availProc else: try: numberOfProcessors = int(string) except ValueError: raise argparse.ArgumentTypeError("{} is not a valid number of processors".format(string)) except Exception as e: raise argparse.ArgumentTypeError( "the given value {} is not valid. " "Error message: {}\nThe number of " "available processors in your " "computer is {}.".format(string, e, availProc) ) if numberOfProcessors > availProc: numberOfProcessors = availProc return numberOfProcessors
[docs]def smartLabel(label): """ Remove the path name and the last extension from the file name /pth/to/file.name.bam -> file.name """ lab = os.path.splitext(os.path.basename(label))[0] if lab == "": # Maybe we have a dot file? lab = os.path.basename(label) return lab
[docs]def smartLabels(labels): smrt = [smartLabel(x) for x in labels] if len(smrt) != len(set(smrt)): print( "Labels inferred from file names are not unique. " "Please be aware that in case of overlapping barcodes the counts will be merged." ) return smrt
[docs]def validateInputs(args, process_barcodes=True): """ Ensure that right input is provided from argparse """ ## Labels if args.groupTag: # in case of --groupTag, use args.labels as groups if len(args.bamfiles) > 1: print("Only a single BAM file is allowed when --groupTag is specified.") exit(0) if not args.labels: print("Please indicate the sample groups to be processed from the BAM file with --labels") exit(0) else: if args.labels and len(args.bamfiles) != len(args.labels): print( "The number of labels does not match the number of bam files. " "This is only allowed if a single BAM file is provided and --groupTag is specified." ) exit(0) if not args.labels: args.labels = smartLabels(args.bamfiles) ## Motif and GC filter if args.motifFilter: if not args.genome2bit: print("MotifFilter asked but genome (2bit) file not provided.") sys.exit(1) else: args.motifFilter = [x.strip(" ").split(",") for x in args.motifFilter] if args.GCcontentFilter: gc = args.GCcontentFilter.strip(" ").split(",") args.GCcontentFilter = [float(x) for x in gc] ## Barcodes + new labels (if required) if process_barcodes: with open(args.barcodes, "r") as f: barcodes = f.read().splitlines() f.close() args.barcodes = barcodes newlabels = ["{}::{}".format(a, b) for a in args.labels for b in barcodes] return args, newlabels else: return args