Added readers and writers for the asyncapiAPI based on newtonsoft

Author: Eamonn Moloney

.gitignore

@@ -348,3 +348,9 @@ MigrationBackup/
 
 # Ionide (cross platform F# VS Code tools) working folder
 .ionide/
+
+# MacOS
+**/.DS_Store
+
+# Jetbrains
+**/.idea

AsyncAPI.sln

@@ -0,0 +1,29 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 16
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "LEGO.AsyncAPI.Tests", "test\LEGO.AsyncAPI.Tests\LEGO.AsyncAPI.Tests.csproj", "{32C4357C-F664-4C6C-B87B-AEF1759EC060}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "LEGO.AsyncAPI", "src\LEGO.AsyncAPI\LEGO.AsyncAPI.csproj", "{D4559946-300D-4C6F-B92B-4376414D19C9}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "LEGO.AsyncAPI.E2E.Tests", "test\LEGO.AsyncAPI.E2E.Tests\LEGO.AsyncAPI.E2E.Tests.csproj", "{85E0F568-3B0C-4253-A03B-83578865A788}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{32C4357C-F664-4C6C-B87B-AEF1759EC060}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{32C4357C-F664-4C6C-B87B-AEF1759EC060}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{32C4357C-F664-4C6C-B87B-AEF1759EC060}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{32C4357C-F664-4C6C-B87B-AEF1759EC060}.Release|Any CPU.Build.0 = Release|Any CPU
+		{D4559946-300D-4C6F-B92B-4376414D19C9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{D4559946-300D-4C6F-B92B-4376414D19C9}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{D4559946-300D-4C6F-B92B-4376414D19C9}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{D4559946-300D-4C6F-B92B-4376414D19C9}.Release|Any CPU.Build.0 = Release|Any CPU
+		{85E0F568-3B0C-4253-A03B-83578865A788}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{85E0F568-3B0C-4253-A03B-83578865A788}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{85E0F568-3B0C-4253-A03B-83578865A788}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{85E0F568-3B0C-4253-A03B-83578865A788}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+EndGlobal

src/LEGO.AsyncAPI.sln

@@ -0,0 +1,14 @@
+using LEGO.AsyncAPI.Any;
+using LEGO.AsyncAPI.Models;
+using Newtonsoft.Json;
+
+namespace LEGO.AsyncAPI
+{
+    public class AsyncApiReaderNewtonJson<T>: IReader<T>
+    {
+        public T Consume(Stream stream)
+        {
+            return JsonConvert.DeserializeObject<T>(new StreamReader(stream).ReadToEnd(), new PayloadConverter());
+        }
+    }
+}

src/LEGO.AsyncAPI/AsyncAPIReaderNewtonJson.cs

@@ -0,0 +1,17 @@
+using Newtonsoft.Json;
+
+namespace LEGO.AsyncAPI
+{
+    public class AsyncApiWriter<T>
+    {
+        public string Produce(T asyncApiDocument)
+        {
+            JsonSerializerSettings jsonSerializerSettings = new JsonSerializerSettings
+            {
+                NullValueHandling = NullValueHandling.Ignore,
+                Formatting = Formatting.Indented,
+            };
+            return JsonConvert.SerializeObject(asyncApiDocument, jsonSerializerSettings);
+        }
+    }
+}

src/LEGO.AsyncAPI/AsyncAPIWriter.cs

@@ -0,0 +1,32 @@
+using System.Text.Json;
+using Json.Schema;
+using LEGO.AsyncAPI.Any;
+using LEGO.AsyncAPI.Models;
+using Newtonsoft.Json;
+
+namespace LEGO.AsyncAPI
+{
+    public class AsyncApiSchemaValidator
+    {
+        private const string SampleFolderPath = "";
+
+        public async Task<ValidationResults> Validate(JsonDocument jsonDocument)
+        {
+            var type = typeof(AsyncApiSchemaValidator);
+            var schemaPath = type.Namespace + "." +
+                             Path.Combine(SampleFolderPath, "schema-v2.3.0.json").Replace("/", ".");
+            Stream schemaStream = type.Assembly.GetManifestResourceStream(schemaPath);
+
+            var schema = JsonSchema.FromText(new StreamReader(schemaStream).ReadToEnd());
+
+
+            var json = jsonDocument;
+
+            var options = new ValidationOptions();
+            options.DefaultBaseUri =
+                new Uri("https://raw.githubusercontent.com/asyncapi/spec-json-schemas/master/schemas/2.3.0.json");
+            var result = schema.Validate(json.RootElement, options);
+            return result;
+        }
+    }
+}

src/LEGO.AsyncAPI/AsyncApiSchemaValidator.cs

@@ -0,0 +1,7 @@
+namespace LEGO.AsyncAPI
+{
+    public interface IReader<T>
+    {
+        public T Consume(Stream jsonDocument);
+    }
+}

src/LEGO.AsyncAPI/IReader.cs

@@ -18,11 +18,17 @@
   </ItemGroup>
 
   <ItemGroup>
+    <PackageReference Include="JsonSchema.Net" Version="2.0.1" />
+    <PackageReference Include="Newtonsoft.Json" Version="9.0.1" />
     <PackageReference Include="SharpYaml" Version="1.8.0" />
     <PackageReference Include="StyleCop.Analyzers" Version="1.1.118">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>
   </ItemGroup>
 
+  <ItemGroup>
+    <EmbeddedResource Include="schema-v2.3.0.json" />
+  </ItemGroup>
+
 </Project>

src/LEGO.AsyncAPI/LEGO.AsyncAPI.csproj

@@ -26,5 +26,10 @@ public enum AnyType
         /// Object.
         /// </summary>
         Object,
+        
+        /// <summary>
+        /// Undefined
+        /// </summary>
+        Undefined
     }
 }

src/LEGO.AsyncAPI/Models/Any/AnyType.cs

@@ -11,5 +11,7 @@ public class Array : List<IAny>, IAny
         /// The type of <see cref="IOpenApiAny"/>.
         /// </summary>
         public AnyType AnyType { get; } = AnyType.Array;
+        
+        public List<IAny> Value { get; set; }
     }
 }