gclib/tophat_cpp/tophat_reports.cpp

/*
 *  tophat_reports.cpp
 *  TopHat
 *
 *  Created by Cole Trapnell on 11/20/08.
 *  Copyright 2008 Cole Trapnell. All rights reserved.
 *
 */

#ifdef HAVE_CONFIG_H
#include <config.h>
#else
#define PACKAGE_VERSION "INTERNAL"
#define SVN_REVISION "XXX"
#endif

#include <cassert>
#include <cstdio>
#include <cstring>
#include <vector>
#include <string>
#include <map>
#include <algorithm>
#include <set>
#include <stdexcept>
#include <iostream>
#include <fstream>
#include <seqan/sequence.h>
#include <seqan/find.h>
#include <seqan/file.h>
#include <getopt.h>

#include <boost/thread.hpp>
#include <boost/random/mersenne_twister.hpp>

#include "common.h"
#include "utils.h"
#include "bwt_map.h"
#include "junctions.h"
#include "insertions.h"
#include "deletions.h"
#include "fusions.h"
#include "align_status.h"
#include "fragments.h"
#include "wiggles.h"
#include "tokenize.h"
#include "reads.h"
#include "coverage.h"


#include "inserts.h"

using namespace std;
using namespace seqan;
using std::set;

static const JunctionSet empty_junctions;
static const InsertionSet empty_insertions;
static const DeletionSet empty_deletions;
static const FusionSet empty_fusions;
static const Coverage empty_coverage;

// daehwan - this is redundancy, which should be removed.
void get_seqs(istream& ref_stream,
              RefSequenceTable& rt,
              bool keep_seqs = true)
{    
  while(ref_stream.good() && !ref_stream.eof())
    {
      RefSequenceTable::Sequence* ref_str = new RefSequenceTable::Sequence();
      string name;
      readMeta(ref_stream, name, Fasta());
      string::size_type space_pos = name.find_first_of(" \t\r");
      if (space_pos != string::npos)
        {
          name.resize(space_pos);
        }
      fprintf(stderr, "\tLoading %s...", name.c_str());
      seqan::read(ref_stream, *ref_str, Fasta());
      fprintf(stderr, "done\n");
      
      rt.get_id(name, keep_seqs ? ref_str : NULL, 0);
    }
}

struct cmp_read_alignment
{
  bool operator() (const BowtieHit& l, const BowtieHit& r) const
  {
    return l.alignment_score() > r.alignment_score();
  }
};

void read_best_alignments(const HitsForRead& hits_for_read,
                          HitsForRead& best_hits,
                          const JunctionSet& gtf_junctions,
                          const JunctionSet& junctions = empty_junctions,
                          const InsertionSet& insertions = empty_insertions,
                          const DeletionSet& deletions = empty_deletions,
                          const FusionSet& fusions = empty_fusions,
                          const Coverage& coverage = empty_coverage,
                          bool final_report = false)
{
  const vector<BowtieHit>& hits = hits_for_read.hits;

  if (hits.size() >= max_multihits * 5)
    return;

  for (size_t i = 0; i < hits.size(); ++i)
    {
      if (hits[i].edit_dist() > max_read_mismatches)
        continue;

      BowtieHit hit = hits[i];
      AlignStatus align_status(hit, gtf_junctions,
                               junctions, insertions, deletions, fusions, coverage);
      hit.alignment_score(align_status._alignment_score);

      if (report_secondary_alignments || !final_report)
        {
          best_hits.hits.push_back(hit);
        }
      else
        {
          // Is the new status better than the current best one?
          if (best_hits.hits.size() == 0 || cmp_read_alignment()(hit, best_hits.hits[0]))
            {
              best_hits.hits.clear();
              best_hits.hits.push_back(hit);
            }
          else if (!cmp_read_alignment()(best_hits.hits[0], hit)) // is it just as good?
            {
              best_hits.hits.push_back(hit);
            }
        }
    }

  if ((report_secondary_alignments || !final_report) && best_hits.hits.size() > 0)
    {
      sort(best_hits.hits.begin(), best_hits.hits.end(), cmp_read_alignment());
    }

  if (final_report)
    {
      if (best_hits.hits.size() > max_multihits)
        best_hits.hits.erase(best_hits.hits.begin() + max_multihits, best_hits.hits.end());
    }
}

bool set_insert_alignment_grade(const BowtieHit& lh, const BowtieHit& rh, const JunctionSet& junctions, InsertAlignmentGrade& grade)
{
  bool fusion = false;
  bool left_fusion = lh.fusion_opcode() != FUSION_NOTHING;
  bool right_fusion = rh.fusion_opcode() != FUSION_NOTHING;
  if (left_fusion && right_fusion)
    return false;
  
  fusion = left_fusion || right_fusion;
  if (!fusion && lh.ref_id() != rh.ref_id())
    fusion = true;
  
  if (!fusion && lh.ref_id() == rh.ref_id())
    {
      if (lh.antisense_align() == rh.antisense_align())
        fusion = true;
      else
        {
          int inner_dist = 0;
          if (lh.antisense_align())
            // used rh.left() instead of rh.right() for the cases,
            // where reads overlap with each other or reads span introns
            inner_dist = lh.left() - rh.left(); 
          else
            inner_dist = rh.left() - lh.left();
          
          if (inner_dist < 0 || inner_dist > (int)fusion_min_dist)
            fusion = true;
        }
    }

  // a read contains its partner, in which case the paired mapping will be ignored.
  if (!fusion)
    {
      if (lh.left() <= rh.left() && lh.right() >= rh.right() && lh.right() - lh.left() > rh.right() - rh.left())
        return false;
      else if (rh.left() <= lh.left() && rh.right() >= lh.right() && rh.right() - rh.left() > lh.right() - lh.left())
        return false;
    }

  grade = InsertAlignmentGrade(lh, rh, junctions, fusion);
  
  return true;
}

struct cmp_pair_alignment
{
  cmp_pair_alignment(const JunctionSet& junctions) :
    _junctions(&junctions) {}
    
  bool operator() (const pair<BowtieHit, BowtieHit>& l, const pair<BowtieHit, BowtieHit>& r) const
  {
    InsertAlignmentGrade gl; set_insert_alignment_grade(l.first, l.second, *_junctions, gl);
    InsertAlignmentGrade gr; set_insert_alignment_grade(r.first, r.second, *_junctions, gr);

    bool better = gr < gl;
    bool worse = gl < gr;

    if (better && !worse)
      return true;
    else        
      return false;
  }

  const JunctionSet* _junctions;
};

void pair_best_alignments(const HitsForRead& left_hits,
                          const HitsForRead& right_hits,
                          InsertAlignmentGrade& best_grade,
                          vector<pair<BowtieHit, BowtieHit> >& best_hits,
                          const JunctionSet& gtf_junctions,
                          const JunctionSet& junctions = empty_junctions,
                          const InsertionSet& insertions = empty_insertions,
                          const DeletionSet& deletions = empty_deletions,
                          const FusionSet& fusions = empty_fusions,
                          const Coverage& coverage = empty_coverage,
                          bool final_report = false)
{
  const vector<BowtieHit>& left = left_hits.hits;
  const vector<BowtieHit>& right = right_hits.hits;

  if (left.size() >= max_multihits * 5 || right.size() >= max_multihits * 5)
    return;

  for (size_t i = 0; i < left.size(); ++i)
    {
      if (left[i].edit_dist() > max_read_mismatches) continue;

      BowtieHit lh = left[i];
      AlignStatus align_status(lh, gtf_junctions,
                               junctions, insertions, deletions, fusions, coverage);
      lh.alignment_score(align_status._alignment_score);

      for (size_t j = 0; j < right.size(); ++j)
        {
          if (right[j].edit_dist() > max_read_mismatches) continue;
          
          BowtieHit rh = right[j];
          AlignStatus align_status(rh, gtf_junctions,
                                   junctions, insertions, deletions, fusions, coverage);
          rh.alignment_score(align_status._alignment_score);
          InsertAlignmentGrade g;
          bool allowed;
          allowed = set_insert_alignment_grade(lh, rh, final_report ? junctions : gtf_junctions, g);

          // daehwan - for debugging purposes
#if 0
          if (lh.insert_id() == 325708 && !g.is_fusion() && false)
            {
              fprintf(stderr, "lh %d:%d %s score: %d (from %d) NM: %d\n",
                      lh.ref_id(), lh.left(), print_cigar(lh.cigar()).c_str(),
                      lh.alignment_score(), left[i].alignment_score(), lh.edit_dist());
              fprintf(stderr, "rh %d:%d %s score: %d (from %d) NM: %d\n",
                      rh.ref_id(), rh.left(), print_cigar(rh.cigar()).c_str(),
                      rh.alignment_score(), right[j].alignment_score(), rh.edit_dist());
              fprintf(stderr, "combined score: %d is_fusion(%d)\n", g.align_score(), g.is_fusion());
            }
#endif

          if (!allowed) continue;
          if (!fusion_search && !report_discordant_pair_alignments && g.is_fusion()) continue;

          if (report_secondary_alignments || !final_report)
            {
              best_hits.push_back(make_pair(lh, rh));
            }
          else
            {
              // Is the new status better than the current best one?
              if (best_grade < g)
                {
                  best_hits.clear();
                  best_grade = g;
                  best_hits.push_back(make_pair(lh, rh));
                }
              else if (!(g < best_grade))
                {
                  best_hits.push_back(make_pair(lh, rh));
                }
            }
        }
    }
 
  if ((report_secondary_alignments || !final_report) && best_hits.size() > 0)
    {
      cmp_pair_alignment cmp(final_report ? junctions : gtf_junctions);
      sort(best_hits.begin(), best_hits.end(), cmp);
      set_insert_alignment_grade(best_hits[0].first, best_hits[0].second, final_report ? junctions : gtf_junctions, best_grade);
    }

  if (final_report)
    {
      if (best_hits.size() > max_multihits)
        best_hits.erase(best_hits.begin() + max_multihits, best_hits.end());
    }
  
  best_grade.num_alignments = best_hits.size();
}

enum FragmentType {FRAG_UNPAIRED, FRAG_LEFT, FRAG_RIGHT};

