tinybufr 0.1.3

A decoder for BUFR meteorological data format
Documentation 
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

use std::fs;
use std::io::{BufRead, BufReader};

use tinybufr::tables::local::jma::{JMA_DATA_DESCRIPTORS, JMA_SEQUENCE_DESCRIPTORS};
use tinybufr::*;

mod common;

#[test]
fn test_amedas() {
    read_example(
        "./tests/testdata/jma/Z__C_RJTD_20210918110000_OBS_AMDS_Rjp_N2_bufr4.bin",
        false,
    );
    read_example(
        "./tests/testdata/jma/Z__C_RJTD_20210918110000_OBS_AMDSRR_Rjp_N1_bufr4.bin",
        false,
    );
}

#[test]
fn test_wind_profiler() {
    read_example(
        "./tests/testdata/jma/Z__C_RJTD_20200728040000_WPR_SEQ_RS-all_Pww_bufr4.bin",
        false,
    );
}

#[test]
fn test_ryuikishisu() {
    read_example(
        "./tests/testdata/jma/Z__C_RJTD_20230815070000_MET_SEQ_Ggis1km_Proi_Aper10min_RJsuikei830_ANAL_bufr4.bin",
        false,
    );
    read_example(
        "./tests/testdata/jma/Z__C_RJTD_20230815070000_MET_SEQ_Ggis1km_Proi_Fper10min_RJsuikei811_FH0010-0100_bufr4.bin",
        false,
    );
}

#[test]
fn test_istc62() {
    read_example(
        "./tests/testdata/jma/ISTC62_RJTD_310000_201707310002140_001_93839.bin",
        true,
    );
}

#[test]
fn test_istc82() {
    read_example("./tests/testdata/jma/ISTC82.dat", true);
}

#[test]
fn test_ixac41() {
    read_example(
        "./tests/testdata/jma/201806180758.20230110141530_520.BUFR",
        false,
    );
}

fn read_example(filename: &str, skip_first_line: bool) {
    // Extend the default tables with JMA local descriptors
    let mut tables = Tables::default();
    for desc in &JMA_DATA_DESCRIPTORS {
        tables.table_b.insert(desc.xy, desc);
    }
    for seq in &JMA_SEQUENCE_DESCRIPTORS {
        tables.table_d.insert(seq.xy, seq);
    }

    let file = fs::File::open(filename).unwrap();
    let mut reader = BufReader::new(file);
    if skip_first_line {
        // Some files have a first line that is not part of the BUFR message
        let mut buf = String::new();
        reader.read_line(&mut buf).unwrap();
    }

    common::test_full_read(reader, &tables);
}