LogicalLocation.cc

Go to the documentation of this file.

// -*- lsst-c++ -*-

/* 
 * 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/>.
 */
 

#ifndef __GNUC__
#  define __attribute__(x) /*NOTHING*/
#endif
static char const* SVNid __attribute__((unused)) = "$Id$";

#include "lsst/daf/persistence/LogicalLocation.h"

#include "boost/regex.hpp"
#include "lsst/pex/exceptions.h"
#include "lsst/log/Log.h"

namespace dafBase = lsst::daf::base;
namespace dafPersist = lsst::daf::persistence;
namespace pexExcept = lsst::pex::exceptions;

namespace {
LOG_LOGGER _log = LOG_GET("daf.persistence.LogicalLocation");
}

dafBase::PropertySet::Ptr dafPersist::LogicalLocation::_map;

dafPersist::LogicalLocation::LogicalLocation(
    std::string const& locString, CONST_PTR(dafBase::PropertySet) additionalData) :
    lsst::daf::base::Citizen(typeid(*this)), _locString() {
    boost::regex expr("(%.*?)\\((\\w+?)\\)");
    boost::sregex_iterator i = make_regex_iterator(locString, expr);
    boost::sregex_iterator last;
    LOGLS_DEBUG(_log, "Input string: " << locString);
    while (i != boost::sregex_iterator()) {
        last = i;
        if ((*i).prefix().matched) {
            _locString += (*i).prefix().str();
        }
        std::string fmt = (*i).str(1);
        std::string key = (*i).str(2);
        LOGLS_DEBUG(_log, "Key: " << key);
        if (_map && _map->exists(key)) {
            if (_map->typeOf(key) == typeid(int)) {
                int value = _map->getAsInt(key);
                LOGLS_DEBUG(_log, "Map Val: " << value);
                if (fmt == "%") {
                    _locString += (boost::format("%1%") % value).str();
                }
                else {
                    _locString += (boost::format(fmt) % value).str();
                }
            }
            else {
                std::string value = _map->getAsString(key);
                LOGLS_DEBUG(_log, "Map Val: " << value);
                _locString += value;
            }
        }
        else if (additionalData && additionalData->exists(key)) {
            if (additionalData->typeOf(key) == typeid(int)) {
                int value = additionalData->getAsInt(key);
                LOGLS_DEBUG(_log, "Map Val: " << value);
                if (fmt == "%") {
                    _locString += (boost::format("%1%") % value).str();
                }
                else {
                    _locString += (boost::format(fmt) % value).str();
                }
            }
            else {
                std::string value = additionalData->getAsString(key);
                LOGLS_DEBUG(_log, "Map Val: " << value);
                _locString += value;
            }
        }
        else {
            throw LSST_EXCEPT(pexExcept::RuntimeError,
                              "Unknown substitution: " + key);
        }
        ++i;
    }
    if (last == boost::sregex_iterator()) {
        _locString = locString;
        LOGLS_DEBUG(_log, "Copy to: " << _locString);
    }
    else {
        _locString += (*last).suffix().str();
        LOGLS_DEBUG(_log, "Result: " << _locString);
    }
}

std::string const& dafPersist::LogicalLocation::locString(void) const {
    return _locString;
}

void dafPersist::LogicalLocation::setLocationMap(PTR(dafBase::PropertySet) map) {
    dafBase::PersistentCitizenScope scope;
    if (map) {
        _map = map->deepCopy();
    } else {
        _map.reset();
    }
}