mirror of
https://github.com/CopterExpress/clever-show.git
synced 2026-05-26 07:07:58 +00:00
server: todos and cleanup
This commit is contained in:
@@ -33,9 +33,6 @@ if not os.path.exists(log_path):
|
|||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
ConfigOption = collections.namedtuple("ConfigOption", ["section", "option", "value"])
|
|
||||||
|
|
||||||
|
|
||||||
class Server(messaging.Singleton):
|
class Server(messaging.Singleton):
|
||||||
def __init__(self, config_path=os.path.join(current_dir, os.pardir, "config", "server.ini"), server_id=None):
|
def __init__(self, config_path=os.path.join(current_dir, os.pardir, "config", "server.ini"), server_id=None):
|
||||||
self.id = server_id if server_id else str(random.randint(0, 9999)).zfill(4)
|
self.id = server_id if server_id else str(random.randint(0, 9999)).zfill(4)
|
||||||
@@ -274,7 +271,7 @@ def requires_any_connected(f):
|
|||||||
|
|
||||||
return wrapper
|
return wrapper
|
||||||
|
|
||||||
|
# TODO do a factory class for clients\connection managers with common properties
|
||||||
class Client(messaging.ConnectionManager):
|
class Client(messaging.ConnectionManager):
|
||||||
clients = {}
|
clients = {}
|
||||||
|
|
||||||
@@ -311,7 +308,7 @@ class Client(messaging.ConnectionManager):
|
|||||||
if self.on_connect:
|
if self.on_connect:
|
||||||
self.on_connect(self)
|
self.on_connect(self)
|
||||||
|
|
||||||
def _got_id(self, _client, value):
|
def _got_id(self, _client, value): # TODO make as regular comand
|
||||||
logging.info("Got copter id: {} for client {}".format(value, self.addr))
|
logging.info("Got copter id: {} for client {}".format(value, self.addr))
|
||||||
old_id = self.copter_id
|
old_id = self.copter_id
|
||||||
self.copter_id = value
|
self.copter_id = value
|
||||||
@@ -319,7 +316,7 @@ class Client(messaging.ConnectionManager):
|
|||||||
if old_id is None:
|
if old_id is None:
|
||||||
self.get_response("clover_dir", self._got_clover_dir)
|
self.get_response("clover_dir", self._got_clover_dir)
|
||||||
|
|
||||||
if old_id is None and self.on_first_connect:
|
if old_id is None and self.on_first_connect: # TODO merge
|
||||||
self.on_first_connect(self)
|
self.on_first_connect(self)
|
||||||
|
|
||||||
def _got_clover_dir(self, _client, value):
|
def _got_clover_dir(self, _client, value):
|
||||||
|
|||||||
@@ -254,7 +254,7 @@ class MainWindow(QtWidgets.QMainWindow):
|
|||||||
return list(self.iterate_selected(lambda copter: copter.client.send_message(
|
return list(self.iterate_selected(lambda copter: copter.client.send_message(
|
||||||
command, command_args, command_kwargs)))
|
command, command_args, command_kwargs)))
|
||||||
|
|
||||||
def new_client_connected(self, client: Client):
|
def new_client_connected(self, client: Client): # TODO merge with client_connection_changed
|
||||||
if self.model.get_row_by_attr('client', client) is not None:
|
if self.model.get_row_by_attr('client', client) is not None:
|
||||||
logging.warning("Client is already in table! {}".format(client))
|
logging.warning("Client is already in table! {}".format(client))
|
||||||
return
|
return
|
||||||
|
|||||||
Reference in New Issue
Block a user