void add_auxData(vector<string>& auxdata, vector<string>& sam_toks,
                 const RefSequenceTable& rt,const BowtieHit& bh, FragmentType insert_side,
                 int num_hits, const BowtieHit* next_hit, int hitIndex) {
  bool XS_found = false;
  if (sam_toks.size()>11) {
    
    for (size_t i=11;i<sam_toks.size();++i) {
      if (sam_toks[i].find("NH:i:")==string::npos &&
          sam_toks[i].find("XS:i:")==string::npos)
        auxdata.push_back(sam_toks[i]);

      if (sam_toks[i].find("XS:A:")!=string::npos)
        XS_found = true;
    }
  }
  string aux("NH:i:");
  str_appendInt(aux, num_hits);
  auxdata.push_back(aux);
  if (next_hit) {
    const char* nh_ref_name = "=";
    nh_ref_name = rt.get_name(next_hit->ref_id());
    assert (nh_ref_name != NULL);
    bool same_contig=(next_hit->ref_id()==bh.ref_id());
    aux="CC:Z:";
    aux+= (same_contig ? "=" : nh_ref_name);
    auxdata.push_back(aux);
    aux="CP:i:";
    int nh_gpos=next_hit->left() + 1;
    str_appendInt(aux, nh_gpos);
    auxdata.push_back(aux);
  } //has next_hit
    // FIXME: this code is still a bit brittle, because it contains no
    // consistency check that the mates are on opposite strands - a current protocol
    // requirement, and that the strand indicated by the alignment is consistent
    // with the orientation of the splices (though that should be handled upstream).
  if (!XS_found) {
    const string xs_f("XS:A:+");
    const string xs_r("XS:A:-");
    if (library_type == FR_FIRSTSTRAND) {
      if (insert_side == FRAG_LEFT || insert_side == FRAG_UNPAIRED) {
        if (bh.antisense_align())
          auxdata.push_back(xs_f);
        else
          auxdata.push_back(xs_r);
      }
      else {
        if (bh.antisense_align())
          auxdata.push_back(xs_r);
        else
          auxdata.push_back(xs_f);
      }
    }
    else if (library_type == FR_SECONDSTRAND)   {
      if (insert_side == FRAG_LEFT || insert_side == FRAG_UNPAIRED){
        if (bh.antisense_align())
          auxdata.push_back(xs_r);
        else
          auxdata.push_back(xs_f);
      }
      else
        {
          if (bh.antisense_align())
            auxdata.push_back(xs_f);
          else
            auxdata.push_back(xs_r);
        }
    }
  }
  if (hitIndex >= 0)
    {
      string aux("HI:i:");
      str_appendInt(aux, hitIndex);
      auxdata.push_back(aux);
    }
}

bool rewrite_sam_record(GBamWriter& bam_writer,
                        const RefSequenceTable& rt,
                        const BowtieHit& bh,
                        const char* bwt_buf,
                        const char* read_alt_name,
                        FragmentType insert_side,
                        int num_hits,
                        const BowtieHit* next_hit,
                        bool primary,
                        int hitIndex)
{
  // Rewrite this hit, filling in the alt name, mate mapping
  // and setting the pair flag
  vector<string> sam_toks;
  tokenize(bwt_buf, "\t", sam_toks);

  string ref_name = sam_toks[2], ref_name2 = "";
  char cigar1[1024] = {0}, cigar2[1024] = {0};
  string left_seq, right_seq, left_qual, right_qual;
  int left1 = -1, left2 = -1;
  bool fusion_alignment = false;
  size_t XF_index = 0;
  for (size_t i = 11; i < sam_toks.size(); ++i)
    {
      string& tok = sam_toks[i];
      if (strncmp(tok.c_str(), "XF", 2) == 0)
        {
          fusion_alignment = true;
          XF_index = i;
          
          vector<string> tuple_fields;
          tokenize(tok.c_str(), " ", tuple_fields);
          vector<string> contigs;
          tokenize(tuple_fields[1].c_str(), "-", contigs);
          if (contigs.size() >= 2)
            {
              ref_name = contigs[0];
              ref_name2 = contigs[1];
            }   
          
          extract_partial_hits(bh, tuple_fields[4].c_str(), tuple_fields[5].c_str(),
                               cigar1, cigar2, left_seq, right_seq,
                               left_qual, right_qual, left1, left2);
          
          break;
        }

      else if (strncmp(tok.c_str(), "AS", 2) == 0)
        {
          char AS_score[128] = {0};
          sprintf(AS_score, "AS:i:%d", min(0, bh.alignment_score()));
          tok = AS_score;
        }
    }
  
  string qname(read_alt_name);
  size_t slash_pos=qname.rfind('/');
  if (slash_pos!=string::npos)
    qname.resize(slash_pos);
  //read_alt_name as QNAME
  int flag=atoi(sam_toks[1].c_str()); //FLAG
  if (insert_side != FRAG_UNPAIRED) {
    //flag = atoi(sam_toks[1].c_str());
    // mark this as a singleton mate
    flag |= 0x0001;
    if (insert_side == FRAG_LEFT)
      flag |= 0x0040;
    else if (insert_side == FRAG_RIGHT)
      flag |= 0x0080;
    flag |= 0x0008;
    //char flag_buf[64];
    //sprintf(flag_buf, "%d", flag);
    //sam_toks[t] = flag_buf;
  }
  if (!primary)
    flag |= 0x100;
  
  int gpos=isdigit(sam_toks[3][0]) ? atoi(sam_toks[3].c_str()) : 0;
  int mapQ = 50;
  if (num_hits > 1)  {
    double err_prob = 1 - (1.0 / num_hits);
    mapQ = (int)(-10.0 * log(err_prob) / log(10.0));
  }
  int tlen =atoi(sam_toks[8].c_str()); //TLEN
  int mate_pos=atoi(sam_toks[7].c_str());

  string rg_aux = "";
  if (!sam_readgroup_id.empty())
      rg_aux = string("RG:Z:") + sam_readgroup_id;

  GBamRecord* bamrec=NULL;
  if (fusion_alignment) {
    vector<string> auxdata;
    add_auxData(auxdata, sam_toks, rt, bh, insert_side, num_hits, next_hit, hitIndex);
    if (rg_aux != "")
      auxdata.push_back(rg_aux);
    bamrec=bam_writer.new_record(qname.c_str(), flag, ref_name.c_str(), left1 + 1, mapQ,
                                 cigar1, sam_toks[6].c_str(), mate_pos,
                                 tlen, left_seq.c_str(), left_qual.c_str(), &auxdata);
    bam_writer.write(bamrec);
    delete bamrec;

    auxdata.clear();
    sam_toks[XF_index][5] = '2';
    add_auxData(auxdata, sam_toks, rt, bh, insert_side, num_hits, next_hit, hitIndex);
    if (rg_aux != "")
      auxdata.push_back(rg_aux);
    bamrec=bam_writer.new_record(qname.c_str(), flag, ref_name2.c_str(), left2 + 1, mapQ,
                                 cigar2, sam_toks[6].c_str(), mate_pos,
                                 tlen, right_seq.c_str(), right_qual.c_str(), &auxdata);
    bam_writer.write(bamrec);
    delete bamrec;
  } else {
    vector<string> auxdata;
    add_auxData(auxdata, sam_toks, rt, bh, insert_side, num_hits, next_hit, hitIndex);
    if (rg_aux != "")
      auxdata.push_back(rg_aux);
    bamrec=bam_writer.new_record(qname.c_str(), flag, sam_toks[2].c_str(), gpos, mapQ,
                                 sam_toks[5].c_str(), sam_toks[6].c_str(), mate_pos,
                                 tlen, sam_toks[9].c_str(), sam_toks[10].c_str(), &auxdata);
    bam_writer.write(bamrec);
    delete bamrec;
  }
    
  return true;
}

