SimpleSkills.java

package dansplugins.simpleskills;

import dansplugins.simpleskills.bstats.Metrics;
import dansplugins.simpleskills.commands.*;
import dansplugins.simpleskills.commands.tab.TabCommand;
import dansplugins.simpleskills.listeners.PlayerJoinEventListener;
import dansplugins.simpleskills.playerrecord.PlayerRecordRepository;
import dansplugins.simpleskills.config.ConfigService;
import dansplugins.simpleskills.message.MessageService;
import dansplugins.simpleskills.services.StorageService;
import dansplugins.simpleskills.skill.SkillRepository;
import dansplugins.simpleskills.skill.abs.AbstractSkill;
import dansplugins.simpleskills.chance.ChanceCalculator;
import dansplugins.simpleskills.experience.ExperienceCalculator;

import dansplugins.simpleskills.logging.Log;
import dansplugins.simpleskills.skill.skills.*;
import org.bukkit.Bukkit;
import org.bukkit.command.Command;
import org.bukkit.command.CommandSender;
import org.bukkit.command.PluginCommand;
import org.jetbrains.annotations.NotNull;
import preponderous.ponder.minecraft.bukkit.PonderMC;
import preponderous.ponder.minecraft.bukkit.abs.AbstractPluginCommand;
import preponderous.ponder.minecraft.bukkit.abs.PonderBukkitPlugin;
import preponderous.ponder.minecraft.bukkit.nms.NMSAssistant;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Timer;
import java.util.TimerTask;

/**
 * @author Daniel Stephenson
 */
public class SimpleSkills extends PonderBukkitPlugin {
    private final String pluginVersion = "v" + getDescription().getVersion();
    private PonderMC ponder;

    private final ConfigService configService = new ConfigService(this);
    private final Log log = new Log(this, configService);
    private final MessageService messageService = new MessageService(this);
    private final ExperienceCalculator experienceCalculator = new ExperienceCalculator();
    private final SkillRepository skillRepository = new SkillRepository();
    private final PlayerRecordRepository playerRecordRepository = new PlayerRecordRepository(log, messageService, skillRepository, configService, experienceCalculator);
    private final StorageService storageService = new StorageService(playerRecordRepository, skillRepository, messageService, configService, experienceCalculator, log);
    private final ChanceCalculator chanceCalculator = new ChanceCalculator(playerRecordRepository, configService, skillRepository, messageService, experienceCalculator, log);
    private final PlayerJoinEventListener playerJoinEventListener = new PlayerJoinEventListener(playerRecordRepository, log);
    private Timer autosaveTimer;


    /**
     * This runs when the server starts.
     */
    @Override
    public void onEnable() {
        this.ponder = new PonderMC(this);
        configService.createConfig();
        performNMSChecks();
        setTabCompleterForCoreCommands();
        setupMetrics();
        log.debug("Loading files.");
        storageService.load();
        log.debug("Creating language files.");
        messageService.createlang();
        initializeSkills();
        registerEventListeners();
        initializeCommandService();
        checkFilesVersion();
        startAutosave();
    }

    /**
     * This runs when the server stops.
     */
    @Override
    public void onDisable() {
        stopAutosave();
        log.debug("Saving files.");
        storageService.save();
        log.debug("Saving language files.");
        messageService.savelang();
        log.debug("Saving config files.");
        configService.saveConfig();
    }

    /**
     * This method handles commands sent to the minecraft server and interprets them if the label matches one of the core commands.
     *
     * @param sender The sender of the command.
     * @param cmd    The command that was sent. This is unused.
     * @param label  The core command that has been invoked.
     * @param args   Arguments of the core command. Often sub-commands.
     * @return A boolean indicating whether the execution of the command was successful.
     */
    public boolean onCommand(@NotNull CommandSender sender, @NotNull Command cmd, @NotNull String label, String[] args) {
        if (args.length == 0) {
            DefaultCommand defaultCommand = new DefaultCommand(messageService, this);
            return defaultCommand.execute(sender);
        }

        return ponder.getCommandService().interpretAndExecuteCommand(sender, label, args);
    }

    public String getVersion() {
        return pluginVersion;
    }

    private void checkFilesVersion() {
        log.debug("Checking config and message files for version compatibility.");
        if (messageService.getlang().getDouble("message-version") != 0.2) {
            log.error("Outdated message.yml! Please backup & update message.yml file and restart server again!!");
        }
        if (configService.getConfig().getDouble("config-version") != 0.1) {
            log.error("Outdated config.yml! Please backup & update config.yml file and restart server again!!");
        }
    }

