package com.pixelannouncer.manager; import com.cryptomorin.xseries.XSound; import com.pixelannouncer.PixelAnnouncer; import com.pixelannouncer.model.Announcement; import com.pixelannouncer.model.ClickableText; import com.pixelannouncer.util.ColorUtils; import com.tcoded.folialib.wrapper.task.WrappedTask; import me.clip.placeholderapi.PlaceholderAPI; import net.kyori.adventure.text.Component; import net.kyori.adventure.text.TextComponent; import net.kyori.adventure.text.event.ClickEvent; import net.kyori.adventure.text.event.HoverEvent; import net.kyori.adventure.title.Title; import org.bukkit.Bukkit; import org.bukkit.configuration.ConfigurationSection; import org.bukkit.configuration.file.FileConfiguration; import org.bukkit.configuration.file.YamlConfiguration; import org.bukkit.entity.Player; import java.io.File; import java.time.Duration; import java.util.*; import java.util.concurrent.ConcurrentHashMap; public class AnnouncementManager { private final PixelAnnouncer plugin; private final List announcements; private final Map lastBroadcast; private final Map> cachedMessages; private final Map cachedComponents; private final Random random; private long lastGlobalBroadcast; private WrappedTask broadcastTask; public AnnouncementManager(PixelAnnouncer plugin) { this.plugin = plugin; this.announcements = new ArrayList<>(); this.lastBroadcast = new ConcurrentHashMap<>(); this.cachedMessages = new ConcurrentHashMap<>(); this.cachedComponents = new ConcurrentHashMap<>(); this.random = new Random(); this.lastGlobalBroadcast = 0L; } public void loadAnnouncements() { announcements.clear(); lastBroadcast.clear(); cachedMessages.clear(); cachedComponents.clear(); File file = new File(plugin.getDataFolder(), "announcements.yml"); FileConfiguration config = YamlConfiguration.loadConfiguration(file); ConfigurationSection section = config.getConfigurationSection("announcements"); if (section == null) { plugin.getLogger().warning("No announcements section found in announcements.yml!"); return; } int defaultInterval = plugin.getConfig().getInt("broadcast.interval", 300); long currentTime = System.currentTimeMillis() / 1000; for (String key : section.getKeys(false)) { ConfigurationSection announcementSection = section.getConfigurationSection(key); if (announcementSection == null) continue; boolean enabled = announcementSection.getBoolean("enabled", true); if (!enabled) continue; List messages = announcementSection.getStringList("messages"); if (messages.isEmpty()) continue; String typeStr = announcementSection.getString("type", "CHAT").toUpperCase(); Announcement.AnnouncementType type; try { type = Announcement.AnnouncementType.valueOf(typeStr); } catch (IllegalArgumentException e) { type = Announcement.AnnouncementType.CHAT; } String permission = announcementSection.getString("permission", ""); String sound = announcementSection.getString("sound", ""); int textInterval = announcementSection.getInt("text-interval", defaultInterval); boolean titleEnabled = announcementSection.getBoolean("title.enabled", false); String title = announcementSection.getString("title.title", ""); String subtitle = announcementSection.getString("title.subtitle", ""); int fadeIn = announcementSection.getInt("title.fade-in", 10); int stay = announcementSection.getInt("title.stay", 70); int fadeOut = announcementSection.getInt("title.fade-out", 20); boolean centered = announcementSection.getBoolean("centered", false); List worlds = announcementSection.getStringList("worlds"); List clickableTexts = new ArrayList<>(); if (announcementSection.contains("clickable-texts")) { ConfigurationSection clickSection = announcementSection.getConfigurationSection("clickable-texts"); if (clickSection != null) { for (String clickKey : clickSection.getKeys(false)) { ConfigurationSection clickItemSection = clickSection.getConfigurationSection(clickKey); if (clickItemSection == null) continue; String text = clickItemSection.getString("text", ""); String actionStr = clickItemSection.getString("action", "COMMAND").toUpperCase(); String value = clickItemSection.getString("value", ""); String hover = clickItemSection.getString("hover", ""); ClickableText.ClickAction action; try { action = ClickableText.ClickAction.valueOf(actionStr); } catch (IllegalArgumentException e) { action = ClickableText.ClickAction.COMMAND; } clickableTexts.add(ClickableText.builder() .text(text) .action(action) .value(value) .hover(hover) .build()); } } } Announcement announcement = Announcement.builder() .id(key) .enabled(true) .messages(messages) .type(type) .permission(permission) .sound(sound) .textInterval(textInterval) .titleEnabled(titleEnabled) .title(title) .subtitle(subtitle) .fadeIn(fadeIn) .stay(stay) .fadeOut(fadeOut) .centered(centered) .worlds(worlds) .clickableTexts(clickableTexts) .build(); announcements.add(announcement); lastBroadcast.put(key, currentTime); if (centered) { List centeredComponents = new ArrayList<>(); for (String message : messages) { String centered_text = centerText(message); centeredComponents.add(ColorUtils.toComponent(centered_text)); } cachedMessages.put(key, centeredComponents); } } plugin.getLogger().info("Loaded " + announcements.size() + " announcements!"); } public void startBroadcasting() { if (!plugin.getConfig().getBoolean("enabled", true)) { plugin.getLogger().info("Announcements are disabled in config!"); return; } if (announcements.isEmpty()) { plugin.getLogger().warning("No announcements to broadcast!"); return; } broadcastTask = plugin.getFoliaLib().getScheduler().runTimerAsync(() -> { checkAndBroadcast(); }, 20L, 60L); plugin.getLogger().info("Broadcasting started with per-announcement intervals!"); } public void stopBroadcasting() { if (broadcastTask != null && !broadcastTask.isCancelled()) { broadcastTask.cancel(); plugin.getLogger().info("Broadcasting stopped!"); } } private void checkAndBroadcast() { long currentTime = System.currentTimeMillis() / 1000; if (currentTime - lastGlobalBroadcast < 2) { return; } boolean randomOrder = plugin.getConfig().getBoolean("broadcast.random-order", false); List readyAnnouncements = new ArrayList<>(); for (Announcement announcement : announcements) { long lastTime = lastBroadcast.getOrDefault(announcement.getId(), 0L); long elapsed = currentTime - lastTime; if (elapsed >= announcement.getTextInterval()) { readyAnnouncements.add(announcement); } } if (readyAnnouncements.isEmpty()) { return; } List toBroadcast; if (randomOrder) { Announcement randomAnnouncement = readyAnnouncements.get(random.nextInt(readyAnnouncements.size())); toBroadcast = Collections.singletonList(randomAnnouncement); } else { toBroadcast = readyAnnouncements; } for (Announcement announcement : toBroadcast) { broadcast(announcement); lastBroadcast.put(announcement.getId(), currentTime); } lastGlobalBroadcast = currentTime; } public void broadcast(Announcement announcement) { boolean requirePermission = plugin.getConfig().getBoolean("broadcast.require-permission", false); String prefix = plugin.getConfig().getString("broadcast.prefix", ""); Component prefixComponent = prefix.isEmpty() ? null : getCachedComponent(prefix); List eligiblePlayers = new ArrayList<>(); for (Player player : Bukkit.getOnlinePlayers()) { if (!plugin.getPlayerToggleManager().hasAnnouncementsEnabled(player.getUniqueId())) { continue; } if (requirePermission && !announcement.getPermission().isEmpty()) { if (!player.hasPermission(announcement.getPermission())) { continue; } } if (announcement.getWorlds() != null && !announcement.getWorlds().isEmpty()) { if (!announcement.getWorlds().contains(player.getWorld().getName())) { continue; } } eligiblePlayers.add(player); } if (eligiblePlayers.isEmpty()) { return; } for (Player player : eligiblePlayers) { plugin.getFoliaLib().getScheduler().runAtEntity(player, task -> { broadcastToPlayerOptimized(player, announcement, prefixComponent); }); } } private void broadcastToPlayerOptimized(Player player, Announcement announcement, Component prefixComponent) { List rawMessages = announcement.getMessages(); List messages; if (announcement.isCentered() && cachedMessages.containsKey(announcement.getId())) { messages = cachedMessages.get(announcement.getId()); } else { messages = new ArrayList<>(); for (String raw : rawMessages) { String processed = processPlaceholders(raw, player); if (announcement.isCentered()) { processed = centerText(processed); } messages.add(ColorUtils.toComponent(processed)); } } switch (announcement.getType()) { case CHAT: if (announcement.getClickableTexts() != null && !announcement.getClickableTexts().isEmpty()) { sendClickableMessages(player, rawMessages, prefixComponent, announcement.getClickableTexts()); } else { for (Component message : messages) { if (prefixComponent != null) { player.sendMessage(prefixComponent.append(message)); } else { player.sendMessage(message); } } } break; case ACTIONBAR: Component actionbarComponent = messages.isEmpty() ? Component.empty() : messages.get(0); for (int i = 1; i < messages.size(); i++) { actionbarComponent = actionbarComponent.append(Component.space()).append(messages.get(i)); } player.sendActionBar(actionbarComponent); break; case TITLE: Component titleComponent = messages.isEmpty() ? Component.empty() : messages.get(0); Component subtitleComponent = messages.size() > 1 ? messages.get(1) : Component.empty(); Title title = Title.title( titleComponent, subtitleComponent, Title.Times.times( Duration.ofMillis(announcement.getFadeIn() * 50L), Duration.ofMillis(announcement.getStay() * 50L), Duration.ofMillis(announcement.getFadeOut() * 50L) ) ); player.showTitle(title); break; } if (announcement.isTitleEnabled() && announcement.getType() == Announcement.AnnouncementType.CHAT) { String titleText = processPlaceholders(announcement.getTitle(), player); String subtitleText = processPlaceholders(announcement.getSubtitle(), player); Title title = Title.title( ColorUtils.toComponent(titleText), ColorUtils.toComponent(subtitleText), Title.Times.times( Duration.ofMillis(announcement.getFadeIn() * 50L), Duration.ofMillis(announcement.getStay() * 50L), Duration.ofMillis(announcement.getFadeOut() * 50L) ) ); player.showTitle(title); } playSound(player, announcement); } public void broadcastToPlayer(Player player, Announcement announcement, String prefix) { Component prefixComponent = prefix.isEmpty() ? null : getCachedComponent(prefix); broadcastToPlayerOptimized(player, announcement, prefixComponent); } private void sendClickableMessages(Player player, List rawMessages, Component prefixComponent, List clickableTexts) { for (String rawMessage : rawMessages) { String message = processPlaceholders(rawMessage, player); TextComponent.Builder builder = Component.text(); int lastIndex = 0; for (ClickableText clickable : clickableTexts) { int index = message.indexOf(clickable.getText()); if (index >= 0) { if (index > lastIndex) { builder.append(ColorUtils.toComponent(message.substring(lastIndex, index))); } Component clickComponent = ColorUtils.toComponent(clickable.getText()); switch (clickable.getAction()) { case COMMAND: clickComponent = clickComponent.clickEvent(ClickEvent.runCommand(clickable.getValue())); break; case SUGGEST_COMMAND: clickComponent = clickComponent.clickEvent(ClickEvent.suggestCommand(clickable.getValue())); break; case URL: clickComponent = clickComponent.clickEvent(ClickEvent.openUrl(clickable.getValue())); break; } if (!clickable.getHover().isEmpty()) { clickComponent = clickComponent.hoverEvent(HoverEvent.showText(ColorUtils.toComponent(clickable.getHover()))); } builder.append(clickComponent); lastIndex = index + clickable.getText().length(); } } if (lastIndex < message.length()) { builder.append(ColorUtils.toComponent(message.substring(lastIndex))); } Component finalMessage = builder.build(); if (prefixComponent != null) { player.sendMessage(prefixComponent.append(finalMessage)); } else { player.sendMessage(finalMessage); } } } private void playSound(Player player, Announcement announcement) { if (!plugin.getConfig().getBoolean("sounds.enabled", true)) { return; } String soundName = announcement.getSound(); if (soundName == null || soundName.isEmpty()) { soundName = plugin.getConfig().getString("sounds.default-sound", ""); } if (soundName.isEmpty()) { return; } float volume = (float) plugin.getConfig().getDouble("sounds.volume", 1.0); float pitch = (float) plugin.getConfig().getDouble("sounds.pitch", 1.0); String finalSoundName = soundName; XSound.matchXSound(finalSoundName).ifPresent(xSound -> xSound.play(player, volume, pitch)); } private String processPlaceholders(String text, Player player) { if (plugin.isPlaceholderAPI()) { return PlaceholderAPI.setPlaceholders(player, text); } return text; } private String centerText(String text) { String plainText = text.replaceAll("&[0-9a-fk-orA-FK-OR]", "").replaceAll("&#[A-Fa-f0-9]{6}", ""); int width = plainText.length(); int spaces = (60 - width) / 2; if (spaces <= 0) { return text; } StringBuilder centered = new StringBuilder(); for (int i = 0; i < spaces; i++) { centered.append(" "); } centered.append(text); return centered.toString(); } private Component getCachedComponent(String text) { return cachedComponents.computeIfAbsent(text, ColorUtils::toComponent); } public List getAnnouncements() { return new ArrayList<>(announcements); } public int getAnnouncementCount() { return announcements.size(); } }