bool rewrite_sam_record(GBamWriter& bam_writer,
                        const RefSequenceTable& rt,
                        const BowtieHit& bh,
                        const char* bwt_buf,
                        const char* read_alt_name,
                        const InsertAlignmentGrade& grade,
                        FragmentType insert_side,
                        const BowtieHit* partner,
                        int num_hits,
                        const BowtieHit* next_hit,
                        bool primary,
                        int hitIndex)
{
  // Rewrite this hit, filling in the alt name, mate mapping
  // and setting the pair flag
  vector<string> sam_toks;
  tokenize(bwt_buf, "\t", sam_toks);
  string qname(read_alt_name);
  size_t slash_pos=qname.rfind('/');
  if (slash_pos!=string::npos)
    qname.resize(slash_pos);
  //read_alt_name as QNAME
  int flag = atoi(sam_toks[1].c_str());
  // 0x0010 (strand of query) is assumed to be set correctly
  // to begin with
  flag |= 0x0001; //it must be paired
  if (insert_side == FRAG_LEFT)
    flag |= 0x0040;
  else if (insert_side == FRAG_RIGHT)
    flag |= 0x0080;
  if (!primary)
    flag |= 0x100;

  string ref_name = sam_toks[2], ref_name2 = "";
  char cigar1[1024] = {0}, cigar2[1024] = {0};
  string left_seq, right_seq, left_qual, right_qual;
  int left1 = -1, left2 = -1;
  bool fusion_alignment = false;
  size_t XF_tok_idx = 11;
  for (; XF_tok_idx < sam_toks.size(); ++XF_tok_idx)
    {
      string& tok = sam_toks[XF_tok_idx];
      if (strncmp(tok.c_str(), "XF", 2) == 0)
        {
          fusion_alignment = true;
          
          vector<string> tuple_fields;
          tokenize(tok.c_str(), " ", tuple_fields);
          vector<string> contigs;
          tokenize(tuple_fields[1].c_str(), "-", contigs);
          if (contigs.size() >= 2)
            {
              ref_name = contigs[0];
              ref_name2 = contigs[1];
            }   
          
          extract_partial_hits(bh, tuple_fields[4].c_str(), tuple_fields[5].c_str(),
                               cigar1, cigar2, left_seq, right_seq,
                               left_qual, right_qual, left1, left2);
          
          break;
        }

      else if (strncmp(tok.c_str(), "AS", 2) == 0)
        {
          char AS_score[128] = {0};
          sprintf(AS_score, "AS:i:%d", min(0, bh.alignment_score()));
          tok = AS_score;
        }
    }
  
  int gpos=isdigit(sam_toks[3][0]) ? atoi(sam_toks[3].c_str()) : 0;
  int mapQ = 50;
  if (grade.num_alignments > 1) {
    double err_prob = 1 - (1.0 / grade.num_alignments);
    mapQ = (int)(-10.0 * log(err_prob) / log(10.0));
  }
  int tlen=0; //TLEN
  int mate_pos=atoi(sam_toks[7].c_str());
  if (partner) {
    if (partner->ref_id()==bh.ref_id()) {
      sam_toks[6] = "="; //same chromosome
      //TLEN:
      tlen = bh.left() < partner->left() ? partner->right() - bh.left() :
        partner->left() - bh.right();
    }
    
    else { //partner on different chromosome/contig
      sam_toks[6] = rt.get_name(partner->ref_id());
    }
    mate_pos = partner->left() + 1;
    if (grade.happy())
      flag |= 0x0002;
    if (partner->antisense_align())
      flag |=  0x0020;

    if (partner->fusion_opcode() != FUSION_NOTHING)
      {
        char partner_pos[1024];
        sprintf(partner_pos, "XP:Z:%s-%s %d", rt.get_name(partner->ref_id()), rt.get_name(partner->ref_id2()), partner->left() + 1);
        sam_toks.push_back(partner_pos);
      }
  }
  else {
    sam_toks[6] = "*";
    mate_pos = 0;
    flag |= 0x0008;
  }

  string rg_aux = "";
  if (!sam_readgroup_id.empty())
    rg_aux = string("RG:Z:") + sam_readgroup_id;

  GBamRecord* bamrec=NULL;
  if (fusion_alignment) {
    vector<string> auxdata;
    add_auxData(auxdata, sam_toks, rt, bh, insert_side, num_hits, next_hit, hitIndex);
    if (rg_aux != "")
      auxdata.push_back(rg_aux);
    bamrec=bam_writer.new_record(qname.c_str(), flag, ref_name.c_str(), left1 + 1, mapQ,
                                 cigar1, sam_toks[6].c_str(), mate_pos,
                                 tlen, left_seq.c_str(), left_qual.c_str(), &auxdata);
    bam_writer.write(bamrec);
    delete bamrec;

    auxdata.clear();
    sam_toks[XF_tok_idx][5] = '2';
    add_auxData(auxdata, sam_toks, rt, bh, insert_side, num_hits, next_hit, hitIndex);
    if (rg_aux != "")
      auxdata.push_back(rg_aux);
    bamrec=bam_writer.new_record(qname.c_str(), flag, ref_name2.c_str(), left2 + 1, mapQ,
                                 cigar2, sam_toks[6].c_str(), mate_pos,
                                 tlen, right_seq.c_str(), right_qual.c_str(), &auxdata);
    bam_writer.write(bamrec);
    delete bamrec;
  } else {
    vector<string> auxdata;
    add_auxData(auxdata, sam_toks, rt, bh, insert_side, num_hits, next_hit, hitIndex);
    if (rg_aux != "")
      auxdata.push_back(rg_aux);
    bamrec=bam_writer.new_record(qname.c_str(), flag, sam_toks[2].c_str(), gpos, mapQ,
                                 sam_toks[5].c_str(), sam_toks[6].c_str(), mate_pos,
                                 tlen, sam_toks[9].c_str(), sam_toks[10].c_str(), &auxdata);
    bam_writer.write(bamrec);
    delete bamrec;
  }

  return true;
}

struct lex_hit_sort
{
    lex_hit_sort(const RefSequenceTable& rt, const HitsForRead& hits)
        : _rt(rt), _hits(hits)
    {}
    
    bool operator()(const uint32_t& l, const uint32_t& r) const
    {
        const BowtieHit& lhs = _hits.hits[l];
        const BowtieHit& rhs = _hits.hits[r];

        uint32_t l_id = lhs.ref_id();
        uint32_t r_id = rhs.ref_id();
        if (l_id != r_id)
          return l_id < r_id;

        return lhs.left() < rhs.left();
    }
    
    const RefSequenceTable& _rt;
    const HitsForRead& _hits;
};

void print_sam_for_single(const RefSequenceTable& rt,
                          const HitsForRead& hits,
                          FragmentType frag_type,
                          const string& alt_name,
                          GBamWriter& bam_writer,
                          boost::random::mt19937& rng)
{
    //assert(!read.alt_name.empty());
    if (hits.hits.empty())
      return;
    
    lex_hit_sort s(rt, hits);
    vector<uint32_t> index_vector;

    size_t i;
    for (i = 0; i < hits.hits.size(); ++i)
        index_vector.push_back(i);
    
    sort(index_vector.begin(), index_vector.end(), s);

    size_t primaryHit = 0;
    if (!report_secondary_alignments)
      primaryHit = rng() % hits.hits.size();
    
    bool multipleHits = (hits.hits.size() > 1);
    for (i = 0; i < hits.hits.size(); ++i)
      {
        size_t index = index_vector[i];
        bool primary = (index == primaryHit);
        const BowtieHit& bh = hits.hits[index];
        rewrite_sam_record(bam_writer, rt,
                           bh,
                           bh.hitfile_rec().c_str(),
                           alt_name.c_str(),
                           frag_type,
                           hits.hits.size(),
                           (i < hits.hits.size()-1) ? &(hits.hits[index_vector[i+1]]) : NULL,
                           primary,
                           (multipleHits? i: -1));
      }
}

void print_sam_for_pair(const RefSequenceTable& rt,
                        const vector<pair<BowtieHit, BowtieHit> >& best_hits,
                        const InsertAlignmentGrade& grade,
                        GBamWriter& bam_writer,
                        const string& left_alt_name,
                        const string& right_alt_name,
                        boost::random::mt19937& rng,
                        uint64_t begin_id = 0,
                        uint64_t end_id = std::numeric_limits<uint64_t>::max())
{
    Read left_read;
    Read right_read;
    if (best_hits.empty())
      return;

    size_t i;
    HitsForRead right_hits;
    for (i = 0; i < best_hits.size(); ++i)
      right_hits.hits.push_back(best_hits[i].second);
    
    size_t primaryHit = 0;
    vector<uint32_t> index_vector;
    lex_hit_sort s(rt, right_hits);
    for (i = 0; i < right_hits.hits.size(); ++i)
      index_vector.push_back(i);
    
    sort(index_vector.begin(), index_vector.end(), s);

    if (!report_secondary_alignments)
      primaryHit = rng() % right_hits.hits.size();
    
    bool multipleHits = (best_hits.size() > 1);
    for (i = 0; i < best_hits.size(); ++i)
      {
        size_t index = index_vector[i];
        bool primary = (index == primaryHit);
        const BowtieHit& right_bh = best_hits[index].second;
        const BowtieHit& left_bh = best_hits[index].first;
        
        rewrite_sam_record(bam_writer, rt,
                           right_bh,
                           right_bh.hitfile_rec().c_str(),
                           right_alt_name.c_str(),
                           grade,
                           FRAG_RIGHT,
                           &left_bh,
                           best_hits.size(),
                           (i < best_hits.size() - 1) ? &(best_hits[index_vector[i+1]].second) : NULL,
                           primary, 
                           (multipleHits? i: -1));
        rewrite_sam_record(bam_writer, rt,
                           left_bh,
                           left_bh.hitfile_rec().c_str(),
                           left_alt_name.c_str(),
                           grade,
                           FRAG_LEFT,
                           &right_bh,
                           best_hits.size(),
                           (i < best_hits.size() - 1) ? &(best_hits[index_vector[i+1]].first) : NULL,
                           primary,
                           (multipleHits? i: -1));
      }
}

/**
 * Given all of the hits for a particular read, update the read counts for insertions and deletions.
 * @param hits hits The alignments for a particular read
 * @param insertions Maps from an insertion to the number of supporting reads for that insertion
 * @param deletions Maps from a deletion to the number of supporting reads for that deletion
 */
void update_insertions_and_deletions(const HitsForRead& hits,
                                     InsertionSet& insertions,
                                     DeletionSet& deletions)
{
  for (size_t i = 0; i < hits.hits.size(); ++i)
    {
      const BowtieHit& bh = hits.hits[i];
      insertions_from_alignment(bh, insertions);
      deletions_from_alignment(bh, deletions);
    }
}

void update_coverage(const HitsForRead& hits,
                     Coverage& coverage)
{
  for (size_t i = 0; i < hits.hits.size(); ++i)
    {
      const BowtieHit& hit = hits.hits[i];
      const vector<CigarOp>& cigar = hit.cigar();
      unsigned int positionInGenome = hit.left();
      RefID ref_id = hit.ref_id();
      
      for(size_t c = 0; c < cigar.size(); ++c)
        {
          int opcode = cigar[c].opcode;
          int length = cigar[c].length;
          switch(opcode)
            {
            case REF_SKIP:
            case MATCH:
            case DEL:
              if (opcode == MATCH)
                coverage.add_coverage(ref_id, positionInGenome, length);
      
              positionInGenome += length;
              break;
            case rEF_SKIP:
            case mATCH:
            case dEL:
              positionInGenome -= length;

              if (opcode == mATCH)
                coverage.add_coverage(ref_id, positionInGenome + 1, length);
              break;
            case FUSION_FF:
            case FUSION_FR:
            case FUSION_RF:
            case FUSION_RR:
                positionInGenome = length;
                ref_id = hit.ref_id2();
              break;
            default:
              break;
            }   
        }
    }
}


void update_fusions(const HitsForRead& hits,
                    RefSequenceTable& rt,
                    FusionSet& fusions,
                    const FusionSet& fusions_ref = empty_fusions)
{
  if (!fusion_search)
    return;
  
  if (hits.hits.size() > fusion_multireads)
    return;

  bool update_stat = fusions_ref.size() > 0;
  for (size_t i = 0; i < hits.hits.size(); ++i)
    {
      const BowtieHit& bh = hits.hits[i];

      if (bh.edit_dist() > fusion_read_mismatches)
        continue;

      fusions_from_alignment(bh, fusions, rt, update_stat);

      if (update_stat)
        unsupport_fusions(bh, fusions, fusions_ref);
    }
}

void update_junctions(const HitsForRead& hits,
                      JunctionSet& junctions)
{
  for (size_t i = 0; i < hits.hits.size(); ++i)
    {
      const BowtieHit& bh = hits.hits[i];
      junctions_from_alignment(bh, junctions);
    }
}

