// -*- C++ -*-
//
// Package:     FWLite
// Class  :     Record
//
// Implementation:
//     [Notes on implementation]
//
// Original Author:
//         Created:  Thu Dec 10 15:58:33 CST 2009
//

// system include files
#include <cassert>
#include "TTree.h"
// user include files
#include "DataFormats/FWLite/interface/Record.h"
#include "DataFormats/Provenance/interface/ESRecordAuxiliary.h"
#include "FWCore/Utilities/interface/Exception.h"
#include "FWCore/Reflection/interface/TypeWithDict.h"
#include "DataFormats/FWLite/interface/format_type_name.h"

//
// constants, enums and typedefs
//
using namespace fwlite;
//
// static data member definitions
//
typedef std::map<IOVSyncValue, unsigned int> StartIOVtoEntryMap;

//
// constructors and destructor
//
Record::Record(const char* iName, TTree* iTree)
    : m_name(iName),
      m_tree(iTree),
      m_entry(-1),
      m_start(IOVSyncValue::invalidIOVSyncValue()),
      m_end(IOVSyncValue::invalidIOVSyncValue()) {
  //read the start iovs and get them in order
  edm::ESRecordAuxiliary aux;
  edm::ESRecordAuxiliary* pAux = &aux;
  TBranch* auxBranch = m_tree->FindBranch("ESRecordAuxiliary");
  auxBranch->SetAddress(&pAux);
  IOVSyncValue temp;
  for (unsigned int index = 0; index < m_tree->GetEntries(); ++index) {
    auxBranch->GetEntry(index);
    if (aux.timestamp() != edm::Timestamp::invalidTimestamp()) {
      if (aux.eventID().run() != 0) {
        temp = IOVSyncValue(aux.eventID(), aux.timestamp());
      } else {
        temp = IOVSyncValue(aux.timestamp());
      }
    } else {
      temp = IOVSyncValue(aux.eventID());
      assert(aux.eventID().run() != 0);
    }

    m_startIOVtoEntry[temp] = index;
  }
}

// Record::Record(const Record& rhs)
// {
//    // do actual copying here;
// }

Record::~Record() { resetCaches(); }

//
// assignment operators
//
// const Record& Record::operator=(const Record& rhs)
// {
//   //An exception safe implementation is
//   Record temp(rhs);
//   swap(rhs);
//
//   return *this;
// }

//
// member functions
//
void Record::syncTo(const edm::EventID& iEvent, const edm::Timestamp& iTime) {
  IOVSyncValue temp;
  if (iTime != edm::Timestamp::invalidTimestamp()) {
    if (iEvent.run() != 0) {
      temp = IOVSyncValue(iEvent, iTime);
    } else {
      temp = IOVSyncValue(iTime);
    }
  } else {
    temp = IOVSyncValue(iEvent);
    assert(iEvent.run() != 0);
  }

  //already synched
  if ((m_start != IOVSyncValue::invalidIOVSyncValue()) && (m_start <= temp) &&
      ((m_end == IOVSyncValue::invalidIOVSyncValue()) || (temp < m_end))) {
    return;
  }
  std::pair<StartIOVtoEntryMap::iterator, StartIOVtoEntryMap::iterator> range = m_startIOVtoEntry.equal_range(temp);
  if (range.first != range.second) {
    //happens to be the start of the IOV
    m_start = range.first->first;
    m_entry = range.first->second;
  } else {
    if (range.first != m_startIOVtoEntry.begin()) {
      //we have overshot
      --range.first;
      m_start = range.first->first;
      m_entry = range.first->second;
    } else {
      //off the beginning
      m_start = IOVSyncValue::invalidIOVSyncValue();
      m_entry = -1;
    }
  }
  if (range.second == m_startIOVtoEntry.end()) {
    m_end = IOVSyncValue::invalidIOVSyncValue();
  } else {
    m_end = range.second->first;
  }
  resetCaches();
}

void Record::resetCaches() {
  for (auto& b : m_branches) {
    TClass* cls = nullptr;
    EDataType dt;
    if (nullptr == b.second.first or nullptr == b.second.second)
      continue;
    if (0 == b.second.first->GetExpectedType(cls, dt)) {
      cls->Destructor(b.second.second);
      b.second.second = nullptr;
    }
  }
  for (auto& b : m_branches) {
    if (nullptr == b.second.first)
      continue;
    assert(b.second.second == nullptr);
  }
}

//
// const member functions
//
const std::string& Record::name() const { return m_name; }

const IOVSyncValue& Record::startSyncValue() const { return m_start; }
const IOVSyncValue& Record::endSyncValue() const { return m_end; }

cms::Exception* Record::get(const edm::TypeID& iType, const char* iLabel, const void*& iData) const {
  cms::Exception* returnValue = nullptr;

  std::pair<TBranch*, void*>& branch = m_branches[std::make_pair(iType, iLabel)];
  if (nullptr == branch.first) {
    branch.second = nullptr;
    if (!edm::hasDictionary(iType.typeInfo())) {
      returnValue = new cms::Exception("UnknownType");
      (*returnValue) << "The type " << iType.typeInfo().name() << " was requested from Record " << name()
                     << " but the type has no known dictionary";
      return returnValue;
    }
    //build branch name
    std::string branchName = fwlite::format_type_to_mangled(iType.className()) + "__" + iLabel;
    branch.first = m_tree->FindBranch(branchName.c_str());

    if (nullptr == branch.first) {
      returnValue = new cms::Exception("NoDataAvailable");
      (*returnValue) << "The data of type " << iType.className() << " with label '" << iLabel << "' for Record "
                     << name() << " is not in this file.";
      return returnValue;
    }
    //We need GetExpectedType to work in order to delete objects
    TClass* cls;
    EDataType dt;
    if (0 != branch.first->GetExpectedType(cls, dt)) {
      returnValue = new cms::Exception("UnknownType");
      (*returnValue) << "The type " << iType.typeInfo().name() << " was requested from Record " << name()
                     << " but the TBranch does not know what Type it holds.";
      return returnValue;
    }

    branch.first->SetAutoDelete(kFALSE);
  }
  if (m_entry < 0) {
    returnValue = new cms::Exception("NoValidIOV");
    (*returnValue) << " The Record " << name() << " was asked to get data for a 'time' for which it has no data";
    return returnValue;
  }
  if (nullptr != branch.second) {
    iData = branch.second;
    return nullptr;
  }

  assert(nullptr == branch.second);
  branch.first->SetAddress(&branch.second);
  iData = branch.second;
  branch.first->GetEntry(m_entry);
  return returnValue;
}

std::vector<std::pair<std::string, std::string> > Record::typeAndLabelOfAvailableData() const {
  std::vector<std::pair<std::string, std::string> > returnValue;

  TObjArray* branches = m_tree->GetListOfBranches();
  TIter next(branches);
  while (TObject* obj = next()) {
    TBranch* branch = static_cast<TBranch*>(obj);
    const char* name = branch->GetName();
    if (0 != strcmp(name, "ESRecordAuxiliary")) {
      //The type and label are separated by a double underscore so we need to find that
      size_t len = strlen(name);
      const char* cIndex = name + len;
      std::string label;
      while (name != --cIndex) {
        if (*cIndex == '_') {
          if (*(cIndex - 1) == '_') {
            label = std::string(cIndex + 1);
            break;
          }
        }
      }
      std::string type(name, cIndex - name - 1);
      type = fwlite::unformat_mangled_to_type(type);
      returnValue.push_back(std::make_pair(type, label));
    }
  }
  return returnValue;
}

//
// static member functions
//