oopsie
This commit is contained in:
@@ -35,7 +35,9 @@ client_controller = ClientController(app, auth_data, "https://192.168.15.120:800
|
||||
message_controller = MessageController(app, auth_data, "https://192.168.15.120:8000", database_service)
|
||||
|
||||
def handle_login(data):
|
||||
local_broker, api_broker, forwarder = create_forwarder(data, local_broker_address, local_broker_port, api_broker_address, api_broker_port)
|
||||
local_broker, api_broker, forwarder = create_forwarder(data,
|
||||
local_broker_address, local_broker_port,
|
||||
api_broker_address, api_broker_port, database_service)
|
||||
|
||||
client_id = data.get_client_id()
|
||||
api_broker.subscribe(f"/chat/{client_id}/message", message_controller.handle_message_received)
|
||||
|
||||
Reference in New Issue
Block a user