package net.minecraft.core;

import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableMap.Builder;
import com.mojang.serialization.DynamicOps;
import com.mojang.serialization.Lifecycle;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.Set;
import java.util.function.Supplier;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import net.minecraft.core.Cloner.Factory;
import net.minecraft.core.Holder.Reference;
import net.minecraft.core.Holder.Reference.Type;
import net.minecraft.core.HolderLookup.RegistryLookup.Delegate;
import net.minecraft.core.HolderSet.Named;
import net.minecraft.core.RegistrySetBuilder.3.1;
import net.minecraft.data.worldgen.BootstrapContext;
import net.minecraft.resources.RegistryOps;
import net.minecraft.resources.ResourceKey;
import net.minecraft.resources.ResourceLocation;
import net.minecraft.tags.TagKey;
import org.apache.commons.lang3.mutable.MutableObject;
import org.jetbrains.annotations.Nullable;

public class RegistrySetBuilder {
	private final List<RegistrySetBuilder.RegistryStub<?>> entries = new ArrayList();

	static <T> HolderGetter<T> wrapContextLookup(HolderLookup.RegistryLookup<T> owner) {
		return new RegistrySetBuilder.EmptyTagLookup<T>(owner) {
			@Override
			public Optional<Reference<T>> get(ResourceKey<T> resourceKey) {
				return owner.get(resourceKey);
			}
		};
	}

	static <T> HolderLookup.RegistryLookup<T> lookupFromMap(
		ResourceKey<? extends Registry<? extends T>> registryKey, Lifecycle registryLifecycle, HolderOwner<T> owner, Map<ResourceKey<T>, Reference<T>> elements
	) {
		return new RegistrySetBuilder.EmptyTagRegistryLookup<T>(owner) {
			@Override
			public ResourceKey<? extends Registry<? extends T>> key() {
				return registryKey;
			}

			@Override
			public Lifecycle registryLifecycle() {
				return registryLifecycle;
			}

			@Override
			public Optional<Reference<T>> get(ResourceKey<T> resourceKey) {
				return Optional.ofNullable((Reference)elements.get(resourceKey));
			}

			@Override
			public Stream<Reference<T>> listElements() {
				return elements.values().stream();
			}
		};
	}

	public <T> RegistrySetBuilder add(ResourceKey<? extends Registry<T>> key, Lifecycle lifecycle, RegistrySetBuilder.RegistryBootstrap<T> bootstrap) {
		this.entries.add(new RegistrySetBuilder.RegistryStub<>(key, lifecycle, bootstrap));
		return this;
	}

	public <T> RegistrySetBuilder add(ResourceKey<? extends Registry<T>> key, RegistrySetBuilder.RegistryBootstrap<T> bootstrap) {
		return this.add(key, Lifecycle.stable(), bootstrap);
	}

	private RegistrySetBuilder.BuildState createState(RegistryAccess registryAccess) {
		RegistrySetBuilder.BuildState buildState = RegistrySetBuilder.BuildState.create(
			registryAccess, this.entries.stream().map(RegistrySetBuilder.RegistryStub::key)
		);
		this.entries.forEach(registryStub -> registryStub.apply(buildState));
		return buildState;
	}

	private static HolderLookup.Provider buildProviderWithContext(
		RegistrySetBuilder.UniversalOwner owner, RegistryAccess registryAccess, Stream<HolderLookup.RegistryLookup<?>> lookups
	) {
		record Entry<T>(HolderLookup.RegistryLookup<T> lookup, RegistryOps.RegistryInfo<T> opsInfo) {
			public static <T> Entry<T> createForContextRegistry(HolderLookup.RegistryLookup<T> lookup) {
				return new Entry<>(new RegistrySetBuilder.EmptyTagLookupWrapper<>(lookup, lookup), RegistryOps.RegistryInfo.fromRegistryLookup(lookup));
			}

			public static <T> Entry<T> createForNewRegistry(RegistrySetBuilder.UniversalOwner owner, HolderLookup.RegistryLookup<T> lookup) {
				return new Entry<>(
					new RegistrySetBuilder.EmptyTagLookupWrapper<>(owner.cast(), lookup), new RegistryOps.RegistryInfo<>(owner.cast(), lookup, lookup.registryLifecycle())
				);
			}
		}

		final Map<ResourceKey<? extends Registry<?>>, Entry<?>> map = new HashMap();
		registryAccess.registries().forEach(registryEntry -> map.put(registryEntry.key(), Entry.createForContextRegistry(registryEntry.value())));
		lookups.forEach(registryLookup -> map.put(registryLookup.key(), Entry.createForNewRegistry(owner, registryLookup)));
		return new HolderLookup.Provider() {
			@Override
			public Stream<ResourceKey<? extends Registry<?>>> listRegistryKeys() {
				return map.keySet().stream();
			}

			<T> Optional<Entry<T>> getEntry(ResourceKey<? extends Registry<? extends T>> registryKey) {
				return Optional.ofNullable((Entry)map.get(registryKey));
			}

			@Override
			public <T> Optional<HolderLookup.RegistryLookup<T>> lookup(ResourceKey<? extends Registry<? extends T>> registryKey) {
				return this.getEntry(registryKey).map(Entry::lookup);
			}

			@Override
			public <V> RegistryOps<V> createSerializationContext(DynamicOps<V> ops) {
				return RegistryOps.create(ops, new 1(this));
			}
		};
	}

