TauDiscriminantCutMultiplexer.cc

Go to the documentation of this file.

/*
 * TauDiscriminantCutMultiplexerT
 *
 * Authors: Evan K. Friis, UW; Sebastian Wozniewski, KIT
 *
 * Takes a PFTauDiscriminatorContainer with two raw values: The toMultiplex diescriminator is expected at rawValues[0] and the key (needed by certain discriminators) is expected at rawValues[1].
 *
 * The "key" discriminantor is rounded to the nearest integer.
 *
 * A set of cuts for different keys on the "toMultiplex" discriminantor is
 * provided in the config file.
 *
 * Both the key and toMultiplex discriminators should map to the same PFTau
 * collection.
 *
 */
#include "RecoTauTag/RecoTau/interface/TauDiscriminationProducerBase.h"
#include "FWCore/Utilities/interface/InputTag.h"
#include "CommonTools/Utils/interface/StringObjectFunction.h"
#include "DataFormats/TauReco/interface/PFTau.h"
#include "FWCore/ParameterSet/interface/FileInPath.h"

#include <FWCore/ParameterSet/interface/ConfigurationDescriptions.h>
#include <FWCore/ParameterSet/interface/ParameterSetDescription.h>

#include <memory>

#include "CondFormats/PhysicsToolsObjects/interface/PhysicsTGraphPayload.h"
#include "CondFormats/DataRecord/interface/PhysicsTGraphPayloadRcd.h"
#include "CondFormats/PhysicsToolsObjects/interface/PhysicsTFormulaPayload.h"
#include "CondFormats/DataRecord/interface/PhysicsTFormulaPayloadRcd.h"

#include "TGraph.h"
#include "TFormula.h"
#include "TFile.h"

template <class TauType, class TauTypeRef, class ParentClass>
class TauDiscriminantCutMultiplexerT : public ParentClass {
public:
  explicit TauDiscriminantCutMultiplexerT(const edm::ParameterSet& pset);

  ~TauDiscriminantCutMultiplexerT() override;
  reco::SingleTauDiscriminatorContainer discriminate(const TauTypeRef&) const override;
  void beginEvent(const edm::Event& event, const edm::EventSetup& eventSetup) override;

  static void fillDescriptions(edm::ConfigurationDescriptions& descriptions);

private:
  std::string moduleLabel_;

  bool loadMVAfromDB_;
  edm::FileInPath inputFileName_;

  struct DiscriminantCutEntry {
    DiscriminantCutEntry() : cutVariable_(), cutFunction_(), mode_(kUndefined) {}
    ~DiscriminantCutEntry() {}
    double cutValue_;
    std::string cutName_;
    edm::ESGetToken<PhysicsTGraphPayload, PhysicsTGraphPayloadRcd> cutToken_;
    std::unique_ptr<StringObjectFunction<TauType>> cutVariable_;
    std::unique_ptr<const TGraph> cutFunction_;
    enum { kUndefined, kFixedCut, kVariableCut };
    int mode_;
  };
  typedef std::map<int, std::vector<std::unique_ptr<DiscriminantCutEntry>>> DiscriminantCutMap;
  DiscriminantCutMap cuts_;
  uint n_raws_;
  int raw_discriminator_idx_ = -1;
  int raw_category_idx_ = -1;

  std::string mvaOutputNormalizationName_;
  edm::ESGetToken<PhysicsTFormulaPayload, PhysicsTFormulaPayloadRcd> formulaToken_;
  std::unique_ptr<const TFormula> mvaOutput_normalization_;

  bool isInitialized_;

  edm::InputTag toMultiplex_;
  edm::Handle<reco::TauDiscriminatorContainer> toMultiplexHandle_;
  edm::EDGetTokenT<reco::TauDiscriminatorContainer> toMultiplex_token;

  int verbosity_;
};

namespace {
  std::unique_ptr<TFile> openInputFile(const edm::FileInPath& inputFileName) {
    if (inputFileName.location() == edm::FileInPath::Unknown) {
      throw cms::Exception("TauDiscriminantCutMultiplexerT::loadObjectFromFile")
          << " Failed to find File = " << inputFileName << " !!\n";
    }
    return std::make_unique<TFile>(inputFileName.fullPath().data());
  }

