feat: handle maximum balance

api/src/main/java/dev/xhyrom/lighteco/api/exception/CannotBeGreaterThan.java

@@ -0,0 +1,7 @@
+package dev.xhyrom.lighteco.api.exception;
+
+public class CannotBeGreaterThan extends IllegalArgumentException {
+    public CannotBeGreaterThan(String message) {
+        super(message);
+    }
+}

api/src/main/java/dev/xhyrom/lighteco/api/exception/CannotBeNegative.java

@@ -0,0 +1,7 @@
+package dev.xhyrom.lighteco.api.exception;
+
+public class CannotBeNegative extends IllegalArgumentException {
+    public CannotBeNegative(String message) {
+        super(message);
+    }
+}

bukkit/src/main/java/dev/xhyrom/lighteco/bukkit/commands/GiveCommand.java

@@ -7,6 +7,7 @@ import dev.jorel.commandapi.arguments.OfflinePlayerArgument;
 import dev.jorel.commandapi.executors.CommandArguments;
 import dev.xhyrom.lighteco.bukkit.chat.BukkitCommandSender;
 import dev.xhyrom.lighteco.bukkit.manager.BukkitCommandManager;
+import dev.xhyrom.lighteco.bukkit.util.Util;
 import dev.xhyrom.lighteco.common.model.currency.Currency;
 import lombok.RequiredArgsConstructor;
 import org.bukkit.OfflinePlayer;