	public HolderLookup.Provider build(RegistryAccess registryAccess) {
		RegistrySetBuilder.BuildState buildState = this.createState(registryAccess);
		Stream<HolderLookup.RegistryLookup<?>> stream = this.entries
			.stream()
			.map(registryStub -> registryStub.collectRegisteredValues(buildState).buildAsLookup(buildState.owner));
		HolderLookup.Provider provider = buildProviderWithContext(buildState.owner, registryAccess, stream);
		buildState.reportNotCollectedHolders();
		buildState.reportUnclaimedRegisteredValues();
		buildState.throwOnError();
		return provider;
	}

	private HolderLookup.Provider createLazyFullPatchedRegistries(
		RegistryAccess registry,
		HolderLookup.Provider lookupProvider,
		Factory clonerFactory,
		Map<ResourceKey<? extends Registry<?>>, RegistrySetBuilder.RegistryContents<?>> registries,
		HolderLookup.Provider registryLookupProvider
	) {
		RegistrySetBuilder.UniversalOwner universalOwner = new RegistrySetBuilder.UniversalOwner();
		MutableObject<HolderLookup.Provider> mutableObject = new MutableObject<>();
		List<HolderLookup.RegistryLookup<?>> list = (List<HolderLookup.RegistryLookup<?>>)registries.keySet()
			.stream()
			.map(resourceKey -> this.createLazyFullPatchedRegistries(universalOwner, clonerFactory, resourceKey, registryLookupProvider, lookupProvider, mutableObject))
			.collect(Collectors.toUnmodifiableList());
		HolderLookup.Provider provider = buildProviderWithContext(universalOwner, registry, list.stream());
		mutableObject.setValue(provider);
		return provider;
	}

	private <T> HolderLookup.RegistryLookup<T> createLazyFullPatchedRegistries(
		HolderOwner<T> owner,
		Factory clonerFactory,
		ResourceKey<? extends Registry<? extends T>> registryKey,
		HolderLookup.Provider registryLookupProvider,
		HolderLookup.Provider lookupProvider,
		MutableObject<HolderLookup.Provider> object
	) {
		Cloner<T> cloner = clonerFactory.cloner(registryKey);
		if (cloner == null) {
			throw new NullPointerException("No cloner for " + registryKey.location());
		} else {
			Map<ResourceKey<T>, Reference<T>> map = new HashMap();
			HolderLookup.RegistryLookup<T> registryLookup = registryLookupProvider.lookupOrThrow(registryKey);
			registryLookup.listElements().forEach(reference -> {
				ResourceKey<T> resourceKey = reference.key();
				RegistrySetBuilder.LazyHolder<T> lazyHolder = new RegistrySetBuilder.LazyHolder<>(owner, resourceKey);
				lazyHolder.supplier = () -> cloner.clone((T)reference.value(), registryLookupProvider, object.getValue());
				map.put(resourceKey, lazyHolder);
			});
			HolderLookup.RegistryLookup<T> registryLookup2 = lookupProvider.lookupOrThrow(registryKey);
			registryLookup2.listElements().forEach(reference -> {
				ResourceKey<T> resourceKey = reference.key();
				map.computeIfAbsent(resourceKey, resourceKey2 -> {
					RegistrySetBuilder.LazyHolder<T> lazyHolder = new RegistrySetBuilder.LazyHolder<>(owner, resourceKey);
					lazyHolder.supplier = () -> cloner.clone((T)reference.value(), lookupProvider, object.getValue());
					return lazyHolder;
				});
			});
			Lifecycle lifecycle = registryLookup.registryLifecycle().add(registryLookup2.registryLifecycle());
			return lookupFromMap(registryKey, lifecycle, owner, map);
		}
	}

