SpacePts_module.cc

Go to the documentation of this file.

//
// \file SpacePts_module.cc
//
// \author echurch@fnal.gov, msoderbe@fnal.gov
//
// A very ArgoNeuTy module, for now.

#include <vector>
#include <string>

#include <cmath>
#include <algorithm>
#include <iomanip>

// Framework includes
#include "art/Framework/Core/ModuleMacros.h" 
#include "art/Framework/Core/EDProducer.h" 
#include "canvas/Persistency/Common/FindManyP.h"
#include "art/Framework/Principal/Event.h" 
#include "fhiclcpp/ParameterSet.h" 
#include "art/Framework/Principal/Handle.h" 
#include "canvas/Persistency/Common/Ptr.h" 
#include "canvas/Persistency/Common/PtrVector.h" 
#include "art/Framework/Services/Registry/ServiceHandle.h" 
#include "art/Framework/Services/Optional/TFileService.h" 
#include "art/Framework/Services/Optional/TFileDirectory.h" 
#include "messagefacility/MessageLogger/MessageLogger.h" 

// LArSoft includes
#include "larcore/Geometry/Geometry.h"
#include "larcorealg/Geometry/CryostatGeo.h"
#include "larcorealg/Geometry/TPCGeo.h"
#include "larcorealg/Geometry/PlaneGeo.h"
#include "larcorealg/Geometry/WireGeo.h"
#include "lardataobj/RecoBase/EndPoint2D.h"
#include "lardataobj/RecoBase/Cluster.h"
#include "lardataobj/RecoBase/Track.h"
#include "lardataobj/RecoBase/Hit.h"
#include "lardataobj/RecoBase/SpacePoint.h"
#include "lardata/DetectorInfoServices/DetectorPropertiesService.h"
#include "lardata/Utilities/AssociationUtil.h"

// ROOT includes
#include "TVectorD.h"
#include "TMath.h"
#include "TGraph.h"
#include "TF1.h"

namespace trkf {
   
  class SpacePts : public art::EDProducer {
    
  public:
    
    explicit SpacePts(fhicl::ParameterSet const& pset);
    ~SpacePts();
    
    void reconfigure(fhicl::ParameterSet const& p);
    void produce(art::Event& evt); 
    void beginJob();
    void endJob();

  private:
        
    int             ftmatch; // tolerance for time matching (in time samples) 
    double          fPreSamplings; // in ticks
    double fvertexclusterWindow;
    std::string     fClusterModuleLabel;// label for input cluster collection
    std::string     fEndPoint2DModuleLabel;//label for input EndPoint2D collection
  protected: 
    
  
  }; // class SpacePts