@@ -27,8 +28,8 @@ public class GiveCommand implements Command {
                 .withArguments(
                         new OfflinePlayerArgument("target"),
                         currency.getProxy().fractionalDigits() > 0
-                                ? new DoubleArgument("amount", 1)
+                                ? new DoubleArgument("amount", 1, Util.bigDecimalToDouble(this.manager.plugin.getConfig().maximumBalance))
-                                : new IntegerArgument("amount", 1)
+                                : new IntegerArgument("amount", 1, this.manager.plugin.getConfig().maximumBalance.intValue())
                 )
                 .executes((sender, args) -> {
                     this.handleGive(sender, args, currency);

bukkit/src/main/java/dev/xhyrom/lighteco/bukkit/commands/PayCommand.java

@@ -7,6 +7,7 @@ import dev.jorel.commandapi.arguments.OfflinePlayerArgument;
 import dev.jorel.commandapi.executors.CommandArguments;
 import dev.xhyrom.lighteco.bukkit.chat.BukkitCommandSender;
 import dev.xhyrom.lighteco.bukkit.manager.BukkitCommandManager;
+import dev.xhyrom.lighteco.bukkit.util.Util;
 import dev.xhyrom.lighteco.common.model.currency.Currency;
 import lombok.RequiredArgsConstructor;
 import org.bukkit.OfflinePlayer;
@@ -27,8 +28,8 @@ public class PayCommand implements Command {
                 .withArguments(
                         new OfflinePlayerArgument("target"),
                         currency.getProxy().fractionalDigits() > 0
-                                ? new DoubleArgument("amount", 1)
+                                ? new DoubleArgument("amount", 1, Util.bigDecimalToDouble(this.manager.plugin.getConfig().maximumBalance))
-                                : new IntegerArgument("amount", 1)
+                                : new IntegerArgument("amount", 1, this.manager.plugin.getConfig().maximumBalance.intValue())
                 )
                 .executesPlayer((sender, args) -> {
                     this.handlePay(sender, args, currency);

bukkit/src/main/java/dev/xhyrom/lighteco/bukkit/commands/SetCommand.java

@@ -7,6 +7,7 @@ import dev.jorel.commandapi.arguments.OfflinePlayerArgument;
 import dev.jorel.commandapi.executors.CommandArguments;
 import dev.xhyrom.lighteco.bukkit.chat.BukkitCommandSender;
 import dev.xhyrom.lighteco.bukkit.manager.BukkitCommandManager;
+import dev.xhyrom.lighteco.bukkit.util.Util;
 import dev.xhyrom.lighteco.common.model.currency.Currency;
 import lombok.RequiredArgsConstructor;
 import org.bukkit.OfflinePlayer;
@@ -27,8 +28,8 @@ public class SetCommand implements Command {
                 .withArguments(
                         new OfflinePlayerArgument("target"),
                         currency.getProxy().fractionalDigits() > 0
-                                ? new DoubleArgument("amount", 0)
+                                ? new DoubleArgument("amount", 0, Util.bigDecimalToDouble(this.manager.plugin.getConfig().maximumBalance))
-                                : new IntegerArgument("amount", 0)
+                                : new IntegerArgument("amount", 0, this.manager.plugin.getConfig().maximumBalance.intValue())
                 )
                 .executes((sender, args) -> {
                     this.handleSet(sender, args, currency);

bukkit/src/main/java/dev/xhyrom/lighteco/bukkit/commands/TakeCommand.java

@@ -7,6 +7,7 @@ import dev.jorel.commandapi.arguments.OfflinePlayerArgument;
 import dev.jorel.commandapi.executors.CommandArguments;
 import dev.xhyrom.lighteco.bukkit.chat.BukkitCommandSender;
 import dev.xhyrom.lighteco.bukkit.manager.BukkitCommandManager;
+import dev.xhyrom.lighteco.bukkit.util.Util;
 import dev.xhyrom.lighteco.common.model.currency.Currency;
 import lombok.RequiredArgsConstructor;
 import org.bukkit.OfflinePlayer;
@@ -27,8 +28,8 @@ public class TakeCommand implements Command {
                 .withArguments(
                         new OfflinePlayerArgument("target"),
                         currency.getProxy().fractionalDigits() > 0
-                                ? new DoubleArgument("amount", 1)
+                                ? new DoubleArgument("amount", 1, Util.bigDecimalToDouble(this.manager.plugin.getConfig().maximumBalance))
-                                : new IntegerArgument("amount", 1)
+                                : new IntegerArgument("amount", 1, this.manager.plugin.getConfig().maximumBalance.intValue())
                 )
                 .executes((sender, args) -> {
                     this.handleTake(sender, args, currency);

bukkit/src/main/java/dev/xhyrom/lighteco/bukkit/util/Util.java

@@ -0,0 +1,19 @@
+package dev.xhyrom.lighteco.bukkit.util;
+
+import lombok.experimental.UtilityClass;
+
+import java.math.BigDecimal;
+
+@UtilityClass
+public class Util {
+    public double bigDecimalToDouble(final BigDecimal value) {
+        double amount = value.doubleValue();
+
+        // Don't return bigger balance than user actually has
+        if (BigDecimal.valueOf(amount).compareTo(value) > 0) {
+            amount = Math.nextAfter(amount, Double.NEGATIVE_INFINITY);
+        }
+
+        return amount;
+    }
+}

common/src/main/java/dev/xhyrom/lighteco/common/config/Config.java

@@ -7,6 +7,8 @@ import eu.okaeri.configs.OkaeriConfig;
 import eu.okaeri.configs.annotation.Comment;
 import eu.okaeri.configs.annotation.Header;
 
+import java.math.BigDecimal;
+
 @Header("LightEco configuration file.")
 @Header("")
 public class Config extends OkaeriConfig {
@@ -21,6 +23,10 @@ public class Config extends OkaeriConfig {
     @Comment("Save interval to storage in seconds.")
     public long saveInterval = 5L;
 
+    @Comment("Maximum allowed balance.")
+    @Comment("If you want to change this value, you must also change the data type in the database.")
+    public BigDecimal maximumBalance = BigDecimal.valueOf(999999999999999.99);
+
     @Comment("Messages")
     public MessageConfig messages = new MessageConfig();
 

common/src/main/java/dev/xhyrom/lighteco/common/config/message/CurrencyMessageConfig.java

@@ -18,4 +18,5 @@ public class CurrencyMessageConfig extends OkaeriConfig {
     public String wait = "<red>Please wait a moment before using this command again.";
     public String notEnoughMoney = "<red>You don't have enough money!";
     public String cannotPaySelf = "<red>You cannot pay yourself!";
+    public String cannotBeGreaterThan = "<red>Amount cannot be greater than <gold><max>";
 }

common/src/main/java/dev/xhyrom/lighteco/common/manager/command/AbstractCommandManager.java

@@ -1,5 +1,6 @@
 package dev.xhyrom.lighteco.common.manager.command;
 
+import dev.xhyrom.lighteco.api.exception.CannotBeGreaterThan;
 import dev.xhyrom.lighteco.common.config.message.CurrencyMessageConfig;
 import dev.xhyrom.lighteco.common.model.chat.CommandSender;
 import dev.xhyrom.lighteco.common.model.currency.Currency;
@@ -101,7 +102,19 @@ public abstract class AbstractCommandManager implements CommandManager {
         addToMustWait(sender.getUniqueId(), target.getUniqueId());
         amount = amount.setScale(currency.getProxy().fractionalDigits(), RoundingMode.DOWN);
 
-        target.setBalance(currency, amount);
+        try {
+            target.setBalance(currency, amount);
+        } catch (CannotBeGreaterThan e) {
+            removeFromMustWait(target.getUniqueId(), sender.getUniqueId());
+            sender.sendMessage(
+                    miniMessage.deserialize(
+                            this.getConfig(currency).cannotBeGreaterThan,
+                            Placeholder.parsed("max", this.plugin.getConfig().maximumBalance.toPlainString())
+                    )
+            );
+
+            return;
+        }
 
         sender.sendMessage(
                 miniMessage.deserialize(
@@ -120,7 +133,19 @@ public abstract class AbstractCommandManager implements CommandManager {
         addToMustWait(sender.getUniqueId(), target.getUniqueId());
         amount = amount.setScale(currency.getProxy().fractionalDigits(), RoundingMode.DOWN);
 
-        target.deposit(currency, amount);
+        try {
+            target.deposit(currency, amount);
+        } catch (CannotBeGreaterThan e) {
+            removeFromMustWait(target.getUniqueId(), sender.getUniqueId());
+            sender.sendMessage(
+                    miniMessage.deserialize(
+                            this.getConfig(currency).cannotBeGreaterThan,
+                            Placeholder.parsed("max", this.plugin.getConfig().maximumBalance.toPlainString())
+                    )
+            );
+
+            return;
+        }
 
         sender.sendMessage(
                 miniMessage.deserialize(
@@ -140,7 +165,19 @@ public abstract class AbstractCommandManager implements CommandManager {
         addToMustWait(sender.getUniqueId(), target.getUniqueId());
         amount = amount.setScale(currency.getProxy().fractionalDigits(), RoundingMode.DOWN);
 
-        target.withdraw(currency, amount);
+        try {
+            target.withdraw(currency, amount);
+        } catch (CannotBeGreaterThan e) {
+            removeFromMustWait(target.getUniqueId(), sender.getUniqueId());
+            sender.sendMessage(
+                    miniMessage.deserialize(
+                            this.getConfig(currency).cannotBeGreaterThan,
+                            Placeholder.parsed("max", this.plugin.getConfig().maximumBalance.toPlainString())
+                    )
+            );
+
+            return;
+        }
 
         sender.sendMessage(
                 miniMessage.deserialize(
@@ -186,8 +223,20 @@ public abstract class AbstractCommandManager implements CommandManager {
         // subtract tax from amount
         BigDecimal taxedAmount = amount.subtract(tax);
 
-        target.deposit(currency, taxedAmount);
+        try {
-        user.withdraw(currency, amount);
+            target.deposit(currency, taxedAmount);
+            user.withdraw(currency, amount);
+        } catch (CannotBeGreaterThan e) {
+            removeFromMustWait(target.getUniqueId(), sender.getUniqueId());
+            sender.sendMessage(
+                    miniMessage.deserialize(
+                            this.getConfig(currency).cannotBeGreaterThan,
+                            Placeholder.parsed("max", this.plugin.getConfig().maximumBalance.toPlainString())
+                    )
+            );
+
+            return;
+        }
 
         String template = tax.compareTo(BigDecimal.ZERO) > 0
                 ? this.getConfig(currency).payWithTax

common/src/main/java/dev/xhyrom/lighteco/common/model/user/User.java

@@ -1,5 +1,7 @@
 package dev.xhyrom.lighteco.common.model.user;
 
+import dev.xhyrom.lighteco.api.exception.CannotBeGreaterThan;
+import dev.xhyrom.lighteco.api.exception.CannotBeNegative;
 import dev.xhyrom.lighteco.common.api.impl.ApiUser;
 import dev.xhyrom.lighteco.common.cache.RedisBackedMap;
 import dev.xhyrom.lighteco.common.model.currency.Currency;
@@ -46,13 +48,17 @@ public class User {
         return balances.getOrDefault(currency, currency.getDefaultBalance());
     }
 
-    public void setBalance(@NonNull Currency currency, @NonNull BigDecimal balance) {
+    public void setBalance(@NonNull Currency currency, @NonNull BigDecimal balance) throws CannotBeNegative, CannotBeGreaterThan {
         this.setBalance(currency, balance, false);
     }
 
-    public void setBalance(@NonNull Currency currency, @NonNull BigDecimal balance, boolean force) {
+    public void setBalance(@NonNull Currency currency, @NonNull BigDecimal balance, boolean force) throws CannotBeNegative, CannotBeGreaterThan {
         if (balance.compareTo(BigDecimal.ZERO) < 0) {
-            throw new IllegalArgumentException("Balance cannot be negative");
+            throw new CannotBeNegative("Balance cannot be negative");
+        }
+
+        if (balance.compareTo(this.plugin.getConfig().maximumBalance) > 0) {
+            throw new CannotBeGreaterThan("Balance cannot be greater than " + this.plugin.getConfig().maximumBalance);
         }
 
         balance = balance.setScale(currency.fractionalDigits(), RoundingMode.DOWN);
@@ -62,19 +68,27 @@ public class User {
             this.setDirty(true);
     }
 
-    public void deposit(@NonNull Currency currency, @NonNull BigDecimal amount) throws IllegalArgumentException {
+    public void deposit(@NonNull Currency currency, @NonNull BigDecimal amount) throws CannotBeNegative, CannotBeGreaterThan {
         if (amount.compareTo(BigDecimal.ZERO) < 0) {
             throw new IllegalArgumentException("Amount cannot be negative");
         }
 
+        if (amount.compareTo(this.plugin.getConfig().maximumBalance) > 0) {
+            throw new CannotBeGreaterThan("Amount cannot be greater than " + this.plugin.getConfig().maximumBalance);
+        }
+
         this.setBalance(currency, this.getBalance(currency).add(amount));
     }
 
-    public void withdraw(@NonNull Currency currency, @NonNull BigDecimal amount) throws IllegalArgumentException {
+    public void withdraw(@NonNull Currency currency, @NonNull BigDecimal amount) throws CannotBeNegative, CannotBeGreaterThan {
         if (amount.compareTo(BigDecimal.ZERO) < 0) {
             throw new IllegalArgumentException("Amount cannot be negative");
         }
 
+        if (amount.compareTo(this.plugin.getConfig().maximumBalance) > 0) {
+            throw new CannotBeGreaterThan("Amount cannot be greater than " + this.plugin.getConfig().maximumBalance);
+        }
+
         if (this.getBalance(currency).compareTo(amount) < 0) {
             // Withdraw all
             amount = this.getBalance(currency);

common/src/main/java/dev/xhyrom/lighteco/common/storage/provider/sql/SqlStorageProvider.java

@@ -31,7 +31,7 @@ public class SqlStorageProvider implements StorageProvider {
     private static final String CREATE_TABLE = """
     CREATE TABLE IF NOT EXISTS '{prefix}_{table}' (
         'uuid'                  VARCHAR(36)     NOT NULL,
-        'balance'               DECIMAL(10, 2)  NOT NULL,
+        'balance'               DECIMAL(20, 2)  NOT NULL,
         PRIMARY KEY (`uuid`)
     );
     """.trim();

currency-money/src/main/java/dev/xhyrom/lighteco/currency/money/bukkit/hooks/vault/Vault.java

@@ -2,6 +2,8 @@ package dev.xhyrom.lighteco.currency.money.bukkit.hooks.vault;
 
 import dev.xhyrom.lighteco.api.LightEco;
 import dev.xhyrom.lighteco.api.LightEcoProvider;
+import dev.xhyrom.lighteco.api.exception.CannotBeGreaterThan;
+import dev.xhyrom.lighteco.api.exception.CannotBeNegative;
 import dev.xhyrom.lighteco.api.model.currency.Currency;
 import dev.xhyrom.lighteco.api.model.user.User;
 import dev.xhyrom.lighteco.currency.money.common.Plugin;
@@ -114,12 +116,12 @@ public class Vault extends AbstractEconomy {
 
         try {
             user.withdraw(currency, BigDecimal.valueOf(amount));
-        } catch (IllegalArgumentException e) {
+        } catch (CannotBeGreaterThan | CannotBeNegative e) {
             return new EconomyResponse(
                     amount,
                     bigDecimalToDouble(user.getBalance(currency)),
                     EconomyResponse.ResponseType.FAILURE,
-                    "Cannot withdraw negative funds"
+                    e.getMessage()
             );
         }
 
@@ -143,12 +145,12 @@ public class Vault extends AbstractEconomy {
 
         try {
             user.deposit(currency, BigDecimal.valueOf(amount));
-        } catch (IllegalArgumentException e) {
+        } catch (CannotBeGreaterThan | CannotBeNegative e) {
             return new EconomyResponse(
                     amount,
                     bigDecimalToDouble(user.getBalance(currency)),
                     EconomyResponse.ResponseType.FAILURE,
-                    "Cannot deposit negative funds"
+                    e.getMessage()
             );
         }