Enabled friends module, added friends check in imbusy, fixed small mistakes

chatalias.py

@@ -55,6 +55,12 @@ permission_FINFO = "utils.alias.finfo"
 # CODE #
 ########
 
+# OnEnable
+enabled = helpers_version in helpers_versions
+if not enabled:
+    error = colorify("&6Incompatible versions detected (&chelpers.py&6)")
+
+
 def safe_open_json(uuid):
     if not os.path.exists("plugins/redstoner-utils.py.dir/files/aliases"):
         os.makedirs("plugins/redstoner-utils.py.dir/files/aliases")
@@ -174,7 +180,7 @@ def add(sender, args):
         return True
     args = [args[0]] + [" ".join(args[1:])]
     if not add_alias_data(uid(sender), str(args[0]), args[1]):
-        msg(sender, colorify("&c") + "Could not add this alias because it would cause some sequences to be replaced multiple times", usecolor = False)
+        msg(sender, colorify("&c") + "Could not add an alias for this sequence because a priorly added alias contains it")
         return True
     msg(sender, colorify("&7Alias: ") + args[0] + colorify("&7 -> " + args[1] + colorify("&7 was succesfully created!")), usecolor=sender.hasPermission("essentials.chat.color"))
     return True
@@ -191,8 +197,6 @@ def radd(sender, args):
     if args[3].lower() == "false":
         plugin_header(target, "Alias")
         msg(target, "&cPlayer " + sender_name + " &cis creating an alias for you!")
-    elif args[3].lower() != "true":
-        args[2] += " " + args[3]
     if not sender.hasPermission(permission_ALL) and len(data[uid(sender)]) >= int(get_permission_content(target, permission_AMOUNT)):
         msg(sender, "&cCould not create alias: Max_limit reached!")
         if args[3].lower() == "false":
@@ -201,7 +205,7 @@ def radd(sender, args):
     if len(args) == 3:
         args += ["true"]
     if not add_alias_data(uid(target), str(args[1]), str(args[2])):
-        message = colorify("&c") + "Could not add this alias because it would cause some sequences to be replaced multiple times"
+        message = colorify("&c") + "Could not add an alias for this sequence because a priorly added alias contains it"
         msg(sender, message)
         if args[3].lower() == "false":
             msg(target, message)
@@ -214,18 +218,10 @@ def radd(sender, args):
 
 def add_alias_data(puuid, aliased, new_alias):
     prior = data[puuid]
-
-    # prevent 2 -> 3 if there is 1 -> 2
     if aliased not in prior:
         for alias in prior.values():
             if aliased in alias:
                 return False
-
-    # prevent 1 -> 2 if there is 2 -> 3
-    for sequence in prior:
-        if sequence in new_alias:
-            return False
-
     prior[aliased] = new_alias
     save_data(puuid)
     return True
@@ -276,7 +272,7 @@ def rlist_alias(sender, args):
     plugin_header(sender, "Alias")
     target = get_player(args[0])
     if is_player(sender):
-        sender_name = colorify(sender.getDisplayName())
+        sender_name = colorify(sender.getDisplayName)
     else:
         sender_name = colorify("&6Console")
     if len(args) == 1:
@@ -284,9 +280,11 @@ def rlist_alias(sender, args):
     msg(sender, "Player " + args[0] + " has following aliases (" + str(len(data[uid(target)])) + " in total):")
     if args[1].lower() == "false":
         plugin_header(target, "Alias")
-        msg(target, "&cPlayer " + sender_name + " &cis listing your aliases")
+        msg(target, "&cPlayer " + sender_name + " &cis listing your aliases (" + str(len(data[uid(target)])) + " in total):")
     for word, alias in data[str(uid(target))].items():
         msg(sender, colorify("&7") + word + colorify("&7 -> ") + alias, usecolor=target.hasPermission("essentials.chat.color"))
+        if args[1].lower() == "false":
+            msg(target, colorify("&7") + word + colorify("&7 -> ") + alias, usecolor=target.hasPermission("essentials.chat.color"))
     return True
 
 
@@ -341,34 +339,14 @@ def save_data_thread(uuid):
 # Subcommands:
 subcommands = {
     "help": help,
-    "?": help,
     "add": add,
     "remove": remove,
-    "del": remove,
-    "delete": remove,
     "player": remote,
-    "remote": remote,
     "list": list_alias
 }
 
 remotes = {
     "add": radd,
     "remove": rremove,
-    "del": rremove,
-    "delete": rremove,
     "list": rlist_alias,
 }
-
-# OnModuleLoad
-
-enabled = helpers_version in helpers_versions
-if not enabled:
-    error = colorify("&6Incompatible versions detected (&chelpers.py&6)")
-for player in server.getOnlinePlayers():
-    if enabled:
-        t = threading.Thread(target=load_data, args=(uid(player), ))
-        t.daemon = True
-        t.start()
-    else:
-        if player.hasPermission(permission_FINFO):
-            disabled_fallback(player)

friends.py