  template <typename T>
  std::unique_ptr<const T> loadObjectFromFile(TFile& inputFile, const std::string& objectName) {
    const T* object = dynamic_cast<T*>(inputFile.Get(objectName.data()));
    if (!object)
      throw cms::Exception("TauDiscriminantCutMultiplexerT::loadObjectFromFile")
          << " Failed to load Object = " << objectName.data() << " from file = " << inputFile.GetName() << " !!\n";
    //Need to use TObject::Clone since the type T might be a base class
    return std::unique_ptr<const T>{static_cast<T*>(object->Clone())};
  }

  std::unique_ptr<const TGraph> loadTGraphFromDB(
      const edm::EventSetup& es,
      const std::string& graphName,
      const edm::ESGetToken<PhysicsTGraphPayload, PhysicsTGraphPayloadRcd>& graphToken,
      const int& verbosity_ = 0) {
    if (verbosity_) {
      std::cout << "<loadTGraphFromDB>:" << std::endl;
      std::cout << " graphName = " << graphName << std::endl;
    }
    return std::make_unique<TGraph>(es.getData(graphToken));
  }

  std::unique_ptr<TFormula> loadTFormulaFromDB(
      const edm::EventSetup& es,
      const std::string& formulaName,
      const edm::ESGetToken<PhysicsTFormulaPayload, PhysicsTFormulaPayloadRcd>& formulaToken_,
      const TString& newName,
      const int& verbosity_ = 0) {
    if (verbosity_) {
      std::cout << "<loadTFormulaFromDB>:" << std::endl;
      std::cout << " formulaName = " << formulaName << std::endl;
    }
    auto const& formulaPayload = es.getData(formulaToken_);

    if (formulaPayload.formulas().size() == 1 && formulaPayload.limits().size() == 1) {
      return std::make_unique<TFormula>(newName, formulaPayload.formulas().at(0).data());
    } else {
      throw cms::Exception("TauDiscriminantCutMultiplexerT::loadTFormulaFromDB")
          << "Failed to load TFormula = " << formulaName << " from Database !!\n";
    }
    return std::unique_ptr<TFormula>{};
  }
}  // namespace

