Agent: Address addr type TODO in RelayConnectionHandler
This commit is contained in:
parent
1cd544e227
commit
76fe0be990
|
@ -13,10 +13,13 @@ class RelayConnectionHandler:
|
||||||
self._relay_user_handler = relay_user_handler
|
self._relay_user_handler = relay_user_handler
|
||||||
|
|
||||||
def handle_new_connection(self, sock: socket.socket):
|
def handle_new_connection(self, sock: socket.socket):
|
||||||
|
addr, _ = sock.getpeername()
|
||||||
|
addr = IPv4Address(addr)
|
||||||
|
|
||||||
control_message = sock.recv(socket.MSG_PEEK)
|
control_message = sock.recv(socket.MSG_PEEK)
|
||||||
addr, _ = sock.getpeername() # TODO check the type of the addr object
|
|
||||||
if control_message.startswith(RELAY_CONTROL_MESSAGE):
|
if control_message.startswith(RELAY_CONTROL_MESSAGE):
|
||||||
self._relay_user_handler.disconnect_user(IPv4Address(addr))
|
self._relay_user_handler.disconnect_user(addr)
|
||||||
else:
|
else:
|
||||||
self._relay_user_handler.add_relay_user(IPv4Address(addr))
|
self._relay_user_handler.add_relay_user(addr)
|
||||||
self._pipe_spawner.spawn_pipe(sock)
|
self._pipe_spawner.spawn_pipe(sock)
|
||||||
|
|
Loading…
Reference in New Issue