// Extracts junctions from all the SAM hits (based on REF_SKIPs) in the hit file
// resets the stream when finished.
void exclude_hits_on_filtered_junctions(const JunctionSet& junctions, HitsForRead& hits)
{
  HitsForRead remaining;
  remaining.insert_id = hits.insert_id;
  
  for (size_t i = 0; i < hits.hits.size(); ++i)
    {
      BowtieHit& bh = hits.hits[i];
      if (bh.edit_dist() > max_read_mismatches)
        continue;
      
      bool filter_hit = false;
      if (!bh.contiguous())
        {
          JunctionSet bh_juncs;
          junctions_from_alignment(bh, bh_juncs);
          for (JunctionSet::iterator itr = bh_juncs.begin();
               itr != bh_juncs.end();
               itr++)
            {
              const Junction& j = itr->first;
              JunctionSet::const_iterator target = junctions.find(j);
              if (target == junctions.end() || !target->second.accepted)
                {
                  filter_hit = true;
                  break;
                }
            }
        }
      if (!filter_hit)
        remaining.hits.push_back(bh);
    }
  hits = remaining;
}

void realign_reads(HitsForRead& hits,
                   const RefSequenceTable& rt,
                   const JunctionSet& junctions,
                   const JunctionSet& rev_junctions,
                   const InsertionSet& insertions,
                   const DeletionSet& deletions,
                   const DeletionSet& rev_deletions,
                   const FusionSet& fusions)
{
  if (color)
    return;

  vector<BowtieHit> additional_hits;
  for (size_t i = 0; i < hits.hits.size(); ++i)
    {
      BowtieHit& bh = hits.hits[i];
      if (fusion_search && bh.fusion_opcode() != FUSION_NOTHING)
        return;

      const vector<CigarOp>& cigars = bh.cigar();
      int pos = bh.left();
      int refid = bh.ref_id();
      for (size_t j = 0; j < cigars.size(); ++j)
        {
          const CigarOp& op = cigars[j];
          if (j == 0 || j == cigars.size() - 1)
            {
              // let's do this for MATCH case only,
              if (op.opcode == MATCH || op.opcode == mATCH)
                {
                  int left1, left2;
                  if (op.opcode == MATCH)
                    {
                      left1 = pos;
                      left2 = pos + op.length - 1;
                    }
                  else
                    {
                      left1 = pos - op.length + 1;
                      left2 = pos;
                    }

                  {
                    JunctionSet::const_iterator lb, ub;
                    JunctionSet temp_junctions;
                    if (j == 0)
                      {
                        lb = rev_junctions.upper_bound(Junction(refid, left1, 0, true));
                        ub = rev_junctions.lower_bound(Junction(refid, left2, left2, false));
                        while (lb != ub && lb != rev_junctions.end())
                          {
                            Junction temp_junction = lb->first;
                            temp_junction.left = lb->first.right;
                            temp_junction.right = lb->first.left;
                            temp_junctions[temp_junction] = lb->second;
                            ++lb;
                          }
                      }
                    
                    if (j == cigars.size() - 1)
                      {
                        int common_right = left2 + max_report_intron_length;
                        lb = junctions.upper_bound(Junction(refid, left1, common_right, true));
                        ub = junctions.lower_bound(Junction(refid, left2, common_right, false));
                        while (lb != ub && lb != junctions.end())
                          {
                            temp_junctions[lb->first] = lb->second;
                            ++lb;
                          }
                      }

                    if (temp_junctions.size() > 10)
                      continue;

                    JunctionSet::const_iterator junc_iter = temp_junctions.begin();
                    for (; junc_iter != temp_junctions.end(); ++junc_iter)
                      {
                        Junction junc = junc_iter->first;
                        
                        /*
                        fprintf(stderr, "%d %d-%d %s (AS:%d XM:%d) with junc %u-%u\n",
                                bh.insert_id(), bh.left(), bh.right(),
                                print_cigar(bh.cigar()).c_str(),
                                bh.alignment_score(), bh.edit_dist(),
                                junc.left, junc.right);
                        //*/

                        int new_left = bh.left();
                        int intron_length = junc.right - junc.left - 1;
                        vector<CigarOp> new_cigars;
                        bool anchored = false;
                        if (j == 0 && bh.left() > (int)junc.left)
                          {
                            new_left -= intron_length;
                            int before_match_length = junc.left - new_left + 1;;
                            int after_match_length = op.length - before_match_length;
                            
                            if (before_match_length > 0 && after_match_length)
                              {
                                anchored = true;
                                new_cigars.push_back(CigarOp(MATCH, before_match_length));
                                new_cigars.push_back(CigarOp(REF_SKIP, intron_length));
                                new_cigars.push_back(CigarOp(MATCH, after_match_length));
                                
                                new_cigars.insert(new_cigars.end(), cigars.begin() + 1, cigars.end());
                              }
                          }
                        else
                          {
                            new_cigars.insert(new_cigars.end(), cigars.begin(), cigars.end() - 1);
                            
                            int before_match_length = junc.left - pos + 1;
                            int after_match_length = op.length - before_match_length;
                            
                            if (before_match_length > 0 && after_match_length > 0)
                              {
                                anchored = true;
                                new_cigars.push_back(CigarOp(MATCH, before_match_length));
                                new_cigars.push_back(CigarOp(REF_SKIP, intron_length));
                                new_cigars.push_back(CigarOp(MATCH, after_match_length));
                              }
                          }

                        BowtieHit new_bh(bh.ref_id(),
                                         bh.ref_id2(),
                                         bh.insert_id(), 
                                         new_left,  
                                         new_cigars,
                                         bh.antisense_align(),
                                         junc.antisense,
                                         0, /* edit_dist - needs to be recalculated */
                                         0, /* splice_mms - needs to be recalculated */
                                         false);

                        new_bh.seq(bh.seq());
                        new_bh.qual(bh.qual());

                        const RefSequenceTable::Sequence* ref_str = rt.get_seq(bh.ref_id());

                        if (new_left >= 0 &&
                            new_bh.right() <= (int)length(*ref_str) &&
                            anchored)
                          {
                            vector<string> aux_fields;
                            bowtie_sam_extra(new_bh, rt, aux_fields);
                            
                            vector<string>::const_iterator aux_iter = aux_fields.begin();
                            for (; aux_iter != aux_fields.end(); ++aux_iter)
                              {
                                const string& aux_field = *aux_iter;
                                if (strncmp(aux_field.c_str(), "AS", 2) == 0)
                                  {
                                    int alignment_score = atoi(aux_field.c_str() + 5);
                                    new_bh.alignment_score(alignment_score);
                                  }
                                else if (strncmp(aux_field.c_str(), "XM", 2) == 0)
                                  {
                                    int XM_value =  atoi(aux_field.c_str() + 5);
                                    new_bh.edit_dist(XM_value);
                                  }
                              }
                            
                            vector<string> sam_toks;
                            tokenize(bh.hitfile_rec().c_str(), "\t", sam_toks);
                            
                            char coord[20] = {0,};
                            sprintf(coord, "%d", new_bh.left() + 1);
                            sam_toks[3] = coord;
                            sam_toks[5] = print_cigar(new_bh.cigar());
                            for (size_t a = 11; a < sam_toks.size(); ++a)
                              {
                                string& sam_tok = sam_toks[a];
                                for (size_t b = 0; b < aux_fields.size(); ++b)
                                  {
                                    const string& aux_tok = aux_fields[b];
                                    if (strncmp(sam_tok.c_str(), aux_tok.c_str(), 5) == 0)
                                      {
                                        sam_tok = aux_tok;
                                        break;
                                      }
                                  }
                              }
                            
                            if (!bh.is_spliced())
                              {
                                if (junc.antisense)
                                  sam_toks.push_back("XS:A:-");
                                else
                                  sam_toks.push_back("XS:A:+");
                              }
                            
                            
                            string new_rec = "";
                            for (size_t d = 0; d < sam_toks.size(); ++d)
                              {
                                new_rec += sam_toks[d];
                                if (d < sam_toks.size() - 1)
                                  new_rec += "\t";
                              }
                            
                            new_bh.hitfile_rec(new_rec);
                            
                            if (new_bh.edit_dist() <= bh.edit_dist())
                              additional_hits.push_back(new_bh);

                            /*
                              fprintf(stderr, "\t%d %d-%d %s (AS:%d XM:%d) with junc %u-%u\n",
                              new_bh.insert_id(), new_bh.left(), new_bh.right(),
                              print_cigar(new_bh.cigar()).c_str(),
                              new_bh.alignment_score(), new_bh.edit_dist(),
                              junc.left, junc.right);
                            //*/
                          }
                      }
                  }

#if 0
                  {
                    DeletionSet::const_iterator lb, ub;
                    bool use_rev_deletions = (j == 0);
                    const DeletionSet& curr_deletions = (use_rev_deletions ? rev_deletions : deletions);
                    if (use_rev_deletions)
                      {
                        lb = curr_deletions.upper_bound(Deletion(refid, left1, 0, true));
                        ub = curr_deletions.lower_bound(Deletion(refid, left2, left2, false));
                      }
                    else
                      {
                        int common_right = left2 + 100;
                        lb = curr_deletions.upper_bound(Deletion(refid, left1, common_right, true));
                        ub = curr_deletions.lower_bound(Deletion(refid, left2, common_right, false));
                      }
                  
                    while (lb != curr_deletions.end() && lb != ub)
                      {
                        Deletion del = lb->first;
                        if (use_rev_deletions)
                          {
                            int temp = del.left;
                            del.left = del.right;
                            del.right = temp;
                          }                   
                        
                        // daehwan - for debuggin purposes
                        /*
                          fprintf(stderr, "(type%d) %d %d-%d %s (AS:%d XM:%d) with junc %u-%u\n",
                          !use_rev_junctions,
                          bh.insert_id(), bh.left(), bh.right(),
                          print_cigar(bh.cigar()).c_str(),
                          bh.alignment_score(), bh.edit_dist(),
                          junc.left, junc.right);
                        */
                        
                        int del_length = del.right - del.left - 1;
                        int new_left = bh.left();
                        if (j == 0)
                          new_left -= del_length;
                        
                        vector<CigarOp> new_cigars;
                        if (j == 0)
                          {
                            int before_match_length = del.left - new_left + 1;;
                            int after_match_length = op.length - before_match_length;
                            
                            if (before_match_length > 0)
                              new_cigars.push_back(CigarOp(MATCH, before_match_length));
                            new_cigars.push_back(CigarOp(DEL, del_length));
                            if (after_match_length > 0)
                              new_cigars.push_back(CigarOp(MATCH, after_match_length));
                            
                            new_cigars.insert(new_cigars.end(), cigars.begin() + 1, cigars.end());
                          }
                        else
                          {
                            new_cigars.insert(new_cigars.end(), cigars.begin(), cigars.end() - 1);
                            
                            int before_match_length = del.left - pos + 1;
                            int after_match_length = op.length - before_match_length;
                            
                            if (before_match_length > 0)
                              new_cigars.push_back(CigarOp(MATCH, before_match_length));
                            new_cigars.push_back(CigarOp(DEL, del_length));
                            if (after_match_length > 0)
                              new_cigars.push_back(CigarOp(MATCH, after_match_length));
                          }
                        
                        BowtieHit new_bh(bh.ref_id(),
                                         bh.ref_id2(),
                                         bh.insert_id(), 
                                         new_left,  
                                         new_cigars,
                                         bh.antisense_align(),
                                         bh.antisense_splice(),
                                         0, /* edit_dist - needs to be recalculated */
                                         0, /* splice_mms - needs to be recalculated */
                                         false);
                        
                        new_bh.seq(bh.seq());
                        new_bh.qual(bh.qual());
                        
                        vector<string> aux_fields;
                        bowtie_sam_extra(new_bh, rt, aux_fields);
                      
                        vector<string>::const_iterator aux_iter = aux_fields.begin();
                        for (; aux_iter != aux_fields.end(); ++aux_iter)
                          {
                            const string& aux_field = *aux_iter;
                            if (strncmp(aux_field.c_str(), "AS", 2) == 0)
                              {
                                int alignment_score = atoi(aux_field.c_str() + 5);
                                new_bh.alignment_score(alignment_score);
                              }
                            else if (strncmp(aux_field.c_str(), "XM", 2) == 0)
                              {
                                int XM_value =  atoi(aux_field.c_str() + 5);
                                new_bh.edit_dist(XM_value);
                              }
                          }

                        vector<string> sam_toks;
                        tokenize(bh.hitfile_rec().c_str(), "\t", sam_toks);
                        
                        char coord[20] = {0,};
                        sprintf(coord, "%d", new_bh.left() + 1);
                        sam_toks[3] = coord;
                        sam_toks[5] = print_cigar(new_bh.cigar());
                        for (size_t a = 11; a < sam_toks.size(); ++a)
                          {
                            string& sam_tok = sam_toks[a];
                            for (size_t b = 0; b < aux_fields.size(); ++b)
                              {
                                const string& aux_tok = aux_fields[b];
                                if (strncmp(sam_tok.c_str(), aux_tok.c_str(), 5) == 0)
                                  {
                                    sam_tok = aux_tok;
                                    break;
                                  }
                              }
                          }

                        string new_rec = "";
                        for (size_t d = 0; d < sam_toks.size(); ++d)
                          {
                            new_rec += sam_toks[d];
                            if (d < sam_toks.size() - 1)
                              new_rec += "\t";
                          }
                        
                        new_bh.hitfile_rec(new_rec);
                        
                        if (new_bh.edit_dist() <= bh.edit_dist())
                          additional_hits.push_back(new_bh);
                        
                        /*
                          fprintf(stderr, "\t%d %d-%d %s (AS:%d XM:%d) with junc %u-%u\n",
                          new_bh.insert_id(), new_bh.left(), new_bh.right(),
                          print_cigar(new_bh.cigar()).c_str(),
                          new_bh.alignment_score(), new_bh.edit_dist(),
                          junc.left, junc.right);
                        */
                        
                        ++lb;
                      }
                  }

                  {
                    InsertionSet::const_iterator lb, ub;
                    lb = insertions.upper_bound(Insertion(refid, left1, ""));
                    ub = insertions.lower_bound(Insertion(refid, left2, ""));
                  
                    while (lb != insertions.end() && lb != ub)
                      {
                        // daehwan - for debugging purposse
                        break;
                        
                        Insertion ins = lb->first;
                        
                        // daehwan - for debugging purposes
                        /*
                          fprintf(stderr, "(type%d) %d %d-%d %s (AS:%d XM:%d) with junc %u-%u\n",
                          !use_rev_junctions,
                          bh.insert_id(), bh.left(), bh.right(),
                          print_cigar(bh.cigar()).c_str(),
                          bh.alignment_score(), bh.edit_dist(),
                          junc.left, junc.right);
                        */

                        int ins_length = ins.sequence.length();
                        int new_left = bh.left();
                        if (j == 0)
                          new_left -= ins_length;
                        
                        vector<CigarOp> new_cigars;
                        if (j == 0)
                          {
                            int before_match_length = ins.left - new_left + 1;;
                            int after_match_length = op.length - before_match_length - ins_length;
                            
                            if (before_match_length > 0)
                              new_cigars.push_back(CigarOp(MATCH, before_match_length));
                            new_cigars.push_back(CigarOp(INS, ins_length));
                            if (after_match_length > 0)
                              new_cigars.push_back(CigarOp(MATCH, after_match_length));
                            
                            new_cigars.insert(new_cigars.end(), cigars.begin() + 1, cigars.end());
                          }
                        else
                          {
                            new_cigars.insert(new_cigars.end(), cigars.begin(), cigars.end() - 1);
                            
                            int before_match_length = ins.left - pos + 1;
                            int after_match_length = op.length - before_match_length - ins_length;
                            
                            if (before_match_length > 0)
                              new_cigars.push_back(CigarOp(MATCH, before_match_length));
                            new_cigars.push_back(CigarOp(INS, ins_length));
                            if (after_match_length > 0)
                              new_cigars.push_back(CigarOp(MATCH, after_match_length));
                          }
                        
                        BowtieHit new_bh(bh.ref_id(),
                                         bh.ref_id2(),
                                         bh.insert_id(), 
                                         new_left,  
                                         new_cigars,
                                         bh.antisense_align(),
                                         bh.antisense_splice(),
                                         0, /* edit_dist - needs to be recalculated */
                                         0, /* splice_mms - needs to be recalculated */
                                         false);
                        
                        new_bh.seq(bh.seq());
                        new_bh.qual(bh.qual());
                        
                        vector<string> aux_fields;
                        bowtie_sam_extra(new_bh, rt, aux_fields);
                      
                        vector<string>::const_iterator aux_iter = aux_fields.begin();
                        for (; aux_iter != aux_fields.end(); ++aux_iter)
                          {
                            const string& aux_field = *aux_iter;
                            if (strncmp(aux_field.c_str(), "AS", 2) == 0)
                              {
                                int alignment_score = atoi(aux_field.c_str() + 5);
                                new_bh.alignment_score(alignment_score);
                              }
                            else if (strncmp(aux_field.c_str(), "XM", 2) == 0)
                              {
                                int XM_value =  atoi(aux_field.c_str() + 5);
                                new_bh.edit_dist(XM_value);
                              }
                          }
                        
                        /*
                          fprintf(stderr, "\t%d %d-%d %s (AS:%d XM:%d) with junc %u-%u\n",
                          new_bh.insert_id(), new_bh.left(), new_bh.right(),
                          print_cigar(new_bh.cigar()).c_str(),
                          new_bh.alignment_score(), new_bh.edit_dist(),
                          junc.left, junc.right);
                        */
                        
                        ++lb;
                      }
                  }
#endif
                }
            }
          
          switch(op.opcode)
            {
            case REF_SKIP:
              pos += op.length;
              break;
            case rEF_SKIP:
              pos -= op.length;
              break;
            case MATCH:
            case DEL:
              pos += op.length;
              break;
            case mATCH:
            case dEL:
              pos -= op.length;
              break;
            case FUSION_FF:
            case FUSION_FR:
            case FUSION_RF:
            case FUSION_RR:
              pos = op.length;
              refid = bh.ref_id2();
              break;
            default:
              break;
            }
        }
    }

  hits.hits.insert(hits.hits.end(), additional_hits.begin(), additional_hits.end());

  std::sort(hits.hits.begin(), hits.hits.end());
  vector<BowtieHit>::iterator new_end = std::unique(hits.hits.begin(), hits.hits.end());
  hits.hits.erase(new_end, hits.hits.end());  
}