template <class TauType, class TauTypeRef, class ParentClass>
TauDiscriminantCutMultiplexerT<TauType, TauTypeRef, ParentClass>::TauDiscriminantCutMultiplexerT(
    const edm::ParameterSet& cfg)
    : ParentClass(cfg),
      moduleLabel_(cfg.getParameter<std::string>("@module_label")),
      mvaOutput_normalization_(),
      isInitialized_(false) {
  toMultiplex_ = cfg.getParameter<edm::InputTag>("toMultiplex");
  toMultiplex_token = this->template consumes<reco::TauDiscriminatorContainer>(toMultiplex_);

  verbosity_ = cfg.getParameter<int>("verbosity");

  mvaOutputNormalizationName_ = cfg.getParameter<std::string>("mvaOutput_normalization");

  loadMVAfromDB_ = cfg.getParameter<bool>("loadMVAfromDB");
  if (!loadMVAfromDB_) {
    inputFileName_ = cfg.getParameter<edm::FileInPath>("inputFileName");
  } else if (not mvaOutputNormalizationName_.empty()) {
    formulaToken_ = this->esConsumes(edm::ESInputTag{"", mvaOutputNormalizationName_});
  }
  if (verbosity_)
    std::cout << moduleLabel_ << " loadMVA = " << loadMVAfromDB_ << std::endl;

  // Setup our cut map, first raw values then working points
  typedef std::vector<edm::ParameterSet> VPSet;
  typedef std::vector<std::string> VString;
  typedef std::vector<double> VDouble;
  VString rawValueConfig = cfg.getParameter<VString>("rawValues");
  for (uint i = 0; i < rawValueConfig.size(); i++) {
    if (rawValueConfig[i] == "discriminator")
      raw_discriminator_idx_ = i;
    else if (rawValueConfig[i] == "category")
      raw_category_idx_ = i;
    else
      throw cms::Exception("TauDiscriminantCutMultiplexerT")
          << " Configuration Parameter 'rawValues' containes unknown values. Must be 'discriminator' or 'category'!!\n";
  }
  n_raws_ = rawValueConfig.size();
  VPSet mapping = cfg.getParameter<VPSet>("mapping");
  for (auto const& mappingEntry : mapping) {
    unsigned category = mappingEntry.getParameter<uint32_t>("category");
    std::vector<std::unique_ptr<DiscriminantCutEntry>> cutWPs;
    std::string categoryname = mappingEntry.getParameter<std::string>("cut");
    bool localWPs = false;
    bool wpsAsDouble = false;
    if (mappingEntry.exists("workingPoints")) {
      localWPs = true;
      if (mappingEntry.existsAs<VDouble>("workingPoints")) {
        wpsAsDouble = true;
      } else if (mappingEntry.existsAs<VString>("workingPoints")) {
        wpsAsDouble = false;
      } else {
        throw cms::Exception("TauDiscriminantCutMultiplexerT")
            << " Configuration Parameter 'workingPoints' must be filled with cms.string or cms.double!!\n";
      }
    } else if (cfg.exists("workingPoints")) {
      localWPs = false;
      if (cfg.existsAs<VDouble>("workingPoints")) {
        wpsAsDouble = true;
      } else if (cfg.existsAs<VString>("workingPoints")) {
        wpsAsDouble = false;
      } else {
        throw cms::Exception("TauDiscriminantCutMultiplexerT")
            << " Configuration Parameter 'workingPoints' must be filled with cms.string or cms.double!!\n";
      }
    } else {
      throw cms::Exception("TauDiscriminantCutMultiplexerT")
          << " Undefined Configuration Parameter 'workingPoints' !!\n";
    }
    if (wpsAsDouble) {
      VDouble workingPoints;
      if (localWPs)
        workingPoints = mappingEntry.getParameter<VDouble>("workingPoints");
      else
        workingPoints = cfg.getParameter<VDouble>("workingPoints");
      for (auto const& wp : workingPoints) {
        std::unique_ptr<DiscriminantCutEntry> cut{new DiscriminantCutEntry()};
        cut->cutValue_ = wp;
        cut->mode_ = DiscriminantCutEntry::kFixedCut;
        cutWPs.push_back(std::move(cut));
      }
    } else {
      VString workingPoints;
      if (localWPs)
        workingPoints = mappingEntry.getParameter<VString>("workingPoints");
      else
        workingPoints = cfg.getParameter<VString>("workingPoints");
      for (auto const& wp : workingPoints) {
        std::unique_ptr<DiscriminantCutEntry> cut{new DiscriminantCutEntry()};
        cut->cutName_ = categoryname + wp;
        if (loadMVAfromDB_) {
          cut->cutToken_ = this->esConsumes(edm::ESInputTag{"", cut->cutName_});
        }
        std::string cutVariable_string = mappingEntry.getParameter<std::string>("variable");
        cut->cutVariable_.reset(new StringObjectFunction<TauType>(cutVariable_string));
        cut->mode_ = DiscriminantCutEntry::kVariableCut;
        cutWPs.push_back(std::move(cut));
      }
    }
    cuts_[category] = std::move(cutWPs);
  }

  verbosity_ = cfg.getParameter<int>("verbosity");
  if (verbosity_)
    std::cout << "constructed " << moduleLabel_ << std::endl;
}

template <class TauType, class TauTypeRef, class ParentClass>
TauDiscriminantCutMultiplexerT<TauType, TauTypeRef, ParentClass>::~TauDiscriminantCutMultiplexerT() {}

