Update src/nucleus/domains/network/server.py
Тестирование ядра / Tester (push) Failing after 2s

This commit is contained in:
2026-04-20 12:26:28 +03:00
parent 340213ad11
commit 10f25350bd
+10 -10
View File
@@ -16,32 +16,32 @@ class ServerProtocol:
def __init__(self, broker):
self.__broker = broker
identifier = uuid4().hex
log.info('ServerProtocol.__init__', identifier)
print('ServerProtocol.__init__', identifier)
context = Context()
containers[identifier] = context
self.identifier = identifier
def connection_lost(self, exc):
log.info('ServerProtocol.connection_lost', self.identifier)
print('ServerProtocol.connection_lost', self.identifier)
context = containers[self.identifier]
context.transport.close()
del containers[self.identifier]
def connection_made(self, transport):
log.info('ServerProtocol.connection_made', self.identifier)
print('ServerProtocol.connection_made', self.identifier)
context = containers[self.identifier]
context.transport = transport
peername = transport.get_extra_info('peername')
log.info('Connection from {}'.format(peername))
print('Connection from {}'.format(peername))
def data_received(self, data):
log.info('ServerProtocol.data_received', self.identifier)
print('ServerProtocol.data_received', self.identifier)
context = containers[self.identifier]
log.info('Data received:', data)
print('Data received:', data)
message = data.decode()
log.info('Data decode received:', message)
print('Data decode received:', message)
request = parse(data)
log.info('request', request)
print('request', request)
method = self.__broker(request)
if method:
response = method(request)
@@ -51,9 +51,9 @@ class ServerProtocol:
body = 'HTTP1.1 404 Not found\r\n\r\nok'.encode()
message = body.decode()
log.info('Send:', message)
print('Send:', message)
context = containers[self.identifier]
context.transport.write(body)
log.info('Close the client socket')
print('Close the client socket')
context.transport.close()