303 lines
10 KiB
Python
303 lines
10 KiB
Python
"""
|
|
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 friends import is_friend_of
|
|
import org.bukkit.command.Command as Command
|
|
|
|
imbusy_version = "v1.1.0"
|
|
|
|
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
|
|
|
|
|
|
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, "&7Sorry, Console cannot be busy")
|
|
return True
|
|
|
|
plugin_header(recipient = sender, name = "I'M BUSY!")
|
|
|
|
if not sender.hasPermission(base_permission):
|
|
noperm(sender)
|
|
return True
|
|
|
|
if len(args) == 0:
|
|
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[sender_name] = 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):
|
|
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):
|
|
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):
|
|
message = event.getMessage().split(" ")
|
|
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())
|