[
https://issues.apache.org/jira/browse/AVRO-3735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710279#comment-17710279
]
Martin Tzvetanov Grigorov commented on AVRO-3735:
-------------------------------------------------
I've added the code snippets as a test case -
[https://github.com/apache/avro/pull/2184]
The test passes!
Most probably it has been fixed since 0.14, but if you see a problem in the
test case then please comment on the PR!
> [Rust] Validation fails for
> ----------------------------
>
> Key: AVRO-3735
> URL: https://issues.apache.org/jira/browse/AVRO-3735
> Project: Apache Avro
> Issue Type: Bug
> Components: rust
> Reporter: Matthew Cargille
> Assignee: Martin Tzvetanov Grigorov
> Priority: Major
> Labels: pull-request-available, rust
> Attachments: avro_example.zip
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> Schema validation fails when referencing a previously defined type which has
> inherited a namespace.
>
> Schema:
>
> {code:java}
> {
> "type": "record",
> "name": "Foo",
> "namespace": "name.space",
> "fields":
> [
> {
> "name": "barInit",
> "type":
> {
> "type": "enum",
> "name": "Bar",
> "symbols":
> [
> "bar0",
> "bar1"
> ]
> }
> },
> {
> "name": "barUse",
> "type": "Bar"
> }
> ]
> } {code}
>
>
> Rust Objects (from rsgen)
>
> {code:java}
> #[derive(Debug, PartialEq, Eq, Hash, PartialOrd, Ord, Clone,
> serde::Deserialize, serde::Serialize,)]
> pub enum Bar {
> #[serde(rename = "bar0")]
> Bar0,
> #[serde(rename = "bar1")]
> Bar1,
> }
> #[derive(Debug, PartialEq, Eq, Clone, serde::Deserialize, serde::Serialize)]
> pub struct Foo {
> #[serde(rename = "barInit")]
> pub bar_init: Bar,
> #[serde(rename = "barUse")]
> pub bar_use: Bar,
> }
> {code}
>
>
> Test
>
> {code:java}
> #[test]
> fn test_serialize() {
> testing_logger::setup();
> let schema = Schema::parse_str(&get_raw_example_schema()).unwrap();
> let foo = Foo {
> bar_init: Bar::Bar0,
> bar_use: Bar::Bar1,
> };
> let avro_value = to_value(foo).unwrap();
> println!(
> "value is valid for schema: {}",
> avro_value.validate(&schema)
> );
> testing_logger::validate(|logs| {
> for log in logs {
> println!("{}", log.body)
> }
> });
> let mut writer = Writer::new(&schema, Vec::new());
> // schema validation happens here
> writer.append(avro_value).unwrap();
> } {code}
>
>
> Test & Log Output
>
> {code:java}
> value is valid for schema: false
> Invalid value: Record([("barInit", Enum(0, "bar0")), ("barUse", Enum(1,
> "bar1"))]) for schema: Record { name: Name { name: "Foo", namespace:
> Some("name.space") }, aliases: None, doc: None, fields: [RecordField { name:
> "barInit", doc: None, default: None, schema: Enum { name: Name { name: "Bar",
> namespace: None }, aliases: None, doc: None, symbols: ["bar0", "bar1"] },
> order: Ascending, position: 0 }, RecordField { name: "barUse", doc: None,
> default: None, schema: Ref { name: Name { name: "Bar", namespace: None } },
> order: Ascending, position: 1 }], lookup: {"barInit": 0, "barUse": 1} }.
> Reason: Unresolved schema reference: 'Bar'. Parsed names: [Name { name:
> "Bar", namespace: Some("name.space") }, Name { name: "Foo", namespace:
> Some("name.space") }]
> thread 'test::test_serialize' panicked at 'called `Result::unwrap()` on an
> `Err` value: ValidationWithReason("Unresolved schema reference: 'Bar'. Parsed
> names: [Name { name: \"Foo\", namespace: Some(\"name.space\") }, Name { name:
> \"Bar\", namespace: Some(\"name.space\") }]")', src/main.rs:33:35 {code}
>
> full test repo is attached
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
