/*
 * @project      The CERN Tape Archive (CTA)
 * @copyright    Copyright © 2021-2022 CERN
 * @license      This program is free software, distributed under the terms of the GNU General Public
 *               Licence version 3 (GPL Version 3), copied verbatim in the file "COPYING". You can
 *               redistribute it and/or modify it under the terms of the GPL Version 3, or (at your
 *               option) any later version.
 *
 *               This program is distributed in the hope that it will be useful, but WITHOUT ANY
 *               WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
 *               PARTICULAR PURPOSE. See the GNU General Public License for more details.
 *
 *               In applying this licence, CERN does not waive the privileges and immunities
 *               granted to it by virtue of its status as an Intergovernmental Organization or
 *               submit itself to any jurisdiction.
 */

#include "tapeserver/daemon/Tpconfig.hpp"
#include "common/utils/utils.hpp"
#include "common/exception/Errnum.hpp"

#include <errno.h>
#include <memory>
#include <fstream>
#include <algorithm>

namespace cta::tape::daemon {

//------------------------------------------------------------------------------
// parseTpconfigFile
//------------------------------------------------------------------------------
Tpconfig Tpconfig::parseFile(const std::string &filename) {
  Tpconfig ret;
  // Try to open the configuration file, throwing an exception if there is a
  // failure
  std::ifstream file(filename);
  if (file.fail()) {
    cta::exception::Errnum ex;
    ex.getMessage() << " In Tpconfig::parseFile()"
      ": Failed to open tpConfig file"
      ": filename=" << filename;
    throw ex;
  }

  std::string line;
  size_t lineNumber=0;
  while(++lineNumber, std::getline(file, line)) {
    // If there is a comment, then remove it from the line
    line = line.substr(0, line.find('#'));
    // get rid of potential tabs
    std::replace(line.begin(),line.end(),'\t',' ');
    std::istringstream sline(line);
    // This is the expected fields in the line.
    std::string unitName, logicalLibarry, devFilePath, librarySlot;
    // If there is nothing on the line, ignore it.
    if (!(sline >> unitName)) continue;
    // But if there is anything, we expect all parameters.
    if (!( (sline >> logicalLibarry)
         &&(sline >> devFilePath)
         &&(sline >> librarySlot))) {
      cta::exception::Exception ex;
      ex.getMessage() << "In Tpconfig::parseFile(): " <<
        "missing parameter(s) from line=" << line <<
        " filename=" << filename;
      throw ex;
    }
    std::string extra;
    if ( sline >> extra) {
      cta::exception::Exception ex;
      ex.getMessage() << "In Tpconfig::parseFile(): " <<
        "extra parameter(s) from line=" << line <<
        " filename=" << filename;
      throw ex;
    }
    // The constructor implicitly validates the lengths
    const TpconfigLine configLine(unitName, logicalLibarry, devFilePath, librarySlot);
    // Store the value of the data-columns in the output list parameter
    // Check for duplication
    if (ret.count(configLine.unitName)) {
      DuplicateEntry ex("In Tpconfig::parseFile(): duplicate entry for unit ");
      ex.getMessage() << configLine.unitName << " at " << filename << ":" << lineNumber
         << " previous at " << ret.at(configLine.unitName).source();
      throw ex;
    }
    // Check there is not duplicate of the path
    {
      auto i = std::find_if(ret.begin(), ret.end(),
        // https://trac.cppcheck.net/ticket/10739
        [&configLine](decltype(*ret.begin()) i) { // cppcheck-suppress internalAstError
          return i.second.value().devFilename == configLine.devFilename;
        });
      if(ret.end() != i) {
        DuplicateEntry ex("In Tpconfig::parseFile(): duplicate path for unit ");
        ex.getMessage() << configLine.unitName << " at " << filename << ":" << lineNumber
           << " previous at " << i->second.source();
        throw ex;
      }
    }
    // Check there is not duplicate of the library slot
    {
      auto i = std::find_if(ret.begin(), ret.end(),
        [&configLine](decltype(*ret.begin()) j) {
          return j.second.value().rawLibrarySlot == configLine.rawLibrarySlot;
      });
      if (ret.end() != i) {
        DuplicateEntry ex("In Tpconfig::parseFile(): duplicate library slot for unit ");
        ex.getMessage() << configLine.unitName << " at " << filename << ":" << lineNumber
           << " previous at " << i->second.source();
        throw ex;
      }
    }
    // This is a re-use of the container for the cta-taped.conf representation.
    // There is no category nor key here.
    std::stringstream linestr;
    linestr << filename << ":" << lineNumber;
    ret.emplace(configLine.unitName, decltype(ret.begin()->second)("", "", configLine, linestr.str()));
  }
  return ret;
}

} // namespace cta::tape::daemon