MeteoCH.h

Go to the documentation of this file.

// SPDX-License-Identifier: LGPL-3.0-or-later
/***********************************************************************************/
/*  Copyright 2026 WSL Institute for Snow and Avalanche Research    SLF-DAVOS      */
/***********************************************************************************/
/* This file is part of MeteoIO.
    MeteoIO 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 3 of the License, or
    (at your option) any later version.
 
    MeteoIO 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 MeteoIO.  If not, see <http://www.gnu.org/licenses/>.
*/
#ifndef METEOCH_H
#define METEOCH_H
 
#include <meteoio/dataClasses/Date.h>
#include <meteoio/IOInterface.h>
 
#include <string>
#include <vector>
#include <optional>
 
#ifdef _MSC_VER
        #pragma warning(disable:4512) //we don't need any = operator!
#endif
 
namespace mio {
 
class JsonWrapper; //forward declaration, it is defined in an include called in the .cc file
 
class MeteoCH : public IOInterface {
        public:
                MeteoCH(const std::string& configfile);
                MeteoCH(const Config&);
                MeteoCH(const MeteoCH&);
                ~MeteoCH() override;
 
                MeteoCH& operator=(const mio::MeteoCH&);
                
                virtual void readStationData(const Date& date, std::vector<StationData>& vecStation) override;
                
                virtual void readMeteoData(const Date& dateStart, const Date& dateEnd,
                                           std::vector< std::vector<MeteoData> >& vecMeteo) override;
                
        private:
                // Metadata field identifiers
                enum MetaField { ID, NAME, LATITUDE, LONGITUDE, ALTITUDE, WIGOS_ID, DATA_OWNER, NR_META };
                
                // For building the list of files to fetch for a given station
                using FileInfo = std::pair<DateRange, std::string>; //pair of date range and file name
                
                // Data source combining primary (10min preferred) and optional hourly fallback
                struct DataSource {
                        FileInfo primary;  
                        FileInfo fallback; 
                        bool hasFallback;
                        DataSource() : primary(), fallback(), hasFallback(false) {}
                };
                
                void initMeteoCHConnection(const Config& cfg);
                void readStationMeta();
                void parseMetaHeader(std::istringstream& csv_stream);
                void parseMetaContent(std::istringstream& csv_stream);
                void getStationDataFiles(std::string station_id);
                DateRange createDateRangeFromPeriod(const std::string& period, char type = 'h');
                
                // Structure for mapping MeteoSwiss CSV fields to MeteoIO parameters with unit conversions
                struct FieldMapping {
                        size_t field_index;          
                        std::string meteoio_param;   
                        double units_factor;    
                        double units_offset;    
                        
                        FieldMapping(size_t idx, const std::string& param,
                                     double factor = 1.0, double offset = 0.0)
                            : field_index(idx), meteoio_param(param),
                              units_factor(factor), units_offset(offset) {}
                };
                std::vector<FieldMapping> mapMeteoSwissParams(const std::vector<std::string>& meteoswiss_fields);
                std::vector<MeteoData> readCSVFile(const StationData& sd, const Date& start, const Date& end, const std::string& stationID, const std::string& filename);
                std::vector<MeteoData> parseCSVMeteoData(const StationData& sd, const Date& dateStart, const Date& dateEnd, std::istringstream& csv_stream);
                static Date parseTimestamp(const std::string& timestamp);
                void merge(std::vector<MeteoData>& results, std::vector<MeteoData>& vecData);
                void merge(std::vector<MeteoData>& results, std::vector<MeteoData>& vec10minutes, std::vector<MeteoData>& vecHourly);
                std::vector<MeteoData> readMeteoData(Date dateStart, Date dateEnd, const StationData& sd);
                
                std::map<std::string, std::vector<DataSource>> sources;
                std::map<std::string, size_t> requestedStationsMap;
                std::map<MetaField, size_t> metadataFields;
                std::vector<StationData> vecMeta;
                std::string coordin; 
                std::string coordinparam; 
                DateRange coverageRestrict; 
                JsonWrapper *json;
                bool meteoch_debug;
 
                static const int http_timeout_dflt;
                static const std::string base_url;
                static const std::string metadata_path;
                static const std::string meteo_collection_path;
};
 
} //end namespace mio
 
#endif