	public RegistrySetBuilder.PatchedRegistries buildPatch(RegistryAccess registryAccess, HolderLookup.Provider lookupProvider, Factory clonerFactory) {
		RegistrySetBuilder.BuildState buildState = this.createState(registryAccess);
		Map<ResourceKey<? extends Registry<?>>, RegistrySetBuilder.RegistryContents<?>> map = new HashMap();
		this.entries
			.stream()
			.map(registryStub -> registryStub.collectRegisteredValues(buildState))
			.forEach(registryContents -> map.put(registryContents.key, registryContents));
		Set<ResourceKey<? extends Registry<?>>> set = (Set<ResourceKey<? extends Registry<?>>>)registryAccess.listRegistryKeys()
			.collect(Collectors.toUnmodifiableSet());
		lookupProvider.listRegistryKeys()
			.filter(resourceKey -> !set.contains(resourceKey))
			.forEach(resourceKey -> map.putIfAbsent(resourceKey, new RegistrySetBuilder.RegistryContents(resourceKey, Lifecycle.stable(), Map.of())));
		Stream<HolderLookup.RegistryLookup<?>> stream = map.values().stream().map(registryContents -> registryContents.buildAsLookup(buildState.owner));
		HolderLookup.Provider provider = buildProviderWithContext(buildState.owner, registryAccess, stream);
		buildState.reportUnclaimedRegisteredValues();
		buildState.throwOnError();
		HolderLookup.Provider provider2 = this.createLazyFullPatchedRegistries(registryAccess, lookupProvider, clonerFactory, map, provider);
		return new RegistrySetBuilder.PatchedRegistries(provider2, provider);
	}

	record BuildState(
		RegistrySetBuilder.UniversalOwner owner,
		RegistrySetBuilder.UniversalLookup lookup,
		Map<ResourceLocation, HolderGetter<?>> registries,
		Map<ResourceKey<?>, RegistrySetBuilder.RegisteredValue<?>> registeredValues,
		List<RuntimeException> errors
	) {

		public static RegistrySetBuilder.BuildState create(RegistryAccess registryAccess, Stream<ResourceKey<? extends Registry<?>>> registries) {
			RegistrySetBuilder.UniversalOwner universalOwner = new RegistrySetBuilder.UniversalOwner();
			List<RuntimeException> list = new ArrayList();
			RegistrySetBuilder.UniversalLookup universalLookup = new RegistrySetBuilder.UniversalLookup(universalOwner);
			Builder<ResourceLocation, HolderGetter<?>> builder = ImmutableMap.builder();
			registryAccess.registries()
				.forEach(registryEntry -> builder.put(registryEntry.key().location(), RegistrySetBuilder.wrapContextLookup(registryEntry.value())));
			registries.forEach(resourceKey -> builder.put(resourceKey.location(), universalLookup));
			return new RegistrySetBuilder.BuildState(universalOwner, universalLookup, builder.build(), new HashMap(), list);
		}

		public <T> BootstrapContext<T> bootstrapContext() {
			return new net.minecraft.core.RegistrySetBuilder.BuildState.1(this);
		}

		public void reportUnclaimedRegisteredValues() {
			this.registeredValues
				.forEach((resourceKey, registeredValue) -> this.errors.add(new IllegalStateException("Orpaned value " + registeredValue.value + " for key " + resourceKey)));
		}

		public void reportNotCollectedHolders() {
			for (ResourceKey<Object> resourceKey : this.lookup.holders.keySet()) {
				this.errors.add(new IllegalStateException("Unreferenced key: " + resourceKey));
			}
		}

		public void throwOnError() {
			if (!this.errors.isEmpty()) {
				IllegalStateException illegalStateException = new IllegalStateException("Errors during registry creation");

				for (RuntimeException runtimeException : this.errors) {
					illegalStateException.addSuppressed(runtimeException);
				}

				throw illegalStateException;
			}
		}
	}

	abstract static class EmptyTagLookup<T> implements HolderGetter<T> {
		protected final HolderOwner<T> owner;

		protected EmptyTagLookup(HolderOwner<T> owner) {
			this.owner = owner;
		}

		@Override
		public Optional<Named<T>> get(TagKey<T> tagKey) {
			return Optional.of(HolderSet.emptyNamed(this.owner, tagKey));
		}
	}

	static class EmptyTagLookupWrapper<T> extends RegistrySetBuilder.EmptyTagRegistryLookup<T> implements Delegate<T> {
		private final HolderLookup.RegistryLookup<T> parent;

		EmptyTagLookupWrapper(HolderOwner<T> owner, HolderLookup.RegistryLookup<T> parent) {
			super(owner);
			this.parent = parent;
		}

		public HolderLookup.RegistryLookup<T> parent() {
			return this.parent;
		}
	}

	abstract static class EmptyTagRegistryLookup<T> extends RegistrySetBuilder.EmptyTagLookup<T> implements HolderLookup.RegistryLookup<T> {
		protected EmptyTagRegistryLookup(HolderOwner<T> holderOwner) {
			super(holderOwner);
		}

		@Override
		public Stream<Named<T>> listTags() {
			throw new UnsupportedOperationException("Tags are not available in datagen");
		}
	}

