diff options
Diffstat (limited to 'imbusy.py')
| -rw-r--r-- | imbusy.py | 358 |
1 files changed, 277 insertions, 81 deletions
@@ -1,107 +1,303 @@ -# I'M BUSY! Plugin by Curs3d # -############################## -# Concept by CookieManors :D # -# http://bit.ly/1GnNPW8 # -############################## -# This plugin permits users to -# send a command that renders -# them "busy", not letting them -# to get tpa requests or direct -# messages, except from console. -# On restart, all busy data will -# be cleared. +""" +This plugin permits users to +send a command that renders +them "busy", not letting them +to get tpa requests or direct +messages, except from console. +On restart, all busy data will +be cleared. +""" from helpers import * -from basecommands import simplecommand -from traceback import format_exc as trace -busy_players = [] +from friends import is_friend_of +import org.bukkit.command.Command as Command +imbusy_version = "v1.1.0" -def unclear(): - msg(sender, "Umm, what? Sorry, directions unlclear, got head stuck in washing machine") +base_permission = "utils.imbusy" # for /busy status +use_permission = "utils.imbusy.use" # for being busy +override_permission = "utils.imbusy.override" # for being able to bother busy people -@hook.command("busy", - aliases = ["focus"], - usage = "/<command> <on|off|status>", - description = "Sets busy mode on, you cannot recieve tpas and MSGs" +busy_players = {} # name : false/true where false is normal busy and true is super busy + + +@hook.command("imbusy", + aliases = ["busy"], + usage = "/<command> [on, off, status/check]", + description = "Offers control over your busy status" ) def on_busy_command(sender, cmd, label, args): - if not is_player(sender): - msg(sender, "Sorry, Console cannot be busy") - return True + msg(sender, "&7Sorry, Console cannot be busy") + return True + + plugin_header(recipient = sender, name = "I'M BUSY!") - if not sender.hasPermission("utils.busy.allowed"): - plugin_header(recipient = sender, name = "I'M BUSY!") + if not sender.hasPermission(base_permission): noperm(sender) return True if len(args) == 0: - plugin_header(recipient = sender, name = "I'M BUSY!") - msg(sender, "This plugin allows being busy, and when turned on you will not recieve any direct messages or tpa requests.") - msg(sender, "\nCommands:") - msg(sender, "/busy on: turns on busy mode") - msg(sender, "/busy off: turns off busy mode") - msg(sender, "/busy status [player]: shows your or [player]'s current busy status.") + return toggle(sender) + + arg0 = args[0].lower() + if arg0 == "on": + return on(sender) + if arg0 == "off": + return off(sender) + if arg0 in ("status", "check"): + return status(sender, args[1:]) + if arg0 == "super": + return super_cmd(sender) + return help(sender) + + +def toggle(sender): + if not sender.hasPermission(use_permission): + noperm(sender) return True + sender_name = sender.getName() + if sender_name in busy_players: + del busy_players[sender_name] + broadcast(None, sender.getDisplayName() + " &7is no longer busy...") + else: + busy_players.append(sender_name) + broadcast(None, sender.getDisplayName() + " &7is now busy...") + return True - elif len(args) == 1: - if args[0] == "on": - if sender.getName() in busy_players: - plugin_header(recipient = sender, name = "I'M BUSY!") - msg(sender, "You cannot be even more focused than this without being a jedi!") - return True - busy_players.append(sender.getName()) - plugin_header(recipient = sender, name = "I'M BUSY!") - broadcast(None, "%s is now SUPER busy! Don't even TRY bothering them, it will not work!" % sender.getName()) - return True - - elif args[0] == "off": - plugin_header(recipient = sender, name = "I'M BUSY!") - try: - busy_players.remove(sender.getName()) - msg(sender, "Master has sent /busy command, %s is freeee!" % sender.getName()) - return True - except ValueError: - msg(sender, "You are not busy! You cannot be even less busy! Are you perhaps bored?") - return True - - elif args[0] == "status": - plugin_header(recipient = sender, name = "I'M BUSY!") - if sender.getName() in busy_players: - msg(sender, "You are super-duper busy and concentrated right now. Think, think, think!") - return True - else: - msg(sender, "You are completely unable to focus right now.") - return True - else: - plugin_header(recipient = sender, name = "I'M BUSY!") - unclear() - return False +def help(sender): + msg(sender, "Let's you put yourself in busy status, preventing pms and tpa requests from other players") + msg(sender, "\n&eCommands:") + msg(sender, "&e/busy &7- Toggles busy status") + msg(sender, "&e/busy on &7- Turns on busy status") + msg(sender, "&e/busy off &7- Turns off busy status") + msg(sender, "&e/busy status [player] &7- shows your or [player]'s current busy status") + msg(sender, "&e/busy super &7- sets your status to SUPER busy such that even friends can not bother you") + return True + + +def on(sender): + if not sender.hasPermission(use_permission): + noperm(sender) + return True + sender_name = sender.getName() + if busy_players.get(sender_name) is False: # can be None, False or True + msg(sender, "&7You are already busy!") + else: + busy_players[sender_name] = False # busy but not super busy + broadcast(None, sender.getDisplayName() + " &7is now busy...") + return True - elif len(args) == 2 and args[0] == "status": - plugin_header(recipient = sender, name = "I'M BUSY!") - if args[1] in busy_players: - msg(sender, "Yes, %s is busy. Shhh..." % args[1]) - return True + +def off(sender): + if not sender.hasPermission(use_permission): + noperm(sender) + return True + sender_name = sender.getName() + if sender_name not in busy_players: + msg(sender, "&7You are not busy! You cannot be even less busy! Are you perhaps bored?") + return True + del busy_players[sender_name] + broadcast(None, sender.getDisplayName() + " &7is no longer busy...") + return True + + +def status(sender, args): + if not sender.hasPermission(base_permission): + noperm(sender) + return True + if len(args) == 0: + if sender.getName() in busy_players: + if busy_players[sender_name] is False: + msg(sender, "&7You are currently busy.") + else: + msg(sender, "&7You are currently SUPER busy.") else: - msg(sender, "No, you're good. Feel free to chat with %s!" % args[1]) - return True + msg(sender, "&7You are currently not busy.") + else: + target = server.getPlayer(args[0]) + if target is None: + msg(sender, "&7That player is not online") + elif target.getName() in busy_players: + if busy_players[target.getName()] is False: + msg(sender, "&7Player %s &7is currently busy." % target.getDisplayName()) + else: + msg(sender, "&7Player %s &7is currently SUPER busy." % target.getDisplayName()) + else: + msg(sender, "&7Player %s &7is currently not busy." % target.getDisplayName()) + return True + +def super_cmd(sender): + if not sender.hasPermission(use_permission): + noperm(sender) + return True + sender_name = sender.getName() + if busy_players.get(sender_name) is True: + msg(sender, "&7You are already SUPER busy!") else: - plugin_header(recipient = sender, name = "I'M BUSY!") - unclear() + busy_players[sender_name] = True # SUPER busy + broadcast(None, sender.getDisplayName() + " &7is now SUPER busy...") + return True + + +@hook.event("player.PlayerQuitEvent", "lowest") +def on_player_leave(event): + player_name = event.getPlayer().getName() + if player_name in busy_players: + del busy_players[player_name] + + +#---- Dicode for catching any bothering of busy people ---- + + +reply_targets = {} + + +def can_send(sender, target): + if not target.getName() in busy_players: + return True + if target is sender or sender.hasPermission(override_permission): + return True + return busy_players[target.getName()] is False and is_friend_of(target, sender) + + +def whisper(sender, target_name): + target = server.getPlayer(target_name) + + if target is not None: + if not can_send(sender, target): + msg(sender, "&c[&fBUSY&c] %s&r is busy!" % target.getDisplayName()) + return False + + reply_targets[sender.getName()] = target.getName() + + # allow the target to reply regardless of sender being busy + if target.getName() in reply_targets: + del reply_targets[target.getName()] + return True + + +def reply(sender): + if sender.getName() in reply_targets: + target = server.getPlayer(reply_targets[sender.getName()]) + if target is not None: + if not can_send(sender, target): + msg(sender, "&c[&fBUSY&c] %s&r is busy!" % target.getDisplayName()) + return False + + # allow the target to reply regardless of sender being busy + if target.getName() in reply_targets: + del reply_targets[target.getName()] + return True + + +class CommandWrapper(Command): + + def __init__(self, wrapped, checker): + Command.__init__(self, wrapped.getName()) + self.setDescription(wrapped.getDescription()) + self.setPermission(wrapped.getPermission()) + self.setUsage(wrapped.getUsage()) + self.setAliases(wrapped.getAliases()) + self.wrapped = wrapped + self.checker = checker + + def execute(self, sender, label, args): + try: + if not is_player(sender) or self.checker(sender, args): + return self.wrapped.execute(sender, label, args) + except: + error(trace()) + return True + + def tabComplete(self, sender, alias, args): + return self.wrapped.tabComplete(sender, alias, args) + + +def msg_command_checker(sender, args): + return len(args) <= 1 or whisper(sender, args[0]) + +def reply_command_checker(sender, args): + return len(args) == 0 or reply(sender) + +def tpa_command_checker(sender, args): + if len(args) == 0: + return True + target = server.getPlayer(args[0]) + if target is not None and not can_send(sender, target): + msg(sender, "&c[&fBUSY&c] %s&r is busy!" % target.getDisplayName()) + return False + return True + +def tpahere_command_checker(sender, args): + return tpa_command_checker(sender, args) + +def mail_command_checker(sender, args): + info("Mail command executed") + if len(args) < 3 or args[0].lower() != "send": + return True + target = server.getPlayer(args[1]) + if target is not None and not can_send(sender, target): + msg(sender, "&c[&fBUSY&c] %s&r is busy!" % target.getDisplayName()) return False + return True @hook.event("player.PlayerCommandPreprocessEvent", "monitor") -def on_cmd_preprocess_event(event): +def on_player_command_preprocess(event): message = event.getMessage().split(" ") - if message[0] == "/msg" or message[0] == "/w" or message[0] == "/m" or \ - message[0] == "/tell" or message[0] == "/tpa" or message[0] == "/tpahere": - if message[1] in busy_players: - plugin_header(recipient = event.getPlayer(), name = "I'M BUSY!") - msg(event.getPlayer(), "We are sorry, but %s is currently busy. Please try again later." % message[1]) - event.setCancelled(True) + if len(message) > 1 and message[0].lower() in ("/tell", "/minecraft:tell") and not whisper(event.getPlayer(), message[1]): + event.setCancelled(True) + + +def replace_ess_commands(): + + try: + map_field = server.getPluginManager().getClass().getDeclaredField("commandMap") + map_field.setAccessible(True) + command_map = map_field.get(server.getPluginManager()) + + commands_field = command_map.getClass().getDeclaredField("knownCommands") + commands_field.setAccessible(True) + map = commands_field.get(command_map) + + ess_msg_cmd = map.get("essentials:msg") + ess_reply_cmd = map.get("essentials:reply") + ess_tpa_cmd = map.get("essentials:tpa") + ess_tpahere_cmd = map.get("essentials:tpahere") + ess_mail_cmd = map.get("essentials:mail") + + msg_cmd_wrapper = CommandWrapper(ess_msg_cmd, msg_command_checker) + reply_cmd_wrapper = CommandWrapper(ess_reply_cmd, reply_command_checker) + tpa_cmd_wrapper = CommandWrapper(ess_tpa_cmd, tpa_command_checker) + tpahere_cmd_wrapper = CommandWrapper(ess_tpahere_cmd, tpahere_command_checker) + mail_cmd_wrapper = CommandWrapper(ess_mail_cmd, mail_command_checker) + + iterator = map.entrySet().iterator() + wrapped_commands = [] + while iterator.hasNext(): + entry = iterator.next() + value = entry.getValue() + changed = True + if value is ess_msg_cmd: + entry.setValue(msg_cmd_wrapper) + elif value is ess_reply_cmd: + entry.setValue(reply_cmd_wrapper) + elif value is ess_tpa_cmd: + entry.setValue(tpa_cmd_wrapper) + elif value is ess_tpahere_cmd: + entry.setValue(tpahere_cmd_wrapper) + elif value is ess_mail_cmd: + entry.setValue(mail_cmd_wrapper) + else: + changed = False + if changed: + wrapped_commands.append(entry.getKey()) + info("[imbusy] wrapped commands: /" + ", /".join(wrapped_commands)) + + except: + error("[Imbusy] Failed to wrap essentials commands") + error(trace()) |