|
64 | 64 | import discord4j.common.util.Snowflake; |
65 | 65 | import java.io.File; |
66 | 66 | import java.sql.SQLException; |
| 67 | +import java.time.Clock; |
67 | 68 | import java.time.Duration; |
| 69 | +import java.time.Instant; |
68 | 70 | import java.util.stream.Stream; |
69 | 71 | import net.kyori.adventure.text.minimessage.MiniMessage; |
70 | 72 | import net.milkbowl.vault.economy.Economy; |
@@ -217,15 +219,18 @@ public void onEnable() { |
217 | 219 | new LoadUserController(userManager, server) |
218 | 220 | ).forEach(controller -> server.getPluginManager().registerEvents(controller, this)); |
219 | 221 |
|
220 | | - Metrics metrics = new Metrics(this, 17677); |
221 | | - UpdaterService updaterService = new UpdaterService(this.getPluginMeta().getVersion()); |
| 222 | + new Metrics(this, 17677); |
| 223 | + new UpdaterService(this.getPluginMeta().getVersion()); |
222 | 224 |
|
223 | 225 | parcelRepository.findAll().thenAccept(optionalParcels -> optionalParcels |
224 | 226 | .stream() |
225 | 227 | .filter(parcel -> parcel.status() != ParcelStatus.DELIVERED) |
226 | 228 | .forEach(parcel -> deliveryRepository.find(parcel.uuid()).thenAccept(optionalDelivery -> |
227 | 229 | optionalDelivery.ifPresent(delivery -> { |
228 | | - long delay = Math.max(0, delivery.deliveryTimestamp().toEpochMilli() - System.currentTimeMillis()); |
| 230 | + long delay = Math.max( |
| 231 | + 0, |
| 232 | + Duration.between(Instant.now(Clock.systemDefaultZone()), delivery.deliveryTimestamp()).toMillis() |
| 233 | + ); |
229 | 234 | scheduler.runLaterAsync( |
230 | 235 | new ParcelSendTask(parcel, parcelService, deliveryManager), |
231 | 236 | Duration.ofMillis(delay)); |
|
0 commit comments