/* SPDX-License-Identifier: Apache-2.0
*
* The OpenSearch Contributors require contributions made to
* this file be licensed under the Apache-2.0 license or a
* compatible open source license.
*/
/*
* Modifications Copyright OpenSearch Contributors. See
* GitHub history for details.
*
*  Licensed to Elasticsearch B.V. under one or more contributor
*  license agreements. See the NOTICE file distributed with
*  this work for additional information regarding copyright
*  ownership. Elasticsearch B.V. 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
*
* 	http://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.
*/

#region Utf8Json License https://github.com/neuecc/Utf8Json/blob/master/LICENSE
// MIT License
//
// Copyright (c) 2017 Yoshifumi Kawai
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in all
// copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
// SOFTWARE.
#endregion

using System;
using System.Linq;
using System.Reflection;
using System.Reflection.Emit;
using OpenSearch.Net.Utf8Json.Internal.Emit;

namespace OpenSearch.Net.Utf8Json.Resolvers
{
	internal static class ResolverConfig
	{
		// this needs to be determined `dynamically` at compile time
		// because we rewrite namespaces and published versioned packages
		public static readonly string Namespace = string.Join(".", typeof(ResolverConfig).Namespace.Split('.').Take(2));
	}

	internal sealed class CompositeResolver : IJsonFormatterResolver
	{
		public static readonly CompositeResolver Instance = new CompositeResolver();

		private static bool _isFrozen;
		private static IJsonFormatter[] _formatters = new IJsonFormatter[0];
		private static IJsonFormatterResolver[] _resolvers = new IJsonFormatterResolver[0];

		private CompositeResolver()
		{
		}

		public static void Register(params IJsonFormatterResolver[] resolvers)
		{
			if (_isFrozen)
				throw new InvalidOperationException("Register must call on startup(before use GetFormatter<T>).");

			_resolvers = resolvers;
		}

		public static void Register(params IJsonFormatter[] formatters)
		{
			if (_isFrozen)
			{
				throw new InvalidOperationException("Register must call on startup(before use GetFormatter<T>).");
			}

			_formatters = formatters;
		}

		public static void Register(IJsonFormatter[] formatters, IJsonFormatterResolver[] resolvers)
		{
			if (_isFrozen)
			{
				throw new InvalidOperationException("Register must call on startup(before use GetFormatter<T>).");
			}

			_resolvers = resolvers;
			_formatters = formatters;
		}

		public static void RegisterAndSetAsDefault(params IJsonFormatterResolver[] resolvers)
		{
			Register(resolvers);
			JsonSerializer.SetDefaultResolver(CompositeResolver.Instance);
		}

		public static void RegisterAndSetAsDefault(params IJsonFormatter[] formatters)
		{
			Register(formatters);
			JsonSerializer.SetDefaultResolver(CompositeResolver.Instance);
		}

		public static void RegisterAndSetAsDefault(IJsonFormatter[] formatters, IJsonFormatterResolver[] resolvers)
		{
			Register(formatters);
			Register(resolvers);
			JsonSerializer.SetDefaultResolver(CompositeResolver.Instance);
		}

		public static IJsonFormatterResolver Create(params IJsonFormatter[] formatters) =>
			Create(formatters, new IJsonFormatterResolver[0]);

		public static IJsonFormatterResolver Create(params IJsonFormatterResolver[] resolvers) =>
			Create(new IJsonFormatter[0], resolvers);

		public static IJsonFormatterResolver Create(IJsonFormatter[] formatters, IJsonFormatterResolver[] resolvers) =>
			DynamicCompositeResolver.Create(formatters, resolvers);

		public IJsonFormatter<T> GetFormatter<T>() => FormatterCache<T>.formatter;

		private static class FormatterCache<T>
		{
			public static readonly IJsonFormatter<T> formatter;

			static FormatterCache()
			{
				_isFrozen = true;

				foreach (var item in _formatters)
				{
					foreach (var implInterface in item.GetType().GetInterfaces())
					{
						if (implInterface.IsGenericType && implInterface.GenericTypeArguments[0] == typeof(T))
						{
							formatter = (IJsonFormatter<T>)item;
							return;
						}
					}
				}

				foreach (var item in _resolvers)
				{
					var f = item.GetFormatter<T>();
					if (f != null)
					{
						formatter = f;
						return;
					}
				}
			}
		}
	}