// events include splice junction, indels, and fusion points.
struct ConsensusEventsWorker
{
  void operator()()
  {
    ReadTable it;
    vector<BAMHitFactory*> hit_factories;
    hit_factories.push_back(new BAMHitFactory(it, *rt));
    HitStream l_hs(left_map_fname, hit_factories.back(), false, true, true, true);
    if (left_map_offset > 0)
      l_hs.seek(left_map_offset);

    hit_factories.push_back(new BAMHitFactory(it, *rt));
    HitStream r_hs(right_map_fname, hit_factories.back(), false, true, true, true);
    if (right_map_offset > 0)
      r_hs.seek(right_map_offset);

    HitsForRead curr_left_hit_group;
    HitsForRead curr_right_hit_group;
    
    l_hs.next_read_hits(curr_left_hit_group);
    r_hs.next_read_hits(curr_right_hit_group);
    
    uint32_t curr_left_obs_order = it.observation_order(curr_left_hit_group.insert_id);
    uint32_t curr_right_obs_order = it.observation_order(curr_right_hit_group.insert_id);

    // While we still have unreported hits...
    while((curr_left_obs_order != VMAXINT32 || curr_right_obs_order != VMAXINT32) &&
          (curr_left_obs_order < end_id || curr_right_obs_order < end_id))
      {
        // Chew up left singletons
        while (curr_left_obs_order < curr_right_obs_order &&
               curr_left_obs_order < end_id &&
               curr_left_obs_order != VMAXINT32)
          {
            HitsForRead best_hits;
            best_hits.insert_id = curr_left_obs_order;
            
            // Process hits for left singleton, select best alignments
            read_best_alignments(curr_left_hit_group, best_hits, *gtf_junctions);
            update_coverage(best_hits, *coverage);
            update_junctions(best_hits, *junctions);
            update_insertions_and_deletions(best_hits, *insertions, *deletions);
            update_fusions(best_hits, *rt, *fusions);
                        
            // Get next hit group
            l_hs.next_read_hits(curr_left_hit_group);
            curr_left_obs_order = it.observation_order(curr_left_hit_group.insert_id);
          }
        
        // Chew up right singletons
        while (curr_left_obs_order > curr_right_obs_order &&
               curr_right_obs_order < end_id &&
               curr_right_obs_order != VMAXINT32)
          {
            HitsForRead best_hits;
            best_hits.insert_id = curr_right_obs_order;
            if (curr_right_obs_order >= begin_id)
              {
                // Process hit for right singleton, select best alignments
                read_best_alignments(curr_right_hit_group, best_hits, *gtf_junctions);
                update_coverage(best_hits, *coverage);
                update_junctions(best_hits, *junctions);
                update_insertions_and_deletions(best_hits, *insertions, *deletions);
                update_fusions(best_hits, *rt, *fusions);
              }
            
            // Get next hit group
            r_hs.next_read_hits(curr_right_hit_group);
            curr_right_obs_order = it.observation_order(curr_right_hit_group.insert_id);
          }
        
        // Since we have both left hits and right hits for this insert,
        // Find the best pairing and print both
        while (curr_left_obs_order == curr_right_obs_order &&
               curr_left_obs_order < end_id &&
               curr_left_obs_order != VMAXINT32)
          {
            vector<pair<BowtieHit, BowtieHit> > best_hits;

            InsertAlignmentGrade grade;
            pair_best_alignments(curr_left_hit_group,
                                 curr_right_hit_group,
                                 grade,
                                 best_hits,
                                 *gtf_junctions);

            HitsForRead best_left_hit_group; best_left_hit_group.insert_id = curr_left_obs_order;
            HitsForRead best_right_hit_group; best_right_hit_group.insert_id = curr_left_obs_order;

            if (best_hits.size() > 0)
              {
                for (size_t i = 0; i < best_hits.size(); ++i)
                  {
                    best_left_hit_group.hits.push_back(best_hits[i].first);
                    best_right_hit_group.hits.push_back(best_hits[i].second);
                  }
              }
            else
              {
                best_left_hit_group.hits = curr_left_hit_group.hits;
                best_right_hit_group.hits = curr_right_hit_group.hits;
              }

            update_coverage(best_left_hit_group, *coverage);
            update_junctions(best_left_hit_group, *junctions);
            update_insertions_and_deletions(best_left_hit_group, *insertions, *deletions);
            update_fusions(best_left_hit_group, *rt, *fusions);

            update_coverage(best_right_hit_group, *coverage);
            update_junctions(best_right_hit_group, *junctions);
            update_insertions_and_deletions(best_right_hit_group, *insertions, *deletions);
            update_fusions(best_right_hit_group, *rt, *fusions);
                    
            l_hs.next_read_hits(curr_left_hit_group);
            curr_left_obs_order = it.observation_order(curr_left_hit_group.insert_id);
            
            r_hs.next_read_hits(curr_right_hit_group);
            curr_right_obs_order = it.observation_order(curr_right_hit_group.insert_id);
          }
      }

    for (size_t i = 0; i < hit_factories.size(); ++i)
      delete hit_factories[i];
    
    hit_factories.clear();
  }

