janis/docker_minecraft_server_auto_starter
1
0
Fork 0
mirror of https://github.com/DerTyp7/docker_minecraft_server_auto_starter.git synced 2025-10-30 04:57:09 +01:00
Code Issues Packages Projects Releases Wiki Activity

Update Docker and NGINX configurations

Browse Source
This commit is contained in:
Janis
2023-12-08 00:26:23 +01:00
parent 4126feef38
commit 92054a114d
7 changed files with 94 additions and 62 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
app/requestHandler.py
View File

@@ -1,5 +1,6 @@
import os
import socket
import logging
import threading
from utils import docker_container_mapping
@@ -12,81 +13,86 @@ class RequestHandler(threading.Thread):
self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
server_address = ('localhost', self.port)
print(f'Starting up on {server_address[0]} port {server_address[1]}')
logging.info(
f'Starting up on {server_address[0]} port {server_address[1]}')
self.sock.bind(server_address)
self.sock.listen(1)
def restart(self):
print(f'Restarting request handler for port {self.port}')
logging.info(f'Restarting request handler for port {self.port}')
self.sock.close()
self.__init__(self.port, self.docker_handler)
def run(self):
while True:
try:
print(f'Waiting for a connection on port {self.port}')
logging.info(f'Waiting for a connection on port {self.port}')
self.connection, self.client_address = self.sock.accept()
try:
print('Connection from', self.client_address)
logging.info('Connection from', self.client_address)
self.handle_request()
except Exception as e:
print(
logging.info(
f'Error in request handler for port {self.port}: {e}')
print('Restarting request handler...')
logging.info('Restarting request handler...')
self.restart()
finally:
self.connection.close()
self.restart()
except Exception as e:
print(f'Error in request handler for port {self.port}: {e}')
print('Restarting request handler...')
logging.info(
f'Error in request handler for port {self.port}: {e}')
logging.info('Restarting request handler...')
self.restart()
def handle_request(self):
print(f'Handling request on port {self.port}')
logging.info(f'Handling request on port {self.port}')
container_ip = docker_container_mapping().get(str(self.port))
if container_ip:
container = self.docker_handler.get_container_by_ip(
container_ip)
isStarting = self.docker_handler.is_container_starting(container)
request = self.connection.recv(1024)
print(f'Received request: {request}')
logging.info(f'Received request: {request}')
# b'\x1b\x00\xfb\x05\x14mc.tealfire.de\x00FML3\x00c\xa0\x02\x1a\x00\x07DerTyp7\x01\xf2]\x9a\x18*\xeaJ\xed\xbe0g\x9c\x8aT\xa9t'
if request[0] == 0x10 or request[0] == 0x15 or request[0] == 0x1b:
if b'\x02' in request:
print(f'Detected join/login request for {container_ip}')
logging.info(
f'Detected join/login request for {container_ip}')
if isStarting:
print(
logging.info(
f'Container {container_ip} is already starting...')
self.forward_request_to_placeholder(
request, isStarting)
else:
print(f'Starting container {container_ip}')
logging.info(f'Starting container {container_ip}')
container.start()
elif b'\x01' in request:
print(f'Detected ping request for {container_ip}')
logging.info(f'Detected ping request for {container_ip}')
self.forward_request_to_placeholder(request, isStarting)
elif request[0] == 0xFE:
print(f'Detected legacy ping request for {container_ip}')
logging.info(
f'Detected legacy ping request for {container_ip}')
self.forward_request_to_placeholder(request, isStarting)
else:
print(f'Detected unknown request for {container_ip}')
logging.info(f'Detected unknown request for {container_ip}')
self.forward_request_to_placeholder(request, isStarting)
else:
print(f'No container mapped to port {self.port}')
logging.info(f'No container mapped to port {self.port}')
def forward_request_to_placeholder(self, request, isStarting=False):
print('Forwarding request to placeholder server')
logging.info('Forwarding request to placeholder server')
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as server_socket:
ip = os.environ.get('PLACEHOLDER_SERVER_SLEEPING_IP')
if isStarting:
print('Container is starting. Using starting placeholder IP')
logging.info(
'Container is starting. Using starting placeholder IP')
ip = os.environ.get('PLACEHOLDER_SERVER_STARTING_IP')
if not ip:
print('No placeholder server IP found')
logging.info('No placeholder server IP found')
return
try:
server_socket.connect((ip, 25565))
@@ -94,5 +100,6 @@ class RequestHandler(threading.Thread):
response = server_socket.recv(1024)
self.connection.sendall(response)
except Exception as e:
print(f'Error while handling request on port {self.port}: {e}')
logging.info(
f'Error while handling request on port {self.port}: {e}')
self.restart()