Granule.cc

// -*- mode: c++; c-basic-offset:4 -*-
 
// This file is part of cmr_module, A C++ MODULE that can be loaded in to
// the OPeNDAP Back-End Server (BES) and is able to handle remote requests.
 
// Copyright (c) 2015 OPeNDAP, Inc.
// Author: Nathan Potter <ndp@opendap.org>
//
// This library is free software; you can redistribute it and/or
// modify it under the terms of the GNU Lesser General Public
// License as published by the Free Software Foundation; either
// version 2.1 of the License, or (at your option) any later version.
//
// This library 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
// Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public
// License along with this library; if not, write to the Free Software
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
//
// You can contact OPeNDAP, Inc. at PO Box 112, Saunderstown, RI. 02874-0112.
 
/*
 * Granule.h
 *
 *  Created on: July, 13 2018
 *      Author: ndp
 */
#include "config.h"
 
#include <cstdlib>     /* atol */
#include <sstream>
 
#include "JsonUtils.h"
#include "BESDebug.h"
 
#include "CmrNames.h"
#include "CmrInternalError.h"
#include "CmrNotFoundError.h"
#include "Granule.h"
#include "CmrApi.h"
 
 
using namespace std;
 
#define prolog std::string("Granule::").append(__func__).append("() - ")
 
 
namespace cmr {
Granule::Granule(const nlohmann::json& granule_json)
{
    setId(granule_json);
    setName(granule_json);
    setSize(granule_json);
    setDapServiceUrl(granule_json);
    setDataGranuleUrl(granule_json);
    setMetadataAccessUrl(granule_json);
    setLastModifiedStr(granule_json);
}
 
 
void Granule::setName(const nlohmann::json& granule_json)
{
    JsonUtils json;
    d_name = json.get_str_if_present(CMR_V2_TITLE_KEY, granule_json);
}
 
 
void Granule::setId(const nlohmann::json& granule_json)
{
    JsonUtils json;
    d_id = json.get_str_if_present(CMR_GRANULE_ID_KEY, granule_json);
}
 
 
void Granule::setSize(const nlohmann::json& granule_json)
{
    JsonUtils json;
    d_size_str = json.get_str_if_present(CMR_GRANULE_SIZE_KEY, granule_json);
}
 

void Granule::setLastModifiedStr(const nlohmann::json& granule_json)
{
    JsonUtils json;
    d_last_modified_time = json.get_str_if_present(CMR_GRANULE_LMT_KEY, granule_json);
}
 

const nlohmann::json& Granule::get_links_array(const nlohmann::json& granule_json) const
{
    JsonUtils json;
    return json.qc_get_array(CMR_GRANULE_LINKS_KEY, granule_json);
}
 
 

void Granule::setDataGranuleUrl(const nlohmann::json& granule_json)
{
    const auto& links = get_links_array(granule_json);
    for(auto &link : links){
        string rel = link[CMR_GRANULE_LINKS_REL].get<string>();
        if(rel == CMR_GRANULE_LINKS_REL_DATA_ACCESS){
            d_data_access_url = link[CMR_GRANULE_LINKS_HREF];
            return;
        }
    }
    stringstream msg;
    msg << "ERROR: Failed to locate granule data access link (";
    msg << CMR_GRANULE_LINKS_REL_DATA_ACCESS << "), :(";
    throw CmrInternalError(msg.str(), __FILE__, __LINE__);
}

void Granule::setDapServiceUrl(const nlohmann::json& granule_json)
{
    JsonUtils json;
    BESDEBUG(MODULE, prolog << "JSON: " << endl << granule_json.dump(4) << endl);
    const auto& links = get_links_array(granule_json);
    for(auto &link : links){
        string rel = json.get_str_if_present(CMR_GRANULE_LINKS_REL,link);
        if (rel == CMR_GRANULE_LINKS_REL_SERVICE) {
            // Check the service link title to see itf it's an OPeNDAP thing
            string title = json.get_str_if_present(CMR_V2_TITLE_KEY,link);
            // change to upper case
            transform(title.begin(), title.end(), title.begin(), ::toupper);
            if (title.find("OPENDAP") != string::npos) {
                // Ooh! It's an OPeNDAP service link.
                d_dap_service_url = json.get_str_if_present(CMR_GRANULE_LINKS_HREF, link);
                return;
            }
        }
    }
    stringstream msg;
    msg << "Failed to locate DAP service link (";
    msg << CMR_GRANULE_LINKS_REL_SERVICE << "), :(";
    BESDEBUG(MODULE, prolog << msg.str() << endl);
}
 

void Granule::setMetadataAccessUrl(const nlohmann::json& granule_json)
{
    const auto &links = get_links_array(granule_json);
    for(auto &link : links){
        string rel = link[CMR_GRANULE_LINKS_REL].get<string>();
        if(rel == CMR_GRANULE_LINKS_REL_METADATA_ACCESS){
            d_metadata_access_url = link[CMR_GRANULE_LINKS_HREF].get<string>();
            return;
        }
    }
    stringstream msg;
    msg << "ERROR: Failed to locate granule metadata access link (";
    msg << CMR_GRANULE_LINKS_REL_METADATA_ACCESS << "), :(";
    throw CmrInternalError(msg.str(), __FILE__, __LINE__);
}
 
size_t Granule::getSize() const {
    double value = strtod(getSizeStr().c_str(), nullptr);
    value *= 1024*1204;
    return static_cast<size_t>(value);
}
 
 
 
bes::CatalogItem *Granule::getCatalogItem(const BESCatalogUtils *d_catalog_utils) const
{
    auto *item = new bes::CatalogItem();
    item->set_type(bes::CatalogItem::leaf);
    item->set_name(getName());
    item->set_lmt(getLastModifiedStr());
    item->set_size(getSize());
    item->set_is_data(d_catalog_utils->is_data(item->get_name()));
    if(!getDapServiceUrl().empty()) {
        item->set_dap_service_url(getDapServiceUrl());
    }
 
    return item;
}
 
 
 
} //namespace cmr