  string left_map_fname;
  string right_map_fname;

  RefSequenceTable* rt;

  JunctionSet* gtf_junctions;

  uint64_t begin_id;
  uint64_t end_id;
  int64_t left_map_offset;
  int64_t right_map_offset;

  JunctionSet* junctions;
  InsertionSet* insertions;
  DeletionSet* deletions;
  FusionSet* fusions;

  Coverage* coverage;
};

struct ReportWorker
{
  void write_singleton_alignments(uint64_t curr_obs_order,
                                  HitsForRead& curr_hit_group,
                                  ReadStream& reads_file,
                                  GBamWriter& bam_writer,
                                  GBamWriter& um_out,
                                  FragmentType fragment_type)
  {
    HitsForRead best_hits;
    best_hits.insert_id = curr_obs_order;
    
    realign_reads(curr_hit_group, *rt, *junctions, *rev_junctions,
                  *insertions, *deletions, *rev_deletions, *fusions);
    
    exclude_hits_on_filtered_junctions(*junctions, curr_hit_group);
    
    // Process hits for singleton, select best alignments
    const bool final_report = true;
    read_best_alignments(curr_hit_group, best_hits, *gtf_junctions,
                         *junctions, *insertions, *deletions, *fusions, *coverage,
                         final_report);
    
    if (best_hits.hits.size() > 0)
      {
        Read read;
        bool got_read = reads_file.getRead(curr_obs_order, read,
                                           reads_format, false, begin_id, end_id,
                                           &um_out, false);
        assert (got_read);
        if (got_read)
          {
            update_junctions(best_hits, *final_junctions);
            update_insertions_and_deletions(best_hits, *final_insertions, *final_deletions);
            update_fusions(best_hits, *rt, *final_fusions, *fusions);
            
            print_sam_for_single(*rt,
                                 best_hits,
                                 fragment_type,
                                 read.alt_name,
                                 bam_writer,
                                 rng);
          }
      }
  }
  
  void operator()()
  {
    rng.seed(1);
    
    ReadTable it;
    GBamWriter bam_writer(bam_output_fname.c_str(), sam_header.c_str());

    ReadStream left_reads_file(left_reads_fname);
    if (left_reads_file.file() == NULL)
      err_die("Error: cannot open %s for reading\n", left_reads_fname.c_str());
    if (left_reads_file.isBam()) {
        left_reads_file.use_alt_name();
        left_reads_file.ignoreQC();
        }
    if (left_reads_offset > 0)
      left_reads_file.seek(left_reads_offset);
    
    //if (!zpacker.empty()) left_um_fname+=".z";
    GBamWriter* left_um_out=new GBamWriter(left_um_fname.c_str(), sam_header.c_str());
    GBamWriter* right_um_out=NULL;
    
    ReadStream right_reads_file(right_reads_fname);
    if (right_reads_offset > 0)
      right_reads_file.seek(right_reads_offset);
    
    //FZPipe right_um_out;
    if (!right_reads_fname.empty())
      {
      if (right_reads_file.isBam()) {
        right_reads_file.use_alt_name();
        right_reads_file.ignoreQC();
        right_um_out=new GBamWriter(right_um_fname.c_str(), sam_header.c_str());
      }
        //if (!zpacker.empty()) right_um_fname+=".z";
        //if (right_um_out.openWrite(right_um_fname.c_str(), zpacker)==NULL)
        //  err_die("Error: cannot open file %s for writing!\n",right_um_fname.c_str());
      }

    vector<BAMHitFactory*> hit_factories;
    hit_factories.push_back(new BAMHitFactory(it, *rt));
    HitStream left_hs(left_map_fname, hit_factories.back(), false, true, true, true);
    if (left_map_offset > 0)
      left_hs.seek(left_map_offset);

    hit_factories.push_back(new BAMHitFactory(it, *rt));
    HitStream right_hs(right_map_fname, hit_factories.back(), false, true, true, true);
    if (right_map_offset > 0)
      right_hs.seek(right_map_offset);
    
    HitsForRead curr_left_hit_group;
    HitsForRead curr_right_hit_group;
    
    left_hs.next_read_hits(curr_left_hit_group);
    right_hs.next_read_hits(curr_right_hit_group);
    
    uint64_t curr_left_obs_order = it.observation_order(curr_left_hit_group.insert_id);
    uint64_t curr_right_obs_order = it.observation_order(curr_right_hit_group.insert_id);

    const bool final_report = true;

    // While we still have unreported hits...
    Read l_read;
    Read r_read;
    while((curr_left_obs_order != VMAXINT32 || curr_right_obs_order != VMAXINT32) &&
          (curr_left_obs_order < end_id || curr_right_obs_order < end_id))
      {
        // Chew up left singletons (pairs with right reads unmapped)
        while (curr_left_obs_order < curr_right_obs_order &&
               curr_left_obs_order < end_id &&
               curr_left_obs_order != VMAXINT32)
          {
            write_singleton_alignments(curr_left_obs_order,
                                       curr_left_hit_group,
                                       left_reads_file,
                                       bam_writer,
                                       *left_um_out,
                                       right_map_fname.empty() ? FRAG_UNPAIRED : FRAG_LEFT);
            
            // Get next hit group
            left_hs.next_read_hits(curr_left_hit_group);
            curr_left_obs_order = it.observation_order(curr_left_hit_group.insert_id);
          } //left singletons 
        
        // Chew up right singletons
        while (curr_left_obs_order > curr_right_obs_order &&
               curr_right_obs_order < end_id &&
               curr_right_obs_order != VMAXINT32)
          {
            write_singleton_alignments(curr_right_obs_order,
                                       curr_right_hit_group,
                                       right_reads_file,
                                       bam_writer,
                                       *right_um_out,
                                       FRAG_RIGHT);

            // Get next hit group
            right_hs.next_read_hits(curr_right_hit_group);
            curr_right_obs_order = it.observation_order(curr_right_hit_group.insert_id);
          }
        
        // Since we have both left hits and right hits for this insert,
        // Find the best pairing and print both
        while (curr_left_obs_order == curr_right_obs_order &&
               curr_left_obs_order < end_id &&
               curr_left_obs_order != VMAXINT32)
          {
            realign_reads(curr_left_hit_group, *rt, *junctions, *rev_junctions,
                          *insertions, *deletions, *rev_deletions, *fusions);
            exclude_hits_on_filtered_junctions(*junctions, curr_left_hit_group);
            
            realign_reads(curr_right_hit_group, *rt, *junctions, *rev_junctions,
                            *insertions, *deletions, *rev_deletions, *fusions);
            exclude_hits_on_filtered_junctions(*junctions, curr_right_hit_group);
            
            vector<pair<BowtieHit, BowtieHit> > best_hits;

            bool paired_alignments = curr_left_hit_group.hits.size() > 0 && curr_right_hit_group.hits.size() > 0;
            InsertAlignmentGrade grade;

            if (paired_alignments)
              {
                pair_best_alignments(curr_left_hit_group,
                                     curr_right_hit_group,
                                     grade, best_hits, *gtf_junctions,
                                     *junctions, *insertions, *deletions, *fusions, *coverage,
                                     final_report);

                if (best_hits.size() <= 0 ||
                    (grade.fusion && !fusion_search && !report_discordant_pair_alignments))
                    paired_alignments = false;
              }

            if (paired_alignments)
              {
                HitsForRead best_left_hit_group; best_left_hit_group.insert_id = curr_left_obs_order;
                HitsForRead best_right_hit_group; best_right_hit_group.insert_id = curr_left_obs_order;
                
                for (size_t i = 0; i < best_hits.size(); ++i)
                  {
                    best_left_hit_group.hits.push_back(best_hits[i].first);
                    best_right_hit_group.hits.push_back(best_hits[i].second);
                  }
                
                if (best_hits.size() > 0)
                  {
                    bool got_left_read = left_reads_file.getRead(best_hits[0].first.insert_id(), l_read,
                                                                 reads_format, false, begin_id, end_id,
                                                                 left_um_out, false);
                    
                    bool got_right_read = right_reads_file.getRead(best_hits[0].first.insert_id(), r_read,
                                                                   reads_format, false, begin_id, end_id,
                                                                   right_um_out, false);
                    
                    assert (got_left_read && got_right_read);
                    
                    if (got_left_read && got_right_read)
                      {
                        update_junctions(best_left_hit_group, *final_junctions);
                        update_insertions_and_deletions(best_left_hit_group, *final_insertions, *final_deletions);
                        update_fusions(best_left_hit_group, *rt, *final_fusions, *fusions);
                        
                        update_junctions(best_right_hit_group, *final_junctions);
                        update_insertions_and_deletions(best_right_hit_group, *final_insertions, *final_deletions);
                        update_fusions(best_right_hit_group, *rt, *final_fusions, *fusions);
                        
                        pair_support(best_hits, *final_fusions, *fusions);
                        
                        print_sam_for_pair(*rt,
                                           best_hits,
                                           grade,
                                           bam_writer,
                                           l_read.alt_name,
                                           r_read.alt_name,
                                           rng,
                                           begin_id,
                                           end_id);
                      }
                  }
              }
            else
              {
                if (curr_left_hit_group.hits.size() > 0)
                  {
                    write_singleton_alignments(curr_left_obs_order,
                                               curr_left_hit_group,
                                               left_reads_file,
                                               bam_writer,
                                               *left_um_out,
                                               (right_map_fname.empty() ? FRAG_UNPAIRED : FRAG_LEFT));
                  }
                
                if (curr_right_hit_group.hits.size() > 0)
                  {   //only right read mapped
                    //write it in the mapped file with the #MAPPED# flag
                    write_singleton_alignments(curr_right_obs_order,
                                               curr_right_hit_group,
                                               right_reads_file,
                                               bam_writer,
                                               *right_um_out,
                                               FRAG_RIGHT);
                  }
              }
            
            left_hs.next_read_hits(curr_left_hit_group);
            curr_left_obs_order = it.observation_order(curr_left_hit_group.insert_id);
            
            right_hs.next_read_hits(curr_right_hit_group);
            curr_right_obs_order = it.observation_order(curr_right_hit_group.insert_id);
          }
      } //while we still have unreported hits..
    //print the remaining unmapped reads at the end of each reads' stream

    left_reads_file.getRead(VMAXINT32, l_read,
                            reads_format, false, begin_id, end_id,
                            left_um_out, false);
    if (right_reads_file.file())
      right_reads_file.getRead(VMAXINT32, r_read,
                               reads_format, false, begin_id, end_id,
                               right_um_out, false);


    // pclose (pipe close), which waits for a process to end, seems to conflict with boost::thread::join somehow,
    // resulting in deadlock like behavior.
    delete left_um_out;
    delete right_um_out;


    for (size_t i = 0; i < hit_factories.size(); ++i)
      delete hit_factories[i];

    hit_factories.clear();
  }

