Skip to content

Commit

Permalink
fix unnecessary saves & missing save complete packets
Browse files Browse the repository at this point in the history
  • Loading branch information
jpenilla committed Aug 19, 2023
1 parent dc9d9b0 commit ed3fcf3
Showing 1 changed file with 9 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,14 @@ protected CachingUserManager(
protected abstract void saveSync(CarbonPlayerCommon player);

private CompletableFuture<Void> save(final CarbonPlayerCommon player) {
return CompletableFuture.runAsync(() -> this.saveSync(player), this.executor);
return CompletableFuture.runAsync(() -> {
this.saveSync(player);
player.saved();
this.messagingManager.get().withPacketService(packetService -> {
packetService.queuePacket(this.packetFactory.saveCompletedPacket(player.uuid()));
packetService.flushQueue();
});
}, this.executor);
}

@Override
Expand All @@ -94,13 +101,7 @@ public CompletableFuture<Void> saveIfNeeded(final CarbonPlayerCommon player) {
if (!player.needsSave()) {
return CompletableFuture.completedFuture(null);
}
return this.save(player).whenComplete(($, $$) -> {
player.saved();
this.messagingManager.get().withPacketService(packetService -> {
packetService.queuePacket(this.packetFactory.saveCompletedPacket(player.uuid()));
packetService.flushQueue();
});
});
return this.save(player);
}

@Override
Expand Down

0 comments on commit ed3fcf3

Please sign in to comment.