115 lines
2.1 KiB
Python
115 lines
2.1 KiB
Python
from helpers import *
|
|
import socket
|
|
import threading
|
|
import time
|
|
from java.lang import Runnable
|
|
from adminchat import adminchat
|
|
|
|
"""
|
|
Module to allow our servercontrol telnet server forward chat and speak in AC
|
|
|
|
|
|
"""
|
|
host = ""
|
|
port = 1122
|
|
|
|
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR,1)
|
|
|
|
try:
|
|
sock.bind((host,port))
|
|
sock.setblocking(True)
|
|
sock.listen(5)
|
|
except socket.error as e:
|
|
print(str(e))
|
|
|
|
def command_process(text):
|
|
text = list(text)
|
|
args = []
|
|
arg = ""
|
|
|
|
for char in text:
|
|
if char != " " and char != "\n" and char != "\r" and char != "\t":
|
|
arg += char
|
|
elif arg != "":
|
|
args.append(arg)
|
|
arg = ""
|
|
if arg != "":
|
|
args.append(arg)
|
|
return args
|
|
|
|
clients = []
|
|
clients_l = threading.Lock()
|
|
|
|
class client():
|
|
def __init__(self,conn,address,name):
|
|
self.conn = conn
|
|
self.address = address
|
|
self.name = name
|
|
|
|
with clients_l:
|
|
clients.append(self)
|
|
|
|
self.conn.setblocking(False)
|
|
|
|
self.client_thread = threading.Thread(target=self.client_t)
|
|
self.client_thread.daemon = True
|
|
self.client_thread.start()
|
|
|
|
def getName(self):
|
|
return self.name
|
|
|
|
|
|
def close_connection(self):
|
|
try:
|
|
self.conn.close()
|
|
with clients_l:
|
|
clients.remove(self)
|
|
except:
|
|
pass
|
|
|
|
|
|
def client_t(self):
|
|
|
|
while True:
|
|
time.sleep(0.1)
|
|
try:
|
|
data = self.conn.recv(1024)
|
|
except:
|
|
if self not in clients:
|
|
self.close_connection()
|
|
continue
|
|
|
|
if self not in clients: #If the connection was closed, kill the thread
|
|
break
|
|
|
|
adminchat(self,data)
|
|
|
|
|
|
def handle_conn():
|
|
while True:
|
|
try:
|
|
conn, address = sock.accept()
|
|
except:
|
|
time.sleep(0.1)
|
|
continue
|
|
|
|
#Send name
|
|
data = conn.recv(1024)
|
|
data = command_process(data)
|
|
print "servercontrol connected! %s " %data[0]
|
|
client_c = client(conn, address,data[0])
|
|
|
|
|
|
handle_conn_t = threading.Thread(target=handle_conn)
|
|
handle_conn_t.daemon = True
|
|
handle_conn_t.start()
|
|
|
|
|
|
@hook.event("player.AsyncPlayerChatEvent","low")
|
|
def on_chat(event):
|
|
sender = event.getPlayer().getName()
|
|
msg = event.getMessage()
|
|
|
|
for entry in clients:
|
|
entry.conn.sendall(sender + " " + msg) |