bam

bam is a crate that allows to read BAM files, written completely in Rust. Currently, it allows to read BAM files in indexed and consecutive modes (bam::IndexedReader and bam::Reader). The future versions will support writing BAM files.

Why?

Having a crate written completely in Rust reduces the number of dependencies and compilation time. Additionally, it removes the need to install additional C libraries.

Errors produced by this crate are more readable and easier to catch and fix on-the-fly.

Usage

Currently, there are two readers: * bam::IndexedReader, which allows to fetch records from random genomic regions, * bam::Reader, which allows to read the BAM file consecutively.

IndexedReader

The following code would load BAM file test.bam and its index test.bam.bai, take all records from 2:100001-200000 and print them on the stdout.

```rust extern crate bam;

fn main() { let mut reader = bam::IndexedReader::from_path("test.bam").unwrap();

// We need to clone the header to have access to reference names as the
// reader will be blocked during fetch.
let header = reader.header().clone();
let mut stdout = std::io::BufWriter::new(std::io::stdout());

for record in reader.fetch(1, 100_000, 200_000) {
    record.unwrap().write_sam(&mut stdout, &header).unwrap();
}

} ```

Additionally, you can use read_into(&mut record) to save time on record allocation: ```rust extern crate bam;

// You need to import BamReader trait use bam::BamReader;

fn main() { let mut reader = bam::IndexedReader::from_path("test.bam").unwrap();

let header = reader.header().clone();
let mut stdout = std::io::BufWriter::new(std::io::stdout());

let mut viewer = reader.fetch(1, 100_000, 200_000);
let mut record = bam::Record::new();
loop {
    match viewer.read_into(&mut record) {
        Ok(()) => {},
        Err(bam::Error::NoMoreRecords) => break,
        Err(e) => panic!("{}", e),
    }
    record.write_sam(&mut stdout, &header).unwrap();
}

} ```

Note that currently printing the read is much slower than loading it. Without printing, it takes almost the same time to load records using bam crate and samtools view.

If only records with specific MAPQ or FLAGs are needed, you can use fetch_by. For example, rust reader.fetch_by(1, 100_000, 200_000, |record| record.mapq() >= 30 && !record.is_secondary()) to load only records with MAPQ at least 30 and skip all secondary alignments. In some cases it helps to save time by not calculating the right-most aligned read position, as well as remove additional allocations.

You can also use IndexedReaderBuilder, which gives more control over loading IndexedReader. For example you can create a reader using a different BAI path, and a different cache capacity: rust let mut reader = bam::IndexedReader::build() .bai_path("other_dir/test.bai") .cache_capacity(10000) .from_path("test.bam").unwrap();

Reader

Reader allows to read all records from the BAM file consecutively. Reader itself is an iterator and implements the same trait BamReader, which allows to load records similarly: ```rust extern crate bam;

fn main() { let reader = bam::Reader::from_path("test.bam").unwrap();

let header = reader.header().clone();
let mut stdout = std::io::BufWriter::new(std::io::stdout());

for record in reader {
    record.unwrap().write_sam(&mut stdout, &header).unwrap();
}

} ```

Similarly, you can skip allocation with ```rust extern crate bam;

// You need to import BamReader trait use bam::BamReader;

fn main() { let mut reader = bam::Reader::from_path("test.bam").unwrap();

let header = reader.header().clone();
let mut stdout = std::io::BufWriter::new(std::io::stdout());

let mut record = bam::Record::new();
loop {
    match reader.read_into(&mut record) {
        Ok(()) => {},
        Err(bam::Error::NoMoreRecords) => break,
        Err(e) => panic!("{}", e),
    }
    record.write_sam(&mut stdout, &header).unwrap();
}

} ```

However, there is no way to skip records using a predicate like fetch_by.

CRC32

Each bgzip block contains a CRC32 checksum. By default, the bam crate does not compare checksums to save time. However, you can compare checksums by adding the following line to your Cargo.toml: bam = { version = "*", features = ["check_crc"] }

Changelog

Future versions