tpack 0.1.0

Std facade, registry integration, and optional serde support for TPACK
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

use tpack::{
    EncodeOptions, Encoder, EnvelopeMode, ErrorKind, Field, Limits, Schema, TpackValue,
    TypeDescriptor, encode_schema,
};

fn oversized_schema() -> Schema {
    Schema::new(TypeDescriptor::Struct(vec![Field::new(
        1,
        "schema_name",
        TypeDescriptor::Null,
    )]))
}

#[test]
fn encoder_rejects_schema_bytes_over_max_schema_len() {
    let schema = oversized_schema();
    let schema_len = encode_schema(&schema).expect("encode schema").len();
    let options = EncodeOptions {
        limits: Limits {
            max_schema_len: schema_len - 1,
            ..Limits::default()
        },
        ..EncodeOptions::default()
    };

    let mut schema_encoder = Encoder::with_options(options);
    assert!(matches!(
        schema_encoder.encode_schema(&schema).unwrap_err().kind(),
        ErrorKind::SchemaLengthExceeded
    ));

    let value = TpackValue::Struct(vec![(1, TpackValue::Null)]);
    let mut message_encoder = Encoder::with_options(options);
    assert!(matches!(
        message_encoder
            .encode_message(&schema, &value, EnvelopeMode::FullSchema, None)
            .unwrap_err()
            .kind(),
        ErrorKind::SchemaLengthExceeded
    ));
}