	static class LazyHolder<T> extends Reference<T> {
		@Nullable
		Supplier<T> supplier;

		protected LazyHolder(HolderOwner<T> owner, @Nullable ResourceKey<T> key) {
			super(Type.STAND_ALONE, owner, key, null);
		}

		@Override
		protected void bindValue(T value) {
			super.bindValue(value);
			this.supplier = null;
		}

		@Override
		public T value() {
			if (this.supplier != null) {
				this.bindValue((T)this.supplier.get());
			}

			return super.value();
		}
	}

	public record PatchedRegistries(HolderLookup.Provider full, HolderLookup.Provider patches) {
	}

	record RegisteredValue<T>(T value, Lifecycle lifecycle) {
	}

	@FunctionalInterface
	public interface RegistryBootstrap<T> {
		void run(BootstrapContext<T> bootstrapContext);
	}

	record RegistryContents<T>(
		ResourceKey<? extends Registry<? extends T>> key, Lifecycle lifecycle, Map<ResourceKey<T>, RegistrySetBuilder.ValueAndHolder<T>> values
	) {

		public HolderLookup.RegistryLookup<T> buildAsLookup(RegistrySetBuilder.UniversalOwner owner) {
			Map<ResourceKey<T>, Reference<T>> map = (Map<ResourceKey<T>, Reference<T>>)this.values
				.entrySet()
				.stream()
				.collect(Collectors.toUnmodifiableMap(java.util.Map.Entry::getKey, entry -> {
					RegistrySetBuilder.ValueAndHolder<T> valueAndHolder = (RegistrySetBuilder.ValueAndHolder<T>)entry.getValue();
					Reference<T> reference = (Reference<T>)valueAndHolder.holder().orElseGet(() -> Reference.createStandAlone(owner.cast(), (ResourceKey<T>)entry.getKey()));
					reference.bindValue(valueAndHolder.value().value());
					return reference;
				}));
			return RegistrySetBuilder.lookupFromMap(this.key, this.lifecycle, owner.cast(), map);
		}
	}

	record RegistryStub<T>(ResourceKey<? extends Registry<T>> key, Lifecycle lifecycle, RegistrySetBuilder.RegistryBootstrap<T> bootstrap) {
		void apply(RegistrySetBuilder.BuildState state) {
			this.bootstrap.run(state.bootstrapContext());
		}

		public RegistrySetBuilder.RegistryContents<T> collectRegisteredValues(RegistrySetBuilder.BuildState buildState) {
			Map<ResourceKey<T>, RegistrySetBuilder.ValueAndHolder<T>> map = new HashMap();
			Iterator<java.util.Map.Entry<ResourceKey<?>, RegistrySetBuilder.RegisteredValue<?>>> iterator = buildState.registeredValues.entrySet().iterator();

			while (iterator.hasNext()) {
				java.util.Map.Entry<ResourceKey<?>, RegistrySetBuilder.RegisteredValue<?>> entry = (java.util.Map.Entry<ResourceKey<?>, RegistrySetBuilder.RegisteredValue<?>>)iterator.next();
				ResourceKey<?> resourceKey = (ResourceKey<?>)entry.getKey();
				if (resourceKey.isFor(this.key)) {
					RegistrySetBuilder.RegisteredValue<T> registeredValue = (RegistrySetBuilder.RegisteredValue<T>)entry.getValue();
					Reference<T> reference = (Reference<T>)buildState.lookup.holders.remove(resourceKey);
					map.put(resourceKey, new RegistrySetBuilder.ValueAndHolder<>(registeredValue, Optional.ofNullable(reference)));
					iterator.remove();
				}
			}

			return new RegistrySetBuilder.RegistryContents<>(this.key, this.lifecycle, map);
		}
	}

	static class UniversalLookup extends RegistrySetBuilder.EmptyTagLookup<Object> {
		final Map<ResourceKey<Object>, Reference<Object>> holders = new HashMap();

		public UniversalLookup(HolderOwner<Object> holderOwner) {
			super(holderOwner);
		}

		@Override
		public Optional<Reference<Object>> get(ResourceKey<Object> resourceKey) {
			return Optional.of(this.getOrCreate(resourceKey));
		}

		<T> Reference<T> getOrCreate(ResourceKey<T> key) {
			return (Reference<T>)this.holders.computeIfAbsent(key, resourceKey -> Reference.createStandAlone(this.owner, resourceKey));
		}
	}

	static class UniversalOwner implements HolderOwner<Object> {
		public <T> HolderOwner<T> cast() {
			return this;
		}
	}

	record ValueAndHolder<T>(RegistrySetBuilder.RegisteredValue<T> value, Optional<Reference<T>> holder) {
	}
}