Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
19 changes: 12 additions & 7 deletions src/subcommands/fire.rs
Original file line number Diff line number Diff line change
Expand Up @@ -72,20 +72,25 @@ pub fn add_fire_to_bam(fire_opts: &mut FireOptions) -> Result<(), anyhow::Error>
let n_msps = rec.msp.annotations.len();
if fire_opts.skip_no_m6a || fire_opts.min_msp > 0 || fire_opts.min_ave_msp_size > 0
{
// skip no calls
if rec.m6a.annotations.is_empty() || n_msps == 0 {
// skip reads with no m6a calls
if fire_opts.skip_no_m6a && rec.m6a.annotations.is_empty() {
skip_because_no_m6a += 1;
continue;
}
//let max_msp_len = *rec.msp.lengths.iter().flatten().max().unwrap_or(&0);
if n_msps < fire_opts.min_msp {
skip_because_num_msp += 1;
continue;
}
let ave_msp_size = rec.msp.lengths().iter().sum::<i64>() / n_msps as i64;
if ave_msp_size < fire_opts.min_ave_msp_size {
skip_because_ave_msp_length += 1;
continue;
if fire_opts.min_ave_msp_size > 0 {
if n_msps == 0 {
skip_because_ave_msp_length += 1;
continue;
}
let ave_msp_size = rec.msp.lengths().iter().sum::<i64>() / n_msps as i64;
if ave_msp_size < fire_opts.min_ave_msp_size {
skip_because_ave_msp_length += 1;
continue;
}
}
}
out.write(&rec.record)?;
Expand Down
Loading