decoder.h

#ifndef WREPORT_BUFR_DECODER_H
#define WREPORT_BUFR_DECODER_H
 
#include <wreport/var.h>
#include <wreport/bulletin.h>
#include <wreport/bulletin/interpreter.h>
#include <wreport/bufr/input.h>
 
namespace wreport {
namespace bufr {
struct DispatchToSubsets;
 
struct Decoder
{
    Input in;
    /* Output decoded variables */
    BufrBulletin& out;
    size_t expected_subsets;
    bool conf_add_undef_attrs = false;
    unsigned optional_section_length = 0;
    FILE* verbose_output = nullptr;
 
    Decoder(const std::string& buf, const char* fname, size_t offset, BufrBulletin& out);
 
    void read_options(const BufrCodecOptions& opts);
 
    void decode_sec1ed3();
    void decode_sec1ed4();
 
    /* Decode the message header only */
    void decode_header();
 
    /* Decode message data section after the header has been decoded */
    void decode_data();
};
 
struct DecoderTarget
{
    Input& in;
 
    DecoderTarget(Input& in) : in(in) {}
    virtual ~DecoderTarget() {}
 
    virtual const Subset& reference_subset() const = 0;
 
    virtual Varinfo lookup_info(unsigned pos) const = 0;
 
    virtual Var decode_uniform_b_value(Varinfo info) = 0;
 
    virtual const Var& decode_and_add_to_all(Varinfo info) = 0;
 
    virtual const Var& decode_and_add_bitmap(const Tables& tables, Varcode code, unsigned bitmap_size) = 0;
 
    virtual void decode_and_set_attribute(Varinfo info, unsigned pos) = 0;
 
    virtual void decode_and_add_b_value(Varinfo info) = 0;
 
    virtual void decode_and_add_b_value_with_associated_field(Varinfo info, const bulletin::AssociatedField& field) = 0;
 
    virtual void decode_and_add_raw_character_data(Varinfo info) = 0;
 
    virtual int decode_c03_refval_override(unsigned bits) = 0;
 
    virtual void print_last_variable_added(FILE* out) = 0;
 
    virtual void print_last_attribute_added(FILE* out, Varcode code, unsigned pos) = 0;
};
 
struct UncompressedDecoderTarget : public DecoderTarget
{
    Subset& out;
 
    UncompressedDecoderTarget(Input& in, Subset& out);
 
    const Subset& reference_subset() const override;
    Varinfo lookup_info(unsigned pos) const override;
    Var decode_uniform_b_value(Varinfo info) override;
    const Var& decode_and_add_to_all(Varinfo info) override;
    const Var& decode_and_add_bitmap(const Tables& tables, Varcode code, unsigned bitmap_size) override;
    void decode_and_set_attribute(Varinfo info, unsigned pos) override;
    void decode_and_add_b_value(Varinfo info) override;
    void decode_and_add_b_value_with_associated_field(Varinfo info, const bulletin::AssociatedField& field) override;
    void decode_and_add_raw_character_data(Varinfo info) override;
    int decode_c03_refval_override(unsigned bits) override;
 
    void print_last_variable_added(FILE* out) override;
    void print_last_attribute_added(FILE* out, Varcode code, unsigned pos) override;
};
 
struct CompressedDecoderTarget : public DecoderTarget
{
    Bulletin& out;
 
    unsigned subset_count;
 
    CompressedDecoderTarget(Input& in, Bulletin& out);
 
    const Subset& reference_subset() const override;
    Varinfo lookup_info(unsigned pos) const override;
    Var decode_uniform_b_value(Varinfo info) override;
    const Var& decode_and_add_to_all(Varinfo info) override;
    const Var& decode_and_add_bitmap(const Tables& tables, Varcode code, unsigned bitmap_size) override;
    void decode_and_set_attribute(Varinfo info, unsigned pos) override;
    void decode_and_add_b_value(Varinfo info) override;
    void decode_and_add_b_value_with_associated_field(Varinfo info, const bulletin::AssociatedField& field) override;
    void decode_and_add_raw_character_data(Varinfo info) override;
    int decode_c03_refval_override(unsigned bits) override;
 
    void print_last_variable_added(FILE* out) override;
    void print_last_attribute_added(FILE* out, Varcode code, unsigned pos) override;
 
protected:
    void decode_b_value(Varinfo info, std::function<void(unsigned, Var&&)> dest);
};
 
struct DataSectionDecoder : public bulletin::Interpreter
{
    DecoderTarget& target;
 
    DataSectionDecoder(Bulletin& bulletin, DecoderTarget& target);
 
    unsigned define_delayed_replication_factor(Varinfo info) override;
    unsigned define_associated_field_significance(Varinfo info) override;
    unsigned define_bitmap_delayed_replication_factor(Varinfo info) override;
    void define_c03_refval_override(Varcode code) override;
    void define_bitmap(unsigned bitmap_size) override;
    void define_attribute(Varinfo info, unsigned pos) override;
    void define_substituted_value(unsigned pos) override;
    void define_variable(Varinfo info) override;
    void define_variable_with_associated_field(Varinfo info) override;
    void define_raw_character_data(Varcode code) override;
};
 
struct VerboseDataSectionDecoder : public DataSectionDecoder
{
protected:
    void print_lead(Varcode code);
    void print_lead_continued();
 
public:
    FILE* out;
 
    unsigned indent = 0;
 
    unsigned indent_step = 2;
 
    VerboseDataSectionDecoder(Bulletin& bulletin, DecoderTarget& target, FILE* out);
 
    void b_variable(Varcode code) override;
    void c_modifier(Varcode code, Opcodes& next) override;
    void r_replication(Varcode code, Varcode delayed_code, const Opcodes& ops) override;
    void run_d_expansion(Varcode code) override;
    unsigned define_delayed_replication_factor(Varinfo info) override;
    unsigned define_associated_field_significance(Varinfo info) override;
    unsigned define_bitmap_delayed_replication_factor(Varinfo info) override;
    void define_c03_refval_override(Varcode code) override;
    void define_bitmap(unsigned bitmap_size) override;
    void define_attribute(Varinfo info, unsigned pos) override;
    void define_substituted_value(unsigned pos) override;
    void define_variable(Varinfo info) override;
    void define_variable_with_associated_field(Varinfo info) override;
    void define_raw_character_data(Varcode code) override;
};
 
}
}
#endif