msgapi.h

#ifndef DBALLE_FORTRAN_MSGAPI_H
#define DBALLE_FORTRAN_MSGAPI_H
 
#include "commonapi.h"
#include <dballe/core/defs.h>
#include <dballe/fwd.h>
#include <dballe/msg/fwd.h>
 
namespace wreport {
struct Var;
}
 
namespace dballe {
namespace fortran {
 
class MsgAPI : public CommonAPIImplementation
{
protected:
    enum {
        STATE_BLANK        = 1,
        STATE_QUANTESONO   = 2,
        STATE_VOGLIOQUESTO = 4,
        STATE_EOF          = 8,
    };
    File* file;
    unsigned int state;
    Importer* importer;
    std::string exporter_template;
    Exporter* exporter = nullptr;
    size_t curmsgidx;
    int cached_cat;
    int cached_subcat;
    int cached_lcat;

    bool readNextMessage();
 
public:
    std::shared_ptr<impl::Message> wmsg                 = nullptr;
    std::vector<std::shared_ptr<dballe::Message>>* msgs = nullptr;

    MsgAPI(const char* fname, const char* mode, const char* type);
    virtual ~MsgAPI();

    const impl::Message* curmsg() const;
    impl::Message* curmsg();
    void flushSubset();
    void flushMessage();
    void set_exporter(const char* template_name);
 
    void reinit_db(const char* repinfofile = 0) override;
    int query_stations() override;
    int query_data() override;
    void insert_data() override;
    void remove_data() override;
    void remove_all() override;
    void messages_open_input(const char* filename, const char* mode,
                             Encoding format, bool) override;
    void messages_open_output(const char* filename, const char* mode,
                              Encoding format) override;
    bool messages_read_next() override;
    void messages_write_next(const char*) override;
};
 
} // namespace fortran
} // namespace dballe
#endif