JsonReferenceResolver
using Microsoft.Runtime.CompilerServices;
using NJsonSchema.Infrastructure;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
namespace NJsonSchema
{
public class JsonReferenceResolver
{
private readonly JsonSchemaResolver _schemaResolver;
private readonly Dictionary<string, JsonSchema4> _resolvedSchemas = new Dictionary<string, JsonSchema4>();
public JsonReferenceResolver(JsonSchemaResolver schemaResolver)
{
_schemaResolver = schemaResolver;
}
public void AddDocumentReference(string documentPath, JsonSchema4 schema)
{
_resolvedSchemas[documentPath] = schema;
}
public async Task<JsonSchema4> ResolveReferenceAsync(object rootObject, string jsonPath)
{
if (jsonPath == "#") {
if (rootObject is JsonSchema4)
return (JsonSchema4)rootObject;
throw new InvalidOperationException("Could not resolve the JSON path '#' because the root object is not a JsonSchema4.");
}
if (jsonPath.StartsWith("#/"))
return ResolveDocumentReference(rootObject, jsonPath);
ConfiguredTaskAwaitable<JsonSchema4> val;
ConfiguredTaskAwaiter val2;
if (jsonPath.StartsWith("http://") || jsonPath.StartsWith("https://")) {
val = AwaitExtensions.ConfigureAwait<JsonSchema4>(ResolveUrlReferenceWithAlreadyResolvedCheckAsync(jsonPath, jsonPath), false);
val2 = val.GetAwaiter();
if (!val2.get_IsCompleted()) {
await val2;
ConfiguredTaskAwaiter val3 = default(ConfiguredTaskAwaiter);
val2 = val3;
}
!0 result = val2.GetResult();
val2 = default(ConfiguredTaskAwaiter);
return (JsonSchema4)result;
}
string documentPath = (rootObject as IDocumentPathProvider)?.DocumentPath;
if (documentPath != null) {
if (documentPath.StartsWith("http://") || documentPath.StartsWith("https://")) {
val = AwaitExtensions.ConfigureAwait<JsonSchema4>(ResolveUrlReferenceWithAlreadyResolvedCheckAsync(new Uri(new Uri(documentPath), jsonPath).ToString(), jsonPath), false);
val2 = val.GetAwaiter();
if (!val2.get_IsCompleted()) {
await val2;
ConfiguredTaskAwaiter val3 = default(ConfiguredTaskAwaiter);
val2 = val3;
}
!0 result2 = val2.GetResult();
val2 = default(ConfiguredTaskAwaiter);
return (JsonSchema4)result2;
}
val = AwaitExtensions.ConfigureAwait<JsonSchema4>(ResolveFileReferenceWithAlreadyResolvedCheckAsync(DynamicApis.PathCombine(DynamicApis.PathGetDirectoryName(documentPath), jsonPath), jsonPath), false);
val2 = val.GetAwaiter();
if (!val2.get_IsCompleted()) {
await val2;
ConfiguredTaskAwaiter val3 = default(ConfiguredTaskAwaiter);
val2 = val3;
}
!0 result3 = val2.GetResult();
val2 = default(ConfiguredTaskAwaiter);
return (JsonSchema4)result3;
}
throw new NotSupportedException("Could not resolve the JSON path '" + jsonPath + "' because no document path is available.");
}
public virtual JsonSchema4 ResolveDocumentReference(object rootObject, string jsonPath)
{
List<string> segments = jsonPath.Split(new char[1] {
'/'
}).Skip(1).ToList();
JsonSchema4 jsonSchema = ResolveDocumentReference(rootObject, segments, new HashSet<object>());
if (jsonSchema == null)
throw new InvalidOperationException("Could not resolve the path '" + jsonPath + "'.");
return jsonSchema;
}
public virtual async Task<JsonSchema4> ResolveFileReferenceAsync(string filePath)
{
ConfiguredTaskAwaiter val = AwaitExtensions.ConfigureAwait<JsonSchema4>(JsonSchema4.FromFileAsync(filePath, (JsonSchema4 schema) => this), false).GetAwaiter();
if (!val.get_IsCompleted()) {
await val;
ConfiguredTaskAwaiter val2 = default(ConfiguredTaskAwaiter);
val = val2;
}
!0 result = val.GetResult();
val = default(ConfiguredTaskAwaiter);
return (JsonSchema4)result;
}
public virtual async Task<JsonSchema4> ResolveUrlReferenceAsync(string url)
{
ConfiguredTaskAwaiter val = AwaitExtensions.ConfigureAwait<JsonSchema4>(JsonSchema4.FromUrlAsync(url, (JsonSchema4 schema) => this), false).GetAwaiter();
if (!val.get_IsCompleted()) {
await val;
ConfiguredTaskAwaiter val2 = default(ConfiguredTaskAwaiter);
val = val2;
}
!0 result = val.GetResult();
val = default(ConfiguredTaskAwaiter);
return (JsonSchema4)result;
}
private async Task<JsonSchema4> ResolveFileReferenceWithAlreadyResolvedCheckAsync(string fullJsonPath, string jsonPath)
{
try {
string[] arr = Regex.Split(fullJsonPath, "(?=#)");
ConfiguredTaskAwaitable<JsonSchema4> val;
ConfiguredTaskAwaiter val2;
ConfiguredTaskAwaiter val3 = default(ConfiguredTaskAwaiter);
if (!_resolvedSchemas.ContainsKey(arr[0])) {
val = AwaitExtensions.ConfigureAwait<JsonSchema4>(ResolveFileReferenceAsync(arr[0]), false);
val2 = val.GetAwaiter();
if (!val2.get_IsCompleted()) {
await val2;
val2 = val3;
val3 = default(ConfiguredTaskAwaiter);
}
!0 result = val2.GetResult();
val2 = default(ConfiguredTaskAwaiter);
JsonSchema4 jsonSchema = (JsonSchema4)result;
_schemaResolver.AppendSchema(jsonSchema, null);
_resolvedSchemas[arr[0]] = jsonSchema;
}
JsonSchema4 jsonSchema2 = _resolvedSchemas[arr[0]];
JsonSchema4 result2;
if (arr.Length == 1)
result2 = jsonSchema2;
else {
val = AwaitExtensions.ConfigureAwait<JsonSchema4>(ResolveReferenceAsync(jsonSchema2, arr[1]), false);
val2 = val.GetAwaiter();
if (!val2.get_IsCompleted()) {
await val2;
val2 = val3;
}
!0 result3 = val2.GetResult();
val2 = default(ConfiguredTaskAwaiter);
result2 = (JsonSchema4)result3;
}
return result2;
} catch (Exception innerException) {
throw new InvalidOperationException("Could not resolve the JSON path '" + jsonPath + "' with the full JSON path '" + fullJsonPath + "'.", innerException);
}
}
private async Task<JsonSchema4> ResolveUrlReferenceWithAlreadyResolvedCheckAsync(string fullJsonPath, string jsonPath)
{
try {
string[] arr = fullJsonPath.Split(new char[1] {
'#'
});
ConfiguredTaskAwaitable<JsonSchema4> val;
ConfiguredTaskAwaiter val2;
ConfiguredTaskAwaiter val3 = default(ConfiguredTaskAwaiter);
if (!_resolvedSchemas.ContainsKey(arr[0])) {
val = AwaitExtensions.ConfigureAwait<JsonSchema4>(ResolveUrlReferenceAsync(arr[0]), false);
val2 = val.GetAwaiter();
if (!val2.get_IsCompleted()) {
await val2;
val2 = val3;
val3 = default(ConfiguredTaskAwaiter);
}
!0 result = val2.GetResult();
val2 = default(ConfiguredTaskAwaiter);
JsonSchema4 jsonSchema = (JsonSchema4)result;
_schemaResolver.AppendSchema(jsonSchema, null);
_resolvedSchemas[arr[0]] = jsonSchema;
}
JsonSchema4 jsonSchema2 = _resolvedSchemas[arr[0]];
JsonSchema4 result2;
if (arr.Length == 1)
result2 = jsonSchema2;
else {
val = AwaitExtensions.ConfigureAwait<JsonSchema4>(ResolveReferenceAsync(jsonSchema2, "#" + arr[1]), false);
val2 = val.GetAwaiter();
if (!val2.get_IsCompleted()) {
await val2;
val2 = val3;
}
!0 result3 = val2.GetResult();
val2 = default(ConfiguredTaskAwaiter);
result2 = (JsonSchema4)result3;
}
return result2;
} catch (Exception innerException) {
throw new InvalidOperationException("Could not resolve the JSON path '" + jsonPath + "' with the full JSON path '" + fullJsonPath + "'.", innerException);
}
}
private JsonSchema4 ResolveDocumentReference(object obj, List<string> segments, HashSet<object> checkedObjects)
{
if (obj == null || obj is string || checkedObjects.Contains(obj))
return null;
if (segments.Count == 0)
return obj as JsonSchema4;
checkedObjects.Add(obj);
string text = segments[0];
if (obj is IDictionary) {
if (((IDictionary)obj).Contains(text))
return ResolveDocumentReference(((IDictionary)obj)[text], segments.Skip(1).ToList(), checkedObjects);
} else if (obj is IEnumerable) {
if (int.TryParse(text, out int result)) {
object[] array = ((IEnumerable)obj).Cast<object>().ToArray();
if (array.Length > result)
return ResolveDocumentReference(array[result], segments.Skip(1).ToList(), checkedObjects);
}
} else {
foreach (ReflectionCache.PropertyOrField item in from p in ReflectionCache.GetPropertiesAndFields(obj.GetType())
where p.CustomAttributes.JsonIgnoreAttribute == null
select p) {
if (item.GetName() == text) {
object value = item.GetValue(obj);
return ResolveDocumentReference(value, segments.Skip(1).ToList(), checkedObjects);
}
}
}
return null;
}
}
}