diff --git a/RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/internal/DataManager.java b/RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/internal/AbstractDataManager.java similarity index 98% rename from RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/internal/DataManager.java rename to RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/internal/AbstractDataManager.java index a38d64c..0b2fc20 100644 --- a/RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/internal/DataManager.java +++ b/RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/internal/AbstractDataManager.java @@ -23,7 +23,7 @@ import java.util.concurrent.TimeUnit; * * @since 0.3.3 */ -public abstract class DataManager { +public abstract class AbstractDataManager { private final RedisBungeePlugin

plugin; private final Cache serverCache = createCache(); private final Cache proxyCache = createCache(); @@ -31,7 +31,7 @@ public abstract class DataManager { private final Cache lastOnlineCache = createCache(); private final Gson gson = new Gson(); - public DataManager(RedisBungeePlugin

plugin) { + public AbstractDataManager(RedisBungeePlugin

plugin) { this.plugin = plugin; } diff --git a/RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/internal/RedisBungeePlugin.java b/RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/internal/RedisBungeePlugin.java index 61b42a4..cb16cc7 100644 --- a/RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/internal/RedisBungeePlugin.java +++ b/RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/internal/RedisBungeePlugin.java @@ -42,7 +42,7 @@ public interface RedisBungeePlugin

extends EventsPlatform{ Set getLocalPlayersAsUuidStrings(); - DataManager getDataManager(); + AbstractDataManager getDataManager(); Set getPlayers(); diff --git a/RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/internal/RedisUtil.java b/RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/internal/RedisUtil.java index d70fbe6..5998075 100644 --- a/RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/internal/RedisUtil.java +++ b/RedisBungee-API/src/main/java/com/imaginarycode/minecraft/redisbungee/internal/RedisUtil.java @@ -17,9 +17,9 @@ public class RedisUtil { rsc.hdel("player:" + player, "server", "ip", "proxy"); long timestamp = System.currentTimeMillis(); rsc.hset("player:" + player, "online", String.valueOf(timestamp)); - rsc.publish("redisbungee-data", gson.toJson(new DataManager.DataManagerMessage<>( - UUID.fromString(player), RedisBungeeAPI.getRedisBungeeApi().getServerId(), DataManager.DataManagerMessage.Action.LEAVE, - new DataManager.LogoutPayload(timestamp)))); + rsc.publish("redisbungee-data", gson.toJson(new AbstractDataManager.DataManagerMessage<>( + UUID.fromString(player), RedisBungeeAPI.getRedisBungeeApi().getServerId(), AbstractDataManager.DataManagerMessage.Action.LEAVE, + new AbstractDataManager.LogoutPayload(timestamp)))); } public static void cleanUpPlayer(String player, Pipeline rsc) { @@ -27,9 +27,9 @@ public class RedisUtil { rsc.hdel("player:" + player, "server", "ip", "proxy"); long timestamp = System.currentTimeMillis(); rsc.hset("player:" + player, "online", String.valueOf(timestamp)); - rsc.publish("redisbungee-data", gson.toJson(new DataManager.DataManagerMessage<>( - UUID.fromString(player), RedisBungeeAPI.getRedisBungeeApi().getServerId(), DataManager.DataManagerMessage.Action.LEAVE, - new DataManager.LogoutPayload(timestamp)))); + rsc.publish("redisbungee-data", gson.toJson(new AbstractDataManager.DataManagerMessage<>( + UUID.fromString(player), RedisBungeeAPI.getRedisBungeeApi().getServerId(), AbstractDataManager.DataManagerMessage.Action.LEAVE, + new AbstractDataManager.LogoutPayload(timestamp)))); } public static boolean isRedisVersionRight(String redisVersion) { diff --git a/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/BungeeDataManager.java b/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/BungeeDataManager.java index d5f9fea..e73c82a 100644 --- a/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/BungeeDataManager.java +++ b/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/BungeeDataManager.java @@ -1,7 +1,7 @@ package com.imaginarycode.minecraft.redisbungee; import com.imaginarycode.minecraft.redisbungee.events.PubSubMessageEvent; -import com.imaginarycode.minecraft.redisbungee.internal.DataManager; +import com.imaginarycode.minecraft.redisbungee.internal.AbstractDataManager; import com.imaginarycode.minecraft.redisbungee.internal.RedisBungeePlugin; import net.md_5.bungee.api.connection.ProxiedPlayer; import net.md_5.bungee.api.event.PlayerDisconnectEvent; @@ -9,7 +9,7 @@ import net.md_5.bungee.api.event.PostLoginEvent; import net.md_5.bungee.api.plugin.Listener; import net.md_5.bungee.event.EventHandler; -public class BungeeDataManager extends DataManager implements Listener { +public class BungeeDataManager extends AbstractDataManager implements Listener { public BungeeDataManager(RedisBungeePlugin plugin) { super(plugin); diff --git a/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RBUtils.java b/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RBUtils.java index 580944f..f065b61 100644 --- a/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RBUtils.java +++ b/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RBUtils.java @@ -1,7 +1,7 @@ package com.imaginarycode.minecraft.redisbungee; import com.google.gson.Gson; -import com.imaginarycode.minecraft.redisbungee.internal.DataManager; +import com.imaginarycode.minecraft.redisbungee.internal.AbstractDataManager; import net.md_5.bungee.api.connection.PendingConnection; import net.md_5.bungee.api.connection.ProxiedPlayer; import redis.clients.jedis.Pipeline; @@ -29,9 +29,9 @@ public class RBUtils { pipeline.hmset("player:" + connection.getUniqueId().toString(), playerData); if (fireEvent) { - pipeline.publish("redisbungee-data", gson.toJson(new DataManager.DataManagerMessage<>( - connection.getUniqueId(), RedisBungeeAPI.getRedisBungeeApi().getServerId(), DataManager.DataManagerMessage.Action.JOIN, - new DataManager.LoginPayload(connection.getAddress().getAddress())))); + pipeline.publish("redisbungee-data", gson.toJson(new AbstractDataManager.DataManagerMessage<>( + connection.getUniqueId(), RedisBungeeAPI.getRedisBungeeApi().getServerId(), AbstractDataManager.DataManagerMessage.Action.JOIN, + new AbstractDataManager.LoginPayload(connection.getAddress().getAddress())))); } } diff --git a/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeBungeePlugin.java b/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeBungeePlugin.java index aac6213..a6e159a 100644 --- a/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeBungeePlugin.java +++ b/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeBungeePlugin.java @@ -95,7 +95,7 @@ public class RedisBungeeBungeePlugin extends Plugin implements RedisBungeePlugin } @Override - public DataManager getDataManager() { + public AbstractDataManager getDataManager() { return this.dataManager; } diff --git a/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeListener.java b/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeListener.java index 797ba98..245e851 100644 --- a/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeListener.java +++ b/RedisBungee-Bungee/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeListener.java @@ -7,13 +7,12 @@ import com.google.common.io.ByteArrayDataInput; import com.google.common.io.ByteArrayDataOutput; import com.google.common.io.ByteStreams; import com.imaginarycode.minecraft.redisbungee.internal.AbstractRedisBungeeListener; -import com.imaginarycode.minecraft.redisbungee.internal.DataManager; +import com.imaginarycode.minecraft.redisbungee.internal.AbstractDataManager; import com.imaginarycode.minecraft.redisbungee.internal.RedisBungeePlugin; import com.imaginarycode.minecraft.redisbungee.events.PubSubMessageEvent; import com.imaginarycode.minecraft.redisbungee.internal.RedisUtil; import com.imaginarycode.minecraft.redisbungee.internal.util.RedisCallable; import net.md_5.bungee.api.AbstractReconnectHandler; -import net.md_5.bungee.api.ProxyServer; import net.md_5.bungee.api.config.ServerInfo; import net.md_5.bungee.api.connection.ProxiedPlayer; import net.md_5.bungee.api.connection.Server; @@ -90,9 +89,9 @@ public class RedisBungeeListener extends AbstractRedisBungeeListener( - player.getUniqueId(), RedisBungeeAPI.getRedisBungeeApi().getServerId(), DataManager.DataManagerMessage.Action.JOIN, - new DataManager.LoginPayload(player.getRemoteAddress().getAddress())))); + pipeline.publish("redisbungee-data", gson.toJson(new AbstractDataManager.DataManagerMessage<>( + player.getUniqueId(), RedisBungeeAPI.getRedisBungeeApi().getServerId(), AbstractDataManager.DataManagerMessage.Action.JOIN, + new AbstractDataManager.LoginPayload(player.getRemoteAddress().getAddress())))); } } diff --git a/RedisBungee-Velocity/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeListener.java b/RedisBungee-Velocity/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeListener.java index efae24d..c85b136 100644 --- a/RedisBungee-Velocity/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeListener.java +++ b/RedisBungee-Velocity/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeListener.java @@ -1,7 +1,7 @@ package com.imaginarycode.minecraft.redisbungee; import com.imaginarycode.minecraft.redisbungee.internal.AbstractRedisBungeeListener; -import com.imaginarycode.minecraft.redisbungee.internal.DataManager; +import com.imaginarycode.minecraft.redisbungee.internal.AbstractDataManager; import com.imaginarycode.minecraft.redisbungee.internal.RedisBungeePlugin; import com.imaginarycode.minecraft.redisbungee.events.PubSubMessageEvent; import com.imaginarycode.minecraft.redisbungee.internal.RedisUtil; @@ -83,9 +83,9 @@ public class RedisBungeeListener extends AbstractRedisBungeeListener( - event.getPlayer().getUniqueId(), plugin.getApi().getServerId(), DataManager.DataManagerMessage.Action.JOIN, - new DataManager.LoginPayload(event.getPlayer().getRemoteAddress().getAddress())))); + jedis.publish("redisbungee-data", gson.toJson(new AbstractDataManager.DataManagerMessage<>( + event.getPlayer().getUniqueId(), plugin.getApi().getServerId(), AbstractDataManager.DataManagerMessage.Action.JOIN, + new AbstractDataManager.LoginPayload(event.getPlayer().getRemoteAddress().getAddress())))); return null; } }); @@ -115,9 +115,9 @@ public class RedisBungeeListener extends AbstractRedisBungeeListener( - event.getPlayer().getUniqueId(), plugin.getApi().getServerId(), DataManager.DataManagerMessage.Action.SERVER_CHANGE, - new DataManager.ServerChangePayload(event.getServer().getServerInfo().getName(), currentServer)))); + jedis.publish("redisbungee-data", gson.toJson(new AbstractDataManager.DataManagerMessage<>( + event.getPlayer().getUniqueId(), plugin.getApi().getServerId(), AbstractDataManager.DataManagerMessage.Action.SERVER_CHANGE, + new AbstractDataManager.ServerChangePayload(event.getServer().getServerInfo().getName(), currentServer)))); return null; } }); diff --git a/RedisBungee-Velocity/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeVelocityPlugin.java b/RedisBungee-Velocity/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeVelocityPlugin.java index e319cc1..347f837 100644 --- a/RedisBungee-Velocity/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeVelocityPlugin.java +++ b/RedisBungee-Velocity/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungeeVelocityPlugin.java @@ -112,7 +112,7 @@ public class RedisBungeeVelocityPlugin implements RedisBungeePlugin { } @Override - public DataManager getDataManager() { + public AbstractDataManager getDataManager() { return this.dataManager; } diff --git a/RedisBungee-Velocity/src/main/java/com/imaginarycode/minecraft/redisbungee/VelocityDataManager.java b/RedisBungee-Velocity/src/main/java/com/imaginarycode/minecraft/redisbungee/VelocityDataManager.java index 544159e..1daa3f7 100644 --- a/RedisBungee-Velocity/src/main/java/com/imaginarycode/minecraft/redisbungee/VelocityDataManager.java +++ b/RedisBungee-Velocity/src/main/java/com/imaginarycode/minecraft/redisbungee/VelocityDataManager.java @@ -1,7 +1,7 @@ package com.imaginarycode.minecraft.redisbungee; import com.imaginarycode.minecraft.redisbungee.events.PubSubMessageEvent; -import com.imaginarycode.minecraft.redisbungee.internal.DataManager; +import com.imaginarycode.minecraft.redisbungee.internal.AbstractDataManager; import com.imaginarycode.minecraft.redisbungee.internal.RedisBungeePlugin; import com.velocitypowered.api.event.Subscribe; import com.velocitypowered.api.event.connection.DisconnectEvent; @@ -9,7 +9,7 @@ import com.velocitypowered.api.event.connection.PostLoginEvent; import com.velocitypowered.api.proxy.Player; -public class VelocityDataManager extends DataManager { +public class VelocityDataManager extends AbstractDataManager { public VelocityDataManager(RedisBungeePlugin plugin) { super(plugin);