VtSource.cxx

Go to the documentation of this file.

/* Copyright (C) 2025 Jagiellonian University, Krakow
   SPDX-License-Identifier: GPL-3.0-only
   Authors: Bartosz Sobol [committer] */
 
#include "VtSource.h"
 
#include "RraSource.h"
#include "SimSource.h"
 
#include <Utility.hpp>
#include <regex>
 
#include <fmt/format.h>
 
VtSource::VtSource(const std::string& locator)
{
  UriComponents uri{locator};
 
  if (uri.scheme == "file") {
    std::regex ext_regex{R"(\.([^.\\/]+)$)"};
    std::smatch ext_match;
    std::regex_search(uri.path, ext_match, ext_regex);
    const auto filetype = ext_match[1].str();
 
    if (filetype == "rra") {
      L_(debug) << fmt::format("[VtSource] Adding RraSource with locator {} as underlying source", locator);
      fActualSource = std::make_unique<RraSource>(locator);
    }
    else if (filetype == "root") {
      L_(debug) << fmt::format("[VtSource] Adding SimSource with locator {} as underlying source", locator);
      fActualSource = std::make_unique<SimSource>(locator);
    }
    else {
      throw std::runtime_error(fmt::format("[VtSource] Unsupported input filetype: {}", filetype));
    }
  }
  else {
    throw std::runtime_error(fmt::format("[VtSource] Unsupported input scheme: {}", uri.scheme));
  }
}
 
bool VtSource::eos() const { return fActualSource->eos(); }
 
fles::StorableTimeslice* VtSource::do_get() { return fActualSource->get().release(); }