package com.earth2me.essentials.commands; import com.earth2me.essentials.CommandSource; import static com.earth2me.essentials.I18n._; import com.earth2me.essentials.User; import com.earth2me.essentials.utils.FormatUtil; import com.earth2me.essentials.utils.StringUtil; import java.util.List; import org.bukkit.Server; public class Commandmail extends EssentialsCommand { private static int mailsPerMinute = 0; private static long timestamp = 0; public Commandmail() { super("mail"); } //TODO: Tidy this up / TL these errors. @Override public void run(final Server server, final User user, final String commandLabel, final String[] args) throws Exception { if (args.length >= 1 && "read".equalsIgnoreCase(args[0])) { final List mail = user.getMails(); if (mail.isEmpty()) { user.sendMessage(_("noMail")); throw new NoChargeException(); } for (String messages : mail) { user.sendMessage(messages); } user.sendMessage(_("mailClear")); return; } if (args.length >= 3 && "send".equalsIgnoreCase(args[0])) { if (!user.isAuthorized("essentials.mail.send")) { throw new Exception(_("noPerm", "essentials.mail.send")); } if (user.isMuted()) { throw new Exception(_("voiceSilenced")); } User u = ess.getUser(args[1]); if (u == null) { throw new Exception(_("playerNeverOnServer", args[1])); } if (!u.isIgnoredPlayer(user)) { final String mail = user.getName() + ": " + StringUtil.sanitizeString(FormatUtil.stripFormat(getFinalArg(args, 2))); if (mail.length() > 1000) { throw new Exception("Mail message too long. Try to keep it below 1000"); } if (Math.abs(System.currentTimeMillis() - timestamp) > 60000) { timestamp = System.currentTimeMillis(); mailsPerMinute = 0; } mailsPerMinute++; if (mailsPerMinute > ess.getSettings().getMailsPerMinute()) { throw new Exception("Too many mails have been send within the last minute. Maximum: " + ess.getSettings().getMailsPerMinute()); } u.addMail(mail); } user.sendMessage(_("mailSent")); return; } if (args.length > 1 && "sendall".equalsIgnoreCase(args[0])) { if (!user.isAuthorized("essentials.mail.sendall")) { throw new Exception(_("noPerm", "essentials.mail.sendall")); } ess.runTaskAsynchronously(new SendAll(user.getName() + ": " + FormatUtil.stripFormat(getFinalArg(args, 1)))); user.sendMessage(_("mailSent")); return; } if (args.length >= 1 && "clear".equalsIgnoreCase(args[0])) { user.setMails(null); user.sendMessage(_("mailCleared")); return; } throw new NotEnoughArgumentsException(); } @Override protected void run(Server server, CommandSource sender, String commandLabel, String[] args) throws Exception { if (args.length >= 1 && "read".equalsIgnoreCase(args[0])) { throw new Exception(_("onlyPlayers", commandLabel + " read")); } else if (args.length >= 1 && "clear".equalsIgnoreCase(args[0])) { throw new Exception(_("onlyPlayers", commandLabel + " clear")); } else if (args.length >= 3 && "send".equalsIgnoreCase(args[0])) { User u = ess.getUser(args[1]); if (u == null) { throw new Exception(_("playerNeverOnServer", args[1])); } u.addMail("Server: " + getFinalArg(args, 2)); sender.sendMessage(_("mailSent")); return; } else if (args.length >= 2 && "sendall".equalsIgnoreCase(args[0])) { ess.runTaskAsynchronously(new SendAll("Server: " + getFinalArg(args, 1))); sender.sendMessage(_("mailSent")); return; } else if (args.length >= 2) { //allow sending from console without "send" argument, since it's the only thing the console can do User u = ess.getUser(args[0]); if (u == null) { throw new Exception(_("playerNeverOnServer", args[0])); } u.addMail("Server: " + getFinalArg(args, 1)); sender.sendMessage(_("mailSent")); return; } throw new NotEnoughArgumentsException(); } private class SendAll implements Runnable { String message; public SendAll(String message) { this.message = message; } @Override public void run() { for (String username : ess.getUserMap().getAllUniqueUsers()) { User user = ess.getUserMap().getUser(username); if (user != null) { user.addMail(message); } } } } }