	internal abstract class DynamicCompositeResolver : IJsonFormatterResolver
	{
		private static readonly string ModuleName =  $"{ResolverConfig.Namespace}.DynamicCompositeResolver";

		private static readonly DynamicAssembly Assembly;

		static DynamicCompositeResolver() => Assembly = new DynamicAssembly(ModuleName);

		public static IJsonFormatterResolver Create(IJsonFormatter[] formatters, IJsonFormatterResolver[] resolvers)
		{
			var id = Guid.NewGuid().ToString().Replace("-", "");
			var resolverType = Assembly.DefineType("DynamicCompositeResolver_" + id, TypeAttributes.Class | TypeAttributes.NotPublic | TypeAttributes.Sealed, typeof(DynamicCompositeResolver));
			var cacheType = Assembly.DefineType("DynamicCompositeResolverCache_" + id, TypeAttributes.Class | TypeAttributes.NotPublic | TypeAttributes.Sealed);
			var genericP = cacheType.DefineGenericParameters("T")[0];

			const string fieldName = "instance";
			const string formatter = "formatter";

			var resolverInstanceField = resolverType.DefineField(fieldName, resolverType, FieldAttributes.Public | FieldAttributes.Static);

			var f = cacheType.DefineField(formatter, typeof(IJsonFormatter<>).MakeGenericType(genericP), FieldAttributes.Static | FieldAttributes.Public);
			{
				var cctor = cacheType.DefineConstructor(MethodAttributes.Static, CallingConventions.Standard, Type.EmptyTypes);
				var il = cctor.GetILGenerator();
				il.EmitLdsfld(resolverInstanceField);
				il.EmitCall(typeof(DynamicCompositeResolver).GetMethod(nameof(GetFormatterLoop)).MakeGenericMethod(genericP));
				il.Emit(OpCodes.Stsfld, f);
				il.Emit(OpCodes.Ret);
			}
			var cacheTypeT = cacheType.CreateTypeInfo().AsType();

			{
				var ctor = resolverType.DefineConstructor(MethodAttributes.Public, CallingConventions.Standard, new[] { typeof(IJsonFormatter[]), typeof(IJsonFormatterResolver[]) });
				var il = ctor.GetILGenerator();
				il.EmitLdarg(0);
				il.EmitLdarg(1);
				il.EmitLdarg(2);
				il.Emit(OpCodes.Call, typeof(DynamicCompositeResolver).GetConstructors()[0]);
				il.Emit(OpCodes.Ret);
			}
			{
				var m = resolverType.DefineMethod(nameof(GetFormatter), MethodAttributes.Public | MethodAttributes.Virtual);

				var gpp = m.DefineGenericParameters("T")[0];
				m.SetReturnType(typeof(IJsonFormatter<>).MakeGenericType(gpp));

				var il = m.GetILGenerator();
				var formatterField = TypeBuilder.GetField(cacheTypeT.MakeGenericType(gpp), cacheTypeT.GetField(formatter, BindingFlags.Public | BindingFlags.Static | BindingFlags.GetField));
				il.EmitLdsfld(formatterField);
				il.Emit(OpCodes.Ret);
			}

			var resolverT = resolverType.CreateTypeInfo().AsType();
			var instance = Activator.CreateInstance(resolverT, new object[] { formatters, resolvers });
			var finfo = instance.GetType().GetField(fieldName, BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Static);
			finfo.SetValue(null, instance);

			return (IJsonFormatterResolver)instance;
		}

		private readonly IJsonFormatter[] _formatters;
		private readonly IJsonFormatterResolver[] _resolvers;

		public DynamicCompositeResolver(IJsonFormatter[] formatters, IJsonFormatterResolver[] resolvers)
		{
			_formatters = formatters;
			_resolvers = resolvers;
		}

		public IJsonFormatter<T> GetFormatterLoop<T>()
		{
			foreach (var item in _formatters)
			{
				foreach (var implInterface in item.GetType().GetInterfaces())
				{
					if (implInterface.IsGenericType && implInterface.GenericTypeArguments[0] == typeof(T))
						return (IJsonFormatter<T>)item;
				}
			}

			foreach (var item in _resolvers)
			{
				var f = item.GetFormatter<T>();
				if (f != null)
					return f;
			}

			return null;
		}

		public abstract IJsonFormatter<T> GetFormatter<T>();
	}
}