@@ -5,6 +5,10 @@ friends           = open_json_file("friends", {}) # {Player_UUID:[List_of_friend
 friend_join_sound = "random.orb"
 
 
+def is_friend_of(player, other):
+    lst = friends.get(uid(player))
+    return lst is not None and uid(other) in lst
+
 
 @hook.event("player.PlayerJoinEvent", "high") # creates sound and sends a bold message on friend join
 def fjm(event): # friend join message

imbusy.py

@@ -1,112 +1,178 @@
-# I'M BUSY! Plugin by Curs3d #
+##################################
-##############################
+# I'M BUSY! Plugin by Curs3d     #
-# Concept by CookieManors :D #
+# Concept by CookieManors :D     #
-# http://bit.ly/1GnNPW8      #
+##################################
-##############################
+# This plugin permits users to   #
-# This plugin permits users to
+# send a command that renders    #
-# send a command that renders
+# them "busy", not letting them  #
-# them "busy", not letting them
+# to get tpa requests or direct  #
-# to get tpa requests or direct
+# messages, except from console. #
-# messages, except from console.
+# On restart, all busy data will #
-# On restart, all busy data will
+# be cleared.                    #
-# be cleared.
+##################################
 
 from helpers import *
-from basecommands import simplecommand
+from friends import is_friend_of
 import org.bukkit.command.Command as Command
-from traceback import format_exc as trace
 
-busy_players = []
+imbusy_version = "v1.1.0"
+
+base_permission = "utils.busy" # for /busy status
+use_permission = "utils.busy.use" # for being busy
+override_permission = "utils.busy.override" # for being able to bother busy people
 
 
-def unclear(sender):
+busy_players = {} # name : false/true where false is normal busy and true is super busy
-    msg(sender, "Umm, what? Sorry, directions unclear, got head stuck in washing machine")
 
 
-@hook.command("busy",
+@hook.command("imbusy",
-    aliases = ["focus"],
+    aliases = ["busy"],
-    usage = "/<command> <on|off|status>",
+    usage = "/<command> [on, off, status/check]",
-    description = "Sets busy mode on, you cannot recieve tpas and MSGs"
+    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")
+        msg(sender, "&7Sorry, Console cannot be busy")
-       return True
+        return True
 
     plugin_header(recipient = sender, name = "I'M BUSY!")
 
-    if not sender.hasPermission("utils.busy.allowed"):
+    #args = array_to_list(args)
+    if not sender.hasPermission(base_permission):
         noperm(sender)
         return True
 
     if len(args) == 0:
-        msg(sender, "This plugin allows being busy, and when turned on you will not receive any direct messages or tpa requests.")
+        return toggle(sender)
-        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.")
 
-    elif len(args) == 1:
+    arg0 = args[0].lower()
-        if args[0] == "on":
+    if arg0 == "on":
-            if sender.getName() in busy_players:
+        return on(sender)
-                msg(sender, "You cannot be even more focused than this without being a jedi!")
+    if arg0 == "off":
-            else:
+        return off(sender)
-                busy_players.append(sender.getName())
+    if arg0 in ("status", "check"):
-                broadcast(None, "&c[&2Busy&c] &fNow busy: %s&r, don't even TRY bothering them!" % sender.getDisplayName())
+        return status(sender, args[1:])
+    if arg0 == "super":
+        return super_cmd(sender)
+    return help(sender)
 
-        elif args[0] == "off":
-            try:
-                busy_players.remove(sender.getName())
-                msg(sender, "Master has sent /busy command, %s&r is freeee of bothering!" % sender.getDisplayName())
-            except ValueError:
-                msg(sender, "You are not busy! You cannot be even less busy! Are you perhaps bored?")
-
-        elif args[0] == "status":
-            if sender.getName() in busy_players:
-                msg(sender, "You are super-duper busy and concentrated right now. Think, think, think!")
-            else:
-                msg(sender, "You are completely unable to focus right now.")
-
-        else:
-            unclear(sender)
-            return False
-
-    elif len(args) == 2 and args[0] == "status":
-        target = server.getPlayer(args[1])
-        if target is None:
-            msg(sender, "That player is not online, I doubt they are busy.")
-        elif target.getName() in busy_players:
-            msg(sender, "Yes, %s&r is busy. Shhh..." % target.getDisplayName())
-        else:
-            msg(sender, "No, you're good. Feel free to chat with %s&r!" % target.getDisplayName())
 
+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:
-        unclear(sender)
+        busy_players.append(sender_name)
-        return False
+        broadcast(None, sender.getDisplayName() + " &7is now busy...")
+    return True
+
+
+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
+
+
+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, "&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:
+        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):
-    try:
+    player_name = event.getPlayer().getName()
-        busy_players.remove(event.getPlayer().getName())
+    if player_name in busy_players:
-    except:
+        del busy_players[player_name]
-        pass
 
 
 #---- Dicode for catching any bothering of busy people ----
 
 
 reply_targets = {}
-override_perm = "utils.imbusy.override"
+
+
+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 target is not sender and not sender.hasPermission(override_perm) and target.getName() in busy_players:
+        if not can_send(sender, target):
             msg(sender, "&c[&fBUSY&c] %s&r is busy!" % target.getDisplayName())
             return False
 
@@ -122,7 +188,7 @@ def reply(sender):
     if sender.getName() in reply_targets:
         target = server.getPlayer(reply_targets[sender.getName()])
         if target is not None: 
-            if target is not sender and not sender.hasPermission(override_perm) and target.getName() in busy_players:
+            if not can_send(sender, target):
                 msg(sender, "&c[&fBUSY&c] %s&r is busy!" % target.getDisplayName())
                 return False
 
@@ -145,7 +211,7 @@ class CommandWrapper(Command):
 
     def execute(self, sender, label, args):
         try:
-            if self.checker(sender, args):
+            if not is_player(sender) or self.checker(sender, args):
                 return self.wrapped.execute(sender, label, args)
         except:
             error(trace())
@@ -154,6 +220,7 @@ class CommandWrapper(Command):
     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])
 
