src/nf_modules/RSEM/tests.sh

-./nextflow src/nf_modules/RSEM/indexing.nf \
-  -c src/nf_modules/RSEM/indexing.config \
-  -profile docker \
-  --fasta "data/tiny_dataset/fasta/tiny_v2.fasta" \
-  --annotation "data/tiny_dataset/annot/tiny.gff"
-
-./nextflow src/nf_modules/RSEM/quantification_single.nf \
-  -c src/nf_modules/RSEM/quantification_single.config \
-  -profile docker \
-  --index "results/mapping/index/tiny_v2.index*" \
-  --fastq "data/tiny_dataset/fastq/tiny*_S.fastq"
-
-./nextflow src/nf_modules/RSEM/quantification_paired.nf \
-  -c src/nf_modules/RSEM/quantification_paired.config \
-  -profile docker \
-  --index "results/mapping/index/tiny_v2.index*" \
-  --fastq "data/tiny_dataset/fastq/tiny*_R{1,2}.fastq"
-

src/nf_modules/SAMtools/filter_bams.config

-profiles {
-  docker {
-    docker.temp = 'auto'
-    docker.enabled = true
-    process {
-      $filter_bam {
-        container = "samtools:1.7"
-      }
-    }
-  }
-  sge {
-    process{
-      $filter_bam {
-        beforeScript = "module purge; module load SAMtools/1.7"
-      }
-    }
-  }
-}

src/nf_modules/SAMtools/filter_bams.nf

-params.bam = "$baseDir/data/bam/*.bam"
-params.bed = "$baseDir/data/bam/*.bed"
-
-log.info "bams files : ${params.bam}"
-log.info "bed file : ${params.bed}"
-
-Channel
-  .fromPath( params.bam )
-  .ifEmpty { error "Cannot find any bam files matching: ${params.bam}" }
-  .map { it -> [(it.baseName =~ /([^\.]*)/)[0][1], it]}
-  .set { bam_files }
-Channel
-  .fromPath( params.bed )
-  .ifEmpty { error "Cannot find any bed file matching: ${params.bed}" }
-  .set { bed_files }
-
-process filter_bam {
-  tag "$file_id"
-  cpus 4
-
-  input:
-    set file_id, file(bam) from bam_files
-    file bed from bed_files
-
-  output:
-    set file_id, "*_filtered.bam*" into filtered_bam_files
-  script:
-"""
-samtools view -@ ${task.cpus} -hb ${bam} -L ${bed} > ${file_id}_filtered.bam
-"""
-}
-
-

src/nf_modules/SAMtools/index_bams.config

-profiles {
-  docker {
-    docker.temp = 'auto'
-    docker.enabled = true
-    process {
-      $index_bam {
-        container = "samtools:1.7"
-      }
-    }
-  }
-  sge {
-    process{
-      $index_bam {
-        beforeScript = "module purge; module load SAMtools/1.7"
-      }
-    }
-  }
-}

src/nf_modules/SAMtools/index_bams.nf

-params.bam = "$baseDir/data/bam/*.bam"
-
-log.info "bams files : ${params.bam}"
-
-Channel
-  .fromPath( params.bam )
-  .ifEmpty { error "Cannot find any bam files matching: ${params.bam}" }
-  .map { it -> [(it.baseName =~ /([^\.]*)/)[0][1], it]}
-  .set { bam_files }
-
-process index_bam {
-  tag "$file_id"
-
-  input:
-    set file_id, file(bam) from bam_files
-
-  output:
-    set file_id, "*.bam*" into indexed_bam_file
-
-  script:
-"""
-samtools index ${bam}
-"""
-}
-

src/nf_modules/SAMtools/sort_bams.config

-profiles {
-  docker {
-    docker.temp = 'auto'
-    docker.enabled = true
-    process {
-      $sort_bam {
-        container = "samtools:1.7"
-      }
-    }
-  }
-  sge {
-    process{
-      $sort_bam {
-        beforeScript = "module purge; module load SAMtools/1.7"
-      }
-    }
-  }
-}

