diff --git a/src/main/java/creator/loki/feature/radio/RadioManager.java b/src/main/java/creator/loki/feature/radio/RadioManager.java index 1e9da08..76bdbb6 100644 --- a/src/main/java/creator/loki/feature/radio/RadioManager.java +++ b/src/main/java/creator/loki/feature/radio/RadioManager.java @@ -69,6 +69,16 @@ public class RadioManager { finalState.streamUrl = getRadioUrl(guildId); Guild guild = radioJda.getGuildById(guildId); if (guild == null) return; + var client = lavalinkManager.getClient(); + if (client != null + && !VoiceHelper.waitForCondition( + () -> client.getNodes().stream().anyMatch(n -> n.getSessionId() != null), + VOICE_TIMEOUT_MS, + TimeUnit.MILLISECONDS)) { + LoggerDecorator.warn( + logger, "Radio: Lavalink node not ready for guild " + guildId); + return; + } guild.getJDA().getDirectAudioController().connect(guild.getVoiceChannelById(channelId)); var self = guild.getMember(guild.getJDA().getSelfUser()); if (!VoiceHelper.waitForCondition(