  string bam_output_fname;
  string sam_header_fname;

  string left_reads_fname;
  string left_map_fname;
  string right_reads_fname;
  string right_map_fname;

  string left_um_fname;
  string right_um_fname;

  JunctionSet* gtf_junctions;
  
  JunctionSet* junctions;
  JunctionSet* rev_junctions;
  InsertionSet* insertions;
  DeletionSet* deletions;
  DeletionSet* rev_deletions;
  FusionSet* fusions;
  Coverage* coverage;

  JunctionSet* final_junctions;
  InsertionSet* final_insertions;
  DeletionSet* final_deletions;
  FusionSet* final_fusions;

  RefSequenceTable* rt;

  uint64_t begin_id;
  uint64_t end_id;
  int64_t left_reads_offset;
  int64_t left_map_offset;
  int64_t right_reads_offset;
  int64_t right_map_offset;

  boost::random::mt19937 rng;
};

void driver(const string& bam_output_fname,
            istream& ref_stream,
            const string& left_map_fname,
            const string& left_reads_fname,
            const string& right_map_fname,
            const string& right_reads_fname,
            FILE* junctions_out,
            FILE* insertions_out,
            FILE* deletions_out,
            FILE* fusions_out)
{
  if (!parallel)
    num_threads = 1;

  RefSequenceTable rt(sam_header, true);
  get_seqs(ref_stream, rt, true);

  srandom(1);
  
  JunctionSet gtf_junctions;
  if (!gtf_juncs.empty())
    {
      char splice_buf[4096];
      FILE* splice_coords = fopen(gtf_juncs.c_str(), "r");
      if (splice_coords)
        {
          while (fgets(splice_buf, sizeof(splice_buf), splice_coords))
            {
              char* nl = strrchr(splice_buf, '\n');
              char* buf = splice_buf;
              if (nl) *nl = 0;

              char* ref_name = get_token((char**)&buf, "\t");
              char* scan_left_coord = get_token((char**)&buf, "\t");
              char* scan_right_coord = get_token((char**)&buf, "\t");
              char* orientation = get_token((char**)&buf, "\t");

              if (!scan_left_coord || !scan_right_coord || !orientation)
                {
                  fprintf(stderr,"Error: malformed splice coordinate record in %s\n:%s\n",
                        gtf_juncs.c_str(), buf);
                  exit(1);
                }

              uint32_t ref_id = rt.get_id(ref_name, NULL, 0);
              uint32_t left_coord = atoi(scan_left_coord);
              uint32_t right_coord = atoi(scan_right_coord);
              bool antisense = *orientation == '-';

              JunctionStats junction_stat;
              junction_stat.gtf_match = true;
              junction_stat.accepted = true;
              
              gtf_junctions.insert(make_pair<Junction, JunctionStats>(Junction(ref_id, left_coord, right_coord, antisense), junction_stat));
            }
        }
      fprintf(stderr, "Loaded %d GFF junctions from %s.\n", (int)(gtf_junctions.size()), gtf_juncs.c_str());
    }

  vector<uint64_t> read_ids;
  vector<vector<int64_t> > offsets;
  if (num_threads > 1)
    {
      vector<string> fnames;
      if (right_map_fname != "")
        {
          fnames.push_back(right_reads_fname);
          fnames.push_back(right_map_fname);
        }
      fnames.push_back(left_reads_fname);
      fnames.push_back(left_map_fname);
      bool enough_data = calculate_offsets(fnames, read_ids, offsets);
      if (!enough_data)
        num_threads = 1;
    }

  JunctionSet vjunctions[num_threads];
  InsertionSet vinsertions[num_threads];
  DeletionSet vdeletions[num_threads];
  FusionSet vfusions[num_threads];
  Coverage vcoverages[num_threads];
  
  vector<boost::thread*> threads;
  for (int i = 0; i < num_threads; ++i)
    {
      ConsensusEventsWorker worker;

      worker.left_map_fname = left_map_fname;
      worker.right_map_fname = right_map_fname;
      worker.rt = &rt;
      worker.gtf_junctions = &gtf_junctions;
      
      worker.junctions = &vjunctions[i];
      worker.insertions = &vinsertions[i];
      worker.deletions = &vdeletions[i];
      worker.fusions = &vfusions[i];
      worker.coverage = &vcoverages[i];

      worker.right_map_offset = 0;
      
      if (i == 0)
        {
          worker.begin_id = 0;
          worker.left_map_offset = 0;
        }
      else
        {
          size_t offsets_size = offsets[i-1].size();

          worker.begin_id = read_ids[i-1];
          worker.left_map_offset = offsets[i-1].back();
          if (offsets_size == 4)
            worker.right_map_offset = offsets[i-1][1];
        }
      
      worker.end_id = (i+1 < num_threads) ? read_ids[i] : std::numeric_limits<uint64_t>::max();

      if (num_threads > 1)
        threads.push_back(new boost::thread(worker));
      else
        worker();
    }

  for (size_t i = 0; i < threads.size(); ++i)
    {
      threads[i]->join();
      delete threads[i];
      threads[i] = NULL;
    }
  threads.clear();

  JunctionSet& junctions = vjunctions[0];
  InsertionSet& insertions = vinsertions[0];
  DeletionSet& deletions = vdeletions[0];
  FusionSet& fusions = vfusions[0];
  Coverage& coverage = vcoverages[0];
  for (int i = 1; i < num_threads; ++i)
    {
      merge_with(junctions, vjunctions[i]);
      vjunctions[i].clear();

      merge_with(insertions, vinsertions[i]);
      vinsertions[i].clear();
      
      merge_with(deletions, vdeletions[i]);
      vdeletions[i].clear();

      merge_with(fusions, vfusions[i]);
      vfusions[i].clear();

      coverage.merge_with(vcoverages[i]);
      vcoverages[i].clear();
    }

  merge_with(junctions, gtf_junctions);

  coverage.calculate_coverage();
  
  JunctionSet rev_junctions;
  JunctionSet::const_iterator junction_iter = junctions.begin();
  for (; junction_iter != junctions.end(); ++junction_iter)
    {
      const Junction& junction = junction_iter->first;
      Junction rev_junction = junction;
      rev_junction.left = junction.right;
      rev_junction.right = junction.left;
      rev_junctions[rev_junction] = junction_iter->second;
    }

  DeletionSet rev_deletions;
#if 0
  DeletionSet::const_iterator deletion_iter = deletions.begin();
  for (; deletion_iter != deletions.end(); ++deletion_iter)
    {
      const Deletion& deletion = deletion_iter->first;
      Deletion rev_deletion = deletion;
      rev_deletion.left = deletion.right;
      rev_deletion.right = deletion.left;
      rev_deletions[rev_deletion] = deletion_iter->second;
    }
#endif

  size_t num_unfiltered_juncs = junctions.size();
  fprintf(stderr, "Loaded %lu junctions\n", (long unsigned int) num_unfiltered_juncs);

  // Read hits, extract junctions, and toss the ones that arent strongly enough supported.
  filter_junctions(junctions, gtf_junctions);
  
  //size_t num_juncs_after_filter = junctions.size();
  //fprintf(stderr, "Filtered %lu junctions\n",
  //     num_unfiltered_juncs - num_juncs_after_filter);

  /*
    size_t small_overhangs = 0;
    for (JunctionSet::iterator i = junctions.begin(); i != junctions.end(); ++i)
    {
    if (i->second.accepted &&
    (i->second.left_extent < min_anchor_len || i->second.right_extent < min_anchor_len))
    {
    small_overhangs++;
    }
    }
    
    if (small_overhangs >0)
    fprintf(stderr, "Warning: %lu small overhang junctions!\n", (long unsigned int)small_overhangs);
  */

  JunctionSet vfinal_junctions[num_threads];
  InsertionSet vfinal_insertions[num_threads];
  DeletionSet vfinal_deletions[num_threads];
  FusionSet vfinal_fusions[num_threads];

  for (int i = 0; i < num_threads; ++i)
    {
      ReportWorker worker;

      worker.sam_header_fname = sam_header;
      char filename[1024] = {0};
      sprintf(filename, "%s%d.bam", bam_output_fname.c_str(), i);
      worker.bam_output_fname = filename;
      string tmpoutdir=getFdir(worker.bam_output_fname);
      worker.left_um_fname = tmpoutdir;
      sprintf(filename, "unmapped_left_%d.bam", i);
      worker.left_um_fname+=filename;
      
      if (right_reads_fname != "")
        {
          sprintf(filename, "unmapped_right_%d.bam", i);
          worker.right_um_fname = tmpoutdir;
          worker.right_um_fname += filename;
        }
      
      worker.left_reads_fname = left_reads_fname;
      worker.left_map_fname = left_map_fname;
      worker.right_reads_fname = right_reads_fname;
      worker.right_map_fname = right_map_fname;

      worker.gtf_junctions = &gtf_junctions;
      worker.junctions = &junctions;
      worker.rev_junctions = &rev_junctions;
      worker.insertions = &insertions;
      worker.deletions = &deletions;
      worker.rev_deletions = &rev_deletions;
      worker.fusions = &fusions;
      worker.coverage = &coverage;
      
      worker.final_junctions = &vfinal_junctions[i];
      worker.final_insertions = &vfinal_insertions[i];
      worker.final_deletions = &vfinal_deletions[i];
      worker.final_fusions = &vfinal_fusions[i];
      worker.rt = &rt;

      worker.right_reads_offset = 0;
      worker.right_map_offset = 0;
      
      if (i == 0)
        {
          worker.begin_id = 0;
          worker.left_reads_offset = 0;
          worker.left_map_offset = 0;
        }
      else
        {
          size_t offsets_size = offsets[i-1].size();
          
          worker.begin_id = read_ids[i-1];
          worker.left_reads_offset = offsets[i-1][offsets_size - 2];
          worker.left_map_offset = offsets[i-1].back();
          if (offsets_size == 4)
            {
              worker.right_reads_offset = offsets[i-1][0];
              worker.right_map_offset = offsets[i-1][1];
            }
        }
      
      worker.end_id = (i+1 < num_threads) ? read_ids[i] : std::numeric_limits<uint64_t>::max();

      if (num_threads > 1)
        threads.push_back(new boost::thread(worker));
      else
        worker();
    }

  for (size_t i = 0; i < threads.size(); ++i)
    {
      threads[i]->join();
      delete threads[i];
      threads[i] = NULL;
    }
  threads.clear();

  JunctionSet final_junctions = vfinal_junctions[0];
  InsertionSet final_insertions = vfinal_insertions[0];
  DeletionSet final_deletions = vfinal_deletions[0];
  FusionSet final_fusions = vfinal_fusions[0];
  for (int i = 1; i < num_threads; ++i)
    {
      merge_with(final_junctions, vfinal_junctions[i]);
      vfinal_junctions[i].clear();

      merge_with(final_insertions, vfinal_insertions[i]);
      vfinal_insertions[i].clear();
      
      merge_with(final_deletions, vfinal_deletions[i]);
      vfinal_deletions[i].clear();

      merge_with(final_fusions, vfinal_fusions[i]);
      vfinal_fusions[i].clear();
    }

  fprintf (stderr, "Reporting final accepted alignments...");
  fprintf (stderr, "done.\n");
  
  //small_overhangs = 0;
  for (JunctionSet::iterator i = final_junctions.begin(); i != final_junctions.end();)
    {
      if (i->second.supporting_hits == 0 || i->second.left_extent < 8 || i->second.right_extent < 8)
        {
          final_junctions.erase(i++);
        }
      else
        {
          ++i;
        }
    }
  
  //    if (small_overhangs > 0)
  //            fprintf(stderr, "Warning: %lu small overhang junctions!\n", small_overhangs);

  fprintf (stderr, "Printing junction BED track...");
  print_junctions(junctions_out, final_junctions, rt);
  fprintf (stderr, "done\n");
  
  fprintf (stderr, "Printing insertions...");
  print_insertions(insertions_out, final_insertions,rt);
  fclose(insertions_out);
  fprintf (stderr, "done\n");
  
  fprintf (stderr, "Printing deletions...");
  print_deletions(deletions_out, final_deletions, rt);
  fclose(deletions_out);
  fprintf (stderr, "done\n");

  if (fusion_search)
    {
      fprintf (stderr, "Printing fusions...");
      print_fusions(fusions_out, final_fusions, rt);
      fclose(fusions_out);
      fprintf (stderr, "done\n");
    }
  
  fprintf(stderr, "Found %lu junctions from happy spliced reads\n", (long unsigned int)final_junctions.size());
}

