PolicyWriter.cc

Go to the documentation of this file.

/*
 * LSST Data Management System
 * Copyright 2008, 2009, 2010 LSST Corporation.
 *
 * This product includes software developed by the
 * LSST Project (http://www.lsst.org/).
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, 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.
 *
 * You should have received a copy of the LSST License Statement and
 * the GNU General Public License along with this program.  If not,
 * see <http://www.lsstcorp.org/LegalNotices/>.
 */

#include "lsst/pex/policy/PolicyWriter.h"
#include "lsst/pex/policy/Policy.h"
#include "lsst/pex/policy/PolicyFile.h"

#include <fstream>
#include <sstream>

namespace lsst {
namespace pex {
namespace policy {

//@cond
using lsst::daf::base::Persistable;
using lsst::daf::base::PropertySet;

/*
 * create a writer attached to an output stream
 * @param out     the output stream to write data to
 */
PolicyWriter::PolicyWriter(std::ostream* out) : _myos(0), _os(out) {
    if (!out) {
        _myos = new std::ostringstream();
        _os = _myos;
    }
}

/*
 * create a writer attached to a file.  The file will be immediately
 * opened for writing.
 * @param file     the path to the output file
 */
PolicyWriter::PolicyWriter(const std::string& file, bool append)
        : _myos(new std::ofstream(file.c_str(), append ? std::ios_base::app : std::ios_base::trunc)), _os(0) {
    _myos->exceptions(std::ofstream::failbit | std::ofstream::badbit);
    _os = _myos;
}

PolicyWriter::~PolicyWriter() {
    if (_myos) delete _myos;
}

/*
 * return the written data as a string.  This string will be non-empty
 * only if this class was was instantiated without an attached stream.
 */
std::string PolicyWriter::toString() {
    std::ostringstream* ss = dynamic_cast<std::ostringstream*>(_os);
    if (ss) return ss->str();
    return std::string();
}

/*
 * close the output stream.  This has no effect if the attached
 * stream is not a file stream.
 */
void PolicyWriter::close() {
    std::ofstream* fs = dynamic_cast<std::ofstream*>(_os);
    if (fs) fs->close();
}

/*
 * write the contents of a policy the attached stream.  Each top-level
 * parameter will be recursively printed.
 * @param policy     the policy data to write
 */
void PolicyWriter::write(const Policy& policy, bool doDecl) {
    if (doDecl) (*_os) << "#<?cfg paf policy ?>" << std::endl;

    Policy::StringArray names = policy.names(true);
    Policy::StringArray::const_iterator ni;
    for (ni = names.begin(); ni != names.end(); ++ni) {
        try {
            const std::type_info& tp = policy.typeOf(*ni);
            if (tp == typeid(bool)) {
                writeBools(*ni, policy.getBoolArray(*ni));
            } else if (tp == typeid(int)) {
                writeInts(*ni, policy.getIntArray(*ni));
            } else if (tp == typeid(double)) {
                writeDoubles(*ni, policy.getDoubleArray(*ni));
            } else if (tp == typeid(std::string)) {
                writeStrings(*ni, policy.getStringArray(*ni));
            } else if (tp == daf::base::PropertySet::typeOfT<std::shared_ptr<daf::base::PropertySet>>()) {
                writePolicies(*ni, policy.getPolicyArray(*ni));
            } else if (tp == daf::base::PropertySet::typeOfT<std::shared_ptr<daf::base::Persistable>>()) {
                writeFiles(*ni, policy.getFileArray(*ni));
            } else {
                throw LSST_EXCEPT(pexExcept::LogicError, "Policy: unexpected type for name=" + *ni);
            }
        } catch (NameNotFound&) {
            // shouldn't happen
            writeString(*ni, "<missing data>");
        }
    }
}

void PolicyWriter::writeBool(const std::string& name, bool value) {
    std::vector<bool> vals;
    vals.push_back(value);
    writeBools(name, vals);
}

void PolicyWriter::writeInt(const std::string& name, int value) {
    std::vector<int> vals;
    vals.push_back(value);
    writeInts(name, vals);
}

void PolicyWriter::writeDouble(const std::string& name, double value) {
    std::vector<double> vals;
    vals.push_back(value);
    writeDoubles(name, vals);
}

void PolicyWriter::writeString(const std::string& name, const std::string& value) {
    std::vector<std::string> vals;
    vals.push_back(value);
    writeStrings(name, vals);
}

void PolicyWriter::writePolicy(const std::string& name, const Policy& value) {
    std::vector<Policy::Ptr> vals;
    vals.push_back(Policy::Ptr(new Policy(value)));
    writePolicies(name, vals);
}

void PolicyWriter::writeFile(const std::string& name, const PolicyFile& value) {
    std::vector<Policy::FilePtr> vals;
    vals.push_back(Policy::FilePtr(new PolicyFile(value)));
    writeFiles(name, vals);
}

//@endcond

}  // namespace policy
}  // namespace pex
}  // namespace lsst