explorer.h

#ifndef DBALLE_DB_EXPLORER_H
#define DBALLE_DB_EXPLORER_H

#include <dballe/core/query.h>
#include <dballe/db/db.h>
#include <dballe/db/summary.h>
#include <map>
#include <set>
#include <vector>

namespace dballe {
namespace db {

template <typename Station> class BaseExplorer
{
protected:
    std::shared_ptr<dballe::db::BaseSummary<Station>> _global_summary;

    dballe::core::Query filter;

    std::shared_ptr<dballe::db::BaseSummary<Station>> _active_summary;

    void commit();

    void update_active_summary();

public:
    class Update
    {
    protected:
        BaseExplorer<Station>* explorer = nullptr;

        Update(BaseExplorer<Station>* explorer);

    public:
        Update();
        Update(const Update&) = delete;
        Update(Update&&);
        ~Update();

        Update& operator=(const Update&) = delete;
        Update& operator=(Update&&);

        void add_db(dballe::db::Transaction& tr);

        void add_cursor(dballe::CursorSummary& cur);

        void add_json(core::json::Stream& in);

        template <typename OStation>
        void add_explorer(const BaseExplorer<OStation>& explorer);

        void add_message(const dballe::Message& message,
                         bool station_data = true, bool data = true);

        void add_messages(
            const std::vector<std::shared_ptr<dballe::Message>>& messages,
            bool station_data = true, bool data = true);

        void commit();

        friend class BaseExplorer<Station>;
    };

    BaseExplorer();
    BaseExplorer(const std::string& pathname);
    BaseExplorer(const BaseExplorer&) = delete;
    BaseExplorer(BaseExplorer&&)      = delete;
    ~BaseExplorer();
    BaseExplorer& operator=(const BaseExplorer&) = delete;
    BaseExplorer& operator=(BaseExplorer&&)      = delete;

    const dballe::Query& get_filter() const;

    void set_filter(const dballe::Query& query);

    Update rebuild();

    Update update();

    const dballe::db::BaseSummary<Station>& global_summary() const;

    const dballe::db::BaseSummary<Station>& active_summary() const;

    void to_json(core::JSONWriter& writer) const;
};

typedef BaseExplorer<dballe::Station> Explorer;

typedef BaseExplorer<dballe::DBStation> DBExplorer;

extern template class BaseExplorer<dballe::Station>;
extern template void BaseExplorer<dballe::Station>::Update::add_explorer(
    const BaseExplorer<DBStation>&);
extern template class BaseExplorer<dballe::DBStation>;
extern template void BaseExplorer<dballe::DBStation>::Update::add_explorer(
    const BaseExplorer<Station>&);

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