Skip to content

Commit

Permalink
Update lavalink protocol
Browse files Browse the repository at this point in the history
  • Loading branch information
duncte123 committed Feb 7, 2024
1 parent a39fdd4 commit e78c5bc
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 12 deletions.
2 changes: 1 addition & 1 deletion settings.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ fun VersionCatalogBuilder.versionRefs() {
version("dokka", "1.9.10")
version("grgit", "5.2.0")
version("maven-publish", "0.25.3")
version("lavalink", "4.0.1")
version("lavalink", "4.0.3")

version("logger", "2.0.7")
}
Expand Down
25 changes: 14 additions & 11 deletions testbot/src/main/java/me/duncte123/testbot/JDAListener.java
Original file line number Diff line number Diff line change
Expand Up @@ -59,12 +59,18 @@ public void onReady(@NotNull ReadyEvent event) {

@Override
public void onSlashCommandInteraction(@NotNull SlashCommandInteractionEvent event) {
Guild guild = event.getGuild();

if (guild == null) {
return;
}

switch (event.getFullCommandName()) {
case "join":
joinHelper(event);
break;
case "stop":
this.client.getLink(event.getGuild().getIdLong())
this.client.getLink(guild.getIdLong())
.updatePlayer(
(update) -> update.setTrack(null).setPaused(false)
)
Expand All @@ -73,11 +79,11 @@ public void onSlashCommandInteraction(@NotNull SlashCommandInteractionEvent even
});
break;
case "leave":
event.getJDA().getDirectAudioController().disconnect(event.getGuild());
event.getJDA().getDirectAudioController().disconnect(guild);
event.reply("Leaving your channel!").queue();
break;
case "now-playing": {
final var link = this.client.getLink(event.getGuild().getIdLong());
final var link = this.client.getLink(guild.getIdLong());
final var player = link.getCachedPlayer();

if (player == null) {
Expand All @@ -95,24 +101,24 @@ public void onSlashCommandInteraction(@NotNull SlashCommandInteractionEvent even
final var trackInfo = track.getInfo();

event.reply(
"Currently playing: %s\nDuration: %s/%s".formatted(
"Currently playing: %s\nDuration: %s/%s\nRequester: <@%s>".formatted(
trackInfo.getTitle(),
player.getPosition(),
trackInfo.getLength()
trackInfo.getLength(),
track.getUserData(MyUserData.class).requester()
)
).queue();
break;
}
case "pause":
this.client.getLink(event.getGuild().getIdLong())
this.client.getLink(guild.getIdLong())
.getPlayer()
.flatMap((player) -> player.setPaused(!player.getPaused()))
.subscribe((player) -> {
event.reply("Player has been " + (player.getPaused() ? "paused" : "resumed") + "!").queue();
});
break;
case "karaoke on": {
final Guild guild = event.getGuild();
final long guildId = guild.getIdLong();
final Link link = this.client.getLink(guildId);

Expand All @@ -129,7 +135,6 @@ public void onSlashCommandInteraction(@NotNull SlashCommandInteractionEvent even
break;
}
case "karaoke off": {
final Guild guild = event.getGuild();
final long guildId = guild.getIdLong();
final Link link = this.client.getLink(guildId);

Expand All @@ -144,8 +149,6 @@ public void onSlashCommandInteraction(@NotNull SlashCommandInteractionEvent even
break;
}
case "play": {
final Guild guild = event.getGuild();

// We are already connected, go ahead and play
if (guild.getSelfMember().getVoiceState().inAudioChannel()) {
event.deferReply(false).queue();
Expand All @@ -163,7 +166,7 @@ public void onSlashCommandInteraction(@NotNull SlashCommandInteractionEvent even
break;
}
case "custom-request": {
final Link link = this.client.getLink(event.getGuild().getIdLong());
final Link link = this.client.getLink(guild.getIdLong());

link.getNode().customRequest(
(builder) -> builder.get().path("/version").header("Accept", "text/plain")
Expand Down

0 comments on commit e78c5bc

Please sign in to comment.