FUCK-CustomDiscs/src/main/java/me/Navoei/customdiscsplugin/CustomDiscs.java

package me.Navoei.customdiscsplugin;

import com.comphenix.protocol.PacketType;
import com.comphenix.protocol.ProtocolLibrary;
import com.comphenix.protocol.ProtocolManager;
import com.comphenix.protocol.events.ListenerPriority;
import com.comphenix.protocol.events.PacketAdapter;
import com.comphenix.protocol.events.PacketContainer;
import com.comphenix.protocol.events.PacketEvent;
import de.maxhenkel.voicechat.api.BukkitVoicechatService;
import dev.jorel.commandapi.CommandAPI;
import dev.jorel.commandapi.CommandAPIBukkitConfig;
import me.Navoei.customdiscsplugin.command.CustomDiscCommand;
import me.Navoei.customdiscsplugin.event.JukeBox;
import me.Navoei.customdiscsplugin.event.HornPlay;
import me.Navoei.customdiscsplugin.language.Lang;
import org.bukkit.NamespacedKey;
import org.bukkit.block.Jukebox;
import org.bukkit.entity.Player;
import org.bukkit.configuration.file.YamlConfiguration;
import org.bukkit.persistence.PersistentDataType;
import org.bukkit.plugin.java.JavaPlugin;

import javax.annotation.Nullable;
import java.io.*;
import java.util.Objects;
import java.util.logging.Level;
import java.util.logging.Logger;

public final class CustomDiscs extends JavaPlugin {
	static CustomDiscs instance;
	
	@Nullable
	private VoicePlugin voicechatPlugin;
	private Logger log;
	public static YamlConfiguration LANG;
	public static File LANG_FILE;
	public float musicDiscDistance;
        public float musicDiscMaxDistance;
	public float musicDiscVolume;
	public float hornCooldown;
	public int hornMaxCooldown;
	public int hornMaxCooldownTicks;
	
	@Override
	public void onLoad() {
		CustomDiscs.instance = this;
		CommandAPI.onLoad(new CommandAPIBukkitConfig(this).verboseOutput(true));
		new CustomDiscCommand(this).register("customdiscs");
	}
	
	@Override
	public void onEnable() {
		log = getLogger();
		
		CommandAPI.onEnable();
		
		BukkitVoicechatService service = getServer().getServicesManager().load(BukkitVoicechatService.class);
		
		this.saveDefaultConfig();
		loadLang();
		
		File musicData = new File(this.getDataFolder(), "musicdata");
		if (!(musicData.exists())) {
			musicData.mkdirs();
		}
		
		if (service != null) {
			voicechatPlugin = new VoicePlugin();
			service.registerPlugin(voicechatPlugin);
			log.info("Successfully registered CustomDiscs plugin");
		} else {
			log.info("Failed to register CustomDiscs plugin");
		}
		
		getServer().getPluginManager().registerEvents(new JukeBox(), this);
                getServer().getPluginManager().registerEvents(new HornPlay(), this);
		getServer().getPluginManager().registerEvents(new HopperManager(), this);
		
		musicDiscDistance = Objects.requireNonNull(getConfig().getInt("music-disc-distance"));
                musicDiscMaxDistance = Objects.requireNonNull(getConfig().getInt("music-disc-max-distance"));
		musicDiscVolume = Float.parseFloat(Objects.requireNonNull(getConfig().getString("music-disc-volume")));
		hornCooldown = Float.parseFloat(Objects.requireNonNull(getConfig().getString("horn-cooldown")));
                hornMaxCooldown = Objects.requireNonNull(getConfig().getInt("horn-max-cooldown"));
                hornMaxCooldownTicks = (Objects.requireNonNull(getConfig().getInt("horn-max-cooldown")) * 20);
		
		ProtocolManager protocolManager = ProtocolLibrary.getProtocolManager();
		
		protocolManager.addPacketListener(new PacketAdapter(this, ListenerPriority.NORMAL, PacketType.Play.Server.WORLD_EVENT) {
			@Override
			public void onPacketSending(PacketEvent event) {
				PacketContainer packet = event.getPacket();
				
				if (packet.getIntegers().read(0).toString().equals("1010")) {
					Jukebox jukebox = (Jukebox) packet.getBlockPositionModifier().read(0).toLocation(event.getPlayer().getWorld()).getBlock().getState();
					
					if (!jukebox.getRecord().hasItemMeta()) return;
					
					if (jukebox.getRecord().getItemMeta().getPersistentDataContainer().has(new NamespacedKey(this.plugin, "customdisc"), PersistentDataType.STRING)) {
						jukebox.stopPlaying();
						event.setCancelled(true);
					}
					
					//Spawn particles if there isnt any music playing at this location.
					ParticleManager.start(jukebox);
				}
			}
		});
		
	}
	
	@Override
	public void onDisable() {
		CommandAPI.onDisable();
		if (voicechatPlugin != null) {
			getServer().getServicesManager().unregister(voicechatPlugin);
			log.info("Successfully unregistered CustomDiscs plugin");
		}
	}
	
	public static CustomDiscs getInstance() {
		return instance;
	}
        
        public static boolean isMusicDisc(Player p) {
                return p.getInventory().getItemInMainHand().getType().toString().contains("MUSIC_DISC");
        }
    
        public static boolean isGoatHorn(Player p) {
                return p.getInventory().getItemInMainHand().getType().toString().contains("GOAT_HORN");
        }
        
	/**
	 * Load the lang.yml file.
	 *
	 * @return The lang.yml config.
	 */
	public void loadLang() {
		File lang = new File(getDataFolder(), "lang.yml");
		if (!lang.exists()) {
			try {
				getDataFolder().mkdir();
				lang.createNewFile();
				InputStream defConfigStream = this.getResource("lang.yml");
				if (defConfigStream != null) {
					copyInputStreamToFile(defConfigStream, lang);
					YamlConfiguration defConfig = YamlConfiguration.loadConfiguration(lang);
					defConfig.save(lang);
					Lang.setFile(defConfig);
				}
			} catch (IOException e) {
				e.printStackTrace(); // So they notice
				log.severe("Failed to create lang.yml for CustomDiscs.");
				log.severe("Now disabling...");
				this.setEnabled(false); // Without it loaded, we can't send them messages
			}
		}
		YamlConfiguration conf = YamlConfiguration.loadConfiguration(lang);
		for (Lang item : Lang.values()) {
			if (conf.getString(item.getPath()) == null) {
				conf.set(item.getPath(), item.getDefault());
			}
		}
		Lang.setFile(conf);
		LANG = conf;
		LANG_FILE = lang;
		try {
			conf.save(getLangFile());
		} catch (IOException e) {
			log.log(Level.WARNING, "Failed to save lang.yml for CustomDiscs");
			log.log(Level.WARNING, "Now disabling...");
			e.printStackTrace();
		}
	}
	
	/**
	 * Gets the lang.yml config.
	 *
	 * @return The lang.yml config.
	 */
	public YamlConfiguration getLang() {
		return LANG;
	}
	
	/**
	 * Get the lang.yml file.
	 *
	 * @return The lang.yml file.
	 */
	public File getLangFile() {
		return LANG_FILE;
	}
	
	public static void copyInputStreamToFile(InputStream input, File file) {
		
		try (OutputStream output = new FileOutputStream(file)) {
			input.transferTo(output);
		} catch (IOException ioException) {
			ioException.printStackTrace();
		}
		
	}
}