package com.pixelcore.radio; import com.pixelcore.PixelCore; import net.md_5.bungee.api.ChatMessageType; import net.md_5.bungee.api.chat.TextComponent; import org.bukkit.Bukkit; import org.bukkit.Sound; import org.bukkit.SoundCategory; import org.bukkit.entity.Player; import org.bukkit.scheduler.BukkitTask; import java.util.*; import java.util.stream.Collectors; /** * Core radio state machine. * *

Playback loop

 *   PLAYING ──(n ticks before end)──► FADE_OUT ──(silence gap)──► [IDENT] ──► FADE_IN ──► PLAYING
 *

* *

Audio: entity-anchored sound

All audio is sent via {@code player.playSound(player, sound, category, volume, pitch)}, * using the player entity as both the listener and the sound source. This means the * sound origin follows the player as they move — there is no distance attenuation because the * source is always co-located with the listener. This is the standard approach for * "personal" sounds that should be globally audible regardless of position, matching how * the Minecraft client handles music (which also doesn't attenuate with position).

* *

The {@code playSound(Entity, ...)} overload was added in Bukkit 1.17 and is fully * supported on the 1.19.4 target of this plugin.

* *

Volume preference

Per-player volume is stored as 0.0–1.0 and applied at the next {@code playSound} call. * Because Bukkit cannot alter a currently-playing sound's volume, the preference takes effect * at the next track or transition — this is communicated clearly in the command response.

* *

Sound category

All radio audio uses {@link SoundCategory#RECORDS} ("Jukebox/Noteblocks" slider), matching * the expected category for disc music so players can mute only the radio if desired.

* *

Sync behaviour

Because playback cannot be seeked, players who join or toggle the radio on mid-track are * queued for the next transition. They receive a message indicating the current on-air track * and will hear audio as soon as the next track begins.

*/ public class RadioManager { // ───────────────────────────────────────────────────────────────────────── // State enum // ───────────────────────────────────────────────────────────────────────── public enum State { /** Station is fully off; no scheduled tasks outstanding. */ STOPPED, /** A disc is actively playing for all listeners. */ PLAYING, /** Audio has been stopped; silence gap before the ident (or next track). */ FADE_OUT, /** Ident sound is playing (only when idents-enabled = true). */ IDENT, /** Brief gap after ident before the next disc starts. */ FADE_IN } // ───────────────────────────────────────────────────────────────────────── // Transition timing // ───────────────────────────────────────────────────────────────────────── /** * Silence ticks before (and after) the ident, representing the "fade" window. * With a resource pack the ident audio can contain fade-in/out curves, making * this gap feel like a genuine crossfade. */ private static final long SILENCE_TICKS = 60L; // 3 seconds /** * Extra gap inserted after the ident ends and before the next disc begins, * giving the ident audio time to decay naturally on the client. */ private static final long POST_IDENT_GAP_TICKS = 20L; // 1 second // ───────────────────────────────────────────────────────────────────────── // Fields // ───────────────────────────────────────────────────────────────────────── private final PixelCore plugin; private State state = State.STOPPED; private RadioTrack currentTrack = null; private RadioTrack nextTrack = null; private BukkitTask pendingTask = null; private final List allTracks = new ArrayList<>(); private final Deque queue = new ArrayDeque<>(); private final Random rng = new Random(); private RadioTrack lastPlayed = null; // Ident configuration — disabled by default until resource pack is ready. private boolean identsEnabled = false; private long identDurTicks = 100L; private final List identSounds = new ArrayList<>(); // Per-player preferences private final Set optedOut = new HashSet<>(); private final Map volumes = new HashMap<>(); // ───────────────────────────────────────────────────────────────────────── // Construction // ───────────────────────────────────────────────────────────────────────── public RadioManager(PixelCore plugin) { this.plugin = plugin; buildTrackCatalogue(); reload(); } /** * Hard-coded disc catalogue for 1.19.4. * * Durations are vanilla audio asset lengths in ticks (20/s). The scheduler * cuts SILENCE_TICKS before the natural end so the disc stops before trailing * silence in the audio file becomes audible. */ private void buildTrackCatalogue() { allTracks.clear(); allTracks.addAll(Arrays.asList( new RadioTrack("13", Sound.MUSIC_DISC_13, "§f♫ Disc 13", 3560L), new RadioTrack("cat", Sound.MUSIC_DISC_CAT, "§f♫ Cat", 3700L), new RadioTrack("blocks", Sound.MUSIC_DISC_BLOCKS, "§f♫ Blocks", 6900L), new RadioTrack("chirp", Sound.MUSIC_DISC_CHIRP, "§f♫ Chirp", 3700L), new RadioTrack("far", Sound.MUSIC_DISC_FAR, "§f♫ Far", 3480L), new RadioTrack("mall", Sound.MUSIC_DISC_MALL, "§f♫ Mall", 3940L), new RadioTrack("mellohi", Sound.MUSIC_DISC_MELLOHI, "§f♫ Mellohi", 1920L), new RadioTrack("stal", Sound.MUSIC_DISC_STAL, "§f♫ Stal", 3000L), new RadioTrack("strad", Sound.MUSIC_DISC_STRAD, "§f♫ Strad", 3760L), new RadioTrack("ward", Sound.MUSIC_DISC_WARD, "§f♫ Ward", 5020L), new RadioTrack("11", Sound.MUSIC_DISC_11, "§f♫ 11", 1420L), new RadioTrack("wait", Sound.MUSIC_DISC_WAIT, "§f♫ Wait", 4760L), new RadioTrack("pigstep", Sound.MUSIC_DISC_PIGSTEP, "§f♫ Pigstep", 2960L), new RadioTrack("otherside", Sound.MUSIC_DISC_OTHERSIDE, "§f♫ Otherside", 3900L), new RadioTrack("5", Sound.MUSIC_DISC_5, "§f♫ 5", 3560L) )); } // ───────────────────────────────────────────────────────────────────────── // Config reload // ───────────────────────────────────────────────────────────────────────── public void reload() { identsEnabled = plugin.getConfig().getBoolean("radio.idents-enabled", false); identDurTicks = plugin.getConfig().getLong("radio.ident-duration-seconds", 5) * 20L; identSounds.clear(); identSounds.addAll(plugin.getConfig().getStringList("radio.idents")); if (identsEnabled && identSounds.isEmpty()) { plugin.getLogger().warning( "[Radio] radio.idents-enabled is true but radio.idents is empty — " + "idents disabled until sounds are added."); identsEnabled = false; } plugin.getLogger().info(String.format( "[Radio] Config loaded — idents: %s, ident duration: %.1fs, tracks: %d", identsEnabled, identDurTicks / 20.0, allTracks.size())); } // ───────────────────────────────────────────────────────────────────────── // Admin station controls // ───────────────────────────────────────────────────────────────────────── public boolean start() { if (state != State.STOPPED) return false; plugin.getLogger().info("[Radio] Station starting."); transitionToNextTrack(); return true; } public boolean stop() { if (state == State.STOPPED) return false; cancelPending(); state = State.STOPPED; currentTrack = null; nextTrack = null; stopAudioForAll(); broadcastActionBar("§7📻 Radio station has stopped."); plugin.getLogger().info("[Radio] Station stopped."); return true; } public boolean override(RadioTrack track) { if (state == State.STOPPED) return false; nextTrack = track; cancelPending(); enterFadeOut(); plugin.getLogger().info("[Radio] Override → " + track.getId()); return true; } public boolean skip() { if (state == State.STOPPED) return false; nextTrack = null; cancelPending(); enterFadeOut(); plugin.getLogger().info("[Radio] Skip requested."); return true; } // ───────────────────────────────────────────────────────────────────────── // Player controls // ───────────────────────────────────────────────────────────────────────── /** * Toggles the radio for a player. * @return true if now opted IN, false if now opted OUT. */ public boolean toggle(UUID uuid) { if (optedOut.contains(uuid)) { optedOut.remove(uuid); return true; } else { optedOut.add(uuid); Player p = Bukkit.getPlayer(uuid); if (p != null) stopAudioForPlayer(p); return false; } } public boolean isListening(UUID uuid) { return !optedOut.contains(uuid); } /** * Stores a volume preference (0.0–1.0). Applied at the next track start * because Bukkit cannot alter a currently-playing sound's volume. */ public void setVolume(UUID uuid, float volume) { volumes.put(uuid, Math.max(0.0f, Math.min(1.0f, volume))); } /** Returns the player's stored volume preference, defaulting to 1.0 (full). */ public float getVolume(UUID uuid) { return volumes.getOrDefault(uuid, 1.0f); } /** * Called when a player joins the server. * They are queued for the next transition — mid-track sync is not possible * because Bukkit audio cannot be seeked. */ public void onPlayerJoin(Player player) { if (optedOut.contains(player.getUniqueId())) return; if (state == State.STOPPED) return; player.sendMessage("§6[§f📻 PixelRadio§6] §7The radio is active — you'll hear the next track shortly."); if (currentTrack != null) { player.sendMessage("§6[§f📻 PixelRadio§6] §7Now on air: " + currentTrack.getDisplayName()); } player.sendMessage("§6[§f📻 PixelRadio§6] §7Type §f/radio §7to toggle · §f/radio volume <1-100> §7to adjust."); } // ───────────────────────────────────────────────────────────────────────── // State machine — transitions // ───────────────────────────────────────────────────────────────────────── private void transitionToNextTrack() { if (nextTrack == null) { nextTrack = dequeue(); } currentTrack = nextTrack; nextTrack = null; lastPlayed = currentTrack; state = State.PLAYING; playAudioForAll(currentTrack); broadcastActionBar("§6📻 §fnow playing: " + currentTrack.getDisplayName()); plugin.getLogger().info("[Radio] ▶ " + currentTrack.getDisplayName() + " (" + (currentTrack.getDurationTicks() / 20) + "s)"); long trackTicks = currentTrack.getDurationTicks(); long cutBuffer = Math.min(SILENCE_TICKS, trackTicks / 2); long cutDelay = Math.max(1L, trackTicks - cutBuffer); pendingTask = scheduleOnce(cutDelay, this::enterFadeOut); } private void enterFadeOut() { state = State.FADE_OUT; stopAudioForAll(); if (nextTrack == null) { nextTrack = dequeue(); } if (identsEnabled) { pendingTask = scheduleOnce(SILENCE_TICKS, this::enterIdent); } else { pendingTask = scheduleOnce(SILENCE_TICKS + POST_IDENT_GAP_TICKS, this::transitionToNextTrack); } } private void enterIdent() { state = State.IDENT; String identKey = identSounds.get(rng.nextInt(identSounds.size())); for (Player p : activeListeners()) { // Custom resource-pack sounds use the String overload, also entity-anchored p.playSound(p, identKey, SoundCategory.RECORDS, getVolume(p.getUniqueId()), 1.0f); } plugin.getLogger().fine("[Radio] ♪ Ident: " + identKey + " (" + (identDurTicks / 20) + "s)"); pendingTask = scheduleOnce(identDurTicks + POST_IDENT_GAP_TICKS, this::transitionToNextTrack); } // ───────────────────────────────────────────────────────────────────────── // Audio helpers // ───────────────────────────────────────────────────────────────────────── private void playAudioForAll(RadioTrack track) { for (Player p : activeListeners()) { playAudioForPlayer(p, track); } } /** * Plays a disc sound for a single player using the entity-anchored overload. * *

{@code p.playSound(p, sound, category, volume, pitch)} passes the player * as both the listener and the sound source. The client moves the sound origin * with the entity, so there is zero distance attenuation — the volume sounds * identical whether the player is standing still or sprinting across the map.

* *

Volume is passed as the player's preference (0.0–1.0). Values below 1.0 * will use the client-side "Jukebox/Noteblocks" slider to reduce output, but * the sound will still follow the player regardless of the value chosen.

*/ private void playAudioForPlayer(Player p, RadioTrack track) { p.playSound(p, track.getSound(), SoundCategory.RECORDS, getVolume(p.getUniqueId()), 1.0f); } private void stopAudioForAll() { for (Player p : activeListeners()) { stopAudioForPlayer(p); } } /** * Stops all radio sounds for a player. * Every catalogued disc is stopped as a safety measure against timing edge cases. */ private void stopAudioForPlayer(Player p) { for (RadioTrack t : allTracks) { p.stopSound(t.getSound(), SoundCategory.RECORDS); } for (String ident : identSounds) { p.stopSound(ident, SoundCategory.RECORDS); } } // ───────────────────────────────────────────────────────────────────────── // Shuffle queue // ───────────────────────────────────────────────────────────────────────── private RadioTrack dequeue() { if (queue.isEmpty()) refillQueue(); return queue.poll(); } private void refillQueue() { List shuffled = new ArrayList<>(allTracks); Collections.shuffle(shuffled, rng); // Prevent back-to-back repeat if (lastPlayed != null && !shuffled.isEmpty() && shuffled.get(0).getId().equals(lastPlayed.getId())) { RadioTrack repeat = shuffled.remove(0); int insertAt = shuffled.isEmpty() ? 0 : 1 + rng.nextInt(shuffled.size()); shuffled.add(insertAt, repeat); } queue.addAll(shuffled); plugin.getLogger().fine("[Radio] Shuffle queue refilled (" + queue.size() + " tracks)."); } // ───────────────────────────────────────────────────────────────────────── // Broadcast helpers // ───────────────────────────────────────────────────────────────────────── private void broadcastActionBar(String message) { for (Player p : activeListeners()) { p.spigot().sendMessage(ChatMessageType.ACTION_BAR, TextComponent.fromLegacyText(message)); } } private List activeListeners() { return Bukkit.getOnlinePlayers().stream() .filter(p -> !optedOut.contains(p.getUniqueId())) .collect(Collectors.toList()); } // ───────────────────────────────────────────────────────────────────────── // Scheduler // ───────────────────────────────────────────────────────────────────────── private BukkitTask scheduleOnce(long delayTicks, Runnable task) { return Bukkit.getScheduler().runTaskLater(plugin, task, delayTicks); } private void cancelPending() { if (pendingTask != null && !pendingTask.isCancelled()) { pendingTask.cancel(); pendingTask = null; } } // ───────────────────────────────────────────────────────────────────────── // Getters // ───────────────────────────────────────────────────────────────────────── public State getState() { return state; } public RadioTrack getCurrentTrack() { return currentTrack; } public List getAllTracks() { return Collections.unmodifiableList(allTracks); } public RadioTrack getTrackById(String id) { return allTracks.stream() .filter(t -> t.getId().equalsIgnoreCase(id)) .findFirst().orElse(null); } public int getListenerCount() { return (int) Bukkit.getOnlinePlayers().stream() .filter(p -> !optedOut.contains(p.getUniqueId())) .count(); } }