Temporary: run generated comment cleanup

VotingPlugin/src/main/java/com/bencodez/votingplugin/backendproxy/BackendProxyRewardRegistrar.java

@@ -0,0 +1,16 @@
+package com.bencodez.votingplugin.backendproxy;
+
+import com.bencodez.votingplugin.VotingPluginMain;
+import com.bencodez.votingplugin.rewards.DirectlyDefinedRewardPath;
+
+/** Registers directly-defined backend/proxy reward paths. */
+public final class BackendProxyRewardRegistrar {
+
+	private BackendProxyRewardRegistrar() {
+	}
+
+	public static void register(VotingPluginMain plugin) {
+		plugin.addDirectlyDefinedRewards(DirectlyDefinedRewardPath.of("BungeeVotePartyRewards",
+				plugin.getBungeeSettings()));
+	}
+}

VotingPlugin/src/main/java/com/bencodez/votingplugin/backendproxy/cache/ProcessedVoteCache.java

@@ -0,0 +1,60 @@
+package com.bencodez.votingplugin.backendproxy.cache;
+
+import java.util.UUID;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.TimeUnit;
+
+import lombok.Getter;
+
+/**
+ * Tracks recently processed proxy vote ids so duplicate delivery is ignored.
+ */
+public class ProcessedVoteCache {
+
+	private static final long DEFAULT_TTL_MILLIS = TimeUnit.MINUTES.toMillis(30);
+
+	@Getter
+	private final ConcurrentHashMap<UUID, Long> processedVotes = new ConcurrentHashMap<>();
+	private final long ttlMillis;
+
+	public ProcessedVoteCache() {
+		this(DEFAULT_TTL_MILLIS);
+	}
+
+	public ProcessedVoteCache(long ttlMillis) {
+		this.ttlMillis = ttlMillis;
+	}
+
+	public boolean reserve(UUID voteId) {
+		if (voteId == null) {
+			return true;
+		}
+
+		long now = System.currentTimeMillis();
+		long expiresAt = now + ttlMillis;
+
+		while (true) {
+			Long currentExpiry = processedVotes.get(voteId);
+			if (currentExpiry == null) {
+				if (processedVotes.putIfAbsent(voteId, expiresAt) == null) {
+					cleanup(now);
+					return true;
+				}
+				continue;
+			}
+
+			if (currentExpiry > now) {
+				return false;
+			}
+
+			if (processedVotes.replace(voteId, currentExpiry, expiresAt)) {
+				cleanup(now);
+				return true;
+			}
+		}
+	}
+
+	private void cleanup(long now) {
+		processedVotes.entrySet().removeIf(entry -> entry.getValue() <= now);
+	}
+}

VotingPlugin/src/main/java/com/bencodez/votingplugin/backendproxy/global/BackendGlobalDataSync.java

