bumped version

* Allow unsuccessful replacement of BungeeCord thread pool

Port https://github.com/minecrafter/RedisBungee/pull/76

Some BungeeCord forks have different implementation of thread pool and RedisBungee won't load in such case

* Update RedisBungee.java

.github/ISSUE_TEMPLATE/bug_report.md

@@ -0,0 +1,32 @@
+---
+name: Bug report
+about: if you find a bug please report it here...
+title: ''
+labels: waiting.....
+assignees: ham1255
+
+---
+
+**Describe the bug**
+
+
+**To Reproduce**
+Steps to reproduce the behavior:
+1. Go to '...'
+2. Click on '....'
+3. Scroll down to '....'
+4. See error
+
+**Expected behavior**
+A clear and concise description of what you expected to happen.
+
+**Screenshots**
+If applicable, add screenshots to help explain your problem.
+
+**Redis version? it should be at least 6 and above.**
+
+**Bungeecord version or (the bungee fork name eg: waterfall) and your plugins**
+ 
+
+**console logs?**
+please provide any errors if there any.

.github/ISSUE_TEMPLATE/question.md

@@ -0,0 +1,10 @@
+---
+name: Question
+about: ask your questions here
+title: ''
+labels: question
+assignees: GovindasOM, ham1255
+
+---
+
+## What is your question?

.github/workflows/maven.yml

@@ -1,7 +1,7 @@
 # This workflow will build a Java project with Maven
 # For more information see: https://help.github.com/actions/language-and-framework-guides/building-and-testing-java-with-maven
 
-name: Java CI with Maven
+name: RedisBungee Build
 
 on:
   push:

README.md

@@ -1,39 +1,81 @@
 # Limework fork of RedisBungee
