package com.staffvision.manager; import com.staffvision.StaffVision; import com.staffvision.data.PlayerSnapshot; import org.bukkit.Location; import org.bukkit.entity.Player; import org.bukkit.scheduler.BukkitRunnable; import java.util.*; import java.util.concurrent.ConcurrentHashMap; public class ReplayManager { final StaffVision plugin; private final Map> replayBuffer; private final int maxBufferSize; private final int snapshotInterval; private int captureTaskId; public ReplayManager(StaffVision plugin) { this.plugin = plugin; this.replayBuffer = new ConcurrentHashMap<>(); this.maxBufferSize = plugin.getConfig().getInt("replay.buffer-duration", 60) * 10; this.snapshotInterval = plugin.getConfig().getInt("replay.snapshot-interval", 2); this.startCapturing(); } private void startCapturing() { this.captureTaskId = new BukkitRunnable() { @Override public void run() { for (Player player : plugin.getServer().getOnlinePlayers()) { captureSnapshot(player); } } }.runTaskTimer(plugin, 0L, snapshotInterval).getTaskId(); } private void captureSnapshot(Player player) { UUID uuid = player.getUniqueId(); LinkedList buffer = replayBuffer.computeIfAbsent(uuid, k -> new LinkedList<>()); Location loc = player.getLocation(); PlayerSnapshot snapshot = new PlayerSnapshot( System.currentTimeMillis(), loc.clone(), loc.getYaw(), loc.getPitch(), false, player.isSneaking(), player.isSprinting() ); buffer.addLast(snapshot); if (buffer.size() > maxBufferSize) { buffer.removeFirst(); } } public List getReplayData(UUID playerUUID) { LinkedList buffer = replayBuffer.get(playerUUID); if (buffer == null || buffer.isEmpty()) { return Collections.emptyList(); } return new ArrayList<>(buffer); } public List getReplayData(UUID playerUUID, int secondsAgo) { List allData = getReplayData(playerUUID); if (allData.isEmpty()) { return Collections.emptyList(); } long cutoffTime = System.currentTimeMillis() - (secondsAgo * 1000L); List filtered = new ArrayList<>(); for (int i = allData.size() - 1; i >= 0; i--) { PlayerSnapshot snapshot = allData.get(i); if (snapshot.getTimestamp() >= cutoffTime) { filtered.add(0, snapshot); } else { break; } } return filtered; } public void clearBuffer(UUID playerUUID) { replayBuffer.remove(playerUUID); } public void shutdown() { plugin.getServer().getScheduler().cancelTask(captureTaskId); replayBuffer.clear(); } }