blob: 1ddfb92350b0f6ac5a1f1589093fab5f92fefc45 [file] [log] [blame]
/**
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* https://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using Avro.IO;
using Avro.Reflect;
using NUnit.Framework;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Avro.test.Reflect
{
[TestFixture]
public class TestRecursive
{
private const string _recurse = @"
{
""type"": ""record"",
""namespace"": ""AvroSchemaGenerator.Tests"",
""name"": ""Recursive"",
""fields"": [
{
""name"": ""Fo"",
""type"": [
""null"",
{
""type"": ""record"",
""namespace"": ""AvroSchemaGenerator.Tests"",
""name"": ""SimpleFoo"",
""fields"": [
{
""name"": ""Age"",
""type"": ""int""
},
{
""name"": ""Name"",
""type"": ""string""
},
{
""name"": ""FactTime"",
""type"": ""long""
},
{
""name"": ""Point"",
""type"": ""double""
},
{
""name"": ""Precision"",
""type"": ""float""
},
{
""name"": ""Attending"",
""type"": ""boolean""
},
{
""name"": ""Id"",
""type"": [
""null"",
""bytes""
],
""default"": null
}
]
}
],
""default"": null
},
{
""name"": ""Recurse"",
""type"": [
""null"",
""Recursive""
],
""default"": null
}
]
}";
[TestCase]
public void RecurseTest()
{
var schema = Schema.Parse(_recurse);
var recursive = new Recursive
{
Fo = new SimpleFoo
{
Age = 67,
Attending = true,
FactTime = 90909099L,
Id = new byte[0] { },
Name = "Ebere",
Point = 888D,
Precision = 787F
},
Recurse = new Recursive
{
Fo = new SimpleFoo
{
Age = 6,
Attending = false,
FactTime = 90L,
Id = new byte[0] { },
Name = "Ebere Abanonu",
Point = 88D,
Precision = 78F
},
}
};
var writer = new ReflectWriter<Recursive>(schema);
var reader = new ReflectReader<Recursive>(schema, schema);
using (var stream = new MemoryStream(256))
{
writer.Write(recursive, new BinaryEncoder(stream));
stream.Seek(0, SeekOrigin.Begin);
var recursiveRead = reader.Read(new BinaryDecoder(stream));
Assert.IsTrue(recursiveRead.Fo.Attending);
Assert.AreEqual(recursiveRead.Recurse.Fo.Name, "Ebere Abanonu");
}
}
}
public class Recursive
{
public SimpleFoo Fo { get; set; }
public Recursive Recurse { get; set; }
}
public class SimpleFoo
{
public int Age { get; set; }
public string Name { get; set; }
public long FactTime { get; set; }
public double Point { get; set; }
public float Precision { get; set; }
public bool Attending { get; set; }
public byte[] Id { get; set; }
}
}