src/nf_modules/SAMtools/sort_bams.nf

-params.bam = "$baseDir/data/bam/*.bam"
-
-log.info "bams files : ${params.bam}"
-
-Channel
-  .fromPath( params.bam )
-  .ifEmpty { error "Cannot find any bam files matching: ${params.bam}" }
-  .map { it -> [(it.baseName =~ /([^\.]*)/)[0][1], it]}
-  .set { bam_files }
-
-process sort_bam {
-  tag "$file_id"
-  cpus 4
-
-  input:
-    set file_id, file(bam) from bam_files
-
-  output:
-    set file_id, "*_sorted.bam" into sorted_bam_files
-
-  script:
-"""
-samtools sort -@ ${task.cpus} -O BAM -o ${file_id}_sorted.bam ${bam}
-"""
-}
-

src/nf_modules/SAMtools/split_bams.config

-profiles {
-  docker {
-    docker.temp = 'auto'
-    docker.enabled = true
-    process {
-      $split_bam {
-        container = "samtools:1.7"
-      }
-    }
-  }
-  sge {
-    process{
-      $split_bam {
-        beforeScript = "module purge; module load SAMtools/1.7"
-      }
-    }
-  }
-}

src/nf_modules/SAMtools/split_bams.nf

-params.bam = "$baseDir/data/bam/*.bam"
-
-log.info "bams files : ${params.bam}"
-
-Channel
-  .fromPath( params.bam )
-  .ifEmpty { error "Cannot find any bam files matching: ${params.bam}" }
-  .map { it -> [(it.baseName =~ /([^\.]*)/)[0][1], it]}
-  .set { bam_files }
-
-process split_bam {
-  tag "$file_id"
-  cpus 2
-
-  input:
-    set file_id, file(bam) from bam_files
-
-  output:
-    set file_id, "*_forward.bam*" into forward_bam_files
-    set file_id, "*_reverse.bam*" into reverse_bam_files
-  script:
-"""
-samtools view -hb -F 0x10 ${bam} > ${file_id}_forward.bam &
-samtools view -hb -f 0x10 ${bam} > ${file_id}_reverse.bam
-"""
-}
-

src/nf_modules/SAMtools/tests.sh

-./nextflow src/nf_modules/SAMtools/sort_bams.nf \
-  -c src/nf_modules/SAMtools/sort_bams.config \
-  -profile docker \
-  --bam "data/tiny_dataset/map/tiny_v2.bam"
-
-./nextflow src/nf_modules/SAMtools/index_bams.nf \
-  -c src/nf_modules/SAMtools/index_bams.config \
-  -profile docker \
-  --bam "data/tiny_dataset/map/tiny_v2.sort.bam"
-
-./nextflow src/nf_modules/SAMtools/split_bams.nf \
-  -c src/nf_modules/SAMtools/split_bams.config \
-  -profile docker \
-  --bam "data/tiny_dataset/map/tiny_v2.bam"
-
-./nextflow src/nf_modules/SAMtools/filter_bams.nf \
-  -c src/nf_modules/SAMtools/filter_bams.config \
-  -profile docker \
-  --bam "data/tiny_dataset/map/tiny_v2.bam" \
-  --bed "data/tiny_dataset/OLD/2genes.bed"

src/nf_modules/SRAtoolkit/fastqdump.config

-profiles {
-  docker {
-    docker.temp = 'auto'
-    docker.enabled = true
-    process {
-      $fastq_dump {
-        container = "sratoolkit:2.8.2"
-      }
-    }
-  }
-  sge {
-    process{
-      $fastq_dump {
-        beforeScript = "module purge; module load SRAtoolkit/2.8.2"
-        executor = "sge"
-        cpus = 1
-        memory = "5GB"
-        time = "6h"
-        queueSize = 1000
-        pollInterval = '60sec'
-        queue = 'monointeldeb128'
-      }
-    }
-  }
-}

src/nf_modules/SRAtoolkit/fastqdump.nf

