station.h

#ifndef DBALLE_DB_V7_STATION_H
#define DBALLE_DB_V7_STATION_H

#include <cstdio>
#include <dballe/core/fwd.h>
#include <dballe/db/v7/cache.h>
#include <dballe/db/v7/fwd.h>
#include <dballe/fwd.h>
#include <dballe/sql/fwd.h>
#include <functional>
#include <memory>
#include <unordered_map>
#include <unordered_set>
#include <vector>

namespace wreport {
struct Var;
}

namespace dballe {
namespace db {
namespace v7 {

struct Station
{
protected:
    v7::Transaction& tr;
    virtual void
    _dump(std::function<void(int, int, const Coords& coords, const char* ident)>
              out) = 0;

public:
    Station(v7::Transaction& tr);
    virtual ~Station();

    virtual DBStation lookup(Tracer<>& trc, int id_station) = 0;

    virtual int maybe_get_id(Tracer<>& trc, const dballe::DBStation& st) = 0;

    virtual int insert_new(Tracer<>& trc, const dballe::DBStation& desc) = 0;

    virtual void run_station_query(
        Tracer<>& trc, const v7::StationQueryBuilder& qb,
        std::function<void(const dballe::DBStation& station)>) = 0;

    virtual void get_station_vars(
        Tracer<>& trc, int id_station,
        std::function<void(std::unique_ptr<wreport::Var>)> dest) = 0;

    virtual void add_station_vars(Tracer<>& trc, int id_station,
                                  DBValues& values) = 0;

    void dump(FILE* out);
};

} // namespace v7
} // namespace db
} // namespace dballe
#endif