Upstream/Plan
1
0
Fork 0
mirror of https://github.com/plan-player-analytics/Plan.git synced 2025-02-04 22:41:41 +01:00
Code Issues Projects Releases Wiki Activity

Fix broken PlayerLeaveEventConsumerTest

Browse Source
This commit is contained in:
Aurora Lahtela 2022-08-31 09:07:58 +03:00
parent 9d7684e3fb
commit f14b78dede
2 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
Plan/common/src/main/java/com/djrapitops/plan/gathering/events/PlayerLeaveEventConsumer.java
View File

@ -68,10 +68,14 @@ public class PlayerLeaveEventConsumer {
} }
public void onLeaveGameServer(PlayerLeave leave) { public void onLeaveGameServer(PlayerLeave leave) {
onLeaveGameServer(leave, 0);
}
public void onLeaveGameServer(PlayerLeave leave, int attempt) {
Optional<ActiveSession> activeSession = SessionCache.getCachedSession(leave.getPlayerUUID()); Optional<ActiveSession> activeSession = SessionCache.getCachedSession(leave.getPlayerUUID());
if (activeSession.isEmpty()) { if (activeSession.isEmpty() && attempt < 50) {
// Quit event processed before Join event, delay processing // Quit event processed before Join event, delay processing
processing.submitCritical(() -> onLeaveGameServer(leave)); processing.submitCritical(() -> onLeaveGameServer(leave, attempt + 1));
return; return;
} }

5
Plan/common/src/test/java/com/djrapitops/plan/gathering/events/PlayerLeaveEventConsumerTest.java
View File

@ -151,7 +151,10 @@ class PlayerLeaveEventConsumerTest {
} }
@Test @Test
void leavingGameServerSavesBanStatus(Database database, ServerUUID serverUUID) { void leavingGameServerSavesBanStatus(PlanSystem system, Database database, ServerUUID serverUUID) {
SessionCache sessionCache = system.getCacheSystem().getSessionCache();
long sessionStart = System.currentTimeMillis();
sessionCache.cacheSession(TestConstants.PLAYER_ONE_UUID, new ActiveSession(TestConstants.PLAYER_ONE_UUID, serverUUID, sessionStart, "World", GMTimes.SURVIVAL));
registerPlayer(database, serverUUID); registerPlayer(database, serverUUID);
PlayerLeave leave = createPlayerLeave(createTestPlayer() PlayerLeave leave = createPlayerLeave(createTestPlayer()
.setBanned(true)); .setBanned(true));