+[![RedisBungee Build](https://github.com/Limework/RedisBungee/actions/workflows/maven.yml/badge.svg)](https://github.com/Limework/RedisBungee/actions/workflows/maven.yml) [![](https://jitpack.io/v/limework/redisbungee.svg)](https://jitpack.io/#limework/redisbungee)
 
 Spigot link: [click](https://www.spigotmc.org/resources/redisbungee.87700/)
 
-this fork was made due the maintainer of redisBungee became inactive, so we took the place to develop it!
+The maintainer of RedisBungee has became inactive, so we have taken the development of the plugin.
 
-RedisBungee bridges [Redis](http://redis.io) and BungeeCord together. 
+RedisBungee uses [Redis](https://redis.io) to Synchronize data between [BungeeCord](https://github.com/SpigotMC/BungeeCord) proxies
 
-RedisBungee was used on thechunk server which we think was shutdown due website not loading...
+# 0.7 API BREAKING CHANGE:
-~~This is the solution deployed on [The Chunk](http://thechunk.net) to make sure our multi-Bungee setup flows smoothly together.~~
+we do not advice using version (0.7) till we finish making it stable , 
+but if you plan to use redis-bungee 0.7 the api has breaking change. 
+JedisPool was changed to Pool<Jedis> to support Redis Sentinel
+If ANYONE found a good way to fix this api breaking change
+pull requests are welcomed :)
+## Notice: about older versions of redis than redis 6.0
 
-this will be deployed soon on [Govindas limework!](https://Limework.net) 
+As of now Version 0.6.4-SNAPSHOT is only supporting redis 6.0 and above!
 
 ## Compiling
 
-Now you can use maven without installing it using Maven wrapper [github?](https://github.com/takari/maven-wrapper) :)
+Now you can use Maven without installing it using [Maven wrappe](https://github.com/takari/maven-wrapper) :)
 
-RedisBungee is distributed as a [maven](http://maven.apache.org) project. To compile it and install it in your local Maven repository:
+RedisBungee is distributed as a [maven](https://maven.apache.org) project. 
 
-    git clone https://github.com/Limework/RedisBungee.git
+To compile and installing to in your local Maven repository:
-    cd RedisBungee
+
+    git clone https://github.com/Limework/RedisBungee.git .
     mvnw clean install
+    mvnw package
+
+If you have deb maven installed, you can use the `mvn` command instead.
+
+And use it in your pom file.
+
+    <dependency>
+      <groupId>com.imaginarycode.minecraft</groupId>
+      <artifactId>RedisBungee</artifactId>
+      <version>0.6.4-SNAPSHOT</version>
+      <scope>provided</scope>
+    </dependency>
+
+Or if you want to use the jitpack maven server
+
+    <repositories>
+		<repository>
+		    <id>jitpack.io</id>
+		    <url>https://jitpack.io</url>
+		</repository>
+	</repositories>
+    
+And use it in your pom file.
+    
+    <dependency>
+	    <groupId>com.github.limework</groupId>
+	    <artifactId>redisbungee</artifactId>
+	    <version>0.6.3</version>
+	</dependency>
+
 
 ## Javadocs
-The current version is 0.6-snapshot! will be updated every version number change!
+Hosted on limework website. Version 0.6.0 (note: any version 0.6.* will not have API changes.)
-
 https://limework.net/JavaDocs/RedisBungee/
 
 ## Configuration
 
-**REDISBUNGEE REQUIRES A REDIS SERVER**, preferably with reasonably low latency. The default [config](https://github.com/minecrafter/RedisBungee/blob/master/src/main/resources/example_config.yml) is saved when the plugin first starts.
+**REDISBUNGEE REQUIRES A REDIS SERVER**, preferably with reasonably low latency. The default [config](https://github.com/limework/RedisBungee/blob/master/src/main/resources/example_config.yml) is saved when the plugin first starts.
 
 ## License!
 
 This project is distributed under Eclipse Public License 1.0
 
-which you can find it [here](https://github.com/Limework/RedisBungee/blob/master/LICENSE)
+You can find it [here](https://github.com/Limework/RedisBungee/blob/master/LICENSE)
 
-you can find the original redisBungee by minecrafter [here](https://github.com/minecrafter/RedisBungee) or spigot page [here](https://www.spigotmc.org/resources/redisbungee.13494/)
+You can find the original RedisBungee by minecrafter [here](https://github.com/minecrafter/RedisBungee) or spigot page [here](https://www.spigotmc.org/resources/redisbungee.13494/)
+
+## YourKit
+
+YourKit supports open source projects with innovative and intelligent tools for monitoring and profiling Java and .NET applications. YourKit is the creator of [YourKit Java Profiler](https://www.yourkit.com/java/profiler/), [YourKit .NET Profiler](https://www.yourkit.com/.net/profiler/) and [YourKit YouMonitor](https://www.yourkit.com/youmonitor/).
+
+![YourKit](https://www.yourkit.com/images/yklogo.png)

pom.xml

@@ -6,14 +6,7 @@
 
     <groupId>com.imaginarycode.minecraft</groupId>
     <artifactId>RedisBungee</artifactId>
-    <version>0.6.1</version>
+    <version>0.6.4</version>
-
-    <distributionManagement>
-        <repository>
-            <id>Limework-Maven-Public</id>
-            <url>http://mc.limework.net:8081/repository/public-maven/</url>
-        </repository>
-    </distributionManagement>
 
 
     <repositories>
@@ -99,7 +92,7 @@
         <dependency>
             <groupId>redis.clients</groupId>
             <artifactId>jedis</artifactId>
-            <version>3.4.1</version>
+            <version>3.6.1</version>
             <scope>compile</scope>
         </dependency>
         <dependency>
@@ -111,14 +104,14 @@
         <dependency>
             <groupId>net.md-5</groupId>
             <artifactId>bungeecord-api</artifactId>
-            <version>1.16-R0.5-SNAPSHOT</version>
+            <version>1.17-R0.1-SNAPSHOT</version>
             <type>jar</type>
             <scope>provided</scope>
         </dependency>
         <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
-            <version>1.18.16</version>
+            <version>1.18.20</version>
             <scope>provided</scope>
         </dependency>
         <dependency>

src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungee.java

@@ -104,7 +104,7 @@ public final class RedisBungee extends Plugin {
                     if (lagged ? time >= stamp + 30 : time <= stamp + 30)
                         servers.add(entry.getKey());
                     else if (nag && nagTime <= 0) {
-                        getLogger().severe(entry.getKey() + " is " + (time - stamp) + " seconds behind! (Time not synchronized or server down?) and was removed from heartbeat.");
+                        getLogger().warning(entry.getKey() + " is " + (time - stamp) + " seconds behind! (Time not synchronized or server down?) and was removed from heartbeat.");
                         jedis.hdel("heartbeats", entry.getKey());
                     }
                 } catch (NumberFormatException ignored) {
@@ -223,14 +223,15 @@ public final class RedisBungee extends Plugin {
     @Override
     public void onEnable() {
         ThreadFactory factory = ((ThreadPoolExecutor) getExecutorService()).getThreadFactory();
-        getExecutorService().shutdownNow();
+        ScheduledExecutorService service = Executors.newScheduledThreadPool(24, factory);
-        ScheduledExecutorService service;
         try {
             Field field = Plugin.class.getDeclaredField("service");
             field.setAccessible(true);
-            field.set(this, service = Executors.newScheduledThreadPool(24, factory));
+            ExecutorService builtinService = (ExecutorService) field.get(this);
+            field.set(this, service);
+            builtinService.shutdownNow();
         } catch (Exception e) {
-            throw new RuntimeException("Can't replace BungeeCord thread pool with our own", e);
+            getLogger().log(Level.WARNING, "Can't replace BungeeCord thread pool with our own", e);
         }
         try {
             loadConfig();
@@ -246,8 +247,9 @@ public final class RedisBungee extends Plugin {
                 for (String s : info.split("\r\n")) {
                     if (s.startsWith("redis_version:")) {
                         String version = s.split(":")[1];
+                        getLogger().info(version + " <- redis version");
                         if (!(usingLua = RedisUtil.canUseLua(version))) {
-                            getLogger().warning("Your version of Redis (" + version + ") is not at least version 2.6. RedisBungee requires a newer version of Redis.");
+                            getLogger().warning("Your version of Redis (" + version + ") is not at least version 6.0 RedisBungee requires a newer version of Redis.");
                             throw new RuntimeException("Unsupported Redis version detected");
                         } else {
                             LuaManager manager = new LuaManager(this);
@@ -416,6 +418,7 @@ public final class RedisBungee extends Plugin {
         final boolean useSSL = configuration.getBoolean("useSSL");
         String redisPassword = configuration.getString("redis-password");
         String serverId = configuration.getString("server-id");
+        final String randomUUID = UUID.randomUUID().toString();
 
         if (redisPassword != null && (redisPassword.isEmpty() || redisPassword.equals("none"))) {
             redisPassword = null;
@@ -423,7 +426,20 @@ public final class RedisBungee extends Plugin {
 
         // Configuration sanity checks.
         if (serverId == null || serverId.isEmpty()) {
-            throw new RuntimeException("server-id is not specified in the configuration or is empty");
+            /*
+            *  this check causes the config comments to disappear somehow
+            *  I think due snake yaml limitations so as todo: write our own yaml parser?
+            */
+            String genId = UUID.randomUUID().toString();
+            getLogger().info("Generated server id " + genId + " and saving it to config.");
+            configuration.set("server-id", genId);
+            ConfigurationProvider.getProvider(YamlConfiguration.class).save(configuration, new File(getDataFolder(), "config.yml"));
+        } else {
+            getLogger().info("Loaded server id " + serverId + '.');
+        }
+
+        if (configuration.getBoolean("use-random-id-string", false)) {
+            serverId = configuration.getString("server-id") + "-" + randomUUID;
         }
 
         if (redisServer != null && !redisServer.isEmpty()) {
@@ -475,7 +491,7 @@ public final class RedisBungee extends Plugin {
                         httpClient.setDispatcher(dispatcher);
                         NameFetcher.setHttpClient(httpClient);
                         UUIDFetcher.setHttpClient(httpClient);
-                        RedisBungee.configuration = new RedisBungeeConfiguration(RedisBungee.this.getPool(), configuration);
+                        RedisBungee.configuration = new RedisBungeeConfiguration(RedisBungee.this.getPool(), configuration, randomUUID);
                         return null;
                     }
                 });

src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeConfiguration.java

@@ -8,6 +8,7 @@ import redis.clients.jedis.JedisPool;
 
 import java.net.InetAddress;
 import java.util.List;
+import java.util.UUID;
 
 public class RedisBungeeConfiguration {
     @Getter
@@ -19,9 +20,15 @@ public class RedisBungeeConfiguration {
     @Getter
     private final List<InetAddress> exemptAddresses;
 
-    public RedisBungeeConfiguration(JedisPool pool, Configuration configuration) {
+
+    public RedisBungeeConfiguration(JedisPool pool, Configuration configuration, String randomUUID) {
         this.pool = pool;
+        if (configuration.getBoolean("use-random-id-string", false)) {
+            this.serverId = configuration.getString("server-id") + "-" + randomUUID;
+        } else {
             this.serverId = configuration.getString("server-id");
+        }
+
         this.registerBungeeCommands = configuration.getBoolean("register-bungee-commands", true);
 
         List<String> stringified = configuration.getStringList("exempt-ip-addresses");
@@ -33,4 +40,5 @@ public class RedisBungeeConfiguration {
 
         this.exemptAddresses = addressBuilder.build();
     }
+
 }

src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeListener.java

@@ -14,7 +14,6 @@ import net.md_5.bungee.api.AbstractReconnectHandler;
 import net.md_5.bungee.api.ChatColor;
 import net.md_5.bungee.api.chat.BaseComponent;
 import net.md_5.bungee.api.chat.ComponentBuilder;
-import net.md_5.bungee.api.chat.TextComponent;
 import net.md_5.bungee.api.config.ServerInfo;
 import net.md_5.bungee.api.connection.ProxiedPlayer;
 import net.md_5.bungee.api.connection.Server;
@@ -62,7 +61,7 @@ public class RedisBungeeListener implements Listener {
                         if (player != null) {
                             event.setCancelled(true);
                             // TODO: Make it accept a BaseComponent[] like everything else.
-                            event.setCancelReason(TextComponent.toLegacyText(ONLINE_MODE_RECONNECT));
+                            event.setCancelReason(ONLINE_MODE_RECONNECT);
                             return null;
                         }
                     }
@@ -71,7 +70,7 @@ public class RedisBungeeListener implements Listener {
                         if (jedis.sismember("proxy:" + s + ":usersOnline", event.getConnection().getUniqueId().toString())) {
                             event.setCancelled(true);
                             // TODO: Make it accept a BaseComponent[] like everything else.
-                            event.setCancelReason(TextComponent.toLegacyText(ALREADY_LOGGED_IN));
+                            event.setCancelReason(ALREADY_LOGGED_IN);
                             return null;
                         }
                     }
@@ -146,14 +145,13 @@ public class RedisBungeeListener implements Listener {
         event.getResponse().getPlayers().setOnline(plugin.getCount());
     }
 
+    @SuppressWarnings("UnstableApiUsage")
     @EventHandler
     public void onPluginMessage(final PluginMessageEvent event) {
-        if ((event.getTag().equals("legacy:RedisBungee") || event.getTag().equals("RedisBungee")) && event.getSender() instanceof Server) {
+        if ((event.getTag().equals("legacy:redisbungee") || event.getTag().equals("RedisBungee")) && event.getSender() instanceof Server) {
             final String currentChannel = event.getTag();
             final byte[] data = Arrays.copyOf(event.getData(), event.getData().length);
-            plugin.getProxy().getScheduler().runAsync(plugin, new Runnable() {
+            plugin.getProxy().getScheduler().runAsync(plugin, () -> {
-                @Override
-                public void run() {
                 ByteArrayDataInput in = ByteStreams.newDataInput(data);
 
                 String subchannel = in.readUTF();
@@ -246,7 +244,6 @@ public class RedisBungeeListener implements Listener {
                 }
 
                 ((Server) event.getSender()).sendData(currentChannel, out.toByteArray());
-                }
             });
         }
     }
@@ -259,6 +256,7 @@ public class RedisBungeeListener implements Listener {
         }
     }
 
+    @SuppressWarnings("SameParameterValue")
     private void serializeMultimap(Multimap<String, String> collection, boolean includeNames, ByteArrayDataOutput output) {
         output.writeInt(collection.keySet().size());
         for (Map.Entry<String, Collection<String>> entry : collection.asMap().entrySet()) {

src/main/java/com/imaginarycode/minecraft/redisbungee/RedisUtil.java

@@ -58,16 +58,13 @@ public class RedisUtil {
     }
 
     public static boolean canUseLua(String redisVersion) {
-        // Need to use >=2.6 to use Lua optimizations.
+        // Need to use >=6.2 to use Lua optimizations.
         String[] args = redisVersion.split("\\.");
-
         if (args.length < 2) {
             return false;
         }
-
         int major = Integer.parseInt(args[0]);
         int minor = Integer.parseInt(args[1]);
-
+        return major >= 6 && minor >= 0;
-        return major >= 3 || (major == 2 && minor >= 6);
     }
 }

src/main/resources/example_config.yml

@@ -16,8 +16,13 @@ max-redis-connections: 8
 # you must disable this if redis version is under 6 you must disable this or connection wont work!!!
 useSSL: false
 
-# An identifier for this BungeeCord instance.
+# An identifier for this BungeeCord instance. Will randomly generate if leaving it blank.
-server-id: test1
+server-id: "test1"
+# Should use random string? if this  is enabled the proxy id will be like this if server-id is test1: "test1-66cd2aeb-91f3-43a7-a106-e0307b098652"
+# or if id is limework-bungee it will be "limework-bungee-66cd2aeb-91f3-43a7-a106-e0307b098652"
+# this great for servers who run replicas in Kubernetes or any auto deploying replica service
+# and used for if proxy died in a kubernetes network and deleted then new proxy setup itself.
+use-random-id-string: false
 
 # Whether or not RedisBungee should install its version of regular BungeeCord commands.
 # Often, the RedisBungee commands are desired, but in some cases someone may wish to

src/main/resources/plugin.yml

@@ -1,7 +1,7 @@
 name: ${project.name}
 main: com.imaginarycode.minecraft.redisbungee.RedisBungee
 version: ${project.version}
-author: Chunker and Govindas limework
+author: Chunkr and Govindas limework
 authors:
   - chunkr
   - Govindas Limework

src/test/java/com/imaginarycode/minecraft/redisbungee/test/RedisUtilTest.java

@@ -7,11 +7,14 @@ import org.junit.Test;
 public class RedisUtilTest {
     @Test
     public void testRedisLuaCheck() {
-        Assert.assertTrue(RedisUtil.canUseLua("2.6.0"));
+        Assert.assertTrue(RedisUtil.canUseLua("6.2.0"));
+        Assert.assertTrue(RedisUtil.canUseLua("6.1.0"));
+        Assert.assertTrue(RedisUtil.canUseLua("6.0.0"));
+        Assert.assertFalse(RedisUtil.canUseLua("2.6.0"));
         Assert.assertFalse(RedisUtil.canUseLua("2.2.12"));
         Assert.assertFalse(RedisUtil.canUseLua("1.2.4"));
-        Assert.assertTrue(RedisUtil.canUseLua("2.8.4"));
+        Assert.assertFalse(RedisUtil.canUseLua("2.8.4"));
-        Assert.assertTrue(RedisUtil.canUseLua("3.0.0"));
+        Assert.assertFalse(RedisUtil.canUseLua("3.0.0"));
-        Assert.assertTrue(RedisUtil.canUseLua("3.2.1"));
+        Assert.assertFalse(RedisUtil.canUseLua("3.2.1"));
     }
 }