2
0
mirror of https://github.com/proxiodev/RedisBungee.git synced 2025-07-07 05:18:02 +00:00

Compare commits

..

No commits in common. "1decbd6c7b0d17ca70025e907886394af181d50f" and "d0ae5d5342766d4c5f6e1f991f9b20607761dc7b" have entirely different histories.

8 changed files with 34 additions and 33 deletions

View File

@ -35,6 +35,7 @@ blossom {
commit = "$commitStdout".replace("\n", "") // for some reason it adds new line so remove it. commit = "$commitStdout".replace("\n", "") // for some reason it adds new line so remove it.
commitStdout.close() commitStdout.close()
replaceToken("@git_commit@", commit) replaceToken("@git_commit@", commit)
replaceToken("@build_date@", "${Instant.now().epochSecond}")
} }

View File

@ -15,6 +15,7 @@ public class Constants {
public final static String VERSION = "@version@"; public final static String VERSION = "@version@";
public final static String GIT_COMMIT = "@git_commit@"; public final static String GIT_COMMIT = "@git_commit@";
public final static long BUILD_DATE = Long.parseLong("@build_date@");
public static String getGithubCommitLink() { public static String getGithubCommitLink() {
return "https://github.com/ProxioDev/RedisBungee/commit/" + GIT_COMMIT; return "https://github.com/ProxioDev/RedisBungee/commit/" + GIT_COMMIT;

View File

@ -12,6 +12,7 @@ package com.imaginarycode.minecraft.redisbungee.api.config.loaders;
import org.jetbrains.annotations.Nullable; import org.jetbrains.annotations.Nullable;
;
import java.io.IOException; import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import java.nio.file.Files; import java.nio.file.Files;

View File

@ -56,7 +56,7 @@ network-id: "main"
# You can set Environment variable 'REDISBUNGEE_PROXY_ID' to override # You can set Environment variable 'REDISBUNGEE_PROXY_ID' to override
proxy-id: "proxy-1" proxy-id: "proxy-1"
# since RedisBungee Internally now uses UnifiedJedis instead of Jedis, JedisPool. # since RedisBungee Internally now uses JedisPooled instead of Jedis, JedisPool.
# which will break compatibility with old plugins that uses RedisBungee JedisPool # which will break compatibility with old plugins that uses RedisBungee JedisPool
# so to mitigate this issue, RedisBungee will create an JedisPool for compatibility reasons. # so to mitigate this issue, RedisBungee will create an JedisPool for compatibility reasons.
# disabled by default # disabled by default

View File

@ -197,6 +197,7 @@ public class RedisBungee extends Plugin implements RedisBungeePlugin<ProxiedPlay
public void initialize() { public void initialize() {
logInfo("Initializing RedisBungee....."); logInfo("Initializing RedisBungee.....");
logInfo("Version: {}", Constants.VERSION); logInfo("Version: {}", Constants.VERSION);
logInfo("Build date: {}", Date.from(Instant.ofEpochSecond(Constants.BUILD_DATE)));
ThreadFactory factory = ((ThreadPoolExecutor) getExecutorService()).getThreadFactory(); ThreadFactory factory = ((ThreadPoolExecutor) getExecutorService()).getThreadFactory();
ScheduledExecutorService service = Executors.newScheduledThreadPool(24, factory); ScheduledExecutorService service = Executors.newScheduledThreadPool(24, factory);
try { try {

View File

@ -11,7 +11,6 @@
package com.imaginarycode.minecraft.redisbungee.commands; package com.imaginarycode.minecraft.redisbungee.commands;
import co.aikar.commands.CommandIssuer; import co.aikar.commands.CommandIssuer;
import co.aikar.commands.RegisteredCommand;
import co.aikar.commands.annotation.*; import co.aikar.commands.annotation.*;
import com.google.common.primitives.Ints; import com.google.common.primitives.Ints;
import com.imaginarycode.minecraft.redisbungee.Constants; import com.imaginarycode.minecraft.redisbungee.Constants;
@ -27,12 +26,12 @@ import net.kyori.adventure.text.minimessage.MiniMessage;
import net.kyori.adventure.text.minimessage.tag.resolver.Placeholder; import net.kyori.adventure.text.minimessage.tag.resolver.Placeholder;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@CommandAlias("rb|redisbungee") @CommandAlias("rb|redisbungee")
@CommandPermission("redisbungee.command.use") @CommandPermission("redisbungee.command.use")
@Description("Main command")
public class CommandRedisBungee extends AdventureBaseCommand { public class CommandRedisBungee extends AdventureBaseCommand {
private final RedisBungeePlugin<?> plugin; private final RedisBungeePlugin<?> plugin;
@ -43,12 +42,12 @@ public class CommandRedisBungee extends AdventureBaseCommand {
@Default @Default
@Subcommand("info|version|git") @Subcommand("info|version|git")
@Description("information about current redisbungee build")
public void info(CommandIssuer issuer) { public void info(CommandIssuer issuer) {
final String message = """ final String message = """
<color:aqua>This proxy is running RedisBungee Limework's fork <color:aqua>This proxy is running RedisBungee Limework's fork
<color:gold>======================================== <color:gold>========================================
<color:aqua>RedisBungee version: <color:green><version> <color:aqua>RedisBungee version: <color:green><version>
<color:aqua>Build date: <color:green><build-date>
<color:aqua>Commit: <color:green><commit> <color:aqua>Commit: <color:green><commit>
<color:gold>======================================== <color:gold>========================================
<color:gold>run /rb help for more commands"""; <color:gold>run /rb help for more commands""";
@ -58,6 +57,7 @@ public class CommandRedisBungee extends AdventureBaseCommand {
.deserialize( .deserialize(
message, message,
Placeholder.component("version", Component.text(Constants.VERSION)), Placeholder.component("version", Component.text(Constants.VERSION)),
Placeholder.component("build-date", Component.text( new Date(Constants.BUILD_DATE * 1000).toString() )),
Placeholder.component( Placeholder.component(
"commit", "commit",
Component.text(Constants.GIT_COMMIT.substring(0, 8)) Component.text(Constants.GIT_COMMIT.substring(0, 8))
@ -67,29 +67,19 @@ public class CommandRedisBungee extends AdventureBaseCommand {
} }
// <color:aqua>......: <color:green>...... // <color:aqua>......: <color:green>......
@HelpCommand @HelpCommand
@Description("shows the help page")
public void help(CommandIssuer issuer) { public void help(CommandIssuer issuer) {
final String barFormat = "<color:gold>========================================"; final String message = """
final String commandFormat = "<color:aqua>/rb <sub-command>: <color:green><description>"; <color:gold>========================================
<color:aqua>/rb info: <color:green>shows info of this version.
TextComponent.Builder message = Component.text(); <color:aqua>/rb help: <color:green>shows this page.
message.append(MiniMessage.miniMessage().deserialize(barFormat)); <color:aqua>/rb clean: <color:green>cleans up the uuid cache
<color:red><bold>WARNING...</bold> <color:white>command above could cause performance issues
getSubCommands().forEach((subCommand, registeredCommand) -> { <color:aqua>/rb show: <color:green>shows list of proxies with player count
String[] split = registeredCommand.getCommand().split(" "); <color:gold>========================================
if (split.length > 1 && subCommand.equalsIgnoreCase(split[1])) { <color:gold>run /rb help for more commands""";
message.appendNewline().append(MiniMessage.miniMessage().deserialize(commandFormat, Placeholder.component("sub-command", Component.text(subCommand)), sendMessage(issuer, MiniMessage.miniMessage().deserialize(message));
Placeholder.component("description", MiniMessage.miniMessage().deserialize(registeredCommand.getHelpText()))
));
}
});
message.appendNewline().append(MiniMessage.miniMessage().deserialize(barFormat));
sendMessage(issuer, message.build());
} }
@Subcommand("clean") @Subcommand("clean")
@Description("cleans up the uuid cache<color:red> <bold>WARNING...</bold> <color:white>command above could cause performance issues")
@Private @Private
public void cleanUp(CommandIssuer issuer) { public void cleanUp(CommandIssuer issuer) {
if (StopperUUIDCleanupTask.isRunning) { if (StopperUUIDCleanupTask.isRunning) {
@ -109,7 +99,6 @@ public class CommandRedisBungee extends AdventureBaseCommand {
} }
@Subcommand("show") @Subcommand("show")
@Description("Shows proxies in this network")
public void showProxies(CommandIssuer issuer, String[] args) { public void showProxies(CommandIssuer issuer, String[] args) {
final String closer = "<color:gold>========================================"; final String closer = "<color:gold>========================================";
final String pageTop = "<color:yellow>Page: <color:green><current>/<max> <color:yellow>Network ID: <color:green><network> <color:yellow>Proxies online: <color:green><proxies>"; final String pageTop = "<color:yellow>Page: <color:green><current>/<max> <color:yellow>Network ID: <color:green><network> <color:yellow>Proxies online: <color:green><proxies>";
@ -134,6 +123,15 @@ public class CommandRedisBungee extends AdventureBaseCommand {
} else currentPage = 1; } else currentPage = 1;
var data = new ArrayList<>(plugin.proxyDataManager().eachProxyCount().entrySet()); var data = new ArrayList<>(plugin.proxyDataManager().eachProxyCount().entrySet());
data.addAll(data);
data.addAll(data);
data.addAll(data);
data.addAll(data);
data.addAll(data);
data.addAll(data);
data.addAll(data);
data.addAll(data);
// there is no way this runs because there is always an heartbeat. // there is no way this runs because there is always an heartbeat.
// if not could be some shenanigans done by devs :P // if not could be some shenanigans done by devs :P
if (data.isEmpty()) { if (data.isEmpty()) {
@ -141,7 +139,7 @@ public class CommandRedisBungee extends AdventureBaseCommand {
return; return;
} }
// compute the total pages // compute the total pages
int maxPages = (int) Math.ceil(data.size() / (double) pageSize); int maxPages = data.size() < pageSize ? 1 : data.size() / pageSize ;
if (currentPage > maxPages) currentPage = maxPages; if (currentPage > maxPages) currentPage = maxPages;
var subList = subListProxies(data, currentPage, pageSize); var subList = subListProxies(data, currentPage, pageSize);
TextComponent.Builder builder = Component.text(); TextComponent.Builder builder = Component.text();
@ -171,19 +169,17 @@ public class CommandRedisBungee extends AdventureBaseCommand {
} }
if (currentPage > 1) { if (currentPage > 1) {
builder.append(MiniMessage.miniMessage().deserialize(previousPage) builder.append(MiniMessage.miniMessage().deserialize(previousPage)
.color(NamedTextColor.WHITE).clickEvent(ClickEvent.runCommand("/rb show " + (currentPage - 1)))); .clickEvent(ClickEvent.runCommand("/rb show " + (currentPage - 1))));
} else {
builder.append(MiniMessage.miniMessage().deserialize(previousPage).color(NamedTextColor.GRAY));
} }
if (subList.size() == pageSize && !subListProxies(data, currentPage + 1, pageSize).isEmpty()) { if (subList.size() == pageSize && !subListProxies(data, currentPage + 1, pageSize).isEmpty()) {
builder.append(MiniMessage.miniMessage().deserialize(nextPage) builder.append(MiniMessage.miniMessage().deserialize(nextPage)
.color(NamedTextColor.WHITE).clickEvent(ClickEvent.runCommand("/rb show " + (currentPage + 1)))); .clickEvent(ClickEvent.runCommand("/rb show " + (currentPage + 1))));
} else {
builder.append(MiniMessage.miniMessage().deserialize(nextPage).color(NamedTextColor.GRAY));
} }
builder.appendNewline(); builder.appendNewline();
builder.append(MiniMessage.miniMessage().deserialize(closer)); builder.append(MiniMessage.miniMessage().deserialize(closer));
sendMessage(issuer, builder.build()); sendMessage(issuer, builder.build());
} }
} }

View File

@ -102,6 +102,7 @@ public class RedisBungeeVelocityPlugin implements RedisBungeePlugin<Player>, Con
this.logger = logger; this.logger = logger;
this.dataFolder = dataDirectory; this.dataFolder = dataDirectory;
logInfo("Version: {}", Constants.VERSION); logInfo("Version: {}", Constants.VERSION);
logInfo("Build date: {}", Date.from(Instant.ofEpochSecond(Constants.BUILD_DATE)));
try { try {
loadConfig(this, dataDirectory); loadConfig(this, dataDirectory);
loadLangConfig(this, dataDirectory); loadLangConfig(this, dataDirectory);

View File

@ -1,2 +1,2 @@
group=com.imaginarycode.minecraft group=com.imaginarycode.minecraft
version=0.12.0 version=0.12.0-SNAPSHOT