-/*
-* sra-tools :
-
-*/
-
-/*                      fastq-dump
-* Imputs : srr list
-* Outputs : fastq files
-*/
-
-params.list_srr = "$baseDir/data/SRR/*.txt"
-
-log.info "downloading list srr : ${params.list_srr}"
-
-Channel
-  .fromPath( params.list_srr )
-  .ifEmpty { error "Cannot find any bam files matching: ${params.list_srr}" }
-  .splitCsv()
-  .map { it -> it[0]}
-  .set { SRR }
-
-//run is the column name containing SRR ids
-
-process fastq_dump {
-  tag "$file_id"
-  publishDir "results/download/fastq/${file_id}/", mode: 'copy'
-
-  input:
-    val file_id from SRR
-
-  output:
-    set file_id, "*.fastq" into fastq
-
-  script:
-"""
-#for test only 10000  reads are downloading with the option -N 10000 -X 20000
-fastq-dump --split-files --defline-seq '@\$ac_\$si/\$ri' --defline-qual "+" -N 10000 -X 20000 ${file_id}
-if [ -f ${file_id}_1.fastq ]
-then
-  mv ${file_id}_1.fastq ${file_id}_R1.fastq
-fi
-if [ -f ${file_id}_2.fastq ]
-then
-  mv ${file_id}_2.fastq ${file_id}_R2.fastq
-fi
-"""
-}

src/nf_modules/SRAtoolkit/tests.sh

-./nextflow src/nf_modules/SRAtoolkit/fastqdump.nf \
-  -c src/nf_modules/SRAtoolkit/fastqdump.config \
-  -profile docker \
-  --list_srr "src/nf_modules/SRAtoolkit/list-srr.txt"

src/nf_modules/UrQt/tests.sh

-./nextflow src/nf_modules/UrQt/trimming_paired.nf \
-  -c src/nf_modules/UrQt/trimming_paired.config \
-  -profile docker \
-  --fastq "data/tiny_dataset/fastq/tiny_R{1,2}.fastq"
-
-./nextflow src/nf_modules/UrQt/trimming_single.nf \
-  -c src/nf_modules/UrQt/trimming_single.config \
-  -profile docker \
-  --fastq "data/tiny_dataset/fastq/tiny_R{1,2}.fastq"

src/nf_modules/UrQt/trimming_paired.config

-profiles {
-  docker {
-    docker.temp = 'auto'
-    docker.enabled = true
-    process {
-      $trimming {
-        container = "urqt:d62c1f8"
-      }
-    }
-  }
-  sge {
-    process{
-      $trimming {
-        beforeScript = "module purge; module load UrQt/d62c1f8"
-        executor = "sge"
-        cpus = 4
-        memory = "5GB"
-        time = "6h"
-        queueSize = 1000
-        pollInterval = '60sec'
-        queue = 'h6-E5-2667v4deb128'
-        penv = 'openmp8'
-      }
-    }
-  }
-}

src/nf_modules/UrQt/trimming_paired.nf

-log.info "fastq files : ${params.fastq}"
-
-Channel
-  .fromFilePairs( params.fastq )
-  .ifEmpty { error "Cannot find any fastq files matching: ${params.fastq}" }
-  .set { fastq_files }
-
-process trimming {
-  tag "${reads}"
-  cpus 4
-  publishDir "results/fastq/trimming/", mode: 'copy'
-
-  input:
-  set pair_id, file(reads) from fastq_files
-
-  output:
-  set pair_id, "*_trim_R{1,2}.fastq.gz" into fastq_files_trim
-
-  script:
-"""
-UrQt --t 20 --m ${task.cpus} --gz \
---in ${reads[0]} --inpair ${reads[1]} \
---out ${pair_id}_trim_R1.fastq.gz --outpair ${pair_id}_trim_R2.fastq.gz \
-> ${pair_id}_trimming_report.txt
-"""
-}
-

src/nf_modules/UrQt/trimming_single.config

