From 995b8b58aa8c890c9181ae479e12a4facfa05a25 Mon Sep 17 00:00:00 2001 From: shedaniel Date: Thu, 25 Mar 2021 03:55:36 +0800 Subject: Relocate most of the internal classes to match the api Signed-off-by: shedaniel --- .../me/shedaniel/rei/impl/PluginManagerImpl.java | 213 --------------------- 1 file changed, 213 deletions(-) delete mode 100644 runtime/src/main/java/me/shedaniel/rei/impl/PluginManagerImpl.java (limited to 'runtime/src/main/java/me/shedaniel/rei/impl/PluginManagerImpl.java') diff --git a/runtime/src/main/java/me/shedaniel/rei/impl/PluginManagerImpl.java b/runtime/src/main/java/me/shedaniel/rei/impl/PluginManagerImpl.java deleted file mode 100644 index baf2a5a3a..000000000 --- a/runtime/src/main/java/me/shedaniel/rei/impl/PluginManagerImpl.java +++ /dev/null @@ -1,213 +0,0 @@ -/* - * This file is licensed under the MIT License, part of Roughly Enough Items. - * Copyright (c) 2018, 2019, 2020 shedaniel - * - * 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. - */ - -package me.shedaniel.rei.impl; - -import com.google.common.base.MoreObjects; -import com.google.common.base.Stopwatch; -import com.google.common.collect.FluentIterable; -import com.google.common.collect.Iterables; -import me.shedaniel.rei.RoughlyEnoughItemsCore; -import me.shedaniel.rei.api.client.registry.category.CategoryRegistry; -import me.shedaniel.rei.api.client.registry.display.DisplayCategory; -import me.shedaniel.rei.api.client.registry.display.DisplayRegistry; -import me.shedaniel.rei.api.client.registry.entry.EntryRegistry; -import me.shedaniel.rei.api.client.registry.screen.ScreenRegistry; -import me.shedaniel.rei.api.common.plugins.PluginManager; -import me.shedaniel.rei.api.common.plugins.PluginView; -import me.shedaniel.rei.api.common.plugins.REIPlugin; -import me.shedaniel.rei.api.common.plugins.REIPluginProvider; -import me.shedaniel.rei.api.common.registry.Reloadable; -import me.shedaniel.rei.api.common.util.CollectionUtils; -import net.fabricmc.api.EnvType; -import net.fabricmc.api.Environment; -import net.minecraft.Util; -import net.minecraft.network.chat.Component; -import org.apache.commons.lang3.tuple.MutablePair; -import org.jetbrains.annotations.ApiStatus; - -import java.io.Closeable; -import java.util.*; -import java.util.concurrent.ConcurrentHashMap; -import java.util.function.Consumer; -import java.util.function.UnaryOperator; -import java.util.stream.Collectors; - -@ApiStatus.Internal -@Environment(EnvType.CLIENT) -public class PluginManagerImpl

> implements PluginManager

, PluginView