template <class TauType, class TauTypeRef, class ParentClass>
void TauDiscriminantCutMultiplexerT<TauType, TauTypeRef, ParentClass>::beginEvent(const edm::Event& evt,
                                                                                  const edm::EventSetup& es) {
  if (verbosity_)
    std::cout << " begin! " << moduleLabel_ << " " << isInitialized_ << std::endl;
  if (!isInitialized_) {
    //Only open the file once and we can close it when this routine is done
    // since all objects gotten from the file will have been copied
    std::unique_ptr<TFile> inputFile;
    if (!mvaOutputNormalizationName_.empty()) {
      if (!loadMVAfromDB_) {
        inputFile = openInputFile(inputFileName_);
        mvaOutput_normalization_ = loadObjectFromFile<TFormula>(*inputFile, mvaOutputNormalizationName_);
      } else {
        auto temp = loadTFormulaFromDB(es,
                                       mvaOutputNormalizationName_,
                                       formulaToken_,
                                       Form("%s_mvaOutput_normalization", moduleLabel_.data()),
                                       verbosity_);
        mvaOutput_normalization_ = std::move(temp);
      }
    }
    for (auto const& cutWPs : cuts_) {
      for (auto const& cut : cutWPs.second) {
        if (cut->mode_ == DiscriminantCutEntry::kVariableCut) {
          if (!loadMVAfromDB_) {
            if (not inputFile) {
              inputFile = openInputFile(inputFileName_);
            }
            if (verbosity_)
              std::cout << "Loading from file" << inputFileName_ << std::endl;
            cut->cutFunction_ = loadObjectFromFile<TGraph>(*inputFile, cut->cutName_);
          } else {
            if (verbosity_)
              std::cout << "Loading from DB" << std::endl;
            cut->cutFunction_ = loadTGraphFromDB(es, cut->cutName_, cut->cutToken_, verbosity_);
          }
        }
      }
    }
    isInitialized_ = true;
  }

  evt.getByToken(toMultiplex_token, toMultiplexHandle_);
}

template <class TauType, class TauTypeRef, class ParentClass>
reco::SingleTauDiscriminatorContainer TauDiscriminantCutMultiplexerT<TauType, TauTypeRef, ParentClass>::discriminate(
    const TauTypeRef& tau) const {
  if (verbosity_) {
    std::cout << "<TauDiscriminantCutMultiplexerT::discriminate>:" << std::endl;
    std::cout << " moduleLabel = " << moduleLabel_ << std::endl;
  }

  reco::SingleTauDiscriminatorContainer result;
  result.rawValues.resize(n_raws_);
  double disc_result = (*toMultiplexHandle_)[tau].rawValues.at(0);
  if (verbosity_) {
    std::cout << "disc_result = " << disc_result << std::endl;
  }
  if (raw_discriminator_idx_ >= 0)
    result.rawValues[raw_discriminator_idx_] = disc_result;
  if (mvaOutput_normalization_) {
    disc_result = mvaOutput_normalization_->Eval(disc_result);
    if (verbosity_) {
      std::cout << "disc_result (normalized) = " << disc_result << std::endl;
    }
  }
  double key_result = 0.0;
  if ((*toMultiplexHandle_)[tau].rawValues.size() == 2) {
    key_result = (*toMultiplexHandle_)[tau].rawValues.at(1);
    if (raw_category_idx_ >= 0)
      result.rawValues[raw_category_idx_] = key_result;
  }
  typename DiscriminantCutMap::const_iterator cutWPsIter = cuts_.find(std::round(key_result));

  // Return null if it doesn't exist
  if (cutWPsIter == cuts_.end()) {
    return result;
  }
  // See if the discriminator passes our cuts
  for (auto const& cutIter : cutWPsIter->second) {
    bool passesCuts = false;
    if (cutIter->mode_ == DiscriminantCutEntry::kFixedCut) {
      passesCuts = (disc_result > cutIter->cutValue_);
      if (verbosity_) {
        std::cout << "cutValue (fixed) = " << cutIter->cutValue_ << " --> passesCuts = " << passesCuts << std::endl;
      }
    } else if (cutIter->mode_ == DiscriminantCutEntry::kVariableCut) {
      double cutVariable = (*cutIter->cutVariable_)(*tau);
      double xMin, xMax, dummy;
      cutIter->cutFunction_->GetPoint(0, xMin, dummy);
      cutIter->cutFunction_->GetPoint(cutIter->cutFunction_->GetN() - 1, xMax, dummy);
      const double epsilon = 1.e-3;
      if (cutVariable < (xMin + epsilon))
        cutVariable = xMin + epsilon;
      else if (cutVariable > (xMax - epsilon))
        cutVariable = xMax - epsilon;
      double cutValue = cutIter->cutFunction_->Eval(cutVariable);
      passesCuts = (disc_result > cutValue);
      if (verbosity_) {
        std::cout << "cutValue (@" << cutVariable << ") = " << cutValue << " --> passesCuts = " << passesCuts
                  << std::endl;
      }
    }
    result.workingPoints.push_back(passesCuts);
  }
  return result;
}