-profiles {
-  docker {
-    docker.temp = 'auto'
-    docker.enabled = true
-    process {
-      $trimming {
-        container = "urqt:d62c1f8"
-      }
-    }
-  }
-  sge {
-    process{
-      $trimming {
-        beforeScript = "module purge; module load UrQt/d62c1f8"
-        executor = "sge"
-        cpus = 4
-        memory = "5GB"
-        time = "6h"
-        queueSize = 1000
-        pollInterval = '60sec'
-        queue = 'h6-E5-2667v4deb128'
-        penv = 'openmp8'
-      }
-    }
-  }
-}

src/nf_modules/UrQt/trimming_single.nf

-params.fastq = "$baseDir/data/fastq/*.fastq"
-
-log.info "fastq files : ${params.fastq}"
-
-Channel
-  .fromPath( params.fastq )
-  .ifEmpty { error "Cannot find any fastq files matching: ${params.fastq}" }
-  .map { it -> [(it.baseName =~ /([^\.]*)/)[0][1], it]}
-  .set { fastq_files }
-
-process trimming {
-  tag "$file_id"
-  cpus 4
-
-  input:
-  set file_id, file(reads) from fastq_files
-
-  output:
-  set file_id, "*_trim.fastq.gz" into fastq_files_trim
-
-  script:
-  """
-  UrQt --t 20 --m ${task.cpus} --gz \
-  --in ${reads} \
-  --out ${file_id}_trim.fastq.gz \
-  > ${file_id}_trimming_report.txt
-  """
-}
-

src/nf_modules/UrQt/urqt.config

-profiles {
-  docker {
-    docker.temp = 'auto'
-    docker.enabled = true
-    process {
-      $trimming {
-        container = "urqt:d62c1f8"
-      }
-    }
-  }
-  sge {
-    process{
-      $trimming {
-        beforeScript = "module purge; module load UrQt/d62c1f8"
-        executor = "sge"
-        cpus = 4
-        memory = "5GB"
-        time = "6h"
-        queueSize = 1000
-        pollInterval = '60sec'
-        queue = 'h6-E5-2667v4deb128'
-        penv = 'openmp8'
-      }
-    }
-  }
-}

src/nf_modules/agat/main.nf

+// SPDX-FileCopyrightText: 2022 Laurent Modolo <laurent.modolo@ens-lyon.fr>
+//
+// SPDX-License-Identifier: AGPL-3.0-or-later
+
+version = "0.8.0"
+container_url = "lbmc/agat:${version}"
+
+params.gff_to_bed = ""
+params.gff_to_bed_out = ""
+process gff_to_bed {
+  container = "${container_url}"
+  label "big_mem_mono_cpus"
+  tag "$file_id"
+  if (params.gff_to_bed_out != "") {
+    publishDir "results/${params.gff_to_bed_out}", mode: 'copy'
+  }
+
+  input:
+    tuple val(file_id), path(gff)
+  output:
+    tuple val(file_id), path("*.bed"), emit: bed
+
+  script:
+"""
+zcat ${gff} > ${gff.baseName}.gff
+agat_convert_sp_gff2bed.pl ${params.gff_to_bed} --gff ${gff.baseName}.gff -o ${gff.simpleName}.bed
+"""
+}
+
+params.gff_to_gtf = ""
+params.gff_to_gtf_out = ""
+process gff_to_gtf {
+  container = "${container_url}"
+  label "big_mem_mono_cpus"
+  tag "$file_id"
+  if (params.gff_to_gtf_out != "") {
+    publishDir "results/${params.gff_to_gtf_out}", mode: 'copy'
+  }
+
+  input:
+    tuple val(file_id), path(gff)
+  output:
+    tuple val(file_id), path("*.gtf"), emit: gtf
+
+  script:
+"""
+zcat ${gff} > ${gff.baseName}.gff
+agat_convert_sp_gff2gtf.pl ${params.gff_to_gtf} --gff ${gff.baseName}.gff -o ${gff.simpleName}.gtf
+"""
+}
\ No newline at end of file