{ - private final List> reloadables = new ArrayList<>(); - private final Map>, Reloadable> cache = new ConcurrentHashMap<>(); - private final UnaryOperator> view; - private boolean arePluginsLoading = false; - private final List> plugins = new ArrayList<>(); - - @SafeVarargs - public PluginManagerImpl(UnaryOperator> view, Reloadable

... reloadables) { - this.view = view; - for (Reloadable

reloadable : reloadables) { - registerReloadable(reloadable); - } - } - - @Override - public void registerReloadable(Reloadable reloadable) { - this.reloadables.add((Reloadable

) reloadable); - } - - @Override - public boolean arePluginsReloading() { - return arePluginsLoading; - } - - @Override - public > T get(Class reloadableClass) { - Reloadable reloadable = this.cache.get(reloadableClass); - if (reloadable != null) return (T) reloadable; - - for (Reloadable

r : reloadables) { - if (reloadableClass.isInstance(r)) { - this.cache.put((Class>) reloadableClass, r); - return (T) r; - } - } - throw new IllegalArgumentException("Unknown reloadable type! " + reloadableClass.getName()); - } - - @Override - public List> getReloadables() { - return Collections.unmodifiableList(reloadables); - } - - @Override - public PluginView

view() { - return view.apply(this); - } - - @Override - public void registerPlugin(REIPluginProvider plugin) { - plugins.add((REIPluginProvider

) plugin); - RoughlyEnoughItemsCore.LOGGER.info("Registered plugin provider %s", plugin.getPluginProviderName()); - } - - @Override - public List> getPluginProviders() { - return Collections.unmodifiableList(plugins); - } - - @Override - public FluentIterable

getPlugins() { - return FluentIterable.concat(Iterables.transform(plugins, REIPluginProvider::provide)); - } - - private static class SectionClosable implements Closeable { - private MutablePair sectionData; - - public SectionClosable(MutablePair sectionData, String section) { - this.sectionData = sectionData; - sectionData.setRight(section); - RoughlyEnoughItemsCore.LOGGER.debug("Reloading Section: \"%s\"", section); - sectionData.getLeft().reset().start(); - } - - @Override - public void close() { - sectionData.getLeft().stop(); - String section = sectionData.getRight(); - RoughlyEnoughItemsCore.LOGGER.debug("Reloading Section: \"%s\" done in %s", section, sectionData.getLeft().toString()); - sectionData.getLeft().reset(); - } - } - - private SectionClosable section(MutablePair sectionData, String section) { - return new SectionClosable(sectionData, section); - } - - private void pluginSection(MutablePair sectionData, String sectionName, List

list, Consumer

consumer) { - for (P plugin : list) { - try (SectionClosable section = section(sectionData, sectionName + " for " + plugin.getPluginName())) { - consumer.accept(plugin); - } catch (Throwable throwable) { - RoughlyEnoughItemsCore.LOGGER.error(plugin.getPluginName() + " plugin failed to " + sectionName + "!", throwable); - } - } - } - - @Override - public void startReload() { - try { - long startTime = Util.getMillis(); - MutablePair sectionData = new MutablePair<>(Stopwatch.createUnstarted(), ""); - - try (SectionClosable startReload = section(sectionData, "start-reload")) { - for (Reloadable

reloadable : reloadables) { - reloadable.startReload(); - } - } - - arePluginsLoading = true; - List

plugins = new ArrayList<>(getPlugins().toList()); - plugins.sort(Comparator.comparingInt(P::getPriority).reversed()); - RoughlyEnoughItemsCore.LOGGER.info("Reloading REI, registered %d plugins: %s", plugins.size(), CollectionUtils.mapAndJoinToString(plugins, REIPlugin::getPluginName, ", ")); - Collections.reverse(plugins); - - pluginSection(sectionData, "pre-register", plugins, REIPlugin::preRegister); - for (Reloadable

reloadable : getReloadables()) { - Class reloadableClass = reloadable.getClass(); - pluginSection(sectionData, "reloadable-plugin-" + MoreObjects.firstNonNull(reloadableClass.getSimpleName(), reloadableClass.getName()), plugins, reloadable::acceptPlugin); - } - pluginSection(sectionData, "post-register", plugins, REIPlugin::postRegister); - - try (SectionClosable endReload = section(sectionData, "end-reload")) { - for (Reloadable

reloadable : reloadables) { - reloadable.endReload(); - } - } - - arePluginsLoading = false; - - try (SectionClosable refilter = section(sectionData, "entry-registry-refilter")) { - EntryRegistry.getInstance().refilter(); - } - - long usedTime = Util.getMillis() - startTime; - RoughlyEnoughItemsCore.LOGGER.info("Reloaded %d stack entries, %d displays, %d exclusion zones suppliers, %d overlay deciders, %d visibility predicates and %d categories (%s) in %dms.", - EntryRegistry.getInstance().size(), - DisplayRegistry.getInstance().getDisplayCount(), - ScreenRegistry.getInstance().exclusionZones().getZonesCount(), - ScreenRegistry.getInstance().getDeciders().size(), - DisplayRegistry.getInstance().getVisibilityPredicates().size(), - CategoryRegistry.getInstance().size(), - CategoryRegistry.getInstance().stream() - .map(CategoryRegistry.CategoryConfiguration::getCategory) - .map(DisplayCategory::getTitle) - .map(Component::getString).collect(Collectors.joining(", ")), - usedTime - ); - } catch (Throwable throwable) { - throwable.printStackTrace(); - } finally { - arePluginsLoading = false; - } - } -} -- cgit