FileHandler.cc

/**************************************************************************
 * basf2 (Belle II Analysis Software Framework)                           *
 * Author: The Belle II Collaboration                                     *
 *                                                                        *
 * See git log for contributors and copyright holders.                    *
 * This file is licensed under LGPL-3.0, see LICENSE.md.                  *
 **************************************************************************/
 
#include <framework/gearbox/FileHandler.h>
#include <framework/gearbox/Gearbox.h>
#include <framework/logging/Logger.h>
#include <framework/utilities/FileSystem.h>
#include <framework/datastore/StoreObjPtr.h>
#include <framework/dataobjects/EventMetaData.h>
 
#include <regex>
#include <boost/filesystem.hpp>
#include <boost/iostreams/device/file.hpp>
#include <boost/iostreams/filter/gzip.hpp>
 
using namespace std;
namespace io = boost::iostreams;
namespace fs = boost::filesystem;
 
namespace Belle2::gearbox {
 
  FileContext::FileContext(const string& filename, bool compressed)
  {
    B2DEBUG(100, "Opening " << filename << (compressed ? " (gzip)" : ""));
    if (compressed) m_stream.push(io::gzip_decompressor());
    m_stream.push(io::file_source(filename));
  }
 
  FileHandler::FileHandler(const std::string& uri): InputHandler(uri), m_path(uri)
  {
 
    if (m_path.empty()) {
      m_path = "/data/";
    } else {
      //Check if we have placeholder for experiment or run information
      std::regex exp(R"(\{EXP(?::(\d+))?\})");
      std::regex run(R"(\{RUN(?::(\d+))?\})");
      m_rundependence = std::regex_search(m_path, exp) || std::regex_search(m_path, run);
      if (m_rundependence) {
        //Apparently we do have placeholders, replace them by something
        //boost::format will understand. The placeholder is something like
        //{EXP} or {EXP:<n>} where <n> is an integer to make the number
        //zero-filled with <n> digits, so we replace it with %1$0d or
        //%1$0<n>d to denote to the first argument in a boost format string.
        //Same for {RUN} and {RUN:<n>} but as second argument
        StoreObjPtr<EventMetaData> eventMetaDataPtr;
        eventMetaDataPtr.isRequired();
        std::string tmp = std::regex_replace(m_path, exp, std::string("%1$$0$1d"));
        tmp = std::regex_replace(tmp, run, std::string("%2$$0$1d"));
        B2DEBUG(300, "Found run-dependence in file path, resulting in " << tmp);
        m_pathformat = boost::format(tmp);
        m_pathformat.exceptions(boost::io::all_error_bits ^ boost::io::too_many_args_bit);
      }
    }
    B2DEBUG(300, "Created FileHandler for directory " << m_path);
  }
 
  InputContext* FileHandler::open(const std::string& path)
  {
    if (m_rundependence) {
      StoreObjPtr<EventMetaData> eventMetaDataPtr;
      if (!eventMetaDataPtr.isValid()) {
        B2DEBUG(300, "No run info, probably initialize? Skipping backend");
        return nullptr;
      }
      int exp = eventMetaDataPtr->getExperiment();
      int run = eventMetaDataPtr->getRun();
      m_path = (m_pathformat % exp % run).str();
    }
    fs::path basedir(m_path);
    std::string filename = (basedir / path).string();
    bool repeat(false);
    do {
      //Ok, let's try to find the file
      B2DEBUG(350, "Trying to find " << filename);
 
      std::string fullpath = FileSystem::findFile(filename, true);
      if (!fullpath.empty()) {
        if (m_rundependence) B2INFO("gearbox::FileHandler: Reading '" << fullpath << "'");
        return new FileContext(fullpath, false);
      }
      fullpath = FileSystem::findFile(filename + ".gz", true);
      if (!fullpath.empty()) {
        if (m_rundependence) B2INFO("gearbox::FileHandler: Reading '" << fullpath << "' (gzip)");
        return new FileContext(fullpath, true);
      }
 
      //did not work, replace last slash by a - and try again if such a
      //replacement was successful. This allows flattening the directory
      //structure from e.g. data/pxd/PXD-Alignment.xml to
      //data-pxd-PXD-Alignment.xml to more easily override single files
      size_t last_slash = filename.find_last_of('/');
      //If the last slash we found is after the primary path we try again.
      //This means we try to replace all slashes in the requested filename
      //but not in the given base path, for example:
      // - if the base path is "/somedir/data/" and the file to be opened is
      //   "foo/bar/baz.xml", we will look only for files up to
      //   "/somedir/data/foo-bar-baz.xml"
      // - if the base path does not end in "/", e.g. "/somedir/data" we also
      //   look for "/somedir/data-foo-bar-baz.xml"
      repeat = (last_slash >= m_path.size()) && (last_slash != std::string::npos);
      if (repeat) {
        filename[last_slash] = '-';
      }
    } while (repeat);
    return nullptr;
  }
 
  B2_GEARBOX_REGISTER_INPUTHANDLER(FileHandler, "file");
}