Add write,MSnExp and write,OnDiskMSnExp

DESCRIPTION

@@ -45,9 +45,9 @@ Depends:
     methods,
     BiocGenerics (>= 0.7.1),
     Biobase (>= 2.15.2),
-    mzR (>= 2.7.6),
+    mzR (>= 2.11.11),
     BiocParallel,
-    ProtGenerics (>= 1.5.1)
+    ProtGenerics (>= 1.9.1)
 Imports:
     plyr,
     IRanges,

NAMESPACE

@@ -286,7 +286,8 @@ exportMethods(updateObject,
               "$<-",
               chromatogram,
               "colnames<-",
-              reduce)
+              reduce,
+              writeMSData)
 
 ## methods NOT exported
 ## curveStats

NEWS

@@ -1,3 +1,8 @@
+Changes in version 2.3.11
+-------------------------
+- Add write support for MSnExp and OnDiskMSnExp objects allowing to save the MS
+  data to mzML or mzXML files. <2017-09-15 Fri>
+
 Changes in version 2.3.10
 -------------------------
 - New `isCentroidedFromFile` function <2017-08-11 Fri>

NEWS.md

@@ -1,7 +1,8 @@
 # MSnbase 2.3
 
 ## Changes in version 2.3.11
-- Nothing yet <2017-09-07 Thu>
+- Add write support for MSnExp and OnDiskMSnExp objects allowing to save the MS
+  data to mzML or mzXML files. <2017-09-15 Fri>
 
 ## Changes in version 2.3.10
 - New `isCentroidedFromFile` function <2017-08-11 Fri>

R/AllGenerics.R