// template specialization to get the correct default config names in the following fillDescriptions
template <class TauType>
std::string getDefaultConfigString() {
  // this generic one shoudl never be called.
  // these are specialized in TauDiscriminationProducerBase.cc
  throw cms::Exception("TauDiscriminantCutMultiplexerT")
      << "Unsupported TauType used. You must use either PFTau or PATTau.";
}

template <>
std::string getDefaultConfigString<reco::PFTau>() {
  return "recoTauDiscriminantCutMultiplexerDefault";
}
template <>
std::string getDefaultConfigString<pat::Tau>() {
  return "patTauDiscriminantCutMultiplexerDefault";
}

template <class TauType, class TauTypeRef, class ParentClass>
void TauDiscriminantCutMultiplexerT<TauType, TauTypeRef, ParentClass>::fillDescriptions(
    edm::ConfigurationDescriptions& descriptions) {
  // recoTauDiscriminantCutMultiplexer
  edm::ParameterSetDescription desc;
  desc.add<edm::InputTag>("toMultiplex", edm::InputTag("fixme"));
  desc.add<int>("verbosity", 0);

  {
    edm::ParameterSet pset_mapping;
    pset_mapping.addParameter<unsigned int>("category", 0);
    pset_mapping.addParameter<std::string>("cut", "fixme");
    edm::ParameterSetDescription desc_mapping;
    desc_mapping.add<unsigned int>("category", 0);
    desc_mapping.add<std::string>("cut");
    // it seems the parameter string "variable" exists only when workingPoints are string
    // see hpsPFTauDiscriminationByVLooseIsolationMVArun2v1DBdR03oldDMwLT in RecoTauTag/Configuration/python/HPSPFTaus_cff.py
    desc_mapping.addOptional<std::string>("variable")
        ->setComment("the parameter is required when \"workingPoints\" are string");
    std::vector<edm::ParameterSet> vpsd_mapping;
    vpsd_mapping.push_back(pset_mapping);
    desc.addVPSet("mapping", desc_mapping, vpsd_mapping);
  }

  std::vector<std::string> defaultRaws{"discriminator"};
  desc.add<std::vector<std::string>>("rawValues", defaultRaws);
  std::vector<double> defaultWP{0.0};
  desc.addNode(edm::ParameterDescription<std::vector<double>>("workingPoints", defaultWP, true) xor
               edm::ParameterDescription<std::vector<std::string>>("workingPoints", true));
  desc.add<edm::FileInPath>("inputFileName", edm::FileInPath("RecoTauTag/RecoTau/data/emptyMVAinputFile"));
  desc.add<bool>("loadMVAfromDB", true);
  ParentClass::fillProducerDescriptions(desc);  // inherited from the base
  desc.add<std::string>("mvaOutput_normalization", "");
  descriptions.add(getDefaultConfigString<TauType>(), desc);
}

// define our implementations
typedef TauDiscriminantCutMultiplexerT<reco::PFTau, reco::PFTauRef, PFTauDiscriminationContainerProducerBase>
    RecoTauDiscriminantCutMultiplexer;
typedef TauDiscriminantCutMultiplexerT<pat::Tau, pat::TauRef, PATTauDiscriminationContainerProducerBase>
    PATTauDiscriminantCutMultiplexer;

DEFINE_FWK_MODULE(RecoTauDiscriminantCutMultiplexer);
DEFINE_FWK_MODULE(PATTauDiscriminantCutMultiplexer);