    private void performNMSChecks() {
        try {
            final NMSAssistant nmsAssistant = new NMSAssistant();
            if (nmsAssistant.isVersionGreaterThan(12)) {
                log.info("Loading data for NMS " + nmsAssistant.getNMSVersion().toString());
            } else {
                log.warning("The server version is not suitable to load the plugin");
                log.warning("This plugin is tested on a 1.21.4 server.");
                Bukkit.getServer().getPluginManager().disablePlugin(this);
            }
        } catch(NumberFormatException e) {
            log.warning("Failed to determine NMS version due to NumberFormatException. Some features may not work correctly.");
        } catch (Exception e) {
            log.warning("Failed to determine NMS version due to an exception. Some features may not work correctly. Error: " + e.getMessage());
        }
    }

    private void setupMetrics() {
        log.debug("Setting up bStats metrics for SimpleSkills.");
        int pluginId = 13470;
        Metrics metrics = new Metrics(this, pluginId);

        double configVersion = configService.getConfig().getDouble("config-version");
        int defaultMaxLevel = configService.getConfig().getInt("defaultMaxLevel");
        int defaultBaseExperienceRequirement = configService.getConfig().getInt("defaultBaseExperienceRequirement");
        double defaultExperienceIncreaseFactor = configService.getConfig().getDouble("defaultExperienceIncreaseFactor");
        boolean levelUpAlert = configService.getConfig().getBoolean("levelUpAlert");
        boolean benefitAlert = configService.getConfig().getBoolean("benefitAlert");

        metrics.addCustomChart(new Metrics.SimplePie("config_version", () -> String.valueOf(configVersion)));
        metrics.addCustomChart(new Metrics.SimplePie("default_max_level", () -> String.valueOf(defaultMaxLevel)));
        metrics.addCustomChart(new Metrics.SimplePie("default_base_experience_requirement", () -> String.valueOf(defaultBaseExperienceRequirement)));
        metrics.addCustomChart(new Metrics.SimplePie("default_experience_increase_factor", () -> String.valueOf(defaultExperienceIncreaseFactor)));
        metrics.addCustomChart(new Metrics.SimplePie("level_up_alert", () -> String.valueOf(levelUpAlert)));
        metrics.addCustomChart(new Metrics.SimplePie("benefit_alert", () -> String.valueOf(benefitAlert)));
    }


    private void setTabCompleterForCoreCommands() {
        log.debug("Setting up tab completers for core commands.");
        for (String key : getDescription().getCommands().keySet()) {
            PluginCommand command = getCommand(key);
            if (command == null) {
                continue;
            }
            command.setTabCompleter(new TabCommand());
        }
    }

    private void registerEventListeners() {
        log.debug("Registering events...");
        for (AbstractSkill skill : skillRepository.getSkills()) {
            log.debug("Registering events for skill: " + skill.getName());
            skill.register();
        }

        Bukkit.getPluginManager().registerEvents(playerJoinEventListener, this);
    }

    private void initializeCommandService() {
        log.debug("Initializing command service...");
        ArrayList<AbstractPluginCommand> commands = new ArrayList<>(Arrays.asList(
                new HelpCommand(messageService),
                new InfoCommand(playerRecordRepository, messageService, skillRepository, configService, experienceCalculator, log),
                new StatsCommand(messageService, playerRecordRepository, skillRepository),
                new ForceCommand(playerRecordRepository, skillRepository),
                new SkillCommand(messageService, skillRepository),
                new TopCommand(playerRecordRepository, messageService, skillRepository),
                new ReloadCommand(messageService, configService)
        ));
        ponder.getCommandService().initialize(commands, "That command wasn't found.");
    }

    private void initializeSkills() {
        log.debug("Initializing skills...");
        skillRepository.addSkill(new Athlete(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Boating(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Breeding(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Cardio(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Crafting(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Digging(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Dueling(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Enchanting(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Farming(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Fishing(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Floriculture(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Gliding(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Hardiness(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Woodcutting(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Mining(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new MonsterHunting(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Pyromaniac(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Quarrying(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Riding(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
        skillRepository.addSkill(new Strength(configService, log, playerRecordRepository, this, messageService, chanceCalculator));
    }

    /**
     * Starts the autosave scheduler which saves data every 5 minutes.
     */
    private void startAutosave() {
        log.debug("Starting autosave task.");
        autosaveTimer = new Timer(true);
        autosaveTimer.scheduleAtFixedRate(new TimerTask() {
            @Override
            public void run() {
                if (!isEnabled()) {
                    autosaveTimer.cancel();
                    return;
                }
                Bukkit.getScheduler().runTask(SimpleSkills.this, () -> {
                    log.debug("Autosaving files.");
                    storageService.save();
                });
            }
        }, 1000 * 60 * 5, 1000 * 60 * 5);
    }

    /**
     * Stops the autosave scheduler.
     */
    private void stopAutosave() {
        if (autosaveTimer != null) {
            log.debug("Stopping autosave task.");
            autosaveTimer.cancel();
            autosaveTimer = null;
        }
    }

}