  struct SortByWire 
  {
    bool operator() (art::Ptr<recob::Hit> const& h1, art::Ptr<recob::Hit> const& h2) const 
    { return h1->Channel() < h2->Channel() ;
    }
  };




//-------------------------------------------------
SpacePts::SpacePts(fhicl::ParameterSet const& pset)
{
  this->reconfigure(pset);
  
  produces< std::vector<recob::Track>                   >();
  produces< std::vector<recob::SpacePoint>              >();
  produces< art::Assns<recob::Track, recob::SpacePoint> >();
  produces< art::Assns<recob::Track, recob::Cluster>    >();
  produces< art::Assns<recob::Track, recob::Hit>        >();
  produces< art::Assns<recob::SpacePoint, recob::Hit>   >();
}

//-------------------------------------------------
SpacePts::~SpacePts()
{
}

void SpacePts::reconfigure(fhicl::ParameterSet const& pset) 
{
  fPreSamplings           = pset.get< double >("TicksOffset");
  ftmatch                 = pset.get< int    >("TMatch");
  fClusterModuleLabel     = pset.get< std::string >("ClusterModuleLabel");
  fEndPoint2DModuleLabel  = pset.get< std::string >("EndPoint2DModuleLabel");
  fvertexclusterWindow    = pset.get< double >("vertexclusterWindow");
}

//-------------------------------------------------
void SpacePts::beginJob()
{
}

void SpacePts::endJob()
{
}

//------------------------------------------------------------------------------------//
void SpacePts::produce(art::Event& evt)
{ 

  
  // get services
  art::ServiceHandle<geo::Geometry> geom;
  const detinfo::DetectorProperties* detprop = lar::providerFrom<detinfo::DetectorPropertiesService>();
  
  // Make a std::unique_ptr<> for the thing you want to put into the event
  // because that handles the memory management for you
  std::unique_ptr<std::vector<recob::Track>      >              tcol (new std::vector<recob::Track>);      
  std::unique_ptr<std::vector<recob::SpacePoint> >            spcol(new std::vector<recob::SpacePoint>);
  std::unique_ptr<art::Assns<recob::Track, recob::SpacePoint> > tspassn(new art::Assns<recob::Track, recob::SpacePoint>);
  std::unique_ptr<art::Assns<recob::Track, recob::Cluster> >    tcassn(new art::Assns<recob::Track, recob::Cluster>);
  std::unique_ptr<art::Assns<recob::Track, recob::Hit> >        thassn(new art::Assns<recob::Track, recob::Hit>);
  std::unique_ptr<art::Assns<recob::SpacePoint, recob::Hit> >   shassn(new art::Assns<recob::SpacePoint, recob::Hit>);
  // define TPC parameters
  TString tpcName = geom->GetLArTPCVolumeName();
  
  //TPC dimensions
  double YC =  (geom->DetHalfHeight())*2.; // TPC height in cm
  double Angle = geom->Plane(1).Wire(0).ThetaZ(false)-TMath::Pi()/2.; // wire angle with respect to the vertical direction
  // Parameters temporary defined here, but possibly to be retrieved somewhere in the code
  double timetick = 0.198;    //time sample in us
  double presamplings = fPreSamplings; // 60.;
  const double wireShift=50.; // half the number of wires from the Induction(Collection) plane intersecting with a wire from the Collection(Induction) plane.
  double plane_pitch = geom->PlanePitch(0,1);   //wire plane pitch in cm 
  double wire_pitch = geom->WirePitch();    //wire pitch in cm
  double Efield_drift = 0.5;  // Electric Field in the drift region in kV/cm
  double Efield_SI = 0.7;     // Electric Field between Shield and Induction planes in kV/cm
  double Efield_IC = 0.9;     // Electric Field between Induction and Collection planes in kV/cm
  double Temperature = 90.;  // LAr Temperature in K
  
  double driftvelocity = detprop->DriftVelocity(Efield_drift,Temperature);    //drift velocity in the drift region (cm/us)
  double driftvelocity_SI = detprop->DriftVelocity(Efield_SI,Temperature);    //drift velocity between shield and induction (cm/us)
  double driftvelocity_IC = detprop->DriftVelocity(Efield_IC,Temperature);    //drift velocity between induction and collection (cm/us)
  double timepitch = driftvelocity*timetick;                         //time sample (cm) 
  double tSI = plane_pitch/driftvelocity_SI/timetick;                   //drift time between Shield and Collection planes (time samples)
  double tIC = plane_pitch/driftvelocity_IC/timetick;                //drift time between Induction and Collection planes (time samples)
  
  
  // get input Cluster object(s).
  art::Handle< std::vector<recob::Cluster> > clusterListHandle;
  evt.getByLabel(fClusterModuleLabel,clusterListHandle);
  
  // get input EndPoint2D object(s).
  art::Handle< std::vector<recob::EndPoint2D> > endpointListHandle;
  evt.getByLabel(fEndPoint2DModuleLabel,endpointListHandle); 
  
  art::PtrVector<recob::EndPoint2D> endpointlist;
  if(evt.getByLabel(fEndPoint2DModuleLabel,endpointListHandle))
    for (unsigned int i = 0; i < endpointListHandle->size(); ++i){
      art::Ptr<recob::EndPoint2D> endpointHolder(endpointListHandle,i);
      endpointlist.push_back(endpointHolder);
    }
   
  // Declare some vectors..
  // Induction
  std::vector<double> Iwirefirsts;       // in cm
  std::vector<double> Iwirelasts;        // in cm
  std::vector<double> Itimefirsts;       // in cm
  std::vector<double> Itimelasts;        // in cm
  std::vector<double> Itimefirsts_line;  // in cm
  std::vector<double> Itimelasts_line;   // in cm
  std::vector < std::vector< art::Ptr<recob::Hit> > > IclusHitlists;
  std::vector<unsigned int> Icluster_count; 

  // Collection
  std::vector<double> Cwirefirsts;       // in cm
  std::vector<double> Cwirelasts;        // in cm
  std::vector<double> Ctimefirsts;       // in cm
  std::vector<double> Ctimelasts;        // in cm
  std::vector<double> Ctimefirsts_line;  // in cm
  std::vector<double> Ctimelasts_line;   // in cm
  std::vector< std::vector< art::Ptr<recob::Hit> > > CclusHitlists;
  std::vector<unsigned int> Ccluster_count; 

  art::FindManyP<recob::Hit> fm(clusterListHandle, evt, fClusterModuleLabel);

  for(unsigned int ii = 0; ii < clusterListHandle->size(); ++ii){

    art::Ptr<recob::Cluster> cl(clusterListHandle, ii);
      
    // Figure out which View the cluster belongs to 
    //only consider merged-lines that are associated with the vertex.
    //this helps get rid of through-going muon background -spitz                  
    int vtx2d_w = -99999;
    double vtx2d_t = -99999;
    bool found2dvtx = false;
      
    for (unsigned int j = 0; j<endpointlist.size();j++){
      if (endpointlist[j]->View() == cl->View()){
        vtx2d_w = endpointlist[j]->WireID().Wire;  //for update to EndPoint2D ... WK 4/22/13
        vtx2d_t = endpointlist[j]->DriftTime();
        found2dvtx = true;
        break;
      }
    }
    if (found2dvtx){
      double w = cl->StartWire();
      double t = cl->StartTick();
      double dtdw = std::tan(cl->StartAngle());
      double t_vtx = t+dtdw*(vtx2d_w-w);
      double dis = std::abs(vtx2d_t-t_vtx);
      if (dis>fvertexclusterWindow)       continue;     
    }
    //else continue; //what to do if a 2D vertex is not found? perhaps vertex finder was not even run.
    
    // Some variables for the hit
    float time;            //hit time at maximum
            
    std::vector< art::Ptr<recob::Hit> > hitlist = fm.at(ii);
    std::sort(hitlist.begin(), hitlist.end(), trkf::SortByWire());
      
    TGraph *the2Dtrack = new TGraph(hitlist.size());
      
    std::vector<double> wires;
    std::vector<double> times;
     
      
    int np=0;
    //loop over cluster hits
    for(std::vector< art::Ptr<recob::Hit> >::const_iterator theHit = hitlist.begin(); theHit != hitlist.end();  theHit++){
      //recover the Hit
      //      recob::Hit* theHit = (recob::Hit*)(*hitIter);
      time = (*theHit)->PeakTime() ;
        
      time -= presamplings;
        
                
      if(geom->SignalType((*theHit)->Channel()) == geo::kCollection) 
        time -= tIC;   // Collection
      //transform hit wire and time into cm
      double wire_cm = 0.; 
      if(geom->SignalType((*theHit)->Channel()) == geo::kInduction)
        wire_cm = (double)(((*theHit)->WireID().Wire+3.95) * wire_pitch);          
      else
        wire_cm = (double)(((*theHit)->WireID().Wire+1.84) * wire_pitch);
        
      //double time_cm = (double)(time * timepitch);
      double time_cm;
      if(time>tSI) time_cm = (double)( (time-tSI)*timepitch + tSI*driftvelocity_SI*timetick);
      else time_cm = time*driftvelocity_SI*timetick;
        
      wires.push_back(wire_cm);
      times.push_back(time_cm);
        
      the2Dtrack->SetPoint(np,wire_cm,time_cm);
      np++;
    }//end of loop over cluster hits
      
    // fit the 2Dtrack and get some info to store
    try{
      the2Dtrack->Fit("pol1","Q");
    }
    catch(...){
      std::cout<<"The 2D track fit failed"<<std::endl;
      continue;
    }
      
    TF1 *pol1=(TF1*) the2Dtrack->GetFunction("pol1");
    double par[2];
    pol1->GetParameters(par);
    double intercept = par[0];
    double slope = par[1];
      
  
    double w0 = wires.front();      // first hit wire (cm)
    double w1 = wires.back();        // last hit wire (cm)
    double t0 = times.front();      // first hit time (cm)
    double t1 = times.back();        // last hit time (cm)
    double t0_line = intercept + (w0)*slope;// time coordinate at wire w0 on the fit line (cm)  
    double t1_line = intercept + (w1)*slope;// time coordinate at wire w1 on the fit line (cm)
    


    // actually store the 2Dtrack info
    switch(geom->SignalType((*hitlist.begin())->Channel())){
    case geo::kInduction:
      Iwirefirsts.push_back(w0);
      Iwirelasts.push_back(w1);
      Itimefirsts.push_back(t0);
      Itimelasts.push_back(t1); 
      Itimefirsts_line.push_back(t0_line);
      Itimelasts_line.push_back(t1_line);    
      IclusHitlists.push_back(hitlist);
      Icluster_count.push_back(ii);
      break;
    case geo::kCollection:
      Cwirefirsts.push_back(w0);
      Cwirelasts.push_back(w1);
      Ctimefirsts.push_back(t0);
      Ctimelasts.push_back(t1);
      Ctimefirsts_line.push_back(t0_line);
      Ctimelasts_line.push_back(t1_line);
      CclusHitlists.push_back(hitlist);
      Ccluster_count.push_back(ii);
      break;   
    case geo::kMysteryType:
      break;
    }
    delete pol1;
  }// end of loop over all input clusters
  

  for(unsigned int collectionIter=0; collectionIter < CclusHitlists.size();collectionIter++){  //loop over Collection view 2D tracks
    // Recover previously stored info
    double Cw0 = Cwirefirsts[collectionIter];
    double Cw1 = Cwirelasts[collectionIter];
    //double Ct0 = Ctimefirsts[collectionIter];
    //double Ct1 = Ctimelasts[collectionIter];
    double Ct0_line = Ctimefirsts_line[collectionIter];
    double Ct1_line = Ctimelasts_line[collectionIter];
    std::vector< art::Ptr<recob::Hit> > hitsCtrk = CclusHitlists[collectionIter];

    double collLength = TMath::Sqrt( TMath::Power(Ct1_line - Ct0_line,2) + TMath::Power(Cw1 - Cw0,2));

    for(unsigned int inductionIter=0;inductionIter<IclusHitlists.size();inductionIter++){   //loop over Induction view 2D tracks
      // Recover previously stored info
      double Iw0 = Iwirefirsts[inductionIter];
      double Iw1 = Iwirelasts[inductionIter];
      //double It0 = Itimefirsts[inductionIter];
      //double It1 = Itimelasts[inductionIter];
      double It0_line = Itimefirsts_line[inductionIter];
      double It1_line = Itimelasts_line[inductionIter];
      std::vector< art::Ptr<recob::Hit> > hitsItrk = IclusHitlists[inductionIter];

      double indLength = TMath::Sqrt( TMath::Power(It1_line - It0_line,2) + TMath::Power(Iw1 - Iw0,2)); 

      bool forward_match = ((std::abs(Ct0_line-It0_line)<ftmatch*timepitch) && (std::abs(Ct1_line-It1_line)<ftmatch*timepitch));
      bool backward_match = ((std::abs(Ct0_line-It1_line)<ftmatch*timepitch) && (std::abs(Ct1_line-It0_line)<ftmatch*timepitch));
         

      if(forward_match || backward_match ){     

        // Reconstruct the 3D track
        TVector3 XYZ0, XYZ1;  // track endpoints
        if(forward_match){
          XYZ0.SetXYZ(Ct0_line,(Cw0-Iw0)/(2.*TMath::Sin(Angle)),(Cw0+Iw0)/(2.*TMath::Cos(Angle))-YC/2.*TMath::Tan(Angle));
          XYZ1.SetXYZ(Ct1_line,(Cw1-Iw1)/(2.*TMath::Sin(Angle)),(Cw1+Iw1)/(2.*TMath::Cos(Angle))-YC/2.*TMath::Tan(Angle));
        }
        else{
          XYZ0.SetXYZ(Ct0_line,(Cw0-Iw1)/(2.*TMath::Sin(Angle)),(Cw0+Iw1)/(2.*TMath::Cos(Angle))-YC/2.*TMath::Tan(Angle));
          XYZ1.SetXYZ(Ct1_line,(Cw1-Iw0)/(2.*TMath::Sin(Angle)),(Cw1+Iw0)/(2.*TMath::Cos(Angle))-YC/2.*TMath::Tan(Angle));
        }

        //compute track direction in Local co-ordinate system
        //WARNING:  There is an ambiguity introduced here for the case of backwards-going tracks.  
        //If available, vertex info. could sort this out.
        TVector3 startpointVec,endpointVec;
        TVector2 collVtx, indVtx;
        if(XYZ0.Z() <= XYZ1.Z()){
          startpointVec.SetXYZ(XYZ0.X(),XYZ0.Y(),XYZ0.Z());
          endpointVec.SetXYZ(XYZ1.X(),XYZ1.Y(),XYZ1.Z());
          if(forward_match){
            collVtx.Set(Ct0_line,Cw0);
            indVtx.Set(It0_line,Iw0);
          }else{
            collVtx.Set(Ct0_line,Cw0);
            indVtx.Set(It1_line,Iw1);
          }
        }
        else{
          startpointVec.SetXYZ(XYZ1.X(),XYZ1.Y(),XYZ1.Z());
          endpointVec.SetXYZ(XYZ0.X(),XYZ0.Y(),XYZ0.Z());
          if(forward_match){
            collVtx.Set(Ct1_line,Cw1);
            indVtx.Set(It1_line,Iw1);
          }else{
            collVtx.Set(Ct1_line,Cw1);
            indVtx.Set(It0_line,Iw0);
          }
        }

        //compute track (normalized) cosine directions in the TPC co-ordinate system
        TVector3 DirCos = endpointVec - startpointVec;
            
        //SetMag casues a crash if the magnitude of the vector is zero
        try
          {
            DirCos.SetMag(1.0);//normalize vector
          }
        catch(...){std::cout<<"The Spacepoint is infinitely small"<<std::endl;
          continue;
        }

        art::Ptr <recob::Cluster> cl1(clusterListHandle,Icluster_count[inductionIter]);
        art::Ptr <recob::Cluster> cl2(clusterListHandle,Ccluster_count[collectionIter]);
        art::PtrVector<recob::Cluster> clustersPerTrack;
        clustersPerTrack.push_back(cl1);
        clustersPerTrack.push_back(cl2);

 
        // Match hits

        //create collection of spacepoints that will be used when creating the Track object
        std::vector<recob::SpacePoint> spacepoints;
        

        std::vector< art::Ptr<recob::Hit> > minhits = hitsCtrk.size() <= hitsItrk.size() ? hitsCtrk : hitsItrk;
        std::vector< art::Ptr<recob::Hit> > maxhits = hitsItrk.size() < hitsCtrk.size() ? hitsCtrk : hitsItrk;


        std::vector<bool> maxhitsMatch(maxhits.size());
        for(unsigned int it=0;it<maxhits.size();it++) maxhitsMatch[it] = false;

        std::vector<recob::Hit*> hits3Dmatched;
        // For the matching start from the view where the track projection presents less hits
        unsigned int imaximum = 0;
        size_t spStart = spcol->size();
        for(unsigned int imin=0;imin<minhits.size();imin++){ //loop over hits
          //get wire - time coordinate of the hit
          //unsigned int channel,wire,plane1,plane2,tpc,cstat;
          geo::WireID hit1WireID = minhits[imin]->WireID();
          auto const hitSigType = minhits[imin]->SignalType();
          double w1=0;
               
          //the 3.95 and 1.84 below are the ArgoNeuT TPC offsets for the induction and collection plane, respectively and are in units of wire pitch.
          if(hitSigType == geo::kInduction)
            w1 = (double)((hit1WireID.Wire+3.95) * wire_pitch);          
          else
            w1 = (double)((hit1WireID.Wire+1.84) * wire_pitch);
               
          double temptime1 = minhits[imin]->PeakTime()-presamplings;
          if(hitSigType == geo::kCollection) temptime1 -= tIC;
          double t1;// = plane1==1?(double)((minhits[imin]->PeakTime()-presamplings-tIC)*timepitch):(double)((minhits[imin]->PeakTime()-presamplings)*timepitch); //in cm
          if(temptime1>tSI) t1 = (double)( (temptime1-tSI)*timepitch + tSI*driftvelocity_SI*timetick);
          else t1 = temptime1*driftvelocity_SI*timetick;

          //get the track origin co-ordinates in the two views
          TVector2 minVtx2D;
          (hitSigType == geo::kCollection) ? minVtx2D.Set(collVtx.X(),collVtx.Y()): minVtx2D.Set(indVtx.X(),indVtx.Y());
          TVector2 maxVtx2D;
          (hitSigType == geo::kCollection) ? maxVtx2D.Set(indVtx.X(),indVtx.Y()): maxVtx2D.Set(collVtx.X(),collVtx.Y());
               
          double ratio = (collLength>indLength) ? collLength/indLength : indLength/collLength;    

          //compute the distance of the hit (imin) from the relative track origin
          double minDistance = ratio*TMath::Sqrt(TMath::Power(t1-minVtx2D.X(),2) + TMath::Power(w1-minVtx2D.Y(),2));
          
          
          //core matching algorithm
          double difference = 9999999.;   

          for(unsigned int imax = 0; imax < maxhits.size(); imax++){ //loop over hits of the other view
            if(!maxhitsMatch[imax]){
              //get wire - time coordinate of the hit
              geo::WireID hit2WireID = maxhits[imax]->WireID();
              auto const hit2SigType = maxhits[imax]->SignalType();
              double w2=0.;
              if(hit2SigType == geo::kInduction)
                w2 = (double)((hit2WireID.Wire+3.95) * wire_pitch);          
              else
                w2 = (double)((hit2WireID.Wire+1.84) * wire_pitch);
                     
              double temptime2 = maxhits[imax]->PeakTime()-presamplings;
              if(hit2SigType == geo::kCollection) temptime2 -= tIC;
              double t2;
              if(temptime2>tSI) t2 = (double)( (temptime2-tSI)*timepitch + tSI*driftvelocity_SI*timetick);
              else t2 = temptime2*driftvelocity_SI*timetick;
                   
              bool timematch = (std::abs(t1-t2)<ftmatch*timepitch);
              bool wirematch = (std::abs(w1-w2)<wireShift*wire_pitch);
              
              double maxDistance = TMath::Sqrt(TMath::Power(t2-maxVtx2D.X(),2)+TMath::Power(w2-maxVtx2D.Y(),2));
              if (wirematch && timematch && std::abs(maxDistance-minDistance)<difference) {
                difference = std::abs(maxDistance-minDistance);
                imaximum = imax;
              }
            }
          }
          maxhitsMatch[imaximum]=true;
          
          art::PtrVector<recob::Hit> sp_hits;
          if(difference!= 9999999.){
            sp_hits.push_back(minhits[imin]);
            sp_hits.push_back(maxhits[imaximum]);
          }
          
          // Get the time-wire co-ordinates of the matched hit
          geo::WireID hit2WireID = maxhits[imaximum]->WireID();
          auto const hit2SigType = maxhits[imaximum]->SignalType();
                                
          //double w1_match = (double)((wire+1)*wire_pitch);  
          double w1_match=0.;
          if(hit2SigType == geo::kInduction)
            w1_match = (double)((hit2WireID.Wire+3.95) * wire_pitch);          
          else
            w1_match = (double)((hit2WireID.Wire+1.84) * wire_pitch);
               
          double temptime3 = maxhits[imaximum]->PeakTime()-presamplings;
          if(hit2SigType == geo::kCollection) temptime3 -= tIC;
          double t1_match;
          if(temptime3>tSI) t1_match = (double)( (temptime3-tSI)*timepitch + tSI*driftvelocity_SI*timetick);
          else t1_match = temptime3*driftvelocity_SI*timetick;
             
          // create the 3D hit, compute its co-ordinates and add it to the 3D hits list   
          double Ct = hitSigType==geo::kCollection?t1:t1_match;
          double Cw = hit2SigType==geo::kCollection?w1:w1_match;
          double Iw = hit2SigType==geo::kCollection?w1_match:w1;

          const TVector3 hit3d(Ct,(Cw-Iw)/(2.*TMath::Sin(Angle)),(Cw+Iw)/(2.*TMath::Cos(Angle))-YC/2.*TMath::Tan(Angle)); 
               
               
          Double_t hitcoord[3];       
          hitcoord[0] = hit3d.X();
          hitcoord[1] = hit3d.Y();
          hitcoord[2] = hit3d.Z();

          /*
            double yy,zz;
            if(geom->ChannelsIntersect(geom->PlaneWireToChannel(0,(int)((Iw/wire_pitch)-3.95)),      geom->PlaneWireToChannel(1,(int)((Cw/wire_pitch)-1.84)),yy,zz))
            {
            //channelsintersect provides a slightly more accurate set of y and z coordinates. use channelsintersect in case the wires in question do cross.
            hitcoord[1] = yy;
            hitcoord[2] = zz;               
            mf::LogInfo("SpacePts: ") << "SpacePoint adding xyz ..." << hitcoord[0] <<","<< hitcoord[1] <<","<< hitcoord[2];           
            //             std::cout<<"wire 1: "<<(Iw/wire_pitch)-3.95<<" "<<(Cw/wire_pitch)-1.84<<std::endl;
            //                std::cout<<"Intersect: "<<yy<<" "<<zz<<std::endl;
            }
            else
            continue;
          */
                   
          double err[6] = {util::kBogusD};
          recob::SpacePoint mysp(hitcoord, err, util::kBogusD, spStart + spacepoints.size());//3d point at end of track
          // Don't add a spacepoint right on top of the last one.
          const double eps(0.1); // 1mm
          if (spacepoints.size()>=1){
            TVector3 magNew(mysp.XYZ()[0],mysp.XYZ()[1],mysp.XYZ()[2]);
            TVector3 magLast(spacepoints.back().XYZ()[0],
                             spacepoints.back().XYZ()[1],
                             spacepoints.back().XYZ()[2]);
            if (!(magNew.Mag()>=magLast.Mag()+eps || 
                  magNew.Mag()<=magLast.Mag()-eps) )
              continue;
          }
          spacepoints.push_back(mysp);
          spcol->push_back(mysp);       
          util::CreateAssn(*this, evt, *spcol, sp_hits, *shassn);

        }//loop over min-hits

        size_t spEnd = spcol->size();
      
        // Add the 3D track to the vector of the reconstructed tracks
        if(spacepoints.size()>0){

          // make a vector of the trajectory points along the track
          std::vector<TVector3> xyz(spacepoints.size());
          for(size_t s = 0; s < spacepoints.size(); ++s){
            xyz[s] = TVector3(spacepoints[s].XYZ());
          }
                
          std::vector<TVector3> dircos(spacepoints.size(), DirCos);

          tcol->push_back(recob::Track(recob::TrackTrajectory(recob::tracking::convertCollToPoint(xyz),
                                                              recob::tracking::convertCollToVector(dircos),
                                                              recob::Track::Flags_t(xyz.size()), false),
                                       0, -1., 0, recob::tracking::SMatrixSym55(), recob::tracking::SMatrixSym55(), tcol->size()));

          // make associations between the track and space points
          util::CreateAssn(*this, evt, *tcol, *spcol, *tspassn, spStart, spEnd);

          // now the track and clusters
          util::CreateAssn(*this, evt, *tcol, clustersPerTrack, *tcassn);

          // and the hits and track
          art::FindManyP<recob::Hit> fmh(clustersPerTrack, evt, fClusterModuleLabel);
          for(size_t cpt = 0; cpt < clustersPerTrack.size(); ++cpt)
            util::CreateAssn(*this, evt, *tcol, fmh.at(cpt), *thassn);

        }
      } //close match 2D tracks

    }//close loop over Induction view 2D tracks
    
  }//close loop over Collection xxview 2D tracks

  mf::LogVerbatim("Summary") << std::setfill('-') << std::setw(175) << "-" << std::setfill(' ');
  mf::LogVerbatim("Summary") << "SpacePts Summary:";
  for(unsigned int i = 0; i<tcol->size(); ++i) mf::LogVerbatim("Summary") << tcol->at(i) ;
 
  evt.put(std::move(tcol));
  evt.put(std::move(spcol));
  evt.put(std::move(tspassn));
  evt.put(std::move(tcassn));
  evt.put(std::move(thassn));
  evt.put(std::move(shassn));

} // end SpacePts::produce()


  DEFINE_ART_MODULE(SpacePts)
  
} // end namespace