tabnas-render 0.2.4

Renderers for the tabnas transducer protocols: incremental CSV and JSON text from streamed tables and events.
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

// test/spec/records.tsv: `TableRows/1` events and a missing policy in,
// through `RecordsToJson` and a compact `JsonRenderer`, the exact JSON
// text out, or the code of the first failure.

mod common;

use serde_json::Value as Json;
use tabnas_render::{JsonOptions, JsonRenderer, MissingRecord, RecordsToJson, StringOut};
use tabnas_support::{Row, Runner, Value};

use common::{expected_text, failure, feed_table, field, json_column, known_fields, malformed};

fn missing(row: &Row) -> MissingRecord {
    let json = json_column(row, "options", "{}");
    known_fields(row, &json, &["missing"]);
    match field(row, &json, "missing").map(Json::as_str) {
        None | Some(Some("skip")) => MissingRecord::Skip,
        Some(Some("null")) => MissingRecord::Null,
        Some(Some("error")) => MissingRecord::Error,
        Some(other) => malformed(row, format!("missing {other:?}")),
    }
}

#[test]
fn records() {
    Runner::new_with_row(|_input, row| {
        let events = common::table_events(row, &json_column(row, "events", ""));
        let renderer = JsonRenderer::new(StringOut::new(), JsonOptions::default());
        let mut records = RecordsToJson::new(renderer).with_missing(missing(row));
        feed_table(&mut records, &events).map_err(|f| failure(&f))?;
        Ok(Value::String(
            records.into_inner().into_inner().into_string(),
        ))
    })
    .input("events")
    .expected("expected")
    .parse_expected(expected_text)
    .file(common::spec("records.tsv"));
}