/usr/include/dballe/msg/wr_codec.h is in libdballe-dev 7.7-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 | #ifndef DBALLE_MSG_WR_CODEC_H
#define DBALLE_MSG_WR_CODEC_H
#include <dballe/msg/codec.h>
#include <wreport/varinfo.h>
#include <stdint.h>
#include <map>
#include <string>
namespace wreport {
struct Bulletin;
struct Subset;
}
namespace dballe {
struct Msg;
namespace msg {
struct Context;
class WRImporter : public Importer
{
public:
WRImporter(const Options& opts);
/**
* Import a decoded BUFR/CREX message
*/
Messages from_bulletin(const wreport::Bulletin& msg) const override;
/**
* Decode a message from its decoded bulletin, calling \a dest on each
* resulting Msg.
*
* Return false from \a dest to stop decoding.
*
* @param rmsg
* Encoded message.
* @retval dest
* The function that consumes the decoded messages.
* @returns true if it got to the end of decoding, false if dest returned false.
*/
bool foreach_decoded_bulletin(const wreport::Bulletin& msg, std::function<bool(std::unique_ptr<Message>&&)> dest) const;
};
class BufrImporter : public WRImporter
{
public:
BufrImporter(const Options& opts=Options());
virtual ~BufrImporter();
bool foreach_decoded(const BinaryMessage& msg, std::function<bool(std::unique_ptr<Message>&&)> dest) const override;
};
class CrexImporter : public WRImporter
{
public:
CrexImporter(const Options& opts=Options());
virtual ~CrexImporter();
bool foreach_decoded(const BinaryMessage& msg, std::function<bool(std::unique_ptr<Message>&&)> dest) const override;
};
namespace wr {
class Template;
}
class WRExporter : public Exporter
{
public:
WRExporter(const Options& opts);
/**
* Import a decoded BUFR/CREX message
*/
std::unique_ptr<wreport::Bulletin> to_bulletin(const Messages& msgs) const override;
/**
* Infer a template name from the message contents
*/
std::unique_ptr<wr::Template> infer_template(const Messages& msgs) const;
};
class BufrExporter : public WRExporter
{
public:
BufrExporter(const Options& opts=Options());
virtual ~BufrExporter();
virtual std::string to_binary(const Messages& msgs) const;
virtual std::unique_ptr<wreport::Bulletin> make_bulletin() const;
};
class CrexExporter : public WRExporter
{
public:
CrexExporter(const Options& opts=Options());
virtual ~CrexExporter();
virtual std::string to_binary(const Messages& msgs) const;
virtual std::unique_ptr<wreport::Bulletin> make_bulletin() const;
};
namespace wr {
struct TemplateRegistry;
class Template
{
protected:
virtual void setupBulletin(wreport::Bulletin& bulletin);
virtual void to_subset(const Msg& msg, wreport::Subset& subset);
void add(wreport::Varcode code, const msg::Context* ctx, int shortcut) const;
void add(wreport::Varcode code, const msg::Context* ctx, wreport::Varcode srccode) const;
void add(wreport::Varcode code, const msg::Context* ctx) const;
void add(wreport::Varcode code, int shortcut) const;
void add(wreport::Varcode code, wreport::Varcode srccode, const Level& level, const Trange& trange) const;
void add(wreport::Varcode code, const wreport::Var* var) const;
// Set station name, truncating it if it's too long
void do_station_name(wreport::Varcode dstcode) const;
/// Find a variable in c_station, or nullptr if not found
const wreport::Var* find_station_var(wreport::Varcode code) const;
void do_ecmwf_past_wtr() const;
void do_station_height() const;
// WMO block and station numbers
void do_D01001() const;
void do_D01004() const;
// Date (year, month, day)
void do_D01011() const;
// Time (hour and minute), return the hour
int do_D01012() const;
// Time (hour, minute, second)
void do_D01013() const;
// Latitude and longitude, high accuracy
void do_D01021() const;
void do_D01022() const;
// Latitude and longitude, coarse accuracy
void do_D01023() const;
public:
const Exporter::Options& opts;
const Messages& msgs;
const Msg* msg = 0; // Msg being read
const msg::Context* c_station = 0;
const msg::Context* c_gnd_instant = 0;
wreport::Subset* subset = 0; // Subset being written
Template(const Exporter::Options& opts, const Messages& msgs)
: opts(opts), msgs(msgs) {}
virtual ~Template() {}
virtual const char* name() const = 0;
virtual const char* description() const = 0;
virtual void to_bulletin(wreport::Bulletin& bulletin);
};
struct TemplateFactory
{
typedef std::function<std::unique_ptr<Template>(const Exporter::Options& opts, const Messages& msgs)> factory_func;
unsigned data_category = MISSING_INT;
std::string name;
std::string description;
factory_func factory;
TemplateFactory(unsigned data_category, std::string name, std::string description, factory_func factory)
: data_category(data_category), name(name), description(description), factory(factory) {}
};
struct TemplateRegistry : public std::map<std::string, TemplateFactory>
{
static const TemplateRegistry& get();
static const TemplateFactory& get(const std::string& name);
void register_factory(
unsigned data_category,
const std::string& name,
const std::string& desc,
TemplateFactory::factory_func fac);
};
}
}
}
#endif
|