bufr2ioda.cpp

Go to the documentation of this file.

/*
 * (C) Copyright 2020 NOAA/NWS/NCEP/EMC
 *
 * This software is licensed under the terms of the Apache Licence Version 2.0
 * which can be obtained at http://www.apache.org/licenses/LICENSE-2.0.
 */
 
#include <string>
#include <iostream>
#include <ostream>
#include <iomanip>
 
#include "eckit/config/YAMLConfiguration.h"
#include "eckit/exception/Exceptions.h"
#include "eckit/filesystem/PathName.h"
 
#include "BufrParser/BufrDescription.h"
#include "BufrParser/BufrMnemonicSet.h"
#include "BufrParser/BufrParser.h"
#include "IodaEncoder/IodaDescription.h"
#include "IodaEncoder/IodaEncoder.h"
#include "DataContainer.h"
 
#include "ParserFactory.h"
 
 
namespace Ingester
{
    void parse(std::string yamlPath)
    {
        std::unique_ptr<eckit::YAMLConfiguration>
            yaml(new eckit::YAMLConfiguration(eckit::PathName(yamlPath)));
 
        if (yaml->has("observations"))
        {
            for (const auto& obsConf : yaml->getSubConfigurations("observations"))
            {
                if (!obsConf.has("obs space") ||
                    !obsConf.has("ioda"))
                {
                    eckit::BadParameter(
                        "Incomplete obs found. All obs must have a obs space and ioda.");
                }
 
                auto parser = ParserFactory::create(obsConf.getSubConfiguration("obs space"));
                auto data = parser->parse();
 
                auto encoder = IodaEncoder(obsConf.getSubConfiguration("ioda"));
                encoder.encode(data);
            }
        }
        else
        {
            eckit::BadParameter("No section named \"observations\"");
        }
    }
 
    void registerParsers()
    {
        ParserFactory::registerParser<BufrParser>("bufr");
    }
}  // namespace Ingester
 
 
int main(int argc, char **argv)
{
    if (argc < 2)
    {
        eckit::BadParameter("Missing argument. Must include YAML file path.");
    }
 
    Ingester::registerParsers();
    Ingester::parse(std::string(argv[1]));
 
    return 0;
}