2024-06-14 21:33:55 +00:00
|
|
|
import subprocess
|
|
|
|
import shlex
|
|
|
|
|
2024-06-20 16:57:04 +00:00
|
|
|
|
2024-06-14 21:33:55 +00:00
|
|
|
class MinecraftServerManager:
|
2024-07-08 20:05:07 +00:00
|
|
|
allowed_properties: list[str] = ["difficulty", "gamemode", "force-gamemode", "hardcore", "generate-structures",
|
|
|
|
"motd", "pvp", "online-mode", "max-players"]
|
|
|
|
|
2024-06-14 21:33:55 +00:00
|
|
|
def __init__(self):
|
2024-06-25 04:55:49 +00:00
|
|
|
self.servers: dict = {}
|
|
|
|
self.servers_count: int = 0
|
2024-06-14 21:33:55 +00:00
|
|
|
|
2024-06-25 04:55:49 +00:00
|
|
|
def start_server(self, server_directory: str, port: int,
|
2024-06-25 20:46:03 +00:00
|
|
|
java_executable='java', jar_file='server.jar', memory_size='2048M') -> int or None:
|
|
|
|
|
|
|
|
if port in self.servers:
|
|
|
|
return None
|
|
|
|
|
2024-06-14 21:33:55 +00:00
|
|
|
command = f"{java_executable} -Xmx{memory_size} -Xms{memory_size} -jar {jar_file} > /dev/null"
|
|
|
|
process = subprocess.Popen(shlex.split(command), cwd=server_directory, stdin=subprocess.PIPE)
|
|
|
|
|
2024-06-25 04:55:49 +00:00
|
|
|
self.servers_count = len(self.servers) + 1
|
|
|
|
self.servers[port] = {
|
2024-06-14 21:33:55 +00:00
|
|
|
'process': process,
|
|
|
|
'directory': server_directory,
|
2024-06-25 04:55:49 +00:00
|
|
|
'port': port
|
2024-06-14 21:33:55 +00:00
|
|
|
}
|
2024-06-25 04:55:49 +00:00
|
|
|
return port
|
|
|
|
|
2024-06-25 20:46:03 +00:00
|
|
|
def execute_server_command(self, port, command) -> bool:
|
|
|
|
if port not in self.servers:
|
2024-06-25 04:55:49 +00:00
|
|
|
return False
|
2024-06-25 20:46:03 +00:00
|
|
|
process = self.servers[port]['process']
|
2024-06-25 04:55:49 +00:00
|
|
|
process.stdin.write(command.encode('utf-8') + b'\n')
|
|
|
|
process.stdin.flush()
|
|
|
|
return True
|
|
|
|
|
2024-06-25 20:46:03 +00:00
|
|
|
def stop_server(self, port: int) -> bool:
|
|
|
|
if port not in self.servers:
|
2024-06-25 04:55:49 +00:00
|
|
|
return False
|
2024-06-25 20:46:03 +00:00
|
|
|
process = self.servers[port]['process']
|
2024-06-25 04:55:49 +00:00
|
|
|
process.communicate(input=b"stop\n")
|
2024-06-25 20:46:03 +00:00
|
|
|
del self.servers[port]
|
2024-06-25 04:55:49 +00:00
|
|
|
return True
|
|
|
|
|
|
|
|
def stop_server_forcefully(self, server_id) -> bool:
|
|
|
|
if server_id not in self.servers:
|
|
|
|
return False
|
|
|
|
process = self.servers[server_id]['process']
|
|
|
|
process.terminate()
|
|
|
|
del self.servers[server_id]
|
|
|
|
return True
|
2024-06-14 21:33:55 +00:00
|
|
|
|
|
|
|
def get_servers(self):
|
|
|
|
return self.servers.values()
|
2024-06-20 16:57:04 +00:00
|
|
|
|
2024-06-14 21:33:55 +00:00
|
|
|
def get_server_id_by_port(self, port):
|
|
|
|
for server_id, server_info in self.servers.items():
|
|
|
|
if server_info['port'] == port:
|
|
|
|
return server_id
|
|
|
|
return None
|
|
|
|
|
|
|
|
|
|
|
|
if __name__ == "__main__":
|
|
|
|
pass
|