mirror of
https://github.com/proxiodev/RedisBungee.git
synced 2024-11-26 22:18:01 +00:00
move backward api into Bungeecord only, and remove deprecated apis added after fork
This commit is contained in:
parent
78333f4415
commit
d79b729d79
@ -14,16 +14,11 @@ import com.google.common.collect.ImmutableSet;
|
|||||||
import com.google.common.collect.Multimap;
|
import com.google.common.collect.Multimap;
|
||||||
import com.imaginarycode.minecraft.redisbungee.api.RedisBungeeMode;
|
import com.imaginarycode.minecraft.redisbungee.api.RedisBungeeMode;
|
||||||
import com.imaginarycode.minecraft.redisbungee.api.RedisBungeePlugin;
|
import com.imaginarycode.minecraft.redisbungee.api.RedisBungeePlugin;
|
||||||
import com.imaginarycode.minecraft.redisbungee.api.summoners.JedisClusterSummoner;
|
|
||||||
import com.imaginarycode.minecraft.redisbungee.api.summoners.JedisPooledSummoner;
|
|
||||||
import com.imaginarycode.minecraft.redisbungee.api.summoners.Summoner;
|
import com.imaginarycode.minecraft.redisbungee.api.summoners.Summoner;
|
||||||
import net.kyori.adventure.text.Component;
|
import net.kyori.adventure.text.Component;
|
||||||
import org.checkerframework.checker.nullness.qual.NonNull;
|
import org.checkerframework.checker.nullness.qual.NonNull;
|
||||||
import org.checkerframework.checker.nullness.qual.Nullable;
|
import org.checkerframework.checker.nullness.qual.Nullable;
|
||||||
import redis.clients.jedis.Jedis;
|
|
||||||
import redis.clients.jedis.JedisCluster;
|
|
||||||
import redis.clients.jedis.JedisPool;
|
import redis.clients.jedis.JedisPool;
|
||||||
import redis.clients.jedis.JedisPooled;
|
|
||||||
|
|
||||||
import java.net.InetAddress;
|
import java.net.InetAddress;
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
@ -216,19 +211,6 @@ public abstract class AbstractRedisBungeeAPI {
|
|||||||
return plugin.proxyDataManager().proxyId();
|
return plugin.proxyDataManager().proxyId();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Get the current BungeeCord / Velocity proxy ID for this server.
|
|
||||||
*
|
|
||||||
* @return the current server ID
|
|
||||||
* @see #getAllServers()
|
|
||||||
* @since 0.2.5
|
|
||||||
* @deprecated to avoid confusion between A server and A proxy see #getProxyId()
|
|
||||||
*/
|
|
||||||
@Deprecated(forRemoval = true)
|
|
||||||
public final String getServerId() {
|
|
||||||
return getProxyId();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Get all the linked proxies in this network.
|
* Get all the linked proxies in this network.
|
||||||
*
|
*
|
||||||
@ -240,41 +222,6 @@ public abstract class AbstractRedisBungeeAPI {
|
|||||||
return plugin.proxyDataManager().proxiesIds();
|
return plugin.proxyDataManager().proxiesIds();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Get all the linked proxies in this network.
|
|
||||||
*
|
|
||||||
* @return the list of all proxies
|
|
||||||
* @see #getServerId()
|
|
||||||
* @since 0.2.5
|
|
||||||
* @deprecated to avoid confusion between A server and A proxy see see {@link #getAllProxies()}
|
|
||||||
*/
|
|
||||||
@Deprecated(forRemoval = true)
|
|
||||||
public final List<String> getAllServers() {
|
|
||||||
return getAllProxies();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Register (a) PubSub channel(s), so that you may handle PubSubMessageEvent for it.
|
|
||||||
*
|
|
||||||
* @param channels the channels to register
|
|
||||||
* @since 0.3
|
|
||||||
* @deprecated No longer required
|
|
||||||
*/
|
|
||||||
@Deprecated(forRemoval = true)
|
|
||||||
public final void registerPubSubChannels(String... channels) {
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Unregister (a) PubSub channel(s).
|
|
||||||
*
|
|
||||||
* @param channels the channels to unregister
|
|
||||||
* @since 0.3
|
|
||||||
* @deprecated No longer required
|
|
||||||
*/
|
|
||||||
@Deprecated(forRemoval = true)
|
|
||||||
public final void unregisterPubSubChannels(String... channels) {
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Fetch a name from the specified UUID. UUIDs are cached locally and in Redis. This function falls back to Mojang
|
* Fetch a name from the specified UUID. UUIDs are cached locally and in Redis. This function falls back to Mojang
|
||||||
* as a last resort, so calls <strong>may</strong> be blocking.
|
* as a last resort, so calls <strong>may</strong> be blocking.
|
||||||
@ -342,34 +289,6 @@ public abstract class AbstractRedisBungeeAPI {
|
|||||||
return plugin.getUuidTranslator().getTranslatedUuid(name, expensiveLookups);
|
return plugin.getUuidTranslator().getTranslatedUuid(name, expensiveLookups);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Kicks a player from the network
|
|
||||||
* calls {@link #getUuidFromName(String)} to get uuid
|
|
||||||
*
|
|
||||||
* @param playerName player name
|
|
||||||
* @param message kick message that player will see on kick
|
|
||||||
* @since 0.8.0
|
|
||||||
* @deprecated
|
|
||||||
*/
|
|
||||||
@Deprecated(forRemoval = true)
|
|
||||||
public void kickPlayer(String playerName, String message) {
|
|
||||||
kickPlayer(getUuidFromName(playerName), message);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Kicks a player from the network
|
|
||||||
*
|
|
||||||
* @param playerUUID player name
|
|
||||||
* @param message kick message that player will see on kick
|
|
||||||
* @since 0.8.0
|
|
||||||
* @deprecated
|
|
||||||
*/
|
|
||||||
@Deprecated(forRemoval = true)
|
|
||||||
public void kickPlayer(UUID playerUUID, String message) {
|
|
||||||
kickPlayer(playerUUID, Component.text(message));
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Kicks a player from the network
|
* Kicks a player from the network
|
||||||
* calls {@link #getUuidFromName(String)} to get uuid
|
* calls {@link #getUuidFromName(String)} to get uuid
|
||||||
@ -394,81 +313,6 @@ public abstract class AbstractRedisBungeeAPI {
|
|||||||
this.plugin.playerDataManager().kickPlayer(playerUUID, message);
|
this.plugin.playerDataManager().kickPlayer(playerUUID, message);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* This gives you instance of Jedis
|
|
||||||
*
|
|
||||||
* @return {@link Jedis}
|
|
||||||
* @throws IllegalStateException if the {@link #getMode()} is not equal to {@link RedisBungeeMode#SINGLE}
|
|
||||||
* @see #getJedisPool()
|
|
||||||
* @since 0.7.0
|
|
||||||
* @deprecated use {@link #getSummoner() }
|
|
||||||
*/
|
|
||||||
@Deprecated(forRemoval = true)
|
|
||||||
public Jedis requestJedis() {
|
|
||||||
if (getMode() == RedisBungeeMode.SINGLE) {
|
|
||||||
return getJedisPool().getResource();
|
|
||||||
} else {
|
|
||||||
throw new IllegalStateException("Mode is not " + RedisBungeeMode.SINGLE);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* This gets Redis Bungee {@link JedisPool}
|
|
||||||
*
|
|
||||||
* @return {@link JedisPool}
|
|
||||||
* @throws IllegalStateException if the {@link #getMode()} is not equal to {@link RedisBungeeMode#SINGLE}
|
|
||||||
* @throws IllegalStateException if JedisPool compatibility mode is disabled in the config
|
|
||||||
* @since 0.6.5
|
|
||||||
*/
|
|
||||||
public JedisPool getJedisPool() {
|
|
||||||
if (getMode() == RedisBungeeMode.SINGLE) {
|
|
||||||
JedisPool jedisPool = ((JedisPooledSummoner) this.plugin.getSummoner()).getCompatibilityJedisPool();
|
|
||||||
if (jedisPool == null) {
|
|
||||||
throw new IllegalStateException("JedisPool compatibility mode is disabled, Please enable it in the RedisBungee config.yml");
|
|
||||||
}
|
|
||||||
return jedisPool;
|
|
||||||
} else {
|
|
||||||
throw new IllegalStateException("Mode is not " + RedisBungeeMode.SINGLE);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* This gives you an instance of JedisCluster that can't be closed
|
|
||||||
* see {@link com.imaginarycode.minecraft.redisbungee.api.summoners.NotClosableJedisCluster}
|
|
||||||
*
|
|
||||||
* @return {@link redis.clients.jedis.JedisCluster}
|
|
||||||
* @throws IllegalStateException if the {@link #getMode()} is not equal to {@link RedisBungeeMode#CLUSTER}
|
|
||||||
* @since 0.8.0
|
|
||||||
* @deprecated use {@link #getSummoner()}
|
|
||||||
*/
|
|
||||||
@Deprecated(forRemoval = true)
|
|
||||||
public JedisCluster requestClusterJedis() {
|
|
||||||
if (getMode() == RedisBungeeMode.CLUSTER) {
|
|
||||||
return ((JedisClusterSummoner) this.plugin.getSummoner()).obtainResource();
|
|
||||||
} else {
|
|
||||||
throw new IllegalStateException("Mode is not " + RedisBungeeMode.CLUSTER);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* This gives you an instance of JedisPooled that can't be closed
|
|
||||||
* see {@link com.imaginarycode.minecraft.redisbungee.api.summoners.NotClosableJedisPooled}
|
|
||||||
*
|
|
||||||
* @return {@link redis.clients.jedis.JedisPooled}
|
|
||||||
* @throws IllegalStateException if the {@link #getMode()} is not equal to {@link RedisBungeeMode#SINGLE}
|
|
||||||
* @since 0.8.0
|
|
||||||
* @deprecated use {@link #getSummoner()}
|
|
||||||
*/
|
|
||||||
@Deprecated(forRemoval = true)
|
|
||||||
public JedisPooled requestJedisPooled() {
|
|
||||||
if (getMode() == RedisBungeeMode.SINGLE) {
|
|
||||||
return ((JedisPooledSummoner) this.plugin.getSummoner()).obtainResource();
|
|
||||||
} else {
|
|
||||||
throw new IllegalStateException("Mode is not " + RedisBungeeMode.SINGLE);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* returns Summoner class responsible for Single Jedis {@link redis.clients.jedis.JedisPooled} with {@link JedisPool}, Cluster Jedis {@link redis.clients.jedis.JedisCluster} handling
|
* returns Summoner class responsible for Single Jedis {@link redis.clients.jedis.JedisPooled} with {@link JedisPool}, Cluster Jedis {@link redis.clients.jedis.JedisCluster} handling
|
||||||
*
|
*
|
||||||
@ -479,7 +323,6 @@ public abstract class AbstractRedisBungeeAPI {
|
|||||||
return this.plugin.getSummoner();
|
return this.plugin.getSummoner();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* shows what mode is RedisBungee is on
|
* shows what mode is RedisBungee is on
|
||||||
* Basically what every redis mode is used like cluster or single instance.
|
* Basically what every redis mode is used like cluster or single instance.
|
||||||
|
@ -10,12 +10,17 @@
|
|||||||
|
|
||||||
package com.imaginarycode.minecraft.redisbungee;
|
package com.imaginarycode.minecraft.redisbungee;
|
||||||
|
|
||||||
|
import com.imaginarycode.minecraft.redisbungee.api.RedisBungeeMode;
|
||||||
import com.imaginarycode.minecraft.redisbungee.api.RedisBungeePlugin;
|
import com.imaginarycode.minecraft.redisbungee.api.RedisBungeePlugin;
|
||||||
|
import com.imaginarycode.minecraft.redisbungee.api.summoners.JedisPooledSummoner;
|
||||||
|
import net.kyori.adventure.text.Component;
|
||||||
import net.md_5.bungee.api.config.ServerInfo;
|
import net.md_5.bungee.api.config.ServerInfo;
|
||||||
import net.md_5.bungee.api.plugin.Plugin;
|
import net.md_5.bungee.api.plugin.Plugin;
|
||||||
import org.checkerframework.checker.nullness.qual.NonNull;
|
import org.checkerframework.checker.nullness.qual.NonNull;
|
||||||
import org.checkerframework.checker.nullness.qual.Nullable;
|
import org.checkerframework.checker.nullness.qual.Nullable;
|
||||||
|
import redis.clients.jedis.JedisPool;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
import java.util.UUID;
|
import java.util.UUID;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -51,6 +56,88 @@ public class RedisBungeeAPI extends AbstractRedisBungeeAPI {
|
|||||||
return ((Plugin) this.plugin).getProxy().getServerInfo(serverName);
|
return ((Plugin) this.plugin).getProxy().getServerInfo(serverName);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// LEGACY API FOR BACKWARD COMPATIBILITY
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Warning: this is Legacy API to maintain backward compatibility with RedisBungee Pre fork 0.5
|
||||||
|
* <p>
|
||||||
|
* Get all the linked proxies in this network.
|
||||||
|
*
|
||||||
|
* @return the list of all proxies
|
||||||
|
* @see #getServerId()
|
||||||
|
* @since 0.2.5
|
||||||
|
* @deprecated to avoid confusion between A server and A proxy see see {@link #getAllProxies()}
|
||||||
|
*/
|
||||||
|
@Deprecated
|
||||||
|
public final List<String> getAllServers() {
|
||||||
|
return getAllProxies();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Warning: this is Legacy API to maintain backward compatibility with RedisBungee Pre fork 0.5
|
||||||
|
* <p>
|
||||||
|
* Get the current BungeeCord / Velocity proxy ID for this server.
|
||||||
|
*
|
||||||
|
* @return the current server ID
|
||||||
|
* @see #getAllServers()
|
||||||
|
* @since 0.2.5
|
||||||
|
* @deprecated to avoid confusion between A server and A proxy see #getProxyId()
|
||||||
|
*/
|
||||||
|
@Deprecated
|
||||||
|
public final String getServerId() {
|
||||||
|
return getProxyId();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Warning: this is Legacy API to maintain backward compatibility with RedisBungee Pre fork 0.5
|
||||||
|
* <p>
|
||||||
|
* Register (a) PubSub channel(s), so that you may handle PubSubMessageEvent for it.
|
||||||
|
*
|
||||||
|
* @param channels the channels to register
|
||||||
|
* @since 0.3
|
||||||
|
* @deprecated No longer required
|
||||||
|
*/
|
||||||
|
@Deprecated
|
||||||
|
public final void registerPubSubChannels(String... channels) {
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Warning: this is Legacy API to maintain backward compatibility with RedisBungee Pre fork 0.5
|
||||||
|
* <p>
|
||||||
|
* Unregister (a) PubSub channel(s).
|
||||||
|
*
|
||||||
|
* @param channels the channels to unregister
|
||||||
|
* @since 0.3
|
||||||
|
* @deprecated No longer required
|
||||||
|
*/
|
||||||
|
@Deprecated
|
||||||
|
public final void unregisterPubSubChannels(String... channels) {
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Warning: this is Legacy API to maintain backward compatibility with RedisBungee Pre fork 0.5
|
||||||
|
* <p>
|
||||||
|
* This gets Redis Bungee {@link JedisPool}
|
||||||
|
*
|
||||||
|
* @return {@link JedisPool}
|
||||||
|
* @throws IllegalStateException if the {@link #getMode()} is not equal to {@link RedisBungeeMode#SINGLE}
|
||||||
|
* @throws IllegalStateException if JedisPool compatibility mode is disabled in the config
|
||||||
|
* @since 0.6.5
|
||||||
|
*/
|
||||||
|
public JedisPool getJedisPool() {
|
||||||
|
if (getMode() == RedisBungeeMode.SINGLE) {
|
||||||
|
JedisPool jedisPool = ((JedisPooledSummoner) this.plugin.getSummoner()).getCompatibilityJedisPool();
|
||||||
|
if (jedisPool == null) {
|
||||||
|
throw new IllegalStateException("JedisPool compatibility mode is disabled, Please enable it in the RedisBungee config.yml");
|
||||||
|
}
|
||||||
|
return jedisPool;
|
||||||
|
} else {
|
||||||
|
throw new IllegalStateException("Mode is not " + RedisBungeeMode.SINGLE);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
//
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Api instance
|
* Api instance
|
||||||
*
|
*
|
||||||
|
@ -62,7 +62,7 @@ import java.util.logging.Level;
|
|||||||
public class RedisBungee extends Plugin implements RedisBungeePlugin<ProxiedPlayer>, ConfigLoader, LangConfigLoader {
|
public class RedisBungee extends Plugin implements RedisBungeePlugin<ProxiedPlayer>, ConfigLoader, LangConfigLoader {
|
||||||
|
|
||||||
private static RedisBungeeAPI apiStatic;
|
private static RedisBungeeAPI apiStatic;
|
||||||
private AbstractRedisBungeeAPI api;
|
private RedisBungeeAPI api;
|
||||||
private RedisBungeeMode redisBungeeMode;
|
private RedisBungeeMode redisBungeeMode;
|
||||||
private ProxyDataManager proxyDataManager;
|
private ProxyDataManager proxyDataManager;
|
||||||
private BungeePlayerDataManager playerDataManager;
|
private BungeePlayerDataManager playerDataManager;
|
||||||
|
Loading…
Reference in New Issue
Block a user