Made iptracker async
This commit is contained in:
13
iptracker.py
13
iptracker.py
@@ -7,11 +7,17 @@ from org.bukkit import *
|
|||||||
from traceback import format_exc as trace
|
from traceback import format_exc as trace
|
||||||
from iptracker_secrets import *
|
from iptracker_secrets import *
|
||||||
|
|
||||||
|
|
||||||
iptrack_permission = "utils.iptrack"
|
iptrack_permission = "utils.iptrack"
|
||||||
|
|
||||||
|
|
||||||
@hook.event("player.PlayerJoinEvent", "low")
|
@hook.event("player.PlayerJoinEvent", "low")
|
||||||
def on_player_join(event):
|
def on_player_join(event):
|
||||||
|
t = threading.Thread(target=on_player_join_thread, args=(event))
|
||||||
|
t.daemon = True
|
||||||
|
t.start()
|
||||||
|
|
||||||
|
def on_player_join_thread(event):
|
||||||
player = event.getPlayer()
|
player = event.getPlayer()
|
||||||
ip = player.getAddress().getHostString()
|
ip = player.getAddress().getHostString()
|
||||||
uuid = uid(player)
|
uuid = uid(player)
|
||||||
@@ -50,9 +56,14 @@ def on_player_join(event):
|
|||||||
|
|
||||||
@hook.command("getinfo")
|
@hook.command("getinfo")
|
||||||
def on_getinfo_command(sender, args):
|
def on_getinfo_command(sender, args):
|
||||||
|
t = threading.Thread(target=on_player_join_thread, args=(sender, args))
|
||||||
|
t.daemon = True
|
||||||
|
t.start()
|
||||||
|
|
||||||
|
def on_getinfo_command_thread(sender, args):
|
||||||
if(sender.hasPermission(iptrack_permission)):
|
if(sender.hasPermission(iptrack_permission)):
|
||||||
if not checkargs(sender, args, 1, 1):
|
if not checkargs(sender, args, 1, 1):
|
||||||
return false
|
return False
|
||||||
else:
|
else:
|
||||||
if isIP(args[0]):
|
if isIP(args[0]):
|
||||||
conn = zxJDBC.connect(mysql_database, mysql_user, mysql_pass, "com.mysql.jdbc.Driver")
|
conn = zxJDBC.connect(mysql_database, mysql_user, mysql_pass, "com.mysql.jdbc.Driver")
|
||||||
|
|||||||
Reference in New Issue
Block a user