blob: 1fdbf2ae896d2aa4caefa7daa1fed1f38067c1c7 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
package net.tylermurphy.ken.command.music;
import com.sedmelluq.discord.lavaplayer.player.AudioPlayer;
import com.sedmelluq.discord.lavaplayer.track.AudioTrack;
import net.dv8tion.jda.api.entities.AudioChannel;
import net.dv8tion.jda.api.entities.Guild;
import net.dv8tion.jda.api.entities.GuildMessageChannel;
import net.dv8tion.jda.api.entities.Member;
import net.dv8tion.jda.api.managers.AudioManager;
import net.tylermurphy.ken.Ken;
import net.tylermurphy.ken.util.Command;
import net.tylermurphy.ken.command.Response;
import net.tylermurphy.ken.music.GuildMusicManager;
import net.tylermurphy.ken.music.PlayerManager;
import net.tylermurphy.ken.music.TrackScheduler;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class Skip {
private final Map<AudioTrack, List<String>> skips = new HashMap<>();
@Command(name="skip", description="Skips current track")
public Response execute(Member sender, GuildMessageChannel channel, Guild guild, List<Object> args) {
AudioManager audioManager = guild.getAudioManager();
PlayerManager playerManager = Ken.getInstance().getPlayerManager();
GuildMusicManager musicManager = playerManager.getGuildMusicManager(guild);
TrackScheduler scheduler = musicManager.scheduler;
AudioPlayer player = musicManager.player;
AudioTrack track = player.getPlayingTrack();
if (player.getPlayingTrack() == null) {
return Response.error("Nothing is currently playing");
}
AudioChannel audioChannel = audioManager.getConnectedChannel();
if(skips.get(track) == null) {
List<String> users = new ArrayList<String>();
users.add(sender.getUser().getDiscriminator());
skips.put(track, users);
} else {
List<String> users = skips.get(track);
boolean found = false;
for(String s : users) {
if(sender.getUser().getDiscriminator().equals(s)) {
found = true;
break;
}
}
if(!found) {
users.add(sender.getUser().getDiscriminator());
skips.put(track, users);
}
}
int people = (int) audioChannel.getMembers().stream().filter(member -> !member.getUser().isBot()).count();
int skipsNeeded = (int) Math.ceil(people/2.0);
if(skips.get(track).size()>=skipsNeeded) {
skips.remove(track);
scheduler.nextTrack();
return Response.success(":arrow_right: Skipping the current track");
} else {
return Response.success(String.format(
":arrow_right: Skips (%s/%s) for skipping current track. Use the command fskip to force skip.",
skips.get(track).size(),
skipsNeeded
));
}
}
}
|