@@ -0,0 +1,175 @@
+package com.bencodez.votingplugin.backendproxy.global;
+
+import java.time.LocalDateTime;
+import java.time.ZoneOffset;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+import java.util.function.Consumer;
+
+import com.bencodez.advancedcore.api.time.TimeType;
+import com.bencodez.advancedcore.api.user.UserStorage;
+import com.bencodez.advancedcore.bungeeapi.globaldata.GlobalDataHandler;
+import com.bencodez.advancedcore.bungeeapi.globaldata.GlobalMySQL;
+import com.bencodez.simpleapi.servercomm.codec.JsonEnvelope;
+import com.bencodez.simpleapi.sql.data.DataValue;
+import com.bencodez.simpleapi.sql.data.DataValueBoolean;
+import com.bencodez.simpleapi.sql.mysql.config.MysqlConfigSpigot;
+import com.bencodez.votingplugin.VotingPluginMain;
+import com.bencodez.votingplugin.proxy.VotingPluginWire;
+
+import lombok.Getter;
+
+/**
+ * Owns backend global-data polling and proxy-driven time-change processing.
+ */
+public class BackendGlobalDataSync {
+
+	private final VotingPluginMain plugin;
+	private final Consumer<JsonEnvelope> sender;
+
+	@Getter
+	private GlobalDataHandler globalDataHandler;
+	@Getter
+	private ScheduledExecutorService timer;
+
+	public BackendGlobalDataSync(VotingPluginMain plugin, Consumer<JsonEnvelope> sender) {
+		this.plugin = plugin;
+		this.sender = sender;
+	}
+
+	public void checkGlobalData() {
+		if (globalDataHandler == null) {
+			return;
+		}
+		HashMap<String, DataValue> data = globalDataHandler.getExact(plugin.getBungeeSettings().getServer());
+
+		if (data.containsKey("ForceUpdate") && checkGlobalDataTimeValue(data.get("ForceUpdate"))) {
+			if (plugin.getStorageType().equals(UserStorage.MYSQL)) {
+				plugin.getMysql().clearCacheBasic();
+			}
+			plugin.getUserManager().getDataManager().clearCache();
+			plugin.setUpdate(true);
+			plugin.update();
+			globalDataHandler.setBoolean(plugin.getBungeeSettings().getServer(), "ForceUpdate", false);
+		}
+
+		boolean forceUpdate = checkGlobalDataTime(TimeType.MONTH, data);
+		forceUpdate |= checkGlobalDataTime(TimeType.WEEK, data);
+		forceUpdate |= checkGlobalDataTime(TimeType.DAY, data);
+
+		if (forceUpdate) {
+			HashMap<String, DataValue> dataToSet = new HashMap<>();
+			dataToSet.put("FinishedProcessing", new DataValueBoolean(true));
+			dataToSet.put("Processing", new DataValueBoolean(false));
+			globalDataHandler.setData(plugin.getBungeeSettings().getServer(), dataToSet);
+		}
+	}
+
+	public boolean checkGlobalDataTime(TimeType type, HashMap<String, DataValue> data) {
+		if (!data.containsKey(type.toString()) || !checkGlobalDataTimeValue(data.get(type.toString()))) {
+			return false;
+		}
+
+		long lastUpdated = Long.valueOf(data.get("LastUpdated").getString()).longValue();
+		plugin.debug("LastUpdated: " + lastUpdated);
+		if (LocalDateTime.now().atZone(ZoneOffset.UTC).toInstant().toEpochMilli() - lastUpdated > 1000 * 60 * 60 * 2) {
+			plugin.getLogger().warning("Ignoring bungee time change since it was more than 2 hours ago");
+			globalDataHandler.setBoolean(plugin.getBungeeSettings().getServer(), type.toString(), false);
+			return false;
+		}
+
+		globalDataHandler.setBoolean(plugin.getBungeeSettings().getServer(), "Processing", true);
+		plugin.debug("Detected time change from bungee: " + type.toString());
+		plugin.getTimeChecker().forceChanged(type, false, true, true);
+		globalDataHandler.setBoolean(plugin.getBungeeSettings().getServer(), type.toString(), false);
+
+		JsonEnvelope.Builder builder = JsonEnvelope.builder("TimeChangeFinished").schema(VotingPluginWire.SCHEMA_VERSION);
+		builder.put("server", plugin.getBungeeSettings().getServer());
+		sender.accept(builder.build());
+		return true;
+	}
+
+	public boolean checkGlobalDataTimeValue(DataValue data) {
+		if (data.isBoolean()) {
+			return data.getBoolean();
+		}
+		return Boolean.valueOf(data.getString());
+	}
+
+	public void load() {
+		if (!plugin.getBungeeSettings().isGloblalDataEnabled()) {
+			return;
+		}
+
+		shutdownTimer();
+		timer = Executors.newScheduledThreadPool(1);
+		timer.scheduleWithFixedDelay(this::checkGlobalData, 60, 10, TimeUnit.SECONDS);
+		timer.scheduleWithFixedDelay(() -> {
+			if (globalDataHandler != null) {
+				globalDataHandler.setString(plugin.getBungeeSettings().getServer(), "LastOnline",
+						"" + LocalDateTime.now().atZone(ZoneOffset.UTC).toInstant().toEpochMilli());
+			}
+		}, 1, 60, TimeUnit.MINUTES);
+
+		closeGlobalMysql();
+
+		if (plugin.getBungeeSettings().isGloblalDataUseMainMySQL()
+				&& plugin.getStorageType().equals(UserStorage.MYSQL)) {
+			globalDataHandler = new GlobalDataHandler(new GlobalMySQL("VotingPlugin_GlobalData", plugin.getMysql().getMysql()) {
+				@Override public void debugEx(Exception e) { plugin.debug(e); }
+				@Override public void debugLog(String text) { plugin.debug(text); }
+				@Override public void info(String text) { plugin.getLogger().info(text); }
+				@Override public void logSevere(String text) { plugin.getLogger().severe(text); }
+				@Override public void warning(String text) { plugin.getLogger().warning(text); }
+			});
+		} else {
+			globalDataHandler = new GlobalDataHandler(new GlobalMySQL("VotingPlugin_GlobalData",
+					new MysqlConfigSpigot(plugin.getBungeeSettings().getData().getConfigurationSection("GlobalData"))) {
+				@Override public void debugEx(Exception e) { plugin.debug(e); }
+				@Override public void debugLog(String text) { plugin.debug(text); }
+				@Override public void info(String text) { plugin.getLogger().info(text); }
+				@Override public void logSevere(String text) { plugin.getLogger().severe(text); }
+				@Override public void warning(String text) { plugin.getLogger().warning(text); }
+			});
+		}
+
+		for (Map.Entry<String, String> column : Map.of(
+				"IgnoreTime", "VARCHAR(5)",
+				"MONTH", "VARCHAR(5)",
+				"WEEK", "VARCHAR(5)",
+				"DAY", "VARCHAR(5)",
+				"FinishedProcessing", "VARCHAR(5)",
+				"Processing", "VARCHAR(5)",
+				"LastUpdated", "MEDIUMTEXT",
+				"ForceUpdate", "VARCHAR(5)").entrySet()) {
+			globalDataHandler.getGlobalMysql().alterColumnType(column.getKey(), column.getValue());
+		}
+		plugin.getTimeChecker().setProcessingEnabled(false);
+	}
+
+	public void close() {
+		closeGlobalMysql();
+	}
+
+	private void closeGlobalMysql() {
+		if (globalDataHandler != null) {
+			globalDataHandler.getGlobalMysql().close();
+		}
+	}
+
+	private void shutdownTimer() {
+		if (timer == null) {
+			return;
+		}
+		timer.shutdown();
+		try {
+			timer.awaitTermination(5, TimeUnit.SECONDS);
+		} catch (InterruptedException e) {
+			Thread.currentThread().interrupt();
+		}
+		timer.shutdownNow();
+	}
+}