This commit is contained in:
@ -31,17 +31,21 @@ public class CookieEvents extends BasicListener {
|
|||||||
|
|
||||||
@Subscribe
|
@Subscribe
|
||||||
public void handleCookies(CookieReceiveEvent e) {
|
public void handleCookies(CookieReceiveEvent e) {
|
||||||
if (e.getOriginalKey().equals(EventModeListener.EVENT_TO_SPECTATE_KEY)) {
|
System.out.println(e.getOriginalKey() + " " + e.getOriginalData());
|
||||||
Player player = e.getPlayer();
|
if (!e.getOriginalKey().namespace().equals(EventModeListener.EVENT_TO_SPECTATE_KEY.namespace()))
|
||||||
SteamwarUser user = SteamwarUser.get(player.getUniqueId());
|
return;
|
||||||
|
if (!e.getOriginalKey().value().equals(EventModeListener.EVENT_TO_SPECTATE_KEY.value()))
|
||||||
|
return;
|
||||||
|
e.setResult(CookieReceiveEvent.ForwardResult.handled());
|
||||||
|
Player player = e.getPlayer();
|
||||||
|
SteamwarUser user = SteamwarUser.get(player.getUniqueId());
|
||||||
|
|
||||||
EventFight.getActiveFights().stream()
|
EventFight.getActiveFights().stream()
|
||||||
.filter(fight -> fight.getTeamRed() == user.getTeam() || fight.getTeamBlue() == user.getTeam())
|
.filter(fight -> fight.getTeamRed() == user.getTeam() || fight.getTeamBlue() == user.getTeam())
|
||||||
.filter(fight -> fight.getSpectatePort() != null)
|
.filter(fight -> fight.getSpectatePort() != null)
|
||||||
.filter(fight -> fight.getSpectatePort() != 0)
|
.filter(fight -> fight.getSpectatePort() != 0)
|
||||||
.findFirst()
|
.findFirst()
|
||||||
.flatMap(fight -> VelocityCore.getProxy().getServer(EventStarter.getSpectatePorts().get(fight.getSpectatePort())))
|
.flatMap(fight -> VelocityCore.getProxy().getServer(EventStarter.getSpectatePorts().get(fight.getSpectatePort())))
|
||||||
.ifPresent(registeredServer -> player.createConnectionRequest(registeredServer).fireAndForget());
|
.ifPresent(registeredServer -> player.createConnectionRequest(registeredServer).fireAndForget());
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user