AliYAMLConfiguration.cxx

Go to the documentation of this file.

//
//

#include "AliYAMLConfiguration.h"

#include <cstdio>
#include <fstream>

#include <TSystem.h>
#include <TGrid.h>
#include <TFile.h>
#include <TUUID.h>

ClassImp(PWG::Tools::AliYAMLConfiguration);

namespace PWG {
namespace Tools {

AliYAMLConfiguration::AliYAMLConfiguration(const std::string prefixString, const std::string delimiterCharacter):
  TObject(),
  fConfigurations(),
  fConfigurationsStrings(),
  fInitialized(false),
  fPrefixString(prefixString),
  fDelimiter(delimiterCharacter)
{
}

int AliYAMLConfiguration::AddEmptyConfiguration(const std::string & configurationName)
{
  YAML::Node node;
  AliInfoStream() << "Adding configuration \"" << configurationName << "\" as an empty YAML node.\n";
  return AddConfiguration(node, configurationName);
}

int AliYAMLConfiguration::AddConfiguration(std::string configurationFilename, std::string configurationName)
{
  SetupReadingConfigurationFilePath(configurationFilename, configurationName);

  // Add file
  if (DoesFileExist(configurationFilename) == false) {
    AliErrorStream() << "Configuration filename \"" << configurationFilename << "\" does not exist!\n";
    return -1;
  }

  // Create node from filename
  auto node = YAML::LoadFile(configurationFilename);

  if (node.IsNull() == true) {
    AliErrorStream() << "The node at configuration filename \"" << configurationFilename << "\" is null and will not be added!\n";
    return -1;
  }

  AliInfoStream() << "Adding configuration \"" << configurationName << "\" located at \"" << configurationFilename << "\".\n";
  return AddConfiguration(node, configurationName);
}

int AliYAMLConfiguration::AddConfiguration(const YAML::Node node, std::string configurationName)
{
  if (configurationName == "")
  {
    // Attempt to get name from node
    // It is fine if the node is empty
    GetPropertyFromNode(node, "name", configurationName);
  }

  if (configurationName == "") {
    AliErrorStream() << "Could not determine a name for the configuration:\n\"\n" << node << "\n\" Configuration will not be added!\n";
    return -1;
  }

  // Add the configuration
  AliDebugStream(2) << "Adding configuration \"" << configurationName << "\".\n";
  fConfigurations.push_back(std::make_pair(configurationName, node));

  // Return the location of the new configuration
  return fConfigurations.size() - 1;
}

bool AliYAMLConfiguration::RemoveConfiguration(const unsigned int i)
{
  bool returnValue = false;
  if (i < fConfigurations.size())
  {
    fConfigurations.erase(fConfigurations.begin() + i);
    returnValue = true;
  }

  return returnValue;
}

bool AliYAMLConfiguration::WriteConfiguration(const std::string & filename, const unsigned int index) const
{
  // Write to a local temp filename
  TUUID tempUUID;
  std::string localFilename = tempUUID.AsString();
  localFilename += ".yaml";

  if (!DoesConfigurationExist(index)) {
    AliWarningStream() << "Requested configuration index " << index << " does not exist - it cannot be written!\n";
    return false;
  }
  auto configPair = fConfigurations.at(index);
  std::ofstream outputFile(localFilename);
  outputFile << configPair.second;
  outputFile.close();

  // Hanldes writing to places like AliEn
  WriteConfigurationToFilePath(localFilename, filename);

  remove(localFilename.c_str());

  return true;
}

bool AliYAMLConfiguration::WriteConfiguration(const std::string & filename, const std::string & configurationName) const
{
  return WriteConfiguration(filename, GetConfigurationIndexFromName(configurationName, fConfigurations));
}

bool AliYAMLConfiguration::CompareConfigurations(const int configIndex1, const int configIndex2) const
{
  bool returnValue = false;

  bool configsExist = true;
  std::vector<int> configs = {configIndex1, configIndex2};
  for (auto config : configs) {
    if (!DoesConfigurationExist(config)) {
      AliErrorStream() << "Configuration at index " << config << " does not exist.\n";
      configsExist = false;
    }
  }

  if (configsExist)
  {
    // Generate YAML nodes for the comparison
    auto configPair1 = GetConfiguration(configIndex1);
    auto configPair2 = GetConfiguration(configIndex2);

    // Need to stream the configuration back to a string to remove the comments
    // since they are not preserved in the YAML node.
    std::stringstream config1SS;
    config1SS << configPair1.second;
    std::stringstream config2SS;
    config2SS << configPair2.second;

    // Compare the nodes. Make the comparison as strings, as the YAML nodes do _not_ match,
    // despite the strings matching. In fact, the YAML nodes will _not_ match even if they
    // are generated from the same string....
    if (config1SS.str() == config2SS.str()) {
      returnValue = true;
    }
    else {
      // Already should be the case, but just to be explicit.
      returnValue = false;

      // Inform the user about the details of the mismatch
      std::stringstream errorMessageSS;
      errorMessageSS << "Configuration mismatch between configuration at index " << configIndex1 << " and at index " << configIndex2 << "\n";
      errorMessageSS << "Config 1:\n";
      Print(errorMessageSS, configIndex1);
      errorMessageSS << "Config 2:\n";
      Print(errorMessageSS, configIndex2);
      AliWarningStream() << errorMessageSS.str();
    }
  }

  return returnValue;
}


inline bool AliYAMLConfiguration::DoesFileExist(const std::string & filename) const
{
  std::ifstream inFile(filename);
  return inFile.good();
}

void AliYAMLConfiguration::SetupReadingConfigurationFilePath(std::string & filename, const std::string & fileIdentifier) const
{
  if (filename != "")
  {
    // Handle if in AliPhysics and includes $ALICE_PHYSICS
    filename = gSystem->ExpandPathName(filename.c_str());

    // Handle grid
    if(filename.find("alien://") != std::string::npos)
    {
      AliDebug(2, TString::Format("Opening file \"%s\" on the grid!", filename.c_str()));
      // Initialize AliEn connection if needed
      if (!gGrid) {
        TGrid::Connect("alien://");
      }

      // Determine the local filename and copy file to local directory
      std::string localFilename = gSystem->BaseName(filename.c_str());
      // Add identifier if it's not an empty string
      if (fileIdentifier != "") {
        localFilename = fileIdentifier + "." + localFilename;
      }
      // Add UUID to ensure there are no conflicts if multiple yaml configs have the same configuration file name
      TUUID tempUUID;
      localFilename = "." + localFilename;
      localFilename = tempUUID.AsString() + localFilename;

      // Copy file
      TFile::Cp(filename.c_str(), localFilename.c_str());

      // yaml-cpp should only open the local file
      filename = localFilename;
    }
  }
}

void AliYAMLConfiguration::WriteConfigurationToFilePath(const std::string & localFilename, std::string filename) const
{
  bool cannotWriteFile = false;
  if (localFilename == "") {
    AliErrorStream() << "Local filename is null, so the file cannot be written!\n";
    cannotWriteFile = true;
  }
  if (filename == "") {
    AliErrorStream() << "Filename is null, so the file cannot be written\n";
    cannotWriteFile = true;
  }

  if (cannotWriteFile == false) {
    // Handle if in AliPhysics and includes $ALICE_PHYSICS
    filename = gSystem->ExpandPathName(filename.c_str());

    // Handle grid
    if(filename.find("alien://") != std::string::npos)
    {
      AliDebugStream(2) << "Writing file \"" << filename << "\" on the grid!\n";
      // Initialize AliEn connection if needed
      if (!gGrid) {
        TGrid::Connect("alien://");
      }
    }

    // Copy file
    AliDebugStream(2) << "Copying localFilename \"" << localFilename << "\" to filename \"" << filename << "\".\n";
    TFile::Cp(localFilename.c_str(), filename.c_str());
  }
}

bool AliYAMLConfiguration::Initialize()
{
  // Copy all configurations to their respective strings.
  // That way, the strings will be successfully streamed by ROOT and the YAML nodes can be re-initialized on the grid.
  std::stringstream tempSS;
  for (auto & configPair : fConfigurations)
  {
    tempSS.str("");
    tempSS << configPair.second;
    fConfigurationsStrings.push_back(std::make_pair(configPair.first, tempSS.str()));
  }

  fInitialized = true;

  return fInitialized;
}

bool AliYAMLConfiguration::Reinitialize()
{
  bool returnValue = false;

  // If they were not streamed then the size of the vectors should not match
  if (fConfigurations.size() != fConfigurationsStrings.size())
  {
    if (fInitialized == false)
    {
      // Not initialized, so the strings do not represent the nodes
      AliFatalGeneral("AliYAMLConfiguration", "Attempted to re-initialize the YAML nodes, but the string based configurations are not available. Did you remember to call initialize?");
    }

    for (const auto & configStrPair : fConfigurationsStrings)
    {
      YAML::Node node = YAML::Load(configStrPair.second);
      fConfigurations.push_back(std::make_pair(configStrPair.first, node));
    }

    returnValue = true;
  }

  return returnValue;
}

bool AliYAMLConfiguration::IsSharedValue(std::string & value) const
{
  std::string stringToFind = "sharedParameters:";
  std::size_t sharedParameterLocation = value.find(stringToFind);
  if (sharedParameterLocation != std::string::npos)
  {
    value.erase(sharedParameterLocation, sharedParameterLocation + stringToFind.length());
    return true;
  }
  // Return false otherwise
  return false;
}

void AliYAMLConfiguration::PrintConfiguration(std::ostream & stream, const std::pair<std::string, YAML::Node> & configPair) const
{
  stream << "\nConfiguration Name: \"" << configPair.first << "\"\n\n";
  stream << configPair.second << "\n";
}

std::string AliYAMLConfiguration::toString(const int index) const
{
  std::stringstream tempSS;

  if (index < 0) {
    // Print header information
    tempSS << std::boolalpha;
    tempSS << "AliYAMLConfiguration:\n";
    tempSS << "Initialized: " << fInitialized << "\n";
    tempSS << "Prefix string: \"" << fPrefixString << "\"\n";
    tempSS << "Delimiter: \"" << fDelimiter << "\"\n";
    tempSS << "Configurations vector length: " << fConfigurations.size() << ", Configurations string vector length: " << fConfigurationsStrings.size() << "\n";
    tempSS << "\nYAML Configurations:\n";

    // Print all configurations
    for (auto configPair : fConfigurations) {
      PrintConfiguration(tempSS, configPair);
    }
  }
  else {
    // Print a particular configuration
    if (static_cast<const unsigned int>(index) < fConfigurations.size()) {
      PrintConfiguration(tempSS, fConfigurations.at(index));
    }
    else {
      tempSS << "Index " << index << " is out of range!\n";
    }
  }

  return tempSS.str();
}

std::ostream & AliYAMLConfiguration::Print(std::ostream & in, const int index) const {
  in << toString(index);
  return in;
}

std::ostream & AliYAMLConfiguration::Print(std::ostream & in, const std::string & configurationName) const {
  std::ostream & result = Print(in, GetConfigurationIndexFromName(configurationName, fConfigurations));
  return result;
}

void AliYAMLConfiguration::Print(Option_t* opt) const
{
  AliInfoStream() << toString();
}

} // namespace Tools
} // namespace PWG

std::ostream & operator<<(std::ostream & in, const PWG::Tools::AliYAMLConfiguration & myTask)
{
  std::ostream & result = myTask.Print(in);
  return result;
}