void print_usage()
{
        fprintf(stderr, "Usage:   tophat_reports <junctions.bed> <insertions.vcf> <deletions.vcf> <accepted_hits.sam> <left_map1,...,left_mapN> <left_reads.fq>  [right_map1,...,right_mapN] [right_reads.fq]\n");
    
        //      fprintf(stderr, "Usage:   tophat_reports <coverage.wig> <junctions.bed> <accepted_hits.sam> <map1.bwtout> [splice_map1.sbwtout]\n");
}

int main(int argc, char** argv)
{
  fprintf(stderr, "tophat_reports v%s (%s)\n", PACKAGE_VERSION, SVN_REVISION);
  fprintf(stderr, "---------------------------------------\n");
  
  reads_format = FASTQ;
  
  int parse_ret = parse_options(argc, argv, print_usage);
  if (parse_ret)
    return parse_ret;
  
  if(optind >= argc)
    {
      print_usage();
      return 1;
    }
  
  string ref_file_name = argv[optind++];
  
  if(optind >= argc)
    {
      print_usage();
      return 1;
    }
  
  string junctions_file_name = argv[optind++];
  
  if(optind >= argc)
    {
      print_usage();
      return 1;
    }
  
  string insertions_file_name = argv[optind++];
  if(optind >= argc)
    {
      print_usage();
      return 1;
    }
  
  string deletions_file_name = argv[optind++];
  if(optind >= argc)
    {
      print_usage();
      return 1;
    }
  
  string fusions_file_name = argv[optind++];
  if(optind >= argc)
    {
      print_usage();
      return 1;
    }
  
  string accepted_hits_file_name = argv[optind++];
  if(optind >= argc)
    {
      print_usage();
      return 1;
    }
  
  string left_map_filename = argv[optind++];
  if(optind >= argc)
    {
      print_usage();
      return 1;
    }
  
  string left_reads_filename = argv[optind++];
  string unzcmd=getUnpackCmd(left_reads_filename, false);
  string right_map_filename;
  string right_reads_filename;
  
  if (optind < argc)
    {
      right_map_filename = argv[optind++];
      if(optind >= argc) {
        print_usage();
        return 1;
      }
      right_reads_filename=argv[optind++];
    }

  ifstream ref_stream(ref_file_name.c_str(), ifstream::in);
  if (!ref_stream.good())
    {
      fprintf(stderr, "Error: cannot open %s for reading\n",
              ref_file_name.c_str());
      exit(1);
    }
  
  FILE* junctions_file = fopen(junctions_file_name.c_str(), "w");
  if (junctions_file == NULL)
    {
      fprintf(stderr, "Error: cannot open BED file %s for writing\n",
              junctions_file_name.c_str());
      exit(1);
    }
  
  FILE* insertions_file = fopen(insertions_file_name.c_str(), "w");
  if (insertions_file == NULL)
    {
      fprintf(stderr, "Error: cannot open VCF file %s for writing\n",
              insertions_file_name.c_str());
      exit(1);
    }
  
  FILE* deletions_file = fopen(deletions_file_name.c_str(), "w");
  if (deletions_file == NULL)
    {
      fprintf(stderr, "Error: cannot open VCF file %s for writing\n",
              deletions_file_name.c_str());
      exit(1);
    }
  
  FILE* fusions_file = NULL;
  if (fusion_search)
    {
      fusions_file = fopen(fusions_file_name.c_str(), "w");
      if (fusions_file == NULL)
        {
          fprintf(stderr, "Error: cannot open VCF file %s for writing\n",
                  fusions_file_name.c_str());
          exit(1);
        }
    }
  
  driver(accepted_hits_file_name,
         ref_stream,
         left_map_filename,
         left_reads_filename,
         right_map_filename,
         right_reads_filename,
         junctions_file,
         insertions_file,
         deletions_file,
         fusions_file);
  
  return 0;
}
Revision:	256
Committed:	Mon Jun 11 19:35:44 2012 UTC (12 years, 2 months ago) by gpertea
File size:	70966 byte(s)
Log Message:	sync with Daehwan's fixes