ajgeiss0702
106 lines
3.9 KiB
Java
106 lines
3.9 KiB
Java
package us.ajg0702.queue.logic;
|
|
|
|
import com.google.common.collect.ImmutableList;
|
|
import us.ajg0702.queue.api.premium.Logic;
|
|
import us.ajg0702.queue.api.players.AdaptedPlayer;
|
|
import us.ajg0702.queue.api.players.QueuePlayer;
|
|
import us.ajg0702.queue.api.queues.QueueServer;
|
|
import us.ajg0702.queue.api.util.QueueLogger;
|
|
import us.ajg0702.queue.common.QueueMain;
|
|
import us.ajg0702.queue.common.players.QueuePlayerImpl;
|
|
import us.ajg0702.queue.api.premium.PermissionGetter;
|
|
import us.ajg0702.queue.logic.permissions.PermissionGetterImpl;
|
|
|
|
public class PremiumLogic implements Logic {
|
|
|
|
public PermissionGetter getPermissionGetter() {
|
|
return permissionGetter;
|
|
}
|
|
|
|
private final PermissionGetter permissionGetter;
|
|
public PremiumLogic(QueueMain main) {
|
|
permissionGetter = new PermissionGetterImpl(main);
|
|
}
|
|
|
|
@Override
|
|
public boolean isPremium() {
|
|
return true;
|
|
}
|
|
|
|
@Override
|
|
public QueuePlayer priorityLogic(QueueServer server, AdaptedPlayer player) {
|
|
int maxOfflineTime = permissionGetter.getMaxOfflineTime(player);
|
|
|
|
QueueMain main = QueueMain.getInstance();
|
|
|
|
QueueLogger logger = main.getLogger();
|
|
boolean debug = main.getConfig().getBoolean("priority-queue-debug");
|
|
|
|
if(
|
|
player.hasPermission("ajqueue.bypass") ||
|
|
player.hasPermission("ajqueue.serverbypass."+server.getName()) ||
|
|
player.hasPermission("ajqueue.joinfullandbypassserver."+server.getName()) ||
|
|
player.hasPermission("ajqueue.joinfullandbypass") ||
|
|
permissionGetter.hasContextBypass(player, server.getName()) ||
|
|
(main.isPremium() && main.getLogic().getPermissionGetter().hasUniqueFullBypass(player, server.getName()))
|
|
) {
|
|
if(debug) {
|
|
logger.info("[priority] "+player.getName()+" bypass");
|
|
}
|
|
QueuePlayer queuePlayer = new QueuePlayerImpl(player, server, Integer.MAX_VALUE, maxOfflineTime);
|
|
server.addPlayer(queuePlayer, 0);
|
|
main.getQueueManager().sendPlayers(server);
|
|
return queuePlayer;
|
|
}
|
|
|
|
int priority = permissionGetter.getPriority(player);
|
|
int serverPriority = permissionGetter.getServerPriotity(server.getName(), player);
|
|
|
|
if(debug) {
|
|
logger.info("[priority] Using "+permissionGetter.getSelected().getName()+" for permissions");
|
|
}
|
|
|
|
int highestPriority = Math.max(priority, serverPriority);
|
|
|
|
QueuePlayer queuePlayer = new QueuePlayerImpl(player, server, highestPriority, maxOfflineTime);
|
|
|
|
if(debug) {
|
|
logger.info("[priority] "+player.getName()+" highestPriority: "+highestPriority);
|
|
logger.info("[priority] "+player.getName()+" priority: "+priority);
|
|
logger.info("[priority] "+player.getName()+" serverPriority: "+serverPriority);
|
|
}
|
|
|
|
if(highestPriority <= 0) {
|
|
if(debug) {
|
|
logger.info("[priority] "+player.getName()+" No priority" );
|
|
}
|
|
server.addPlayer(queuePlayer);
|
|
return queuePlayer;
|
|
}
|
|
|
|
ImmutableList<QueuePlayer> list = server.getQueue();
|
|
|
|
for(int i = 0; i < list.size(); i++) {
|
|
QueuePlayer pl = list.get(i);
|
|
if(pl.getPriority() < highestPriority) {
|
|
if(debug) {
|
|
logger.info("[priority] "+player.getName()+" Adding to: "+i);
|
|
}
|
|
server.addPlayer(queuePlayer, i);
|
|
return queuePlayer;
|
|
}
|
|
}
|
|
|
|
if(debug) {
|
|
logger.info("[priority] "+player.getName()+" Cant go infront of anyone" );
|
|
}
|
|
server.addPlayer(queuePlayer);
|
|
return queuePlayer;
|
|
}
|
|
|
|
@Override
|
|
public boolean playerDisconnectedTooLong(QueuePlayer player) {
|
|
return player.getTimeSinceOnline() > player.getMaxOfflineTime()*1000L;
|
|
}
|
|
}
|