SantaSpeen/KuiToi-Server
1
0
Fork 0
mirror of https://github.com/kuitoi/kuitoi-Server.git synced 2025-08-17 16:25:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove try block

Browse Source
This commit is contained in:
Maxim Khomutov 2023-07-12 20:25:10 +03:00
parent aab20c17a1
commit b654d62b30
1 changed files with 12 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/core/tcp_server.py
View File

@ -32,7 +32,7 @@ class TCPServer:
await client.kick("Outdated Version.") await client.kick("Outdated Version.")
return False, None return False, None
else: else:
await client.tcp_send(b"A") # Accepted client version await client.tcp_send(b"S") # Accepted client version
data = await client.recv() data = await client.recv()
self.log.debug(f"recv2 data: {data}") self.log.debug(f"recv2 data: {data}")
@ -58,7 +58,7 @@ class TCPServer:
await client.kick('Invalid authentication data! Try to connect in 5 minutes.') await client.kick('Invalid authentication data! Try to connect in 5 minutes.')
# TODO: Password party # TODO: Password party
# await client.tcp_send(b"S") # Ask client key # await client.tcp_send(b"S") # Ask client key (How?)
ev.call_event("on_auth", client) ev.call_event("on_auth", client)
@ -113,18 +113,17 @@ class TCPServer:
async def start(self): async def start(self):
self.log.debug("Starting TCP server.") self.log.debug("Starting TCP server.")
server = await asyncio.start_server(self.handle_client, self.host, self.port,
backlog=config.Game["players"] + 1)
try: try:
self.log.debug(f"TCP server started on {server.sockets[0].getsockname()!r}") server = await asyncio.start_server(self.handle_client, self.host, self.port,
while True: backlog=config.Game["players"] + 1)
async with server: except OSError as e:
await server.serve_forever()
except Exception as e:
self.log.error(f"Error: {e}") self.log.error(f"Error: {e}")
traceback.print_exc() self.Core.run = False
finally: raise e
await self.stop() self.log.debug(f"TCP server started on {server.sockets[0].getsockname()!r}")
while True:
async with server:
await server.serve_forever()
async def stop(self): def stop(self):
self.log.debug("Stopping TCP server") self.log.debug("Stopping TCP server")