@@ -164,7 +231,7 @@ def tpa_command_checker(sender, args):
     if len(args) == 0:
         return True
     target = server.getPlayer(args[0])
-    if target is not None and target is not sender and not sender.hasPermission(override_perm) and target.getName() in busy_players:
+    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
@@ -172,6 +239,16 @@ def tpa_command_checker(sender, args):
 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_player_command_preprocess(event):
@@ -184,40 +261,47 @@ def on_player_command_preprocess(event):
 def replace_ess_commands():
 
     try:
-        mapField = server.getPluginManager().getClass().getDeclaredField("commandMap")
+        map_field = server.getPluginManager().getClass().getDeclaredField("commandMap")
-        mapField.setAccessible(True)
+        map_field.setAccessible(True)
-        commandMap = mapField.get(server.getPluginManager())
+        command_map = map_field.get(server.getPluginManager())
 
-        commandsField = commandMap.getClass().getDeclaredField("knownCommands")
+        commands_field = command_map.getClass().getDeclaredField("knownCommands")
-        commandsField.setAccessible(True)
+        commands_field.setAccessible(True)
-        map = commandsField.get(commandMap)
+        map = commands_field.get(command_map)
 
-        essMsgCmd = map.get("essentials:msg")
+        ess_msg_cmd = map.get("essentials:msg")
-        essReplyCmd = map.get("essentials:reply")
+        ess_reply_cmd = map.get("essentials:reply")
-        essTpaCmd = map.get("essentials:tpa")
+        ess_tpa_cmd = map.get("essentials:tpa")
-        essTpahereCmd = map.get("essentials:tpahere")
+        ess_tpahere_cmd = map.get("essentials:tpahere")
+        ess_mail_cmd = map.get("essentials:mail")
 
-        msgCmdWrapper = CommandWrapper(essMsgCmd, msg_command_checker)
+        msg_cmd_wrapper = CommandWrapper(ess_msg_cmd, msg_command_checker)
-        replyCmdWrapper = CommandWrapper(essReplyCmd, reply_command_checker)
+        reply_cmd_wrapper = CommandWrapper(ess_reply_cmd, reply_command_checker)
-        tpaCmdWrapper = CommandWrapper(essTpaCmd, tpa_command_checker)
+        tpa_cmd_wrapper = CommandWrapper(ess_tpa_cmd, tpa_command_checker)
-        tpahereCmdWrapper = CommandWrapper(essTpahereCmd, tpahere_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()
-            if value is essMsgCmd:
+            changed = True
-                entry.setValue(msgCmdWrapper)
+            if value is ess_msg_cmd:
-                info("[imbusy] wrapped /" + entry.getKey())
+                entry.setValue(msg_cmd_wrapper)
-            elif value is essReplyCmd:
+            elif value is ess_reply_cmd:
-                entry.setValue(replyCmdWrapper)
+                entry.setValue(reply_cmd_wrapper)
-                info("[imbusy] wrapped /" + entry.getKey())
+            elif value is ess_tpa_cmd:
-            elif value is essTpaCmd:
+                entry.setValue(tpa_cmd_wrapper)
-                entry.setValue(tpaCmdWrapper)
+            elif value is ess_tpahere_cmd:
-                info("[imbusy] wrapped /" + entry.getKey())
+                entry.setValue(tpahere_cmd_wrapper)
-            elif value is essTpahereCmd:
+            elif value is ess_mail_cmd:
-                entry.setValue(tpahereCmdWrapper)
+                entry.setValue(mail_cmd_wrapper)
-                info("[imbusy] wrapped /" + entry.getKey())
+            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")

main.py

@@ -44,6 +44,8 @@ shared["load_modules"] = [
     "calc",
     # Adds aliasing of chat words
     "chatalias",
+    # For players to point friends
+    "friends",
     # Plugin to locate laggy chunks. /lc <n> lists chunks with more than n entities
     "lagchunks",
     # Adds /report and /rp, Stores reports with time and location