@@ -146,4 +146,3 @@ setGeneric("splitByFile", function(object, f, ...) standardGeneric("splitByFile"
 ## setGeneric("productMz", function(object, value) standardGeneric("productMz"))
 ## setGeneric("aggregationFun", function(object, ...)
 ##     standardGeneric("aggregationFun"))
-

R/functions-OnDiskMSnExp.R

@@ -591,7 +591,7 @@ precursorValue_OnDiskMSnExp <- function(object, column) {
                     ## Return an empty Chromatogram if there is no spectrum/scan
                     ## within the retention time range.
                     if (!any(in_rt)) {
-                        cur_res[[i]] <- Chromatogram(
+                        cur_res[[i]] <- MSnbase::Chromatogram(
                             filterMz = mzm[i, ],
                             fromFile = as.integer(cur_file),
                             aggregationFun = aggFun)
@@ -627,7 +627,7 @@ precursorValue_OnDiskMSnExp <- function(object, column) {
                     if (!all(is.na(ints)))
                         mz_range <- range(allVals[-c(int_idx, mslevel_idx)],
                                           na.rm = TRUE, finite = TRUE)
-                    cur_res[[i]] <- Chromatogram(
+                    cur_res[[i]] <- MSnbase::Chromatogram(
                         rtime = rts[in_rt],
                         intensity = ints,
                         mz = mz_range,
@@ -656,7 +656,7 @@ precursorValue_OnDiskMSnExp <- function(object, column) {
         for (i in empties) {
             empty_list <- vector(mode = "list", length = nrow(rt))
             for(j in 1:nrow(rt)) {
-                empty_list[[j]] <- Chromatogram(filterMz = mz[j, ],
+                empty_list[[j]] <- MSnbase::Chromatogram(filterMz = mz[j, ],
                                                 fromFile = as.integer(i),
                                                 aggregationFun = aggregationFun)
             }

R/functions-Spectrum.R

@@ -494,3 +494,77 @@ validSpectrum <- function(object) {
     if (is.null(msg)) TRUE
     else stop(msg)
 }
+
+#' @description `.spectrum_header` extracts the header information from a
+#'     `Spectrum` object and returns it as a named numeric vector.
+#'
+#' @note We can not get the following information from Spectrum
+#' objects:
+#' - ionisationEnergy
+#' - mergedResultScanNum
+#' - mergedResultStartScanNum
+#' - mergedResultEndScanNum
+#' 
+#' @param x `Spectrum` object.
+#'
+#' @return A named `numeric` with the following fields:
+#' - acquisitionNum
+#' - msLevel
+#' - polarity
+#' - peaksCount
+#' - totIonCurrent
+#' - retentionTime
+#' - basePeakMZ
+#' - collisionEnergy
+#' - ionisationEnergy
+#' - lowMZ
+#' - highMZ
+#' - precursorScanNum
+#' - precursorMZ
+#' - precurorCharge
+#' - precursorIntensity
+#' - mergedScan
+#' - mergedResultScanNum
+#' - mergedResultStartScanNum
+#' - mergedResultEndScanNum
+#' - injectionTime
+#' 
+#' @author Johannes Rainer
+#'
+#' @md
+#'
+#' @noRd
+.spectrum_header <- function(x) {
+    res <- c(acquisitionNum = acquisitionNum(x),
+             msLevel = msLevel(x),
+             polarity = polarity(x),
+             peaksCount = peaksCount(x),
+             totIonCurrent = tic(x),
+             retentionTime = rtime(x),
+             basePeakMZ = mz(x)[which.max(intensity(x))][1],
+             basePeakIntensity = max(intensity(x)),
+             collisionEnergy = 0,
+             ionisationEnergy = 0,      # How to get that?
+             lowMZ = min(mz(x)),
+             highMZ = max(mz(x)),
+             precursorScanNum = 0,
+             precursorMZ = 0,
+             precursorCharge = 0,
+             precursorIntensity = 0,
+             mergedScan = 0,
+             mergedResultScanNum = 0,   # ???
+             mergedResultStartScanNum = 0, # ???
+             mergedResultEndScanNum = 0,   # ???
+             injectionTime = 0            # Don't have that
+             )
+    if (msLevel(x) > 1) {
+        res["collisionEnergy"] <- collisionEnergy(x)
+        res["precursorScanNum"] <- precScanNum(x)
+        res["precursorMZ"] <- precursorMz(x)
+        res["precursorCharge"] <- precursorCharge(x)
+        res["precursorIntensity"] <- precursorIntensity(x)
+        res["mergedScan"] <- x@merged
+    }
+    res
+}
+

R/methods-pSet.R

@@ -532,8 +532,7 @@ setMethod("spectrapply", "pSet", function(object, FUN = NULL,
     BPPARAM <- getBpParam(object, BPPARAM = BPPARAM)
     if (is.null(FUN))
         return(spectra(object))
-    vals <- bplapply(spectra(object), FUN = FUN, BPPARAM = BPPARAM, ...)
-    return(vals)
+    bplapply(spectra(object), FUN = FUN, BPPARAM = BPPARAM, ...)
 })
 
 setMethod("$", "pSet", function(x, name) {

R/methods-write.R

@@ -0,0 +1,73 @@
+#' @title Write MS data to mzML or mzXML files
+#'
+#' @aliases writeMSData
+#' 
+#' @description The `writeMSData,MSnExp` and `writeMSData,OnDiskMSnExp` saves
+#'     the content of a [MSnExp] or [OnDiskMSnExp] object to MS file(s) in
+#'     either *mzML* or *mzXML* format.
+#'
+#' @details The `writeMSData` method uses the *proteowizard* libraries through
+#'     the `mzR` package to save the MS data. The data can be written to
+#'     *mzML* or *mzXML* files with or without copying additional metadata
+#'     information from the original files from which the data was read by the
+#'     [readMSData()] function. This can be set using the `copy` parameter.
+#'     Note that `copy = TRUE` requires the original files to be available and
+#'     is not supported for input files in other than mzML or mzXML format.
+#'
+#' @note General spectrum data such as total ion current, peak count, base peak
+#'     m/z or base peak intensity are calculated from the actual spectrum data
+#'     before writing the data to the files.
+#'
+#'     For MSn data, if the `OnDiskMSnExp` or `MSnExp` does not contain also the
+#'     precursor scan of a MS level > 1 spectrum `precursorMZ`,
+#'     `precursorCharge` and `precursorIntensity` of the spectrum is set to 0
+#'     in the output file.
+#' 
+#' @param object `OnDiskMSnExp` or `MSnExp` object.
+#'
+#' @param file `character` with the file name(s). Its length has to match the
+#'     number of samples/files of `x`.
+#'
+#' @param outformat `character(1)` defining the format of the output files.
+#'     Default output format is `"mzml"`.
+#'
+#' @param merge `logical(1)` whether the data should be saved into a single
+#'     *mzML* file. Default is `merge = FALSE`, i.e. each sample is saved to
+#'     a separate file. **Note**: `merge = TRUE` is not yet implemented.
+#'
+#' @param verbose `logical(1)` if progress messages should be displayed.
+#'
+#' @param copy `logical(1)` if metadata (data processings, original file names
+#'     etc) should be copied from the original files. See details for more
+#'     information.
+#' 
+#' @param software_processing optionally provide specific data processing steps.
+#'     See documentation of the `software_processing` parameter of
+#'     [mzR::writeMSData()].
+#' 
+#' @author Johannes Rainer
+#' 
+#' @md
+#'
+#' @rdname writeMSData
+setMethod("writeMSData", signature(object = "MSnExp", file = "character"),
+          function(object, file, outformat = c("mzml", "mzxml"),
+                   merge = FALSE, verbose = isMSnbaseVerbose(), copy = FALSE,
+                   software_processing = NULL) {
+              ## Set copy to false if not all original files are available.
+              if (copy & !all(file.exists(fileNames(object)))) {
+                  warning("Setting 'copy = FALSE' because the original files ",
+                          "can not be found.")
+                  copy <- FALSE
+              }
+              if (merge) {
+                  stop("Not yet implemented.")
+                  ## Set copy to FALSE
+                  ## Call .writeMSDataMerged
+              } else {
+                  .writeMSData(object = object, file = file,
+                               outformat = outformat, verbose = verbose,
+                               copy = copy, software_processing)
+              }
+          })
+

R/options.R

@@ -60,5 +60,9 @@ setMSnbaseFastLoad <- function(opt = TRUE) {
 
 ##' @rdname MSnbaseOptions
 isMSnbaseFastLoad <- function() {
-    MSnbaseOptions()$fastLoad
+    fast_load <- MSnbaseOptions()$fastLoad
+    ## For some odd reasons we get also NULL back - parallel processing?
+    if (!length(fast_load))
+        fast_load <- FALSE
+    fast_load
 }

R/utils.R

@@ -1065,7 +1065,8 @@ setMethod("isEmpty", "environment",
 isOnDisk <- function(object)
     any(grepl("spectraProcessingQueue", slotNames(object)))
 
-## Simple function to determine whether parallel or serial processing should be performed
+## Simple function to determine whether parallel or serial processing should be
+## performed.
 ## Check testthat/test_OnDiskMSnExp_benchmarks.R for performance comparisons.
 ## Parameter object is expected to beb a
 getBpParam <- function(object, BPPARAM=bpparam()) {
@@ -1075,14 +1076,8 @@ getBpParam <- function(object, BPPARAM=bpparam()) {
     ## If it's empty, return SerialParam
     if (length(object) == 0)
         return(SerialParam())
-    ## if (is(object, "OnDiskMSnExp")) {
-    ##     ## Return SerialParam if we access less than PARALLEL_THRESH spectra per file.
-    ##     if (mean(table(fData(object)$fileIdx)) < parallel_thresh)
-    ##         return(SerialParam())
-    ## } else {
-        if (length(object) < parallel_thresh)
-            return(SerialParam())
-    ## }
+    if (length(object) < parallel_thresh)
+        return(SerialParam())
     return(BPPARAM)
 }