Make Votifier channel configurable

Author: remdui

src/main/java/nl/hauntedmc/serverfeatures/features/votifier/Votifier.java

@@ -13,7 +13,7 @@
 
 public class Votifier extends BukkitBaseFeature<Meta> {
 
-    private static final String CHANNEL = "vote";     // must match proxy publisher
+    private static final String DEFAULT_CHANNEL = "proxy.votifier.vote";
     private static final String CONNECTION = "hauntedmc";
 
     private EventBusHandler eventBusHandler;
@@ -26,6 +26,7 @@ public Votifier(ServerFeatures plugin) {
     public ConfigMap getDefaultConfig() {
         ConfigMap cfg = new ConfigMap();
         cfg.put("enabled", false);
+        cfg.put("channel", DEFAULT_CHANNEL);
         return cfg;
     }
 
@@ -47,9 +48,15 @@ public void initialize() {
             throw new IllegalStateException("Redis messaging provider is not available for feature '" + getFeatureName() + "'.");
         }
 
-        // Subscribe to the vote channel
+        String configuredChannel = getConfigHandler().get("channel", String.class, DEFAULT_CHANNEL);
+        String channel = resolveChannel(configuredChannel);
+
+        if (configuredChannel == null || configuredChannel.isBlank()) {
+            getLogger().warning("Configured Votifier channel is blank; falling back to \"" + DEFAULT_CHANNEL + "\".");
+        }
+
         this.eventBusHandler = new EventBusHandler(this, redisBus.get());
-        this.eventBusHandler.subscribe(CHANNEL);
+        this.eventBusHandler.subscribe(channel);
     }
 
     @Override
@@ -59,4 +66,13 @@ public void disable() {
             eventBusHandler = null;
         }
     }
+
+    static String resolveChannel(String configuredChannel) {
+        if (configuredChannel == null) {
+            return DEFAULT_CHANNEL;
+        }
+
+        String channel = configuredChannel.trim();
+        return channel.isEmpty() ? DEFAULT_CHANNEL : channel;
+    }
 }

src/test/java/nl/hauntedmc/serverfeatures/features/votifier/VotifierTest.java

@@ -0,0 +1,20 @@
+package nl.hauntedmc.serverfeatures.features.votifier;
+
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+class VotifierTest {
+
+    @Test
+    void resolveChannelFallsBackToDefaultWhenMissing() {
+        assertEquals("proxy.votifier.vote", Votifier.resolveChannel(null));
+        assertEquals("proxy.votifier.vote", Votifier.resolveChannel(""));
+        assertEquals("proxy.votifier.vote", Votifier.resolveChannel("   "));
+    }
+
+    @Test
+    void resolveChannelUsesTrimmedConfiguredValue() {
+        assertEquals("proxy.custom.vote", Votifier.resolveChannel(" proxy.custom.vote "));
+    }
+}